zookeeper實現(xiàn)分布式鎖
zk存儲結構
zk.png
- 在lock節(jié)點下存儲每個節(jié)點對應的臨時節(jié)點數(shù)據(jù)，按順序遞增圾叼。
實現(xiàn)流程
process.png
首先通過Zookeeper客戶端鏈接zookeeper集群
往zk寫臨時順序節(jié)點信息瓷蛙。
判斷目前的節(jié)點是否最小瘫拣。如果是损合，獲取鎖，如果不是瓜挽，獲取前一個次小的節(jié)點。
對前一個節(jié)點加監(jiān)聽征绸，監(jiān)聽nodedeleted或者Sessionclosed的事件久橙。
-
后面兩種做法：
1俄占、事件觸發(fā)，返回到第三部淆衷。
2缸榄、事件觸發(fā)，獲取鎖祝拯。本例采用的是這種方式甚带。
案例后續(xù)優(yōu)化的點
- 細化事件判斷，會存在session斷掉的情況佳头。多測試場景覆蓋鹰贵。
- 業(yè)務系統(tǒng)中使用，最好加上任務啟動的日志記錄康嘉。防止zookeeper集群掛掉碉输，定時任務沒啟動，影響整體的業(yè)務亭珍。說白了就是做冗災和監(jiān)控敷钾。
代碼踩坑記
-
TaskServiceTest方法在剛開始寫的時候，在構造函數(shù)中獲取connect成員變量肄梨，每次都是空的阻荒。跟蹤代碼發(fā)現(xiàn)，犯了一個粗心的錯誤峭范，特記錄如下：
1.png
可以看到代碼中是先實例化對象财松，再通過AbstractAutowireCapableBeanFactory對象的populateBean方法給屬性賦值。所以你在構造函數(shù)中獲取屬性纱控，永遠是空的辆毡。
curator實現(xiàn)
采用的組件有framework和recipes。
- 這里要注意framework和Zookeeper版本兼容性問題甜害，要采用RELEASE版本舶掖，否則會出現(xiàn)curator創(chuàng)建節(jié)點報錯的情況。
- 整體的思想和zookeeper類似尔店。悲觀鎖的方式眨攘。
- 采用Shared Reentrant Lock：Fully distributed locks that are globally synchronous, meaning at any snapshot in time no two clients think they hold the same lock.
- acquire會阻塞，這個要注意嚣州。
代碼可以參見示例
