try {
//创建一个Zookeeper实例,第一个参数为目标服务器地址和端口,第二个参数为Session超时时间,第三个为节点变化时的回调方法
ZooKeeper zk = new ZooKeeper("10.203.98.51:2181", 300000, new Watcher() {
// 监控所有被触发的事件
public void process(WatchedEvent event) {
System.out.println("## " + event.getWrapper() + " ##");
System.out.println("## " + event + " ##");
}
});
//创建一个节点root,数据是mydata,不进行ACL权限控制,节点为永久性的(即客户端shutdown了也不会消失)
String s = zk.create("/root", "mydata".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(s);
//在root下面创建一个childone znode,数据为childone,不进行ACL权限控制,节点为永久性的
s = zk.create("/root/childone", "childone".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(s);
//取得/root节点下的子节点名称,返回List<String>
List<String> children = zk.getChildren("/root", true);
System.out.println(children);
//取得/root/childone节点下的数据,返回byte[]
byte[] data = zk.getData("/root/childone", true, null);
System.out.println(new String(data));
//修改节点/root/childone下的数据,第三个参数为版本,如果是-1,那会无视被修改的数据版本,直接改掉
Stat stat = zk.setData("/root/childone", "childonemodify".getBytes(), -1);
System.out.println(stat);
//删除/root/childone这个节点,第二个参数为版本,-1的话直接删除,无视版本
zk.delete("/root/childone", -1);
zk.delete("/root", -1);
//关闭session
zk.close();
} catch (Exception e) {
e.printStackTrace();
}