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

平凡也就两个字: 懒和惰;
成功也就两个字: 苦和勤;
优秀也就两个字: 你和我。
跟着我从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包：

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>4.0.1</version>
</dependency>

3 zk分布式锁实践

      zookeeperLock类：实现zookeeper分布式锁。

Main测试类：