热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

【并发控制】并发控制与分布式锁(redis/zookeeper)实现【图文教程】_第3章

需求:多个线程并发执行被加了zk锁的服务A,执行服务A之前需要获取锁。zk锁流程:(1)获取锁:在zk的zkLock节点下创建一个名为“zk_”的临时顺序节点。判断当前临时顺序节点

平凡也就两个字: 懒和惰;
成功也就两个字: 苦和勤;
优秀也就两个字: 你和我。
跟着我从0学习JAVA、spring全家桶和linux运维等知识,带你从懵懂少年走向人生巅峰,迎娶白富美!
关注微信公众号【 IT特靠谱 】,每一篇文章都是心得总结,跟我学习你就是大牛!




并发控制与分布式锁(redis/zookeeper)实现【图文教程】_第3章

---zookeeper分布式锁实现并发控制

温馨提示:

      zookeeper锁不仅适用于单机服务,也适用于集群分布式系统的并发控制!!

1 Zk分布式锁机制

      需求:多个线程并发执行被加了zk锁的服务A,执行服务A之前需要获取锁。

      zk锁流程:

      (1)获取锁:在zk的/zkLock节点下创建一个名为“zk_”的临时顺序节点。判断当前临时顺序节点的顺序号是不是最小的,如果是则表示当前线程可以获取到锁了;如果当前临时顺序节点的顺序号不是最小的,那么创建一个watch并监听前一个顺序号节点(监听前一个顺序号节点的删除事件),如果前一个节点被删除了,那么唤醒当前线程,表示当前线程获取到锁了,可以执行服务A了。

      (2)释放锁:服务A执行之后,当前线程结束,临时顺序节点就自动删除消失了,表示锁被释放了!同时关闭zk连接!!

      但是!如今有了Curator框架,通过该框架可以轻松操作zookeeper节点(增删改查),同时提供了分布式锁的实现:InterProcessMetux可重入锁!通过InterProcessMetux可以轻松实现zk分布式锁功能!!InterProcessMetux可重入锁内部就是用的上面阐述的机制!!!

2 使用Curator框架

      由于用到了Curator框架,因此需要引入下面的jar包:


org.apache.curator
curator-recipes
4.0.1

3 zk分布式锁实践

      zookeeperLock类:实现zookeeper分布式锁。

Main测试类:

如果以上教程对您有帮助,为了不迷路,请关注一下吧~


推荐阅读
author-avatar
被爱的超萌baby
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有