zookeeper-Watcher

Posted 2020-11-18 zhangwanhua

　　zookeeper的客户端会从它连接的服务端接收到各种消息，通过注册实现Watcher接口就可以来处理这些事件。

类图结构

　　

Watcher

　　消息处理接口。

public interface Watcher {
    abstract public void process(WatchedEvent event);
}

消息类型

消息	解释
None
NodeCreated	节点创建
NodeDeleted	节点删除
NodeDataChanged	节点数据改变
NodeChildrenChanged	子节点发生变化

 

ClientWatchManager

　　消息处理接口管理器，当发送响应事件时，调用materialize方法返回Watcher集合。ClientWatchManager本身不负责Watcher执行，它只负责在响应事件下管理Watcher。

public interface ClientWatchManager {
    public Set<Watcher> materialize(Watcher.Event.KeeperState state, Watcher.Event.EventType type, String path);
}

WatchRegistration

　　负责Watcher注册，底层向ClientWatchManager添加Watcher。