今天學習一下ZooKeeper的部署和使用。

1. 下載ZooKeeper並解壓到D盤根目錄，如下圖。

2. 更改配置 zoo.cfg

(1) 進入conf目錄，發現有zoo_sample.cfg檔案。拷貝該檔案並重命名為zoo.cfg。
(2) 開啟zoo.cfg檔案，”dataDir=/tmp/zookeeper”是Linux系統下的路徑配置，我們更改為”dataDir=D:\zookeeper-3.4.8\data”。

3. 啟動ZooKeeper

(1) 進入bin目錄下

(2) 啟動ZooKeeper伺服器端：雙擊”zkServer.cmd”檔案。

(3) 啟動ZooKeeper客戶端：雙擊”zkCli.cmd”檔案。

4. 使用ZooKeeper

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;

public class ZooKeeperTest {

    public static void main(String[] args) throws Exception {
        Watcher watcher = new Watcher() {
            // 監控所有被觸發的事件
            public void process(WatchedEvent event) {
                System.out
 
.println("觸發了" + event.getType() + "事件！");
            }
        };

        // 1.連線ZooKeeper伺服器
        // 第一個引數：ZooKeeper伺服器的連線地址，如果ZooKeeper是叢集模式或偽叢集模式（即ZooKeeper伺服器有多個），那麼每個連線地址之間使用英文逗號間隔，單個連線地址的語法格式為"主機IP:ZooKeeper伺服器埠號"；
        // 第二個引數：session超時時長（單位：毫秒）
        // 第三個引數：用於監控目錄節點資料變化和子目錄狀態變化的Watcher物件
        ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181"
 
, 5000, watcher);

        // 2.建立名為"/rootNode"的持久目錄節點
        zooKeeper.create("/rootNode", "RootNodeData".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        // 判斷指定目錄節點是否存在
        System.out.println("'/rootNode'節點狀態：" + zooKeeper.exists("/rootNode", true));
        // 獲取"rootNode"節點上的資料
        System.out.println("'/rootNode'節點上資料：" + new String(zooKeeper.getData("/rootNode", false, null)));

        // 3.建立子目錄節點
        // 在"rootNode"節點下建立一個名為"ChildNode1"的子目錄節點
        zooKeeper.create("/rootNode/ChildNode1", "ChildNode1Data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        // 在"rootNode"節點下建立一個和"ChildNode1"同級的名為"ChildNode2"的子目錄節點
        zooKeeper.create("/rootNode/ChildNode2", "ChildNode2Data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        // 取出目錄節點"rootNode"下的所有子目錄節點
        System.out.println("目錄節點'/rootNode'下的所有子目錄節點有：" + zooKeeper.getChildren("/rootNode", true));
        // 修改名為"ChildNode2"的目錄節點資料
        zooKeeper.setData("/rootNode/ChildNode2", "NewChildNode2Data".getBytes(), -1);

        // 4.操作目錄節點
        // 刪除"/rootNode/ChildNode1"目錄節點
        zooKeeper.delete("/rootNode/ChildNode1", -1);
        // 判斷"/rootNode/ChildNode1"目錄節點是否存在
        System.out.println("'/rootNode/ChildNode1'節點狀態：" + zooKeeper.exists("/rootNode/ChildNode1", false));
        // 刪除"/rootNode/ChildNode2"目錄節點
        zooKeeper.delete("/rootNode/ChildNode2", -1);
        // 刪除"/rootNode"目錄節點
        zooKeeper.delete("/rootNode", -1);

        // 5.關閉與ZooKeeper的連線
        zooKeeper.close();
    }
}

輸出結果是：”
觸發了None事件！
‘/rootNode’節點狀態：3,3,1482156908288,1482156908288,0,0,0,0,12,0,3
‘/rootNode’節點上資料：RootNodeData
目錄節點’/rootNode’下的所有子目錄節點有：[ChildNode1, ChildNode2]
觸發了NodeChildrenChanged事件！
‘/rootNode/ChildNode1’節點狀態：null
觸發了NodeDeleted事件！
“