zookeeperwatch機制的理解-創(chuàng)新互聯(lián)

首先我們看看為什么添加Watch。

創(chuàng)新互聯(lián)不只是一家網(wǎng)站建設的網(wǎng)絡公司；我們對營銷、技術(shù)、服務都有自己獨特見解，公司采取“創(chuàng)意+綜合+營銷”一體化的方式為您提供更專業(yè)的服務！我們經(jīng)歷的每一步也許不一定是最完美的，但每一步都有值得深思的意義。我們珍視每一份信任，關(guān)注我們的網(wǎng)站制作、做網(wǎng)站質(zhì)量和服務品質(zhì)，在得到用戶滿意的同時，也能得到同行業(yè)的專業(yè)認可，能夠為行業(yè)創(chuàng)新發(fā)展助力。未來將繼續(xù)專注于技術(shù)創(chuàng)新，服務升級，滿足企業(yè)一站式營銷型網(wǎng)站建設需求，讓再小的高端網(wǎng)站設計也能產(chǎn)生價值！

ZooKeeper是用來協(xié)調(diào)（同步）分布式進程的服務，提供了一個簡單高性能的協(xié)調(diào)內(nèi)核，用戶可以在此之上構(gòu)建更多復雜的分布式協(xié)調(diào)功能。

多個分布式進程通過ZooKeeper提供的 API 來操作共享的ZooKeeper內(nèi)存數(shù)據(jù)對象ZNode來達成某種一致的行為或結(jié)果，這種模式本質(zhì)上是基于狀態(tài)共享的并發(fā)模型，與Java的多線程并發(fā)模型一致，他們的線程或進程都是“共享式內(nèi)存通信”。Java沒有直接提供某種響應式通知接口來監(jiān)控某個對象狀態(tài)的變化，只能要么浪費CPU時間毫無響應式的輪詢重試，或基于Java提供的某種主動通知（Notif）機制（內(nèi)置隊列）來響應狀態(tài)變化，但這種機制是需要循環(huán)阻塞調(diào)用。而ZooKeeper實現(xiàn)這些分布式進程的狀態(tài)（ZNode的Data、Children）共享時，基于性能的考慮采用了類似的異步非阻塞的主動通知模式即Watch機制，使得分布式進程之間的“共享狀態(tài)通信”更加實時高效，其實這也是ZooKeeper的主要任務決定的—協(xié)調(diào)。

所有的Zookeeper讀操作，包括getData()、getChildren()和exists()，都有一個開關(guān)，可以在操作的同時再設置一個watch。在ZooKeeper中，Watch是一個一次性觸發(fā)器，會在被設置watch的數(shù)據(jù)發(fā)生變化的時候，發(fā)送給設置watch的客戶端。watch的定義中有三個關(guān)鍵點：

一次性觸發(fā)器

一個watch事件將會在數(shù)據(jù)發(fā)生變更時發(fā)送給客戶端。例如，如果客戶端執(zhí)行操作getData(“/znode1″, true)，而后/znode1 發(fā)生變更或是刪除了，客戶端都會得到一個/znode1 的watch事件。如果/znode1 再次發(fā)生變更，則在客戶端沒有設置新的watch的情況下，是不會再給這個客戶端發(fā)送watch事件的。

發(fā)送給客戶端

這就是說，一個事件會發(fā)送給客戶端，但可能在操作成功的返回值到達發(fā)起變動的客戶端之前，這個事件還沒有送達watch的客戶端。Watch是異步發(fā)送的。但ZooKeeper保證了一個順序：一個客戶端在收到watch事件之前，一定不會看到它設置過watch的值的變動。網(wǎng)絡時延和其他因素可能會導致不同的客戶端看到watch和更新返回值的時間不同。但關(guān)鍵點是，每個客戶端所看到的每件事都是有順序的。

被設置了watch的數(shù)據(jù)

這是指節(jié)點發(fā)生變動的不同方式。你可以認為ZooKeeper維護了兩個watch列表：data watch和child watch。getData()和exists()設置data watch，而getChildren()設置child watch?；蛘?，可以認為watch是根據(jù)返回值設置的。getData()和exists()返回節(jié)點本身的信息，而getChildren()返回子節(jié)點的列表。因此，setData()會觸發(fā)znode上設置的data watch（如果set成功的話）。一個成功的?create() 操作會觸發(fā)被創(chuàng)建的znode上的數(shù)據(jù)watch，以及其父節(jié)點上的child watch。而一個成功的?delete()操作將會同時觸發(fā)一個znode的data watch和child watch（因為這樣就沒有子節(jié)點了），同時也會觸發(fā)其父節(jié)點的child watch。

Watch由client連接上的ZooKeeper服務器在本地維護。這樣可以減小設置、維護和分發(fā)watch的開銷。當一個客戶端連接到一個新的服務器上時，watch將會被以任意會話事件觸發(fā)。當與一個服務器失去連接的時候，是無法接收到watch的。而當client重新連接時，如果需要的話，所有先前注冊過的watch，都會被重新注冊。通常這是完全透明的。只有在一個特殊情況下，watch可能會丟失：對于一個未創(chuàng)建的znode的exist watch，如果在客戶端斷開連接期間被創(chuàng)建了，并且隨后在客戶端連接上之前又刪除了，這種情況下，這個watch事件可能會被丟失。?

ZooKeeper對Watch提供了什么保障

對于watch，ZooKeeper提供了這些保障：

Watch與其他事件、其他watch以及異步回復都是有序的。ZooKeeper客戶端庫保證所有事件都會按順序分發(fā)；客戶端會保障它在看到相應的znode的新數(shù)據(jù)之前接收到watch事件；從ZooKeeper接收到的watch事件順序一定和ZooKeeper服務所看到的事件順序是一致的。

關(guān)于Watch的一些值得注意的事情

Watch是一次性觸發(fā)器，如果你得到了一個watch事件，而你希望在以后發(fā)生變更時繼續(xù)得到通知，你應該再設置一個watch。
因為watch是一次性觸發(fā)器，而獲得事件再發(fā)送一個新的設置watch的請求這一過程會有延時，所以你無法確保你看到了所有發(fā)生在ZooKeeper上的一個節(jié)點上的事件。所以請?zhí)幚砗迷谶@個時間窗口中可能會發(fā)生多次znode變更的這種情況。（你可以不處理，但至少請認識到這一點）。

一個watch對象或一個函數(shù)/上下文對，為一個事件只會被通知一次。比如，如果同一個watch對象在同一個文件上分別通過exists和getData注冊了兩次，而這個文件之后被刪除了，這時這個watch對象將只會收到一次該文件的deletion通知。

當你從一個服務器上斷開時（比如服務器出故障了），在再次連接上之前，你將無法獲得任何watch。請使用這些會話事件來進入安全模式：在disconnected狀態(tài)下你將不會收到事件，所以你的程序在此期間應該謹慎行事。

總結(jié)

以上就是本文關(guān)于zookeeper watch機制的全部介紹，有興趣的朋友可以參閱：為zookeeper配置相應的acl權(quán)限、apache zookeeper使用方法實例詳解等，希望對大家有所幫助。

本文題目：zookeeperwatch機制的理解-創(chuàng)新互聯(lián)
本文網(wǎng)址：http://muchs.cn/article48/ihoep.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供移動網(wǎng)站建設、App設計、品牌網(wǎng)站制作、服務器托管、網(wǎng)站設計、Google

廣告

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