Curator使用(二)

Curator 使用(二)

子節(jié)點(diǎn)查詢

List<String> childNodes = client.getChildren()
                           .forPath(nodePath);
System.out.println("開始打印子節(jié)點(diǎn):");
for (String s : childNodes) {
   System.out.println(s);
}

判斷節(jié)點(diǎn)是否存在

// 判斷節(jié)點(diǎn)是否存在,如果不存在則為空
Stat statExist = client.checkExists().forPath(nodePath + "/abc");
System.out.println(statExist);

注冊(cè) Watcher 事件

client.getData().usingWatcher(new MyCuratorWatcher()).forPath(nodePath);
client.getData().usingWatcher(new MyWatcher()).forPath(nodePath);

MyCuratorWatcher

import org.apache.curator.framework.api.CuratorWatcher;
import org.apache.zookeeper.WatchedEvent;

public class MyCuratorWatcher implements CuratorWatcher {
   @Override
   public void process(WatchedEvent event) throws Exception {
      System.out.println("觸發(fā) watcher塑陵,節(jié)點(diǎn)路徑為:" + event.getPath());
   }
}

MyWatcher

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;

public class MyWatcher implements Watcher {
   @Override
   public void process(WatchedEvent event) {
      System.out.println("觸發(fā) watcher,節(jié)點(diǎn)路徑為:" + event.getPath());
   }
}

CuratorWatcherWatcher 的區(qū)別主要在于實(shí)現(xiàn)process方法時(shí)對(duì)于異常的處理顿天。其中 CuratorWatcher 可以拋出異常铆遭。

注冊(cè) Watcher 事件(注冊(cè)一次茫死,監(jiān)聽多次)

// 為節(jié)點(diǎn)添加 watcher
// NodeCache: 監(jiān)聽數(shù)據(jù)節(jié)點(diǎn)的變更奋岁,會(huì)觸發(fā)事件
final NodeCache nodeCache = new NodeCache(cto.client, nodePath);

// buildInitial : 初始化的時(shí)候獲取 node 的值并且緩存
nodeCache.start(true);
if (nodeCache.getCurrentData() != null) {
   System.out.println("節(jié)點(diǎn)初始化數(shù)據(jù)為:" + new String(nodeCache.getCurrentData().getData()));
} else {
   System.out.println("節(jié)點(diǎn)初始化數(shù)據(jù)為空...");
}

nodeCache.getListenable().addListener(new NodeCacheListener() {
   public void nodeChanged() throws Exception {
      if (nodeCache.getCurrentData() == null) {
         System.out.println("空");
         return;
      }
      String data = new String(nodeCache.getCurrentData().getData());
      System.out.println("節(jié)點(diǎn)路徑:" + nodeCache.getCurrentData().getPath() + "數(shù)據(jù):" + data);
   }
});

刪除監(jiān)聽事件可以使用 nodeCache.getListenable().removeListener();

為子節(jié)點(diǎn)注冊(cè) Watcher 事件

這種形式的好處在于可以監(jiān)聽節(jié)點(diǎn)的增刪改查操作的觸發(fā)嚼酝。

// 為子節(jié)點(diǎn)添加 watcher
// PathChildrenCache: 監(jiān)聽數(shù)據(jù)節(jié)點(diǎn)的增刪改妄均,會(huì)觸發(fā)事件
String childNodePathCache =  nodePath;
// cacheData: 設(shè)置緩存節(jié)點(diǎn)的數(shù)據(jù)狀態(tài)
final PathChildrenCache childrenCache = new PathChildrenCache(cto.client, childNodePathCache, true);
/**
 * StartMode: 初始化方式
 * POST_INITIALIZED_EVENT:異步初始化,初始化之后會(huì)觸發(fā)事件
 * NORMAL:異步初始化
 * BUILD_INITIAL_CACHE:同步初始化
 */
childrenCache.start(StartMode.POST_INITIALIZED_EVENT);

List<ChildData> childDataList = childrenCache.getCurrentData();
System.out.println("當(dāng)前數(shù)據(jù)節(jié)點(diǎn)的子節(jié)點(diǎn)數(shù)據(jù)列表:");
for (ChildData cd : childDataList) {
   String childData = new String(cd.getData());
   System.out.println(childData);
}

