Zookeeper的基础介绍和安装教程

1、 Zookeeper入门

1.1 概述

Zookeeper是一个开源的分布式的，为分布式应用提供协调服务的Apache项目。
在这里插入图片描述

1.2 特点

在这里插入图片描述

1.3 数据结构

在这里插入图片描述

1.4 应用场景

提供的服务包括：统一命名服务、统一配置管理、统一集群管理、服务器节点动态上下线、软负载均衡等。

统一命名服务

在这里插入图片描述
统一配置管理
在这里插入图片描述
统一集群管理
在这里插入图片描述
服务器动态上下线

在这里插入图片描述
软负载均衡

在这里插入图片描述

1.5 下载地址

1．官网首页：

https://zookeeper.apache.org/

2. apache的归档目录下载

http://archive.apache.org/dist/zookeeper/

2、 Zookeeper安装

2.1 本地模式安装部署

1．安装前准备
（1）安装Jdk
（2）拷贝Zookeeper安装包到Linux系统下
（3）解压到指定目录
[ybb@hadoop102 software]$ tar -zxvf zookeeper-3.4.10.tar.gz -C /opt/module/
2．配置修改
（1）将/opt/module/zookeeper-3.4.10/conf这个路径下的zoo_sample.cfg修改为zoo.cfg；
[ybb@hadoop102 conf]$ mv zoo_sample.cfg zoo.cfg
（2）打开zoo.cfg文件，修改dataDir路径：
[ybb@hadoop102 zookeeper-3.4.10]$ vim zoo.cfg
修改如下内容：
dataDir=/opt/module/zookeeper-3.4.10/zkData
（3）在/opt/module/zookeeper-3.4.10/这个目录上创建zkData文件夹
[ybb@hadoop102 zookeeper-3.4.10]$ mkdir zkData
3．操作Zookeeper
（1）启动Zookeeper
[ybb@hadoop102 zookeeper-3.4.10]$ bin/zkServer.sh start
（2）查看进程是否启动
[ybb@hadoop102 zookeeper-3.4.10]$ jps
4020 Jps
4001 QuorumPeerMain
（3）查看状态：
[ybb@hadoop102 zookeeper-3.4.10]$ bin/zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /opt/module/zookeeper-3.4.10/bin/…/conf/zoo.cfg
Mode: standalone
（4）启动客户端：
[ybb@hadoop102 zookeeper-3.4.10]$ bin/zkCli.sh
（5）退出客户端：
[zk: localhost:2181(CONNECTED) 0] quit
（6）停止Zookeeper
[ybb@hadoop102 zookeeper-3.4.10]$ bin/zkServer.sh stop

2.2 配置参数解读

Zookeeper中的配置文件zoo.cfg中参数含义解读如下：
1．tickTime =2000：通信心跳数，Zookeeper服务器与客户端心跳时间，单位毫秒
Zookeeper使用的基本时间，服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个tickTime时间就会发送一个心跳，时间单位为毫秒。
它用于心跳机制，并且设置最小的session超时时间为两倍心跳时间。(session的最小超时时间是2*tickTime)
2．initLimit =10：LF初始通信时限
集群中的Follower跟随者服务器与Leader领导者服务器之间初始连接时能容忍的最多心跳数（tickTime的数量），用它来限定集群中的Zookeeper服务器连接到Leader的时限。
3．syncLimit =5：LF同步通信时限
集群中Leader与Follower之间的最大响应时间单位，假如响应超过syncLimit * tickTime，Leader认为Follwer死掉，从服务器列表中删除Follwer。
4．dataDir：数据文件目录+数据持久化路径
主要用于保存Zookeeper中的数据。
5．clientPort =2181：客户端连接端口
监听客户端连接的端口。

3、Zookeeper内部原理

3.1 选举机制

