Zookeeper的API操作
public static void main(String[] args) throws Exception {//创建zk对象ZooKeeper zk = new ZooKeeper("node01:2181,node02:2181,node03:2181", 10000, new Watcher() {@Overridepublic void process(WatchedEvent wat
·
public static void main(String[] args) throws Exception {
//创建zk对象
ZooKeeper zk = new ZooKeeper("node01:2181,node02:2181,node03:2181", 10000, new Watcher() {
@Override
public void process(WatchedEvent watchedEvent) {
System.out.println("监听的路径:"+watchedEvent.getPath());
System.out.println("监听的类型:"+watchedEvent.getType());
System.out.println("监听的状态:"+watchedEvent.getState());
}
});
//1、创建zk节点
//PERSISTENT:永久节点
zk.create("路径", "数据".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//EPHEMERAL:临时节点
zk.create("路径", "数据".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
//PERSISTENT_SEQUENTIAL:有序永久节点
zk.create("路径", "数据".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
//EPHEMERAL_SEQUENTIAL:有序临时节点
zk.create("路径", "数据".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
//2、查看节点数据
System.out.println(new String(zk.getData("路径", false, null)));
//3、修改节点数据
zk.setData("路径", "数据".getBytes(), -1);
//4.删除节点数据
zk.delete("路径", -1);
//关闭zk
zk.close();
}
更多推荐
已为社区贡献4条内容
所有评论(0)