zookeeper 使用

1、zookeeper 数据增删改查

查看当前 zk 运行状态

root@zookeeper01:~# /usr/local/zookeeper/bin/zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /usr/local/zookeeper/bin/../conf/zoo.cfg
Mode: follower

命令行写入数据

可连接至 zookeeper 集群中的任意一台 zookeeper 节点进行操作

root@zookeeper01:~# /usr/local/zookeeper/bin/zkCli.sh -server 192.168.1.86:2181
Connecting to 192.168.1.86:2181
2022-12-22 02:09:07,777 [myid:] - INFO  [main:Environment@100] - Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT
2022-12-22 02:09:07,780 [myid:] - INFO  [main:Environment@100] - Client environment:host.name=zookeeper01
2022-12-22 02:09:07,781 [myid:] - INFO  [main:Environment@100] - Client environment:java.version=1.8.0_352
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:java.vendor=Private Build
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:java.class.path=/usr/local/zookeeper/bin/../zookeeper-server/target/classes:/usr/local/zookeeper/bin/../build/classes:/usr/local/zookeeper/bin/../zookeeper-server/target/lib/*.jar:/usr/local/zookeeper/bin/../build/lib/*.jar:/usr/local/zookeeper/bin/../lib/slf4j-log4j12-1.7.25.jar:/usr/local/zookeeper/bin/../lib/slf4j-api-1.7.25.jar:/usr/local/zookeeper/bin/../lib/netty-3.10.6.Final.jar:/usr/local/zookeeper/bin/../lib/log4j-1.2.17.jar:/usr/local/zookeeper/bin/../lib/jline-0.9.94.jar:/usr/local/zookeeper/bin/../lib/audience-annotations-0.5.0.jar:/usr/local/zookeeper/bin/../zookeeper-3.4.14.jar:/usr/local/zookeeper/bin/../zookeeper-server/src/main/resources/lib/*.jar:/usr/local/zookeeper/bin/../conf:
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:java.io.tmpdir=/tmp
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:java.compiler=<NA>
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:os.name=Linux
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:os.arch=amd64
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:os.version=5.4.0-131-generic
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:user.name=root
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:user.home=/root
2022-12-22 02:09:07,782 [myid:] - INFO  [main:Environment@100] - Client environment:user.dir=/root
2022-12-22 02:09:07,783 [myid:] - INFO  [main:ZooKeeper@442] - Initiating client connection, connectString=192.168.1.86:2181 sessionTimeout=30000 watcher=org.apache.zookeeper.ZooKeeperMain$MyWatcher@41906a77
Welcome to ZooKeeper!
JLine support is enabled
2022-12-22 02:09:07,821 [myid:] - INFO  [main-SendThread(192.168.1.86:2181):ClientCnxn$SendThread@1025] - Opening socket connection to server 192.168.1.86/192.168.1.86:2181. Will not attempt to authenticate using SASL (unknown error)
2022-12-22 02:09:07,851 [myid:] - INFO  [main-SendThread(192.168.1.86:2181):ClientCnxn$SendThread@879] - Socket connection established to 192.168.1.86/192.168.1.86:2181, initiating session
2022-12-22 02:09:07,865 [myid:] - INFO  [main-SendThread(192.168.1.86:2181):ClientCnxn$SendThread@1299] - Session establishment complete on server 192.168.1.86/192.168.1.86:2181, sessionid = 0x300001998660000, negotiated timeout = 30000

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[zk: 192.168.1.86:2181(CONNECTED) 0]

stat path [watch] #支持的命令
set path data [version]
ls path [watch]
delquota [-n|-b] path
ls2 path [watch]
setAcl path acl
setquota -n|-b val path
history
redo cmdno
printwatches on|off
delete path [version]
sync path
listquota path
rmr path
get path [watch]
create [-s] [-e] path data acl
addauth scheme auth
quit
getAcl path
close
connect host:port

# 写入数据
[zk: 192.168.1.86:2181(CONNECTED) 3] create /test "hello"
Created /test
# 验证数据，可以到其他节点验
证数据是否一致
[zk: 192.168.1.86:2181(CONNECTED) 4] get /test
hello
cZxid = 0x200000002                     # leader 生成按照数据写入顺序生成的 zxid
ctime = Thu Dec 22 02:11:09 UTC 2022    # 写入时间
mZxid = 0x200000002                     # 节点最新一次更新发生时的 zxid
mtime = Thu Dec 22 02:11:09 UTC 2022
pZxid = 0x200000002
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 0

2、zookeeper 客户端 ZooInspector

https://github.com/zzhang5/zooinspector

[root@client ~]# cd /data/
[root@client data]# git clone  https://github.com/zzhang5/zooinspector.git
[root@client data]# git clone https://gh.api.99988866.xyz/https://github.com/zzhang5/zooinspector.git

[root@client data]# cd zooinspector-master
[root@client data]# mvn clean package

[root@client zooinspector-master]# chmod +x target/zooinspector-pkg/bin/zooinspector.sh
[root@client zooinspector-master]# export DISPLAY=192.168.1.1:0.0
[root@client zooinspector-master]# target/zooinspector-pkg/bin/zooinspector.sh