1）半数机制：集群中半数以上机器存活，集群可用。所以Zookeeper适合装在奇数台机器上。
2）Zookeeper虽然在配置文件中并没有指定Master和Slave。但是，Zookeeper工作时，是有一个节点为Leader，其他则为Follower，Leader是通过内部的选举机制临时产生的
3）以一个简单的例子来说明整个选举的过程。
假设有五台服务器组成的Zookeeper集群，它们的id从1-5，同时它们都是最新启动的，也就是没有历史数据，在存放数据量这一点上，都是一样的。假设这些服务器依序启动，来看看会发生什么，如图所示。
在这里插入图片描述

（1）服务器1启动，此时只有它一台服务器启动了，它发出去的报文没有任何响应，所以它的选举状态一直是LOOKING状态。
（2）服务器2启动，它与最开始启动的服务器1进行通信，互相交换自己的选举结果，由于两者都没有历史数据，所以id值较大的服务器2胜出，但是由于没有达到超过半数以上的服务器都同意选举它(这个例子中的半数以上是3)，所以服务器1、2还是继续保持LOOKING状态。
（3）服务器3启动，根据前面的理论分析，服务器3成为服务器1、2、3中的老大，而与上面不同的是，此时有三台服务器选举了它，所以它成为了这次选举的Leader。
（4）服务器4启动，根据前面的分析，理论上服务器4应该是服务器1、2、3、4中最大的，但是由于前面已经有半数以上的服务器选举了服务器3，所以它只能接收当小弟的命了。
（5）服务器5启动，同4一样当小弟。

3.2 节点类型

在这里插入图片描述

3.3 Stat结构体

1）czxid-创建节点的事务zxid
每次修改ZooKeeper状态都会收到一个zxid形式的时间戳，也就是ZooKeeper事务ID。
事务ID是ZooKeeper中所有修改总的次序。每个修改都有唯一的zxid，如果zxid1小于zxid2，那么zxid1在zxid2之前发生。
2）ctime - znode被创建的毫秒数(从1970年开始)
3）mzxid - znode最后更新的事务zxid
4）mtime - znode最后修改的毫秒数(从1970年开始)
5）pZxid-znode最后更新的子节点zxid
6）cversion - znode子节点变化号，znode子节点修改次数
7）dataversion - znode数据变化号
8）aclVersion - znode访问控制列表的变化号
9）ephemeralOwner- 如果是临时节点，这个是znode拥有者的session id。如果不是临时节点则是0。
10）dataLength- znode的数据长度
11）numChildren - znode子节点数量

3.4 监听器原理

在这里插入图片描述

3.5 写数据流程

在这里插入图片描述

4、 Zookeeper实战

4.1 分布式安装部署

1．集群规划
在hadoop102、hadoop103和hadoop104三个节点上部署Zookeeper。

