关于java:Zookeeper的原生api操作

38次阅读

共计 1823 个字符，预计需要花费 5 分钟才能阅读完成。

pom 文件引入

<dependencies>
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.14</version>
    </dependency>
</dependencies>

public class CreateSession implements Watcher {private static CountDownLatch countDownLatch = new CountDownLatch(1);

    public static void main(String[] args) throws IOException, InterruptedException {ZooKeeper zooKeeper = new ZooKeeper("119.45.52.68:2181",6000,new CreateSession());
        System.out.println(zooKeeper.getState());
        countDownLatch.await();
        System.out.println("zk session  create success");

    }
    @Override
    public void process(WatchedEvent watchedEvent) {if (watchedEvent.getState()==Event.KeeperState.SyncConnected){countDownLatch.countDown();
        }
    }
}

失常创立回话

public class getNoetNode implements Watcher {

    private  static ZooKeeper zooKeeper;

    public static void main(String[] args) throws InterruptedException, IOException {zooKeeper = new ZooKeeper("119.45.52.68:2181",10000,new getNoetNode());
        //countDownLatch.await();
        Thread.sleep(Integer.MAX_VALUE);
    }

    @Override
    public void process(WatchedEvent event) {if(event.getType() ==Event.EventType.NodeChildrenChanged){
// 再次获取节点数据
            try {
                List<String> children =
                        zooKeeper.getChildren(event.getPath(), true);
                System.out.println(children);
            } catch (KeeperException e) {e.printStackTrace();
            } catch (InterruptedException e) {e.printStackTrace();
            }
        }

        // 当连贯创立了，服务端发送给客户端 SyncConnected 事件
        if(event.getState() == Event.KeeperState.SyncConnected){
            try {
// 调⽤获取单个节点数据⽅法
                getNodeData();
                getChildren();} catch (Exception e) {e.printStackTrace();
            }
        }
        System.out.println();}

    private static void getNodeData() throws Exception {byte[] data = zooKeeper.getData("/persistent/children", true,
                null);
        System.out.println(new String(data,"utf-8"));
    }

    public static  void getChildren() throws Exception{List<String> childrens = zooKeeper.getChildren("persistent",true);
        System.out.println(childrens);

    }
}