首先是pom依賴(lài)：

<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version></dependency>

?java操作zookeeper：

import java.io.IOException; import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.Watcher.Event.EventType; import org.apache.zookeeper.Watcher.Event.KeeperState; import org.apache.zookeeper.ZooDefs.Ids; import org.apache.zookeeper.ZooKeeper;public class TestZookeeper {//連接地址private static final String ADDRES = "127.0.0.1:2181";//session 會(huì)話時(shí)間private static final int SESSION_OUTTIME = 2000;//信號(hào)量,阻塞程序執(zhí)行,用戶(hù)等待zookeeper連接成功,發(fā)送成功信號(hào)，private static final CountDownLatch countDownLatch = new CountDownLatch(1);public static void main(String[] args) throws IOException, InterruptedException, KeeperException {ZooKeeper zk = new ZooKeeper(ADDRES, SESSION_OUTTIME, new Watcher() {@Overridepublic void process(WatchedEvent event) {// 獲取事件狀態(tài)KeeperState keeperState = event.getState();// 獲取事件類(lèi)型EventType eventType = event.getType();if (KeeperState.SyncConnected == keeperState) {if (EventType.None == eventType) {//如果收到了服務(wù)端的響應(yīng)事件，連接成功countDownLatch.countDown();System.out.println("keeperState:"+keeperState);System.out.println("eventType:"+eventType);System.out.println("zk 啟動(dòng)連接...");}};}});// 如果countDownLatch不為0，會(huì)一直進(jìn)行阻塞countDownLatch.await();//參數(shù)一：節(jié)點(diǎn)名稱(chēng)；參數(shù)二：data數(shù)據(jù).getBytes()意為將data變?yōu)樽止?jié)數(shù)組；參數(shù)三：ids為節(jié)點(diǎn)權(quán)限；參數(shù)三：CreateMode為節(jié)點(diǎn)類(lèi)型；String result = zk.create("/qushen001", "info".getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);System.out.println(result);zk.close();}}

?

總結(jié)

以上是生活随笔為你收集整理的ZooKeeper入门（二）Java操作zookeeper的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。