Curator實現zookeeper的節(jié)點監(jiān)聽詳解

更新時間：2023年12月18日 10:23:13 作者：暴躁的程序猿啊

這篇文章主要介紹了Curator實現zookeeper的節(jié)點監(jiān)聽詳解,Curtor框架中一共有三個實現監(jiān)聽的方式,一種是NodeCache監(jiān)聽指定節(jié)點,一種是pathChildrenCache監(jiān)聽子節(jié)點,一種是TreeCache可以監(jiān)控所有節(jié)點相當于以上兩種的合集,需要的朋友可以參考下

Curator實現zookeeper的節(jié)點監(jiān)聽

Curtor框架中一共有三個實現監(jiān)聽的方式一種是NodeCache監(jiān)聽指定節(jié)點一種是pathChildrenCache監(jiān)聽子節(jié)點一種是TreeCache可以監(jiān)控所有節(jié)點相當于以上兩種的合集

引入依賴

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-client</artifactId>
            <version>4.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.3.0</version>
        </dependency>

創(chuàng)建一個測試類連接好客戶端

public class CuratorTest {
    private CuratorFramework curatorFramework;
    @Before
    public void testCreate() {
        ExponentialBackoffRetry retry = new ExponentialBackoffRetry(2, 10);
        curatorFramework = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .connectionTimeoutMs(60 * 1000)
                .sessionTimeoutMs(15 * 10000)
                .retryPolicy(retry).build();
        curatorFramework.start();
    }
   @After
    public void close() {
        if (curatorFramework != null) {
            curatorFramework.close();
        }
    }
}

Watch監(jiān)聽之NodeCache

監(jiān)聽一個指定節(jié)點

 @Test
    public void testUpdate() throws Exception {
        //監(jiān)聽一個節(jié)點
        NodeCache nodeCache = new NodeCache(curatorFramework,"/dongwuyuan");
        //注冊監(jiān)聽
        nodeCache.getListenable().addListener(new NodeCacheListener() {
            @Override
            public void nodeChanged() throws Exception {
                System.out.println("節(jié)點變化了?。。?！");
            }
        });
        //開啟監(jiān)聽 參數 如果設置為true 則開啟監(jiān)聽時加載緩存數據
        nodeCache.start(true);
        while (true){
        }
    }

set /dongwuyuan "laohu"

在這里插入圖片描述

Watch監(jiān)聽之PathChildrenCache

監(jiān)聽子節(jié)點的變化

 @Test
    public void testPathChildrenCache() throws Exception {
        // 參數  客戶端，路徑 ，緩存數據，是否壓縮，線程池
        PathChildrenCache pathChildrenCache = new PathChildrenCache(curatorFramework,"/dongwuyuan",true);
        //綁定監(jiān)聽器
        pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
            @Override
            public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
                System.out.println("子節(jié)點變化了");
                System.out.println(pathChildrenCacheEvent);
                //監(jiān)聽子節(jié)點的變更,并且拿到變更后的數據
                PathChildrenCacheEvent.Type type = pathChildrenCacheEvent.getType();
                //判斷類型是否是update
                if(type.equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){
                     //拿到數據
                    byte[] data = pathChildrenCacheEvent.getData().getData();
                    System.out.println(data);
                }
            }
        });
        //開啟監(jiān)聽
        pathChildrenCache.start();
        while (true){
        }
    }

