ZooKeeper 分布式锁的代码实现

本文涉及到几个zookeeper简单的知识点，永久节点、有序节点、watch机制。比较基础，熟悉的就别看了跳过这篇吧

• 每个线程在/locks节点下创建一个临时有序节点testlock0000000040

• 获得/locks节点下所有子节点A、B、C，排序获得最小值

• 若当前节点B为最小值则获得锁，执行业务逻辑

• 若当前节点B不是最小值则watch比自己小1的节点A，节点A存在则await，否则获得锁

总结：创建临时有序节点 排序 后，watch比自己小1的节点等待获取锁。

下面看代码

1.线程初始化

创建一个名字为lockName的永久节点（只有永久节点才可以创建子节点）

复习一下：

zookeeper的节点有以下几种类型：永久，永久有序，临时，临时有序

2.线程尝试获得锁tryLock

创建临时有序节点，会在你的lockName后面加上一串编号，

例如：/locks/test_ lock_ 0000000035

获取当前lockName下的所有子临时节点

把名字都取出来放进list排个序

若当前节点为最小节点，则直接获取锁成功

若不是最小节点，开始等待，见下一步。

3.开始等待锁

获得当前线程需要等待的节点名

• 获得当前节点的节点名即testlock0000000035

• 获得当前几点在所有排队等锁的线程中的排序

• 根据排序-1，获得排在自己前面的线程的节点名

给exists加上watcher，监控当前线程等待的节点waitLock是否还存在；

若存在即stat不为null，当前线程先开始await；

同时watch线程也启动了开始监控exists操作；

若是exists状态有变化了（即waitLock不存在了）触发watch线程的countDown操作；

countDown操作使当前线程结束waiting，获得锁，开始继续往后执行。

代码算是比较简单的，想看完整代码的同学，可以在公众号后台回复9获得 

推荐阅读

zookeeper-操作与应用场景-《每日五分钟搞定大数据》

zookeeper-架构设计与角色分工-《每日五分钟搞定大数据》

zookeeper-一个关于paxos的故事-《每日五分钟搞定大数据》