网站不用域名需要备案吗,魏县网站制作,电子网站设计,it前端和后端的区别Zookeeper基础入门-1【集群搭建】 一、Zookeeper 入门1.1.概述1.2.Zookeeper工作机制1.3.Zookeeper特点1.4.数据结构1.5.应用场景1.5.1.统一命名服务1.5.2.统一配置管理1.5.3.统一集群管理1.5.4.服务器动态上下线1.5.5.软负载均衡 1.6.Zookeeper官网1.6.1.Zookeeper下载1.6.2.历… Zookeeper基础入门-1【集群搭建】 一、Zookeeper 入门1.1.概述1.2.Zookeeper工作机制1.3.Zookeeper特点1.4.数据结构1.5.应用场景1.5.1.统一命名服务1.5.2.统一配置管理1.5.3.统一集群管理1.5.4.服务器动态上下线1.5.5.软负载均衡 1.6.Zookeeper官网1.6.1.Zookeeper下载1.6.2.历史版本1.6.3.下载Linux 环境安装的tar包 二、Zookeeper安装【Centos7】2.1.环境要求2.1.1.安装JDK2.1.2.上传apache-zookeeper-3.5.7-bin.tar.gz 安装包到/opt/module目录下2.1.3.解压到指定目录2.1.4.修改文件夹名称 2.2.配置修改2.2.1.将zookeeper-3.5.7/conf 路径下的 zoo_sample.cfg 修改为 zoo.cfg2.2.2.修改zookeeper数据文件存放目录2.2.3.创建相关数据文件存放目录 2.3.操作Zookeeper2.3.1.添加到环境变量2.3.2.启动Zookeeper2.3.3.查看进程是否启动2.3.4.ZooKeeper服务端口为2181查看服务已经启动2.3.5.查看状态2.3.6.启动客户端2.3.7.退出客户端2.3.8.停止Zookeeper2.3.9.查看数据文件存放目录zkData 2.4.配置参数解读2.4.1.tickTime 2000通信心跳时间Zookeeper服务器与客户端心跳时间单位毫秒2.4.2.initLimit 10LF初始通信时限2.4.3.syncLimit 5LF同步通信时限2.4.4.dataDir保存Zookeeper中的数据2.4.5.clientPort 2181客户端连接端口通常不做修改 三、Zookeeper 集群操作3.1.集群操作3.1.1.集群安装3.1.1.1.集群规划3.1.1.2.解压安装3.1.1.3.配置服务器编号3.1.1.3.1.创建相关数据文件存放目录 zkData3.1.1.3.2.创建一个 myid 的文件【】3.1.1.3.3.拷贝配置好的 zookeeper 到其他机器上 3.1.1.4.配置zoo.cfg文件3.1.1.4.1.拷贝配置文件zoo_sample.cfg 为zoo.cfg3.1.1.4.2.修改zookeeper配置文件zoo.cfg【】3.1.1.4.3.配置参数解读【】3.1.1.4.4.同步zoo.cfg 配置文件3.1.1.4.5.修改zkEnv.sh文件并同步配置java环境变量 3.1.1.5.集群操作3.1.1.5.1.分别启动Zookeeper3.1.1.5.2.查看状态 3.1.2.选举机制面试重点3.1.2.1.Zookeeper选举机制——第一次启动3.1.2.2.Zookeeper选举机制——非第一次启动 3.1.3.ZK 集群启动停止脚本3.1.3.1.在host128 创建脚本3.1.3.2.脚本内容3.1.3.3.增加脚本执行权限3.1.3.4.Zookeeper 集群启动3.1.3.5.Zookeeper 集群状态3.1.3.6.Zookeeper 集群停止 3.1.4.显示集群的所有java进程状态jpsall 脚本3.1.4.1.在host128 创建脚本3.1.4.2.脚本内容3.1.4.3.增加脚本执行权限3.1.4.4.执行脚本 3.2. 客户端命令行操作3.2.1.命令行基本语法3.2.1.1.启动客户端3.2.1.2.显示所有的操作命令 3.2.2.znode 节点数据信息3.2.2.1.查看当前znode中所包含的内容3.2.2.2.查看当前节点详细数据 3.2.3.节点类型持久/短暂/有序号/无序号3.2.3.1.分别创建2个普通节点永久节点 不带序号3.2.3.2.获得节点的值3.2.3.3.创建带序号的节点永久节点 带序号3.2.3.3.1.先创建一个普通的根节点/sanguo/weiguo3.2.3.3.2.创建带序号的节点 3.2.3.4.创建短暂节点短暂节点 不带序号 or 带序号3.2.3.4.1.创建短暂的不带序号的节点3.2.3.4.2.创建短暂的带序号的节点3.2.3.4.3.在当前客户端是能查看到的3.2.3.4.4.退出当前客户端然后再重启客户端3.2.3.4.5.再次查看根目录下短暂节点已经删除 3.2.3.5.修改节点数据值 3.2.4.监听器原理3.2.4.1.监听原理详解3.2.4.2.常见的监听3.2.4.3.节点的值变化监听3.2.4.4.节点的子节点变化监听路径变化 3.2.5.节点删除与查看3.2.5.1.查看节点状态3.2.5.2.删除节点3.2.5.3.递归删除节点 endl 一、Zookeeper 入门
1.1.概述
Zookeeper 是一个开源的分布式的为分布式框架提供协调服务的Apache 项目。
1.2.Zookeeper工作机制
Zookeeper从设计模式角度来理解是一个基于观察者模式设计的分布式服务管理框架它负责存储和管理大家都关心的数据然后接受观察者的注册一旦这些数据的状态发生变化Zookeeper就将负责通知已经在Zookeeper上注册的那些观察者做出相应的反应。 1.3.Zookeeper特点 1 Zookeeper一个领导者Leader多个跟随者Follower组成的集群。 2 集群中只要有半数以上节点存活Zookeeper集群就能正常服务。所以Zookeeper适合安装奇数台服务器。 3 全局数据一致每个Server保存一份相同的数据副本Client无论连接到哪个Server数据都是一致的。 4 更新请求顺序执行来自同一个Client的更新请求按其发送顺序依次执行。 5 数据更新原子性一次数据更新要么成功要么失败。 6 实时性在一定时间范围内Client能读到最新数据。
1.4.数据结构
ZooKeeper 数据模型的结构与 Unix 文件系统很类似整体上可以看作是一棵树每个节点称做一个 ZNode。 每一个 ZNode 默认能够存储 1MB 的数据每个 ZNode 都可以通过其路径唯一标识。 1.5.应用场景
提供的服务包括统一命名服务、统一配置管理、统一集群管理、服务器节点动态上下线、软负载均衡等。
1.5.1.统一命名服务
在分布式环境下经常需要对应用/服务进行统一命名便于识别。 例如IP不容易记住而域名容易记住。 1.5.2.统一配置管理
分布式环境下配置文件同步非常常见。 一般要求一个集群中所有节点的配置信息是一致的比如 Kafka 集群。对配置文件修改后希望能够快速同步到各个节点上。 配置管理可交由ZooKeeper实现。 可将配置信息写入ZooKeeper上的一个Znode。各个客户端服务器监听这个Znode。一旦Znode中的数据被修改ZooKeeper将通知各个客户端服务器。 1.5.3.统一集群管理
分布式环境中实时掌握每个节点的状态是必要的。 可根据节点实时状态做出一些调整。 ZooKeeper可以实现实时监控节点状态变化 可将节点信息写入ZooKeeper上的一个ZNode。监听这个ZNode可获取它的实时状态变化。 1.5.4.服务器动态上下线
客户端能实时洞察到服务器上下线的变化 1.5.5.软负载均衡
在Zookeeper中记录每台服务器的访问数让访问数最少的服务器去处理最新的客户端请求 1.6.Zookeeper官网
Zookeeper官网https://zookeeper.apache.org/
Zookeeper所有版本https://archive.apache.org/dist/zookeeper/
zookeeper-3.5.7https://archive.apache.org/dist/zookeeper/zookeeper-3.5.7/
1.6.1.Zookeeper下载 1.6.2.历史版本 1.6.3.下载Linux 环境安装的tar包 二、Zookeeper安装【Centos7】
2.1.环境要求
2.1.1.安装JDK 2.1.2.上传apache-zookeeper-3.5.7-bin.tar.gz 安装包到/opt/module目录下
mkdir -p /opt/modulecd /opt/module2.1.3.解压到指定目录
tar -xzvf apache-zookeeper-3.5.7-bin.tar.gz -C /opt/module2.1.4.修改文件夹名称
cd /opt/modulemv apache-zookeeper-3.5.7-bin zookeeper-3.5.72.2.配置修改
2.2.1.将zookeeper-3.5.7/conf 路径下的 zoo_sample.cfg 修改为 zoo.cfg
cd /opt/module/zookeeper-3.5.7/confcp zoo_sample.cfg zoo.cfg2.2.2.修改zookeeper数据文件存放目录
vi /opt/module/zookeeper-3.5.7/conf/zoo.cfg# 修改数据存储路径配置
dataDir/opt/module/zookeeper-3.5.7/zkData2.2.3.创建相关数据文件存放目录
mkdir -p /opt/module/zookeeper-3.5.7/zkData/{logs,data}2.3.操作Zookeeper
2.3.1.添加到环境变量
vim /etc/profile# zookeeper
export ZK_HOME/opt/module/zookeeper-3.5.7
export PATH$PATH:$ZK_HOME/bin# 输入下面命令让设置的环境变量生效
source /etc/profile2.3.2.启动Zookeeper
zkServer.sh start
zkServer.sh status
zkServer.sh stop
zkServer.sh restart
#以打印日志方式启动
zkServer.sh start-foreground2.3.3.查看进程是否启动
# jps 是 Java Process Status Tool 的简称,它的作用是为了列出所有正在运行中的 Java 虚拟机进程
# 每一个 Java 程序在启动的时候都会为之创建一个Jvm 实例,通过jps可以查看这些进程的相关信息
# jps是Jdk提供的一个工具,它安装在 JAVA_HOME/bin下jpsjps -l2.3.4.ZooKeeper服务端口为2181查看服务已经启动
ps -aux | grep zookeepernetstat -ant | grep 21812.3.5.查看状态
zkServer.sh status2.3.6.启动客户端
zkCli.sh2.3.7.退出客户端
quit2.3.8.停止Zookeeper
zkServer.sh stop2.3.9.查看数据文件存放目录zkData 2.4.配置参数解读
2.4.1.tickTime 2000通信心跳时间Zookeeper服务器与客户端心跳时间单位毫秒 2.4.2.initLimit 10LF初始通信时限 Leader和Follower初始连接时能容忍的最多心跳数tickTime的数量
2.4.3.syncLimit 5LF同步通信时限 Leader和Follower之间通信时间如果超过syncLimit * tickTimeLeader认为Follwer死掉从服务器列表中删除Follwer。
2.4.4.dataDir保存Zookeeper中的数据
注意默认的tmp目录容易被Linux系统定期删除所以一般不用默认的tmp目录。
2.4.5.clientPort 2181客户端连接端口通常不做修改
三、Zookeeper 集群操作
3.1.集群操作
在ZooKeeper集群服中务中有三个角色
Leader 领导者
处理事务请求集群内部各服务器的调度者
Follower 跟随者
处理客户端非事务请求转发事务请求给Leader服务器参与Leader选举投票
Observer 观察者
处理客户端非事务请求转发事务请求给Leader服务器 3.1.1.集群安装
3.1.1.1.集群规划
在host128、host129 和host130 三个节点上都部署Zookeeper
思考如果是 10 台服务器需要部署多少台 Zookeeper
3.1.1.2.解压安装
# 解压Zookeeper 安装包到/opt/module/目录下
tar -xzvf apache-zookeeper-3.5.7-bin.tar.gz -C /opt/modulecd /opt/module# 修改apache-zookeeper-3.5.7-bin 名称为zookeeper-3.5.7
mv apache-zookeeper-3.5.7-bin zookeeper-3.5.73.1.1.3.配置服务器编号
3.1.1.3.1.创建相关数据文件存放目录 zkData
mkdir -p /opt/module/zookeeper-3.5.7/zkData/{logs,data}3.1.1.3.2.创建一个 myid 的文件【】
# 在文件中添加与server 对应的编号注意上下不要有空行左右不要有空格
echo 1 /opt/module/zookeeper-3.5.7/zkData/myidcat /opt/module/zookeeper-3.5.7/zkData/myid3.1.1.3.3.拷贝配置好的 zookeeper 到其他机器上
xsync 集群同步工具需要编辑集群分发脚本
xsync.sh zookeeper-3.5.7并分别在host129、host130 上修改myid 文件中内容为 2、3
3.1.1.4.配置zoo.cfg文件
3.1.1.4.1.拷贝配置文件zoo_sample.cfg 为zoo.cfg
cd /opt/module/zookeeper-3.5.7/conf# 拷贝配置文件 zoo_sample.cfg 为zoo.cfg
cp zoo_sample.cfg zoo.cfg3.1.1.4.2.修改zookeeper配置文件zoo.cfg【】
vi /opt/module/zookeeper-3.5.7/conf/zoo.cfg# 修改数据存储路径配置
dataDir/opt/module/zookeeper-3.5.7/zkData# 增加如下配置
#######################cluster##########################
server.1192.168.147.128:2888:3888
server.2192.168.147.129:2888:3888
server.3192.168.147.130:2888:38883.1.1.4.3.配置参数解读【】
# tickTime这个时间是作为zookeeper服务器之间或客户端与服务器之间维持心跳的时间间隔为2ms,也就是说每隔tickTime时间就会发送一个心跳。
tickTime2000# initLimit这个配置项是用来配置zookeeper接受客户端
# 这里所说的客户端不是用户连接zookeeper服务器的客户端,而是zookeeper服务器集群中连接到leader的follower 服务器
# 初始化连接时最长能忍受多少个心跳时间间隔数。当初始化连接时间超过该值则表示连接失败。
# 当已经超过10个心跳的时间也就是tickTime长度后 zookeeper 服务器还没有收到客户端的返回信息,那么表明这个客户端连接失败。
# 对于从节点最初连接到主节点时的超时时间单位为tick值的倍数。总的时间长度就是 10*2000。即20ms
initLimit10# syncLimit这个配置项标识leader与follower之间发送消息,请求和应答时间长度,最长不能超过多少个tickTime的时间长度
# 如果follower在设置时间内不能与leader通信那么此follower将会被丢弃。
# 对于主节点与从节点进行同步操作时的超时时间单位为tick值的倍数。总的时间长度就是5*2000。即10ms
syncLimit5# dataDir就是zookeeper保存数据库数据快照的位置,默认情况下zookeeper将写数据的日志文件也保存在这个目录里
# 注意不能使用 /tmp 路径会被定期清除。使用专用的存储设备能够大大提高系统的性能
# dataDir/tmp/zookeeper
dataLogDir/opt/module/zookeeper-3.5.7/zkData/logs
# 数据文件存放目录
dataDir/opt/module/zookeeper-3.5.7/zkData# clientPort这个端口就是客户端连接Zookeeper服务器的端口,Zookeeper会监听这个端口接受客户端的访问请求
clientPort2181# 客户端最大链接数
maxClientCnxns60# zookeeper在运行过程中会生成快照数据默认不会自动清理会持续占用硬盘空间
# 保存3个快照即3个日志文件
autopurge.snapRetainCount3
# 间隔1个小时执行一次清理
autopurge.purgeInterval1# server.AB:C:D
# 其中A是一个数字,表示这个是第几号服务器
# 集群模式下配置一个文件myid这个文件在dataDir 目录下这个文件里面有一个数据就是 A 的值
# Zookeeper 启动时读取此文件拿到里面的数据与zoo.cfg 里面的配置信息比较从而判断到底是哪个server。
# echo 1 /opt/module/zookeeper-3.5.7/zkData/myid
# B是这个服务器的IP地址
# C第一个端口用来集群成员的信息交换,表示这个服务器Follower与集群中的Leader服务器交换信息的端口
# D标识假如集群中的 Leader 服务器挂了需要一个端口来重新进行选举选出一个新的Leader而这个端口就是用来执行选举时服务器相互通信的端口
# 服务器运行主机心跳端口选举端口
# zk集群
# 3888后面位置不能有空格否则Address unresolved: 192.168.147.128:3888
#######################cluster##########################
server.1192.168.147.128:2888:3888
server.2192.168.147.129:2888:3888
server.3192.168.147.130:2888:38883.1.1.4.4.同步zoo.cfg 配置文件
cd /opt/module/zookeeper-3.5.7/confxsync.sh zoo.cfg3.1.1.4.5.修改zkEnv.sh文件并同步配置java环境变量
不修改容易报错JAVA_HOME is not set and java could not be found in PATH.
vi /opt/module/zookeeper-3.5.7/bin/zkEnv.sh#添加
JAVA_HOME/usr/java/jdk1.8xsync.sh zkEnv.sh3.1.1.5.集群操作
3.1.1.5.1.分别启动Zookeeper
zkServer.sh start
zkServer.sh status
zkServer.sh stop
zkServer.sh restart
#以打印日志方式启动
zkServer.sh start-foreground3.1.1.5.2.查看状态 3.1.2.选举机制面试重点
3.1.2.1.Zookeeper选举机制——第一次启动 1服务器1启动发起一次选举。服务器1投自己一票。此时服务器1票数一票不够半数以上3票选举无法完成服务器1状态保持为LOOKING
2服务器2启动再发起一次选举。服务器1和2分别投自己一票并交换选票信息此时服务器1发现服务器2的myid比自己目前投票推举的服务器1大更改选票为推举服务器2。此时服务器1票数0票服务器2票数2票没有半数以上结果选举无法完成服务器12状态保持LOOKING
3服务器3启动发起一次选举。此时服务器1和2都会更改选票为服务器3。此次投票结果服务器1为0票服务器2为0票服务器3为3票。此时服务器3的票数已经超过半数服务器3当选Leader。服务器12更改状态为FOLLOWING服务器3更改状态为LEADING
4服务器4启动发起一次选举。此时服务器123已经不是LOOKING状态不会更改选票信息。交换选票信息结果服务器3为3票服务器4为1票。此时服务器4服从多数更改选票信息为服务器3并更改状态为FOLLOWING
5服务器5启动同4一样当小弟。
名词简介含义SID服务器ID用来唯一标识一台ZooKeeper集群中的机器每台机器不能重复和myid一致ZXID事务IDZXID是一个事务ID用来标识一次服务器状态的变更。在某一时刻集群中的每台机器的ZXID值不一定完全一致这和ZooKeeper服务器对于客户端“更新请求”的处理逻辑有关。Epoch每个Leader任期的代号没有Leader时同一轮投票过程中的逻辑时钟值是相同的。每投完一次票这个数据就会增加
3.1.2.2.Zookeeper选举机制——非第一次启动 1当zookeeper集群中的一台服务器出现以下两种情况之一时就会开始进入Leader选举
服务器初始化启动服务器运行期间无法和leader保持连接
2而当一台机器进入Leader选举流程时当前集群也可能会处于以下两种状态 集群中本来就已经存在一个Leader 对于这种已经存在Leader的情况机器试图去选举Leader时会被告知当前服务器的Leader信息对于该机器来说仅仅需要和Leader机器建立连接并进行状态同步即可。 集群中确实不存在Leader重点 假设ZooKeeper由5台服务器组成SID分别为1、2、3、4、5ZXID分别为8、8、8、7、7并且此时SID为3的服务器是Leader。某一时刻3和5服务器出现故障因此开始进行Leader选举。最后选了服务器2。 3.1.3.ZK 集群启动停止脚本
3.1.3.1.在host128 创建脚本
vim /usr/bin/zk.sh3.1.3.2.脚本内容
#!/bin/bash
# 定义一个数组
arr(host128 host129 host130)case $1 in
start){for i in ${arr[]}doecho ---------- zookeeper $i 启动 ------------ssh $i bash /opt/module/zookeeper-3.5.7/bin/zkServer.sh startdone
};;
stop){for i in ${arr[]}doecho ---------- zookeeper $i 停止 ------------ ssh $i bash /opt/module/zookeeper-3.5.7/bin/zkServer.sh stopdone
};;
status){for i in ${arr[]}doecho ---------- zookeeper $i 状态 ------------ ssh $i bash /opt/module/zookeeper-3.5.7/bin/zkServer.sh statusdone
};;
esac3.1.3.3.增加脚本执行权限
# u代表所有者user;x代表执行权限; 表示增加权限
chmod ux /usr/bin/zk.sh3.1.3.4.Zookeeper 集群启动
zk.sh start3.1.3.5.Zookeeper 集群状态
zk.sh status3.1.3.6.Zookeeper 集群停止
zk.sh stop3.1.4.显示集群的所有java进程状态jpsall 脚本
3.1.4.1.在host128 创建脚本
vim /usr/bin/jpsall3.1.4.2.脚本内容
#!/bin/bash
# 该脚本是用来显示集群的所有java进程状态
# 定义一个数组
listhost128 host129 host130
JAVA_HOME/usr/java/jdk1.8echo 显示集群的所有java进程状态
for node in $list
doecho $node ssh $node $JAVA_HOME/bin/jps
done
echo 执行结束3.1.4.3.增加脚本执行权限
# u代表所有者user;x代表执行权限; 表示增加权限
chmod ux /usr/bin/jpsall3.1.4.4.执行脚本
jpsall3.2. 客户端命令行操作
3.2.1.命令行基本语法
命令基本语法功能描述help显示所有操作的命令ls path使用 ls 命令来查看当前 znode 的子节点 [可监听] -w 监听子节点变化 -s 附加次级信息create普通创建-s 含有序列-e 临时重启或者超时消失get path获得节点的值 [可监听] -w 监听节点内容变化 -s 附加次级信息set设置节点的具体值stat查看节点状态delete删除节点deleteall递归删除节点
3.2.1.1.启动客户端
cd /opt/module/zookeeper-3.5.7# 指定启动host128的客户端而不是localhost的
bin/zkCli.sh -server host128:21813.2.1.2.显示所有的操作命令
help3.2.2.znode 节点数据信息
3.2.2.1.查看当前znode中所包含的内容
ls /[zk: host128:2181(CONNECTED) 0] ls /
[zookeeper]3.2.2.2.查看当前节点详细数据
ls -s /[zk: host128:2181(CONNECTED) 1] ls -s /
[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创建节点的事务 zxid每次修改 ZooKeeper 状态都会产生一个 ZooKeeper 事务 ID。 事务 ID 是 ZooKeeper 中所有修改总的次序。 每次修改都有唯一的 zxid如果 zxid1 小于 zxid2那么 zxid1 在 zxid2 之前发生。 czxid创建节点的事务 zxidcreate zxidctimeznode 被创建的毫秒数从 1970 年开始mzxidznode 最后更新的事务 zxidmtimeznode 最后修改的毫秒数从 1970 年开始pZxidznode 最后更新的子节点 zxidcversionznode 子节点变化号znode 子节点修改次数 dataversionznode 数据变化号aclVersionznode 访问控制列表的变化号ephemeralOwner如果是临时节点这个是 znode 拥有者的 session id。如果不是临时节点则是 0。dataLengthznode 的数据长度numChildrenznode 子节点数量
3.2.3.节点类型持久/短暂/有序号/无序号
持久Persistent客户端和服务器端断开连接后创建的节点不删除短暂Ephemeral客户端和服务器端断开连接后创建的节点自己删除 说明创建znode时设置顺序标识znode名称后会附加一个值顺序号是一个单调递增的计数器由父节点维护
注意在分布式系统中顺序号可以被用于为所有的事件进行全局排序这样客户端可以通过顺序号推断事件的顺序
3.2.3.1.分别创建2个普通节点永久节点 不带序号
create /sanguo xishicreate /sanguo/shuguo adou[zk: host128:2181(CONNECTED) 2] create /sanguo xishi
Created /sanguo
[zk: host128:2181(CONNECTED) 3] create /sanguo/shuguo adou
Created /sanguo/shuguo
## 注意创建节点时要赋值3.2.3.2.获得节点的值
get -s /sanguoget -s /sanguo/shuguo[zk: host128:2181(CONNECTED) 4] get -s /sanguo
xishi
cZxid 0x400000004
ctime Tue Feb 27 21:42:39 CST 2024
mZxid 0x400000004
mtime Tue Feb 27 21:42:39 CST 2024
pZxid 0x400000005
cversion 1
dataVersion 0
aclVersion 0
ephemeralOwner 0x0
dataLength 5
numChildren 1
[zk: host128:2181(CONNECTED) 5] get -s /sanguo/shuguo
adou
cZxid 0x400000005
ctime Tue Feb 27 21:43:01 CST 2024
mZxid 0x400000005
mtime Tue Feb 27 21:43:01 CST 2024
pZxid 0x400000005
cversion 0
dataVersion 0
aclVersion 0
ephemeralOwner 0x0
dataLength 4
numChildren 03.2.3.3.创建带序号的节点永久节点 带序号
3.2.3.3.1.先创建一个普通的根节点/sanguo/weiguo
[zk: host128:2181(CONNECTED) 6] create /sanguo/weiguo caocao
Created /sanguo/weiguo3.2.3.3.2.创建带序号的节点
如果原来没有序号节点序号从0 开始依次递增。
如果原节点下已有2个节点则再排序时从2开始以此类推。[zk: host128:2181(CONNECTED) 7] create -s /sanguo/weiguo/zhangliao zhangliao
Created /sanguo/weiguo/zhangliao0000000000
[zk: host128:2181(CONNECTED) 8] create -s /sanguo/weiguo/zhangliao zhangliao
Created /sanguo/weiguo/zhangliao0000000001
[zk: host128:2181(CONNECTED) 9] create -s /sanguo/weiguo/zhangliao zhangliao
Created /sanguo/weiguo/zhangliao0000000002
[zk: host128:2181(CONNECTED) 10] create -s /sanguo/weiguo/zhangliao zhangliao
Created /sanguo/weiguo/zhangliao00000000033.2.3.4.创建短暂节点短暂节点 不带序号 or 带序号
3.2.3.4.1.创建短暂的不带序号的节点
[zk: host128:2181(CONNECTED) 0] create -e /sanguo/wuguo zhouyu
Created /sanguo/wuguo3.2.3.4.2.创建短暂的带序号的节点
[zk: host128:2181(CONNECTED) 1] create -e -s /sanguo/wuguo zhouyu
Created /sanguo/wuguo00000000033.2.3.4.3.在当前客户端是能查看到的
[zk: host128:2181(CONNECTED) 2] ls /sanguo
[shuguo, weiguo, wuguo, wuguo0000000003]3.2.3.4.4.退出当前客户端然后再重启客户端
quitbin/zkCli.sh -server host128:21813.2.3.4.5.再次查看根目录下短暂节点已经删除
[zk: host128:2181(CONNECTED) 0] ls /sanguo
[shuguo, weiguo]3.2.3.5.修改节点数据值
[zk: host128:2181(CONNECTED) 1] set /sanguo/weiguo kongming
[zk: host128:2181(CONNECTED) 2] get -s /sanguo/weiguo
kongming
cZxid 0x400000006
ctime Tue Feb 27 21:46:26 CST 2024
mZxid 0x400000011
mtime Tue Feb 27 21:53:24 CST 2024
pZxid 0x40000000a
cversion 4
dataVersion 1
aclVersion 0
ephemeralOwner 0x0
dataLength 8
numChildren 43.2.4.监听器原理
客户端注册监听它关心的目录节点当目录节点发生变化数据改变、节点删除、子目录节点增加删除时ZooKeeper 会通知客户端。 监听机制保证ZooKeeper 保存的任何的数据的任何改变都能快速的响应到监听了该节点的应用程序。
3.2.4.1.监听原理详解
1 首先要有一个main()线程
2 在main线程中创建Zookeeper客户端这时就会创建两个线程一个负责网络连接通信connet一个负责监听listener。
线程connet负责网络通信连接连接服务器
线程Listener负责监听3 通过connect线程将注册的监听事件发送给Zookeeper。
getChildren(/ , true) / 表示监听的是根目录true表示监听不监听用false4 在Zookeeper的注册监听器列表中将注册的监听事件添加到列表中表示这个服务器中的/path即根目录这个路径被客户端监听了
5 Zookeeper监听到有数据或路径变化就会将这个消息发送给listener线程。
6 listener线程内部调用了process()方法采取相应的措施例如更新服务器列表等。 3.2.4.2.常见的监听
1 监听节点数据的变化get path [watch]
2 监听子节点增减的变化ls path [watch]
3.2.4.3.节点的值变化监听
cd /opt/module/zookeeper-3.5.7# 指定启动host129的客户端而不是localhost的
bin/zkCli.sh -server host129:21811在host129 主机上注册监听/sanguo 节点数据变化
[zk: host129:2181(CONNECTED) 1] get -w /sanguo
xishi2在host130 主机上修改/sanguo 节点的数据
[zk: host130:2181(CONNECTED) 2] set /sanguo yangyuhuan3观察host129 主机收到数据变化的监听
[zk: host129:2181(CONNECTED) 2]
WATCHER::WatchedEvent state:SyncConnected type:NodeDataChanged path:/sanguo注意在host130 再多次修改/sanguo的值host129上不会再收到监听。
因为注册一次只能监听一次。想再次监听需要再次注册。
3.2.4.4.节点的子节点变化监听路径变化
1在host129 主机上注册监听/sanguo 节点的子节点变化
[zk: host129:2181(CONNECTED) 2] ls -w /sanguo
[shuguo, weiguo]2在host130 主机/sanguo 节点上创建子节点
[zk: host130:2181(CONNECTED) 3] create /sanguo/jin simayi
Created /sanguo/jin3观察host129 主机收到子节点变化的监听
[zk: host129:2181(CONNECTED) 3]
WATCHER::WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/sanguo注意节点的路径变化也是注册一次生效一次。想多次生效就需要多次注册。
3.2.5.节点删除与查看
3.2.5.1.查看节点状态
[zk: host129:2181(CONNECTED) 3] stat /sanguo
cZxid 0x400000004
ctime Tue Feb 27 21:42:39 CST 2024
mZxid 0x500000005
mtime Wed Feb 28 10:50:35 CST 2024
pZxid 0x500000006
cversion 7
dataVersion 1
aclVersion 0
ephemeralOwner 0x0
dataLength 10
numChildren 33.2.5.2.删除节点
[zk: host129:2181(CONNECTED) 4] ls /sanguo
[jin, shuguo, weiguo]
[zk: host129:2181(CONNECTED) 5] delete /sanguo/jin3.2.5.3.递归删除节点
[zk: host129:2181(CONNECTED) 6] delete /sanguo
Node not empty: /sanguo
[zk: host129:2181(CONNECTED) 7] deleteall /sanguo
[zk: host129:2181(CONNECTED) 8]
[zk: host129:2181(CONNECTED) 8] ls /
[zookeeper]endl
