zk命令行操作 · JAVA

[TOC] # 客戶端連接運行`zkCli.sh?–server?<ip>`進入命令行工具 ![](https://box.kancloud.cn/ee4ff73cd4be3353c90c2cafea906eed_652x713.png) 需要注意的是ZK是不能一次創建多級節點的 ~~~ help # 肯定有個根節點,查看根節點 [zk: localhost:2181(CONNECTED) 0] ls / [zookeeper] # 創建個節點,內容是我的女孩,權限不寫默認是所有人都可以訪問 [zk: localhost:2181(CONNECTED) 1] create /mygir "我的女孩" Created /mygir # 讀取數據 [zk: localhost:2181(CONNECTED) 3] get /mygir 我的女孩 cZxid = 0x100000004 ctime = Wed Feb 28 13:37:35 UTC 2018 mZxid = 0x100000004 mtime = Wed Feb 28 13:37:35 UTC 2018 pZxid = 0x100000004 cversion = 0 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 12 numChildren = 0 # 再創建個節點 [zk: localhost:2181(CONNECTED) 1] create /mygir/liuyifei "我的大女朋友" Created /mygir/liuyifei # 修改數據 [zk: localhost:2181(CONNECTED) 2] set /mygir "都是我的夢想" cZxid = 0x100000004 ctime = Wed Feb 28 13:37:35 UTC 2018 mZxid = 0x100000008 mtime = Wed Feb 28 13:44:15 UTC 2018 pZxid = 0x100000007 cversion = 1 dataVersion = 1 //數據版本,表示修改過了一次 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 18 numChildren = 1 //有幾個節點 ~~~ # `_stat`結構體 ~~~ czxid # 引起這個znode創建的zxid,創建節點的事務的zxid ctime # znode被創建的毫秒數(從1970年開始) mzxid # znode最后更新的zxid mtime # znode最后修改的毫秒數(從1970年開始) pZxid # znode最后更新的子節點zxid cversion # znode子節點變化號,znode子節點修改次數 dataversion # znode數據變化號 aclVersion # znode訪問控制列表的變化號 ephemeralOwner # 如果是臨時節點,這個是znode擁有者的session dataLength # znode的數據長度 numChildren # znode子節點數量 ~~~ # 查看znode路徑 ~~~ ls /mygirls ~~~ # 獲取znode數據 ~~~ get /mygirls ~~~ # Zookeeper客戶端四字符指令 conf 配置信息 cons 連接信息 dump 未處理會話節點 envi 環境信息 reqs 未處理請求 stat 統計信息 wchs 服務器watch的詳細信息 wchp 列出指定路徑下服務器信息 ~~~ [root@zk-003 ~]# echo conf | nc 10.0.0.8 2181 clientPort=2181 dataDir=/tmp/zookeeper/version-2 dataLogDir=/tmp/zookeeper/version-2 tickTime=2000 maxClientCnxns=60 minSessionTimeout=4000 maxSessionTimeout=40000 serverId=8 initLimit=10 syncLimit=5 electionAlg=3 electionPort=3888 quorumPort=2888 peerType=0 [root@zk-003 ~]# echo envi | nc 10.0.0.8 2181 Environment: zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT host.name=zk-001 java.version=1.8.0_121 java.vendor=Oracle Corporation java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.121-0.b13.el6_8.x86_64/jre java.class.path=/usr/local/zookeeper/bin/../build/classes:/usr/local/zookeeper/bin/../build/lib/*.jar:/usr/local/zookeeper/bin/../lib/slf4j-log4j12-1.6.1.jar:/usr/local/zookeeper/bin/../lib/slf4j-api-1.6.1.jar:/usr/local/zookeeper/bin/../lib/netty-3.7.0.Final.jar:/usr/local/zookeeper/bin/../lib/log4j-1.2.16.jar:/usr/local/zookeeper/bin/../lib/jline-0.9.94.jar:/usr/local/zookeeper/bin/../zookeeper-3.4.6.jar:/usr/local/zookeeper/bin/../src/java/lib/*.jar:/usr/local/zookeeper/bin/../conf: java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib java.io.tmpdir=/tmp java.compiler=<NA> os.name=Linux os.arch=amd64 os.version=2.6.32-504.el6.x86_64 user.name=root user.home=/root user.dir=/usr/local/zookeeper/conf [root@zk-003 ~]# echo stat | nc 10.0.0.8 2181 Zookeeper version: 3.4.6-1569965, built on 02/20/2014 09:09 GMT Clients: /10.0.0.10:41192[0](queued=0,recved=1,sent=0) Latency min/avg/max: 0/0/0 Received: 4 Sent: 3 Connections: 1 Outstanding: 0 Zxid: 0x200000000 Mode: leader Node count: 4 ~~~ # 監聽znode事件 ~~~ ls /mygirls watch ## 就對一個節點的子節點變化事件注冊了監聽 get /mygirls watch ## 就對一個節點的數據內容變化事件注冊了監聽 ~~~ 注意：監聽器只生效一次,再次改變,監聽器就不起效果監聽器的工作機制，其實是在客戶端會專門創建一個監聽線程，在本機的一個端口上等待zk集群發送過來事件 ![](https://box.kancloud.cn/3aa5b68a57a86eb30423b18cec569415_923x489.png)