ZooKeeper Java API

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了ZooKeeper Java API，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2153字，纯文字阅读大概需要4分钟。

内容图文

org.apache.zookeeper.Zookeeper
Zookeeper 是在 Java 中客户端主类，负责建立与 zookeeper 集群的会话， 并提供方法进行操作。
org.apache.zookeeper.Watcher
Watcher 接口表示一个标准的事件处理器，其定义了事件通知相关的逻辑， 包含 KeeperState 和 EventType 两个枚举类，分别代表了通知状态和事件类型， 同时定义了事件的回调方法：process（WatchedEvent event）。
process 方法是 Watcher 接口中的一个回调方法，当 ZooKeeper 向客户端发送一个 Watcher 事件通知时，客户端就会对相应的 process 方法进行回调，从而实现对事件的处理。
5.1 ． 基本使用
建立 java maven 项目,引入 maven pom 坐标。
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.9</version>
</dependency>

5.2 ． 更多操作示例
public static void main(String[] args) throws Exception {
// 初始化 ZooKeeper 实例(zk 地址、会话超时时间，与系统默认一致、watcher)
ZooKeeper zk = new ZooKeeper("node-21:2181,node-22:2181", 30000, new Watcher() {br/>@override
public void process(watchedevent event) { system.out.println("事件类型为：" + event.gettype()); system.out.println("事件发生的路径：" + event.getpath()); system.out.println("通知状态为：" +event.getstate()); } }); // 创建一个目录节点 zk.create("/testrootpath", "testrootdata".getbytes(), ids.open_acl_unsafe, createmode.persistent); // 创建一个子目录节点 zk.create("/testrootpath/testchildpathone", "testchilddataone".getbytes(), ids.open_acl_unsafe,createmode.persistent); system.out.println(new string(zk.getdata("/testrootpath",false,null))); // 取出子目录节点列表 system.out.println(zk.getchildren("/testrootpath",true)); // 修改子目录节点数据 zk.setdata("/testrootpath/testchildpathone","modifychilddataone".getbytes(),-1); system.out.println("目录节点状态：["+zk.exists("/testrootpath",true)+"]"); // 创建另外一个子目录节点 zk.create("/testrootpath/testchildpathtwo", "testchilddatatwo".getbytes(), ids.open_acl_unsafe,createmode.persistent); system.out.println(new string(zk.getdata("/testrootpath/testchildpathtwo",true,null))); // 删除子目录节点 zk.delete("/testrootpath/testchildpathtwo",-1); zk.delete("/testrootpath/testchildpathone",-1); // 删除父目录节点 zk.delete("/testrootpath",-1); zk.close(); }

内容总结

以上是互联网集市为您收集整理的ZooKeeper Java API全部内容，希望文章能够帮你解决ZooKeeper Java API所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---