ZooKeeper的Java客戶端工具使用(Curator)
阿新 • • 發佈:2018-12-14
安裝
<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();