1. 程式人生 > >Curator之nodeCache一次註冊,N次監聽

Curator之nodeCache一次註冊,N次監聽

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);
            }
        });

在這裡插入圖片描述在這裡插入圖片描述