2．解压安装
（1）解压Zookeeper安装包到/opt/module/目录下
[ybb@hadoop102 software]$ tar -zxvf zookeeper-3.4.10.tar.gz -C /opt/module/
（2）同步/opt/module/zookeeper-3.4.10目录内容到hadoop103、hadoop104
[ybb@hadoop102 module]$ xsync zookeeper-3.4.10/
3．配置服务器编号
（1）在/opt/module/zookeeper-3.4.10/这个目录下创建zkData
[ybb@hadoop102 zookeeper-3.4.10]$ mkdir -p zkData
（2）在/opt/module/zookeeper-3.4.10/zkData目录下创建一个myid的文件
[ybb@hadoop102 zkData]$ touch myid
添加myid文件，注意一定要在linux里面创建，在notepad++里面很可能乱码
（3）编辑myid文件
[ybb@hadoop102 zkData]$ vi myid
在文件中添加与server对应的编号：
2
（4）拷贝配置好的zookeeper到其他机器上
[ybb@hadoop102 zkData]$ xsync myid
并分别在hadoop102、hadoop103上修改myid文件中内容为3、4
4．配置zoo.cfg文件
（1）重命名/opt/module/zookeeper-3.4.10/conf这个目录下的zoo_sample.cfg为zoo.cfg
[ybb@hadoop102 conf]$ mv zoo_sample.cfg zoo.cfg
（2）打开zoo.cfg文件
[ybb@hadoop102 conf]$ vim zoo.cfg
修改数据存储路径配置
dataDir=/opt/module/zookeeper-3.4.10/zkData
增加如下配置
#######################cluster##########################
server.2=hadoop102:2888:3888
server.3=hadoop103:2888:3888
server.4=hadoop104:2888:3888
（3）同步zoo.cfg配置文件
[ybb@hadoop102 conf]$ xsync zoo.cfg
（4）配置参数解读
server.A=B:C:D。
A是一个数字，表示这个是第几号服务器；
集群模式下配置一个文件myid，这个文件在dataDir目录下，这个文件里面有一个数据就是A的值，Zookeeper启动时读取此文件，拿到里面的数据与zoo.cfg里面的配置信息比较从而判断到底是哪个server。
B是这个服务器的ip地址；
C是这个服务器与集群中的Leader服务器交换信息的端口；
D是万一集群中的Leader服务器挂了，需要一个端口来重新进行选举，选出一个新的Leader，而这个端口就是用来执行选举时服务器相互通信的端口。
4．集群操作
（1）分别启动Zookeeper
[ybb@hadoop102 zookeeper-3.4.10]$ bin/zkServer.sh start
[ybb@hadoop103 zookeeper-3.4.10]$ bin/zkServer.sh start
[ybb@hadoop104 zookeeper-3.4.10]$ bin/zkServer.sh start
（2）查看状态
[ybb@hadoop102 zookeeper-3.4.10]# bin/zkServer.sh status
JMX enabled by default
Using config: /opt/module/zookeeper-3.4.10/bin/…/conf/zoo.cfg
Mode: follower
[ybb@hadoop103 zookeeper-3.4.10]# bin/zkServer.sh status
JMX enabled by default
Using config: /opt/module/zookeeper-3.4.10/bin/…/conf/zoo.cfg
Mode: leader
[ybb@hadoop104 zookeeper-3.4.5]# bin/zkServer.sh status
JMX enabled by default
Using config: /opt/module/zookeeper-3.4.10/bin/…/conf/zoo.cfg
Mode: follower

4.2 客户端命令行操作

在这里插入图片描述

1．启动客户端

[ybb@hadoop103 zookeeper-3.4.10]$ bin/zkCli.sh

2．显示所有操作命令

[zk: localhost:2181(CONNECTED) 1] help

3．查看当前znode中所包含的内容

[zk: localhost:2181(CONNECTED) 0] ls /
[zookeeper]

4．查看当前节点详细数据

[zk: localhost:2181(CONNECTED) 1] ls2 /
[zookeeper]
cZxid = 0x0
ctime = Thu Jan 01 08:00:00 CST 1970
mZxid = 0x0
mtime = Thu Jan 01 08:00:00 CST 1970
pZxid = 0x0
cversion = -1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 0
numChildren = 1

5．分别创建2个普通节点

[zk: localhost:2181(CONNECTED) 3] create /sanguo “jinlian”
Created /sanguo
[zk: localhost:2181(CONNECTED) 4] create /sanguo/shuguo “liubei”
Created /sanguo/shuguo

6．获得节点的值

[zk: localhost:2181(CONNECTED) 5] get /sanguo
jinlian
cZxid = 0x100000003
ctime = Wed Aug 29 00:03:23 CST 2018
mZxid = 0x100000003
mtime = Wed Aug 29 00:03:23 CST 2018
pZxid = 0x100000004
cversion = 1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 7
numChildren = 1
[zk: localhost:2181(CONNECTED) 6]
[zk: localhost:2181(CONNECTED) 6] get /sanguo/shuguo
liubei
cZxid = 0x100000004
ctime = Wed Aug 29 00:04:35 CST 2018
mZxid = 0x100000004
mtime = Wed Aug 29 00:04:35 CST 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 6
numChildren = 0

