開源客戶端Curator 使用（上）

阿新 • • 發佈：2019-01-29

一介紹
Curator是Netflix公司開源的一款Zookeeper客戶端框架，Curator解決了很多Zookeeper客戶端非常底層的細節開發工作，包括連線重連、反覆註冊Watcher等，實現Fluent風格的API介面，目前已經成為Apache的頂級專案，是全世界範圍內使用最廣泛的Zookeeper客戶端之一。

二編輯pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd";>
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.cakin</groupId>
  <artifactId>zookerper</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>
  <name>zookerper</name>
  <url>http://maven.apache.org</url>
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>
  <dependencies>
     <dependency>
         <groupId>org.apache.zookeeper</groupId>
         <artifactId>zookeeper</artifactId>
         <version>3.4.6</version>
     </dependency>
     <dependency>
         <groupId>com.101tec</groupId>
         <artifactId>zkclient</artifactId>
         <version>0.5</version>
     </dependency>
     <dependency>
         <groupId>org.apache.curator</groupId>
         <artifactId>curator-framework</artifactId>
         <version>2.8.0</version>
     </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
  </dependencies>
</project>

三新建Createcuratorsession類
1 程式碼

package com.cakin.zookerper;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.retry.RetryNTimes;
import org.apache.curator.retry.RetryUntilElapsed;
public class Createcuratorsession {
     public static void main(String[] args) throws InterruptedException {;
           //RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
           //RetryPolicy retryPolicy = new RetryNTimes(5, 1000)
           RetryPolicy retryPolicy = new RetryUntilElapsed(5000, 1000);
//         CuratorFramework client = CuratorFrameworkFactory
//                   .newClient("192.168.0.110:2181",5000,5000, retryPolicy);
           CuratorFramework client = CuratorFrameworkFactory
                     .builder()
                     .connectString("192.168.0.110:2181")
                     .sessionTimeoutMs(5000)
                     .connectionTimeoutMs(5000)
                     .retryPolicy(retryPolicy)
                     .build();
           client.start();
           Thread.sleep(Long.MAX_VALUE);
     }
}

四新建CreatecuratorNode類
1 程式碼

package com.cakin.zookerper;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.retry.RetryNTimes;
import org.apache.curator.retry.RetryUntilElapsed;
import org.apache.zookeeper.CreateMode;
public class CreatecuratorNode {
    public static void main(String[] args) throws Exception {;
        //RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        //RetryPolicy retryPolicy = new RetryNTimes(5, 1000)
        RetryPolicy retryPolicy = new RetryUntilElapsed(5000, 1000);
//        CuratorFramework client = CuratorFrameworkFactory
//                .newClient("192.168.0.110:2181",5000,5000, retryPolicy);
        CuratorFramework client = CuratorFrameworkFactory
                .builder()
                .connectString("192.168.0.110:2181")
                .sessionTimeoutMs(5000)
                .connectionTimeoutMs(5000)
                .retryPolicy(retryPolicy)
                .build();
        client.start();
        
        String path = client.create()
                .creatingParentsIfNeeded()
                .withMode(CreateMode.EPHEMERAL)
                .forPath("/cakin/2", "123".getBytes());
        
        System.out.println(path);
        Thread.sleep(Long.MAX_VALUE);
    }
}

2 測試結果
/cakin/2

五新建DelcuratorNode類
1 程式碼

package com.cakin.zookerper;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.retry.RetryNTimes;
import org.apache.curator.retry.RetryUntilElapsed;
import org.apache.zookeeper.CreateMode;
public class DelcuratorNode {
    public static void main(String[] args) throws Exception {;
        //RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        //RetryPolicy retryPolicy = new RetryNTimes(5, 1000)
        RetryPolicy retryPolicy = new RetryUntilElapsed(5000, 1000);
//        CuratorFramework client = CuratorFrameworkFactory
//                .newClient("192.168.0.110:2181",5000,5000, retryPolicy);
        CuratorFramework client = CuratorFrameworkFactory
                .builder()
                .connectString("192.168.0.110:2181")
                .sessionTimeoutMs(5000)
                .connectionTimeoutMs(5000)
                .retryPolicy(retryPolicy)
                .build();
        client.start();
        
        client.delete().guaranteed().deletingChildrenIfNeeded().withVersion(-1).forPath("/test5");
        
        Thread.sleep(Long.MAX_VALUE);
    }
}

2 測試結果
執行程式後，節點被刪除

六新建Delcuratorgetsubnode類
1 程式碼

