ZooKeeper 分散ロック キュレーター ソース コード 1: 再入可能ロック

序文

一般的な作業でよく使用される分散ロックは、Redis と ZooKeeper に基づいています。上記ではRedissonロックに関連するソースコードを紹介しました。それでは、ZooKeeper に基づくロックを見てみましょう。それが Curator フレームワークです。

Curator ロックには多くの種類があります。この記事では、共有再入可能ロックを分析します。

記事が長すぎると読みにくくなることを考慮したので、記事を適切に分割しています。

1環境設定

このマシンには3つのノードがあります

バージョン: 3.7.0 システム: macOS インストール方法: brew install zookeeper Curator Maven 依存関係バージョン: 5.1.0

 <依存関係>
    <グループ ID>org.apache.curator</グループ ID>
    <artifactId>キュレーターレシピ</artifactId>
    <バージョン>5.1.0</バージョン>
 </依存関係>

2 ロックの例

詳細については公式ドキュメント[1]を参照してください。

ロックする前に

ロックする前は、ZooKeeper にはノード/Zookeeper が 1 つだけあります。

ロック

/locks/lock_01 パスにロックを追加します。

ロック後:

• 永続ノード /locks/lock_01 が作成され、その下に子ノード _c_cc4fc045-5a1e-4378-b3c7-8a8d3fb9a37c-lock-0000000000 が存在します。
• ノード /locks/lock_01/_c_cc4fc045-5a1e-4378-b3c7-8a8d3fb9a37c-lock-0000000000 は一時ノードです
• ノード/locks/lock_01/_c_cc4fc045-5a1e-4378-b3c7-8a8d3fb9a37c-lock-0000000000のデータはマシンのIPアドレスです

3 ソースコードをロックする

PS: 以下のコード スクリーンショットのコード スタイルは、Curator ソース コードのコード スタイルです。

入り口

プロセス間ミューテックス#内部ロック

まず、threadData から現在のスレッドを取得します。ここでは現在のスレッドは確実に存在しないため、attemptLock メソッドを入力します。

この方法には、後で紹介するロック再入のロジックも含まれます。

ロック

ロック内部#ロックの試行

核となる部分は次の 2 行です。

• 一時的なシーケンスノードを作成する
• internalLockLoopは作成が成功したかどうかを決定します

一時的なシーケンスノードを作成する

StandardLockInternalsDriver#createsTheLock

ノードのモードが CreateMode.EPHEMERAL_SEQUENTIAL であることがわかります。これは、これが一時的なシーケンシャル ノードであることを意味します。

CreateBuilderImpl#forPath(java.lang.String, byte[]) を入力します。

client.getDefaultData() はローカル IP アドレスです。

adjustPath メソッドは、その名前が示すように、パスを調整するために使用されます。 UUID が生成され、/locks/lock_01 に連結されて、/locks/lock_01/_c_UUID-lock- になります。

一時的なシーケンシャルノードが作成されるため、末尾にシーケンスが自動的に追加され、最終的に /locks/lock_01/_c_UUID-lock-0000000000 になります。

ノードの具体的な作成は CreateBuilderImpl#pathInForeground にあります。

一時ノードを作成します。パスが存在する場合は、正常に作成されます。パスが存在しない場合は作成に失敗します。

作成に失敗した場合は、まずパスを作成し、次にノードを作成します。

4 結論

この記事では、ZooKeeper をベースにした分散ロック フレームワークである Curator の使い方と、ロック プロセス、ソース コード分析について主に紹介します。

内容の概要は次のとおりです。

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

• ZooKeeper ベースの分散ロックは一時的なシーケンシャル ノードを使用し、親ノードは永続ノードです。
• 一時ノードを作成するときに、親ノードが存在しない場合は、まず親ノード (パス) が作成されます。
• ロック構造はロック /locks/lock_01 で、実際のロックは /locks/lock_01/_c_UUID-ロック-シリアル番号です。たとえば、/locks/lock_01/_c_cc4fc045-5a1e-4378-b3c7-8a8d3fb9a37c-lock-0000000000

参考リンク:

[1]ZooKeeper共有再入可能ロック: https://curator.apache.org/curator-recipes/shared-reentrant-lock.html

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