安裝

<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();