当前位置: 首页 > news >正文

Zookeeper入门部署(单点与集群)

          本篇文章基于docker方式部署zookeeper集群,请先安装docker

目录

1.  docker初期准备

2.启动zookeeper

        2.1 单点部署

        2.2 集群部署

 3. Linux脚本实现快速切换启动关闭


1.  docker初期准备

        拉取zookeeper镜像

docker pull zookeeper:3.5.6

        如果拉取时间过长,可以配置docker镜像源重启docker后重试

sudo bash -c 'echo '\''{"registry-mirrors": ["https://05f073ad3c0010ea0f4bc00b7105ec20.mirror.swr.myhuaweicloud.com","https://mirror.ccs.tencentyun.com","https://0dj0t5fb.mirror.aliyuncs.com","https://docker.mirrors.ustc.edu.cn","https://6kx4zyno.mirror.aliyuncs.com","https://akchsmlh.mirror.aliyuncs.com","https://hub-mirror.c.163.com","https://mirror.baidubce.com"]
}'\'' > /etc/docker/daemon.json'
sudo systemctl daemon-reload
sudo systemctl restart docker

        创建docker网络(方便集群内部通信)

docker network create zookeeper-net

2.启动zookeeper

        2.1 单点部署

        启动docker容器

        第一台

# 指定容器名称 zookeeper
# 指定容器的主机名 zookeeper(在容器网络中使用的名称)
# 将容器加入名为 zookeeper-net 的 Docker 网络(方便集群扩展)
# 将容器的 2181 端口映射到宿主机的 2181 端口(Zookeeper 客户端默认端口)
# 设置容器的时区为 Asia/Shanghai
# 卷挂载:将宿主机的 /root/zookeeper/node-1/data 目录挂载到容器的 /data 目录(用于存储 Zookeeper 数据)
# 卷挂载:将宿主机的 /root/zookeeper/node-1/conf 目录挂载到容器的 /conf 目录(用于存放 Zookeeper 配置文件)
# 使用 zookeeper:3.5.6 镜像启动容器
docker run -d \--name zookeeper \--hostname zookeeper \--network zookeeper-net \-p 2181:2181 \-e TZ="Asia/Shanghai" \-v /root/zookeeper/node-1/data:/data \-v /root/zookeeper/node-1/conf:/conf \zookeeper:3.5.6

         默认生成的配置文件都是单点部署的配置文件,那么单点部署就已经完成了

        2.2 集群部署

        由于zookeeper的选举机制是超过半数可用才能正常提供服务,因此一般集群个数为奇数台,这里以三台作案例

        启动第二台

docker run -d \--name zookeeper-2 \--hostname zookeeper-2 \--network zookeeper-net \-p 2182:2181 \-e TZ="Asia/Shanghai" \-v /root/zookeeper/node-2/data:/data \-v /root/zookeeper/node-2/conf:/conf \zookeeper:3.5.6

        启动第三台

docker run -d \--name zookeeper-3 \--hostname zookeeper-3 \--network zookeeper-net \-p 2183:2181 \-e TZ="Asia/Shanghai" \-v /root/zookeeper/node-3/data:/data \-v /root/zookeeper/node-3/conf:/conf \zookeeper:3.5.6

        

        现在我们有了三台zookeeper单点的容器,让我们把它们配置成一个集群

        首先执行以下命令将默认生成的单点配置文件备份

cp /root/zookeeper/node-1/conf/zoo.cfg /root/zookeeper/node-1/conf/zooAlone.cfg

        接着生成集群配置文件

echo 'dataDir=/data
dataLogDir=/datalog
tickTime=2000
initLimit=5
syncLimit=2
autopurge.snapRetainCount=3
autopurge.purgeInterval=0
maxClientCnxns=60
clientPort=2181
admin.enableServer=true
server.1=zookeeper:2888:3888
server.2=zookeeper-2:2888:3888
server.3=zookeeper-3:2888:3888' > /root/zookeeper/node-1/conf/zooCluster.cfg

        使用集群配置文件覆写

