更新時間:2024年01月12日09時53分 來源:傳智教育 瀏覽次數(shù):
Zookeeper提供了分布式數(shù)據(jù)發(fā)布/訂閱功能,一個典型的發(fā)布/訂閱模型系統(tǒng)定義了一種一對多的訂閱關(guān)系,能讓多個訂閱者同時監(jiān)聽某一個主題對象,當(dāng)這個主題對象自身狀態(tài)變化時,會通知所有訂閱者,使他們能夠做出相應(yīng)的處理。
在ZooKeeper中,引入了Watch機(jī)制來實(shí)現(xiàn)這種分布式的通知功能。ZooKeeper允許客戶端向服務(wù)端注冊一個Watch監(jiān)聽,當(dāng)服務(wù)端的一些事件觸發(fā)了這個Watch,那么就會向指定客戶端發(fā)送一個事件通知,來實(shí)現(xiàn)分布式的通知功能。
Watch機(jī)制的特點(diǎn)如下:
當(dāng)Watch的對象發(fā)生改變時,將會觸發(fā)此對象上Watch所對應(yīng)的事件,這種監(jiān)聽是一次性的,后續(xù)再次發(fā)生同樣的事件,也不會再次觸發(fā)。
Zookeeper使用WatchedEvent對象來封裝服務(wù)端事件并傳遞。該對象包含了每個事件的3個基本屬性,即通知狀態(tài)(keeperState)、事件類型(EventType)和節(jié)點(diǎn)路徑(path)。
Watch的通知事件是從服務(wù)端異步發(fā)送到客戶端的。
Zookeeper中的Watch機(jī)制,必須由客戶端先去服務(wù)端注冊監(jiān)聽,這樣才會觸發(fā)事件的監(jiān)聽,并通知給客戶端。