当前位置: 首页 > article >正文

ZooKeeper Java API操作

(1)添加依赖,在pom.xml文件中添加zookeeper依赖:

(2)连接zookeeper服务,创建cn.itcast.zookeeper包,在该包中创建ZooKeeperDemo类,该类用于实现创建会话和操作ZooKeeper,在类中创建main()和getConnect()方法,getConnect()方法用于实现指定ZooKeeper服务创建会话,代码及运行结果如下:

(3)使用create()方法创建ZNode,在ZooKeeperDemo类中创建createNode()方法,用于创建持久节点zkapi,并且在持久节点zkapi中挂载子节点zkchild,该子节点的ZNode类型为持久节点,diamagnetic如下:

修改ZooKeeperDemo类中的main()方法,代码如下:

运行结果如下,递归查看根目录下的节点:

(4)使用exists()方法普安段ZNode是否存在,代码如下:

main()方法修改后如下:

运行结果如下:

(5)在ZooKeeperDemo类中创建getNode()方法,该方法用于获取持久节点zkapi的数据内容,getNode()方法的代码如下:

Main()方法修改如下:

运行结果:

(6)在ZooKeeperDemo类中创建updateNode()方法,该方法用于将持久节点zkapi的数据内容修改为fruit_new,代码如下:

Main()方法修改如下:

运行结果:

(7)在ZooKeeperDemo类中创建getChildNode()方法,该方法用于查看持久节点zkapi的子节点列表,代码如下:

Main()方法修改如下:

运行结果如下:

(8)在类ZooKeeperDemo中创建deleteNode()方法,该方法用于删除持久节点zkapi的子节点zkchild,代码如下:

Main()方法修改如下:

运行结果:


http://www.kler.cn/a/472159.html

相关文章:

  • 游戏引擎学习第77天
  • Elasticsearch:搜索相关性
  • Spring Boot 多环境配置与切换
  • Electron使用记录
  • 深入理解Mybatis原理》MyBatis的sqlSessi
  • 【随时随地学算法】本地部署hello-algo结合内网穿透远程学习新体验
  • HarmonyOS:@Builder装饰器:自定义构建函数
  • MATLAB语言的数据库交互
  • flutter 独立开发之笔记
  • Elasticsearch复习笔记
  • Unity 三种渲染管线比较
  • 【网络云SRE运维开发】2025第2周-每日【2025/01/06】小测-【第6章 VLAN技术原理与配置】理论和实操
  • 图论:Tarjan算法的使用,找连通分量、割点、桥
  • oracle 数据库回收站恢复误删除表
  • Elixir语言的字符串处理
  • Elixir语言的多线程编程
  • Android Audio基础(53)——PCM逻辑设备Write数据
  • 让你的网页动起来:深入理解 CSS 动画和过渡
  • 红日靶场12457-2024
  • 【flink-cdc】flink-cdc 3版本debug启动pipeline任务,mysql-doris