1. 程式人生 > >zookeeper-Watcher

zookeeper-Watcher

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