日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > java >内容正文

java

Zookeeper JavaApi 增删改查

發布時間:2025/3/11 java 34 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Zookeeper JavaApi 增删改查 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.


官網API

http://zookeeper.apache.org/doc/r3.4.6/api/index.html


JAR包

\zookeeper-3.3.6\lib\
jline-0.9.94.jar


\zookeeper-3.3.6\lib\
log4j-1.2.15.jar


\zookeeper-3.3.6\
zookeeper-3.3.6.jar


Demo代碼


注意代碼中的注解

package hello.zookeeper.api;import java.util.List;import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.ZooDefs.Ids; import org.junit.Before; import org.junit.Test; import org.apache.zookeeper.ZooKeeper;public class ZkClient {/** 此處必須與zookeeper的zoo.cfg中一樣* zk會選擇一個連接* 如果windows上運行,hosts也要配置一致*/private static final String connString="zk1:2181,zk2:2181,zk3:2181";/** 超時:連接超時,同步時間間隔,zk有節點值變更,在這個時間內同步*/private static final int sessionTimeout=2000;private ZooKeeper zk=null;@Beforepublic void init() throws Exception{zk=new ZooKeeper(connString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {System.out.println("監聽器:"+event.getType()+"-"+event.getPath());}});}@Testpublic void create() throws Exception{String path="/eclipse";if(zk.exists(path, false)==null){String msg=zk.create(path, "helloworld".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);System.out.println("create:"+msg);}else{System.out.println(path+"已存在!");}}@Testpublic void getChildren() throws Exception{List<String> children = zk.getChildren("/", true);if(children!=null&&children.size()>0){System.out.println("子目錄如下:");for(String s:children){System.out.println(s);}}}@Testpublic void setData() throws Exception{//-1表示刪除所有版本zk.setData("/eclipse", "hello earth !".getBytes(), -1);getData();}@Testpublic void getData() throws Exception{byte[] data = zk.getData("/eclipse", true, null);System.out.println("getData():"+new String(data));}@Testpublic void deleteZnode() throws Exception{zk.delete("/eclipse", -1);getChildren();}}

-------------

更多的Java,Angular,Android,大數據,J2EE,Python,數據庫,Linux,Java架構師,:

http://www.cnblogs.com/zengmiaogen/p/7083694.html


總結

以上是生活随笔為你收集整理的Zookeeper JavaApi 增删改查的全部內容,希望文章能夠幫你解決所遇到的問題。

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