Zookeeper安裝及基本操作

這篇具有很好參考價(jià)值的文章主要介紹了Zookeeper安裝及基本操作。希望對大家有所幫助。如果存在錯(cuò)誤或未考慮完全的地方，請大家不吝賜教，您也可以點(diǎn)擊"舉報(bào)違法"按鈕提交疑問。

zookeeper

ZooKeeper是一個(gè)開源的分布式應(yīng)用程序協(xié)調(diào)服務(wù)

簡單來說可以理解為zookeeper = 文件系統(tǒng)+監(jiān)聽通知機(jī)制

應(yīng)用場景:

集群管理、服務(wù)器狀態(tài)感知
分布式應(yīng)用配置管理
統(tǒng)一命名服務(wù)
分布式鎖

小總結(jié)：

為客戶提供寫數(shù)據(jù)功能數(shù)據(jù)不大狀態(tài)信息數(shù)據(jù)

為客戶提供讀取據(jù)功能

為用戶提監(jiān)控通知功能節(jié)點(diǎn)數(shù)據(jù)的變化節(jié)點(diǎn)的子節(jié)點(diǎn)個(gè)數(shù)

Zookeeper的高度可靠性
是一個(gè)分布式的系統(tǒng),多個(gè)節(jié)點(diǎn) 并且節(jié)點(diǎn)中記錄的數(shù)據(jù)是完全一致(一致性) , 當(dāng)某個(gè)zk的節(jié)點(diǎn)宕機(jī)之后不會影響工作。因?yàn)閆ookeeper的主節(jié)點(diǎn)不存在單點(diǎn)故障！Zookeeper的主節(jié)點(diǎn)是可以動(dòng)態(tài)選舉出來的！

Zookeeper的選舉機(jī)制(奇數(shù)臺)

zookeeper的進(jìn)程在不同的工作模式下，有不同的通信端口（比如選舉時(shí)，通過端口3888通信；作為leader或者follower接收客戶端請求時(shí)通過端口2181；leader和follower之間通信用2888）
zk集群安裝的時(shí)候會人為的為每臺機(jī)器分配一個(gè)唯一的id

Leader選舉過程（以3個(gè)節(jié)點(diǎn)的集群為例）：
? 集群初次啟動(dòng)時(shí)的選舉流程

第一臺機(jī)器(id=1)啟動(dòng)，發(fā)現(xiàn)沒有l(wèi)eader，進(jìn)入投票模式，投自己，并收到自己投這一票，得1票，不能當(dāng)選leader（當(dāng)leader的條件是，集群機(jī)器數(shù)量過半的票數(shù)）
第2臺機(jī)器（id=2）啟動(dòng)，發(fā)現(xiàn)沒有l(wèi)eader，進(jìn)入投票模式，投自己（因?yàn)樽约旱膇d>1 收到的另一臺機(jī)器的票的id）
第1臺機(jī)器收到2的票，發(fā)現(xiàn)集群中有一個(gè)比自己id大的機(jī)器上線了，重新投票，投id=2
第2臺收到的得票數(shù)為2票，過半數(shù)，自己當(dāng)選，切換模式：Leader模式
第1臺就發(fā)現(xiàn)有Leader存在了，自己切換模式：Follower
第3臺啟動(dòng)，發(fā)現(xiàn)有Leader，自動(dòng)進(jìn)入Follower狀態(tài)

如果每個(gè)節(jié)點(diǎn)是同時(shí)啟動(dòng)的zk 同時(shí)選舉自己 ,同時(shí)廣播 , 同時(shí)獲取別人的廣播,3號機(jī)器會當(dāng)選

? 集群在運(yùn)行過程中的選舉流程

在某個(gè)時(shí)間點(diǎn)上，id=2機(jī)器掛了(leader)，別的機(jī)器發(fā)現(xiàn)沒有l(wèi)eader了，全體進(jìn)入投票模式
先投自己，票中會攜帶（自己的id，自己的數(shù)據(jù)的版本號）
大家都投數(shù)據(jù)版本最新的節(jié)點(diǎn)做leader，如果有多個(gè)節(jié)點(diǎn)數(shù)據(jù)版本一樣，則從中選id最大的那個(gè)作為投票目標(biāo)！

