Zookeeper客户端解析

Zookeeper支持多种客户端

1、zkCli客户端脚本：这是一个简易的客户端

2、C/Java客户端API：可编程的客户端

试用zkCli.sh

在test_2.thinking.com上打开客户端

# cd /home/zookeeper-3.4.12/bin
# sh zkCli.sh
Connecting to localhost:2181
2018-07-13 08:28:15,291 [myid:] - INFO  [main:Environment@100] - Client environment:zookeeper.version=3.4.12-e5259e437540f349646870ea94dc2658c4e44b3b, built on 03/27/2018 03:55 GMT
2018-07-13 08:28:15,295 [myid:] - INFO  [main:Environment@100] - Client environment:host.name=a27b828c3b32
2018-07-13 08:28:15,295 [myid:] - INFO  [main:Environment@100] - Client environment:java.version=1.8.0_171
2018-07-13 08:28:15,297 [myid:] - INFO  [main:Environment@100] - Client environment:java.vendor=Oracle Corporation
2018-07-13 08:28:15,298 [myid:] - INFO  [main:Environment@100] - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2018-07-13 08:28:15,298 [myid:] - INFO  [main:Environment@100] - Client environment:java.class.path=/home/zookeeper-3.4.12/bin/../build/classes:/home/zookeeper-3.4.12/bin/../build/lib/*.jar:/home/zookeeper-3.4.12/bin/../lib/slf4j-log4j12-1.7.25.jar:/home/zookeeper-3.4.12/bin/../lib/slf4j-api-1.7.25.jar:/home/zookeeper-3.4.12/bin/../lib/netty-3.10.6.Final.jar:/home/zookeeper-3.4.12/bin/../lib/log4j-1.2.17.jar:/home/zookeeper-3.4.12/bin/../lib/jline-0.9.94.jar:/home/zookeeper-3.4.12/bin/../lib/audience-annotations-0.5.0.jar:/home/zookeeper-3.4.12/bin/../zookeeper-3.4.12.jar:/home/zookeeper-3.4.12/bin/../src/java/lib/*.jar:/home/zookeeper-3.4.12/bin/../conf:
2018-07-13 08:28:15,298 [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
2018-07-13 08:28:15,298 [myid:] - INFO  [main:Environment@100] - Client environment:java.io.tmpdir=/tmp
2018-07-13 08:28:15,298 [myid:] - INFO  [main:Environment@100] - Client environment:java.compiler=
2018-07-13 08:28:15,298 [myid:] - INFO  [main:Environment@100] - Client environment:os.name=Linux
2018-07-13 08:28:15,299 [myid:] - INFO  [main:Environment@100] - Client environment:os.arch=amd64
2018-07-13 08:28:15,299 [myid:] - INFO  [main:Environment@100] - Client environment:os.version=4.13.0-45-generic
2018-07-13 08:28:15,299 [myid:] - INFO  [main:Environment@100] - Client environment:user.name=root
2018-07-13 08:28:15,299 [myid:] - INFO  [main:Environment@100] - Client environment:user.home=/root
2018-07-13 08:28:15,299 [myid:] - INFO  [main:Environment@100] - Client environment:user.dir=/home/zookeeper-3.4.12/bin
2018-07-13 08:28:15,301 [myid:] - INFO  [main:ZooKeeper@441] - Initiating client connection, connectString=localhost:2181 sessionTimeout=30000 watcher=org.apache.zookeeper.ZooKeeperMain$MyWatcher@255316f2
Welcome to ZooKeeper!
2018-07-13 08:28:15,318 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@1028] - Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
JLine support is enabled
2018-07-13 08:28:15,381 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@878] - Socket connection established to localhost/127.0.0.1:2181, initiating session
2018-07-13 08:28:15,399 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@1302] - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x2000073d09d0000, negotiated timeout = 30000

WATCHER::

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

创建节点并查询

[zk: localhost:2181(CONNECTED) 1] create /zk-book 123
Created /zk-book
[zk: localhost:2181(CONNECTED) 2] ls /
[zk-book, zookeeper]
[zk: localhost:2181(CONNECTED) 3] get /zk-book
123
cZxid = 0x100000004
ctime = Fri Jul 13 08:29:04 GMT 2018
mZxid = 0x100000004
mtime = Fri Jul 13 08:29:04 GMT 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 3
numChildren = 0

转到test_1.thinking.com上打开客户端

# cd /home/zookeeper-3.4.12/bin
# sh zkCli.sh
Connecting to localhost:2181
2018-07-13 08:30:01,663 [myid:] - INFO  [main:Environment@100] - Client environment:zookeeper.version=3.4.12-e5259e437540f349646870ea94dc2658c4e44b3b, built on 03/27/2018 03:55 GMT
2018-07-13 08:30:01,666 [myid:] - INFO  [main:Environment@100] - Client environment:host.name=abf492c11dce
2018-07-13 08:30:01,667 [myid:] - INFO  [main:Environment@100] - Client environment:java.version=1.8.0_171
2018-07-13 08:30:01,669 [myid:] - INFO  [main:Environment@100] - Client environment:java.vendor=Oracle Corporation
2018-07-13 08:30:01,669 [myid:] - INFO  [main:Environment@100] - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2018-07-13 08:30:01,669 [myid:] - INFO  [main:Environment@100] - Client environment:java.class.path=/home/zookeeper-3.4.12/bin/../build/classes:/home/zookeeper-3.4.12/bin/../build/lib/*.jar:/home/zookeeper-3.4.12/bin/../lib/slf4j-log4j12-1.7.25.jar:/home/zookeeper-3.4.12/bin/../lib/slf4j-api-1.7.25.jar:/home/zookeeper-3.4.12/bin/../lib/netty-3.10.6.Final.jar:/home/zookeeper-3.4.12/bin/../lib/log4j-1.2.17.jar:/home/zookeeper-3.4.12/bin/../lib/jline-0.9.94.jar:/home/zookeeper-3.4.12/bin/../lib/audience-annotations-0.5.0.jar:/home/zookeeper-3.4.12/bin/../zookeeper-3.4.12.jar:/home/zookeeper-3.4.12/bin/../src/java/lib/*.jar:/home/zookeeper-3.4.12/bin/../conf:
2018-07-13 08:30:01,669 [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
2018-07-13 08:30:01,669 [myid:] - INFO  [main:Environment@100] - Client environment:java.io.tmpdir=/tmp
2018-07-13 08:30:01,669 [myid:] - INFO  [main:Environment@100] - Client environment:java.compiler=
2018-07-13 08:30:01,670 [myid:] - INFO  [main:Environment@100] - Client environment:os.name=Linux
2018-07-13 08:30:01,670 [myid:] - INFO  [main:Environment@100] - Client environment:os.arch=amd64
2018-07-13 08:30:01,670 [myid:] - INFO  [main:Environment@100] - Client environment:os.version=4.13.0-45-generic
2018-07-13 08:30:01,670 [myid:] - INFO  [main:Environment@100] - Client environment:user.name=root
2018-07-13 08:30:01,670 [myid:] - INFO  [main:Environment@100] - Client environment:user.home=/root
2018-07-13 08:30:01,670 [myid:] - INFO  [main:Environment@100] - Client environment:user.dir=/home/zookeeper-3.4.12/bin
2018-07-13 08:30:01,671 [myid:] - INFO  [main:ZooKeeper@441] - Initiating client connection, connectString=localhost:2181 sessionTimeout=30000 watcher=org.apache.zookeeper.ZooKeeperMain$MyWatcher@255316f2
Welcome to ZooKeeper!
2018-07-13 08:30:01,687 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@1028] - Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
JLine support is enabled
2018-07-13 08:30:01,750 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@878] - Socket connection established to localhost/127.0.0.1:2181, initiating session
2018-07-13 08:30:01,760 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@1302] - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x100007346b00001, negotiated timeout = 30000

WATCHER::

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

查询

[zk: localhost:2181(CONNECTED) 2] get /zk-book
123
cZxid = 0x100000004
ctime = Fri Jul 13 08:29:04 GMT 2018
mZxid = 0x100000004
mtime = Fri Jul 13 08:29:04 GMT 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 3
numChildren = 0

发现在test_2.thinking.com创建并写入的节点/zk-book的值可以在test_1.thinking.com上查到。

在test_1.thinking.com执行更改

[zk: localhost:2181(CONNECTED) 3] set /zk-book 321
cZxid = 0x100000004
ctime = Fri Jul 13 08:29:04 GMT 2018
mZxid = 0x100000006
mtime = Fri Jul 13 08:30:40 GMT 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 3
numChildren = 0
[zk: localhost:2181(CONNECTED) 4] get /zk-book    
321
cZxid = 0x100000004
ctime = Fri Jul 13 08:29:04 GMT 2018
mZxid = 0x100000006
mtime = Fri Jul 13 08:30:40 GMT 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 3
numChildren = 0
[zk: localhost:2181(CONNECTED) 5] 

转到test_2.thinking.com上查询

[zk: localhost:2181(CONNECTED) 4] get /zk-book
321
cZxid = 0x100000004
ctime = Fri Jul 13 08:29:04 GMT 2018
mZxid = 0x100000006
mtime = Fri Jul 13 08:30:40 GMT 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 3
numChildren = 0
[zk: localhost:2181(CONNECTED) 5] 

发现在test_1.thinking.com上的更改也可以在test_2.thinking.com上查得到。