java连接zookeeper

API

ZooKeeper官方提供了Java API，可以通过Java代码来连接zookeeper服务进行操作。可以连接、创建节点、获取节点数据、监听节点变化等操作，具体有以下几个重要的类：

  1. ZooKeeper：ZooKeeper类是Java API的核心类，用于与ZooKeeper服务器建立连接，并提供了一系列方法来操作ZooKeeper的节点。
  2. Watcher：Watcher是ZooKeeper的一个回调接口，当节点发生变化时会调用相应的方法进行通知。
  3. CreateMode：CreateMode枚举类定义了节点的类型，包括永久节点、临时节点、顺序节点和临时顺序节点。
  4. Stat：Stat类表示节点的元数据信息，比如修改版本、数据长度、子节点数量等。

添加依赖

<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.7.2</version>
</dependency>

操作例子

String host = "localhost:2181";
//建立连接
zooKeeper = new ZooKeeper(host, 2000, null);
String path = "/test";
Watcher watcher = new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {System.out.println("Node changed: " + watchedEvent.getPath());System.out.println(watchedEvent);}
};
//获取节点状态 如果不存在返回null
Stat stat = zooKeeper.exists(path, false);
if(null != stat){System.out.println(stat.getCzxid()+"-"+stat.getAversion());
}//创建节点 包含版本、时间、数据长度等信息
zooKeeper.create(path,"123".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
//添加watcher
zooKeeper.addWatch(path, watcher, AddWatchMode.PERSISTENT);//获取节点数据
byte[] data = zooKeeper.getData(path, false, null);
System.out.println(new String(data));zooKeeper.create(path+"/1","child1".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
//获取子节点
List<String> children = zooKeeper.getChildren(path, false);
System.out.println("childs size:"+children.size());
//删除子节点
zooKeeper.delete(path+"/1",-1);
zooKeeper.close();
zkClient

zkClient封装了zookeeper的官方api，简化了一些繁琐的操作，并提供了一些额外的功能，提高了开发效.

添加依赖

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

zkclient对节点数据的操作进行了序列化， 这里先准备一个string类型的序列化类。需要实现ZkSerializer接口

public class ZkStringSerializer implements ZkSerializer {@Overridepublic byte[] serialize(Object o) throws ZkMarshallingError {return String.valueOf(o).getBytes();}@Overridepublic Object deserialize(byte[] bytes) throws ZkMarshallingError {return new String(bytes);}
}

基本操作

ZkClient zkClient = new ZkClient("localhost:2181");
//自定义序列化 否则报错
zkClient.setZkSerializer(new ZkStringSerializer());
String path = "/test";
//判断节点是否存在
boolean exist = zkClient.exists(path);
System.out.println(exist);
if(!exist){//创建节点zkClient.create(path,"123", CreateMode.PERSISTENT);
}
//读取节点数据
System.out.println((String) zkClient.readData(path));
zkClient.writeData(path,"456");//设置节点数据
System.out.println((String) zkClient.readData(path));
zkClient.delete(path);//删除节点zkClient.close();

节点变化事件

String path = "/test";
/*** 节点变化事件* 只监听节点增减，不监听数据变化事件*/
zkClient.subscribeChildChanges(path, new IZkChildListener() {@Overridepublic void handleChildChange(String parentPath, List<String> children) throws Exception {System.out.println("节点"+parentPath+"发生变化");System.out.println(children);}
});
//节点操作，观察handleChildChange接收到对应事件
Thread.sleep(2000);
zkClient.createPersistent(path);
Thread.sleep(2000);
zkClient.createPersistent(path+"/child1");
Thread.sleep(2000);
zkClient.writeData(path+"/child1","123");
Thread.sleep(2000);
zkClient.delete(path+"/child1");
Thread.sleep(2000);
zkClient.delete(path);
Thread.sleep(100000);

节点数据变化事件

    String path = "/test";/*** 节点变化事件,只检测当前节点，感知不到其子节点* 节点被删除或节点数据变化*/zkClient.subscribeDataChanges(path, new IZkDataListener() {@Overridepublic void handleDataChange(String s, Object o) throws Exception {System.out.println("节点："+s+"数据变为:"+o);}@Overridepublic void handleDataDeleted(String s) throws Exception {System.out.println("节点："+s+"删除");}});Thread.sleep(2000);zkClient.createPersistent(path);Thread.sleep(2000);zkClient.createPersistent(path+"/child1");Thread.sleep(2000);zkClient.delete(path+"/child1");Thread.sleep(2000);zkClient.writeData(path,"123");Thread.sleep(2000);zkClient.delete(path);Thread.sleep(100000);
}

Curator

curator是另一个java连接zookeeper类库。功能更加强大。提供了连接重试、分布式锁、选举、队列等多种实际场景的用例。这里先简单搞个使用例子。

添加依赖

<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>5.1.0</version>
</dependency>

curator-framework是基础的依赖，一些特定的使用方式需要添加不同的依赖，有curator-recipes、curator-x-discovery、curator-x-async等。

基本操作

//创建连接
CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(1000, 3));
client.start();
String path = "/test";
client.checkExists().forPath(path);//判断是否存在
client.create().forPath(path, "123".getBytes());//创建节点
byte[] data = client.getData().forPath(path);//获取数据
System.out.println(new String(data));
client.setData().forPath(path, "456".getBytes());//设置数据
client.delete().forPath(path);//删除节点client.close();

