zookeeper javaAPI操作

javaAPI操作

创建maven工程并将jar包导入pom文件基本使用

创建maven工程并将jar包导入pom文件

jar包： <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.9</version> </dependency>

基本使用

ZooKeeper zooKeeper = new ZooKeeper("node01:2181,node02:2181,node03:2181", 10000, new Watcher() { @Override public void process(WatchedEvent watchedEvent) { System.out.println("监听类型： " + watchedEvent.getType()); System.out.println("监听状态： " + watchedEvent.getState()); System.out.println("监听路径： " + watchedEvent.getPath()); } }); //创建zk节点 和子节点son zooKeeper.create("/bigdata2", "bigdata1".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); zooKeeper.create("/bigdata2/bigdata2son", "bigdata2son".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); //查看节点数据 System.out.println(new String(zooKeeper.getData("/bigdata2/bigdata2son", false, null))); //修改节点数据 zooKeeper.setData("/bigdata2/bigdata2son", "changelast".getBytes(), -1); //关流zk zooKeeper.close();