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

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…...

【AI非常道】二零二五年一月(二),AI非常道

经常在社区看到一些非常有启发或者有收获的话语,但是,往往看过就成为过眼云烟,有时再想去找又找不到。索性,今年开始,看到好的言语,就记录下来,一月一发布,亦供大家参考。 有关AI非…...

jQuery小游戏(二)

jQuery小游戏(二) 今天是新年的第二天,本人在这里祝大家,新年快乐,万事胜意💕 紧接jQuery小游戏(一)的内容,我们开始继续往下咯😜 游戏中使用到的方法 key…...

【硬件测试】基于FPGA的QPSK+帧同步系统开发与硬件片内测试,包含高斯信道,误码统计,可设置SNR

目录 1.算法仿真效果 2.算法涉及理论知识概要 2.1QPSK 2.2 帧同步 3.Verilog核心程序 4.开发板使用说明和如何移植不同的开发板 5.完整算法代码文件获得 1.算法仿真效果 本文是之前写的文章 《基于FPGA的QPSK帧同步系统verilog开发,包含testbench,高斯信道,误码统计,可…...

NVIDIA GPU介绍:概念、序列、核心、A100、H100

概述 入职一家大模型领域创业公司,恶补相关知识。 概念 一些概念: HPC:High Performance Computing,高性能计算SoC:System on Chip,单片系统FLOPS:Floating Point Operations Per Second&am…...

LINUX部署微服务项目步骤

项目简介技术栈 主体技术:SpringCloud,SpringBoot,VUE2, 中间件:RabbitMQ、Redis 创建用户 在linux服务器home下创建用户qshh,用于后续本项目需要的环境进行安装配置 #创建用户 useradd 用户名 #设置登录密…...

C++ list 容器用法

C list 容器用法 C 标准库提供了丰富的功能&#xff0c;其中 <list> 是一个非常重要的容器类&#xff0c;用于存储元素集合&#xff0c;支持双向迭代器。<list> 是 C 标准模板库&#xff08;STL&#xff09;中的一个序列容器&#xff0c;它允许在容器的任意位置快速…...

解密全同态加密中的自举(Bootstrapping)

摘要 自举&#xff08;Bootstrapping&#xff09;是全同态加密&#xff08;Fully Homomorphic Encryption, FHE&#xff09;中经常使用的术语。熟悉 FHE 的人都知道&#xff0c;自举是 FHE 方案中最复杂且计算密集的部分。然而&#xff0c;只有极少数非 FHE 专家真正理解自举操…...

C#方法(练习)

1.定义一个函数&#xff0c;输入三个值,找出三个数中的最小值 2.定义一个函数&#xff0c;输入三个值,找出三个数中的最大值 3.定义一个函数&#xff0c;输入三个值,找出三个数中的平均值 4.定义一个函数&#xff0c;计算一个数的 N 次方 Pow(2, 3)返回8 5.传入十一…...

显示当前绑定变量

来自v$sql中的信息 测试两个变量的情况&#xff08;实际可以看6个&#xff0c;可根据需要修改&#xff09; DROP TABLE T1 PURGE; CREATE TABLE T1 AS SELECT A.*,SYSDATE RIQI FROM DBA_USERS A ORDER BY 1;var mc char(3); var id number; exec :mc:SYS; exec :id:50;set li…...

随机森林例子

完整代码&#xff1a; # 导入必要的库 from sklearn.datasets import load_iris from sklearn.ensemble import RandomForestClassifier from sklearn.model_selection import train_test_split from sklearn.metrics import accuracy_score import numpy as np# 加载鸢尾花数…...

2025年1月个人工作生活总结

本文为 2025年1月工作生活总结。 研发编码 使用sqlite3命令行查询表数据 可以直接使用sqlite3查询数据表&#xff0c;不需进入命令行模式。示例如下&#xff1a; sqlite3 database_name.db "SELECT * FROM table_name;"linux shell使用read超时一例 先前有个编译…...

arm-linux-gnueabihf安装

Linaro Releases windows下打开wsl2中的ubuntu&#xff0c;资源管理器中输入&#xff1a; \\wsl$gcc-linaro-4.9.4-2017.01-x86_64_arm-linux-gnueabihf.tar.xz 复制到/home/ark01/tool 在 Ubuntu 中创建目录&#xff1a; /usr/local/arm&#xff0c;命令如下&#xff1a; …...

vscode和pycharm的区别

VSCode&#xff08;Visual Studio Code&#xff09;和 PyCharm 是两款常用的 Python 开发工具&#xff0c;它们在功能和使用体验上有一些关键区别&#xff1a; 1. 核心定位 VSCode&#xff1a;轻量级、多语言支持的代码编辑器&#xff0c;依靠插件扩展 Python 开发能力。PyCh…...

宝塔面板SSL加密访问设置教程

参考:https://www.bt.cn/bbs/thread-117246-1-1.html 如何快速使用证书加密访问面板 因早期默认未开启https访问所以没有相关的风险提醒&#xff0c;现面板默认已开启https加密访问、提升安全性 由于采用的是服务器内部本身签发证书&#xff0c;不被公网浏览器信任请参考以下步…...

Baklib在知识管理创新中的价值体现与其他产品的优势比较分析

内容概要 在当前的数字化时代&#xff0c;知识管理成为企业成功的重要组成部分。有效的知识管理不仅有助于提升内部沟通效率&#xff0c;还能促进创新与决策的科学化。尤其是Baklib作为一种知识中台&#xff0c;具有独特的价值&#xff0c;它能够融合企业内外的知识资源&#…...

Python 数据分析 - 初识 Pandas

