实战:ZooKeeper 操作命令和集群部署

ZooKeeper 操作命令

ZooKeeper的操作命令主要用于对ZooKeeper服务中的节点进行创建、查看、修改和删除等操作。以下是一些常用的ZooKeeper操作命令及其说明:

一、启动与连接

  1. 启动ZooKeeper服务器:

    ./zkServer.sh start
    

    这个命令用于启动ZooKeeper服务器。

  2. 连接ZooKeeper客户端:

    ./zkCli.sh
    

    或者,指定服务器地址和端口号进行连接:

    ./zkCli.sh -server <ip>:<port>
    
  3. 退出ZooKeeper客户端:

    quit
    
  4. 关闭ZooKeeper服务器:

    ./zkServer.sh stop
    
  5. 查看ZooKeeper服务器状态:

    ./zkServer.sh status
    

二、节点操作

1. 查看节点
  • ls命令:用于列出指定节点下的所有子节点。

    ls <path> [watch]
    

    其中,<path>是节点的路径,[watch]是可选参数,用于监听该节点的变化。 

    图片

  • ls2命令:与ls命令类似,但会同时列出子节点和节点的状态信息。

    ls2 <path> [watch]
    

    图片

  • get命令:用于获取指定节点的数据内容和属性信息。

    get <path> [watch]
    

    图片

2. 创建节点
  • create命令:用于创建一个新的节点。

    create <path> <data> [acl]
    

    其中,<path>是节点的路径,<data>是节点存储的数据,[acl]是可选的访问控制列表。 

    图片

    create -s <path> <data>
    

    顺序节点会在节点名后自动添加一个递增的序列号。

    create -e <path> <data>
    

    临时节点在客户端会话结束后会自动删除。

    • 创建临时节点:使用-e选项。

    • 创建顺序节点:使用-s选项。

3. 修改节点
  • set命令:用于修改指定节点的数据内容。 bash set <path> <data> [version] 其中,<path>是节点的路径,<data>是新的数据内容,[version]是可选的数据版本号,用于控制更新的条件。

4. 删除节点
  • delete命令:用于删除指定节点。

    delete <path> [version]
    

    其中,<path>是节点的路径,[version]是可选的数据版本号。注意,delete命令只能删除空节点(即没有子节点的节点)。 

    图片

    • 删除非空节点:一些ZooKeeper版本或扩展可能提供了deleteall命令来删除非空节点,但这不是ZooKeeper核心功能的标准部分。在实际使用中,需要先删除非空节点的所有子节点,然后再删除该节点。 

      图片

三、其他命令

  • stat命令:用于获取指定节点的状态信息。

    stat <path> [watch]
    

    图片

  • help命令:在ZooKeeper客户端中,可以使用help命令来查看所有可用的命令及其说明。

    help
    

这些命令是ZooKeeper操作中常用的基本命令,它们涵盖了节点的创建、查看、修改和删除等核心功能。在实际使用中,可以根据需要选择合适的命令进行操作。

ZooKeeper 集群部署

ZooKeeper集群部署是一个涉及多个步骤和配置的过程,主要包括环境准备、ZooKeeper安装、配置文件修改、启动和验证集群等关键步骤。以下是一个以3台服务器详细的部署指南:

一、环境准备

  1. 硬件资源:

    • 通常建议使用3台或更多(推荐为2n+1台,n为大于1的整数)的服务器来部署ZooKeeper集群,以确保高可用性和容错性。

    • 每台服务器应具有足够的CPU、内存和存储空间来支持ZooKeeper的运行。

    • 三个节点, 修改操作系统的/etc/hosts文件,添加IP与主机名映射:

10.109.142.53 zk-001
10.109.190.32 zk-002
10.109.165.20 zk-003
  1. 操作系统:

    • 选择支持ZooKeeper的操作系统,如Linux(推荐CentOS、Ubuntu等)。

  2. 网络配置:

    • 确保所有服务器都能相互通信,且网络延迟和丢包率保持在较低水平。

    • 配置好服务器的IP地址和主机名,并确保它们能在集群中正确解析。

  3. 软件依赖:

    • 安装Java环境,因为ZooKeeper是用Java编写的。推荐使用Java 8或更高版本。

    • 安装必要的工具和库,如tar、wget等,以便下载和解压ZooKeeper安装包。

二、ZooKeeper安装

  1. 下载ZooKeeper安装包:

    • 访问Apache ZooKeeper的官方网站(https://zookeeper.apache.org/)或镜像站点,下载最新版本的ZooKeeper安装包。

    • 可以使用wget命令或浏览器下载到本地,然后上传到服务器。

  2. 解压安装包:

    • 将下载的ZooKeeper安装包解压到指定的目录,如/usr/local/

    • 重命名解压后的文件夹,以便更容易识别,如zookeeper-3.x.x

三、配置文件修改

1. 复制配置文件:
  • 进入ZooKeeper的conf目录,复制zoo_sample.cfg文件为zoo.cfg

2. 编辑zoo.cfg文件:

配置如下:

# 服务器之间或客户端与服务器之间维持心跳的时间间隔
# tickTime以毫秒为单位。tickTime=2000# 集群中的follower服务器(F)与leader服务器(L)之间的初始连接心跳数initLimit=10# 集群中的follower服务器与leader服务器之间请求和应答之间能容忍的最多心跳数syncLimit=5# 快照保存目录# 不要设置为/tmp,该目录重新启动后会被自动清除dataDir=/data/zookeeper/zk1/data# 日志保存目录dataLogDir=/data/zookeeper/zk1/logs# 客户端连接端口clientPort=2181# 客户端最大连接数。# 根据自己实际情况设置,默认为60个# maxClientCnxns=60# 三个接点配置,格式为:# server.服务编号=服务地址、通信端口、选举端口server.1=zk-001:2888:3888server.2=zk-002:2888:3888server.3=zk-003:2888:3888

说明:

  • 修改dataDir参数,指定ZooKeeper存储快照的目录。

  • 如果需要,还可以设置dataLogDir参数,指定ZooKeeper存储事务日志的目录。

  • 修改clientPort参数,设置ZooKeeper服务监听的端口号(默认为2181)。

  • 在配置文件末尾添加集群配置,格式为server.n=host:peerPort:electionPort,其中n是服务器的唯一标识(与myid文件中的值对应);host是服务器的IP地址或主机名;peerPort是用作leader与follwer之间的通信端口号(数据同步),默认为2888;electionPort是用于选举Leader投票的端口号(默认为3888)。

这一步主要是配图中的框出来的内容:

3. 创建myid文件:
  • 在每台服务器的dataDir指定的目录下,创建一个名为myid的文件,内容为该服务器的唯一标识(与zoo.cfg中配置的server.n中的n相对应)。

以第一台为例 vim myid:

按照以上步骤,三台服务器做同样的操作。

四、启动ZooKeeper集群

  1. 启动ZooKeeper服务:

    • 在每台服务器上,进入ZooKeeper的bin目录,执行./zkServer.sh start命令分别启动ZooKeeper服务。

  2. 验证集群状态:

    • 在每台服务器上执行./zkServer.sh status命令,查看ZooKeeper服务的状态。

    • 正常情况下,集群中应该有一个Leader和多个Follower。可以通过查看日志或使用ZooKeeper客户端工具(如zkCli.sh)来进一步验证集群的运行状态。

如第三台服务器: 

图片

五、注意事项

  1. 防火墙和安全组配置:

    • 确保ZooKeeper服务监听的端口(默认为2181)在服务器的防火墙和安全组中已开放。

  2. 数据备份和恢复:

    • 定期备份ZooKeeper的数据目录和日志目录,以便在数据丢失或损坏时能够恢复。

  3. 监控和日志:

    • 配置监控工具来监控ZooKeeper集群的性能和健康状况。

    • 定期查看ZooKeeper的日志文件,以便及时发现并解决问题。

  4. 版本兼容性:

    • 确保集群中所有服务器上的ZooKeeper版本相同,以避免版本不兼容导致的问题。

通过以上步骤,您可以成功部署一个ZooKeeper集群,并确保其能够稳定运行。

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

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

相关文章

403 forbidden (13: Permission denied)

403 forbidden (13: Permission denied) 目录 403 forbidden (13: Permission denied) 【常见模块错误】 【解决方案】 欢迎来到我的主页&#xff0c;我是博主英杰&#xff0c;211科班出身&#xff0c;就职于医疗科技公司&#xff0c;热衷分享知识&#xff0c;武汉城市开发者…

Laravel路由模型绑定:简化依赖注入的艺术

Laravel路由模型绑定&#xff1a;简化依赖注入的艺术 引言 在现代Web应用开发中&#xff0c;Laravel框架以其优雅和简洁的代码而闻名。Laravel的路由模型绑定&#xff08;Route Model Binding&#xff09;是框架提供的一项强大功能&#xff0c;它允许开发者在路由处理中自动注…

基于视觉的语义匹配见多了,那基于雷达的呢?

论文题目&#xff1a; LiDAR-based HD Map Localization using Semantic Generalized ICP with Road Marking Detection 论文作者&#xff1a; Yansong Gong, Xinglian Zhang, Jingyi Feng, Xiao He and Dan Zhang 作者单位&#xff1a;北京驭势科技有限公司 导读&#xff…

python 查询机器python、gpu、安装包等环境版本信息

checkenv.py """Check environment configurations and dependency versions."""import importlib import os import resource import subprocess import sys from collections import OrderedDict, defaultdictimport torch# 查询自己想要的包…

cf960(div2)

A. Submission Bait&#xff08;博弈&#xff09; 题意&#xff1a;爱丽丝和鲍勃在大小为n的数组a中进行游戏&#xff0c;他们轮流进行运算&#xff0c;爱丽丝先开始&#xff0c;不能运算的一方输&#xff0c;一开始mx0&#xff0c;每次操作&#xff0c;玩家可以选择一个牵引i…

MOMFEA-SADE--基于子空间对齐和自适应差分进化的多目标多任务优化算法

MOMFEA-SADE–基于子空间对齐和自适应差分进化的多目标多任务优化算法 title&#xff1a; Evolutionary Multitasking for Multiobjective Optimization With Subspace Alignment and Adaptive Differential Evolution author&#xff1a; Zhengping Liang, Hao Dong, Cheng …

c语言中的整形提升和算数转换

整形提升&#xff1a; 表达式中字符和短整型操作数在使用之前转换为普通整形 分为两种&#xff1a; 有符号整形提升&#xff1a;按照变量的数据类型的符号位来提升 无符号整形提升&#xff1a;按照高位补0的方式及进行提升 例如&#xff1a;char a20&#xff1b;char b130…

【Git】 如何将一个分支的某个提交合并到另一个分支

【Git】 如何将一个分支的某个提交合并到另一个分支 在使用 Git 进行版本控制时&#xff0c;常常会遇到这样的需求&#xff1a;将某个分支的特定提交合并到另一个分支中。这种情况下&#xff0c;我们可以使用 cherry-pick 命令来实现。本文将详细介绍 cherry-pick 命令的使用方…

Java基础巩固 -- 多线程

Java基础巩固 – 多线程 1.多线程 1.1 意义 Java 给多线程编程提供了内置的支持。 一条线程指的是进程中一个单一顺序的控制流&#xff0c;一个进程中可以并发多个线程&#xff0c;每条线程并行执行不同的任务。 多线程是多任务的一种特别的形式&#xff0c;但多线程使用了更…

“链动革新:2+1模式引领用户复购与留存潮流“

大家好&#xff01;我是吴军&#xff0c;来自一家在业界享有盛誉的软件开发公司&#xff0c;担任产品经理一职。今天&#xff0c;我想和大家深入探讨一个话题——如何利用创新的链动21模式来显著提升用户的留存率和复购率。 提到链动模式&#xff0c;很多人可能第一时间想到的是…

DEBUG:机械臂无法连接

问题 机械臂无法连接 ip 网关正确 解决 检查网口是否正常 网口损坏 usb部分可能半坏&#xff08;支持鼠标 不是转网口&#xff09;

Whisper离线部署问题处理

Whisper是OpenAI开发一款开源语音识别模型&#xff0c;可以帮我们低成本的拥有语音识别的能力。具体的安装部署方法&#xff0c;我在这里就不详细说了&#xff0c;网上有很多相关文章&#xff1a; 使用OpenAI的Whisper 模型进行语音识别 (baidu.com) 我这里主要想说的是&…

醒醒,别睡了...讲《数据分析pandas库》了—/—<6>

一、 1、长宽格式转换 基于多重索引&#xff0c;Pandas 可以很容易地完成长型、宽型数据格式的相互转换。 1.1 转换为最简格式 stack&#xff08;&#xff09;其使用法如下&#xff1a; stack函数用于将DataFrame中的列转换为行&#xff0c;即将宽格式数据转换为长格式数据。…

GitHub每周最火火火项目(7.22-7.28)

1. 项目名称&#xff1a;Django 项目介绍&#xff1a;Django 是一个高级 Python Web 框架&#xff0c;鼓励快速开发和简洁、实用的设计。它由经验丰富的开发者构建&#xff0c;旨在解决 Web 开发中的常见问题&#xff0c;提供了一套完整的工具和库&#xff0c;包括数据库ORM、…

中控屏UI设计全解析:布局与交互技巧

在现代科技的浪潮中&#xff0c;中控屏已成为智能系统不可或缺的交互界面。无论是智能家居、车载系统还是工业控制&#xff0c;一个直观、易用且美观的中控屏 UI 设计对于提升用户体验至关重要。本教程将带领你深入探索中控屏UI设计的精髓&#xff0c;指导你如何打造出既专业又…

2024.7.28 记录一次悲惨的笔试——作业帮NLP校招

小红的奇偶抽取 题目描述 题解 #include <iostream> #include<stack> using namespace std;int main() {long long n;stack <int> ji, ou;cin >> n;while (n) {int a n % 10;if (a % 2 0)ou.push(a);elseji.push(a);n n / 10;}long long jN 0, o…

用深度学习改进乳腺癌MRI诊断| 文献速递--AI辅助的放射影像疾病诊断

Title 题目 Improving breast cancer diagnostics with deep learning for MRI 用深度学习改进乳腺癌MRI诊断 01 文献速递介绍 乳腺磁共振成像&#xff08;MRI&#xff09;是一种检测乳腺癌的高度敏感的方式&#xff0c;报告的敏感性超过80%。传统上&#xff0c;其在筛查…

html+css+js作业王者荣耀司空震1个页面带js

htmlcssjs作业王者荣耀司空震1个页面带js 下载地址 https://download.csdn.net/download/qq_42431718/89595421 目录1 目录2 项目视频 htmlcssjs作业王者荣耀司空震1个页面 页面1

QQ微信头像制图工具箱小程序纯前端源码

微信小程序源码&#xff0c;经测试QQ小程序也可以完美运行&#xff0c;所以给大家分享一下这个QQ微信头像制图工具箱小程序纯前端源码。 主要功能有文字九格、头像挂件生成、爆趣九宫格、形状九宫格、创意长图、情侣头像、猫狗交流器。 这个QQ微信小程序源码是纯前端的&#x…

cesium添加流动线

1&#xff1a;新建Spriteline1MaterialProperty.js文件 import * as Cesium from cesium;export function Spriteline1MaterialProperty(duration, image) {this._definitionChanged new Cesium.Event();this.duration duration;this.image image;this._time performance.…