节点监听

CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(1000, 3));
client.start();
String path = "/test";
NodeCache  nodeCache = new NodeCache(client,path);
//添加监听
nodeCache.getListenable().addListener(new NodeCacheListener() {@Overridepublic void nodeChanged() throws Exception {ChildData data = nodeCache.getCurrentData();if (data != null) {System.out.println("Node changed: " + data.getPath() + ", value: " + new String(data.getData()));} else {System.out.println("Node deleted: " + nodeCache.getPath());}}
});
nodeCache.start();
client.create().forPath(path);
client.setData().forPath(path, "123".getBytes());
client.delete().forPath(path);
client.close();

这里NodeCache被标识@Deprecated，也不知道被什么方式代替了，后面再研究。先简单使用。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/128098.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

vue 使用vue-office预览word、excel，pdf同理

vue 使用vue-office预览word、excel，pdf同理

在此&#xff0c;我只使用了docx和excel&#xff0c; pdf我直接使用的iframe进行的展示就不作赘述了 //docx文档预览组件 npm install vue-office/docx//excel文档预览组件 npm install vue-office/excel//pdf文档预览组件 npm install vue-office/pdf如果是vue2.6版本或以下还…
阅读更多...
2.Spark的工作与架构原理

2.Spark的工作与架构原理

概述 目标&#xff1a; spark的工作原理spark数据处理通用流程rdd 什么是rddrdd 的特点 spark架构 spark架构相关进程spark架构原理 spark的工作原理 spark 的工作原理&#xff0c;如下图 图中中间部分是spark集群&#xff0c;也可以是基于 yarn 的&#xff0c;图上可以…
阅读更多...
鲁班猫4（RK3588S）配置Realsense SDK和Realsense ROS（D435i T265）

鲁班猫4（RK3588S）配置Realsense SDK和Realsense ROS（D435i T265）

0 环境 鲁班猫4开发板&#xff08;RK3588S&#xff09;Ubuntu 20.04 &#xff08;lubancat-rk3588-ubuntu20.04-gnome-20230829_update&#xff09;D435iT265ROS noeticRealsense SDK v2.53.1Realsense ROS v2.3.2 1 安装ROS 建议使用fishros.com的ROS一键安装 wget http:/…
阅读更多...
为什么重写 redisTemplate

为什么重写 redisTemplate

为什么重写 redisTemplate 1.安装 redis 上传 redis 的安装包tar -xvf redis-5.0.7.tar.gzyum -y install gcc-cmakemake PREFIX/soft/redis installcd /soft/redis/bin./redis-server redis.conf 2. 集成 redisTemplate maven 依赖 <dependency><groupId>org…
阅读更多...
全国产EtherCAT运动控制边缘控制器（六）：RtBasic文件下载与连续轨迹加工的Python+Qt开发