從上述投票機(jī)制可以看出：
Zookeeper集群的節(jié)點(diǎn)數(shù)最好配置為奇數(shù)！
Zookeeper集群的節(jié)點(diǎn)規(guī)模一般在3~5臺就夠！

數(shù)據(jù)結(jié)構(gòu)

zookeeper數(shù)據(jù)模型的結(jié)構(gòu)與Unix文件系統(tǒng)很類似，整體上可看作是一棵樹（也類似linux，hdfs），每一個(gè)節(jié)點(diǎn)稱作一個(gè)ZNode。每一個(gè)ZNode默認(rèn)只能夠存儲1MB的數(shù)據(jù)(無法存儲海量數(shù)據(jù))。每個(gè)ZNode都可以通過其路徑唯一標(biāo)識。

安裝

1.上傳安裝包并解壓
2.修改配置文件

cd /opt/apps/zookeeper-3.4.6/conf
# 將 zoo_sample.cfg的文件名修改成zoo.cfg
mv  zoo_sample.cfg   zoo.cfg
# 進(jìn)入到zoo.cfg中修改配置信息
vi zoo.cfg

# 修改兩個(gè)地方：
# 1.數(shù)據(jù)存儲路徑
dataDir=/opt/apps/zookeeper-3.4.6/zkData
# 2.zk服務(wù)地址
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
server.1=linux01:2888:3888
server.2=linux02:2888:3888
server.3=linux03:2888:3888

3.在各個(gè)節(jié)點(diǎn)上，手動(dòng)創(chuàng)建數(shù)據(jù)存儲目錄

mkdir -p /opt/apps/zookeeper-3.4.6/zkData

4.在各個(gè)節(jié)點(diǎn)的數(shù)據(jù)存儲目錄中，生成一個(gè)myid文件，內(nèi)容為它的id

# linux01
echo 1 > /opt/apps/zookeeper-3.4.6/zkData/myid
# lunux02
echo 2 > /opt/apps/zookeeper-3.4.6/zkData/myid
# lunux03
echo 3 > /opt/apps/zookeeper-3.4.6/zkData/myid
# 注意：在linux02上，myid里面的值就是2，03上面的值就是3，是依次遞增的

5.分發(fā)安裝包

for i in 2 3
do
scp -r zookeeper-3.4.6 linux0$i:$PWD
done

6.啟動(dòng)zk集群腳本

#!/bin/bash
for i in 1 2 3 
do
ssh linux0${i} "source /etc/profile;/opt/apps/zookeeper-3.4.6/bin/zkServer.sh $1"
done
 
sleep 2
 
if [ $1 == start ]
then
for i in {1..3}
do
ssh doit0${i} "source /etc/profile;/opt/apps/zookeeper-3.4.6/bin/zkServer.sh status "
done
fi

命令行客戶端操作

客戶端啟動(dòng)連接

bin/zkCli.sh  本地連接
bin/zkCli.sh  -server doit02:2181  連接到指定的服務(wù)節(jié)點(diǎn)

ls：查看某個(gè)路徑下的key

ls /
[doit, zookeeper]

ls2：查看指定目錄下的節(jié)點(diǎn) 詳細(xì)

ls2 /zookeeper