7．创建短暂节点

[zk: localhost:2181(CONNECTED) 7] create -e /sanguo/wuguo “zhouyu”
Created /sanguo/wuguo
（1）在当前客户端是能查看到的
[zk: localhost:2181(CONNECTED) 3] ls /sanguo
[wuguo, shuguo]
（2）退出当前客户端然后再重启客户端
[zk: localhost:2181(CONNECTED) 12] quit
[ybb@hadoop104 zookeeper-3.4.10]$ bin/zkCli.sh
（3）再次查看根目录下短暂节点已经删除
[zk: localhost:2181(CONNECTED) 0] ls /sanguo
[shuguo]

8．创建带序号的节点

（1）先创建一个普通的根节点/sanguo/weiguo

[zk: localhost:2181(CONNECTED) 1] create /sanguo/weiguo “caocao”
Created /sanguo/weiguo
（2）创建带序号的节点
[zk: localhost:2181(CONNECTED) 2] create -s /sanguo/weiguo/xiaoqiao “jinlian”
Created /sanguo/weiguo/xiaoqiao0000000000
[zk: localhost:2181(CONNECTED) 3] create -s /sanguo/weiguo/daqiao “jinlian”
Created /sanguo/weiguo/daqiao0000000001
[zk: localhost:2181(CONNECTED) 4] create -s /sanguo/weiguo/diaocan “jinlian”
Created /sanguo/weiguo/diaocan0000000002
如果原来没有序号节点，序号从0开始依次递增。如果原节点下已有2个节点，则再排序时从2开始，以此类推。

9．修改节点数据值

[zk: localhost:2181(CONNECTED) 6] set /sanguo/weiguo “simayi”

10．节点的值变化监听

（1）在hadoop104主机上注册监听/sanguo节点数据变化

[zk: localhost:2181(CONNECTED) 26] [zk: localhost:2181(CONNECTED) 8] get /sanguo watch
（2）在hadoop103主机上修改/sanguo节点的数据
[zk: localhost:2181(CONNECTED) 1] set /sanguo “xisi”
（3）观察hadoop104主机收到数据变化的监听
WATCHER::
WatchedEvent state:SyncConnected type:NodeDataChanged path:/sanguo

11．节点的子节点变化监听（路径变化）

（1）在hadoop104主机上注册监听/sanguo节点的子节点变化

[zk: localhost:2181(CONNECTED) 1] ls /sanguo watch
[aa0000000001, server101]
（2）在hadoop103主机/sanguo节点上创建子节点
[zk: localhost:2181(CONNECTED) 2] create /sanguo/jin “simayi”
Created /sanguo/jin
（3）观察hadoop104主机收到子节点变化的监听
WATCHER::
WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/sanguo

12．删除节点

[zk: localhost:2181(CONNECTED) 4] delete /sanguo/jin

13．递归删除节点

[zk: localhost:2181(CONNECTED) 15] rmr /sanguo/shuguo

14．查看节点状态

[zk: localhost:2181(CONNECTED) 17] stat /sanguo
cZxid = 0x100000003
ctime = Wed Aug 29 00:03:23 CST 2018
mZxid = 0x100000011
mtime = Wed Aug 29 00:21:23 CST 2018
pZxid = 0x100000014
cversion = 9
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 4
numChildren = 1

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

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

相关文章

ros gazebo机械臂仿真，手动控制与MoveIt自动控制

ros gazebo机械臂仿真，手动控制与MoveIt自动控制

本文总结归纳古月居胡春旭ros机械臂教程，给出了一些error的解决方法，补充了通过python运行moveit。十分建议去看github huchunxu源代码的repository。 创建机械臂的xacro模型 首先创建一个工作空间，在工作空间中创建arm_description功能包。…
阅读更多...
GPT如何完成AI绘图？

GPT如何完成AI绘图？

