02-zookeeper

package com.bjsxt; import org.apache.zookeeper.*; import org.apache.zookeeper.data.Stat; import java.io.IOException; import java.util.List; /** * 操作Zookeeper的Znode */ public class ZnodeDemo implements Watcher { public static void main(String[] args) throws KeeperException, InterruptedException, IOException { //创建连接Zookeeper对象 ZooKeeper zooKeeper = new ZooKeeper("192.168.233.130:2181,192.168.233.130:2182,192.168.233.130:2183",150000,new ZnodeDemo()); //创建一个Znode /* String path = zooKeeper.create("/bjsxt/test","oldlu".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL); System.out.println(path);*/ //获取指定节点的数据 /*byte[] data= zooKeeper.getData("/bjsxt/test0000000001",new ZnodeDemo(),new Stat()); System.out.println(new String(data));*/ //获取指定节点中的所有子节点中的数据 /* List<String> list = zooKeeper.getChildren("/bjsxt",new ZnodeDemo()); for(String path :list){ byte[] data= zooKeeper.getData("/bjsxt/"+path,new ZnodeDemo(),null); System.out.println(new String(data)); }*/ //设置Znode中的值 // -1：表示匹配任何版本 /* Stat stat = zooKeeper.setData("/bjsxt/test0000000001","bjsxt".getBytes(),-1); System.out.println(stat);*/ zooKeeper.delete("/bjsxt/test0000000001",-1); } /** * 事件通知回调方法 * @param event */ @Override public void process(WatchedEvent event) { //获取连接事件 if(event.getState() == Event.KeeperState.SyncConnected){ System.out.println("连接成功"); } } }