2023學(xué)年完整公開課版zookeeper監(jiān)聽事件

Zookeeper監(jiān)聽事件2知識目標(biāo)Zookeeper依賴創(chuàng)建一次、永久監(jiān)聽監(jiān)聽子節(jié)點01能力目標(biāo)了解依賴包掌握監(jiān)聽方法明白子節(jié)點的監(jiān)聽02學(xué)習(xí)目標(biāo)3目錄01Zookeeper的依賴包02創(chuàng)建一次監(jiān)聽03創(chuàng)建永久監(jiān)聽04監(jiān)聽子節(jié)點Zookeeper的依賴包4Curator是Netflix公司開源的一個Zookeeper客戶端，目前由Apache進行維護。與Zookeeper原生客戶端相比，Curator的抽象層次更高，功能也更加豐富，是目前Zookeeper使用范圍最廣的Java客戶端。本篇文章主要講解其基本使用，項目采用Maven構(gòu)建，以單元測試的方法進行講解，相關(guān)依賴如下：

Zookeeper的依賴包5<dependencies><!--Curator相關(guān)依賴--><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.0.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.0.0</version>Zookeeper的依賴包6</dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.13</version></dependency><!--單元測試相關(guān)依賴--><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency></dependencies>創(chuàng)建一次監(jiān)聽7

和

Zookeeper原生監(jiān)聽一樣，使用

usingWatcher

注冊的監(jiān)聽是一次性的，即監(jiān)聽只會觸發(fā)一次，觸發(fā)后就銷毀。示例如下：

@TestpublicvoidDisposableWatch()throwsException{client.getData().usingWatcher(newCuratorWatcher(){publicvoidprocess(WatchedEventevent){System.out.println("節(jié)點"+event.getPath()+"發(fā)生了事件:"+event.getType());}}).forPath(nodePath);Thread.sleep(1000*1000);//休眠以觀察測試效果}創(chuàng)建永久監(jiān)聽8Curator還提供了創(chuàng)建永久監(jiān)聽的API，其使用方式如下：publicvoidpermanentWatch()throwsException{//使用NodeCache包裝節(jié)點，對其注冊的監(jiān)聽作用于節(jié)點，且是永久性的NodeCachenodeCache=newNodeCache(client,nodePath);//通常設(shè)置為true,代表創(chuàng)建nodeCache時,就去獲取對應(yīng)節(jié)點的值并緩存nodeCache.start(true);創(chuàng)建永久監(jiān)聽9

nodeCache.getListenable().addListener(newNodeCacheListener(){publicvoidnodeChanged(){ChildDatacurrentData=nodeCache.getCurrentData();if(currentData!=null){System.out.println("節(jié)點路徑："+currentData.getPath()+"數(shù)據(jù)："+newString(currentData.getData()));}}});Thread.sleep(1000*1000);//休眠以觀察測試效果}監(jiān)聽子節(jié)點10這里以監(jiān)聽

/hadoop

下所有子節(jié)點為例，實現(xiàn)方式如下：@TestpublicvoidpermanentChildrenNodesWatch()throwsException{//第三個參數(shù)代表除了節(jié)點狀態(tài)外，是否還緩存節(jié)點內(nèi)容PathChildrenCachechildrenCache=newPathChildrenCache(client,"/hadoop",true);/**StartMode代表初始化方式:*NORMAL:異步初始化*BUILD_INITIAL_CACHE:同步初始化*POST_INITIALIZED_EVENT:異步并通知,初始化之后會觸發(fā)INITIALIZED事件監(jiān)聽子節(jié)點11

childrenCache.start(StartMode.POST_INITIALIZED_EVENT);

List<ChildData>childDataList=childrenCache.getCurrentData();

System.out.println("當(dāng)前數(shù)據(jù)節(jié)點的子節(jié)點列表：");childDataList.forEach(x->System.out.println(x.getPath()));

childrenCache.getListenable().addListener(newPathChildrenCacheListener(){publicvoidchildEvent(CuratorFrameworkclient,監(jiān)聽子節(jié)點12PathChildrenCacheEventevent){switch(event.getType()){caseINITIALIZED:System.out.println("childrenCache初始化完成");break;caseCHILD_ADDED://需要注意的是:即使是之前已經(jīng)存在的子節(jié)點，也會觸發(fā)該監(jiān)聽，因為會把該子節(jié)點加入childrenCache緩存中System.out.println("增加子節(jié)點:"+event.getData().getPath());break;監(jiān)聽子節(jié)點13System.out.println("修改后的數(shù)據(jù):"+newString(event.getData().getData()));break;}}});Thread.sleep(1000*1000);//休眠以觀察測試效果}

caseCHILD_REMOVED:System.out.pr