详情点击链接：GPT如何完成AI绘图？ 一OpenAI 1.最新大模型GPT-4 Turbo 2.最新发布的高级数据分析，AI画图，图像识别，文档API 3.GPT Store 4.从0到1创建自己的GPT应用 5. 模型Gemini以及大模型Claude2二定制自己的GP…
阅读更多...
react antd 计算公式 (+-*/)运算，回显

react antd 计算公式 (+-*/)运算，回显

计算器的源码计算器触发事件源码 import {DictValueEnumObj } from @/components/DictTag; import {getDeptTree, getFormulaListAll, getListAll } from @/services/Energy/Metering;import {getListAllInfo, getDepartmentName } from @/services/Energy/Calculation; import…
阅读更多...
蓝牙网关在物联网领域三大应用

蓝牙网关在物联网领域三大应用

蓝牙网关在物联网的应用主要包括物联网室内定位、物联网数据采集、物联网连接控制三大应用领域，以下对三大应用领域做详细解释。 一、物联网蓝牙室内定位 蓝牙网关在室内定位的应用包括人员定位和资产设备定位两大方向。 1、人员定位 蓝牙网关安装于室内的特定地…
阅读更多...
护眼灯哪个品牌最好？2024年十大护眼灯品牌排行榜

护眼灯哪个品牌最好？2024年十大护眼灯品牌排行榜

由于科技水平的提高和电子产品的普及，儿童青少年的近视率正逐年攀升，出现低龄化现象，面对眼健康问题的严峻形势，我们应该还有爱眼意识、加强眼健康知识普及！现在呢，护眼台灯被越来越多的人发现了&#xff0…
阅读更多...
接口芯片选型分析 四通道差分驱动可满足ANSI TIA/EIA-422-B 和ITU V.11 的要求 低功耗，高速率，高ESD

接口芯片选型分析 四通道差分驱动可满足ANSI TIA/EIA-422-B 和ITU V.11 的要求 低功耗，高速率，高ESD

四通道差分驱动可满足ANSI TIA/EIA-422-B 和ITU V.11 的要求 低功耗，高速率，高ESD。 其中GC26L31S可替代AM26LS31/TI，GC26L32S替代AM26LS32/TI，GC26E31S替代TI的AM26LV31E
阅读更多...
如何快速制作网址的静态码？网址二维码在线制作的简单技巧

如何快速制作网址的静态码？网址二维码在线制作的简单技巧

现在很多人会将网址转换成静态二维码来使用，一个原因是扫码更符合现在人们的生活习惯，二来是采用二维码图片来做传播能够有效的节省制作者的成本，而且容易更快的完成网址内容的传播，所以将网址生成二维码的方法现在应用非常的广泛…
阅读更多...
U盘无法安全弹出怎么办？

U盘无法安全弹出怎么办？

当电脑弹出“弹出USB大容量存储设备时出问题”提示时，只能抱着侥幸的心理直接拔出，如果运气好，可能没有什么事，如果运气不好，你的U盘可能就会报废。那么，为什么U盘无法弹出？遇到U盘无法安全弹出…
阅读更多...
ORA-600 adg无法查询故障

ORA-600 adg无法查询故障

再续前缘 ORA-600[12406]故障解决-CSDN博客 当你点背的时候，看似一个简单的case，总是会迎来反转 上次改完参数没两天，又出现了报错不同，但是现象相似的情况 这次是 ORA-600 [kksgaGetNoAlloc_Int0] 这次出现故障的范围更大&a…
阅读更多...
windows@管理员用户账户

windows@管理员用户账户

