并发控制与分布式锁(redis/zookeeper)实现【图文教程】_第3章
平凡也就两个字: 懒和惰;
成功也就两个字: 苦和勤;
优秀也就两个字: 你和我。
跟着我从0学习JAVA、spring全家桶和linux运维等知识,带你从懵懂少年走向人生巅峰,迎娶白富美!
每一篇文章都是心得总结,跟我学习你就是大牛!
并发控制与分布式锁(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包:
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>4.0.1</version>
</dependency>
3 zk分布式锁实践
zookeeperLock类:实现zookeeper分布式锁。
Main测试类:
如果以上教程对您有帮助,为了不迷路,请关注一下吧~