1. 程式人生 > >Zookeeper Java API呼叫

Zookeeper Java API呼叫

public class ZooKeeperTest  implements Watcher{

    //public final static String zkServerPath = "12.45.67.80:2181";
    //叢集,使用逗號分隔
    public final static String zkServerPath = "12.45.67.80:2181,12.45.67.80:2182,12.45.67.80:2183";
    public final  static  int timeout = 5000;
    public static void main(String[] args) throws  Exception{
        ZooKeeper zk = new ZooKeeper(zkServerPath, timeout, new ZooKeeperTest());

        System.out.println("客戶端開始連線Zookeeper伺服器。。。");
        System.out.println("連線狀態:" +zk.getState());
        new Thread().sleep(5000);
        System.out.println("連線狀態:" +zk.getState());


    }

    public void process(WatchedEvent event) {
        System.out.println("接收到watch通知:" + event.toString());
    }
}

相關推薦

Zookeeper Java API呼叫

public class ZooKeeperTest implements Watcher{ //public final static String zkServerPath = "12.45.67.80:2181"; //叢集,使用逗號分隔 public final

ZooKeeper Java API

state exce 處理 art throws 枚舉類 event exception 類型 org.apache.zookeeper.ZookeeperZookeeper 是在 Java 中客戶端主類,負責建立與 zookeeper 集群的會話, 並提供方法進行操作。o

Java api 呼叫Sqoop2進行MySQL-->Hive的資料同步

1.相關jar包 2.一些需要的引數定義在message.properties中 jdbcHiveUrl=jdbc:hive2://10.1.9.91:10000 //hive地址 jdbcHiveDriver=org.apache.hive.jdbc.Hi

機器學習weka,java api呼叫隨機森林及儲存模型

工作需要,瞭解了一下weka的java api,主要是隨機森林這一塊,剛開始學習,記錄下。 瞭解不多,直接上demo,裡面有一些註釋說明: package weka; import java.io.File; import weka.classifiers.Classifier; i

zookeeper java api(2)

    這裡介紹其他的API對zookeeper的操作。 同步方式獲取子節點資料 public static void getChildrenSync() throws KeeperException, InterruptedException {

zookeeper java api(1)

1 Zookeeper安裝以及啟動     這裡我已經進行了安裝,並且啟動了Zookeeper。埠是2182 2 Zookeeper config tickTime=2000 initLimit=10 syncLimit=5 dataDir=D://zook

Zookeeper --- Java API簡單例項

1、簡單使用 import java.util.List; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeep

使用ZooKeeper Java API程式設計

https://www.cnblogs.com/IcanFixIt/p/7882107.htmlhttps://blog.csdn.net/qiushisoftware/article/details/79043379https://blog.csdn.net/wo54107

Zookeeper Java API (二) zk節點內容的操作和節點的刪除

獲取節點內容 獲取節點內容的方法定義 public byte[] getData(String path, boolean watch, Stat stat) 其中: - path:要獲取內容的節點路徑 - watch:是否設定監控,也就是是否需要

Zookeeper Java API (三) zk節點的通知(Watcher)和回撥(CallBack)

Zk中的通知(Watcher) ZooKeeper中實現對接點的監控,需要實現Watcher介面類,實現其中的process方法 public class WatcherDemo implements Watcher{ public void p

Hadoop學習二(java api呼叫操作HDFS)

上一篇文章記錄了在Ubuntu虛擬機器上啟動了hadoop 這篇文章在windows機器上通過java api方式呼叫操作hdfs,在使用過程中也遇到了一些問題,這裡簡單介紹一下。 工具:.IntellJ IDEA 首先建立了一個maven專案,pom.xml檔案中引入了

ElasticSearch2.3.4之Java Api呼叫例子

ElasticSearch2.3.4 序號 覆蓋功能例子 1 客戶端連結初始化 2 filte無評分查詢用法 3 query有評分查詢用法 4 單欄位分組用法 5 多欄位分組用法 6 讀取有索引無儲存資料的用法 7 設定指定欄位返回 程式碼如下: package com.

【Kafka】使用非自帶zookeeper Java API 例子

這裡沒有使用kafka自帶的zk。1.啟動zk:zk下載解壓至任意資料夾。新建kafka-zk-csdn資料夾。這裡啟動包含三個節點的zk偽叢集,進入kafka-zk-csdn資料夾,新建zk1,zk2和zk3資料夾。kafka-zk-csdn:--zk1    --data

Zookeeper使用--Java API(轉)

包括 acl logs 新的 ack max false pen strong [轉載自作者leesf,原文鏈接] 操作示例   1 創建節點   創建節點有異步和同步兩種方式。無論是異步或者同步,Zookeeper都不支持遞歸調用,即無法在父節點不存在的情況下

使用ZooKeeper提供的Java API操作ZooKeeper

zookeeper 服務協調框架 分布式 集群 Java API 建立客戶端與zk服務端的連接 我們先來創建一個普通的maven工程,然後在pom.xml文件中配置zookeeper依賴: <dependencies> <dependency>

使用Java API操作zookeeper的acl權限

zookeeper Java API 分布式 服務協調框架 ACL權限 默認匿名權限 ZooKeeper提供了如下幾種驗證模式(scheme): digest:Client端由用戶名和密碼驗證,譬如user:password,digest的密碼生成方式是Sha1摘要的base64形式 a

Hbase java API呼叫例子

1、首先要在專案中匯入Hbase依賴的jar包 2、修改windows中的 C:\Windows\System32\drivers\etc\hosts 10.49.85.152 master 10.49.85.182 slaver1 10.49.85.183

zookeeper 基本命令和java api

1.Zookeeper命令工具 啟動zookeeper服務後,連線到zookeeper服務: zkServer -server localhost:2181 執行結果如下: Connecting to localhost:2181 2018-06-10 03:5

Java 破解谷歌翻譯 免費 api 呼叫

在公司大佬的指點下, 寫了個破解谷歌翻譯的工具類,能破解谷歌翻譯, 思路如下: 1 獲取 tkk 2 根據 tkk,和 輸入內容 獲取 tk 3 根據 word,tk ,組裝 url 訪問 谷歌翻譯 api -----------------------------

第6章 使用ZooKeeper原生Java API進行客戶端開發

使用ZooKeeper原生Java API進行客戶端開發 6-1 建立客戶端與zk服務端的連線 6-2 zk會話重連機制 6-3 同步非同步建立zk節點 6-4 修改zk節點資料 6-5 同步非同步刪除zk節點 6-6 CountDownL