Redisson 分散ロック ソースコード 8: MultiLock のロックとロック解除

[[409055]]

序文

Redis に基づく Redisson 分散インターロック RedissonMultiLock オブジェクトは、複数の RLock オブジェクトをインターロックに関連付けることができ、各 RLock オブジェクト インスタンスは異なる Redisson インスタンスから取得できます。

もちろん公式サイトの紹介です。具体的には何ですか？連動するMultiLockの使い方とソースコードを見てみましょう！

1マルチロックの使用

公式ドキュメントによると、ここでの Redisson クライアントは異なる場合があります。もちろん、一般的な仕事では、クライアントが必要ないとは言いません。

2 ロック

MultiLock ロックについて読む前に、通常のロックに関する関連記事を読んでおく必要があります。

ソースコードエントリ: org.redisson.RedissonMultiLock#lock()

デフォルトのタイムアウトのleaseTimeは設定されていないため、-1になります。

このメソッドは長すぎるので、分割して読んでみましょう。

1. 基本待機時間 baseWaitTime = ロック数 * 1500、ここでは 4500 ミリ秒です。
2. leasingTime == -1なのでwaitTime = baseWaitTimeとなり、4500になります。
3. while (true) は tryLock を呼び出して、成功するまでロックします。

waitTime = 4500、leaseTime = -1、unit = MILLISECONDS のパラメータを指定して tryLock メソッドを呼び出します。

tryLock のロジックを見てみましょう。

leasingTime != -1 が満たされていないため、この部分は直接スキップされます。

waitTime != -1 条件が満たされ、remainTime = 4500、lockWaitTime = 4500 になります。

したがって、failedLocksLimit() メソッドは直接 0 を返します。これは、すべてのロックが正常に取得される必要があることを意味します。

重要なポイントは次のとおりです。

すべてのロックを横断し、1 つずつロックします。

ロックのロジックは再入可能ロックと変わりません。したがって、Lua スクリプトは分析されません。

上記はtryLockがロックされた後の結果です。

ロックが正常に取得された場合、成功したロックは acquireLocks コレクションに格納されます。

ロックに失敗した場合はfailedLocksLimitを判断する必要があります。ここでは 0 なので、正常にロックされたセット acquireLocks 内のすべてのロックが直接解放され、正常にロックされたセットがクリアされてイテレータが復元されます。

各ロックの後に、残りのロック時間 remainTime が更新されます。 remainTime が 0 以下の場合、ロックがタイムアウトしたことを意味し、直接 false が返されます。

これにより、外部の while (true) ロジックが実行され、RedissonMultiLock#tryLock が再度実行されます。

3 ロック解除

ロックのロジックを読んだ後では、ロックの解除が理解しやすくなります。

トラバースしてロックを直接解除するだけです。 lock.unlockAsync() は、呼び出される RedissonBaseLock#unlockAsync() メソッドです。

4 結論

私の理解では、図は次のようになります。

一般的には、key1、key2、key3...keyN を List コレクションに入れて、すべてが成功するまで反復処理してロックします。ロックを解除するときは、ロックを再度通過してロックを解除します。

この記事はWeChatの公開アカウント「Programmer Xiaohang」から転載したもので、以下のQRコードからフォローできます。この記事を転載する場合は、プログラマーXiaohangの公式アカウントまでご連絡ください。