Apache ZooKeeper 及 Curator 使用总结

1. 下载

官网地址：Apache ZooKeeper

点击下载按钮

选择对应的版本进行下载

2. 使用

1、解压

tar -zxf apache-zookeeper-3.9.2-bin.tar.gz

2、复制配置文件，有一个示例配置文件 conf/zoo_sample.cfg，此文件不能生效，需要名称为 zoo.cfg 的文件才能生效，因此改名复制一份配置文件

cp conf/zoo_sample.cfg conf/zoo.cfg

3、修改配置，其他配置暂不做修改，只重新指定一下 dataDir 的路径

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
#dataDir=/tmp/zookeeper
dataDir=../data
# the port at which the clients will connect
clientPort=2181

4、启动 ZooKeeper 服务端

./bin/zkServer.sh start

5、ZooKeeper 客户端连接，本机连接可以不写 ip:port

./bin/zkCli.sh -server ip:port

3. 常用命令

通过 help 命令可查看 ZooKeeper 常用命令

1、创建节点，create 命令

在根目录下创建 node1 节点，与它关联的内容是字符串 "node1"

create /node1 "node1"

在 node1 节点下创建 node1.1 节点，与它关联的内容是数字 123

create /node1/node1.1 123

2、获取节点的数据，get 命令

获取 node1 节点下 node1.1 子节点的数据，get /node1/node1.1

[zk: localhost:2181(CONNECTED) 7] get /node1/node1.1
123

3、更新节点数据内容，set 命令

set /node1/node1.1 "node1.1-123"

4、查看节点状态，stat 命令

查看 node1 节点的状态，stat /node1

[zk: localhost:2181(CONNECTED) 6] stat /node1
cZxid = 0x4
ctime = Tue Aug 20 17:01:23 CST 2024
mZxid = 0x4
mtime = Tue Aug 20 17:01:23 CST 2024
pZxid = 0x5
cversion = 1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 1

5、查看某个目录下的子节点，ls 命令

查看根目录下的子节点，ls /

[zk: localhost:2181(CONNECTED) 4] ls /
[node1, zookeeper]

查看 node1 节点下的子节点和状态，ls -s /node1

[zk: localhost:2181(CONNECTED) 9] ls -s /node1
[node1.1]
cZxid = 0x4
ctime = Tue Aug 20 17:01:23 CST 2024
mZxid = 0x4
mtime = Tue Aug 20 17:01:23 CST 2024
pZxid = 0x5
cversion = 1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 1

6、删除节点，delete 命令，要删除的节点必须没有子节点才行

删除 node1 节点，delete /node1，提示该节点不为空

[zk: localhost:2181(CONNECTED) 11] delete /node1
Node not empty: /node1

删除 node1 节点下 node1.1 子节点，delete /node1/node1.1

[zk: localhost:2181(CONNECTED) 12] delete /node1/node1.1

4. Curator

Curator 是 Netflix 公司开源的一套 ZooKeeper Java 客户端框架，相比于 Zookeeper 自带的客户端 zookeeper 来说，Curator 的封装更加完善，各种 API 都可以比较方便地使用

4.1 引入依赖

版本自行选择

<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>${curator.version}</version>
</dependency>
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-client</artifactId><version>${curator.version}</version>
</dependency>
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>${curator.version}</version>
</dependency>

4.2 连接 ZooKeeper 客户端

1、使用工厂类 CuratorFrameworkFactory 的静态 newClient() 方法

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;/*** Curator 客户端** @author GreyFable* @since 2024/8/22 11:33*/
public class CuratorClient {public static void main(String[] args) {// 重试策略RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);// 创建客户端实例CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", retryPolicy);// 启动客户端client.start();}
}

2、使用工厂类 CuratorFrameworkFactory 的静态 builder() 构造者方法

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;/*** Curator 客户端** @author GreyFable* @since 2024/8/22 11:33*/
public class CuratorClient {public static void main(String[] args) {RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);CuratorFramework client = CuratorFrameworkFactory.builder().connectString("localhost:2181")// 会话超时时间.sessionTimeoutMs(5000)// 连接超时时间.connectionTimeoutMs(5000).retryPolicy(retryPolicy).build();client.start();}
}

4.3 操作 ZooKeeper

1、判断节点是否存在

Stat stat = client.checkExists().forPath("/node1/0001");
if (null != stat) {System.out.println("节点已存在");
}

2、创建节点

通常是将 znode 分为 4 大类：

