zookeeper的分布式锁

zookeeper的分布式锁 1.zk中锁的种类：

读锁：⼤家都可以读，要想上读锁的前提：之前的锁没有写锁
写锁：只有得到写锁的才能写。要想上写锁的前提是，之前没有任何锁。

2.zk如何上读锁

创建⼀个临时序号节点，节点的数据是read，表示是读锁
获取当前zk中序号⽐⾃⼰⼩的所有节点
判断最⼩节点是否是读锁：
如果不是读锁的话，则上锁失败，为最⼩节点设置监听。阻塞等待，zk的watch机制
会当最⼩节点发⽣变化时通知当前节点，于是再执⾏第⼆步的流程
如果是读锁的话，则上锁成功

3.zk如何上写锁

创建⼀个临时序号节点，节点的数据是write，表示是 写锁
获取zk中所有的⼦节点
判断⾃⼰是否是最⼩的节点：
如果是，则上写锁成功
如果不是，说明前⾯还有锁，则上锁失败，监听最⼩的节点，如果最⼩节点有变化，
则回到第⼆步。

4.⽺群效应

如果⽤上述的上锁⽅式，只要有节点发⽣变化，就会触发其他节点的监听事件，这样的话对
zk的压⼒⾮常⼤，——⽺群效应。可以调整成链式监听。解决这个问题。

5.curator实现读写锁

1）获取读锁

 @Test
 void testGetReadLock() throws Exception {
 // 读写锁
 InterProcessReadWriteLock interProcessReadWriteLock=new
InterProcessReadWriteLock(client, "/lock1");
 // 获取读锁对象
 InterProcessLock
interProcessLock=interProcessReadWriteLock.readLock();
System.out.println("等待获取读锁对象!");
 // 获取锁
 interProcessLock.acquire();
 for (int i = 1; i <= 100; i++) {
 Thread.sleep(3000);
 System.out.println(i);
 }
 // 释放锁
 interProcessLock.release();
 System.out.println("等待释放锁!");
 }

获取写锁

@Test
 void testGetWriteLock() throws Exception {
 // 读写锁
 InterProcessReadWriteLock interProcessReadWriteLock=new
InterProcessReadWriteLock(client, "/lock1");
 // 获取写锁对象
 InterProcessLock
interProcessLock=interProcessReadWriteLock.writeLock();
 System.out.println("等待获取写锁对象!");
 // 获取锁
 interProcessLock.acquire();
 for (int i = 1; i <= 100; i++) {
 Thread.sleep(3000);
 System.out.println(i);
 }
 // 释放锁
 interProcessLock.release();
 System.out.println("等待释放锁!");
 }