package com.cakin.zookerper;
import java.util.List;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.RetryUntilElapsed;
public class Delcuratorgetsubnode {
     public static void main(String[] args) throws Exception {;
           //RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
           //RetryPolicy retryPolicy = new RetryNTimes(5, 1000)
           RetryPolicy retryPolicy = new RetryUntilElapsed(5000, 1000);
//         CuratorFramework client = CuratorFrameworkFactory
//                   .newClient("192.168.0.110:2181",5000,5000, retryPolicy);
           CuratorFramework client = CuratorFrameworkFactory
                     .builder()
                     .connectString("192.168.0.110:2181")
                     .sessionTimeoutMs(5000)
                     .connectionTimeoutMs(5000)
                     .retryPolicy(retryPolicy)
                     .build();
           client.start();
           List<String> clist = client.getChildren().forPath("/FirstZnode");
           System.out.println(clist.toString());
           Thread.sleep(Long.MAX_VALUE);
     }
}

2 測試結果
[node4, node2, node3, node1]

七新建curatorgetdate類
1 程式碼

package com.cakin.zookerper;
import java.util.List;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.RetryUntilElapsed;
import org.apache.zookeeper.data.Stat;
public class curatorgetdate {
    public static void main(String[] args) throws Exception {;
        //RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        //RetryPolicy retryPolicy = new RetryNTimes(5, 1000)
        RetryPolicy retryPolicy = new RetryUntilElapsed(5000, 1000);
//        CuratorFramework client = CuratorFrameworkFactory
//                .newClient("192.168.0.110:2181",5000,5000, retryPolicy);
        CuratorFramework client = CuratorFrameworkFactory
                .builder()
                .connectString("192.168.0.110:2181")
                .sessionTimeoutMs(5000)
                .connectionTimeoutMs(5000)
                .retryPolicy(retryPolicy)
                .build();
        client.start();
        
        Stat stat = new Stat();
        byte[] ret =client.getData().storingStatIn(stat).forPath("/cakin");
        System.out.println(new String(ret));
        System.out.println(stat);
        Thread.sleep(Long.MAX_VALUE);
    }
}

2 測試結果
data
42949672981,42949673000,1515239231022,1515245251092,1,4,0,0,4,0,42949672994

八參考
http://www.jikexueyuan.com/course/2063_3.html?ss=1

Metasploit Framework（6）客戶端滲透（上）

文章的格式也許不是很好看，也沒有什麼合理的順序完全是想到什麼寫一些什麼，但各個方面都涵蓋到了能耐下心看的朋友歡迎一起學習，大牛和槓精們請繞道前五篇文章講解了Metasploit Framework的一些基本使用而接下來的文章就是具體使用的案例了滲透技術不是隻明白怎麼用就可以

開源客戶端Curator 使用（上）

一介紹 Curator是Netflix公司開源的一款Zookeeper客戶端框架，Curator解決了很多Zookeeper客戶端非常底層的細節開發工作，包括連線重連、反覆註冊Watcher等，實現Fluent風格的API介面，目前已經成為Apache的頂級專案，是全世界

數據庫字符集（AL32UTF8）和客戶端字符集（2%）是不同的

服務端 oracl ges 11g 解決 tle client 相同解碼登錄oracle數據庫時我們會遇到這樣的提示信息：“數據庫字符集（AL32UTF8）和客戶端字符集（2%）是不同的”。這是由於數據庫服務端和客戶端的字符集不一致所造成的，服務端字符集和客戶端字符集

CAS客戶端整合（二） Zabbix

接口 bus markdown init else default function https ssl Zabbix是一個強大的服務器/交換機監控應用，有zabbix-server, zabbix-client, zabbix-web 三部分。zabbix-web管理端

資料庫字符集（AL32UTF8）和客戶端字符集（2%）不同

今天在安裝Oracle資料庫時出現的一個問題，“資料庫字符集（AL32UTF8）和客戶端字符集（2%）是不同的。字符集轉化可能會造成不可預期的後果”。上網查了一些資料得知Oracle資

zabbix安裝之zabbix客戶端安裝（六）

zabbix客戶端安裝： Ubuntu安裝：下載軟體包： [[email protected] ~]# wget http://repo.zabbix.com/zabbix/4.0/ubuntu/pool/main/z/zabbix-release/zabbix-release_4.0-

zookeeper開源客戶端Curator介紹(六)

上一篇文章介紹了zookeeper原生API的使用,使用過原生API不得不說,有很多的問題,比如：不能遞迴建立和刪除節點、Watcher只能使用一次、還有很多可以解決分散式應用問題的api(比如分散式鎖,leader選舉等)，但由於ZooKeeper提供的原始

