java操作zookeeper实例代码

本篇内容主要讲解“java操作zookeeper实例代码”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“java操作zookeeper实例代码”吧!package com.rxzx.demo;import java.io.IOException;import java.util.List;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.KeeperException;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.data.Stat;public class ZKDemo { //连接zookeeper的超时时长（毫秒）privat免费主机域名e static final int OUT_TIME=60000;//zookeeper集群连接对象private ZooKeeper zk;//自定义监听事件对象private Watcher wc=new Watcher(){@Overridepublic void process(WatchedEvent event) {// TODO Auto-generated method stubif(event.getType()==Event.EventType.NodeDataChanged){System.out.println(event.getPath()+” “+event.getType());}else{System.out.println(event.getPath()+” “+event.getType());}}};//获取监控对象public Watcher getWatcher(){return this.wc;}//获取zookeeper集群连接对象public ZooKeeper getZooKeeper(){if(zk==null){try {zk=new ZooKeeper(“192.168.2.100:2181,192.168.2.101:2181,192.168.2.102:2181”,OUT_TIME,null);} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}return zk;}//关闭zookeeper连接对象public void close(){if(zk!=null){try {zk.close();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}public static void main(String[] args) {// TODO Auto-generated method stubZKDemo zd=new ZKDemo();try {//获取zookeeper连接对象ZooKeeper zk=zd.getZooKeeper();//遍历node节点的子节点List nodelist=zk.getChildren(“/node”, zd.getWatcher());for(String s:nodelist){System.out.println(s);}//创建no免费主机域名de的子节点son//zk.create(“/node/son”, “hello word”.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);//判断数据节点是否存在，如果存在则返回该对象Stat son=zk.exists(“/node/son0000000011”, zd.getWatcher());if(son!=null){System.out.println(son.getCzxid());}else{System.out.println(“该节点不存在”);}//对数据节点的数据内容进行修改//zk.setData(“/node/son0000000011”, “wwwwww”.getBytes(), -1);//Stat stat=new Stat();//获取数据节点的数据内容//byte[] d=zk.getData(“/node/son0000000011”, zd.getWatcher(), null);//System.out.println(new String(d));//System.out.println(stat.getCzxid());zk.delete(“/node/son4”, -1);System.out.println(“操作完成”);} catch (KeeperException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{zd.close();}}}到此，相信大家对“java操作zookeeper实例代码”有了更深的了解，不妨来实际操作一番吧！这里是云技术网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！

相关推荐: 如何查看锁定的session信息脚本

这篇文章将为大家详细讲解有关如何查看锁定的session信息脚本，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。 查看当前被阻塞的对象和锁信息SELECT DISTINCT s1.inst_id BlockingInst, s…