基于ZooKeeper实现分布式锁
输入“/”快速插入内容
基于ZooKeeper实现分布式锁
基于ZooKeeper实现分布式锁
Redis实现分布式锁性能较高，ZooKeeper实现分布式锁可靠性更高
1.
如何基于ZooKeeper实现分布式锁
ZooKeeper分布式锁是基于临时顺序节点和Watcher(事件监听器)实现
获取锁：
1.
首先有一个持久节点/locks，客户端获取锁就是在locks下创建临时顺序节点
2.
假设客户端1创建了/locks/lock1节点，创建成功后，判断lock1是否是locks下最小的子节点
3.
若lock1是最小的节点，则获取锁成功，否则获取锁失败
4.
若获取锁失败，则说明有其他客户端已经成功获取锁。客户端1并不会不停地去循环去尝试加锁，而是在前一个节点/locks/lock0上注册一个事件监听器，这个监听器的作用是当前一个节点是否
释放锁：
1.
成功获取锁的客户端在执行完业务流程之后，会将对应的子节点删除
2.
成功获取锁的客户端在出现故障之后，对应的子节点由于是临时顺序节点，也会被自动删除，避免了锁无法被释放
3.
事件监听器其实监听的就是这个子节点删除事件，子节点删除就意味着锁被释放
实际项目中，推荐使用Curator来实现ZooKeeper分布式锁。Curator是Netflix公司开源的一套ZooKeeper Java客户端框架，相比于ZooKeeper自带的客户端zookeeper来说，Curator的封装更加完善，各种API都可以比较方便地使用
CUrator主要实现了下面四种锁：
•
InterProcessMutex：分布式可重入排他锁
•
InterProcessSemaphoreMutex：分布式不可重入排他锁
•
InterProcessReadWriteLock：分布式读写锁
•
InterProcessMultiLock：将多个锁作为单个实体管理的容器，获取锁时获取所有锁，释放锁也会释放所有锁资源（忽略释放失败的锁）
代码块
CuratorFramework client = ZKUtils.getClient();
client.start();
// 分布式可重入排它锁
InterProcessLock lock1 = new InterProcessMutex(client, lockPath1);
// 分布式不可重入排它锁
InterProcessLock lock2 = new InterProcessSemaphoreMutex(client, lockPath2);
// 将多个锁作为一个整体
InterProcessMultiLock lock = new InterProcessMultiLock(Arrays.asList(lock1, lock2));
if (!lock.acquire(10, TimeUnit.SECONDS)) {
throw new IllegalStateException("不能获取多锁");
}
System.out.println("已获取多锁");
System.out.println("是否有第一个锁: " + lock1.isAcquiredInThisProcess());
System.out.println("是否有第二个锁: " + lock2.isAcquiredInThisProcess());
try {
// 资源操作
resource.use();
} finally {
System.out.println("释放多个锁");
lock.release();
}
System.out.println("是否有第一个锁: " + lock1.isAcquiredInThisProcess());
System.out.println("是否有第二个锁: " + lock2.isAcquiredInThisProcess());
client.close();