cp /root/zookeeper/node-1/conf/zooCluster.cfg /root/zookeeper/node-1/conf/zoo.cfg

        这样我们就有了三个文件zoo.cfg,zooCluster.cfg和zooAlone.cfg,zookeeper启动时会读取的是zoo.cfg文件,我们可以根据启动场景使用另外两个配置文件灵活覆写zoo.cfg

        因为已经有一个备份配置文件了,并且单点启动的话只需要启动结点1即可,结点2和3的配置文件可以不进行备份直接覆写

echo 'dataDir=/data
dataLogDir=/datalog
tickTime=2000
initLimit=5
syncLimit=2
autopurge.snapRetainCount=3
autopurge.purgeInterval=0
maxClientCnxns=60
clientPort=2181
admin.enableServer=true
server.1=zookeeper:2888:3888
server.2=zookeeper-2:2888:3888
server.3=zookeeper-3:2888:3888' > /root/zookeeper/node-2/conf/zoo.cfg
echo 'dataDir=/data
dataLogDir=/datalog
tickTime=2000
initLimit=5
syncLimit=2
autopurge.snapRetainCount=3
autopurge.purgeInterval=0
maxClientCnxns=60
clientPort=2181
admin.enableServer=true
server.1=zookeeper:2888:3888
server.2=zookeeper-2:2888:3888
server.3=zookeeper-3:2888:3888' > /root/zookeeper/node-2/conf/zoo.cfg

       

        【重要】

        我们需要编辑/root/zookeeper/node-1/data/myid文件

vim /root/zookeeper/node-1/data/myid

        结点1一般默认内容都是1,不用动即可

1

        这个myid是zookeeper集群内部的身份标识,必须唯一才能启动成功

        同理需要保证结点2,结点三的myid在集群内部唯一

vim /root/zookeeper/node-2/data/myid
2
vim /root/zookeeper/node-3/data/myid
3

        重启容器加载配置文件

docker restart zookeeper
docker restart zookeeper-2
docker restart zookeeper-3

 3. Linux脚本实现快速切换启动关闭

        因为作者的云服务器资源经常不够,虽然学习过程中常常需要集群环境进行选举机制等研究,但是实际使用环境单点部署完全够用了,所以作者需要常常面临单点部署和集群部署模式的切换。对此,作者使用了编写Linux脚本的方式进行快速管理

          单点管理脚本

