Curator之PathChildrenCache子节点监听

￡神魔★判官ぃ 2022-05-13 14:10 303阅读 0赞

**Curator之PathChildrenCache子节点监听：**

/*子节点监听*/
            //子节点添加watcher
            //PathChildrenCache：监听数据节点的增删改，会触发事件
            String childNodePathCache = nodePath;
            //childData：设置缓存节点的数据状态
            final PathChildrenCache childrenCache = new PathChildrenCache(cto.client,childNodePathCache,true);
    
            /*
            * StartMode：初始化方式
            * POST_INITIALIZED_EVENT：异步初始化。初始化后会触发事件
            * NORMAL：异步初始化
            * BUILD_INITIAL_CACHE：同步初始化
            * */
            childrenCache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);
    
            List<ChildData> childDataList = childrenCache.getCurrentData();
            System.out.println("当前数据节点的子节点数据列表:");
            for(ChildData cd : childDataList){
                String childData = new String(cd.getData());
                System.out.println(childData);
            }
    
            childrenCache.getListenable().addListener(new PathChildrenCacheListener() {
                public void childEvent(CuratorFramework ient, PathChildrenCacheEvent event) throws Exception {
                   if(event.getType().equals(PathChildrenCacheEvent.Type.INITIALIZED)){
                       System.out.println("子节点初始化成功");
                   }else if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_ADDED)){
                       System.out.println("添加子节点路径:"+event.getData().getPath());
                       System.out.println("子节点数据:"+new String(event.getData().getData()));
                   }else if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_REMOVED)){
                       System.out.println("删除子节点:"+event.getData().getPath());
                   }else if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){
                       System.out.println("修改子节点路径:"+event.getData().getPath());
                       System.out.println("修改子节点数据:"+new String(event.getData().getData()));
                   }
                }
            });

![在这里插入图片描述][70]![在这里插入图片描述][70 1]

[70]: https://img-blog.csdn.net/20181024174828388?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI2NjQxNzgx/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 1]: /images/20220504/897128da6f324ad2a9dd6ba0c01fb1b4.png