开发者社区> 微枫Micromaple> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

Zookeeper 实现分布式锁

简介: Zookeeper 实现分布式锁
+关注继续查看

zookeeper有四种节点类型:

  • 持久节点
  • 持久顺序节点
  • 临时节点
  • 临时顺序节点

Zookeeper 分布式锁恰恰应用了临时顺序节点。首先,在 Zookeeper 当中创建一个持久节点 ParentLock。当第一个客户端想要获得锁时,需要在 ParentLock 这个节点下面创建一个临时顺序节点 Lock1。之后,Client1 查找 ParentLock 下面所有的临时顺序节点并排序,判断自己所创建的节点 Lock1 是不是顺序最靠前的一个。如果是第一个节点,则成功获得锁。这时候,如果再有一个客户端 Client2 前来获取锁,则在 ParentLock 下载再创建一个临时顺序节点 Lock2。Client2 查找 ParentLock 下面所有的临时顺序节点并排序,判断自己所创建的节点 Lock2 是不是顺序最靠前的一个,结果发现节 点 Lock2 并不是最小的。于是,Client2 向排序仅比它靠前的节点 Lock1 注册 Watcher,用于监听 Lock1 节点是否存在。这意味着 Client2 抢锁失败,进入了等待状态。这时候,如果又有一个客户端 Client3 前来获取锁,则在 ParentLock 下载再创建一个临时顺序节点 Lock3。lient3 查找 ParentLock 下面所有的临时顺序节点并排序,判断自己所创建的节点 Lock3 是不是顺序最靠前的一个,结果同样发 现节点 Lock3 并不是最小的。于是,Client3 向排序仅比它靠前的节点 Lock2 注册 Watcher,用于监听 Lock2 节点是否存在。这意味着 Client3 同样抢锁失败,进入了等待状态。这样一来,Client1 得到了 锁,Client2 监听了 Lock1,Client3 监听了 Lock2。这恰恰形成了一个等待队列。

释放锁:

当任务完成时,Client1 会显示调用删除节点 Lock1 的指令。

获得锁的 Client1 在任务执行过程中,如果崩溃,则会断开与 Zookeeper 服务端的链接。根据临时节点 的特性,相关联的节点 Lock1 会随之自动删除。

由于 Client2 一直监听着 Lock1 的存在状态,当 Lock1 节点被删除,Client2 会立刻收到通知。这时候 Client2 会再次查询 ParentLock 下面的所有节点,确认自己创建的节点 Lock2 是不是目前最小的节点。 如果是最小,则 Client2 顺理成章获得了锁。

同理,如果 Client2 也因为任务完成或者节点崩溃而删除了节点 Lock2,那么 Client3 就会接到通知。最 终,Client3 成功得到了锁

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Zookeeper从0到1实现一个分布式锁
分布式锁,在实际的业务使用场景中算是比较常用的了,而分布式锁的实现,常见的除了redis之外,就是zk的实现了,前面一篇博文介绍了zk的基本概念与使用姿势,那么如果让我们来记住zk的特性来设计一个分布式锁,可以怎么做呢?
44 0
ZK(ZooKeeper)分布式锁实现(1)
ZK(ZooKeeper)分布式锁实现
72 0
ZK(ZooKeeper)分布式锁实现(2)
ZK(ZooKeeper)分布式锁实现
28 0
zookeeper 实现分布式锁安全用法
背景 ConnectionLoss 链接丢失 SessionExpired 会话过期 绕开 zookeeper broker 进行状态通知 leader 选举与zkNode 断开 做好幂等 静态扩容、动态扩容 背景 分布式锁现在用的越来越多,通常用来协调多个并发任务。
1633 0
Curator Zookeeper分布式锁
Curator Zookeeper分布式锁 pom.xml中添加如下配置 org.apache.curator curator-recipes 2.10.0 zookeeper配置 下载zookeeper并解压至D:\java\zookeeper-3.
893 0
zookeeper分布式锁
摘要:分享牛原创,zookeeper使用,zookeeper锁在实际项目开发中还是很常用的,在这里我们介绍一下zookeeper分布式锁的使用,以及我们如何zookeeper分布式锁的原理。
616 0
基于ZooKeeper实现分布式锁
ZooKeeper 保证了数据的强一致性,  zk集群中任意节点(一个zkServer)上的相同znode下的数据一定是相同的。使用zookeeper可以非常简单的实现分布式锁, 其基本逻辑如下: 客户端调用create()方法创建名为“locknode/lock”的节点,需要注意的是,这里节点的创建类型需要设置为EPHEMERAL_SEQUENTIAL。
903 0
+关注
微枫Micromaple
立志于成为一个优秀的全栈工程师
64
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载