ZkClient watch 操作

忘是亡心i 2022-02-02 06:49 305阅读 0赞

文章目录

      • 1、依赖
      • 2、zkClient.subscribeChildChanges() 监听当前节点和下面子节点的新增、删除
        • 2.1、运行结果：
      • 3、zkClient.subscribeDataChanges() 监听 当前节点和子节点的内容修改、删除
        • 3.1、运行结果：

1、依赖

  1. <dependency>
  2.     <groupId>com.101tec</groupId>
  3.     <artifactId>zkclient</artifactId>
  4.     <version>0.10</version>
  5. </dependency>

2、zkClient.subscribeChildChanges() 监听当前节点和下面子节点的新增、删除

监听当前节点和下面子节点的新增、删除。不监听数据发生修改和变化。

参数说明：

  • 第1个参数： 路径path，要监听的节点

  • 第2个参数：这个一个回调函数，要实现 IZkChildListener 接口，并重写 subscribeChildChanges()

    package com.aop8.zkclient.watcher;

    public class ZkClientWatcher1 { 

    1. /** session超时时间 */
    2. static final int SESSION_OUTTIME = 5000;//ms 
    4. public static void main(String[] args) throws Exception { 
    5.     ZkClient zkc = new ZkClient(new ZkConnection("127.0.0.1:2181"), 5000);
    7.     //对父节点添加监听子节点变化。
    8.     zkc.subscribeChildChanges("/super", new IZkChildListener() { 
    9.         @Override
    10.         public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception { 
    11.             System.out.println("parentPath: " + parentPath);
    12.             System.out.println("currentChilds: " + currentChilds);
    13.         }
    14.     });
    16.     Thread.sleep(3000);
    18.     zkc.createPersistent("/super");
    19.     Thread.sleep(1000);
    21.     zkc.createPersistent("/super" + "/" + "c1", "c1内容");
    22.     Thread.sleep(1000);
    24.     zkc.createPersistent("/super" + "/" + "c2", "c2内容");
    25.     Thread.sleep(1000);        
    27.     zkc.delete("/super/c2");
    28.     Thread.sleep(1000);    
    30.     zkc.deleteRecursive("/super");
    31.     Thread.sleep(Integer.MAX_VALUE);        
    32. }

    }

2.1、运行结果：

  1. parentPath: /super
  2. currentChilds: []
  3. ============添加 c1 ==============
  4. parentPath: /super
  5. currentChilds: [c1]
  6. ============添加 c2 ==============
  7. parentPath: /super
  8. currentChilds: [c1, c2]
  9. ============删除 c2 ==============
  10. parentPath: /super
  11. currentChilds: [c1]
  12. ============删除 super ==============
  13. parentPath: /super
  14. currentChilds: null
  15. parentPath: /super
  16. currentChilds: null

3、zkClient.subscribeDataChanges() 监听 当前节点和子节点的内容修改、删除

这是一个回调函数，要实现 IZkDataListener 接口，并重写 handleDataChange() 和 handleDataDeleted() 两个方法。

  1. package com.aop8.zkclient.watcher;
  4. public class ZkClientWatcher2 { 
  6.     /** session超时时间 */
  7.     static final int SESSION_OUTTIME = 5000;//ms 
  10.     public static void main(String[] args) throws Exception { 
  11.         ZkClient zkc = new ZkClient(new ZkConnection("127.0.0.1:2181"), 5000);
  13.         zkc.createPersistent("/super", "1234");
  15.         //对父节点添加监听子节点变化。
  16.         zkc.subscribeDataChanges("/super", new IZkDataListener() { 
  18.             @Override
  19.             public void handleDataChange(String path, Object data) throws Exception { 
  20.                 System.out.println("变更的节点为:" + path + ", 变更内容为:" + data);
  21.             }
  23.             @Override
  24.             public void handleDataDeleted(String path) throws Exception { 
  25.                 System.out.println("删除的节点为:" + path);
  26.             }            
  27.         });
  29.         Thread.sleep(3000);
  30.         zkc.writeData("/super", "456", -1);
  31.         Thread.sleep(1000);
  33.         zkc.delete("/super");
  34.         Thread.sleep(Integer.MAX_VALUE);
  36.         zkc.close();
  37.     }
  38. }

3.1、运行结果：

  1. 变更的节点为:/super, 变更内容为:456 
  2. 删除的节点为:/super

发表评论

表情：
评论列表 （有 0 条评论，305人围观）

还没有评论，来说两句吧...

相关阅读