zookeeper- ZKClient方式

ZkClient的maven依赖

<!-- zkclient依赖 -->
    <dependency>
      <groupId>com.101tec</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.10</version>
    </dependency>

示例代码：

public class ZkClientApiOperatorDemo {

    private final static String CONNECTSTRING="192.168.30.10:2181";

    private static ZkClient  getInstance(){
        return new ZkClient(CONNECTSTRING,10000);
    }

    public static void main(String[] args) throws InterruptedException {
        ZkClient zkClient=getInstance();
        //zkclient 提供递归创建父节点的功能
//        zkClient.createPersistent("/zkclient/zkclient1/zkclient1-1/zkclient1-1-1",true);
//        System.out.println("success");

        //删除节点
        //zkClient.deleteRecursive("/zkclient");



        //获取子节点
//        List<String> list=zkClient.getChildren("/node11");
//        System.out.println(list);

        //watcher

//        zkClient.subscribeDataChanges("/node11", new IZkDataListener() {
//            @Override
//            public void handleDataChange(String s, Object o) throws Exception {
//                System.out.println("节点名称："+s+"->节点修改后的值"+o);
//            }
//
//            @Override
//            public void handleDataDeleted(String s) throws Exception {
//
//            }
//        });
//
//        zkClient.writeData("/node11","node");
//        TimeUnit.SECONDS.sleep(2);

        zkClient.subscribeChildChanges("/node11", new IZkChildListener() {
            @Override
            public void handleChildChange(String s, List<String> list) throws Exception {
                System.out.println("节点名称："+s+"->"+"当前的节点列表："+list);
            }
        });

        zkClient.delete("/node11/node1");;
        TimeUnit.SECONDS.sleep(2);

    }
}