ZooKeeper Watch筆記

1、Watcher詳解、接口    在 ZooKeeper 中， 接口類 Watcher 用于表示一個標(biāo)注你的事件處理器，其定義了事件通知相關(guān)的邏輯，包含 KeeperState 和 EventType 兩個枚舉類，分別代表了通知狀態(tài)和事件類型，同時定義了事件的回調(diào)方法：process（WatchedEvent event）Watcher 觸發(fā)條件：    增、刪、改 ( 重復(fù)修改也會觸發(fā)，因為他只告訴你變更了，不告訴你變更多少，需要 C 自己去拿）abstract public  void process ( WatchedEvent event

2、 )。    process() 是 Watch 接口中的回調(diào)方法。當(dāng) ZooKeeper 向客戶端發(fā)送一個 Watcher 時間通知時，客戶端就會對相應(yīng)的 process 方法進(jìn)行回調(diào)，從而實現(xiàn)對事件的處理。 like this：syncNodes（）方法。        Watcher 設(shè)置是開發(fā)中最常見的，需要搞清楚watcher的一些基本特征，對于exists、getdata、getchild對于節(jié)點的不同操作會收到不同的 watcher信息對父節(jié)點的變更以

3、及子節(jié)點的變更都不會觸發(fā)watcher，而對watcher本身節(jié)點以及子節(jié)點的變更會觸發(fā)watcher繼續(xù)。ZooKeeper 使用 WatchedEvent 對象封裝服務(wù)端事件并傳遞給 Watcher， 從而方便回調(diào)方法 process 對服務(wù)端事件進(jìn)行處理。WatcherEvent 實體實現(xiàn)了序列化接口，因此可以用于網(wǎng)絡(luò)傳輸。數(shù)據(jù)結(jié)構(gòu)如下。Class WatcherEvent  type:int  state:int  path:Stringstate=-112 會話超時狀態(tài)state= -113認(rèn)證失敗狀態(tài)state= 

4、0;1 連接建立中state= 2 (暫時不清楚如何理解這個狀態(tài),ZOO_ASSOCIATING_STATE)state=3 連接已建立狀態(tài)state= 999 無連接狀態(tài)type=1 創(chuàng)建節(jié)點事件type=2 刪除節(jié)點事件type=3 更改節(jié)點事件type=4 子節(jié)點列表變化事件type= -1 會話session事件type=-2 監(jiān)控被移除事件Watcher 發(fā)送過程。        當(dāng)服務(wù)端產(chǎn)生 WatchedEvent 事件之后，會調(diào)用 getWrapper 方法將自己包裝成一個可序列化的 Watcher

5、Event 事件，以便于通過網(wǎng)絡(luò)傳輸?shù)娇蛻舳?。客戶端在接收到服?wù)端的這個事件對象后，首先會將 WatcherEvent 事件還原成一個 WatchedEvent 事件。并傳遞給 process方法處理。 回調(diào)方法根據(jù)傳入?yún)?shù)解析完整服務(wù)端事件。Watcher 發(fā)送的數(shù)據(jù)            無論是 WatcherEvent 還是 WatchedEvent，他對 ZooKeeper 服務(wù)端事件的封裝都是極其簡單的。 當(dāng) /Test/te

6、st1/1_1節(jié)點發(fā)生變更時，服務(wù)端會發(fā)送給客戶端一個“ZNode數(shù)據(jù)變更“ 事件，客戶端也只能接收到如下信息：    KeeperState : SyncConnected    EventType : NodeDataChanged    Path : /zk-b            也就是說，客戶端無法直接從該事件中獲取到對應(yīng)數(shù)據(jù)節(jié)點的原始數(shù)據(jù)內(nèi)容，以及變更后的新數(shù)據(jù)內(nèi)容。而是客戶端再次主動去重新獲取數(shù)據(jù)。這個也是 ZooKeeper 一個非常重要

7、的特性。Watcher 工作機(jī)制服務(wù)端發(fā)送不處理邏輯、客戶端發(fā)送并處理邏輯。客戶端注冊 Watcher        創(chuàng)建一個 new ZooKeeper（） 客戶端對象實例時，可以傳入一個 Watcher .      new ZooKeeper(String connectString,int sessionTimeout, Watcher watcher)       

8、  這個Watcher 將作為整個 ZooKeeper 回話期間的默認(rèn) Watcher，會一直被保存在客戶端 ZKWatchManager 的 defaultWatcher 中。 另外，ZooKeeper 客戶端也可以通過 getData、 getChildren 和 exist 三個接口來向 ZooKeeper 服務(wù)器注冊 Watcher。 列舉個getData 例：            public byte getData(String path,

9、boolean watch, Stat stat)      public byte getData(final String path,Watcher watch, Stat stat)        第一個通過一個 boolean 參數(shù)來標(biāo)識是否使用默認(rèn) Watcher 進(jìn)行注冊，具體注冊邏輯與第二個接口一致。注冊 Watcher 后     

10、   在 getData 接口注冊 Watcher 后，客戶端首先會對當(dāng)前客戶端請求 request 進(jìn)行標(biāo)記， 將其設(shè)置為 ”使用Watcher“監(jiān)聽。同時會封裝一個 Watcher 的注冊信息，WatchRegistration 對象。 用于暫時保存數(shù)據(jù)節(jié)點的路徑 和 Watcher 的對應(yīng)關(guān)系。Packet 與 WatchRegistration。 Packet 類        在 ZooKeeper 中 Packet 可以看做是一個最小的通信協(xié)議單元，用于進(jìn)行客戶端與服務(wù)端之間的網(wǎng)絡(luò)傳輸，任何需要傳輸?shù)膶ο蠖夹枰?/p>

