Zookeeper watcher源码底层分析
Zookeeper的Watcher机制
Zookeeper提供了数据的发布/订阅功能,多个订阅者可同时监听某一特定主题对象,当该主题对象的自身状态发生变化时(例如节点内容改变、节点下的子节点列表改变等),会实时、主动通知所有订阅者。
watcher架构
Watcher实现由三个部分组成:
Zookeeper服务端;
Zookeeper客户端;
客户端的ZKWatchManager对象;
客户端首先将Watcher注册到服务端,同时将Watcher对象保存到客户端的Watch管理器中。当ZooKeeper服务端监听的数据状态发生变化时,服务端会主动通知客户端,接着客户端的Watch管理器会触发相关Watcher来回调相应处理逻辑,从而完成整体的数据发布/订阅流程。
Watcher特性
一次性 Watcher是一次性的,一旦被触发就会移除,再次使用时需要重新注册
客户端顺序回调 Watcher回调是顺序串行化执行的,只有回调后客户端才能看到最新的数据状态。一个Watcher回调逻辑不应该太多,以免影响别的watcher执行
轻量级 WatchEvent是最小的通信单元,结构上只包含通知状态、事件类型和节点路径,并不会告诉数据节点变化前后的具体内容
时效性 Watcher只有在当前session彻底失效时才会无效,若在session有效期内快速重连成功,则watcher依然存在,仍可接收到通知;
Watcher接口设计
Watcher是一个接口,任何实现了Watcher接口的类就是一个新的Watcher。Watcher内部包含了两个枚举类:KeeperState、EventType
Watcher注册及通知流程
客户端Watcher管理器:ZKWatchManager数据结构
服务端Watcher管理器:WatchManager数据结构
Watcher注册流程
Watcher通知流程