Zookeeper JAVA 原生 API 超详细（三）

悠悠 2024-04-17 05:23 67阅读 0赞

## 1、pom文件 ##

<dependencies>
        
        
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
        </dependency>
        
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.8.1</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.6</version>
        </dependency>
    </dependencies>

## 2、创建会话 ##

public class zookeeperTest {
    
        public static final String ZOOKEEPER_SERVER = "192.168.1.38:2181";
    
        public static void main(String[] args) throws IOException {
            //创建一个会话,url,超时时间，监听机制
            ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_SERVER, 5000, null);
            System.out.println(zooKeeper.getState());
        }
    
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70]  
参数表：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 1]

## 3、创建节点 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 3]  
需要注意几点：  
1）、zookeeper不支持递归创建，没有父节点，不支持建立子节点。  
2）、关于权限控制，如果你的应用场景没有太高的权限要求，那么就不用关注acl这个参数。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 5]

## 4、删除节点 ##

![在这里插入图片描述][20190822021507167.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 6]

![在这里插入图片描述][2019082202152088.png]

## 5、读取数据 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][20190822021540259.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 8]

public class zookeeperTest {
    
        public static final String ZOOKEEPER_SERVER = "192.168.1.38:2181";
        public static void main(String[] args) throws Exception {
            //创建一个会话,url,超时时间，监听机制
            ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_SERVER, 5000, null);
            zooKeeper.create("/list", "data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT );
            zooKeeper.create("/list/list1", "data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT );
            zooKeeper.create("/list/list2", "data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT );
            //获取/list下所有子节点，不注册监听
            List<String> children = zooKeeper.getChildren("/list", false);
            System.out.println(children);
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 9]

## 6、监听 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 10]  
常用监听事件：  
EventType.NodeCreated : 节点创建事件类型  
EventType.NodeDeleted : 节点被删除  
EventType.NodeDataChanged : 节点被修改  
EventType.None : 客户端与服务器成功建立会话  
EventType.NodeChildrenChanged : 子节点列表发生变更

public class zookeeperTest {
    
        public static final String ZOOKEEPER_SERVER = "192.168.1.38:2181";
        private static CountDownLatch countDownLatch = new CountDownLatch(1);
    
        public static void main(String[] args) throws Exception {
            //创建一个会话,url,超时时间，监听机制
            ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_SERVER, 5000, new Watcher() {
                //绑定监听事件
                public void process(WatchedEvent watchedEvent) {
                    if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {
                        System.out.println("连接成功");
                        countDownLatch.countDown();
                    }
                    System.out.println(watchedEvent.getType());
                }
            });
    
            countDownLatch.await();
            zooKeeper.create("/list5", "test".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            zooKeeper.getChildren("/list5", true);
            zooKeeper.create("/list5/list1", "test".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 11]

## 7、获取节点内容 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 12]

public class zookeeperTest {
    
        public static final String ZOOKEEPER_SERVER = "192.168.1.38:2181";
        private static CountDownLatch countDownLatch = new CountDownLatch(1);
    
        public static void main(String[] args) throws Exception {
            //创建一个会话,url,超时时间，监听机制
            ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_SERVER, 5000, new Watcher() {
                //绑定监听事件
                public void process(WatchedEvent watchedEvent) {
                    if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {
                        countDownLatch.countDown();
                    }
                    System.out.println(watchedEvent.getType());
                }
            });
            countDownLatch.await();
            Stat stat = new Stat();
            //设置监听事件
            zooKeeper.getData("/list", true,  stat);
            //修改值
            zooKeeper.setData("/list", "lalal".getBytes(), -1);
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 13]

## 8、检查节点是否存在 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 14]

public class zookeeperTest {
    
        public static final String ZOOKEEPER_SERVER = "192.168.1.38:2181";
        private static CountDownLatch countDownLatch = new CountDownLatch(1);
    
        public static void main(String[] args) throws Exception {
            //创建一个会话,url,超时时间，监听机制
            ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_SERVER, 5000, new Watcher() {
                //绑定监听事件
                public void process(WatchedEvent watchedEvent) {
                    if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {
                        countDownLatch.countDown();
                    }
                    System.out.println(watchedEvent.getType());
                }
            });
            countDownLatch.await();
            zooKeeper.exists("/test", true);
            zooKeeper.create("/test", "data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            zooKeeper.delete("/test", -1);
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 15]

## 9、ZkClient ##

9.1、pom

<dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.6</version>
            </dependency>
            
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>

9.2、demo

public class SessionDemo {
    
        private final static String CONNECTIONSTR = "192.168.1.38:2181";
    
        public static void main(String[] args) throws InterruptedException {
    
            ZkClient zkClient = new ZkClient(CONNECTIONSTR, 4000);
            //递归创建父节点
            zkClient.createPersistent("/test/testa",true);
            //递归删除
            //zkClient.deleteRecursive("/test");
            //获取子节点
            List<String> children = zkClient.getChildren("/test");
            System.out.println(children);
            //监听test节点变化时
            zkClient.subscribeDataChanges("/test", new IZkDataListener() {
                public void handleDataChange(String s, Object o) throws Exception {
                    System.out.println("节点名称: " + s + "-> 节点修改后的值为" + o);
                }
                public void handleDataDeleted(String s) throws Exception {
                }
            });
            zkClient.writeData("/test", "node1");
            zkClient.writeData("/test", "value");
            TimeUnit.SECONDS.sleep(2);
            //当节点变化时
            zkClient.subscribeChildChanges("/test", new IZkChildListener() {
                public void handleChildChange(String s, List<String> list) throws Exception {
                    System.out.println("节点名称:" + s + "->" + "当前节点列表: " + list);
                }
            });
            zkClient.delete("/test/testa");
            TimeUnit.SECONDS.sleep(2);
        }
    
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 16]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/c9311f759dbe4e6790589b7118876d9b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/4a1004fa169e4b3c8737de9555a0e43b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/30cf3b9b0158449bbc8da2c78975d646.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/41d34dfa10a84825b4825ac5941e54e6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/d03d8e44c36d453a87ffc4ad43cb58df.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/ee3a34d255ff43e38b1c2fbb0551e37e.png
[20190822021507167.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/a7752b0f722f4668bbe89f370a995746.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/f835d583edb947769365d4b8e3b5edd0.png
[2019082202152088.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/1c3da0bb284a4ed8b871e4f39708c29a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 7]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/637a495b690a42efa333dee65e9c3b67.png
[20190822021540259.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/84b3c061d1604991b4a889c7355af542.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 8]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/465c92c229614f43a810f556515465fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 9]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/2954d14377494ad9a66a4ba7e6225f53.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 10]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/ac493a3b9baf42ba873ec50fb2fa5db6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 11]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/c98acc5f609f41eebd016546e85af5c8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 12]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/dfdff173a3564ec4a17f51073def34fa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 13]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/76920bae0f1d4130ac0cd361e1fa7c59.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 14]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/7596fa0f68a8497c8a1873665bc07fb5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 15]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/a36b9d48a0434f5daf9b0450b0f33c36.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 16]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/a47395698e3242d3b1754abdac7378b1.png