public class CuratorTest {

    public String zookeeperConnectionString = "10.121.214.95:2181";
    CuratorFramework client;

    /**
     *  创建客户端，两种方式，默认客户端，带参数的客户端创建
     */
    @Before
    public void CreateClient() {
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        client = CuratorFrameworkFactory.newClient(zookeeperConnectionString, retryPolicy);
        client.start();
    }

    /**
     * 有了CuratorFramework 实例，就可以使用了,先来创建个空节点
     */
    @Test
    public void createPath() {
        try {
            client.create().forPath("/myPath1");
            client.create().forPath("/myPath1/myChildren1");
            client.create().forPath("/myPath1/myChildren2");
            //client.create().forPath("/myPath1","myData1".getBytes());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    /**
     * 创建临时节点
     * 和持久节点不同的是，临时节点的生命周期和客户端会话绑定。
     * 也就是说，如果客户端会话失效，那么这个节点就会自动被清除掉。
     * 注意，这里提到的是会话失效，而非连接断开。另外，在临时节点下面不能创建子节点。
     */
    @Test
    public void createEphemeral() throws Exception {
        client.create().withMode(CreateMode.EPHEMERAL).forPath("/myPath2", "myData2".getBytes());
    }

    /**
     *  为节点设置数据
     */
    @Test
    public void setData() throws Exception {
        client.setData().forPath("/myPath1", "myData1".getBytes());
    }

    /**
     *  列出子节点
     */
    @Test
    public void watchedGetChildren() throws Exception {
        List<String> list = client.getChildren().watched().forPath("/myPath1");
        for (String s : list) {
            System.out.println(s);
        }
    }


    /**
     *  删除节点
     *  sguaranteed()：接口是一个保障措施，只要客户端会话有效，
     *  那么Curator会在后台持续进行删除操作，直到节点删除成功
     *  deletingChildrenIfNeeded()： 删除一个节点，并递归删除其所有子节点
     */
    @Test
    public void guaranteedDelete() throws Exception {
        //client.delete().forPath("/myPath1");
        //client.delete().guaranteed().forPath("/myPath1");
        client.delete().deletingChildrenIfNeeded().forPath("/myPath1");
    }
}