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方法請自己參照官方或者網絡文章即可同樣調試出來