ZooKeeper 分散ロックキュレーターソースコード 05: 分散読み取り書き込みロックとインターロック

[[411638]]

前言

Curator は、分散型のコメントライトロック [1] とリンクライトロック [2] もサポートしていますが、必要に応じて InterProcessReadWriteLock を使用して、それらのソースコードを実装方法とともに確認します。

1.使用方法

パブリッククラス CuratorDemo { 
 
公共 静的void main(String[] args)は例外をスローします{ 
 
文字列 connectString = "127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" ; 
 
再試行ポリシー retryPolicy = 新しい ExponentialBackoffRetry(1000, 3); 
 
 CuratorFramework クライアント = CuratorFrameworkFactory
 .ビルダー()
 .connectString(接続文字列)
 .retryPolicy(再試行ポリシー)
                。建てる（）;
クライアントを起動します。 
 
 InterProcessReadWriteLock ロック = 新しい InterProcessReadWriteLock(client, "/locks/lock_01" );
ロックを取得します。
ロックを解放します。
ロック。writeLock()。取得();
ロックを解除します。 
 
 }
 }

2.ソースコード

ロック書き込みはすべて InterProcessMutex に基づいて実行されるため、ここで生成されるロック名は -lock- ではなく、__WRIT__ と __READ__ に置き換えられます。

读锁加锁节ポイント名: /locks/lock_01/_c_44a8eaf8-f177-403a-92bf-9119591b54d5-__READ__0000000000、写锁解锁节ポイント名: _c_2e5dde98-c548-4f8b-a798-821ee8330eb6-__WRIT__0000000001。

ここで、ポイントの作成時およびアクセス可能な InterProcessMutex には区切りはありませんが、唯一の区切りは、internalLockLoop メソッド内であり、鍵取得結果を判断するときに区切りがあります。

ロックを再入力できるときは、StandardLockInternalsDriver#getsTheLock で現在のノードが最小ノードであるかどうかが判断されます。

一方、書き込みロックは、InterProcessReadWriteLock#InterProcessReadWriteLock 中に getTheLock メソッドを再書き込みします。

読む锁加锁

ロックが追加されると、現在のプログラムは直接成功を返します。つまり、現在のプログラムの書き込みは相互に影響しません。

他のオンラインプロセスの場合は、すべての子ノードが遍在します。

子ノードには書き込みが含まれており、子ノード内の順序セットのインデックスが書き込みのインデックスよりも小さいため、直接取得できます。そうでない場合は、取得できません。

子ノードは書き込みを含まず、現在のノードの子ノードの順序セットのインデックス < Integer.MAX_VALUE (2147483647) であれば十分です。

つまり、2147483647 が最もサポートされています。

書き込み禁止

ライトアップは直接使用できる、InterProcessMutex のアクセス可能なアクセスポイントであり、ここではライトとライト、およびライトとライトは両方とも同一です。