全国产EtherCAT运动控制边缘控制器（六）：RtBasic文件下载与连续轨迹加工的Python+Qt开发

今天&#xff0c;正运动小助手给大家分享一下全国产EtherCAT运动控制边缘控制器ZMC432H如何使用PythonQT实现连续轨迹加工。 01 功能简介 全国产EtherCAT运动控制边缘控制器ZMC432H是正运动的一款软硬件全国产自主可控&#xff0c;运动控制接口兼容EtherCAT总线和脉冲型的独立…
阅读更多...
编译 linux 内核 ubuntu 22.04 通过 编译降级内核版本

编译 linux 内核 ubuntu 22.04 通过 编译降级内核版本

说的详细 http://kerneltravel.net/blog/2021/compile-kernel/ 也是 ubuntu 更为清爽 https://www.cnblogs.com/harrypotterjackson/p/11846222.html 较为简单的教程 https://www.51cto.com/article/663841.html https://blog.csdn.net/m0_61229668/article/details/1268505…
阅读更多...
【WinForm详细教程五】WinForm中的MenuStrip 、ContextMenuStrip 、ToolStrip、StatusStrip控件

【WinForm详细教程五】WinForm中的MenuStrip 、ContextMenuStrip 、ToolStrip、StatusStrip控件

文章目录 1.MenuStrip2.ContextMenuStrip3.ToolStrip4.StatusStrip 1.MenuStrip MenuStrip作为一个容器可以包含多个菜单项。MenuStrip 的重要属性包括&#xff1a; Name&#xff1a;菜单的名字Dock&#xff1a;菜单的停靠位置Items&#xff1a;菜单项的集合 ToolStripMenuI…
阅读更多...
华为云服务器，在线安装MySQL

华为云服务器，在线安装MySQL

需求 在华为云服务器上&#xff0c;部署MySQL数据库&#xff0c;通过 公网IP 访问数据库。 通过 yum &#xff0c;在线安装MySQL&#xff1b;配置远程连接&#xff0c;开放3306端口&#xff0c;能够通过公网访问。 云服务器配置说明 本文所使用的 华为云服务器 配置如下。 …
阅读更多...
C++进阶语法——STL 标准模板库（上）（Standard Template Library）【学习笔记（六）】

C++进阶语法——STL 标准模板库（上）（Standard Template Library）【学习笔记（六）】

文章目录 STL 标准模板库1、 STL简介2、STL容器的类别3、STL迭代器的类别4、STL算法的类别5、泛型编程&#xff08;generic programming&#xff09;6、C模板&#xff08;template&#xff09;6.1 函数模板&#xff08;function template&#xff09;6.2 类模板&#xff08;cla…
阅读更多...
20231102从头开始配置cv180zb的编译环境（欢迎入坑，肯定还有很多问题等着你）

20231102从头开始配置cv180zb的编译环境（欢迎入坑，肯定还有很多问题等着你）

20231102从头开始配置cv180zb的编译环境&#xff08;欢迎入坑&#xff0c;肯定还有很多问题等着你&#xff09; 2023/11/2 11:31 &#xff08;欢迎入坑&#xff0c;本篇只是针对官方的文档整理的&#xff01;只装这些东西你肯定编译不过的&#xff0c;还有很多问题等着你呢&…
阅读更多...
3.字符集和比较规则简介

3.字符集和比较规则简介

3.字符集和比较规则简介 1.字符集和比较规则简介1.1 字符集简介1.2 比较规则简介1.3 一些重要的比较规则 2. MySQL 中支持的字符集和比较规则2.1 MySQL 的 utf8 和 utf8mb42.2 字符集查看2.3 比较规则查看 3. 字符集和比较规则的应用3.1 各级别的字符集和比较规则1. 服务器级别…
阅读更多...
【求助啊】 计算机专业该何去何从啊

【求助啊】 计算机专业该何去何从啊