childrenCache.getListenable().addListener(new PathChildrenCacheListener() {
   public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
      if(event.getType().equals(PathChildrenCacheEvent.Type.INITIALIZED)){
         System.out.println("子節(jié)點(diǎn)初始化 ok...");
      }

      else if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_ADDED)){
         String path = event.getData().getPath();
         if (path.equals(ADD_PATH)) {
            System.out.println("添加子節(jié)點(diǎn):" + event.getData().getPath());
            System.out.println("子節(jié)點(diǎn)數(shù)據(jù):" + new String(event.getData().getData()));
         } else if (path.equals("/super/imooc/e")) {
            System.out.println("添加不正確...");
         }

      }else if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_REMOVED)){
         System.out.println("刪除子節(jié)點(diǎn):" + event.getData().getPath());
      }else if(event.getType().equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){
         System.out.println("修改子節(jié)點(diǎn)路徑:" + event.getData().getPath());
         System.out.println("修改子節(jié)點(diǎn)數(shù)據(jù):" + new String(event.getData().getData()));
      }
   }
});
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末倒堕,一起剝皮案震驚了整個(gè)濱河市灾测,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌垦巴,老刑警劉巖媳搪,帶你破解...
    沈念sama閱讀 211,743評(píng)論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異骤宣,居然都是意外死亡秦爆,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,296評(píng)論 3 385
  • 文/潘曉璐 我一進(jìn)店門憔披,熙熙樓的掌柜王于貴愁眉苦臉地迎上來鲜结,“玉大人,你說我怎么就攤上這事活逆。” “怎么了拗胜?”我有些...
    開封第一講書人閱讀 157,285評(píng)論 0 348
  • 文/不壞的土叔 我叫張陵蔗候,是天一觀的道長。 經(jīng)常有香客問我埂软,道長锈遥,這世上最難降的妖魔是什么纫事? 我笑而不...
    開封第一講書人閱讀 56,485評(píng)論 1 283
  • 正文 為了忘掉前任,我火速辦了婚禮所灸,結(jié)果婚禮上丽惶,老公的妹妹穿的比我還像新娘。我一直安慰自己爬立,他們只是感情好钾唬,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,581評(píng)論 6 386
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著侠驯,像睡著了一般抡秆。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上吟策,一...
    開封第一講書人閱讀 49,821評(píng)論 1 290
  • 那天儒士,我揣著相機(jī)與錄音,去河邊找鬼檩坚。 笑死着撩,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的匾委。 我是一名探鬼主播拖叙,決...
    沈念sama閱讀 38,960評(píng)論 3 408
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼剩檀!你這毒婦竟也來了憋沿?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 37,719評(píng)論 0 266
  • 序言:老撾萬榮一對(duì)情侶失蹤沪猴,失蹤者是張志新(化名)和其女友劉穎辐啄,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體运嗜,經(jīng)...
    沈念sama閱讀 44,186評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡壶辜,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,516評(píng)論 2 327
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了担租。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片砸民。...
    茶點(diǎn)故事閱讀 38,650評(píng)論 1 340
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖奋救,靈堂內(nèi)的尸體忽然破棺而出岭参,到底是詐尸還是另有隱情,我是刑警寧澤尝艘,帶...
    沈念sama閱讀 34,329評(píng)論 4 330
  • 正文 年R本政府宣布演侯,位于F島的核電站,受9級(jí)特大地震影響背亥,放射性物質(zhì)發(fā)生泄漏秒际。R本人自食惡果不足惜悬赏,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,936評(píng)論 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望娄徊。 院中可真熱鬧闽颇,春花似錦、人聲如沸寄锐。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,757評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽锐峭。三九已至中鼠,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間沿癞,已是汗流浹背援雇。 一陣腳步聲響...
    開封第一講書人閱讀 31,991評(píng)論 1 266
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留椎扬,地道東北人惫搏。 一個(gè)月前我還...
    沈念sama閱讀 46,370評(píng)論 2 360
  • 正文 我出身青樓,卻偏偏與公主長得像蚕涤,于是被迫代替她去往敵國和親筐赔。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,527評(píng)論 2 349