ZooKeeper 分散式鎖的程式碼實現

ZooKeeper 分散式系統 · 發表 2018-10-08 07:07:05

摘要：本文涉及到幾個zookeeper簡單的知識點，永久節點、有序節點、watch機制。比較基礎，熟悉的就別看了跳過這篇吧每個執行緒在/locks節點下建立一個臨時有序節點testlock0000000040 獲得/locks節點下所有子節點A、B、C，排序獲得最...

本文涉及到幾個zookeeper簡單的知識點，永久節點、有序節點、watch機制。比較基礎，熟悉的就別看了跳過這篇吧

下面看程式碼

1.執行緒初始化

建立一個名字為lockName的永久節點（只有永久節點才可以建立子節點）

複習一下：

建立臨時有序節點，會在你的lockName後面加上一串編號，

例如：/locks/test_ lock_ 0000000035

獲取當前lockName下的所有子臨時節點

把名字都取出來放進list排個序

若當前節點為最小節點，則直接獲取鎖成功

若不是最小節點，開始等待，見下一步。

給exists加上watcher，監控當前執行緒等待的節點waitLock是否還存在；

若存在即stat不為null，當前執行緒先開始await；

同時watch執行緒也啟動了開始監控exists操作；

若是exists狀態有變化了（即waitLock不存在了）觸發watch執行緒的countDown操作；

countDown操作使當前執行緒結束waiting，獲得鎖，開始繼續往後執行。

程式碼算是比較簡單的，想看完整程式碼的同學，可以在公眾號後臺回覆9獲得