安装
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-client</artifactId>
<version>2.13.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.13.0</version>
</dependency>
示例
操作失败重试机制:1000
毫秒间隔,重试3
次
RetryPolicy policy = new ExponentialBackoffRetry(1000, 3);
创建Curator客户端
CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.29.110:2181", policy);
启动
client.start();
创建锁对象
final InterProcessMutex lock = new InterProcessMutex(client, "/mylock");
请求锁
lock.acquire();
释放锁
lock.release();