共計 1321 個字符，預計需要花費 4 分鐘才能閱讀完成。

如何調用 Java API 來創建一個最基本的 Zookerper，針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

下面介紹如何調用 Java API 來創建一個最基本的 Zookerper 會話實例

代碼清單

import java.util.concurrent.CountDownLatch;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooKeeper;
public class zookeeper_simple_usage implements Watcher { private static CountDownLatch connectedSemaphore = new CountDownLatch(1);
 
 public static void main (String[] args) throws Exception{
 
 ZooKeeper zookeeper = new ZooKeeper( 202.201.13.55:2100 ,
 5000,
 new zookeeper_simple_usage());
 System.out.println(zookeeper.getState());
 try{ connectedSemaphore.await();
 }
 catch (InterruptedException e){}
 
 System.out.println( ZooKeeper session established. 
 }
 
 public void process(WatchedEvent event) { System.out.println( Received watched evnet:   + event);
 
 if (KeeperState.SyncConnected == event.getState()) { connectedSemaphore.countDown();
 }
 }
}

必須重載 WatchedEvent 中的 process 方法。

執行結果

Received watched evnet: WatchedEvent state:SyncConnected type:None path:null
ZooKeeper session established.

依賴包

需要在 Build Path 中添加四個包

zookerper-3.4.6.jar

log4j-1.2.14.jar

slf4j-api-1.7.12.jar

slf4j-simple-1.7.12.jar

不然會報找不到類的錯誤。

關于如何調用 Java API 來創建一個最基本的 Zookerper 問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注丸趣 TV 行業資訊頻道了解更多相關知識。