<dependency>
	<groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>

// junit测试：
private ZKClient zkClient;
/**
 * 获取ZK客户端连接
 */
@Before
public void before(){
    // 参数1：服务器的ip和端口
    // 参数2：会话的超时时间
    // 参数3：会话的连接时间
    // 参数4：序列化方式
    //// 单机模式
    zkClient = new zkClient("192.168.28.132:2181", 30000, 60000, new SerializableSerializer());
    //// 集群模式
    zkClient = new zkClient("192.168.28.132:2181,192.168.28.132:2182,192.168.28.132:2183", 30000, 60000, new SerializableSerializer());
}

// 在ZK创建结点
@Test
public void testCreateNode(){
    // 1.持久结点
    zkClient.create("/node1", "qyf", CreateMode.PERSISTENT);
    // 2.持久顺序结点
    zkClient.create("/node1/names", "qianyifeng", CreateMode.PERSISTENT_SEQUENTIAL);
    // 3.临时结点
    zkClient.create("/node1/lists", "qq", CreateMode.EPHEMERAL);
    // 4.临时顺序结点
    zkClient.create("/node1/lists11", "qyftemp", CreateMode.EPHEMERAL_SEQUENTIAL);
}
// 删除结点
@Test
public void testDeleteNode(){
    // 删除没有子节点的结点 返回值：是否删除成功
    boolean delete = zkClient.delete("/node1");
    // 递归删除结点信息 返回值：是否删除成功
    boolean recursive = zkClient.deleteRecursive("/node1");
}
// 查看结点的子节点
@Test
public void testFindNodes(){
    // 获取指定路径的结点信息 
    // 返回值为当前节点的子节点信息
    List<String> children = zkClient.getChildren("/");
    children.forEach(System.out::println);
}
// 获取某个结点数据  
// 注意：通过Java客户端操作需要保证节点存储的数据和获取结点时数据序列化方式必须一致（Java是针对对象的序列化和反序列化，所以如果序列化的时候是按照字符串方式序列化，而读取的时候，也就是反序列化的时候按照对象的方式反序列化，那必然就会报错。解决方法就是如果要用Java去读，那就最好用Java去写而不要用shell的方式去写）
@Test
public void testFindNodeData(){
    Object readData = zkClient.readData("/node3");
    System.out.println(readData);
}
// 获取数据以及当前结点的状态信息
@Test
public void testFindNodeDataAndStat(){
    Stat stat = new Stat();
    Object readData = zkClient.readData("/node0000000024", stat);
    System.out.println(readData);
    System.out.println(stat);
    System.out.println(stat.getCversion());
    System.out.println(stat.getCtime());
    System.out.println(stat.getCzxid());
    // ... 只要能在shell中的stat命令能看到的状态信息都可以用Java的方式去得到
}
// 修改结点数据
@Test
public void testWriteData(){
    User user = new User();
    user.setId(1);
    user.setName("消遣");
    user.setAge(23);
    user.setBir(new Date());
    zkClient.writeData("/node1", user);
    User o = zkClient.readData("/node1");
    System.out.println(o);
}
// 监听结点数据的变化
// 需要注意的是，Java中设置的监听必须由Java来执行具体的操作这些操作才能被Java监听到，如果是用shell以命令方式执行具体操作则监听不到
@Test
public void testOnNodeDataChange() throws IOException{
    zkClient.subscribeDataChanges("/node00000000024", new IZkDataListener(){
        // 当结点的值在修改时，会自动调用这个方法将当前修改节点的名字和节点变化之后的数据传递给方法
        public void handleDataChange(String nodeName, Object result) throws Exception{
            System.out.println(nodeName);
            System.out.println(result);
        }
        // 当结点的值被删除的时候，会自动调用这个方法，会将节点的名字以参数形式传递给方法
        public void handleDataDeleted(String nodeName) throws Exception{
            System.out.println("结点名字：" + nodeName);
        }
    });
    // 阻塞客户端，如果不阻塞，程序就会直接执行完毕，读不到监听到的内容。这里我们用阻塞输入流的方式将监听到的内容打印到控制台
    System.in.read();
}
// 监听结点目录的变化
@Test
public void testOnNodesChange() throws IOException{
    zkClient.subscribeChildChanges("/node0000000024", new IZkChildListener(){
        // 当前结点发生变化时，会自动调用这个方法
        // 参数1：父节点名称
        // 参数2：父节点中的所有子节点名称
        public void handleChileChange(String nodeName, List<String> list) throws Exception{
            System.out.println("父节点名称：" + nodeName);
            System.out.println("发生变更后结点的孩子结点名称：");
            list.forEach(System.out::println);
        }
    });
    // 阻塞客户端，如果不阻塞，程序就会直接执行完毕，读不到监听到的内容。这里我们用阻塞输入流的方式将监听到的内容打印到控制台
    System.in.read();
}

/**
 * 关闭资源
 */
@After
public void after(){
    zkClinet.close();
}