vim /root/zookeeper/zookeeperAlone.sh
NODES=("zookeeper")# 检查是否提供了正确的参数
if [ $# -ne 1 ]; thenecho "Usage: $0 {start|stop|restart}"exit 1
fi# 获取操作类型
OPERATION=$1# 检查操作类型是否有效
if [[ "$OPERATION" != "start" && "$OPERATION" != "stop" && "$OPERATION" != "restart" ]]; thenecho "Invalid argument. Usage: $0 {start|stop|restart}"exit 1
fi# 覆写 zoo.cfg 文件
ZOO_CLUSTER_CFG="/root/zookeeper/node-1/conf/zooAlone.cfg"
ZOO_CFG="/root/zookeeper/node-1/conf/zoo.cfg"if [ -f "$ZOO_CLUSTER_CFG" ]; thenecho "Copying $ZOO_CLUSTER_CFG to $ZOO_CFG..."cp "$ZOO_CLUSTER_CFG" "$ZOO_CFG"if [ $? -eq 0 ]; thenecho "Configuration file updated successfully."elseecho "Failed to update configuration file."exit 1fi
elseecho "zooCluster.cfg not found in /root/zookeeper/node-1/conf."exit 1
fi# 执行操作
for node in "${NODES[@]}"; doecho "$OPERATION $node..."docker "$OPERATION" "$node"if [ $? -eq 0 ]; thenecho "$node $OPERATION successfully."elseecho "Failed to $OPERATION $node."fi
done

        集群管理脚本

vim /root/zookeeper/zookeeperCluster.sh
#!/bin/bash# 定义节点列表
NODES=("zookeeper" "zookeeper-2" "zookeeper-3")# 检查是否提供了正确的参数
if [ $# -ne 1 ]; thenecho "Usage: $0 {start|stop|restart}"exit 1
fi# 获取操作类型
OPERATION=$1# 检查操作类型是否有效
if [[ "$OPERATION" != "start" && "$OPERATION" != "stop" && "$OPERATION" != "restart" ]]; thenecho "Invalid argument. Usage: $0 {start|stop|restart}"exit 1
fi# 覆写 zoo.cfg 文件
ZOO_CLUSTER_CFG="/root/zookeeper/node-1/conf/zooCluster.cfg"
ZOO_CFG="/root/zookeeper/node-1/conf/zoo.cfg"if [ -f "$ZOO_CLUSTER_CFG" ]; thenecho "Copying $ZOO_CLUSTER_CFG to $ZOO_CFG..."cp "$ZOO_CLUSTER_CFG" "$ZOO_CFG"if [ $? -eq 0 ]; thenecho "Configuration file updated successfully."elseecho "Failed to update configuration file."exit 1fi
elseecho "zooCluster.cfg not found in /root/zookeeper/node-1/conf."exit 1
fi# 执行操作
for node in "${NODES[@]}"; doecho "$OPERATION $node..."docker "$OPERATION" "$node"if [ $? -eq 0 ]; thenecho "$node $OPERATION successfully."elseecho "Failed to $OPERATION $node."fi
done

          添加可执行权限

chmod +x /root/zookeeper/zookeeperAlone.sh
chmod +x /root/zookeeper/zookeeperCluster.sh

        使用方式:

        单节点

#开启
#关闭
#重启
./root/zookeeper/zookeeperAlone.sh start
./root/zookeeper/zookeeperAlone.sh stop
./root/zookeeper/zookeeperAlone.sh restart

        集群

#开启
#关闭
#重启
./root/zookeeper/zookeeperCluster.sh start
./root/zookeeper/zookeeperCluster.sh stop
./root/zookeeper/zookeeperCluster.sh restart

        读者也可以自己修改脚本内容尝试添加更多参数命令

相关文章:

Zookeeper入门部署(单点与集群)

本篇文章基于docker方式部署zookeeper集群,请先安装docker 目录 1. docker初期准备 2.启动zookeeper 2.1 单点部署 2.2 集群部署 3. Linux脚本实现快速切换启动关闭 1. docker初期准备 拉取zookeeper镜像 docker pull zookeeper:3.5.6 如果拉取时间过长&#xf…...

Kafa分区策略实现

引言 Kafka 的分区策略决定了生产者发送的消息会被分配到哪个分区中,合理的分区策略有助于实现负载均衡、提高消息处理效率以及满足特定的业务需求。 轮询策略(默认) 轮询策略是 Kafka 默认的分区策略(当消息没有指定键时&…...

Pyside/Pyqt中QWebEngineView和QWebEnginePage的区别

在 PySide/Qt 的 WebEngine 模块中,QWebEngineView 和 QWebEnginePage 是两个紧密相关但职责不同的类。以下是它们的核心区别和关系: 1. 职责区分 类名核心职责模块归属QWebEngineView作为可视化的窗口部件(Widget),负…...

Kafka的内部通信协议

引言 kafka内部用到的常见协议和优缺点可以看看原文 Kafka用到的协议 本文奖详细探究kafka核心通信协议和高性能的关键 网络层通信的实现 基于 Java NIO:Kafka 的网络通信层主要基于 Java NIO 来实现,这使得它能够高效地处理大量的连接和数据传输。…...

强大到工业层面的软件

电脑数据删不干净,简直是一种让人抓狂的折磨!明明已经把文件扔进了回收站,清空了,可那些残留的数据就像牛皮癣一样,怎么也除不掉。这种烦恼简直无处不在,让人从头到脚都感到无比烦躁。 首先,心…...

数据分析和AI丨应对AI实施挑战,工程领域AI应用的五大方法

工程领域的人工智能 (AI) 已经开始发挥价值,低代码和无代码工具正在使曾经仅属于专业数据科学家的 AI 能力变得大众化。 然而,并非工程领域的每个人都能从中受益,使用新的便捷的 AI 工具提高工作效率并不难&#xff0c…...

54. UDP协议

UDP协议 UDP(User Datagram Protocol,用户数据报协议)是一个无连接的传输层协议,它提供简单的、不可靠的信息传送服务。与TCP(传输控制协议)不同,UDP不提供数据包的排序、错误检查(仅…...

AJAX笔记入门篇

黑马程序员视频地址: 黑马程序员前端AJAX入门到实战全套教程https://www.bilibili.com/video/BV1MN411y7pw?vd_source0a2d366696f87e241adc64419bf12cab&spm_id_from333.788.videopod.episodes&p2https://www.bilibili.com/video/BV1MN411y7pw?vd_source…...

深入解析Java集合框架:春招面试要点

在上一篇文章中,我们深入探讨了Java核心基础,这是学习Java的基石。而在实际的Java开发中,集合框架的使用频率极高,它为我们提供了丰富的数据结构和算法实现,极大地提高了开发效率。对于春招面试来说,集合框…...

【Elasticsearch】Elasticsearch的查询

Elasticsearch的查询 DSL查询基础语句叶子查询全文检索查询matchmulti_match 精确查询termrange 复合查询算分函数查询bool查询 排序分页基础分页深度分页 高亮高亮原理实现高亮 RestClient查询基础查询叶子查询复合查询排序和分页高亮 数据聚合DSL实现聚合Bucket聚合带条件聚合…...

STM32 PWM驱动直流电机

接线图: 代码配置: 根据驱动舵机的代码来写,与舵机不同的是,这次的引脚接到了PA2上,所以需要改一下引脚以及改为OC3通道。 另外还需在配置两个GPIO引脚,来控制电机的旋转方向,这里连接到了PA4与…...

系统思考—心智模式

“我们的大脑对连贯性的渴望远胜于对准确性的追求。”—诺贝尔经济学得主丹尼尔卡尼曼 在面对复杂的决策时,我们往往更倾向于寻找那些能够迅速串联起来的信息,而非深入挖掘每一个细节的真实性。这种倾向在日常生活中或许能帮助我们迅速作出决策&#xf…...

JavaScript_02 表单

表单常用演示: 1.图片 结果失真了... 2.切换图片 切换结果 3.表单:...

【Qt】06-对话框

对话框 前言一、模态和非模态对话框1.1 概念1.2 模态对话框1.2.1 代码QAction类 1.2.2 模态对话框运行分析 1.3 非模态对话框1.3.1 代码局部变量和成员变量setAttribute 类 1.3.2 现象解释 二、标准对话框2.1 提示对话框 QMessageBox2.1.1 现象及解释 2.2 问题对话框2.2.1 现象…...

AI学习指南Ollama篇-使用Ollama构建自己的私有化知识库

一、引言 (一)背景介绍 随着企业对数据隐私和效率的重视,私有化知识库的需求日益增长。私有化知识库不仅可以保护企业数据的安全性,还能提供高效的知识管理和问答系统,提升企业内部的工作效率和创新能力。 (二)Ollama和AnythingLLM的结合 Ollama和AnythingLLM的结合…...

2.策略模式(Strategy)

定义 定义一系列算法,把它们一个个封装起来,并且使他们可互相替换(变化)。该模式使算法可独立于使用它的客户程序(稳定)而变化(拓展,子类化)。 动机(Motiva…...

Python里的小整数问题挺有意思的

简单来说,Python为了优化性能,会把一些常用的整数(通常是-5到256)提前创建好,放到一个“缓存池”里。这样,当你用到这些小整数时,Python就不用每次都重新创建对象了,直接从缓存池里拿…...

开源智慧园区管理系统对比五款主流产品探索智能运营新模式

内容概要 在这个数字化迅速发展的时代,园区管理也迎来了全新的机遇和挑战。众所周知,开源智慧园区管理系统作为一种创新解决方案,正逐步打破传统管理的局限性。它的开放性不仅使得系统可以根据具体需求进行灵活调整,也为用户提供…...

正则表达式入门

入门 1、提取文章中所有的英文单词 //1.先创建一个Pattern对象,模式对象,可以理解成就是一个正则表达式对象 Pattern pattern Pattern.compile("[a-zA-Z]"); //2.创建一个匹配器对象 //理解:就是 matcher匹配器按照p…...

hive:数据导入,数据导出,加载数据到Hive,复制表结构

hive不建议用insert,因为Hive是建立在Hadoop之上的数据仓库工具,主要用于批处理和大数据分析,而不是为OLTP(在线事务处理)操作设计的。INSERT操作会非常慢 数据导入 命令行界面:建一个文件 查询数据>>复制>>粘贴到新…...

Zustand 状态管理库:极简而强大的解决方案

Zustand 是一个轻量级、快速和可扩展的状态管理库,特别适合 React 应用。它以简洁的 API 和高效的性能解决了 Redux 等状态管理方案中的繁琐问题。 核心优势对比 基本使用指南 1. 创建 Store // store.js import create from zustandconst useStore create((set)…...

【2025年】解决Burpsuite抓不到https包的问题

环境:windows11 burpsuite:2025.5 在抓取https网站时,burpsuite抓取不到https数据包,只显示: 解决该问题只需如下三个步骤: 1、浏览器中访问 http://burp 2、下载 CA certificate 证书 3、在设置--隐私与安全--…...

python爬虫:Newspaper3k 的详细使用(好用的新闻网站文章抓取和解析的Python库)

更多内容请见: 爬虫和逆向教程-专栏介绍和目录 文章目录 一、Newspaper3k 概述1.1 Newspaper3k 介绍1.2 主要功能1.3 典型应用场景1.4 安装二、基本用法2.2 提取单篇文章的内容2.2 处理多篇文档三、高级选项3.1 自定义配置3.2 分析文章情感四、实战案例4.1 构建新闻摘要聚合器…...

ETLCloud可能遇到的问题有哪些?常见坑位解析

数据集成平台ETLCloud,主要用于支持数据的抽取(Extract)、转换(Transform)和加载(Load)过程。提供了一个简洁直观的界面,以便用户可以在不同的数据源之间轻松地进行数据迁移和转换。…...

汇编常见指令

汇编常见指令 一、数据传送指令 指令功能示例说明MOV数据传送MOV EAX, 10将立即数 10 送入 EAXMOV [EBX], EAX将 EAX 值存入 EBX 指向的内存LEA加载有效地址LEA EAX, [EBX4]将 EBX4 的地址存入 EAX(不访问内存)XCHG交换数据XCHG EAX, EBX交换 EAX 和 EB…...

C++课设:简易日历程序(支持传统节假日 + 二十四节气 + 个人纪念日管理)

名人说:路漫漫其修远兮,吾将上下而求索。—— 屈原《离骚》 创作者:Code_流苏(CSDN)(一个喜欢古诗词和编程的Coder😊) 专栏介绍:《编程项目实战》 目录 一、为什么要开发一个日历程序?1. 深入理解时间算法2. 练习面向对象设计3. 学习数据结构应用二、核心算法深度解析…...

如何通过git命令查看项目连接的仓库地址?

要通过 Git 命令查看项目连接的仓库地址,您可以使用以下几种方法: 1. 查看所有远程仓库地址 使用 git remote -v 命令,它会显示项目中配置的所有远程仓库及其对应的 URL: git remote -v输出示例: origin https://…...

以太网PHY布局布线指南

1. 简介 对于以太网布局布线遵循以下准则很重要,因为这将有助于减少信号发射,最大程度地减少噪声,确保器件作用,最大程度地减少泄漏并提高信号质量。 2. PHY设计准则 2.1 DRC错误检查 首先检查DRC规则是否设置正确,然…...

关于疲劳分析的各种方法

疲劳寿命预测方法很多。按疲劳裂纹形成寿命预测的基本假定和控制参数,可分为名义应力法、局部应力一应变法、能量法、场强法等。 1名义应力法 名义应力法是以结构的名义应力为试验和寿命估算的基础,采用雨流法取出一个个相互独立、互不相关的应力循环&…...

信息收集:从图像元数据(隐藏信息收集)到用户身份的揭秘 --- 7000

目录 🌐 访问Web服务 💻 分析源代码 ⬇️ 下载图片并保留元数据 🔍 提取元数据(重点) 👤 生成用户名列表 🛠️ 技术原理 图片元数据(EXIF 数据) Username-Anarch…...