**************************************ZkApiTest **************************************
ZooKeeper zooKeeper=new ZooKeeper("192.168.157.128:2181", 2000, new Watcher() {
**************************************************************************
**************************************************************************
package com.itheima.zkDemo;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.junit.jupiter.api.Test;
import java.io.IOException;
import java.util.List;
public class ZkApiTest {
@Test
public void test() throws IOException, KeeperException, InterruptedException {
// 1、创建zookeeper连接
ZooKeeper zooKeeper=new ZooKeeper("192.168.157.128:2181", 2000, new Watcher() {
public void process(WatchedEvent watchedEvent) {
System.out.println("触发了"+watchedEvent.getType()+"的事件");
}
});
// 2、创建父节点
//String path=zooKeeper.create("/itheima","itheimaValue".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//System.out.println(path);
// 3、创建子节点
//String childrenpath=zooKeeper.create("/itheima/children","childrenValue".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
// System.out.println(childrenpath);
// 4、获取节点中的值(父节点和子节点)
// byte[] data=zooKeeper.getData("/itheima",false,null);
//System.out.println(new String(data));
// List<String> children=zooKeeper.getChildren("/itheima",false);
// for(String child:children)
// {
// System.out.println(child);
// }
// 5、修改节点的值
//Stat stat=zooKeeper.setData("/itheima","itheimaUpdate".getBytes(),-1);
// System.out.println(stat);
// 6、判断某个节点是否存在
//Stat exists=zooKeeper.exists("/itheima/children",false);
//System.out.println(exists);
// 7、删除节点
zooKeeper.delete("/itheima/children",-1);
}
}