創建閉鎖,確保能連接到zk服務器。
// 創建閉鎖
final CountDownLatch countDownLatch = new CountDownLatch(1);
String connectString="139.196.31.237:2181";
int sessionTimeout=5000;
// 創建ZooKeeper對象
ZooKeeper zooKeeper = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
@Override
public void process(WatchedEvent watchedEvent) {
System.out.println("連接zk成功!watchedEvent:"+watchedEvent.getState());
countDownLatch.countDown();
}
});
// 利用閉鎖的await()方法產生阻塞,等待連接zk的線程執行完畢
countDownLatch.await();
詳情請參考:https://www.2cto.com/net/201803/725311.html