(原) 2.2 ZkClient使用

来源:http://www.cnblogs.com/shengkejava/archive/2016/07/04/5633801.html
-Advertisement-
Play Games

本文為原創文章,轉載請註明出處,謝謝 ZkClient使用 1、jar包引入,演示版本為0.8,非maven項目,可以下載jar包導入到項目中 2、創建Zookeeper連接 示例:ZkClient zc = new ZkClient("192.168.117.128:2181",10000,100 ...


本文為原創文章,轉載請註明出處,謝謝

ZkClient使用

1、jar包引入,演示版本為0.8,非maven項目,可以下載jar包導入到項目中

 

<dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.8</version>
</dependency>

 

 

2、創建Zookeeper連接

 示例:ZkClient zc = new ZkClient("192.168.117.128:2181",10000,10000,new SerializableSerializer());

 API:ZkClient(java.lang.String zkServers, int sessionTimeout, int connectionTimeout, org.I0Itec.zkclient.serialize.ZkSerializer zkSerializer)

  • zkServers:Zookeeper伺服器地址
  • sessionTimeout:session超時時間
  • connectionTimeout:連接超時時間
  • zkSerializer:序列化器,ZkClient提供2種
    • SerializableSerializer:對象序列化,可轉換對象
    • BytesPushThroughSerializer:位元組數組序列化

3、創建節點

   示例:

 @Test
    public void createNode() {
        createSession();
        User user = new User();
        user.setId(1l);
        user.setName("scot");
        String path = zc.create("/zkClient_01/02",user, CreateMode.PERSISTENT);
        System.out.println("path :" + path);
    }

 API:

public java.lang.String create(java.lang.String path, java.lang.Object data, org.apache.zookeeper.CreateMode mode) public java.lang.String create(java.lang.String path, java.lang.Object data, java.util.List<org.apache.zookeeper.data.ACL> acl, org.apache.zookeeper.CreateMode mode) 

示例用的為第一種,沒有設置訪問許可權列表(List<org.apache.zookeeper.data.ACL> acl)

  • path:創建節點路徑。(需要確保父路徑存在)
  • data:節點數據。設置與獲取要註意創建連接時候的序列化器
  • Acl:許可權列表。詳情查看 2.1Zookeeper原始API使用
  • mode:節點類型。詳情查看 2.1Zookeeper原始API使用

4、節點是否存在

  boolean exists(java.lang.String path);

5、獲取節點信息

 示例:

 @Test
    public void getNode() {
        createSession();
        User user = zc.readData("/zkClient_01");
        System.out.println(user.getName());

        Stat stat = new Stat();
        User user1 = zc.readData("/zkClient_01",stat);
        System.out.println(user.getName());
        System.out.println(stat);
    }

API:

   public <T> T readData(java.lang.String path)public <T> T readData(java.lang.String path, boolean returnNullIfPathNotExists)public <T> T readData(java.lang.String path, org.apache.zookeeper.data.Stat stat)
  • path:節點路徑。
  • returnnullIfPathNotExists:同字面意思,節點不存在返回null
  • stat:節點詳細信息。傳遞stat對象到readData方法,方法內部會填充stat數據

6、獲取子節點

  示例:

@Test
    public void getChild() {
        createSession();
        String path = "/node_scot";
        boolean b = this.exists(path);
        if(b) {
            List<String> children =zc.getChildren(path);
            System.out.println(children.size());
        }else {
            System.out.println("do not have this node");
        }
    }

 API:

   public java.util.List<java.lang.String> getChildren(java.lang.String path) 

 

7、刪除節點

  示例:   

 @Test
    public void del() {
        createSession();
        String path = "/zkClient_01/01";
        if(this.exists(path)) {
            //zc.delete(path);//刪除當前節點,有子節點無法刪除
            zc.deleteRecursive(path);//刪除非子節點
        }
    }

 API:

public boolean delete(java.lang.String path)

public boolean delete(java.lang.String path, int version) 

public boolean deleteRecursive(java.lang.String path) 
  • version:節點的版本。如果版本不符無法刪除

 8、更新節點信息

  示例:

@Test
    public void writeNode() {
        createSession();
        User user = new User();
        user.setId(11l);
        user.setName("sksujer002");
        zc.writeData("/zkClient_01",user);
    }

 

9、監控子節點改變(當前節點不存在也可以設置監控)

 示例: 

    @Test
    public void subscribeChildChange() throws InterruptedException {
        createSession();
        zc.subscribeChildChanges("/zkClient_01",new MyZkChildListener());
        Thread.sleep(Integer.MAX_VALUE);
    }

    static class MyZkChildListener implements IZkChildListener {

        @Override
        public void handleChildChange(String s, List<String> strings) throws Exception {
            System.out.println("s:"+s);
            System.out.println("Strings:" + strings);
        }
    }

 

API:

public java.util.List<java.lang.String> subscribeChildChanges(java.lang.String path, org.I0Itec.zkclient.IZkChildListener listener)

public interface IZkChildListener {
  void handleChildChange(java.lang.String parentPath, java.util.List<java.lang.String> currentChilds) throws java.lang.Exception;
}
  • subscribeChildChanges:註冊子節點改變監控
    • path:路徑
    • IZkChildListener listener:子節點監控介面
  • IZkChildListener - handChildChange:子節點列表發生改變觸發此方法
    • parentPath:監控節點路徑
    • currentChilds:子節點列表

10、監控節點數據

 示例:

 @Test
    public void subscribeDataChange () throws InterruptedException {
        createSession();
        zc.subscribeDataChanges("/zkClient_01",new MyZkDataListener());
        Thread.sleep(Integer.MAX_VALUE);
    }

    static class MyZkDataListener implements IZkDataListener {

        @Override
        public void handleDataChange(String s, Object o) throws Exception {
            System.out.println("節點信息改變");
            System.out.println("s:"+s);
            System.out.println("o:"+o);
        }

        @Override
        public void handleDataDeleted(String s) throws Exception {
            System.out.println("節點被刪除:"+s);
        }
    }

API:

 public void subscribeDataChanges(java.lang.String path, org.I0Itec.zkclient.IZkDataListener listener)


public interface IZkDataListener {
void handleDataChange(java.lang.String dataPath, java.lang.Object object) throws java.lang.Exception;

void handleDataDeleted(java.lang.String dataPath) throws java.lang.Exception;
}
  • subscribeDataChanges:註冊節點數據監控
    • IZkDataListener listener:數據改變監控介面
  • IZkDataListener - handleDataChange:節點數據改變觸發此方法
    • dataPath:監控節點路徑
    • object:節點的新數據
  • IZkDataListener - handleDataDeleted:節點被刪除觸發此方法
    • dataPath:監控節點路徑

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 代碼一大串! ...
  • 一.設計背景 現實生活中,我們要做一件事情或者完成某項工作,往往有很多種途徑。比如我們出游,可以選擇坐汽車,坐火車,土豪點的選擇是坐飛機。還有我們現線上下的支付方式也有了很多種選擇,以前在外面忘了帶錢的話可能一瓶水都難以買到,現在只要我們手機在身上,可以用微信或者支付寶。 在軟體設計層面,我們把各種 ...
  • 簡介 由於網路技術日趨成熟,黑客們也將註意力從以往對網路伺服器的攻擊逐步轉移到了對web應用的攻擊。據最新調查,信息安全有75%都發生在web應用而非網路層面。 場景 1. 控制訪問的許可權。只讓可以訪問的訪問到最小的資源和許可權。 2. 控制輸入內容。所有輸入都可能是不安全的,所以要過濾。 3. 保證 ...
  • 伏羲八卦、文王六十四卦、老子陰陽太極、西方哲學辯證與"解耦和復用”思想的異曲同工之妙 問題:任何程式語言在遇到複雜邏輯時,代碼維護難度就會加大,如何處理該問題? 答案:重構,模塊化。 重構、模塊化的最終趨向都是"解耦復用"。 問題:那麼如何理解"解耦復用"? 答案: 道可道,非常道;名可名,非常名。 ...
  • 場景 1. 過濾非正常用戶使用的http請求。 2. 限制正常用戶使用的範圍(下載速度、訪問頻率等)。 3. 通過架構規劃來提升安全。 4. 能自動解決http請求問題。 解決方案 代理自身的安全 1. 千萬不要使用root啟動!!! 2. 關閉伺服器的信息。 3. 關閉掉不使用的模塊。 過濾htt ...
  • 一、MyBatis入門簡要介紹(百科) MyBatis 是支持普通 SQL查詢,存儲過程和高級映射的優秀持久層框架。MyBatis 消除了幾乎所有的JDBC代碼和參數的手工設置以及結果集的檢索。MyBatis 使用簡單的 XML或註解用於配置和原始映射,將介面和 Java 的POJOs(Plain ...
  • 在工作過程中,我經常能和來自全球各地的首席信息安全官(chief information security officers ,CISO)交流,他們所在的企業面對著不同的信息安全環境,關心的安全問題也不盡相同。但總體上來說,他們在信息安全防護上的困擾集中在以下四個問題: 1、雲應用安全 如今,越來越 ...
  • 一、平臺簡介 AgileEAS.NET SOA 中間件平臺是一款基於基於敏捷並行開發思想和Microsoft .Net構件(組件)開發技術而構建的一個快速開發應用平臺。用於幫助中小型軟體企業建立一條適合市場快速變化的開發團隊,以達到節省開發成本、縮短開發時間,快速適應市場變化的目的。 AgileEA ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...