1. 程式人生 > 實用技巧 >zookeeper的JAVA API操作

zookeeper的JAVA API操作

1. idea新建一個Java的maven工程:

pom.xml加入以下依賴(我zk服務裝的3.5.8,但是pom引入總是失敗,親測3.4.11可以成功,也就是客戶端版本不一定要和服務端版本一致)


<dependencies>

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

</dependencies>






2. 新建一個類編寫一個main方法

import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

public class Zk {

public static void main(String[] args) throws Exception
{
String connStr = "master:2181,slave1:2181,slave2:2181";

ZooKeeper zk = new ZooKeeper(connStr, 3000, null);

//新增內容上ZK服務端去 zk.create("/sea/javaApi/node_1","node_1".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

//查詢ZK服務端內容
byte[] data1 = zk.getData("/sea/javaApi/node_1", null, new Stat());
byte[] data2 = zk.getData("/sea/company1", null, new Stat());

zk.close();
System.out.println("/sea/javaApi/node_1="+new String(data1));
System.out.println("/sea/company1="+new String(data2));

}


}


3.執行main方法,IDEA控制檯得到如下結果:


從服務端Cli命令列檢視結果一致,說明JAVA api客戶端訪問結果正常:

4. 其他delete刪除,set修改,watch方法請自己參照官方或者網路文章即可同樣調試出來