11、裝成一個 Packet 對象。 因此，在 ClientCnxn 中 WatchRegistration 又會被封裝到 Packet 中去， 然后放入發(fā)送隊列中等待客戶端發(fā)送。隨后，ZooKeeper 客戶端就會向服務(wù)端發(fā)送這個請求，同時等待請求的返回。完成請求發(fā)送后，會由客戶端 SendThread 線程的 readResponse 方法負(fù)責(zé)接收來自服務(wù)端的相應(yīng)， finishPacket 方法會從 Packet 中取出對象的 Watcher 并注冊到 ZKWatchManager 中去。        WatchRegis

12、tration 封裝到了 Packet 對象中去，但事實上，在底層的網(wǎng)絡(luò)傳輸過程中，沒有將 WatchRegistration 對象完全的序列化到底層字節(jié)數(shù)組中去。ZooKeeper 只會將 requestHeader 和 request 兩個屬性進(jìn)行序列化。 也就是說，即使WatchRegistration 對象唄封裝在了 Packet 中，但是并沒有被序列化到底層字節(jié)數(shù)組中去。因此也就不會進(jìn)行網(wǎng)絡(luò)傳輸了。客戶端 Watcher 的注冊流程如下：       服務(wù)端注冊 Watcher 服務(wù)端處理 Watcher 的序列圖：1 Fi

13、nalRequest PcessRequest( ) 中會判斷當(dāng)前請求是否是需要注冊 Watcher：        1） 如果 ZooKeeper 判斷當(dāng)前客戶端需要進(jìn)行 Watcher 注冊，于是就會將當(dāng)前的 ServerCnxn 對象和數(shù)據(jù)路徑傳入 getData 方法中去。 ServerCnxn 是一個 ZooKeeper 客戶端和服務(wù)器之間的連接接口，代表了一個客戶端和服務(wù)器的連接。我們可以 ServerCnxn 看做是一個 Watcher 對象。因為他實現(xiàn)了 Watcher 的 proce

14、ss 接口WatcherManager    是 ZooKeeper 服務(wù)端 Watcher 的管理者，其內(nèi)部管理的 watchTable 和 watch2Paths 兩個存儲結(jié)構(gòu)，分別從兩個維度對 Watcher 進(jìn)行存儲。    1） watchTable     是從數(shù)據(jù)節(jié)點路徑的粒度管理 Watcher。    2） watch2Paths   是從 Watcher 的粒度來控制事件觸發(fā)的數(shù)據(jù)節(jié)點在服務(wù)端，DataTree 中會托管兩個 Watch

15、Manager， 分別是 dataWatches （數(shù)據(jù)變更Watch） 和 childWatches（子節(jié)點變更Watch）。Watcher 觸發(fā)邏輯     1    封裝 WatchedEvent。            將通知狀態(tài) - KeeperState、事件類型 - EventType、節(jié)點路徑 - Path 封裝成一個 WatchedEvent 對象     2    查

16、詢 Watcher。             根據(jù)路徑從 watchTable 中取出對應(yīng)的 Watcher。若無-沒注冊 直接退出。若有-注冊過 將數(shù)據(jù)提取出來 同時 從wTable w2Paths 中刪除掉。 Watcher 在服務(wù)端也是一次性的     3    調(diào)用 process 方法觸發(fā) Watcher             ZooK

17、eeper 會把當(dāng)前請求對應(yīng)的 ServerCnxn 作為一個 Watcher 存儲，因此調(diào)用 process 方法，事實上就是 ServerCnxn 對應(yīng)的 process 方法。客戶端回調(diào) Watcher      1    反序列化                字節(jié)流轉(zhuǎn)換成 WatcherEvent 對象      2    處理 chrootPath

18、0;               如果客戶端設(shè)置了 chrootPath 屬性，那么需要對服務(wù)器傳過來的完整節(jié)點路徑進(jìn)行 chrootPath 處理，生成客戶端的一個相對節(jié)點路徑。 例如客戶端 cPath路徑 /Test/test1 那么針對服務(wù)端傳過來的相應(yīng)包含的節(jié)點路徑為/Test/test1/1_19， 經(jīng)過chrootPath 處理后 會變成一個相對路徑：/ 1_19.      3    還原 WatchedEvent

19、0;               WatcherEvent 轉(zhuǎn)換成 WatchedEvent.      4    回調(diào) Watcher。                最后將 WatcherEvent 對象交給 EventThread 線程，在下一個輪詢周期中進(jìn)行 Watcher 回調(diào)。EventThread 處理時間通知。&

20、#160;       SendThread 接收到服務(wù)端的通知事件后，會通過調(diào)用 EventThread.queueEvent 方法將事件傳給 EventThread 線程。queueEvent 方法首先會根據(jù)該通知事件，從 ZKWatchManager 中取出所有相關(guān)的 Watcher 客戶端識別出 事件類型 EventType 后，會從相應(yīng)的 Watcher 存儲 （即3個注冊方法）中去除對應(yīng)的 Watcher。獲取到相關(guān)的所有 Watcher 后，會將其放入 waitingEvents 這個隊列去。    

21、        注意 此處調(diào)用的是 remove 接口。 客戶端的 Watcher 同樣也是一次性的。即一旦被觸發(fā)，該Watcher 就失效了。        3個注冊方法： dataWatches、existWatcher 或 childWatcher 中的一個或多個        waitingEvents 是一個待處理 Watcher 的隊列，EventThread 的 run 方法會不斷對該隊列進(jìn)行處理Watcher 特性總結(jié)：    一次性        &