zk的watch机制详细介绍
这篇文章主要介绍“zk的watch机制详细介绍”,在日常操作中,相信很多人在zk的watch机制详细介绍问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”zk的watch机制详细介绍”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
目前成都创新互联公司已为近1000家的企业提供了网站建设、域名、雅安服务器托管、网站托管、企业网站设计、丰宁网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。
WatchManager中watch机制
watcher作用:通知状态与事件类型 接口定义了process方法,定义了Event接口,包含KeeperState(通知时zk状态),EventType说明event类型
void process(WatchedEvent event);回调函数实现该函数,表示该event执行行为相关逻辑
WatchedEvent
描述zk检测到的状态变化事件,回应变化,发生了什么,zk当前状态,发生事件znode的路径
/**将属性转换成网络传输的WatcherEvent
* Convert WatchedEvent to type that can be sent over network
*/
public WatcherEvent getWrapper() {
return new WatcherEvent(eventType.getIntValue(), keeperState.getIntValue(), path);
}
WatcherEvent
是一个接口,实现了Record,属性有type,state,path,是网络传输的封装
ClientWatchManager接口
根据event得到需要通知的watcher集合,实现类为ZKWatcherManager
属性:
private final Map> dataWatches = new HashMap >();//数据监听集合 private final Map > existWatches = new HashMap >();//已经存在监听集合 private final Map > childWatches = new HashMap >();//子节点监听集合 private boolean disableAutoWatchReset; ZKWatchManager(boolean disableAutoWatchReset) { this.disableAutoWatchReset = disableAutoWatchReset; } protected volatile Watcher defaultWatcher;
方法:添加watcher
删除watcher 三种类型节点的集合变化
涉及监听类型 enum WatcherType { Children(1), Data(2), Any(3); }
materialize()实现方法
WatcherSetEventPair
将event以及对应需要触发的watches集合进行组合绑定,是一个包装类
private static class WatcherSetEventPair { private final Setwatchers; private final WatchedEvent event; public WatcherSetEventPair(Set watchers, WatchedEvent event) { this.watchers = watchers; this.event = event; } }
UML类图
zk中引入watcher机制来实现通知功能
zk允许客户端向服务端注册一个监听,指定事件触发监听时,服务端向客户端发送监听事件通知,以便客户端完成逻辑操作
特性:
一次性,watcher被触发,zk都将它从相应的相应存储中移除,注册一次,触发一次
客户端串行执行,客户端watcher回调是一个串行过程
轻量:包含事件类型 通知状态,节点路径
到此,关于“zk的watch机制详细介绍”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!
网站标题:zk的watch机制详细介绍
文章链接:http://scyanting.com/article/pdjcch.html