Zookeeper（79）如何进行Zookeeper的监控？
对 Zookeeper 进行监控是确保其高可用性和性能的关键步骤。监控 Zookeeper 通常包括以下几个方面：
- 健康检查：检查 Zookeeper 节点是否在线。
- 性能指标：监控关键性能指标，如请求延迟、事务处理量等。
- 日志监控：监控 Zookeeper 的日志文件，捕获异常和错误信息。
- 集群状态：监控集群中节点的状态和角色分配（Leader、Follower、Observer）。
以下是详细的步骤和代码示例，展示如何进行 Zookeeper 的监控。
1. 健康检查
Zookeeper 提供了四字命令（Four Letter Words）来进行健康检查和获取状态信息。常用的四字命令包括 ruok、stat、mntr 等。
健康检查示例代码
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;public class ZookeeperHealthCheck {private static final String ZK_ADDRESS = "127.0.0.1";private static final int ZK_PORT = 2181;public static void main(String[] args) {try (Socket socket = new Socket(ZK_ADDRESS, ZK_PORT)) {OutputStream out = socket.getOutputStream();out.write("ruok".getBytes());out.flush();BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String response = reader.readLine();if ("imok".equals(response)) {System.out.println("Zookeeper is healthy");} else {System.out.println("Zookeeper is not healthy");}} catch (Exception e) {e.printStackTrace();}}
}
2. 性能指标
使用 mntr 四字命令可以获取 Zookeeper 的关键性能指标。
性能指标监控示例代码
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;public class ZookeeperMetricsMonitor {private static final String ZK_ADDRESS = "127.0.0.1";private static final int ZK_PORT = 2181;public static void main(String[] args) {try (Socket socket = new Socket(ZK_ADDRESS, ZK_PORT)) {OutputStream out = socket.getOutputStream();out.write("mntr".getBytes());out.flush();BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while ((line = reader.readLine()) != null) {System.out.println(line);}} catch (Exception e) {e.printStackTrace();}}
}
3. 日志监控
Zookeeper 的日志文件包含了丰富的运行时信息，可以使用常见的日志监控工具（如 ELK Stack、Splunk 等）来监控 Zookeeper 的日志。
日志配置示例
在 zoo.cfg 配置文件中，设置日志目录：
dataDir=/var/lib/zookeeper/data
dataLogDir=/var/lib/zookeeper/log
使用 Filebeat 进行日志收集
Filebeat 可以用于收集 Zookeeper 的日志并发送到 Elasticsearch 或其他存储系统。
Filebeat 配置示例
filebeat.inputs:
- type: logpaths:- /var/lib/zookeeper/log/*.logoutput.elasticsearch:hosts: ["http://localhost:9200"]
4. 集群状态监控
使用 stat 四字命令可以获取 Zookeeper 集群中节点的状态和角色分配（Leader、Follower、Observer）。
集群状态监控示例代码
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;public class ZookeeperClusterStateMonitor {private static final String ZK_ADDRESS = "127.0.0.1";private static final int ZK_PORT = 2181;public static void main(String[] args) {try (Socket socket = new Socket(ZK_ADDRESS, ZK_PORT)) {OutputStream out = socket.getOutputStream();out.write("stat".getBytes());out.flush();BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while ((line = reader.readLine()) != null) {System.out.println(line);}} catch (Exception e) {e.printStackTrace();}}
}
5. 使用 Prometheus 和 Grafana 进行监控
Prometheus 和 Grafana 是常用的监控和可视化工具，可以用于监控 Zookeeper。
安装 Prometheus JMX Exporter
JMX Exporter 可以将 Zookeeper 的 JMX 指标导出为 Prometheus 格式。
配置 JMX Exporter
创建 zookeeper.yml 配置文件：
hostPort: 127.0.0.1:9998
rules:- pattern: ".*"
启动 Zookeeper 时，添加 JMX Exporter 的 JVM 参数：
-Dcom.sun.management.jmxremote
-Dcom.sun.management.jmxremote.port=9998
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
-javaagent:/path/to/jmx_prometheus_javaagent.jar=9999:/path/to/zookeeper.yml
配置 Prometheus
在 Prometheus 配置文件 prometheus.yml 中添加 Zookeeper 的监控目标：
scrape_configs:- job_name: 'zookeeper'static_configs:- targets: ['127.0.0.1:9999']
配置 Grafana
在 Grafana 中，添加 Prometheus 数据源，并创建仪表盘来展示 Zookeeper 的监控指标。
6. 使用 Zookeeper Admin Server 进行监控
Zookeeper 提供了一个内置的 Admin Server，可以通过 HTTP 接口获取监控信息。
启用 Admin Server
在 zoo.cfg 配置文件中启用 Admin Server：
admin.enableServer=true
admin.serverPort=8080
使用 Admin Server API
以下是一个使用 Java 通过 Admin Server API 获取监控信息的示例代码：
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;public class ZookeeperAdminServerMonitor {private static final String ADMIN_SERVER_URL = "http://127.0.0.1:8080/commands/monitor";public static void main(String[] args) {try {URL url = new URL(ADMIN_SERVER_URL);HttpURLConnection conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod("GET");BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));String inputLine;StringBuilder content = new StringBuilder();while ((inputLine = in.readLine()) != null) {content.append(inputLine);}in.close();conn.disconnect();System.out.println(content.toString());} catch (Exception e) {e.printStackTrace();}}
}
总结
对 Zookeeper 进行监控是确保其高可用性和性能的关键步骤。通过健康检查、性能指标监控、日志监控、集群状态监控以及使用 Prometheus 和 Grafana 进行可视化监控，可以全面掌握 Zookeeper 的运行状态和性能。根据具体的需求和场景，选择适合的监控方法并进行实施。
相关文章：
Zookeeper（79）如何进行Zookeeper的监控？
对 Zookeeper 进行监控是确保其高可用性和性能的关键步骤。监控 Zookeeper 通常包括以下几个方面： 健康检查：检查 Zookeeper 节点是否在线。性能指标：监控关键性能指标，如请求延迟、事务处理量等。日志监控：监控 Zook…...
【江科大STM32】TIM输出比较-PWM功能（学习笔记）
一、PWM驱动LED呼吸灯 接线图： PWM的初始化: 具体步骤： ①RCC开启时钟（把要用的TIM外设和GPIO外设时钟都打开） ② 配置时基单元，包括前面的时钟源选择 ③配置输出比较单元，里面包括CCR的值ÿ…...
playbin之autoplug_factories源码剖析
一、autoplug_factories_cb /* Called when we must provide a list of factories to plug to pad with caps.* We first check if we have a sink that can handle the format and if we do, we* return NULL, to expose the pad. If we have no sink (or the sink does not…...
Spring Cloud之注册中心之Nacos的使用
目录 Naacos 服务注册/服务发现 引⼊Spring Cloud Alibaba依赖 引入Nacos依赖 引入Load Balance依赖 配置Nacos地址 服务端调用 启动服务 Naacos Nacos是Spring Cloud Alibaba的组件, Spring Cloud Alibaba遵循Spring Cloud中定义的服务注册, 服务发现规范. 因此使⽤Na…...
React antd的datePicker自定义，封装成组件
一、antd的datePicker自定义 需求：用户需要为日期选择器的每个日期单元格添加一个Tooltip，当鼠标悬停时显示日期、可兑换流量余额和本公会可兑流量。这些数据需要从接口获取。我需要结合之前的代码，确保Tooltip正确显示，并且数据…...
【tplink】校园网接路由器如何单独登录自己的账号，wan-lan和lan-lan区别
老式路由器TPLINK，接入校园网后一人登录，所有人都能通过连接此路由器上网，无法解决遂上网搜索，无果，幸而偶然看到一个帖子说要把信号源网线接入路由器lan口，开启新世界。 一、wan-lan，lan-lan区…...
散户情绪周期模型（情绪影响操作）
目录 一、个股上涨阶段情绪演化二、个股下跌阶段情绪演化三、底部震荡阶段情绪演化四、情绪观察与操作工具箱1. 情绪自测量表（每日收盘后记录）2. 情绪-指标对照表 五、高阶情绪管理技巧1.认知重构训练2.生理指标监控（需配合智能手表ÿ…...
对比Grok3 普通账户与 30 美元 Super 账户：默认模式、Think 和 DeepSearch 次数限制以及如何升级
面对这个马斯克旗下的"最聪明"的人工智能，很多人都不知道他们的基本模式，本期将从几个方面开始说明： Grok3的背景与功能 账户类型及其详细背景 使用限制 使用限制对比表 如何充值使用 Super 账户 纯干货，带你了解…...
小程序Three Dof识别 实现景区AR体验
代码工程 GitCode - 全球开发者的开源社区,开源代码托管平台 dof...
主流Linux发行版优缺点整理及对比指南（文末附表格）
Linux发行版种类繁多，各有其设计理念和适用场景。本文整理常见发行版的优缺点，并附对比表格，帮助用户根据需求选择最适合的系统。 1. Ubuntu 定位：适合新手的通用型桌面/服务器系统优点： 安装简单，社区支持…...
用大白话解释搜索引擎Elasticsearch是什么，有什么用，怎么用
Elasticsearch是什么？ Elasticsearch（简称ES）就像一个“超级智能的图书馆管理系统”，专门帮你从海量数据中快速找到想要的信息。它底层基于倒排索引技术（类似书籍的目录页），能秒级搜索和分析万…...
坐标变换及视图变换和透视变换（相机透视模型）
文章目录 2D transformationScaleReflectionShear（切变）Rotation around originTranslationReverse变换顺序复杂变换的分解 齐次坐标（Homogenous Coordinates）3D transformationScale&TranslationRotation Viewing / Camera t…...
C# 基于.NET Framework框架WPF应用程序-MQTTNet库实现MQTT消息订阅发布
C# 基于.NET Framework框架WPF应用程序-MQTTNet库实现MQTT消息订阅发布 MQTT简述MQTTNet简述创建项目（基于.NET Framework框架）安装MQTTNet库项目源码运行效果 MQTT简述 mqtt官网 MQTTNet简述 MQTTnet MQTTnet 是一个强大的开源 MQTT 客户端库&#…...
Python实现视频播放器
Python实现视频播放器 Python实现视频播放器，在如下博文中介绍过 Python实现本地视频/音频播放器https://blog.csdn.net/cnds123/article/details/137874107 Python简单GUI程序示例 中 “四、视频播放器” https://blog.csdn.net/cnds123/article/details/122903…...
介绍一款飞算JavaAI编程工具，集成到idea，图文并茂
飞算的插件下载地址，里边也有安装步骤： JavaAI 下载 从file-》setting-》plugin，然后走图中所示 选择从磁盘安装插件：找到下载好的压缩包然后进行idea重启 根据提示模块可以生成代码，就是需要等待，后期不…...
【大数据】Spark Executor内存分配原理与调优
【大数据】Spark Executor内存管理与调优 Executor内存总体布局 统一内存管理 堆内内存 (On-heap Memory) 堆外内存 (Off-heap Memory) Execution 内存和 Storage 内存动态占用机制 任务内存管理（Task Memory Manager） 只用了堆内内存的示例 用了…...
Python 课堂点名桌面小程序
一、场景分析 闲来无事，老婆说叫我开发一个课堂点名桌面小程序，给她在课堂随机点名学生问问题。 人生苦短，那就用 Python 给她写一个吧。 二、依赖安装 因为要用到 excel，所以安装两个依赖： pip install openpyxl…...
配置Spring Boot中的Jackson序列化
配置Spring Boot中的Jackson序列化 在开发基于Spring Boot的应用程序时，Jackson是默认的JSON序列化和反序列化工具。它提供了强大的功能，可以灵活地处理JSON数据。然而，Jackson的默认行为可能无法完全满足我们的需求。例如，日期格…...
Rust学习总结之-match
Rust 有一个叫做 match 的极为强大的控制流运算符，它允许我们将一个值与一系列的模式相比较，并根据相匹配的模式执行相应代码。模式可由字面量、变量、通配符和许多其他内容构成。 一：match定义 可以把 match 表达式想象成某种硬币分类器&a…...
实践教程：使用DeepSeek实现PDF转Word的高效方案
🎈Deepseek推荐工具 PDF文件因其跨平台、格式稳定的特性被广泛使用，但在内容编辑场景中，用户常需将PDF转换为可编辑的Word文档。传统的付费工具（如Adobe Acrobat）或在线转换平台存在成本高、隐私风险等问题。本文将使…...
鸿蒙 ArkUI 实现 2048 小游戏
2048 是一款经典的益智游戏，玩家通过滑动屏幕合并相同数字的方块，最终目标是合成数字 2048。本文基于鸿蒙 ArkUI 框架，详细解析其实现过程，帮助开发者理解如何利用声明式 UI 和状态管理构建此类游戏。 一、核心数据结构与状态管理…...
az devops login报错：Failed to authenticate using the supplied token.
PowerShell，az devops login报错： Failed to authenticate using the supplied token. 检查了一下PAT token是对的。 检查命令： az devops login --organization https://dev.azure.com/xxxxxxxx/ 乍一看好像没问题问题，然后想…...
C ++ 静态存储区+堆空间
静态存储区 特点： 1：生命周期很长，main函数开始之前就存在，main函数结束，才结束 2：同名变量的管理，与栈不一样(重名变量前提，作用域一样)： 栈：遇到重名变…...
gtest 和 gmock讲解
Google Test（gtest）和 Google Mock（gmock）是 Google 开发的用于 C 的测试框架和模拟框架，以下是对它们的详细讲解： Google Test（gtest） 简介 Google Test 是一个用于 C 的单元测试框…...
docker的下载与使用（一）
本文默认使用linux系统以及会linux的基本指令，windows下安装docker较为繁琐 docker是什么 Docker 是一个开源的应用容器引擎，基于go 语言并遵从 Apache2.0 协议开源。 Docker 可以让开发者打包他们的应用以及依赖包到一个轻量级、可移植的容器中&…...
鸿蒙HarmonyOS NEXT开发：组件-样式-基础 2
// 1 // 2 ArkUI 基本语法 // 方舟开发框架（简称：ArkUI），是一套 构建HarmonyOS应用 界面 的框架。 // 构建页面的最小单位就是 "组件"。 // 组件名(参数) { // 内容 // } // .属性1() // .属性2() // .属性N() import text from @ohos.graphics.text // @En…...
如何理解数据库的几种事务隔离级别？以及如何理解脏读、不可重复度、幻读？
在多用户并发访问数据库时，数据库系统需要通过事务隔离级别来控制不同事务之间的相互影响。不同的隔离级别可以避免或减少在并发环境下可能出现的数据不一致或冲突。常见的事务隔离级别有四种：读未提交（Read Uncommitted）、读已提…...
计算机网络基础简答题资料（对口高考）
1、什么是计算机网络？计算机网络的功能有哪些？ 答案：计算机网络，是指将分布在不同地理位置、具有独立功能的多台计算机及其外围设备，通过通信设备和通信线路连接起来，在网络操作系统、网络管理软件及网络通…...
在docker容器中运行vllm部署deepseek-r1大模型
# 在本地部署python环境 cd /app/ python -m venv myenv # 激活虚拟环境 source /app/myenv/activate # 要撤销激活一个虚拟环境，请输入: deactivate# 进入虚拟环境安装modelscope pip install modelscope# 下载大模型（7B为例） modelscope do…...
HeidiSQL如何替换代码中的某些信息
1.SQL代码里的某些内容，比如2025年这个日期信息，我想替换成2024年的，按照:“搜索”---“替换文本”然后按照图片上的步骤来就可以了，特别是在sql代码有几百行甚至几千行的时候使用 2.SQL代码的表格对象中的数据如何一次性把某个内…...
Wireshark 插件开发实战指南
Wireshark 插件开发实战指南 环境搭建流程图 #mermaid-svg-XpNibno7BIyfzNn5 {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-XpNibno7BIyfzNn5 .error-icon{fill:#552222;}#mermaid-svg-XpNibno7BIyfzNn5 .error-t…...
【大模型➕知识图谱】大模型结合医疗知识图谱：解锁智能辅助诊疗系统新范式
【大模型➕知识图谱】大模型结合医疗知识图谱：解锁智能辅助诊疗系统新范式 大模型结合医疗知识图谱：解锁智能辅助诊疗系统新范式引言一、系统架构1.1 系统架构图1.2 架构模块说明1.2.1 用户输入1.2.2 大模型（语义理解与意图识别）1.2.3 Agent（问题解析与任务分配）1.2.4 问…...
大模型应用落地具体规划方案
摘要 本篇文章主要探讨大模型应用落地的具体规划方案，包含六点内容的分享，分别是： 大模型本地部署架构 大模型应用交互场景 基于阿里云RAG 项目的实现方案 大模型推荐落地场景方案 大模型应用落地发展规划 大模型开源架构选型推荐 在阅…...
【Qt】MVC设计模式
目录 一、搭建MVC框架 二、创建数据库连接单例类SingleDB 三、数据库业务操作类model设计 四、control层，关于model管理类设计 五、view层即为窗口UI类 一、搭建MVC框架 里面的bin、lib、database文件夹以及sqlite3.h与工程后缀为.pro文件的配置与上次发的文章…...
python量化交易——金融数据管理最佳实践——qteasy创建本地数据源
文章目录 qteasy金融历史数据管理总体介绍本地数据源——DataSource对象默认数据源查看数据表查看数据源的整体信息最重要的数据表其他的数据表 从数据表中获取数据向数据表中添加数据删除数据表 —— 请尽量小心，删除后无法恢复！！总结 qteas…...
)
深入探索Python机器学习算法：监督学习(线性回归,逻辑回归,决策树与随机森林,支持向量机,K近邻算法)
文章目录 深入探索Python机器学习算法：监督学习一、线性回归二、逻辑回归三、决策树与随机森林四、支持向量机五、K近邻算法 深入探索Python机器学习算法：监督学习 在机器学习领域，Python凭借其丰富的库和简洁的语法成为了众多数据科学家和机…...
word转换为pdf后图片失真解决办法、高质量PDF转换方法
1、安装Adobe Acrobat Pro DC 自行安装 2、配置Acrobat PDFMaker （1）点击word选项卡上的Acrobat插件，（2）点击“首选项”按钮，（3）点击“高级配置”按钮（4）点…...
【MATLAB例程】三维下的IMM（交互式多模型），模型使用CV（匀速）和CA（匀加速）
给出三维下的交互式多模型（IMM）matlab例程，模型使用匀速运动CV和匀加速运动CA，滤波使用EKF（扩展卡尔曼滤波） 文章目录 代码运行结果程序结构 代码讲解模型定义：轨迹生成：IMM核心流程…...
千峰React：Hooks（下）
useLayoutEffect useLayoutEffect在useEffect之前触发 这样会闪屏，因为是异步的，两次都渲染了 import {useEffect,useState } from react;function App() {const [msg,setMsg] useState(hello App)useEffect(() > {setMsg(hello useEffect)});retu…...
突破网络壁垒：实现 Mac SSH 访问 Windows WSL Ubuntu 的最佳实践20250301
突破网络壁垒：实现 Mac SSH 访问 Windows WSL Ubuntu 的最佳实践 背景与痛点 在现代开发环境中，开发者通常会面临不同操作系统之间的协同工作。例如： 主要开发环境位于 Windows 的 WSL Ubuntu 子系统需要从局域网内的 Mac 设备进行远程访问…...
【开源-鸿蒙土拨鼠大理石系统】鸿蒙 HarmonyOS Next App+微信小程序+云平台
✨本人自己开发的开源项目：土拨鼠充电系统 ✨踩坑不易，还希望各位大佬支持一下，在GitHub给我点个 Start ⭐⭐👍👍 ✍GitHub开源项目地址👉：https://github.com/lusson-luo/HarmonyOS-groundhog-…...
RAG 阿里云
RAG-阿里云Spring AI Alibaba官网官网 RAG-阿里云Spring AI Alibaba官网官网 AI应用跑起来，取消一下航班的操作666...
python -ssh学习
def exe_sshcmd(ip,username,userpswd,port,cmd): """ 功能：SSH登录到指定设备，并执行对应的命令 入参：前四项为ssh登录shell的ip和port，具备管理员权限的用户名和密码， cmd可以…...
【Java学习】内部类
面向对象系列六 一、类级别 1.静态成员 2.非静态成员与方法 二、类的创建与成员管理 1.类的创建 2.类的成员管理 三、常见的内部类 1.非静态内部类 2.静态内部类 3.匿名内部类 4.局部内部类 一、类级别 1.1静态成员 静态成员是类级别的是能一路直属都是在类层面的&…...
养生，开启健康生活之门
在这个快节奏的时代，人们在忙碌奔波中，往往忽略了自身健康。养生保健，不再是老年人的专属，而是各个年龄段维持良好生活状态的关键，它是我们开启健康生活的一把钥匙。 规律作息是养生的基石。人体就像一台精密的仪器&am…...
1-3压缩命令
文章目录 1. tar1.1 压缩（.tar.gz .tgz .tar.bz2 ）1.2 解压缩(.tar.gz .tgz .tar.bz2 ) 2.zip2.1 压缩(.zip)2.2 解压缩 3.xz3.1 压缩（.tar.xz）3.2 解压缩 1. tar 1.1 压缩（.tar.gz .tgz .tar.bz2 ） c…...
Dify使用和入门
第一步：了解 Dify 在开始之前，先简单了解一下 Dify 是什么： Dify 是一个开源的 LLM 应用开发平台，专注于帮助开发者快速构建生产级的生成式 AI 应用。它支持知识库集成、RAG（检索增强生成）技术、复杂工作…...
AcWing 5933：爬楼梯 ← 递归 / 递推 / 高精度
【题目来源】 https://www.acwing.com/problem/content/5936/ 【题目描述】 树老师爬楼梯，他可以每次走 1 级或者 2 级，输入楼梯的级数，求不同的走法数。 例如：楼梯一共有 3 级，他可以每次都走一级，或者第…...
WebGL 渲染器 WebGLRenderer
目录 Three.js封装的渲染器 .domElement属性 .setSize(width, height)方法 帧缓冲区的相关封装 渲染器方法.clear(color,depth,stencil) 渲染器方法.clearDepth() 渲染器属性.autoClear Three.js封装的渲染器 .domElement属性 如果想通过WebGL渲染一个三维场景&#…...
基于Three.js的3D赛车游戏开发实战详解
目录 一、项目效果预览二、核心技术架构2.1 三维场景构建2.2 赛道与车辆模型2.3 光照系统三、核心运动系统3.1 车辆运动控制3.2 物理模拟公式3.3 边界限制四、摄像机控制系统4.1 第三人称视角数学原理4.2 鼠标交互实现五、星空背景特效5.1 点云生成算法5.2 动态闪烁效果六、性能…...