  • 持久（PERSISTENT）节点 ：一旦创建就一直存在，即使 ZooKeeper 集群宕机，直到将其删除
  • 临时（EPHEMERAL）节点 ：临时节点的生命周期是与 客户端会话（session） 绑定的，会话消失则节点消失 。并且，临时节点 只能做叶子节点 ，不能创建子节点
  • 持久顺序（PERSISTENT_SEQUENTIAL）节点 ：除了具有持久（PERSISTENT）节点的特性之外， 子节点的名称还具有顺序性。比如 /node1/app0000000001 、/node1/app0000000002
  • 临时顺序（EPHEMERAL_SEQUENTIAL）节点 ：除了具备临时（EPHEMERAL）节点的特性之外，子节点的名称还具有顺序性

在使用 ZooKeeper 的时候，会发现 CreateMode 类中实际有 7 种 znode 类型 ，但是用的最多的还是上面介绍的 4 种

创建默认持久化节点，只有当父节点 /node1 存在时才会成功创建，否则会报错

client.create().forPath("/node1/0001");

创建指定类型的节点，只有当父节点 /node1 存在时才会成功创建，否则会报错

client.create().withMode(CreateMode.PERSISTENT).forPath("/node1/0002");

父节点不存在时自动创建父节点，使用 creatingParentsIfNeeded() 方法

client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).forPath("/node1/0003");

创建节点并指定数据内容，注意数据内容要是 byte 数组

client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).forPath("/node1/0004", "0004".getBytes());

3、获取节点数据

byte[] bytes = client.getData().forPath("/node1/0001");

4、更新节点数据

 client.setData().forPath("/node1/0001", "0001".getBytes());

5、删除节点

删除一个子节点

client.delete().forPath("/node1/0001");

删除一个节点以及其下的所有子节点

client.delete().deletingChildrenIfNeeded().forPath("/node1/0001");

6、获取某个节点的所有子节点路径

List<String> list = client.getChildren().forPath("/node1/0001");

4.4 监听器

Curator 引入了 Cache 来实现对 Zookeeper 服务端事件监听，Cache 事件监听可以理解为一个本地缓存视图与远程 Zookeeper 视图的对比过程，分为一下注册类型

  • NodeCache：对某一个节点进行监听，对当前节点数据变化进行处理
  • PathChildrenCache：对子节点进行监听，但是不会对二级子节点进行监听，对当前节点的子节点数据变化进行处理
  • TreeCache：对当前节点下所有节点进行监听，对当前节点的子节点，及递归子节点数据变化进行处理

不过在 Curator 5.1.0 以后，NodeCache 、PathChildrenCache 、TreeCache 均已被弃用，统一使用 CuratorCache 进行所有节点的事件监听，对应的方法如下：

  • forCreates()：创建
  • forChanges()：设值，
  • forCreatesAndChanges()：创建和设值
  • forDeletes()：删除，如果删除多级节点，会触发多次
  • forAll()：所有事件

默认情况下，Listener 监听整个子树（指定节点及其子节点）的事件，如果指定了 SINGLE_NODE_CACHE 选项，则只监听单个节点的事件

CuratorCache curatorCache = CuratorCache.build(client, "/node1");
// CuratorCache curatorCache = CuratorCache.build(client, "/node1", CuratorCache.Options.SINGLE_NODE_CACHE);CuratorCacheListener listener = CuratorCacheListener.builder().forCreates(childData ->System.out.println("create: " + childData.getPath() + " " + new String(childData.getData()))).forChanges((oldNode, node) -> System.out.println("change")).forCreatesAndChanges((oldNode, node) -> System.out.println("createAndChange")).forDeletes(childData -> System.out.println("delete")).forAll((type, oldData, data) -> {if (type.name().equals(CuratorCacheListener.Type.NODE_CREATED.name())) {System.out.println("create");} else if (type.name().equals(CuratorCacheListener.Type.NODE_CHANGED.name())) {System.out.println("change");} else if (type.name().equals(CuratorCacheListener.Type.NODE_DELETED.name())) {System.out.println("delete");}}).build();curatorCache.listenable().addListener(listener);
curatorCache.start();

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

【非常实用—Navicat重置 MySQL 的密码】

【非常实用—Navicat重置 MySQL 的密码】

Navicat重置 MySQL 的密码 连接本地数据库&#xff0c;忘记原始密码停止 MySQL 服务以安全模式启动 MySQL打开新的命令行窗口重置密码停止 MySQL 并重启 连接本地数据库&#xff0c;忘记原始密码 停止 MySQL 服务 在命令行中使用以下命令停止服务&#xff08;Windows 下&#…
阅读更多...
C语言6大常用标准库 -- 4.＜math.h＞

C语言6大常用标准库 -- 4.＜math.h＞

目录 引言 4. C标准库--math.h 4.1 简介 4.2 库变量 4.3 库宏 4.4 库函数 4.5 常用的数学常量 &#x1f308;你好呀&#xff01;我是 程序猿 &#x1f30c; 2024感谢你的陪伴与支持 ~ &#x1f680; 欢迎一起踏上探险之旅&#xff0c;挖掘无限可能&#xff0c;共同成长&…
阅读更多...
医学数据分析实训 项目五 分类分析--乳腺癌数据分析与诊断

医学数据分析实训 项目五 分类分析--乳腺癌数据分析与诊断

文章目录 项目六&#xff1a;分类分析实践目的实践平台实践内容&#xff08;一&#xff09;数据理解及准备&#xff08;二&#xff09;模型建立、预测及优化任务一&#xff1a;使用 KNN算法进行分类预测任务二&#xff1a;使用贝叶斯分类算法进行分类预测任务三&#xff1a;使用…
阅读更多...
星云股份战略运营副总裁袁智勇︱如何培养“能打胜仗”的项目经理

星云股份战略运营副总裁袁智勇︱如何培养“能打胜仗”的项目经理

全国项目经理专业人士年度盛会 福建星云电子股份有限公司总裁办战略运营副总裁袁智勇先生受邀为PMO评论主办的全国项目经理专业人士年度盛会——2024第四届中国项目经理大会演讲嘉宾&#xff0c;演讲议题为“如何培养“能打胜仗”的项目经理”。大会将于10月26-27日在北京举办&…
阅读更多...
56.【C语言】字符函数和字符串函数(strtok函数)(未完)

56.【C语言】字符函数和字符串函数(strtok函数)(未完)

目录 12.strtok函数(较复杂) *简单使用 总结: *优化 12.strtok函数(较复杂) *简单使用 strtok:string into tokens cplusplus的介绍 点我跳转 翻译: 函数 strtok char * strtok ( char * str, const char * delimiters ); 总结: delimiters参数指向一个字符串&#xff0…
阅读更多...
波士顿机器人滑环的技术特点与应用前景

波士顿机器人滑环的技术特点与应用前景

机器人滑环在现代自动化和机器人技术中扮演着至关重要的角色。作为一种关键的机械组件&#xff0c;滑环允许机器人在旋转和移动的过程中保持稳定的电信号和数据传输。波士顿机器人滑环作为行业中的领先产品&#xff0c;具有多项独特的技术特点和优势&#xff0c;为各种机器人系…
阅读更多...
Packet Tracer - 配置编号的标准 IPv4 ACL(两篇)

Packet Tracer - 配置编号的标准 IPv4 ACL(两篇)

Packet Tracer - 配置编号的标准 IPv4 ACL(第一篇) 目标 第 1 部分&#xff1a;计划 ACL 实施 第 2 部分&#xff1a;配置、应用和验证标准 ACL 背景/场景 标准访问控制列表 (ACL) 为路由器 配置脚本&#xff0c;基于源地址控制路由器 是允许还是拒绝数据包。本练习的主要内…
阅读更多...
如何学习React？一些学习React的网站

如何学习React？一些学习React的网站

React相关网站集锦 React入门 React 官网&#xff1a;https://react.zcopy.site/docs/getting-started.html 深入React原理 1. 图解React&#xff1a;https://7kms.github.io/react-illustration-series/main/bootstrap 帮助我们快速学习React Fiber架构相关知识&#xff0c;主…
阅读更多...
STM32—MPU6050

STM32—MPU6050

1.MPU6050简介 MPU6050是一个6轴姿态传感器可以测量芯片自身X、Y、Z轴的加速度、角速度参数&#xff0c;通过数据融合&#xff0c;可进一步得到姿态角&#xff0c;常应用于平衡车、飞行器等需要检测自身姿态的场景3轴加速度计(Accelerometer&#xff1a;测量X、Y、Z轴的加速度3…
阅读更多...
智源推出下一代检索增强大模型框架MemoRAG

智源推出下一代检索增强大模型框架MemoRAG

北京智源人工智能研究院与中国人民大学高瓴人工智能学院联合发布了一款创新的人工智能模型框架——MemoRAG。该框架基于长期记忆&#xff0c;旨在推动检索增强生成&#xff08;RAG&#xff09;技术的发展&#xff0c;使其能够处理更复杂的任务&#xff0c;而不仅限于简单的问答…
阅读更多...
Vue3 : Pinia的性质与作用

Vue3 : Pinia的性质与作用

目录 一.性质 二.作用 三.Pinia 的核心概念 四.使用 1.count.ts 2.count.vue Vue 3 中 Pinia 是一个专为 Vue 3 设计的状态管理库&#xff0c;它旨在提供一种简单、直观的方式来管理应用的状态。 一.性质 1.集成性&#xff1a;Pinia 是 Vue 3 官方推荐的状态管理库&…
阅读更多...
全志T507-H国产平台Ubuntu系统正式发布，让您的应用开发更便捷！

