首先是pom依賴：

<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 會話時間private static final int SESSION_OUTTIME = 2000;//信號量,阻塞程序執行,用戶等待zookeeper連接成功,發送成功信號，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) {// 獲取事件狀態KeeperState keeperState = event.getState();// 獲取事件類型EventType eventType = event.getType();if (KeeperState.SyncConnected == keeperState) {if (EventType.None == eventType) {//如果收到了服務端的響應事件，連接成功countDownLatch.countDown();System.out.println("keeperState:"+keeperState);System.out.println("eventType:"+eventType);System.out.println("zk 啟動連接...");}};}});// 如果countDownLatch不為0，會一直進行阻塞countDownLatch.await();//參數一：節點名稱；參數二：data數據.getBytes()意為將data變為字節數組；參數三：ids為節點權限；參數三：CreateMode為節點類型；String result = zk.create("/qushen001", "info".getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);System.out.println(result);zk.close();}}

?

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。