[quota]
cZxid = 0x0                              該數(shù)據(jù)節(jié)點(diǎn)被創(chuàng)建時(shí)的事務(wù)id
ctime = Thu Jan 01 08:00:00 CST 1970     該數(shù)據(jù)節(jié)點(diǎn)創(chuàng)建時(shí)間
mZxid = 0x0                              該數(shù)據(jù)節(jié)點(diǎn)被修改時(shí)最新的事物id
mtime = Thu Jan 01 08:00:00 CST 1970     該數(shù)據(jù)節(jié)點(diǎn)最后修改時(shí)間
pZxid = 0x0                              當(dāng)前節(jié)點(diǎn)的父級節(jié)點(diǎn)事務(wù)ID
cversion = -1                            子節(jié)點(diǎn)版本號（子節(jié)點(diǎn)修改次數(shù)，每修改一次值+1）
dataVersion = 0                          當(dāng)前節(jié)點(diǎn)版本號（可以理解為修改次數(shù)，每修改一次值+1）
aclVersion = 0                           當(dāng)前節(jié)點(diǎn)acl版本號（acl節(jié)點(diǎn)被修改次數(shù)，每修改一次值+1）
ephemeralOwner = 0x0                     臨時(shí)節(jié)點(diǎn)標(biāo)示，當(dāng)前節(jié)點(diǎn)如果是臨時(shí)節(jié)點(diǎn)，則存儲的創(chuàng)建者的會話id（sessionId），如果不是，那么值=0
dataLength = 0                           當(dāng)前節(jié)點(diǎn)數(shù)據(jù)長度
numChildren = 1                          當(dāng)前節(jié)點(diǎn)子節(jié)點(diǎn)個(gè)數(shù)

Create：創(chuàng)建一個(gè)znode

create /aaa ddd

[zk: localhost:2181(CONNECTED) 1] create /doit niubi 
# 創(chuàng)建完成后當(dāng)get的時(shí)候會有如下信息
[zk: localhost:2181(CONNECTED) 33] get /doit
niubi
cZxid = 0x2000000013
ctime = Fri May 05 22:25:28 CST 2023
mZxid = 0x2000000013
mtime = Fri May 05 22:25:28 CST 2023
pZxid = 0x2000000013
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 0
# 可以看到cversion 子節(jié)點(diǎn)的版本號還是0，以及dataVersion數(shù)據(jù)節(jié)點(diǎn)版本也還是0
#由于目前是默認(rèn)創(chuàng)建的（沒有使用-s -e），所以創(chuàng)建的這個(gè)節(jié)點(diǎn)是非順序的，沒有順序的，并且是持久化的

#如果想要?jiǎng)?chuàng)建一個(gè)臨時(shí)節(jié)點(diǎn)，可以加上 -e 這個(gè)參數(shù)

[zk: localhost:2181(CONNECTED) 36] create -e /doit/abc aaa
Created /doit/abc
[zk: localhost:2181(CONNECTED) 37] stat /doit             
cZxid = 0x2000000013
ctime = Fri May 05 22:25:28 CST 2023
mZxid = 0x2000000013
mtime = Fri May 05 22:25:28 CST 2023
pZxid = 0x2000000015
cversion = 1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 1
#用stat命令查看的時(shí)候會發(fā)現(xiàn) cversion 變成了1

# 在去查看臨時(shí)節(jié)點(diǎn)的時(shí)候
[zk: localhost:2181(CONNECTED) 38] stat /doit/abc
cZxid = 0x2000000015
ctime = Fri May 05 22:28:29 CST 2023
mZxid = 0x2000000015
mtime = Fri May 05 22:28:29 CST 2023
pZxid = 0x2000000015
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x187ec3969a40000
dataLength = 3
numChildren = 0
#會發(fā)現(xiàn)臨時(shí)節(jié)點(diǎn)和持久化節(jié)點(diǎn)的ephemeralOwner 是不一樣的
#那么應(yīng)該如何刪除臨時(shí)節(jié)點(diǎn)呢？只要斷開客戶端的鏈接即可。按住ctrl + c進(jìn)行退出，然后再查詢一下子節(jié)點(diǎn)

#創(chuàng)建順序節(jié)點(diǎn) create -s
[zk: localhost:2181(CONNECTED) 39] create -s /doit/aaa abc
Created /doit/aaa0000000001
[zk: localhost:2181(CONNECTED) 40] create -s /doit/aaa abc
Created /doit/aaa0000000002
[zk: localhost:2181(CONNECTED) 41] create -s /doit/aaa abc
Created /doit/aaa0000000003
[zk: localhost:2181(CONNECTED) 42] create -s /doit/aaa abc
Created /doit/aaa0000000004
[zk: localhost:2181(CONNECTED) 43] create -s /doit/aaa abc
Created /doit/aaa0000000005

