更新時(shí)間:2020-11-03 來(lái)源:黑馬程序員 瀏覽量:
ZooKeeper提供了分布式數(shù)據(jù)發(fā)布/訂閱功能,一個(gè)典型的發(fā)布/訂閱模型系統(tǒng)定義了一種一對(duì)多的訂閱關(guān)系,能讓多個(gè)訂閱者同時(shí)監(jiān)聽(tīng)某一個(gè)主題對(duì)象,當(dāng)這個(gè)主題對(duì)象自身狀態(tài)變化時(shí),會(huì)通知所有訂閱者,使他們能夠做出相應(yīng)的處理。
在ZooKeeper中,引入了Watch機(jī)制來(lái)實(shí)現(xiàn)這種分布式的通知功能。ZooKeeper允許客戶端向服務(wù)端注冊(cè)一個(gè)Watch監(jiān)聽(tīng),當(dāng)服務(wù)端的一些事件觸發(fā)了這個(gè)Watch,那么就會(huì)向指定客戶端發(fā)送一個(gè)事件通知,來(lái)實(shí)現(xiàn)分布式的通知功能。
Watch機(jī)制在事件中有以下4個(gè)特點(diǎn):
1.一次性觸發(fā)
當(dāng)Watch的對(duì)象發(fā)生改變時(shí),將會(huì)觸發(fā)此對(duì)象上Watch所對(duì)應(yīng)的事件,這種監(jiān)聽(tīng)是一次性的,后續(xù)再次發(fā)生同樣的事件,也不會(huì)再次觸發(fā)。
2.事件封裝
Zookeeper使用WatchedEvent對(duì)象來(lái)封裝服務(wù)端事件并傳遞。該對(duì)象包含了每個(gè)事件的三個(gè)基本屬性,即通知狀態(tài)(keeperState)、事件類(lèi)型(EventType)和節(jié)點(diǎn)路徑(path)。
3.異步發(fā)送
Watch的通知事件是從服務(wù)端異步發(fā)送到客戶端的。
4.先注冊(cè)再觸發(fā)
Zookeeper中的Watch機(jī)制,必須由客戶端先去服務(wù)端注冊(cè)監(jiān)聽(tīng),這樣才會(huì)觸發(fā)事件的監(jiān)聽(tīng),并通知給客戶端。
猜你喜歡:
虛擬機(jī)安裝教程:同一臺(tái)電腦上構(gòu)建多個(gè)Linux虛擬機(jī)環(huán)境
Znode儲(chǔ)存結(jié)構(gòu)是怎樣的?節(jié)點(diǎn)類(lèi)型有哪幾種?
2020-11-03YARN資源管理框架的體系結(jié)構(gòu)【大數(shù)據(jù)文章】
2020-11-03Zookeeper集群中的三種角色簡(jiǎn)單介紹
2020-11-03Spark的集群安裝部署【大數(shù)據(jù)技術(shù)文章】
2020-10-29Spark有哪些特點(diǎn),Spark的生態(tài)系統(tǒng)包含哪些組件?
2020-10-28Scala是什么?Scala發(fā)展歷程簡(jiǎn)介
2020-10-28