文章目录 windows中的管理员用户账户将某个用户提升为管理员🎈直接创建一个管理员账户😊使用lusrmgr.msc程序创建先新建一个用户FAQ 在管理员组中添加新用户为管理员🎈方式1:手动输入方式2:在已有的用户列表中查找并选中修改/禁用pin码(普通情…
阅读更多...
Vue中Vuex的环境搭建和原理分析及使用

Vue中Vuex的环境搭建和原理分析及使用

Vuex的环境搭建 Vuex是Vue实现集中式数据管理的Vue的一个插件，集中式可以理解为一个老师给多个学生讲课。 Vue2.0版本的安装： npm i vuex3 使用Vuex需要在store中的index.js引入Vuex和main.js中引入store,目的是让vm和vc都能看到$store。实现多个组件…
阅读更多...
降噪自编码器（Denoising Autoencoder）

降噪自编码器（Denoising Autoencoder）

降噪自编码器（Denoising Autoencoder）是一种用于无监督学习的神经网络模型。与普通的自编码器不同，降噪自编码器的目标是通过在输入数据中引入噪声，然后尝试从具有噪声的输入中重建原始无噪声数据。 以下是降噪自编码器的主要特点…
阅读更多...
基于SSM的停车管理系统设计与实现

基于SSM的停车管理系统设计与实现

末尾获取源码 开发语言：Java Java开发工具：JDK1.8 后端框架：SSM 前端：采用JSP技术开发 数据库：MySQL5.7和Navicat管理工具结合 服务器：Tomcat8.5 开发软件：IDEA / Eclipse 是否Maven项目&#x…
阅读更多...
Pytest自动化测试框架

Pytest自动化测试框架

1、pytest简介 pytest是Python的一种单元测试框架，与python自带的unittest测试框架类似，但是比unittest框架使用起来更简洁，效率更高。 执行测试过程中可以将某些测试跳过，或者对某些预期失败的case标记成失败能够支持简单的单元…
阅读更多...
关于vite的glob坑

关于vite的glob坑

我先展示一段代码： /*** function 根据pages路径动态生成路由* param {Array} 基础路由*/ export default function (routes) {const modules import.meta.glob("../pages/**/page.js", { eager: true, import: "default" });const comps im…
阅读更多...
如何让ArcGIS Pro启动显示空白页面

如何让ArcGIS Pro启动显示空白页面

刚接触ArcGIS Pro的你是否会觉得在操作上有那么一些不习惯，从一开始软件启动就发现和ArcGIS差距很大：丰富的欢迎页面，加上默认加载的地图让你眼花缭乱，这里教你如何去掉这些繁杂的内容，还你一个干净的启动页面。 跳过…
阅读更多...
【算法】算法设计与分析 期末复习总结

【算法】算法设计与分析 期末复习总结

第一章 算法概述 时间复杂度比大小，用代入法，代入2即可。求渐进表达式，就是求极限，以极限为O的括号；O是指上界，Ω是指下界，θ是指上下界相等，在这里，可以这样理解&#…
阅读更多...
6.综合案例

6.综合案例

1. 需求描述 1.1 显示所有员工信息 URI：emps 请求方式：GET 显示效果 1.2 添加操作- 去往添加页面 显示添加页面： URI：emp 请求方式：GET 显示效果 1.3 添加操作- 添加员工 添加员工信息： URI：emp 请求方式：POST 显示效果：完成添加， 重定向到 list 页面。 1.4…
阅读更多...
【深度学习：Domain Adversarial Neural Networks (DANN) 】领域对抗神经网络简介

【深度学习：Domain Adversarial Neural Networks (DANN) 】领域对抗神经网络简介

【深度学习：Domain Adversarial Neural Networks】领域对抗神经网络简介 前言领域对抗神经网络DANN 模型架构DANN 训练流程DANN示例 GPT示例 前言 领域适应（DA）指的是当不同数据集的输入分布发生变化（这种变化通常被称为共变量变…
阅读更多...
RT-Thread 内核基础（三）

RT-Thread 内核基础（三）

程序内存分布 一般MCU包含的存储空间有：片内Flash与片内RAM，RAM相当于内存，Flash相当于硬盘。 编译器会将一个程序分类为好几个部分，分别存储在MCU不同的存储区。 Keil工程在编译完之后，会有相应的程序所占用的空间提…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023