Java客户端_zkclient库操作Zookeeper-Toy模板网

这篇具有很好参考价值的文章主要介绍了Java客户端_zkclient库操作Zookeeper。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

使用zookeeper遇到问题：

重复注册watcher

session失效重连

异常处理（删除节点不能有子节点，新增节点必须有父节点等）

zkclient是Github上一个开源的Zookeeper客户端，在Zookeeper原生 API接口之上进行了包装，是一个更加易用的Zookeeper客户端。同时Zkclient在内部实现了诸如Session超时重连，Watcher反复注册等功能，从而提高开发效率。文章来源地址https://www.toymoban.com/news/detail-731335.html

添加依赖

<dependency>
   <groupId>com.101tec</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.10</version>
</dependency>

创建会话

String connStr = "192.168.154.128:2181";
ZkClient zk = new ZkClient(connStr);

创建节点

String res = zk.create("/root", "hgy", CreateMode.PERSISTENT);

修改节点数据

zk.writeData("/root", "hgy");

获取节点数据

String res = zk.readData("/root");

删除节点

zk.delete("/root");

注册数据监听

   zk.subscribeDataChanges("/root/ghz", new IZkDataListener() {


       @Override
       public void handleDataDeleted(String arg0) throws Exception {
         System.err.println("数据删除:" + arg0);
       }
       @Override
       public void handleDataChange(String arg0, Object arg1) throws Exception {
         System.err.println("数据修改:" + arg0 + "------" + arg1);


       }
     });

注册节点监听

zk.subscribeChildChanges("/root", (arg0, arg1) -> {
       System.err.println("子节点发生变化：" + arg0);
       arg1.forEach(f -> {
         System.out.println("content：" + f);
       });
     });

到了这里，关于Java客户端_zkclient库操作Zookeeper的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！