怎么使用Java操作Zookeeper

这篇文章给大家分享的是有关怎么使用Java操作ZooKeeper的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

Java的优点是什么

1. 简单，只需理解基本的概念，就可以编写适合于各种情况的应用程序；2. 面向对象；3. 分布性，Java是面向网络的语言；4. 鲁棒性，java提供自动垃圾收集来进行内存管理，防止程序员在管理内存时容易产生的错误。；5. 安全性，用于网络、分布环境下的Java必须防止病毒的入侵。6. 体系结构中立，只要安装了Java运行时系统，就可在任意处理器上运行。7. 可移植性，Java可以方便地移植到网络上的不同机器。8.解释执行，Java解释器直接对Java字节码进行解释执行。

Maven依赖：

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

使用zkclient操作Zookeeper

创建节点：

@Testpublic void testCreatenode() {//建立连接//zkServers: Zookeeper服务器IP地址和端口号，如果是集群情况下用逗号分割多个Zookeeper服务器地址//sessionTimeout: 会话超时时间//connectionTimeout: 连接超时时间ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);//创建数据Student student = new Student();student.setName("张三");student.setAge(18);student.setPhone("1585454xxxx");//创建持久节点zkClient.createPersistent("/p_node", student);//创建持久顺序节点zkClient.createPersistentSequential("/ps_node", student);//创建临时节点zkClient.createEphemeral("/e_node", student);//创建临时顺序节点zkClient.createEphemeralSequential("/ps_node", student);//关闭客户端//关闭客户端的同时，前面创建的临时节点也会被删除zkClient.close();}

读取节点数据：

@Testpublic void testReadNodeData() {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);Stat stat = new Stat();Student student = zkClient.readData("/p_node", stat);System.out.println("节点状态信息：" + JSON.tojsONString(student));System.out.println("节点数据：" + JSON.toJSONString(stat));zkClient.close();}//输出结果：//节点状态信息：{"age":18,"name":"张三","phone":"1585454xxxx"}//节点数据：{"aversion":0,"ctime":1619165355431,"cversion":0,"czxid":165,"dataLength":260,"ephemeralOwner":0,"mtime":1619165355431,"mzxid":165,"numChildren":0,"pzxid":165,"version":0}

删除节点：

@Testpublic void testDeleteNode() {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);//删除节点，不能删除带有子节点的节点zkClient.delete("/p_node");//删除节点，递归删除所有子孙节点zkClient.deleteRecursive("/p_node2");zkClient.close();}

更新节点数据：

@Testpublic void testWriteNodeData() {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);//更新节点数据zkClient.writeData("/p_node", "myData1");//使用CAS更新节点数据//zkClient.writeData("/p_node", "myData2", 1);zkClient.close();}

获取子节点列表：

@Testpublic void testGetChildNodes() {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);//获取子节点列表List<String> childList = zkClient.getChildren("/p_node");childList.stream().forEach(System.out::println);zkClient.close();}

节点监听

Java节点监听都是永久的，触发一次后不会被删除。

监听节点的子节点变化：

@Testpublic void testSubscribeChildChanges() throws IOException {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);zkClient.subscribeChildChanges("/p_node", new IZkChildListener(){//子节点改变时调用@Overridepublic void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {System.out.println(parentPath + "子节点发生改变");System.out.println("当前子节点列表：" + currentChilds);}});//阻塞客户端，便于测试System.in.read();}

监听节点数据变化：

@Testpublic void testSubscribeDataChanges() throws IOException {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);zkClient.subscribeDataChanges("/p_node", new IZkDataListener(){//节点数据改变时调用@Overridepublic void handleDataChange(String dataPath, Object data) throws Exception {System.out.println(dataPath + "节点数据发生变化");System.out.println("修改后的数据为：" + data.toString());}//节点被删除时调用@Overridepublic void handleDataDeleted(String dataPath) throws Exception {System.out.println(dataPath + "节点已被删除");}});//阻塞客户端，便于测试System.in.read();}

监听Zookeeper连接状态变化：

@Testpublic void testSubscribeStateChanges() throws IOException {ZkClient zkClient = new ZkClient("127.0.0.1:2181", 60000, 5000);zkClient.subscribeStateChanges(new IZkStateListener(){//当zookeeper连接状态改变时调用@Overridepublic void handleStateChanged(Watcher.Event.KeeperState state) throws Exception {System.out.println("当前状态" + state);}//在zookeeper会话过期并且创建了一个新的会话之后调用@Overridepublic void handleNewSession() throws Exception {System.out.println("会话过期，已创建新的会话");}//当会话不能重新建立时调用@Overridepublic void handleSessionEstablishmentError(Throwable error) throws Exception {error.printStackTrace();}});//阻塞客户端，便于测试System.in.read();}

感谢各位的阅读！关于“怎么使用Java操作Zookeeper”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！