学校学习的东西跟不上社会的需求&#xff0c;马上要毕业了&#xff0c;来不及自学了&#xff0c;培训班唯一的出路吗&#xff1f;好像很多同学培训班培训后也找不到工作 进场打工吗 孔乙己脱不下的长衫啊&#xff0c; 专升本的 5 年了 学计算机5年还回去进程打工 感觉白读了啊…
阅读更多...
Spring Boot面向切面加注解

Spring Boot面向切面加注解

一.项目pom.xml文件引入切面依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId> </dependency>二.定义注解类 import java.lang.annotation.*;/*** desc 错误日志注解* au…
阅读更多...
AR眼镜定制开发-智能眼镜的主板硬件、软件

AR眼镜定制开发-智能眼镜的主板硬件、软件

AR眼镜定制开发是一项复杂而又重要的工作&#xff0c;它需要准备相关的硬件设备和软件。这些设备包括多个传感器、显示装置和处理器等。传感器用于捕捉用户的动作和环境信息&#xff0c;如摄像头、陀螺仪、加速度计等;显示装置则用于将虚拟信息呈现给用户;处理器用于处理和协调…
阅读更多...
京东科技埋点数据治理和平台建设实践 | 京东云技术团队

京东科技埋点数据治理和平台建设实践 | 京东云技术团队

导读 本文核心内容聚焦为什么要埋点治理、埋点治理的方法论和实践、奇点一站式埋点管理平台的建设和创新功能。读者可以从全局角度深入了解埋点、埋点治理的整体思路和实践方法&#xff0c;落地的埋点工具和创新功能都有较高的实用参考价值。遵循埋点治理的方法论&#xff0c;…
阅读更多...
Web - Servlet详解

Web - Servlet详解

目录 前言 一 . Servlet简介 1.1 动态资源和静态资源 1.2 Servlet简介 二 . Servlet开发流程 2.1 目标 2.2 开发过程 三 . Servlet注解方式配置 ​编辑 四 . servlet生命周期 4.1 生命周期简介 4.2 生命周期测试 4.3 生命周期总结 五 . servlet继承结构 5.1 ser…
阅读更多...
Content-Type 值有哪些?

Content-Type 值有哪些?

1、application/x-www-form-urlencoded 最常见 POST 提交数据的方式。 浏览器的原生 form 表单&#xff0c;如果不设置 enctype 属性&#xff0c;那么最终就会以 application/x-www-form-urlencoded 方式提交数据。 <form action"http://www.haha/ads/sds?name小草莓…
阅读更多...
Jmeter调用测试片段 —— 模块控制器

Jmeter调用测试片段 —— 模块控制器

可以使用模块控制器调用测试片段。模块控制器提供了一种在运行时将测试片段替换为当前测试计划的机制。测试片段可以位于任何线程组中。 1、打开一个Jmeter窗口&#xff0c;添加好线程组、用户定义变量、模块控制器、测试片段、察看结果树。 2、用户定义变量同样定义好访问ip及…
阅读更多...
NI-9236 国产化10 kS/s/ch，350 Ω四分之一桥应变计，8通道C系列应变/桥输入模块

NI-9236 国产化10 kS/s/ch，350 Ω四分之一桥应变计，8通道C系列应变/桥输入模块

10 kS/s/ch&#xff0c;350 Ω四分之一桥应变计&#xff0c;8通道C系列应变/桥输入模块 NI‑9236可同步测量所有通道的动态应变&#xff0c;从而实现了高速同步测量。 该功能对于需要在特定时刻对多个通道进行比较的应用&#xff08;例如冲击测试&#xff09;非常重要。\n\nNI…
阅读更多...
SSM校园设备管信息管理系统开发mysql数据库web结构java编程计算机网页源码eclipse项目

SSM校园设备管信息管理系统开发mysql数据库web结构java编程计算机网页源码eclipse项目

选题理由 随着计算机网络及多媒体技术的广泛应用&#xff0c;互联网已成为高校办学的基础设施和必备条件&#xff0c;基于互联网的高校信息管理越来越综合化&#xff0c;越来越多的教学管理、行政管理工作将架构在互联网上&#xff0c;互联网正在变为学校实施教学、科研和管理…
阅读更多...
最新文章

Copyright @ 2022~2023