#可以看到，用-s創(chuàng)建出來的子節(jié)點(diǎn)后面會跟上一個(gè)遞增的序號
[zk: localhost:2181(CONNECTED) 44] ls /doit
[aaa0000000004, aaa0000000003, abc, aaa0000000005, aaa0000000002, aaa0000000001]

get:查看一個(gè)key的value

get /paopao
niubi
cZxid = 0x2000000003
ctime = Fri May 05 22:10:47 CST 2023
mZxid = 0x2000000005
mtime = Fri May 05 22:12:23 CST 2023
pZxid = 0x2000000003
cversion = 0
dataVersion = 2
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 0

set:給key的value賦值

set /doit paopao
cZxid = 0x2000000013
ctime = Fri May 05 22:25:28 CST 2023
mZxid = 0x200000001b
mtime = Fri May 05 22:38:04 CST 2023
pZxid = 0x200000001a
cversion = 6
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 5
numChildren = 6

delete:刪除空節(jié)點(diǎn)

delete /paopao
 
# 如果這個(gè)節(jié)點(diǎn)不是空的，delete是刪除不了的，只能用rmr刪除
 
create /paopao aaa
Created /paopao

create /doit/abc  aaa
Created /doit/abc

delete /paopao
Node not empty: /paopao

# rmr：刪除節(jié)點(diǎn)(可以遞歸刪除)
rmr /paopao

事件監(jiān)聽

zookeeper中對znode的變化描述有3種事件類型：

節(jié)點(diǎn)value變化事件
節(jié)點(diǎn)的子節(jié)點(diǎn)變化事件
節(jié)點(diǎn)被創(chuàng)建、被刪除事件

對應(yīng)的，客戶端向zk注冊監(jiān)聽的命令為：

get    /abc watch
ls     /abc watch
ls2    /abc watch
stat   /abc watch

# 第一個(gè)客戶端
get /paopao  watch  # 獲取節(jié)點(diǎn)數(shù)據(jù)的時(shí)候監(jiān)控(監(jiān)控當(dāng)前節(jié)點(diǎn)數(shù)據(jù)的變化)
# 克隆一個(gè)會話 在客戶端修改節(jié)點(diǎn)數(shù)據(jù)的值
set /paopao bbb
# 第一個(gè)客戶端會出現(xiàn)如下信息:
WatchedEvent state:SyncConnected type:NodeDataChanged path:/paopao

# 第一個(gè)客戶端
ls /teache  watch
# 克隆一個(gè)會話 創(chuàng)建一個(gè)客戶端 , 在/teacher節(jié)點(diǎn)下創(chuàng)建一個(gè)新的節(jié)點(diǎn)/刪除節(jié)點(diǎn)下的子節(jié)點(diǎn)
create /doit/aaa aaa
Created /doit/aaa
# 第一個(gè)客戶端會出現(xiàn)如下信息:
WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/doit

# 注意：客戶端向zk注冊的事件監(jiān)聽，只會被通知1次！如果需要持續(xù)監(jiān)聽，則需要反復(fù)注冊

java客戶端

添加依賴文章來源地址http://www.zghlxwxcb.cn/news/detail-474530.html

<dependencies>
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.9</version>
    </dependency>
</dependencies>

獲取客戶端

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;

import java.io.IOException;
import java.util.List;

public class zkCliDemo {
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        String connectionString = "linux01:2181,linux02:2181,linux03:2181" ;
        // 超時(shí)時(shí)間  單位毫秒
        int sessionTimeOut = 2000 ;
        // 參數(shù)三  監(jiān)聽  null
        // alt+enter   導(dǎo)包  異常處理
        // 快速返回值    .var   或者   ctrl+alt+v
        // 獲取操作ZK的java客戶端對象
        ZooKeeper zooKeeper = new ZooKeeper(connectionString, sessionTimeOut, null);
        /**
         * 獲取指定目錄下的所有的子節(jié)點(diǎn)
         * 參數(shù)一  路徑   一定以/開始
         * 參數(shù)二 是否監(jiān)控
         */
        List<String> list = zooKeeper.getChildren("/", null);
        // 遍歷指定節(jié)點(diǎn)下的所有的子節(jié)點(diǎn)
        for (String s : list) {
            System.out.println("/節(jié)點(diǎn)下的所有的子節(jié)點(diǎn)有: /"+s);  // "/"s
        }

