vlambda博客
学习文章列表

并发控制与分布式锁(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分布式锁。

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

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


Main测试类:


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