Zookeeper基础知识-java调用客户端

逃离我推掉我的手 2023-10-06 20:32 16阅读 0赞

1）创建一个工程：Zookeeper

2）添加pom文件(Zookeeper,log4j)

<dependency>
         <groupId>log4j</groupId>
         <artifactId>log4j</artifactId>
         <version>1.2.12</version>
    </dependency>
     <dependency>
         <groupId>org.apache.zookeeper</groupId>
         <artifactId>zookeeper</artifactId>
         <version>3.7.0</version>
     </dependency>

3)log4j.properties文件文件放在项目的根目录下

4）创建包和类

private String connectString="172.29.97.56:2181,172.29.97.56:2182,172.29.97.56:2183";
        int  sessionTimeout =1000;
        public ZooKeeper ckClient;
    
        @BeforeEach
        public void init() throws IOException, KeeperException, InterruptedException {
                ckClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
                @Override
                public void process(WatchedEvent watchedEvent) {
                    List<String> children = null;
                    try {
                        children = ckClient.getChildren("/china",true);
                        for (String child:children) {
                            System.out.println(child);
                        }
                    } catch (KeeperException e) {
                        e.printStackTrace();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    
                }
            });
            //CONNECTED
            Thread.sleep(1000);
            System.out.println(ckClient.getState());
        }
    
        @Test
        public void create() throws KeeperException, InterruptedException {
            String nodeCreated=ckClient.create("/china/beijing","beijing".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    
        }
    
        @Test
        public void getChildren() throws KeeperException, InterruptedException {
            List<String> children = ckClient.getChildren("/china",true);
            for (String child:children) {
                System.out.println(child);
            }
            //延迟
            Thread.sleep(Long.MAX_VALUE);
        }

注意点：1.在其它案例执行前执行，使用junit5的@BeforeEach注解，junit4的是@Before注解，使用不对的话，会导致注解失效。