        zooKeeper.close();

    }
}

根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：cluster
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：brokers
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：zookeeper
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：admin
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：isr_change_notification
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：log_dir_event_notification
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：controller_epoch
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：doit
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：consumers
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：latest_producer_id_block
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：config
根節(jié)點(diǎn)下有哪些子節(jié)點(diǎn)：hbase

創(chuàng)建子節(jié)點(diǎn)

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;

import java.util.List;

/**
 * 1.獲取到zk的對象
 * 2.調(diào)用api
 */
public class CreateDemo {
    public static void main(String[] args) throws Exception {

        //創(chuàng)建zk的對象
        ZooKeeper zk = new ZooKeeper("linux01:2181",2000,null);

        //創(chuàng)建一個(gè)子目錄，返回創(chuàng)建的目錄
        /**
         * 參數(shù)1：需要?jiǎng)?chuàng)建的節(jié)點(diǎn)名稱，注意需要寫絕對路徑
         * 參數(shù)2：該節(jié)點(diǎn)對應(yīng)value的值，需要傳二進(jìn)制數(shù)組
         * 參數(shù)3：該節(jié)點(diǎn)的權(quán)限，訪問控制列表
         * OPEN_ACL_UNSAFE:使用完全開放的ACL，允許客戶端對znode進(jìn)行讀/寫
         * CREATOR_ALL_ACL：授予節(jié)點(diǎn)創(chuàng)建者所有權(quán)限。需要注意的是，設(shè)置此權(quán)限之前，創(chuàng)建者必須已經(jīng)通了服務(wù)器的認(rèn)證
         * READ_ACL_UNSAFE：僅僅具有讀權(quán)限
         *參數(shù)四  節(jié)點(diǎn)的類型
         *  EPHEMERAL臨時(shí)的   session級別的臨時(shí)  客戶端斷開以后 節(jié)點(diǎn)會被刪除
         *  EPHEMERA _SEQUENTIAL 臨時(shí)有序
         *  PERSISTENT   永久
         *  PERSISTENT_SEQUENTIAL  永久有序
         */
        String s = zk.create("/teacher1", "xiaotao".getBytes(), ZooDefs.Ids.READ_ACL_UNSAFE, CreateMode.PERSISTENT);

        //打印返回創(chuàng)建的路徑
        System.out.println(s);

        //關(guān)閉資源
        zk.close();

    }
}

刪除子節(jié)點(diǎn)

import org.apache.zookeeper.ZooKeeper;

public class DeleteDemo {
    public static void main(String[] args) throws Exception {
        //創(chuàng)建zk的對象
        ZooKeeper zk = new ZooKeeper("linux01:2181",2000,null);

        /**
         * 注意只能刪除空節(jié)點(diǎn)
         * -1代表任何版本，如果是4，那么到這個(gè)版本才能刪掉，否則就會報(bào)錯(cuò)
         * Exception in thread "main" org.apache.zookeeper.KeeperException$BadVersionException:
         * KeeperErrorCode = BadVersion for /teacher
         */
        zk.delete("/teacher",4);
        
        //zk.delete("/teacher",-1);
        
        zk.close();
    }
}

遞歸刪除節(jié)點(diǎn)

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;

import java.util.List;

/**
 * 遞歸刪除文件夾
 */
public class RMRDemo {
    public static void main(String[] args) throws Exception {
        //創(chuàng)建zk的對象
        ZooKeeper zk = new ZooKeeper("linux01:2181",2000,null);
        rmr("/teacher",zk);
        zk.close();
    }


