六、Java API操作zookeeper节点
2021-11-22 01:16
363 查看
目录
前文
- 一、CentOS7 hadoop3.3.1安装(单机分布式、伪分布式、分布式
- 二、JAVA API实现HDFS
- 三、MapReduce编程实例
- 四、Zookeeper3.7安装
- 五、Zookeeper的Shell操作
pom.xml文件增加依赖
<!-- Zookeeper依赖--> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.7.0</version> </dependency>
新建java文件:ZookeeperTest
/** * @author LEHOSO * @date 2021/11/21 * @apinote */ public class ZookeeperTest { public static void main(String[] args) throws Exception { // 初始化ZooKeeper实例(zk地址、会话超时时间,与系统默认一致, watcher) //步骤一:创建Zookeeper客户端 //参数1:zk地址;参数2:会话超时时间(与系统默认一致);参数3:监视器 ZooKeeper zk = new ZooKeeper( "192.168.142.10:2181," + "192.168.142.20:2181," + "192.168.142.30:2181", 300000, new Watcher() { @Override //监控所有被触发的事件(也就是在这里进行事件的处理) public void process(WatchedEvent watchedEvent) { System.out.println("事件类型为:" + watchedEvent.getType()); System.out.println("事件发生的路径:" + watchedEvent.getPath()); System.out.println("通知状态为:" + watchedEvent.getState()); } }); //步骤二:创建目录节点 //参数1:要创建的节点路径;参数2:节点数据;参数3:节点权限;参数4:节点类型 zk.create("/testRootPath", "testRootData".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); //步骤三:创建子目录节点 zk.create("/testRootPath/testChildPathOne", "testChildPathOne".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); //步骤四:获取目录节点数据 //参数1:存储节点数据的路径; //参数2:是否需要监控此节点(true/false) //参数3:stat节点的统计信息(一般设置null) System.out.println("testRootData节点数据为:" + new String(zk.getData("/testRootPath", false, null))); //步骤五:获取子目录节点数据 // 取出 ad8 子目录节点列表 System.out.println(zk.getChildren("/testRootPath", true)); //步骤六:修改子目录节点数据,使得监听触发 //参数1:存储子目录节点数据的路径; //参数2:要修改的数据; //参数3:预期要匹配的版本(设置为-1,则可匹配任何节点的版本) zk.setData("/testRootPath/testChildPathOne", "modifyChildDataOne".getBytes(), -1); //步骤七:判断目录节点是否存在 System.out.println("目录节点状态[" + zk.exists("/testRootPath", true) + "]"); //步骤八:删除子目录节点 zk.delete("/testRootPath/testChildPathOne", -1); //步骤九:删除目录节点 zk.delete("/testRootPath", -1); zk.close(); } }
GitHub文件下载
相关文章推荐
- java_api操作zookeeper节点
- 初步认识zookeeper(3)--JavaAPI操作节点(增删改查)
- Zookeeper(五)Java客户端节点操作
- ZooKeeper_5_Java操作ZK_创建节点
- Zookeeper系列(七)Zookeeper客户端(JAVA)API之创读取子节点内容
- zookeeper学习之java api查找并删除节点<五>
- Zookeeper学习之源生API的使用(java与shell操作zookeeper)。
- ZooKeeper之Java客户端API使用—检测节点是否存在
- zookeeper JAVA API 简单操作
- ZooKeeper_6_Java操作ZK_删除节点
- Zoookeeper_Java API操作zookeeper 通过zookeeper.jar
- zookeeper使用(二):javaAPI基本操作和循环监听器使用
- ZooKeeper之Java客户端API使用—删除节点。
- ZooKeeper之Java客户端API使用—创建节点。
- Zookeeper 命令行操作及Java api
- ZooKeeper_Java操作(创建节点/获取节点/删除节点)
- Zookeeper系列(五)Zookeeper客户端(JAVA)API之创建节点
- Zookeeper系列(八)Zookeeper客户端(JAVA)API之节点检查和权限控制
- ZooKeeper_9_Java操作ZK_检测节点
- java操作zookeeper,包括增删改节点及其事件通知