watch監(jiān)聽之TreeCache

  /**
     * TreeCache:監(jiān)聽節(jié)點自己和所有子節(jié)點們
     */
    @Test
    public void testTreeCache(){
        //1.創(chuàng)建監(jiān)聽器
        TreeCache treeCache = new TreeCache(curatorFramework, "/dongwuyuan");
        //2.注冊監(jiān)聽
        treeCache.getListenable().addListener(new TreeCacheListener() {
            @Override
            public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {
                System.out.println("節(jié)點變化了");
                System.out.println(event);
            }
        });
        //開啟監(jiān)聽
        try {
            treeCache.start();
            while (true){
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

[zk: localhost:2181(CONNECTED) 13] delete /dongwuyuan/node1

在這里插入圖片描述

[zk: localhost:2181(CONNECTED) 15] set /dongwuyuan/node2  "shizi"

在這里插入圖片描述

完整代碼

public class CuratorTest {
    private CuratorFramework curatorFramework;
    @Before
    public void testCreate() {
        ExponentialBackoffRetry retry = new ExponentialBackoffRetry(2, 10);
        curatorFramework = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .connectionTimeoutMs(60 * 1000)
                .sessionTimeoutMs(15 * 10000)
                .retryPolicy(retry).build();
        curatorFramework.start();
    }
    @Test
    public void testUpdate() throws Exception {
        //監(jiān)聽一個節(jié)點
        NodeCache nodeCache = new NodeCache(curatorFramework,"/dongwuyuan");
        //注冊監(jiān)聽
        nodeCache.getListenable().addListener(new NodeCacheListener() {
            @Override
            public void nodeChanged() throws Exception {
                System.out.println("節(jié)點變化了?。。。?);
            }
        });
        //開啟監(jiān)聽 參數 如果設置為true 則開啟監(jiān)聽時加載緩存數據
        nodeCache.start(true);
        while (true){
        }
    }
    @Test
    public void testPathChildrenCache() throws Exception {
        // 參數  客戶端，路徑 ，緩存數據，是否壓縮，線程池
        PathChildrenCache pathChildrenCache = new PathChildrenCache(curatorFramework,"/dongwuyuan",true);
        //綁定監(jiān)聽器
        pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
            @Override
            public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
                System.out.println("子節(jié)點變化了");
                System.out.println(pathChildrenCacheEvent);
                //監(jiān)聽子節(jié)點的變更,并且拿到變更后的數據
                PathChildrenCacheEvent.Type type = pathChildrenCacheEvent.getType();
                //判斷類型是否是update
                if(type.equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){
                     //拿到數據
                    byte[] data = pathChildrenCacheEvent.getData().getData();
                    System.out.println(data);
                }
            }
        });
        //開啟監(jiān)聽
        pathChildrenCache.start();
        while (true){
        }
    }
    /**
     * TreeCache:監(jiān)聽節(jié)點自己和所有子節(jié)點們
     */
    @Test
    public void testTreeCache(){
        //1.創(chuàng)建監(jiān)聽器
        TreeCache treeCache = new TreeCache(curatorFramework, "/dongwuyuan");
        //2.注冊監(jiān)聽
        treeCache.getListenable().addListener(new TreeCacheListener() {
            @Override
            public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {
                System.out.println("節(jié)點變化了");
                System.out.println(event);
            }
        });
        //開啟監(jiān)聽
        try {
            treeCache.start();
            while (true){
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @After
    public void close() {
        if (curatorFramework != null) {
            curatorFramework.close();
        }
    }
}

到此這篇關于Curator實現zookeeper的節(jié)點監(jiān)聽詳解的文章就介紹到這了,更多相關zookeeper節(jié)點監(jiān)聽內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

springboot v2.0.3版本多數據源配置方法
這篇文章主要介紹了springboot v2.0.3版本多數據源配置方法，本文通過實例代碼給大家介紹的非常詳細，具有一定的參考借鑒價值 ,需要的朋友可以參考下
2018-11-11
深度解析Java中的國際化底層類ResourceBundle
做項目應該都會實現國際化，那么大家知道Java底層是如何實現國際化的嗎？這篇文章就來和大家深度解析一下Java中的國際化底層類ResourceBundle，希望對大家有所幫助
2023-03-03
在 Spring Boot 中實現異常處理最佳實踐
本文介紹如何在Spring Boot中實現異常處理,涵蓋核心概念、實現方法、與先前查詢的集成、性能分析、常見問題和最佳實踐,感興趣的朋友一起看看吧
2025-04-04
Java 8中字符串拼接新姿勢StringJoiner詳解
在本篇文章里小編給大家整理了關于Java 8中字符串拼接新姿勢StringJoiner的詳解內容，需要的朋友們參考下。
2019-09-09
Java方法覆蓋重寫實現原理解析
這篇文章主要介紹了Java方法覆蓋重寫實現原理解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2019-12-12
JavaEE7+Websockets+GlassFish4打造聊天室
Java EE 7已經發(fā)布很久了，新增加了很多新的功能和特性，如新增或更新了不少的JSR標準。其中特別受到關注的是Websockets。它的一個好處之一是減少了不必要的網絡流量。它主要是用于在客戶機和服務器之間建立單一的雙向連接。
2015-09-09
全面解析Spring Security 過濾器鏈的機制和特性
這篇文章主要介紹了Spring Security 過濾器鏈的機制和特性,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
2020-07-07
java垃圾回收原理之GC算法基礎
本章簡要介紹GC的基本原理和相關技術, 下一章節(jié)再詳細講解GC算法的具體實現。各種垃圾收集器的實現細節(jié)雖然并不相同,但總體而言,垃圾收集器都專注于兩件事情:查找所有存活對象，拋棄其他的部分,即死對象,不再使用的對象
2022-01-01
Spring循環(huán)依賴的解決辦法,你真的懂了嗎
循壞依賴即循環(huán)引用，兩個或多個bean相互引用，最終形成一個環(huán)。這篇文章主要介紹了Spring循環(huán)依賴的解決辦法,需要的朋友可以參考下
2020-06-06
Java線程監(jiān)聽,意外退出線程后自動重啟的實現方法
下面小編就為大家?guī)硪黄狫ava線程監(jiān)聽,意外退出線程后自動重啟的實現方法。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-03-03