2. 程式人生 > >基於Curator操作ZooKeeper（二）-Watcher操作-補充TreeCache

基於Curator操作ZooKeeper（二）-Watcher操作-補充TreeCache

阿新 • • 發佈：2018-11-12

轉自：https://blog.csdn.net/Leafage_M/article/details/78735485#treecache

Java原生API操作ZooKeeper可參看：

Java原生API操作Zookeeper（一）

Java原生API操作Zookeeper（二）

相關內容：

基於Curator操作ZooKeeper（一）-基本操作

基於Curator操作ZooKeeper（二）-Watcher操作

TreeCache

TreeCache有點像上面兩種Cache的結合體，NodeCache能夠監聽自身節點的資料變化（或者是建立該節點），PathChildrenCache能夠監聽自身節點下的子節點的變化，而TreeCache既能夠監聽自身節點的變化、也能夠監聽子節點的變化。

TreeCache的話只有一種構造方法了：

TreeCache(CuratorFramework client, String path)//Create a TreeCache for the given client and path with default options.

與上面的PathChildrenCache不同的是，如果指定的節點路徑不存在的話，不會自動建立。但是也能夠監聽到一個INITIALIZED型別的事件。

TreeCache可以新增一個節點變化的監聽器，同樣的也可以新增一個異常的監聽器。

假如ZooKeeper伺服器中還是有如下的節點內容：

使用如下程式碼進行測試，就是當節點的內容發生變化時，輸出節點的變化型別和變化的節點路徑。

public class TreeCacheTest {

    private static final String zkAddress = "centos3";
    private static final int sessionTimeout = 2000;
    private static String parentPath = "/Curator-Recipes1";//父節點

    private static CuratorFramework client = CuratorFrameworkFactory.builder()
            .connectString(zkAddress)
            .sessionTimeoutMs(sessionTimeout)
            .retryPolicy(new ExponentialBackoffRetry(1000,3))
            .build();

    public static void main(String[] args) throws InterruptedException {
        client.start();
        final TreeCache treeCache = new TreeCache(client, parentPath);
        try {
            treeCache.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
        //新增錯誤監聽器
        treeCache.getUnhandledErrorListenable().addListener(new UnhandledErrorListener() {
            public void unhandledError(String s, Throwable throwable) {
                System.out.println(".錯誤原因：" + throwable.getMessage() + "\n==============\n");
            }
        });

        //節點變化的監聽器
        treeCache.getListenable().addListener(new TreeCacheListener() {
            public void childEvent(CuratorFramework curatorFramework, TreeCacheEvent treeCacheEvent) throws Exception {
                System.out.println("treeCache ------ Type:" + treeCacheEvent.getType() + ",");
                System.out.println(treeCacheEvent.getData().getPath());

            }
        });

        Thread.sleep(Integer.MAX_VALUE);
    }
}

執行時輸出的內容如下：

可以看到快取父節點和子節點的時候觸發了NODE_ADDED事件，同時也會觸發一個INITIALIZED事件，並且會在異常監聽器中發生回撥事件，異常的原因就是我們回撥函式因為INITIALIZED事件被觸發了，但是此時執行第條輸出語句的時候發現treeCacheEvent.getData()是null，而我們在null上呼叫了getPath方法，所以會觸發異常監聽。

注意：

  • 無論如何都會收到一個INITIALIZED事件的。
  • 無論是TreeCache、PathChildrenCache，所謂的監聽都是本地檢視和ZooKeeper伺服器進行對比。所以如果ZooKeeper節點不為空的話，才會在快取開始的時候監聽到NODE_ADDED事件，這是因為剛開始本地快取並沒有內容，然後本地快取和伺服器快取進行對比，發現ZooKeeper伺服器有節點而本地快取沒有，這才將伺服器的節點快取到本地，所以才會觸發NODE_ADDED事件。

示例

來一個綜合性的示例，該示例中先使用init進行初始化操作，會建立一個父節點“/Curator-Recipes”以及父節點下的一個子節點“c1”。然後分別使用TreeCache、PathChildrenCache、NodeCache三種快取方式進行快取。最後再建立c2、c3兩個節點並進行修改和刪除觀察監聽器的輸出內容。

package com.leafage.zk;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.UnhandledErrorListener;
import org.apache.curator.framework.recipes.cache.*;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;

/**
 * @Author Leafage
 * @Date 2017/12/6 14:03
 **/
public class CuratorRecipes {

    private static int num = 1;

    private static final String zkAddress = "centos3";
    private static final int sessionTimeout = 2000;
    private static String parentPath = "/Curator-Recipes";//父節點

    private static CuratorFramework client = CuratorFrameworkFactory.builder()
            .connectString(zkAddress)
            .sessionTimeoutMs(sessionTimeout)
            .retryPolicy(new ExponentialBackoffRetry(1000,3))
            .build();

