zookeeper  api

 

 

 

**************************************ZkApiTest **************************************
ZooKeeper zooKeeper=new ZooKeeper("192.168.157.128:2181", 2000, new Watcher() {

zookeeper  api

 

 

**************************************************************************
**************************************************************************
 

 

 

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);
}

}

 

相关文章:

  • 2022-01-22
  • 2021-12-04
  • 2021-11-24
  • 2021-11-16
  • 2021-11-12
  • 2022-12-23
  • 2021-12-29
  • 2021-07-11
猜你喜欢
  • 2021-09-12
  • 2021-05-25
  • 2022-02-10
  • 2021-08-21
  • 2022-12-23
  • 2021-12-18
相关资源
相似解决方案