問題タブ [distributed-lock]

FileReadingMessageSourceカスタムでを使用していますFileLocker:

FileLocker jdbcFileLockerでファイルを処理した後、を使用してファイルのロックを解除したいと思いFileWritingMessageHandlerます。

自分でファイルのロックを解除する必要がありますか、それとも FileWritingMessageHandler@ServiceActivatorに何らかの方法で与えることができますか?FileLocker

編集：追加ExpressionEvaluatingRequestHandlerAdvice

だから私はこれAdviceを私のに追加することができますFileWritingMessageHandler：

ロック解除は、@ServiceActivatorをリッスンすることによって処理されunlockChannelます。

キー値の読み取り、作成、更新を頻繁に行うRedisベースのキャッシュがあります。ダーティな読み取りと書き込みを回避するために、これらの操作を実行する複数のマイクロサービスがあるため、Apache Curator を使用して分散ロックを実装したいと考えています。

アイデアは、キーと値のペアの作成があるたびに、キーを使用してシーケンシャルなエフェメラル ノードを作成したいということです。ロックの子に変更があるときはいつでも、それらの変更を監視してキーを比較し、特定のキーですべての書き込みを順番に実行したいと考えています。

私の質問は、イベントを監視し、Apache Curator でキーを比較する方法です。キー レベル ロックに関する例はありますか。あなたの助けに感謝。

DistributedLock nugetから分散ロックを試しています。

私が使用するコードスニペットは次のとおりです。

問題は、最初のロックを取得した後、解放されないかのように、常にタイムアウトになることです。廃棄後はロックが解除されるとのことですが。しかし、それは起こっていません。2 番目のタスクはロックに入ることができません。

私が得る出力は次のとおりです。

その後、タイムアウトが発生します。

TCPソケットを介してデバイスからデータを読み取るマイクロサービスに取り組んでいます。マイクロサービスも異なるサーバーで提供されます。したがって、分散構造が設計されました。RMapCache が redis に作成されているため、さまざまなサービスからデバイスを定期的にクエリできます。このマップは、処理中のデバイスの現在の IP 情報を保持します。同時に複数のリクエストを同じ IP に送信することは望ましくありません。このマップに ip を追加するために作成されるメソッドのコードは次のとおりです。そのメソッド redisson では、コード ブロックをスレッド セーフにするために FairLock が実装されています。

ただし、複数のサービスインスタンスが同時に実行されると、以下の例外がスローされます。