curator 监听数据节点子节点的变化情况

文章目录

PathChildrenCache
API

PathChildrenCache

NodeCache不仅可以监听节点内容变化，还可以监听指定节点是否存在。如果原本节点不存在，那么Cache就会在节点被创建时触发监听事件，如果该节点被删除，就无法再触发监听事件。
PathChildrenCache用于监听数据节点子节点的变化情况。
curator之事件监听详解

API

package com.ruozedata.bigdata.zookeeper;import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.ChildData;
import org.apache.curator.framework.recipes.cache.TreeCache;
import org.apache.curator.framework.recipes.cache.TreeCacheEvent;
import org.apache.curator.framework.recipes.cache.TreeCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.util.concurrent.CountDownLatch;public class PathChildrenListener {private static Logger logger = LoggerFactory.getLogger(PathChildrenListener.class);private static CountDownLatch watch = new CountDownLatch(1);private static final String zkServerIps = "ruozedata000:2181";  //可以写多个地址，逗号分隔private static RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);// 实例化Curator客户端private static CuratorFramework client = CuratorFrameworkFactory.builder()                  // 使用工厂类来建造客户端的实例对象.connectString(zkServerIps)                         // 放入zookeeper服务器ip.sessionTimeoutMs(15000).retryPolicy(retryPolicy)   // 设定会话时间以及重连策略.build();                                           // 建立连接通道/*** 注册监听* TreeCache: 可以将指定的路径节点作为根节点（祖先节点），对其所有的子节点操作进行监听，* 呈现树形目录的监听，可以设置监听深度，最大监听深度为 int 类型的最大值。*/private static void zkWatch(String path) throws Exception {TreeCache treeCache = new TreeCache(client, path);treeCache.getListenable().addListener(new TreeCacheListener() {@Overridepublic void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {ChildData eventData = event.getData();switch (event.getType()) {case NODE_ADDED:logger.warn(path + "节点添加" + eventData.getPath() + "\t添加数据为：" + new String(eventData.getData()));break;case NODE_UPDATED:logger.warn(eventData.getPath() + "节点数据更新\t更新数据为：" + new String(eventData.getData()) + "\t版本为：" + eventData.getStat().getVersion());break;case NODE_REMOVED:logger.warn(eventData.getPath() + "节点被删除");break;default:break;}}});treeCache.start();watch.await();  //如果不执行 watch.countDown()，进程会一致阻塞在 watch.await()}// 获取节点数据private static void getZnode(String path) throws Exception {byte[] bytes = client.getData().forPath(path);                     // 普通查询System.out.println(new String(bytes));}// 关闭连接private static void closeZnode() {if (client != null) {client.close();}}public static void main(String[] args) throws Exception {client.start();         // 启动Curator客户端System.out.println(client.getState());    //获取连接状态String path = "/ruoze";getZnode(path);        // 获取节点数据zkWatch(path);          // 监听这个节点closeZnode();           // 关闭Curator客户端}}

curator 监听数据节点子节点的变化情况相关推荐

Zk监听机制入门和节点属性信息
zk监听主要是监听:节点创建,节点删除,节点改变.子节点改变我这里用node-1和node-3同时连接node-1 zk客户端监听功能一般步骤: 1.客户端设置监听事件命令:get 节点 watc ...
删除父节点子节点未删除的两种方法
删除父节点子节点未删除的两种方法平时所使用的tree删除父节点,子节点还保留在数据库. 删除前: 删除后: 父节点已删除,但数据库保留了子节点数据,以下有两种方法解决方法一: 使用递归删除方法,我 ...
js给php注册网页添加实时监听,js 实现watch监听数据变化的代码
1.js /** * @desc 属性改变监听,属性被set时出发watch的方法,类似vue的watch * @author Jason * @study https://www.jianshu.c ...
微信小程序，实现 watch 属性，监听数据变化
转自微信小程序,实现 watch 属性,监听数据变化目标在微信小程序实现 watch 属性,监听 data 中的属性,当被监听属性的值改变时,执行我们指定的方法. 思路 Vue 的 compu ...
linux 监听数据包,linux下网络监听与发送数据包的方法(即libpcap、libnet两种类库的使用方法)...
linux下可以用libpcap函数库实现监听数据包,使用libnet 函数库发送数据包安装: 在命令行下apt-get install 就可以了 libpcap的使用: /*author hjj ...
vue，watch监听数据，数据监听
vue,watch监听数据,数据监听三个值: 1.第一个handler:其值是一个回调函数.即监听到变化时应该执行的函数. 2.第二个是deep:其值是true或false:确认是否深入监听.(一般 ...
JavaWeb项目监听数据表变化并通知前台(数据来源于自身)
最近公司有些项目中需要java程序去监听数据表,当数据有变化时把新数据通知前台并且展示出来.本人也去百度上查询了好多相关知识(本意是有现成抄的就直接抄,哈哈,但无奈没有),然后根据自己的理解写了个de ...
ROS2学习笔记22--使用launch启动／监听多个node节点
概要:这篇内容主要介绍如何使用launch启动/监听多个node节点环境:ubuntu20.04,ros2-foxy,vscode 最后如果没有陈述实操过程中碰到问题的话,则表示该章节都可被本人正常 ...
VB6 Treeview的添加节点子节点、Treeview打开、Treeview关闭
=================== VB6 Treeview的添加节点子节点.Treeview打开.Treeview关闭 '在窗体上方一个Treeview,四个command Option ...

curator 监听数据节点子节点的变化情况

文章目录

PathChildrenCache

API

curator 监听数据节点子节点的变化情况相关推荐

最新文章

热门文章