Python 数据分析 - 初识 Pandas 简介SeriesDataFrame创建基本操作添加删除 简介 Pandas 基于 NumPy 开发&#xff0c;它提供了快速、灵活、明确的数据结构&#xff0c;旨在简单、直观地处理数据。 Pandas 适用于处理以下类型的数据&#xff1a; 有序和无序的时间序列数据带行…...

力扣【416. 分割等和子集】详细Java题解(背包问题)

首先我们可以求出数组和&#xff0c;当我们找到一个子集中元素的和为数组和的一半时&#xff0c;该就说明可以分割等和子集。 对于该问题我们可以转换成背包问题&#xff0c;求 数组里的元素 装入 数组和的一半大小的背包 能取得的最大值。 然后注意可以剪枝的地方。 代码&…...

机器学习周报-文献阅读

文章目录 摘要Abstract 1 相关知识1.1 WDN建模1.2 掩码操作&#xff08;Masking Operation&#xff09; 2 论文内容2.1 WDN信息的数据处理2.2 使用所收集的数据构造模型2.2.1 Gated graph neural network2.2.2 Masking operation2.2.3 Training loss2.2.4 Evaluation metrics 2…...

【Linux】Linux C判断两个IPv6地址是否有包含关系

功能说明 要判断两个 IPv6 地址是否具有包含关系&#xff0c;包括前缀的比较&#xff0c;可以通过以下步骤实现&#xff1a; 解析 IPv6 地址和前缀&#xff1a;将两个 IPv6 地址和它们的前缀长度解析为二进制形式。生成掩码&#xff1a;根据前缀长度生成掩码。按位比较&#…...

【Linux】列出所有连接的 WiFi 网络的密码

【Linux】列出所有连接的 WiFi 网络的密码 终端输入 sudo grep psk /etc/NetworkManager/system-connections/*会列出所有连接过 Wifi 的信息&#xff0c;格式类似 /etc/NetworkManager/system-connections/AAAAA.nmconnection:pskBBBBBAAAAA 是 SSID&#xff0c;BBBBB 是对…...

C语言连接Mysql

目录 C语言连接Mysql下载 mysql 开发库 方法介绍mysql_init()mysql_real_connect()mysql_query()mysql_store_result()mysql_num_fields()mysql_fetch_fields()mysql_fetch_row()mysql_free_result()mysql_close() 完整代码 C语言连接Mysql 下载 mysql 开发库 方法一&#xf…...

Synology 群辉NAS安装(6)安装mssql

Synology 群辉NAS安装&#xff08;6&#xff09;安装mssql 写在前面mssql 2019:成功安装说明&#xff0c;这个最终成功了 mssql 2022没有成功1. pull image2.启动mssql docker container 远程连接 写在前面 mssq是一个重要节点。 这是因为我对mysql没有一丝好感。虽然接触了许…...

WEB集群1-5天

文章目录 第一天、1、初始化配置1. 编写的初始化的脚本 init_env.sh2. 远程拷贝初始化脚本到mysql服务器里3.在mysql这台服务器上执行脚本 2、总结 第二天1、yumyum介绍yum操作将冯老师提供的网站的源码包上传到web服务器 2、部署网站1、解压文件2、epel源&#xff1a;可以提供…...

“AI视频智能分析系统:让每一帧视频都充满智慧

嘿&#xff0c;大家好&#xff01;今天咱们来聊聊一个特别厉害的东西——AI视频智能分析系统。想象一下&#xff0c;如果你有一个超级聪明的“视频助手”&#xff0c;它不仅能自动识别视频中的各种元素&#xff0c;还能根据内容生成详细的分析报告&#xff0c;是不是感觉特别酷…...

oracle中使用in 和 not in 查询效率分析

在Oracle数据库中&#xff0c;IN和NOT IN的查询效率受多种因素影响&#xff0c;以下是关键点总结和优化建议&#xff1a; 1. IN 的效率 优化方式&#xff1a; IN 通常会被优化为 OR条件 或 半连接&#xff08;Semi-Join&#xff09;&#xff0c;如果子查询关联到外部表&#x…...

kaggle视频追踪NFL Health Safety - Helmet Assignment

3年前的比赛了&#xff0c;检测视频中的头盔&#xff0c;通过对比赛录像的分析&#xff0c;正确指派球员。每个进攻都有两个相关的视频&#xff0c;一个是边线视角&#xff0c;另一个是端区视角&#xff0c;而且这两个视频是同步的&#xff0c;即视频中的每一帧都是对应的。我用…...

idea对jar包内容进行反编译

1.先安装一下这个插件java Bytecode Decompiler 2.找到这个插件的路径&#xff0c;在idea的plugins下面的lib文件夹内&#xff1a;java-decompiler.jar。下面是我自己本地的插件路径&#xff0c;以作参考&#xff1a; D:\dev\utils\idea\IntelliJ IDEA 2020.1.3\plugins\java-d…...

deepseek R1 14b硬件要求

RTX2080ti 11G显卡&#xff0c;模型7b速度挺快&#xff0c;试试14B也不错。 7B显存使用5.6G&#xff0c;11B显存刚好够&#xff0c;出文字速度差不多。 打算自己写个移动宽带的IPTV播放器&#xff0c;不知道怎么下手&#xff0c;就先问他了。...

DeepSeek-R1环境搭建推理测试

引子 这两天国货之光DeepSeek-R1火爆出圈&#xff0c;凑个热闹。过来看看 aha moment&#xff08;顿悟时刻&#xff09;的神奇&#xff0c;OK&#xff0c;我们开始吧。 一、模型介绍 1月20日&#xff0c;中国AI公司深度求索&#xff08;DeepSeek&#xff09;发布的DeepSeek-…...