ZooKeeper学习(五)Java操作ZookeeperAPI

Myth丶恋晨 2024-02-19 15:07 23阅读 0赞

**Java操作Zookeepe:**

pom:

<dependency>
       <groupId>org.apache.curator</groupId>
       <artifactId>curator-recipes</artifactId>
       <version>4.1.0</version>
    </dependency>

**创建ZooKeeper客户端:**

private static String connectString = "94.191.86.252:2181,94.191.86.252:2182,94.191.86.252:2183";
        private static int sessionTimeout = 2000;
        private ZooKeeper zkClient = null;
        @Before
        public void befor(){
            try {
                zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
                    @Override
                    public void process(WatchedEvent event) {
                        // 收到事件通知后的回调函数（用户的业务逻辑）
                        System.out.println(event.getType() + "--" + event.getPath());
    
                    }
                });
            } catch (IOException e) {
                e.printStackTrace();
            }
    }

**创建节点：**

// 创建子节点
        @Test
        public void create() throws Exception {
            // 数据的增删改查
            // 参数1：要创建的节点的路径； 参数2：节点数据 ； 参数3：节点权限 ；参数4：节点的类型
             zkClient.create("/servera", "hello zk".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
             //创建字节点
             zkClient.create("/servera/server", "hello zk".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    
        }

获取子节点：

@Test
        public void getChildren() throws Exception {
            List<String> children = zkClient.getChildren("/servera", true);
    
            for (String child : children) {
                System.out.println(child);
            }
        }

判断znode是否存在：

@Test
    public void exist() throws Exception {
        Stat stat = zkClient.exists("/servera", false);
    
        System.out.println(stat == null ? "not exist" : "exist");
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70][]

。。。。。。。。。。。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/877051452490415f8bc4f259f5a00b37.png