1.watcher方式一（監(jiān)聽當前節(jié)點發(fā)生變更）

成都創(chuàng)新互聯一直通過網站建設和網站營銷幫助企業(yè)獲得更多客戶資源。 以"深度挖掘，量身打造，注重實效"的一站式服務，以成都網站建設、網站建設、移動互聯產品、全網整合營銷推廣服務為核心業(yè)務。十多年網站制作的經驗，使用新網站建設技術，全新開發(fā)出的標準網站，不但價格便宜而且實用、靈活，特別適合中小公司網站制作。網站管理系統(tǒng)簡單易用，維護方便，您可以完全操作網站資料，是中小公司快速網站建設的選擇。

		String address = "mini1:2181,mini2:2181,mini3:2181";
		 RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 10);
		 
		CuratorFramework client = CuratorFrameworkFactory.newClient(address, new ExponentialBackoffRetry(1000, 3));
		
		client.start();
		
		//創(chuàng)建節(jié)點watcher監(jiān)聽
		 final NodeCache cache = new NodeCache(client, "/super", false);
		 cache.start(true);
		 cache.getListenable().addListener(new NodeCacheListener() {
			
			public void nodeChanged() throws Exception {
				System.out.println(cache.getCurrentData().getPath());
				System.out.println(cache.getCurrentData().getStat());
			}
		});

2.watcher方式二（監(jiān)聽當前節(jié)點的子節(jié)點發(fā)生變更）

		String address = "mini1:2181,mini2:2181,mini3:2181";
		 RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 10);
		 
		CuratorFramework client = CuratorFrameworkFactory.newClient(address, new ExponentialBackoffRetry(1000, 3));
		
		client.start();
	
		//創(chuàng)建子節(jié)點watcher監(jiān)聽
		 PathChildrenCache cache = new PathChildrenCache(client, "/super", true);
		 cache.start(StartMode.POST_INITIALIZED_EVENT);
		 cache.getListenable().addListener(new PathChildrenCacheListener() {
			public void childEvent(CuratorFramework cf, PathChildrenCacheEvent event) throws Exception {
				System.out.println(event.getType());
			}
		});
		 Thread.sleep(Long.MAX_VALUE);

網頁名稱：Curator教程（一）watcher監(jiān)聽
文章地址：http://jinyejixie.com/article8/ppjeop.html

成都網站建設公司_創(chuàng)新互聯，為您提供關鍵詞優(yōu)化、網站制作、外貿建站、網站維護、域名注冊、手機網站建設

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