Zookeeper生产常用命令大全（最新3.8.0版本）
| 阿里云国内75折 回扣 微信号：monov8 |
| 阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6 |
文章目录
官方文档
https://zookeeper.apache.org/doc/r3.8.0/zookeeperCLI.html
一、服务端
zookeeper的shell命令都体现在apache-zookeeper-3.8.0-bin/bin/目录下
➜ bin ls
README.txt zkEnv.sh zkSnapShotToolkit.sh
zkCleanup.sh zkServer-initialize.sh zkSnapshotComparer.cmd
zkCli.cmd zkServer.cmd zkSnapshotComparer.sh
zkCli.sh zkServer.sh zkTxnLogToolkit.cmd
zkEnv.cmd zkSnapShotToolkit.cmd zkTxnLogToolkit.sh
其中包括
1> 启动zookeeper服务
./zkServer.sh start2> 查看zookeeper服务状态
./zkServer.sh status3> 停止zookeeper服务
./zkServer.sh stop4> 重启zookeeper服务
./zkServer.sh restart
二、客户端
1、连接客户端
直接使用 sh zkCli.sh 命令可以连接到本地的zookeeper服务127.0.0.1:2181如果需要连接到其他地址的zookeeper服务需要使用以下命令格式
sh zkCli.sh -server [ip]:[port]
示例命令
sh zkCli.sh -server 127.0.0.1:2181
连接成功后系统会输出 ZooKeeper 的相关环境以及配置信息。 可以在开启的会话中做一些客户端操作 与 zookeeper服务进行交互
2、help
使用 help命令来查看帮助
[zk: 127.0.0.1:2181(CONNECTED) 21] help
ZooKeeper -server host:port -client-configuration properties-file cmd args
addWatch [-m mode] path # optional mode is one of [PERSISTENT, PERSISTENT_RECURSIVE] - default is PERSISTENT_RECURSIVE
addauth scheme auth
close
config [-c] [-w] [-s]
connect host:port
create [-s] [-e] [-c] [-t ttl] path [data] [acl]
delete [-v version] path
deleteall path [-b batch size]
delquota [-n|-b|-N|-B] path
get [-s] [-w] path
getAcl [-s] path
getAllChildrenNumber path
getEphemerals path
history
listquota path
ls [-s] [-w] [-R] path
printwatches on|off
quit
reconfig [-s] [-v version] [[-file path] | [-members serverID=host:port1:port2;port3[,...]*]] | [-add serverId=host:port1:port2;port3[,...]]* [-remove serverId[,...]*]
redo cmdno
removewatches path [-c|-d|-a] [-l]
set [-s] [-v version] path data
setAcl [-s] [-v version] [-R] path acl
setquota -n|-b|-N|-B val path
stat [-w] path
sync path
version
whoami
Command not found: Command not found help
3、create
create命令创建节点默认持久节点
create [-s] [-e] [-c] [-t ttl] path [data] [acl]
- -s有序节点
- -e临时节点不加默认是持久节点
- -t ttl带过期时间节点单位秒比如create ‐t 10 /node_ttl/node_ttl节点在10s后将过期被删除。
- -c容器节点当容器中的最后一个子级被删除时容器将被删除
Zookeeper原生命令不支持级联创建节点树目录需要一级一级的创建curator客户端封装了级联创建的API。
Znode节点类型有四种
- 持久的persistent
- 临时的ephemeral
- 持久有序的persistent_sequential
- 临时有序的ephemeral_sequential
1> 创建持久节点
[zk: 127.0.0.1:2181(CONNECTED) 0] create /node_p1
Created /node_p1
2> 创建临时节点
[zk: 127.0.0.1:2181(CONNECTED) 1] create -e /node_e1 "node value"
Created /node_e1
3> 创建持久有序节点
持久有序节点设置的节点路径会被重命名为序列数不设置节点前缀时序列数从0000000000开始递增
- 某一个节点路径下的序列数一直递增无论一直带前缀、偶尔带前缀、或一直不带前缀
不设置节点前缀时
[zk: 127.0.0.1:2181(CONNECTED) 5] create /node_p2
Created /node_p2
[zk: 127.0.0.1:2181(CONNECTED) 6] create -s /node_p2/
Created /node_p2/0000000000
[zk: 127.0.0.1:2181(CONNECTED) 7] create -s /node_p2/
Created /node_p2/0000000001
设置节点前缀时
[zk: 127.0.0.1:2181(CONNECTED) 12] create -s /node_p2/seq_
Created /node_p2/seq_0000000002
[zk: 127.0.0.1:2181(CONNECTED) 13] create -s /node_p2/seq_
Created /node_p2/seq_0000000003
4> 创建临时有序节点
设置节点前缀时
[zk: 127.0.0.1:2181(CONNECTED) 14] create -s -e /node_p2/e_
Created /node_p2/e_0000000004
[zk: 127.0.0.1:2181(CONNECTED) 15] create -s -e /node_p2/e_
Created /node_p2/e_0000000005
不设置节点前缀时
[zk: 127.0.0.1:2181(CONNECTED) 16] create -s -e /node_p2/
Created /node_p2/0000000006
[zk: 127.0.0.1:2181(CONNECTED) 17] create -s -e /node_p2/
Created /node_p2/0000000007
5> 创建ttl节点
默认禁用需要在 zoo.cfg中添加 extendedTypesEnabled=true 开启。 否者报如下错
[zk: 127.0.0.1:2181(CONNECTED) 18] create -t 10 /node_ttl "ttl node value"
KeeperErrorCode = Unimplemented for /node_ttl
开启ttl之后
[zk: 127.0.0.1:2181(CONNECTED) 8] create -t 10 /node_ttl "ttl node value"
Created /node_ttl
[zk: 127.0.0.1:2181(CONNECTED) 9] get /node_ttl
ttl node value
[zk: 127.0.0.1:2181(CONNECTED) 10] get /node_ttl
Node does not exist: /node_ttl
- /node_ttl10s之后过期
注意ttl不能用于临时节点 。
6> 创建容器节点
[zk: 127.0.0.1:2181(CONNECTED) 0] create -c /container_node mydata
Created /container_node
[zk: 127.0.0.1:2181(CONNECTED) 1] create -c /container_node/child_1 mydata
Created /container_node/child_1
[zk: 127.0.0.1:2181(CONNECTED) 2] create -c /container_node/child_2 mydata
Created /container_node/child_2
[zk: 127.0.0.1:2181(CONNECTED) 3] delete /container_node/child_1
[zk: 127.0.0.1:2181(CONNECTED) 4] delete /container_node/child_2
[zk: 127.0.0.1:2181(CONNECTED) 5] get /container_node
mydata
[zk: 127.0.0.1:2181(CONNECTED) 6] get /container_node
mydata
[zk: 127.0.0.1:2181(CONNECTED) 7] get /container_node
mydata
[zk: 127.0.0.1:2181(CONNECTED) 8] get /container_node
Node does not exist: /container_node
从测试结果来看容器节点的最后一个子级被删除之后过了几秒容器节点才被删除。
4、get
get命令获取节点/文件内容
get [-s] [-w] path
- -s查看节点数据以及节点状态信息
- -w添加一个watch节点数据变更时会通知客户端通知是一次性的。
[zk: 127.0.0.1:2181(CONNECTED) 12] create /node_test "testNode value"
Created /node_test
[zk: 127.0.0.1:2181(CONNECTED) 13] get /node_test
testNode value
-s 选项在获取到节点值的同时会带出节点的状态stat
[zk: 127.0.0.1:2181(CONNECTED) 14] get -s /node_test
testNode value
cZxid = 0x14 # 数据节点创建时的事务ID
ctime = Wed Nov 30 15:09:39 CST 2022 # 数据节点创建时的时间
mZxid = 0x18 # 数据节点最后一次更新时的事务ID
mtime = Wed Nov 30 15:14:25 CST 2022 # 数据节点最后一次更新时的时间
pZxid = 0x14 # 数据节点的子节点最后一次被修改时的事务ID
cversion = 0 # 子节点的更改次数
dataVersion = 3 # 节点数据的更改次数
aclVersion = 0 # 节点的ACL的更改次数
ephemeralOwner = 0x0 # 如果节点是临时节点则表示创建该节点的会话的SessionID如果节点是持久节点则该属性值为0.
dataLength = 24 # 数据内容的长度
numChildren = 0 # 数据节点当前的子节点个数
5、set
set命令修改节点内容每次修改成功后版本号会自动+1初始为0
set [-s] [-v version] path data
- -s更新节点数据并显示节点状态信息
- -v指定数据版本号如果指定的数据版本号和数据当前版本号不一致则更新失败可以理解为乐观锁的概念。
[zk: 127.0.0.1:2181(CONNECTED) 15] set /node_test "updated tesetNode value"
-s选项更新节点数据并显示节点状态信息
[zk: 127.0.0.1:2181(CONNECTED) 16] set -s /node_test "updated tesetNode value2"
cZxid = 0x14
ctime = Wed Nov 30 15:09:39 CST 2022
mZxid = 0x16
mtime = Wed Nov 30 15:13:40 CST 2022
pZxid = 0x14
cversion = 0
dataVersion = 2
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 24
numChildren = 0
-v选项指定数据版本号如果指定的数据版本号和数据当前版本号不一致则更新失败可以理解为乐观锁方式更新
[zk: 127.0.0.1:2181(CONNECTED) 17] set -v 3 /node_test "updated tesetNode value3"
version No is not valid : /node_test
[zk: 127.0.0.1:2181(CONNECTED) 18] set -s -v 2 /node_test "updated tesetNode value3"
cZxid = 0x14
ctime = Wed Nov 30 15:09:39 CST 2022
mZxid = 0x18
mtime = Wed Nov 30 15:14:25 CST 2022
pZxid = 0x14
cversion = 0
dataVersion = 3
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 24
numChildren = 0
- 在 -s选项操作后/node_test的version为2在-v选项更新时必须执行version为2才能完成更新操作。
6、ls
ls命令查看目录下的节点信息
ls [-s] [-w] [-R] path
- -s显示节点详情包括状态信息
- -w添加一个watch监视器
- -R列举出节点的级联节点
- path显示某目录下节点/文件
[zk: 127.0.0.1:2181(CONNECTED) 19] create /node_test/sub_node1 "1"
Created /node_test/sub_node1
[zk: 127.0.0.1:2181(CONNECTED) 20] create /node_test/sub_node2 "2"
Created /node_test/sub_node2
[zk: 127.0.0.1:2181(CONNECTED) 21] ls /node_test
[sub_node1, sub_node2]
[zk: 127.0.0.1:2181(CONNECTED) 22] ls -s /node_test
[sub_node1, sub_node2]
cZxid = 0x14
ctime = Wed Nov 30 15:09:39 CST 2022
mZxid = 0x18
mtime = Wed Nov 30 15:14:25 CST 2022
pZxid = 0x1a
cversion = 2
dataVersion = 3
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 24
numChildren = 2
[zk: 127.0.0.1:2181(CONNECTED) 23] ls -R /node_test
/node_test
/node_test/sub_node1
/node_test/sub_node2
[zk: 127.0.0.1:2181(CONNECTED) 24]
7、stat
stat命令查看节点状态。
stat [-w] path
- -w添加watch
- path查看某目录下节点的状态
[zk: 127.0.0.1:2181(CONNECTED) 24] stat /node_test
cZxid = 0x14
ctime = Wed Nov 30 15:09:39 CST 2022
mZxid = 0x18
mtime = Wed Nov 30 15:14:25 CST 2022
pZxid = 0x1a
cversion = 2
dataVersion = 3
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 24
numChildren = 2
8、删除节点
delete命令只能删除没有子节点的节点deleteall命令可以级联删除当前节点和子节点
1> delete
delete命令只能删除没有子节点的节点。如果其有子节点时无法删除
delete [-v version] path
- -v指定数据版本号如果指定的数据版本号和数据当前版本号不一致则删除失败
[zk: 127.0.0.1:2181(CONNECTED) 25] delete /node_test/sub_node1
[zk: 127.0.0.1:2181(CONNECTED) 26] ls -R /node_test
/node_test
/node_test/sub_node2
2> deleteall
deleteall命令级联删除该节点和子节点。
deleteall path
[zk: 127.0.0.1:2181(CONNECTED) 27] deleteall /node_test
[zk: 127.0.0.1:2181(CONNECTED) 28] ls -R /node_test
Node does not exist: /node_test
[zk: 127.0.0.1:2181(CONNECTED) 29] ls /node_test/sub_node2
Node does not exist: /node_test/sub_node2
8、其他命令
- getAllChildrenNumber获取节点下的所有子孙节点数量
- getEphemerals获取当前客户端创建的所有临时节点
- history显示最近执行的11条命令的历史记录
二、监听器Watcher
Watcher事件监听器允许用户在指定节点上注册 Watcher在特定事件发生时Watcher会被触发Zookeeper服务端将事件通知到响应的客户端上去
该机制是Zookeeper实现分布式协调服务的重要特性。
- 客户端监听节点的变化当节点发生改变时触发相应的事件
- 当事件被触发时客户端会收到一个数据包说明节点已经改变。
1、一次性监听器
1> 监听节点目录变化
监听节点的子节点变化当子节点发生改变时触发
ls -w path
Session1
# 创建节点
[zk: 127.0.0.1:2181(CONNECTED) 31] create /watch_node
Created /watch_node
# 监听节点目录变化
[zk: 127.0.0.1:2181(CONNECTED) 32] ls -w /watch_node
[]
Session2
# 创建/watch_node节点的子节点
[zk: 127.0.0.1:2181(CONNECTED) 0] create /watch_node/node1 "node1 value"
Created /watch_node/node1
[zk: 127.0.0.1:2181(CONNECTED) 1] create /watch_node/node2 "node2 value"
Created /watch_node/node2
当/watch_node节点的子节点第一次发生变化时会触发session1的Watcher触发后会被删除无法再次触发。
[zk: 127.0.0.1:2181(CONNECTED) 33]
WATCHER::
WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/watch_node
图示
2> 监听节点数据变化
当该节点数据发生改变时触发但子节点的数据变化不会触发。一次性监听触发后会被删除无法再次触发。
get -w path
Session1
[zk: 127.0.0.1:2181(CONNECTED) 33] get -w /watch_node
null
Session2
[zk: 127.0.0.1:2181(CONNECTED) 3] set /watch_node "hahaha"
当/watch_node节点的数据第一次发生变化时会触发session1的Watcher触发后会被删除无法再次触发。
[zk: 127.0.0.1:2181(CONNECTED) 34]
WATCHER::
WatchedEvent state:SyncConnected type:NodeDataChanged path:/watch_node
图示
2、永久的监听器
在 Zookeeper 3.6.0版本之后客户端可以在节点上创建永久监听永久监听在被触发后不会被删除。
addWatch [-m mode] path
永久监听器在创建时可以通过 -m 选项指定模式有两种模式
- PERSISTENT节点的数据变化以及子节点的变化会触发相应事件子节点的数据变化不会触发。
- PERSISTENT_RECURSIVE默认模式不指定时使用节点的数据变化以及所有子孙节点的目录或者数据变化都会触发相应事件。
1> PERSISTENT
PERSISTENT该节点的数据变化以及子节点的变化会触发相应事件子节点的数据变化不会触发。
# 1、增加PERSISTENT模式的监听器
[zk: 127.0.0.1:2181(CONNECTED) 34] addWatch -m PERSISTENT /watch_node
# 2、节点数据发生变更时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 35] set /watch_node "node12321"
WATCHER::
WatchedEvent state:SyncConnected type:NodeDataChanged path:/watch_node
# 3、节点的子节点新增时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 36] create /watch_node/node4 "node4"
WATCHER::Created /watch_node/node4
WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/watch_node
# 4、节点的子节点数据发生变化时不会触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 37] set /watch_node/node4 "node4-2"
# 5、节点的子节点删除时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 38] delete /watch_node/node4
WATCHER::
WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/watch_node
2> PERSISTENT_RECURSIVE
PERSISTENT_RECURSIVE节点的数据变化以及所有子孙节点的目录或者数据变化都会触发相应事件。
# 创建一个节点
[zk: 127.0.0.1:2181(CONNECTED) 40] create /watch_node2
Created /watch_node2
# 1、针对节点增加PERSISTENT_RECURSIVE模式的监听器
[zk: 127.0.0.1:2181(CONNECTED) 41] addWatch -m PERSISTENT_RECURSIVE /watch_node2
# 2、节点数据发生变更时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 42] set /watch_node2 "hahahah"
WATCHER::
WatchedEvent state:SyncConnected type:NodeDataChanged path:/watch_node2
# 3、节点的子节点新增时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 43] create /watch_node2/node1
WATCHER::Created /watch_node2/node1
WatchedEvent state:SyncConnected type:NodeCreated path:/watch_node2/node1
# 4、节点的子节点数据发生变化时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 44] set /watch_node2/node1 "node1"
WATCHER::
WatchedEvent state:SyncConnected type:NodeDataChanged path:/watch_node2/node1
# 5、节点的子节点删除时触发监听器
[zk: 127.0.0.1:2181(CONNECTED) 45] delete /watch_node2/node1
WATCHER::
WatchedEvent state:SyncConnected type:NodeDeleted path:/watch_node2/node1
3、删除监听器
删除某个节点的监听器删除后节点相应的变更事件不会再触发监听器
removewatches path
[zk: 127.0.0.1:2181(CONNECTED) 48] removewatches /watch_node2
WATCHER::
WatchedEvent state:SyncConnected type:PersistentWatchRemoved path:/watch_node2