zookeeper開源客戶端Curator典型應用場景之-服務註冊與發現(十一)

隨著業務增加,以前簡單的系統已經變得越來越複雜，單純的提升伺服器效能也不是辦法,而且程式碼也是越來越龐大，維護也變得越來越困難，這一切都催生了新的架構設計風格 – 微服務架構的出現。微服務給我們帶來了很多好處，例如：獨立可擴充套件、易維護。但是隨著應用的分解

zookeeper開源客戶端Curator典型應用場景之-Barrier屏障(十三)

什麼是Barrier Barrier是這樣的：Barrier是一個同步點，每一個程序到達此點都要等待，直到某一個條件滿足，然後所有的節點繼續進行。比如：賽跑大家都知道,所有比賽人員都會在起跑線外等待,直到教練員的槍響之後,所有參賽者立刻開始賽跑。 JDK的併

機房收費系統登陸客戶端錯誤（二）執行時錯誤“-2147217887”

解決了執行錯誤91之後可能還會出現這個錯誤，如圖：什麼是OLE DB？OLEDB是微軟的戰略性的通向不同的資料來源的低階應用程式介面。OLE DB不僅包括微軟資助的標準資料介面開放資料庫連通性（ODBC）的結構化查詢語言（SQL）能力，還具有面向其他非SQL

遊戲客戶端面試（Unity）

推薦閱讀：我的CSDN 我的部落格園 QQ群：704621321 一。最開始的兩家公司筆試面試題目

LINUX下socket實現伺服器與多客戶端通訊（一）

一直對網路方面的技術比較感興趣，有時間就學習學習。雖然現在很多高階語言都已將網路程式設計部分做了封裝處理，使之使用更加方便，但是學習基礎原理，還是一個程式設計師必須要做的。 linux下的socket程式設計原理，網路上已經有大把的詳細說明，這裡不做說明，程式碼中已有簡單註釋。具體方法，有

plsql 登入後，提示資料庫字符集（AL32UTF8）和客戶端字符集（ZHS16GBK）不一致

最近開始學習oracle的時候出現了下面這樣的問題：在網上搜索了一些方法，終於找到了解決的方法：首先大家都普遍說的是這一

RTSP客戶端學習（一）——live555庫的移植和驗證

因為專案原因需要在海思Hi3531平臺上實現RTSP客戶端，之前沒接觸過流媒體，作為小白，就記錄下學習過程吧。客戶端和伺服器端均採用live555，之前嘗試過Darwin Stream Server作為伺服器，可以播放樣例視訊檔案，不能播放塞進去的H264檔案。是D

一個簡單的BitTorrent客戶端實現（六）：peer manager和peer實現

peer manager和peer peer是整個BT通訊中最複雜的部分，主要是裡面各種訊息的傳送和一些choke和unchoke策略，piece選擇策略等等。peer manager用於管理peer，本程式中維護多個peer進行遠端通訊。 peer實現

zookeeper開源客戶端Curator典型應用場景之-分散式計數器(十四)

之前我們瞭解了基於Corator的分散式鎖之後,我們就很容易基於其實現一個分散式計數器，顧名思義，計數器是用來計數的, 利用ZooKeeper可以實現一個叢集共享的計數器。只要使用相同的path就可以得到最新的計數器值，這是由ZooKeeper的一致性保證

Unity3d搭建HTTP弱聯網的伺服器搭建及客戶端編寫（一）之java伺服器

HTTP弱聯網java伺服器通過tomcat搭建java伺服器（linux 1、java環境搭建 java環境較容易搭建，在網上很容易找到相關的教程。 2、tomcat環境搭建開始配置tomcat: 複製解壓後的檔案到 /opt

客戶端websocket（C#）長連線及簡易RPC框架設計（一）

0. 背景最近有個需求：與Web伺服器保持長連線，接收服務端發來的訊息，並通過某RPC協議invoke客戶端某些回撥函式。故有了本文的客戶端websocket（C#）長連線及簡易RPC框架設計內容，

Oracle的客戶端安裝（plsql）

PL/SQL安裝詳情雙擊圖示提示資訊：會進入下面的介面進一步到下面的介面，注意修改路徑（不要有中文和空格），我的路徑改為D:\plsql 修改後的路徑如下點”Next”後，進入如下介面

編寫webservice服務端和客戶端例項（1）

1、首先建立介面 @WebService public interface IMyService { //@WebResult(name="addResult")public Integer add(Integer num1,Integer num2);//@WebPara

開源客戶端Curator 使用（上）

相關推薦