zookeeper的api使用

231weq

将zookeeper服务全部起来使用API来来替代命令行中的操作

比如:
创建节点向节点中写入描述信息

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52

private ZooKeeper zk = null;     @Before     public void init() throws Exception {         zk = new ZooKeeper("192.168.0.203:2181", 2000, new Watcher() {             /** 监听事件发生时的回调方法*/             @Override             public void process(WatchedEvent event) {                 if (event.getType() == EventType.None)                     return;                 System.out.println(event.getType());                 System.out.println(event.getPath());                 try {                     zk.getData("/test1", true, null);                     zk.getChildren("/test1", true);                 } catch (KeeperException | InterruptedException e) {                     e.printStackTrace();                 }             }         });     }     /**      * 向zookeeper服务集群中注册数据，添加znode      */     @Test     public void testCreateZnode() throws UnsupportedEncodingException, KeeperException, InterruptedException { // 该节点如果没创建了下次在创建就会报错         //zk.create("/test1", "diyigeceshi".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);         /** 第一个参数:在已有的节点中创建文件节点             第二个参数:写入对该节点的描述信息             第三个参数:是否开发写入操作             第四个参数:指定该节点的生命周期,sequential的顺序维护是在一个父节点的范围之内*/         zk.create("/test1/a", "zijiedianA".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);         zk.create("/test1/b", "zijiedianB".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);         // 换一个父节点，序号的递增顺序重新开始     //  zk.create("/test2/a", "如诗".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);         zk.close();     } }