版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_27399407/article/details/86577173
- zk实现分布式锁的原理
利用zk的节点特性:临时有序节点。当zookeeper客户端需要抢夺某个资源时,会先在/locker节点下创建临时有序节点,通过监听比自己序号次小的节点的删除事件,来进行一些逻辑,判断自己的节点是否为/locker所有子节点中序号最小的,如果是那么就使用资源,使用完之后,再释放资源删除对应节点。如下图:
原理流程图:
- Curator实现分布式锁的实践
使用curator来实现相对简单的多,代码如下:
@Test
public void client1() throws Exception {
for (Integer i = 0; i < 10; i++) {
new Thread(() -> {
try {
testLock(Thread.currentThread().getName());
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}
TimeUnit.MINUTES.sleep(5);
}
private void testLock(String clientId) throws Exception {
//创建zookeeper的客户端
RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
CuratorFramework client = CuratorFrameworkFactory.newClient(CONNECTION_STRING, retryPolicy);
client.start();
//创建分布式锁, 锁空间的根节点路径为/curator/lock
InterProcessMutex mutex = new InterProcessMutex(client, "/curator/lock");
mutex.acquire();
//获得了锁, 进行业务流程
System.out.println(clientId + "获取到锁,开始执行逻辑。。。");
TimeUnit.SECONDS.sleep(10);
//完成业务流程, 释放锁
mutex.release();
//关闭客户端
client.close();
}
执行结果: