【ZooKeeper高手实战】ZooKeeper常用命令及客户端工具Curator核心功能

2024-01-09 10:52
文章标签 工具 实战 功能 客户端 常用命令 核心 zookeeper curator 高手

本文主要是介绍【ZooKeeper高手实战】ZooKeeper常用命令及客户端工具Curator核心功能，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

🌈🌈🌈🌈🌈🌈🌈🌈
欢迎关注公众号（通过文章导读关注：【11来了】），及时收到 AI 前沿项目工具及新技术 的推送
发送 资料 可领取 深入理解 Redis 系列文章结合电商场景讲解 Redis 使用场景、中间件系列笔记和编程高频电子书！
文章导读地址：点击查看文章导读！
🍁🍁🍁🍁🍁🍁🍁🍁
请添加图片描述

ZooKeeper 中常用运维及使用命令

zk 运维常用命令：

命令执行模板：echo [参数] | nc localhost 2181，常用参数如下：

  • conf：查看当前 zk 配置
  • cons：查看连接的数量
  • crst：重置客户端统计
  • dump：输出会话
  • envi：查看环境
  • ruok：检查节点是否正在运行
  • stat：查看运行时状态
  • srst：重置服务器统计
  • wchs：查看 watcher 信息
  • wchc：输出 watcher 详细信息
  • wchp：输出 watcher，以 znode 为单位分组
  • mntr：输出比 stat 更加详细

基于 jstat 命令监控和检查 zk 的 JVM 运行情况：

# 先查询 zk 的进程 id
ps -ef | grep zookeeper
# 进程 ID 515460 ，采样间隔 250 ms，采样数 4
jstat -gc 515460 250 4

开启 zk 的 JMX 端口以及使用 JConsole 观察 JVM 内存使用：

zk 中启动 JMX 功能，可以去暴露一组端口，以供监控和管理 Java 应用程序

在 zkServer.sh 中，找到 ZOOMAIN 变量，将 ZOOMAIN 后边的内容替换为下边的三条内容：

-Dcom.sum.management.jmxremote.port=21811
-Dcom.sum.management.jmxremote.ssl=false
-Dcom.sum.management.jmxremote.authenticate=false

打开 JMX 端口之后，就可以通过 JDK 自带的可视化 JVM 进程内存分析工具 JConsole 进行内存分析了

zk 操作常用命令：

# 启动服务端
sh zkServer.sh start
# 启动客户端
sh zkCli.sh
# 创建 test 节点，数据为 1010
create /test 1010
# 查看目录 
ls /
# 读取数据
get /test
# 更新数据
set /test 1020
# 删除节点
delete /test

ZooKeeper 客户端工具 Curator 常用功能

目前，业内使用最广泛的 zk 客户端框架为：Curator

Curator 是由 Netflix 开源出来的，提供了丰富的操作 zk 的 API

如果想使用 Curator，需要引入的 maven 依赖如下（zk 使用 3.4.5 版本，对应 curator 框架版本 2.4.2）：

目前 Curator 官网说最新版本的 Curator 已经取消了对 zookeeper 3.4.x 的支持，不过原理都是一致的，先了解原理，再看源码就很容易看懂

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

Curator 连接 zk 使用示例如下：

public class CuratorZkExample {public static void main(String[] args) {// 创建一个 CuratorFramework 实例CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", // ZooKeeper 服务器地址5000, // 客户端跟 zk 进行心跳，如果心跳断开超过 5 秒，绘画就会断开3000, // 连接 zk 的超时时间new ExponentialBackoffRetry(1000, 3) // 重试策略，1秒后重试，最多重试3次);// 启动客户端client.start();try {// 创建一个 ZooKeeper 节点String path = "/example/path";client.create().creatingParentsIfNeeded().forPath(path, "data".getBytes());// 获取节点数据byte[] data = client.getData().forPath(path);System.out.println("Node data: " + new String(data));// 更新节点数据byte[] newData = "new data".getBytes();client.setData().forPath(path, newData);// 读取更新后的节点数据data = client.getData().forPath(path);System.out.println("Updated node data: " + new String(data));// 删除节点client.delete().forPath(path);Thread.sleep(Integer.MAX_VALUE);} catch (Exception e) {e.printStackTrace();} finally {// 关闭客户端client.close();}}
}

zk 一般如何实现元数据存储？

一般是将元数据转成 json 字符串，去创建一个 znode，将元数据的 json 串写到这个 znode 的值中，如果需要就直接从这个 znode 中读取即可

下边主要讲解一下 Curator 中常用的一些功能如何使用：

Curator 中 Leader 的选举

Curator 的 Leader 选举机制有两种：

  • Leader Latch
  • Leader Elction

Leader Latch 使用讲解：

首先创建一个 Leader Latch 如下，在 /leader/latch 目录下创建节点进行 Leader 的选举：

LeaderLatch leaderLatch = new LeaderLatch(client, "/leader/latch");

所有竞选 Leader 目录为 /leader/latch 的节点会进行协商，选择一个 Leader 出来，可以通过 hasLeaderShip 判断自己是否时 Leader：

System.out.println("是否成为 Leader：" + leaderLatch.hasLeadership());

调用 start 方法之后，节点会开始竞选 Leader，之后阻塞在 await 方法上，直到成为 Leader 之后，才可以执行 await 之后的代码：

// 开始竞选 Leader
leaderLatch.start();
// 阻塞等待成为 Leader
leaderLatch.await();
// 执行 Leader 操作
...
// 将当前实例从 Leader 选举中关闭
leaderLatch.close();

完整代码如下：

public class LeaderLatchDemo {public static void main(String[] args) throws Exception {// 创建一个 CuratorFramework 实例CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", // ZooKeeper 服务器地址new ExponentialBackoffRetry(1000, 3) // 重试策略，1秒后重试，最多重试3次);// 启动客户端client.start();LeaderLatch leaderLatch = new LeaderLatch(client, "/leader/latch");leaderLatch.start();leaderLatch.await();System.out.println("是否成为 Leader：" + leaderLatch.hasLeadership());leaderLatch.close();}
}

Leader Election 使用讲解：

使用 Leader Election 时，需要先创建 LeaderSelector 实例，之后调用 start 方法去启动竞选，当成为 Leader 之后，在 LeaderSelector 中注册的监听器中的 takeLeadership 方法将会被调用，在该方法中执行 Leader 所需要的操作，执行完毕之后，当方法退出时，就意味着当前实例放弃了 Leader 地位，完整代码如下：

public class LeaderElectionDemo {public static void main(String[] args) throws Exception {// 创建一个 CuratorFramework 实例CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", // ZooKeeper 服务器地址new ExponentialBackoffRetry(1000, 3) // 重试策略，1秒后重试，最多重试3次);// 启动客户端client.start();LeaderSelector leaderSelector = new LeaderSelector(client, "/leader/selector", new LeaderSelectorListener() {@Overridepublic void takeLeadership(CuratorFramework curatorFramework) throws Exception {System.out.println("你已经成为 Leader");// 在这里做 Leader 要做的事情，此时不能让方法退出Thread.sleep(Integer.MAX_VALUE);}@Overridepublic void stateChanged(CuratorFramework client, ConnectionState newState) {System.out.println("连接状态发生变化");if (newState.equals(ConnectionState.LOST)) {throw new CancelLeadershipException();}}});leaderSelector.start();Thread.sleep(Integer.MAX_VALUE);}
}

Curator 实现分布式锁原理：

Curator 实现 zk 的分布式锁，就是通过 临时顺序节点 实现

简单来说，就是所有人去竞争一个锁

指定一个锁的目录，在此目录下创建一个临时顺序节点

如果是第一个节点的话，表示获取到了锁

如果不是第一个节点，就对上一个节点加一个监听，上一个节点释放锁之后，第二个节点会得到通知，就去拿到锁

在这里插入图片描述

Curator 提供的节点监听机制：

Curator 事件有两种模式：

  • 标准的观察模式，使用 Watcher 监听器

  • 缓存事件监听，类似于将本地缓存视图和 ZooKeeper 视图进行对比的过程，Curator 提供了 3 个接口：

    • Path Cache：对指定路径的子目录进行监听，不监听该节点
    • Node Cache：对一个节点进行监听
    • Tree Cache：对整个目录进行监听

Watcher 监听器处理事件：

需要定义一个事件，再通过 usingWatcher 即可对某个路径进行监听

Watcher watcher = new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {log.info("监听器watchedEvent：" + watchedEvent);}
};byte[] content = client.getData().usingWatcher(watcher).forPath("/test/watcher");
System.out.println(new String(content));

利用 Watcher 对节点进行监听的话，缺点就是只可以监听 1 次，监听到 1 次事件之后这个监听器就会失效

如果要反复监听，那么就需要反复调用 usingWatcher 来注册

缓存事件监听：

PathCache 和 NodeCache 接口的使用都放在下边（这里使用的 Curator 客户端版本为 2.4.2，因此还没有 Tree Cache 功能，这里就不演示了）：

// Path Cache 监听
public static void main(String[] args) throws Exception {// 创建一个 CuratorFramework 实例CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", // ZooKeeper 服务器地址new ExponentialBackoffRetry(1000, 3) // 重试策略，1秒后重试，最多重试3次);// 启动客户端client.start();PathChildrenCache pathChildrenCache = new PathChildrenCache(client, "/cluster", true);pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {@Overridepublic void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {System.out.println("监听到子节点发生变化，收到事件：" + pathChildrenCacheEvent);}});pathChildrenCache.start();Thread.sleep(Integer.MAX_VALUE);
}// NodeCache 监听
public static void main(String[] args) throws Exception {// 创建一个 CuratorFramework 实例final CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", // ZooKeeper 服务器地址new ExponentialBackoffRetry(1000, 3) // 重试策略，1秒后重试，最多重试3次);// 启动客户端client.start();final NodeCache nodeCache = new NodeCache(client, "/nodecache");nodeCache.getListenable().addListener(new NodeCacheListener() {@Overridepublic void nodeChanged() throws Exception {Stat stat = client.checkExists().forPath("/nodecache");if (stat != null) {byte[] bytes = client.getData().forPath("/nodecache");System.out.println("节点数据发生变化" + new String(bytes));System.out.println();} else {System.out.println("节点被删除...");}}});nodeCache.start();Thread.sleep(Integer.MAX_VALUE);
}

ZooKeeper 客户端功能总结：

使用客户端工具 Curator 主要是用来做节点的 CRUD + 监听 + Leader 选举，用在分布式业务系统中

其中 Curator 提供的像 Barrier、分布式计数器、分布式队列这些功能使用场景很少，并且同样的功能还有更好的选择

比如更推荐使用 Redis 做分布式计数、RabbitMQ/RocketMQ 做分布式队列！

这篇关于【ZooKeeper高手实战】ZooKeeper常用命令及客户端工具Curator核心功能的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/586868。

相关文章

Linux中压缩、网络传输与系统监控工具的使用完整指南

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压：数据存储与传输的优化核心1. zip/unzip：通用压缩格式的便捷操作2.
阅读更多...
从原理到实战深入理解Java 断言assert

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言（assert）：从原理到实战引言：为什么需要断言？一、断言基础1.1 语
阅读更多...
mysql表操作与查询功能详解

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE
阅读更多...
Java MQTT实战应用

Java MQTT实战应用

《JavaMQTT实战应用》本文详解MQTT协议,涵盖其发布/订阅机制、低功耗高效特性、三种服务质量等级（QoS0/1/2）,以及客户端、代理、主题的核心概念,最后提供Linux部署教程、Sprin... 目录一、MQTT协议二、MQTT优点三、三种服务质量等级四、客户端、代理、主题1. 客户端（Clien
阅读更多...
在Spring Boot中集成RabbitMQ的实战记录

在Spring Boot中集成RabbitMQ的实战记录

《在SpringBoot中集成RabbitMQ的实战记录》本文介绍SpringBoot集成RabbitMQ的步骤,涵盖配置连接、消息发送与接收,并对比两种定义Exchange与队列的方式:手动声明(... 目录前言准备工作1. 安装 RabbitMQ2. 消息发送者（Producer）配置1. 创建 Spr
阅读更多...
sqlite3 命令行工具使用指南

sqlite3 命令行工具使用指南

《sqlite3命令行工具使用指南》本文系统介绍sqlite3CLI的启动、数据库操作、元数据查询、数据导入导出及输出格式化命令,涵盖文件管理、备份恢复、性能统计等实用功能,并说明命令分类、SQL语... 目录一、启动与退出二、数据库与文件操作三、元数据查询四、数据操作与导入导出五、查询输出格式化六、实用功
阅读更多...
Golang如何用gorm实现分页的功能

Golang如何用gorm实现分页的功能

《Golang如何用gorm实现分页的功能》：本文主要介绍Golang如何用gorm实现分页的功能方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录背景go库下载初始化数据【1】建表【2】插入数据【3】查看数据4、代码示例【1】gorm结构体定义【2】分页结构体
阅读更多...
深度解析Spring Boot拦截器Interceptor与过滤器Filter的区别与实战指南

深度解析Spring Boot拦截器Interceptor与过滤器Filter的区别与实战指南

《深度解析SpringBoot拦截器Interceptor与过滤器Filter的区别与实战指南》本文深度解析SpringBoot中拦截器与过滤器的区别,涵盖执行顺序、依赖关系、异常处理等核心差异,并... 目录Spring Boot拦截器（Interceptor）与过滤器（Filter）深度解析：区别、实现
阅读更多...
深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

《深度解析SpringAOP@Aspect原理、实战与最佳实践教程》文章系统讲解了SpringAOP核心概念、实现方式及原理,涵盖横切关注点分离、代理机制（JDK/CGLIB）、切入点类型、性能... 目录1. @ASPect 核心概念1.1 AOP 编程范式1.2 @Aspect 关键特性2. 完整代码实
阅读更多...
MySQL中的索引结构和分类实战案例详解

MySQL中的索引结构和分类实战案例详解

《MySQL中的索引结构和分类实战案例详解》本文详解MySQL索引结构与分类,涵盖B树、B+树、哈希及全文索引,分析其原理与优劣势,并结合实战案例探讨创建、管理及优化技巧,助力提升查询性能,感兴趣的朋... 目录一、索引概述1.1 索引的定义与作用1.2 索引的基本原理二、索引结构详解2.1 B树索引2.2
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2