zookeeper-Watcher
阿新 • • 發佈:2018-06-13
create nod RoCE 客戶 public pub oid child .com
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。
zookeeper-Watcher