客户端获取锁时#xff0c;在

lock下面的所有子节点#xff0c;客户端获取到所有的子节点之后#xff0c;如果发现自己…核心思想当客户端要获取锁则创建节点使用完锁则删除该节点。

客户端获取锁时在

lock下面的所有子节点客户端获取到所有的子节点之后如果发现自己创建的子节点序号最小那么就认为该客户端获取到了锁。

使用完锁后将该节点删除。

如果发现自己创建的节点并非

lock所有子节点中最小的说明自己还没有获取到锁。

此时客户端需要找到比自己小的那个节点同时对其注册事件监听器监听删除事件。

如果发现比自己小的那个节点被删除则客户端的

Watcher

子节点中序号最小的如果是则获取到了锁如果不是则重复以上步骤继续获取到比自己小的一个节点并注册监听。

Curator

InterProcessSemaphoreMutex分布式排它锁非可重入锁

InterProcessReadWriteLock分布式读写锁

InterProcessMultiLock将多个锁作为单个实体管理的容器

package

org.apache.curator.RetryPolicy;

import

org.apache.curator.framework.CuratorFramework;

import

org.apache.curator.framework.CuratorFrameworkFactory;

import

org.apache.curator.framework.recipes.locks.InterProcessMutex;

import

org.apache.curator.retry.ExponentialBackoffRetry;import

java.util.concurrent.TimeUnit;//以线程的方式模拟卖票

public

CuratorFrameworkFactory.builder().connectString(192.168.2.212:2181).sessionTimeoutMs(60

1000).retryPolicy(retryPolicy).build();//开启连接client.start();lock

new

InterProcessMutex(client,/lock);}Overridepublic

void

0){System.out.println(Thread.currentThread():tickets);Thread.sleep(100);tickets--;}}

catch

Thread(ticket12306,飞猪);t1.start();t2.start();}}

lock

InterProcessMutex(client,“/lock”);创建锁对象就行