    public static void rmr(String path,ZooKeeper zk) throws Exception {
        List<String> children = zk.getChildren(path, null);
        if (children != null && children.size() >0){
            for (String child : children) {
                rmr(path+"/"+child,zk);
                System.out.println("正在刪除的子節(jié)點(diǎn)是："+path+"/"+child);
            }
        }
        zk.delete(path,-1)
    }
}

獲取節(jié)點(diǎn)的數(shù)據(jù)

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;

import java.io.IOException;
import java.util.List;

public class GetDemo {
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        String connectionString = "linux01:2181,linux02:2181,linux03:2181" ;
        // 超時(shí)時(shí)間  單位毫秒
        int sessionTimeOut = 2000 ;
        // 參數(shù)三  監(jiān)聽  null
        // alt+enter   導(dǎo)包  異常處理
        // 快速返回值    .var   或者   ctrl+alt+v
        // 獲取操作ZK的java客戶端對象
        ZooKeeper zk = new ZooKeeper(connectionString, sessionTimeOut, null);
        byte[] data = zk.getData("/a0000000004", null, null);
        String str = new String(data);
        System.out.println(str);
        zk.close();
    }
}

修改節(jié)點(diǎn)的數(shù)據(jù)

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;

public class SetDemo {
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        String connectionString = "linux01:2181,linux02:2181,linux03:2181" ;
        int sessionTimeOut = 2000 ;
        ZooKeeper zk = new ZooKeeper(connectionString, sessionTimeOut, null);
        /**
         * 更新節(jié)點(diǎn)的數(shù)據(jù)
         *  參數(shù)一  節(jié)點(diǎn)
         *  參數(shù)二  value的值
         *  參數(shù)三 數(shù)據(jù)版本
         */
        Stat stat = zk.setData("/a", "abc".getBytes(), -1);
        zk.close();
    }
}

監(jiān)控節(jié)點(diǎn)中值得變化

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;

import java.io.IOException;

/**
 * 監(jiān)聽節(jié)點(diǎn)中值的變化
 */

public class WatcherDemo {
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {

        //創(chuàng)建zk的對象
        ZooKeeper zk = new ZooKeeper("linux01:2181", 2000, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                System.out.println("就單純的整一個(gè)監(jiān)聽器");
            }
        });

        byte[] data = zk.getData("/teacher", new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                byte[] data = new byte[0];
                try {
                    data = zk.getData("/teacher", this, null);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                System.out.println(new String(data));
            }
        }, null);

//        System.out.println(new String(data));

        Thread.sleep(Integer.MAX_VALUE);

    }
}

監(jiān)聽節(jié)點(diǎn)中子節(jié)點(diǎn)得個(gè)數(shù)變化

import com.sun.media.jfxmediaimpl.HostUtils;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;

import java.io.IOException;
import java.util.List;

/**
 * 監(jiān)聽節(jié)點(diǎn)中值的變化
 */

public class WatcherDemo1 {
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {

        //創(chuàng)建zk的對象
        ZooKeeper zk = new ZooKeeper("linux01:2181", 2000, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                System.out.println("就單純的整一個(gè)監(jiān)聽器");
            }
        });

        List<String> list = zk.getChildren("/teacher", new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                try {
                    List<String> children = zk.getChildren("/teacher", this);
                    for (String child : children) {
                        System.out.println(new String(zk.getData("/teacher/"+child,null,null)));
                    }
                    System.out.println("===========分隔符===============");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });

        //遍歷所有的節(jié)點(diǎn)
//        System.out.println(list);

        Thread.sleep(Integer.MAX_VALUE);

    }
}

shell客戶端：
[zk: localhost:2181(CONNECTED) 68] create /teacher/a   1
Created /teacher/a
[zk: localhost:2181(CONNECTED) 69] create /teacher/b   2
Created /teacher/b
[zk: localhost:2181(CONNECTED) 70] create /teacher/c   3
Created /teacher/c
[zk: localhost:2181(CONNECTED) 71] 

控制臺：
就單純的整一個(gè)監(jiān)聽器
1
===========分隔符===============
1
2
===========分隔符===============
1
2
3
===========分隔符===============

到了這里，關(guān)于Zookeeper安裝及基本操作的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！