apache curator怎么操作zookeeper

 org.apache.curator curator-recipes 4.1.0 

public static void main(String[] args) { String zookeeperConnectionString = "localhost:2181"; RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramework client = CuratorFrameworkFactory.newClient(zookeeperConnectionString, retryPolicy); client.start(); try { //创建分布式锁, 锁空间的根节点路径为/curator/lock InterProcessMutex lock = new InterProcessMutex(client, "/curator/lock"); if ( lock.acquire(1000, TimeUnit.SECONDS) ) { try { // do some work inside of the critical section here System.out.println("do some work inside of the critical section here"); } finally { //完成业务流程, 释放锁 lock.release(); } } } catch (Exception e) { e.printStackTrace(); } }