全志T507-H国产平台Ubuntu系统正式发布，让您的应用开发更便捷！

为了满足广大工业用户的需求&#xff0c;创龙科技针对全志T507-H工业平台进行了Ubuntu系统适配&#xff0c;开发环境如下&#xff1a; Ubuntu&#xff1a;Ubuntu18.04.4 U-Boot&#xff1a;U-Boot-2018.05 Kernel&#xff1a;Linux-4.9.170、Linux-RT-4.9.170 LinuxSDK&…
阅读更多...
【AprilTag】视觉定位实战 | 使用 ROS 驱动的 USB 摄像头进行相机标定与 AprilTag 识别

【AprilTag】视觉定位实战 | 使用 ROS 驱动的 USB 摄像头进行相机标定与 AprilTag 识别

写在前面&#xff1a; &#x1f31f; 欢迎光临 清流君 的博客小天地&#xff0c;这里是我分享技术与心得的温馨角落。&#x1f4dd; 个人主页&#xff1a;清流君_CSDN博客&#xff0c;期待与您一同探索 移动机器人 领域的无限可能。 &#x1f50d; 本文系 清流君 原创之作&…
阅读更多...
Mapsui：一个 .NET 开源的地图组件库

Mapsui：一个 .NET 开源的地图组件库

前言 今天大姚给大家分享一个.NET开源&#xff08;MIT License&#xff09;、免费、同时支持多平台框架&#xff08;MAUI、WPF、Avalonia、Uno、Blazor、WinUI、Eto、.NET Android 和 .NET iOS&#xff09;地图组件库&#xff1a;Mapsui。 项目源代码 支持的UI框架的NuGet包 创…
阅读更多...
文章排名优化@大众点评代发灰色词是什么软件

文章排名优化@大众点评代发灰色词是什么软件

文章排名优化大众点评代发灰色词是什么软件 如何优化灰色词百度排名推广&#xff08;灰色词推广代发/代做&#xff09;#百度推广#关键词排名#灰色词排名 欢迎来到百收网SEO搜索群&#xff0c;我是狂潮老师&#xff0c;这一节我们来讲一下 on page SEO是什么&#xff1f;大众点…
阅读更多...
【JAVA入门】Day46 - Commons-io

【JAVA入门】Day46 - Commons-io

【JAVA入门】Day46 - Commons-io 文章目录 【JAVA入门】Day46 - Commons-io一、Commons-io 的常见方法 Commons-io 其实是一个工具包&#xff0c;它里面包含一系列有关IO操作的方法。它的作用就是来提高IO流的开发效率。 Commons 工具包中包含了很多很多有用的工具类&a…
阅读更多...
【专题】2024中国生物医药出海现状与趋势蓝皮书报告合集PDF分享（附原数据表）

【专题】2024中国生物医药出海现状与趋势蓝皮书报告合集PDF分享（附原数据表）

原文链接&#xff1a;https://tecdat.cn/?p37719 出海已成为中国医药产业实现提速扩容的重要途径。目前&#xff0c;中国医药产业发展态势良好&#xff0c;创新能力不断增强&#xff0c;然而也面临着医保政策改革和带量集采带来的压力。政府积极出台多项政策支持医药企业出海…
阅读更多...
【新手上路】衡石分析平台使用手册-租户管理

【新手上路】衡石分析平台使用手册-租户管理

租户管理​ 衡石系统支持服务一个平台方和多个企业客户的租户模式&#xff0c;平台方管理租户&#xff0c;为租户提供数据&#xff0c;租户在系统内进行数据分析。 衡石系统增加工作空间的设计&#xff0c;在平台方和租户之间提供单向的传递通道&#xff0c;平台厂商可以轻松…
阅读更多...
nature communications |多层次蛋白质组分析揭示弥漫型和肠型胃癌之间的分子多样性

nature communications |多层次蛋白质组分析揭示弥漫型和肠型胃癌之间的分子多样性

文章信息 发表期刊&#xff1a;nature communications 发表日期&#xff1a;2023年2月14日 影响因子&#xff1a;14.7 研究背景 胃癌是世界上主要的癌症类型之一。弥漫型胃癌(DGC)和肠型胃癌(IGC)是胃癌(GC)的主要组织学类型&#xff0c;DGC呈分散的细胞组织&#xff0c;黏…
阅读更多...
Vue3使用shapefile读取矢量数据，以数组形式返回坐标点

Vue3使用shapefile读取矢量数据，以数组形式返回坐标点

npm安装: npm install shapefile --save-dev 源码: <script setup> import { ElMessage } from element-plus; import { ref } from vue; // 引入 ref import * as shapefile from "shapefile";// 使用 ref 创建一个引用 const uploadRef ref(null);// 解析…
阅读更多...
最新文章

Copyright @ 2022~2023