先談談watcher和watcheEvent

剛學zookeeper的時候，都會被坑一次，以為watcher的監聽是永久的。其實不然，watcher在大多數時候都只調用一次。
zookeeper使用HashMap<Path,Watcher>維護了所有路徑的watcher，

private static class ZKWatchManager implements ClientWatchManager {    
private final Map<String, Set<Watcher>> dataWatches = new HashMap<String
 
, Set<Watcher>>();  
private final Map<String, Set<Watcher>> existWatches = new HashMap<String, Set<Watcher>>();    
private final Map<String, Set<Watcher>> childWatches = new HashMap<String, Set<Watcher>>();

所有不論註冊多少次，都只會有一個watcher存在。當watcheEvent產生的時候，會移除對應path的watcher，並且回撥。

然而，當type=None的時候，就不會移除watcher，會向所有watcher傳送事件。

何時會產生type=None的事件呢？狀態轉變的時候！

初始化的sessionState=Disconnected，
所以第一次ping成功，（zookeeper client會不斷的給server傳送ping指令）
會產生一個watchEvent:State=SyncConnected，type=None，
此時sessionState=SyncConnected，所以後續的ping就不會產生事件了。
當zk監聽watcher的時候，如果發生網路斷鏈，且在sessionTimeout/2的時間內都沒有恢復連線。
那麼所有註冊的watcher都會接收到
state=Disconnected,type=None,path=Null的watchEvent

• 如果在剩下sessionTimeout/2的時間內恢復連線，即ping通了
  那麼就會收到watchEvent:state=SyncConnected,type=None，path=Null
• 如果超過sessionTimeout時間恢復連線，那麼就會收到
  watchEvent:state=Expired,type=None,path=Null
  此時表示zookeeper客戶端真正與服務端失去連線，就需要重建zookeeper的客戶端了。
• 如果超過sessionTimeout時間也沒恢復連線，只有等恢復連線才會收到Expired事件。

所以對於watcheEvent的事件的處理方式是:

• DisConneted 無視，因為連不上你做啥事都沒用，也就改改某些狀態，能連上的話要麼收到SyncConneted事件，要麼收到Expired 事件
• Expired重新構建zookeeper客戶端。
• SyncConnected
  • 對於type!=None重新註冊watcher.
  • 對於監聽的type做後續處理

再談談zookeeper客戶端操作的Code

• 同步操作會收到KeeperException
• 非同步操作會收到rc
  對於KeeperException 可以使用code()得到Code，對於rc，可以使用KeeperException.Code.get(rc)得到Code

Code表示你這次操作的結果

例如對於delete(path,version)

• 如果節點存在那麼會收到ok
• 如果節點不存在那麼會收到NoNode

那麼如果是斷連呢？

• 如果正處於斷連，那麼會產生ConnectionLoss。
• 如果sessionExpired或者zookeeper.close那麼會收到sessionExpired

所以對於rc處理方式是:

• ConnectionLoss，區域性重試
• sessionExpired，重建zookeeper客戶端
• 其他，業務邏輯處理。

對於zookeeper的初略理解，有問題可以指點指點。
另外關於測試。
模擬zookeeper的sessionExpired可以看看curator的KillSession