Curator之nodeCache一次註冊,N次監聽
阿新 • • 發佈:2018-11-01
Curator之nodeCache一次註冊,N次監聽
/*Curator之nodeCache一次註冊,N次監聽*/ //為節點新增watcher //監聽資料節點的變更,會觸發事件 final NodeCache nodeCache = new NodeCache(cto.client,nodePath); //buildInitial: 初始化的時候獲取node的值並且快取 nodeCache.start(true); if(nodeCache.getCurrentData() != null){ System.out.println("節點的初始化資料為:"+new String(nodeCache.getCurrentData().getData())); }else{ System.out.println("節點初始化資料為空。。。"); } nodeCache.getListenable().addListener(new NodeCacheListener() { public void nodeChanged() throws Exception { //獲取當前資料 String data = new String(nodeCache.getCurrentData().getData()); System.out.println("節點路徑為:"+nodeCache.getCurrentData().getPath()+" 資料: "+data); } });