zookeeper實(shí)現(xiàn)分布式鎖
zk存儲(chǔ)結(jié)構(gòu)
zk.png
- 在lock節(jié)點(diǎn)下存儲(chǔ)每個(gè)節(jié)點(diǎn)對應(yīng)的臨時(shí)節(jié)點(diǎn)數(shù)據(jù)，按順序遞增。
實(shí)現(xiàn)流程
process.png
首先通過Zookeeper客戶端鏈接zookeeper集群
往zk寫臨時(shí)順序節(jié)點(diǎn)信息。
判斷目前的節(jié)點(diǎn)是否最小。如果是，獲取鎖，如果不是，獲取前一個(gè)次小的節(jié)點(diǎn)。
對前一個(gè)節(jié)點(diǎn)加監(jiān)聽，監(jiān)聽nodedeleted或者Sessionclosed的事件。
-
后面兩種做法：
1、事件觸發(fā)，返回到第三部。
2、事件觸發(fā)，獲取鎖。本例采用的是這種方式。
案例后續(xù)優(yōu)化的點(diǎn)
- 細(xì)化事件判斷，會(huì)存在session斷掉的情況。多測試場景覆蓋。
- 業(yè)務(wù)系統(tǒng)中使用，最好加上任務(wù)啟動(dòng)的日志記錄。防止zookeeper集群掛掉，定時(shí)任務(wù)沒啟動(dòng)，影響整體的業(yè)務(wù)。說白了就是做冗災(zāi)和監(jiān)控。
代碼踩坑記
-
TaskServiceTest方法在剛開始寫的時(shí)候，在構(gòu)造函數(shù)中獲取connect成員變量，每次都是空的。跟蹤代碼發(fā)現(xiàn)，犯了一個(gè)粗心的錯(cuò)誤，特記錄如下：
1.png
可以看到代碼中是先實(shí)例化對象，再通過AbstractAutowireCapableBeanFactory對象的populateBean方法給屬性賦值。所以你在構(gòu)造函數(shù)中獲取屬性，永遠(yuǎn)是空的。
curator實(shí)現(xiàn)
采用的組件有framework和recipes。
- 這里要注意framework和Zookeeper版本兼容性問題，要采用RELEASE版本，否則會(huì)出現(xiàn)curator創(chuàng)建節(jié)點(diǎn)報(bào)錯(cuò)的情況。
- 整體的思想和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會(huì)阻塞，這個(gè)要注意。
代碼可以參見示例
