Zookeeper的原生api操作

╰半橙微兮° 2022-10-09 04:52 200阅读 0赞

pom文件引入

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

## zookeeper原生api创建会话操作 ##

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();
            }
        }
    }

正常创建回话![file][]

## zookeeper原生api获取信息操作 ##

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);
    
        }
    }

> 欢迎搜索关注本人的公众号【微瞰技术】,以及总结的分类面试题[https://github.com/zhendiao/JavaInterview][https_github.com_zhendiao_JavaInterview]

![file][file 1]

[file]: /images/20221005/f69594822ae1445ea4b3fa6606497fb8.png
[https_github.com_zhendiao_JavaInterview]: https://github.com/zhendiao/JavaInterview
[file 1]: /images/20221005/642208fd65164247ab5c3829cff78149.png