zookeeperjava

1. 如何解決java介面訪問ZooKeeper時的connectionloss錯誤

常見錯誤日誌如下：
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss

1. 原因：
是因為ZooKeeper建立連接時採用非同步操作，連接操作後並不能保證ZK連接已成功。如果在ZK連接成功前的這個小時間窗口去訪問ZK，就會碰到如上錯誤。
2. 解決思路
我們在新建ZK連接後要等一段時間，保證連接成功後再訪問ZK。

3. 網上比較贊同的解決方案:
主要利用兩個Java類：

（1）java.util.concurrent.CountDownLatch：
一個同步輔助類，類似倒數計數，直到計數器為0時才能對資源「解鎖」。未解鎖前等待該資源的進程只能被阻塞。

主要方法：
public CountDownLatch(int count); /* 構造函數,參數指定計數次數 */
public void countDown(); /* 當前線程調用此函數，則計數減一 */
public void await() throws InterruptedException; /* 此函數會一直阻塞當前線程，直到計時器的值為0為止 */

（2）org.apache.zookeeper.Watcher
ZooKeeper有一個很有用的功能，就是集群上每一個變化都可以通知到自定義的Watchcer。