import org.apache.curator.framework.CuratorFramework; import org.apache.curator.retry.ExponentialBackoffRetry; public class CuratorExample { public static void main(String[] args) throws Exception { CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(1000, 3)); client.start(); byte[] data = client.getData().forPath("/path/to/node"); System.out.println(new String(data)); client.create().forPath("/path/to/node", "data".getBytes()); client.close(); } }


上一篇:
下一篇:
切换中文