    public static void main(String[] args) throws InterruptedException {

        init();
        treeCache();
        pathChildrenCache();
        nodeCache();
        testData();
        Thread.sleep(Integer.MAX_VALUE);

    }

    /**
     * 初始化操作，建立父節點
     */
    public static void init() {
        client.start();
        try {
            //可以用用來確保父節點存在，2.9之後棄用
//            EnsurePath ensurePath = new EnsurePath(parentPath);
//            ensurePath.ensure(client.getZookeeperClient());

            if (client.checkExists().forPath(parentPath) == null) {
                client.create().creatingParentContainersIfNeeded().withMode(CreateMode.PERSISTENT).forPath(parentPath, "This is Parent Data!".getBytes());
            }

            client.create().withMode(CreateMode.EPHEMERAL).forPath(parentPath + "/c1","This is C1.".getBytes());//建立第一個節點

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 監聽子節點變化
     */
    public static void pathChildrenCache() {
        final PathChildrenCache pathChildrenCache = new PathChildrenCache(client, parentPath, true);
        try {
            pathChildrenCache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);//啟動模式
        } catch (Exception e) {
            e.printStackTrace();
        }
        //新增監聽
        pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
            public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
                System.out.println( num++ + ".pathChildrenCache------發生的節點變化型別為：" + pathChildrenCacheEvent.getType() + ",發生變化的節點內容為：" + new String(pathChildrenCacheEvent.getData().getData()) + "\n======================\n");
            }
        });
    }


    /**
     * 監聽節點資料變化
     */
    public static void nodeCache() {
        final NodeCache nodeCache = new NodeCache(client, parentPath, false);
        try {
            nodeCache.start(true);//true代表快取當前節點
        } catch (Exception e) {
            e.printStackTrace();
        }

        if (nodeCache.getCurrentData() != null) {//只有start中的設定為true才能夠直接得到
            System.out.println( num++ + ".nodeCache-------CurrentNode Data is:" + new String(nodeCache.getCurrentData().getData()) + "\n===========================\n");//輸出當前節點的內容
        }

        //新增節點資料監聽
        nodeCache.getListenable().addListener(new NodeCacheListener() {
            public void nodeChanged() throws Exception {
                System.out.println( num++ + ".nodeCache------節點資料發生了改變，發生的路徑為：" + nodeCache.getCurrentData().getPath() + ",節點資料發生了改變 ，新的資料為：" + new String(nodeCache.getCurrentData().getData()) + "\n===========================\n");
            }
        });
    }

    /**
     * 同時監聽資料變化和子節點變化
     */
    public static void treeCache() {
        final TreeCache treeCache = new TreeCache(client, parentPath);
        try {
            treeCache.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
        //新增錯誤
        treeCache.getUnhandledErrorListenable().addListener(new UnhandledErrorListener() {
            public void unhandledError(String s, Throwable throwable) {
                System.out.println(num++ + ".錯誤原因：" + throwable.getMessage() + "\n==============\n");
            }
        });

        treeCache.getListenable().addListener(new TreeCacheListener() {
            public void childEvent(CuratorFramework curatorFramework, TreeCacheEvent treeCacheEvent) throws Exception {
                System.out.println( num++ + ".treeCache------當前發生的變化型別為：" +  treeCacheEvent.getType() + ",發生變化的節點內容為：" + new String(treeCacheEvent.getData().getData()) + "\n=====================\n");
            }
        });
    }

    /**
     * 建立節點、修改資料、刪除節點等操作，用來給其他的監聽器測試使用
     */
    public static void testData() {
        try {
            client.create().withMode(CreateMode.EPHEMERAL).forPath(parentPath + "/c2","This is C2.".getBytes());//建立第一個節點
            client.create().withMode(CreateMode.EPHEMERAL).forPath(parentPath + "/c3","This is C3.".getBytes());//建立第一個節點

            client.setData().forPath(parentPath + "/c2", "This is New C2.".getBytes());//修改節點資料

            client.delete().forPath(parentPath + "/c3");//刪除一個節點

            client.delete().deletingChildrenIfNeeded().forPath(parentPath);//將父節點下所有內容刪除

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

輸出內容（每次執行結果輸出順序可能不一致）：

1.treeCache------當前發生的變化型別為：NODE_ADDED,發生變化的節點內容為：This is Parent Data!
=====================

2.treeCache------當前發生的變化型別為：NODE_ADDED,發生變化的節點內容為：This is C1.
=====================

4.錯誤原因：null
==============

5.nodeCache-------CurrentNode Data is:This is Parent Data!
===========================

6.pathChildrenCache------發生的節點變化型別為：CHILD_ADDED,發生變化的節點內容為：This is C1.
======================

8.nodeCache------節點資料發生了改變，發生的路徑為：/Curator-Recipes,節點資料發生了改變 ，新的資料為：This is Parent Data!
===========================

9.treeCache------當前發生的變化型別為：NODE_ADDED,發生變化的節點內容為：This is C2.
=====================

10.treeCache------當前發生的變化型別為：NODE_ADDED,發生變化的節點內容為：This is C3.
=====================

11.pathChildrenCache------發生的節點變化型別為：CHILD_ADDED,發生變化的節點內容為：This is C3.
======================

12.pathChildrenCache------發生的節點變化型別為：CHILD_ADDED,發生變化的節點內容為：This is C2.
======================

13.treeCache------當前發生的變化型別為：NODE_UPDATED,發生變化的節點內容為：This is New C2.
=====================

14.pathChildrenCache------發生的節點變化型別為：CHILD_UPDATED,發生變化的節點內容為：This is New C2.
======================

15.pathChildrenCache------發生的節點變化型別為：CHILD_REMOVED,發生變化的節點內容為：This is C3.
======================

16.treeCache------當前發生的變化型別為：NODE_REMOVED,發生變化的節點內容為：This is C3.
=====================

17.treeCache------當前發生的變化型別為：NODE_REMOVED,發生變化的節點內容為：This is C1.
=====================

18.pathChildrenCache------發生的節點變化型別為：CHILD_REMOVED,發生變化的節點內容為：This is C1.
======================

19.pathChildrenCache------發生的節點變化型別為：CHILD_REMOVED,發生變化的節點內容為：This is New C2.
======================

20.treeCache------當前發生的變化型別為：NODE_REMOVED,發生變化的節點內容為：This is New C2.
=====================

21.treeCache------當前發生的變化型別為：NODE_REMOVED,發生變化的節點內容為：This is Parent Data!
=====================

從輸出內容可以看到：

1、2 ：代表是TreeCache監聽到了父節點和c1節點的建立快取事件。

3、4 ：同時會發現並沒有3這條語句，而是直接跳到了4，這是因為接收到的事件為：INITIALIZED，所以使用getData會得到null，而我們試圖在null上呼叫getPath，所以才會觸發異常。

5：NodeCache快取進行start的時候傳入true引數，所以能夠直接得到當前節點的內容。

6： PathChildrenCache快取成功c1的時候接收到的事件。

7：會發現沒有7，因為PathChildrenCache的啟動模式是：INITIALIZED，此時也是試圖在null上呼叫GetPath，但是PathChildrenCache沒有提供異常監聽器，所以沒辦法獲取。

8：第八點最讓人疑惑了，因為上面的程式碼中並沒有對父節點的資料進行改變，但是卻監聽到了這個事件，做了很多的測試發現，觸發這個事件的原因為後面的testData方法中呼叫create導致的，並且只會監聽到一次，這一點的具體原因還不太清楚。

9、10、11、12：建立c2、c3節點是TreeCache和PathChildrenCache監聽到的事件。

13、14：修改c2節點資料，TreeCache和PathChildrenCache監聽到的事件。

15、16、17、18、19、20：刪除c2、c1、c3節點時，TreeCache和PathChildrenCache監聽到的事件。

21：刪除根節點時接收到的監聽事件，此時只有TreeCache能夠監聽到。
 

相關推薦

基於Curator操作ZooKeeper（二）-Watcher操作-補充TreeCache

轉自：https://blog.csdn.net/Leafage_M/article/details/78735485#treecache Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二）

基於Curator操作ZooKeeper（二）-Watcher操作

Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二） 相關內容： 基於Curator操作ZooKeeper（一）-基本操作 基於Curator操作ZooKeeper（二）-Watche

基於Curator操作ZooKeeper（一）-基本操作

Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二） 相關內容： 基於Curator操作ZooKeeper（二）-Watcher操作 基於Curator操作ZooKeeper（二）-W

VS2010 操作Word（二）基本操作

建立基本的工程之後，下面就是具體的操作和應用了！ 本節主要介紹如何建立，寫入，儲存一個Word。 我們可以建立一個Word的操作類，我這裡建立的是一個DLL程式，這樣可以將一個Word操作封裝起來，便於其他程式呼叫。 按照第一節的類似介紹，我一次添加了需要用到了類： 同

基於Curator操作ZooKeeper（三）-Curator整合Spring

Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二） 相關內容： 基於Curator操作ZooKeeper（一）-基本操作 基於Curator操作ZooKeeper（二）-Watche

Zookeeper--（二）配置文件講解、客戶端使用

臨時 結束 java .com per 客戶端使用 .cn 事務 客戶端 Java操作zookeeper 創建節點 創建子節點 CreateMode.EPHEMETAL臨時節點保證本次回話有效，本次會話結束臨時節點消失，可以實現分布式事務鎖

Qt5.9.1結合REF開發基於chorm的瀏覽器（二）

aid imp right put 作用 配置 lis res window 將libcef_dll_wrapper編譯方式設置為MD 因為使用的Qt是動態鏈接的，而cef模式使用的是靜態鏈接的方式，所以在使用前需要將cef編譯方式改成Multi-thread DLL(/

UI自動化測試（二）瀏覽器操作及對元素的定位方法（xpath定位和css定位詳解）

cli 刷新 ota api enter 版本 ror apache 窗口 Selenium下的Webdriver工具支持FireFox(geckodriver)、 IE(InternetExplorerDriver)、Chrome(ChromeDriver)、 Opera

30天自制操作系統（二）匯編語言學習與Makefile入門

-c 如何 wid 開發 大小端 bio strong 入門 小端 1 介紹文本編輯器 這部分可直接略過 2 繼續開發 helloos.nas中核心程序之前的內容和啟動區以外的內容先不講了，因為還涉及到一些軟盤方面的知識。然後來講的是helloos.nas這個文件 ; h

python學習筆記（二）列表操作

練習 位數組 post print ihe 之間 反轉 st2 money 列表及列表操作： 　　列表是最常用的數據類型之一，列表也叫數組，列表定義，使用[]即可；列表裏面可以再套列表，一個裏面套一個列表，叫二維數組；一個裏面套一個列表，裏面的列表再套一個列表，這個叫三位數

Python操作MySQL（二） ORM篇

msyql orm sqlalchemy SQLAlchemy是Python編程語言下的一款ORM框架，該框架建立在數據庫API之上，使用關系對象映射進行數據庫操作，簡言之便是：將對象轉換成SQL，然後使用數據API執行SQL並獲取執行結果。 一、安裝 pip3 install SQLAlchemy

Docker（二）容器操作容器

latest id號 stop 選項 循環語句 top exe second sha Docker架構（二）容器操作 容器是Docker的令一個可行概念，容器就是鏡像的運行實例，是獨立運行的一個或一組應用 （1）Docker容器的創建和啟動 容器創建就是鏡像加載過程命令格式

計算機操作系統（二）--- 處理器體系結構（三）(轉)

存儲器 階段 block ia32 便是 過程 原則 數量 href 文章部分圖片文字來自參考文章，參考文章總結地很好。 指令處理階段 為了降低實現的復雜性,采用統一的框架,這樣可以共用一些部件.我們將Y86的指令處理組織成如下幾個

Docker入門（二）基本操作

ddr root eba nxv let targe rules gist gdi （一）、容器的使用1、docker客戶端命令。輸入docker查看docker用法的語法和相關的命令。 [root@localhost ~]# docker Usage: docker

node總結之檔案操作系列（二）

接著上一篇部落格來啊，咱們繼續看非同步模式下關閉檔案的語法格式： fs.close(fd, callback) 引數描述如下： fd - 通過 fs.open() 方法返回的檔案描述符。 callback - 回撥函式，沒有引數。 例項如下： var

從Paxos到ZooKeeper（二）初識ZooKeeper

ZooKeeper是什麼 ZooKeeper是一個典型的分散式資料一致性解決方案 ZooKeeper特性 （一）順序一致性 從一個客戶端發起的請求會嚴格按照發起請求的順序應用到Zookeeper中 （二）原子性 所有事務請求處理的結果在叢集中各個機器上的應用情況是一樣的

Photoshop操作總結（二）

 互補色 兩種色光以適當地比例混合而能產生白色感覺時，則這兩種顏色就稱為"互為補色"。 色彩中的互補色：紅，  黃，  藍三原色，紅色與綠色互補，藍色與橙色互補，紫色與黃色互補。  示例 我在球體上做了互補色的練習，首先需要畫出立體球，畫法在第

PHP學習筆記（二）--資料庫操作

下面使用簡單的例子說下在PHP中操作MySql資料庫，內容包括連線資料庫、查詢操作、事務及儲存過程。 1、訪問MySql一般步驟 1）連線MySql伺服器 使用mysql_connect()函式建立與MySql伺服器的連線。 2）選擇MySql資料庫 使用mysql_select

簡單maven的操作使用（二）

簡單maven入門（二） –Eclipse下的maven javaweb專案 目錄結構： 會出現index.jsp出錯，如下修改： pom.xml: <project xmlns="http://maven.apache.org/POM/4.0.0" xm

20181209——複習ElementUI（二）Form操作

Radio 單選框 el-radio 標籤 裡面v-model繫結這個data中的資料項 label表示是第幾個，在data中資料中的返回值進行選定 disabled屬性，使單選框禁用 只要給radio標籤設定了disabled屬性，無法更改 單選框組，節省了程式碼，無需給每一個單選