zookeeper的JAVA API操作
阿新 • • 發佈:2020-08-14
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方法請自己參照官方或者網路文章即可同樣調試出來