發(fā)現(xiàn)分布式工具，誰(shuí)都不能缺了zookeeper，雖然此前筆者在http://blog.csdn.net/fjssharpsword/article/details/50884201博客中略有了解，但總感覺(jué)意猶未盡，這里重點(diǎn)理解下zookeeper的應(yīng)用場(chǎng)景。

1、Zookeeper部署和安裝，參考官網(wǎng)就可以。

? ? ??http://zookeeper.apache.org/doc/current/zookeeperStarted.html

2、Zookeeper的數(shù)據(jù)模型

??

Zookeeper 會(huì)維護(hù)一個(gè)具有層次關(guān)系的數(shù)據(jù)結(jié)構(gòu)，它非常類似于一個(gè)標(biāo)準(zhǔn)的文件系統(tǒng)，如下圖：

?Zookeeper 數(shù)據(jù)結(jié)構(gòu)

Zookeeper 這種數(shù)據(jù)結(jié)構(gòu)有如下這些特點(diǎn)：
1）每個(gè)子目錄項(xiàng)如 NameService 都被稱作為 znode，這個(gè) znode 是被它所在的路徑唯一標(biāo)識(shí)，如 Server1 這個(gè) znode 的標(biāo)識(shí)為 /NameService/Server1；
2）znode 可以有子節(jié)點(diǎn)目錄，并且每個(gè) znode 可以存儲(chǔ)數(shù)據(jù)，注意 EPHEMERAL 類型的目錄節(jié)點(diǎn)不能有子節(jié)點(diǎn)目錄；
3）znode 是有版本的，每個(gè) znode 中存儲(chǔ)的數(shù)據(jù)可以有多個(gè)版本，也就是一個(gè)訪問(wèn)路徑中可以存儲(chǔ)多份數(shù)據(jù)；
4）znode 可以是臨時(shí)節(jié)點(diǎn)，一旦創(chuàng)建這個(gè) znode 的客戶端與服務(wù)器失去聯(lián)系，這個(gè) znode 也將自動(dòng)刪除，Zookeeper 的客戶端和服務(wù)器通信采用長(zhǎng)連接方式，每個(gè)客戶端和服務(wù)器通過(guò)心跳來(lái)保持連接，這個(gè)連接狀態(tài)稱為 session，如果 znode 是臨時(shí)節(jié)點(diǎn)，這個(gè) session 失效，znode 也就刪除了；
5）znode 的目錄名可以自動(dòng)編號(hào)，如 App1 已經(jīng)存在，再創(chuàng)建的話，將會(huì)自動(dòng)命名為 App2；
6）znode 可以被監(jiān)控，包括這個(gè)目錄節(jié)點(diǎn)中存儲(chǔ)的數(shù)據(jù)的修改，子節(jié)點(diǎn)目錄的變化等，一旦變化可以通知設(shè)置監(jiān)控的客戶端，這個(gè)是 Zookeeper 的核心特性，Zookeeper 的很多功能都是基于這個(gè)特性實(shí)現(xiàn)的，后面在典型的應(yīng)用場(chǎng)景中會(huì)有實(shí)例介紹；

正是基于這個(gè)數(shù)據(jù)結(jié)構(gòu)的特性，Zookeeper作為一個(gè)分布式的服務(wù)框架，可用來(lái)解決分布式集群中應(yīng)用系統(tǒng)的一致性問(wèn)題，它能提供基于類似于文件系統(tǒng)的目錄節(jié)點(diǎn)樹(shù)方式的數(shù)據(jù)存儲(chǔ)，當(dāng)然 Zookeeper 并不是用來(lái)專門存儲(chǔ)數(shù)據(jù)的，它的主要作用是用來(lái)維護(hù)和監(jiān)控你存儲(chǔ)的數(shù)據(jù)的狀態(tài)變化。通過(guò)監(jiān)控這些數(shù)據(jù)狀態(tài)的變化，從而可以達(dá)到基于數(shù)據(jù)的集群管理。

3、Zookeeper機(jī)制

1）數(shù)據(jù)發(fā)布與訂閱?
應(yīng)用配置集中到節(jié)點(diǎn)上，應(yīng)用啟動(dòng)時(shí)主動(dòng)獲取，并在節(jié)點(diǎn)上注冊(cè)一個(gè)watcher，每次配置更新都會(huì)通知到應(yīng)用。

2）名空間服務(wù)
分布式命名服務(wù)，創(chuàng)建一個(gè)節(jié)點(diǎn)后，節(jié)點(diǎn)的路徑就是全局唯一的，可以作為全局名稱使用。

3）分布式通知/協(xié)調(diào)
不同的系統(tǒng)都監(jiān)聽(tīng)同一個(gè)節(jié)點(diǎn)，一旦有了更新，另一個(gè)系統(tǒng)能夠收到通知。

4）分布式鎖
Zookeeper能保證數(shù)據(jù)的強(qiáng)一致性，用戶任何時(shí)候都可以相信集群中每個(gè)節(jié)點(diǎn)的數(shù)據(jù)都是相同的。一個(gè)用戶創(chuàng)建一個(gè)節(jié)點(diǎn)作為鎖，另一個(gè)用戶檢測(cè)該節(jié)點(diǎn)，如果存在，代表別的用戶已經(jīng)鎖住，如果不存在，則可以創(chuàng)建一個(gè)節(jié)點(diǎn)，代表?yè)碛幸粋€(gè)鎖。

5）集群管理
每個(gè)加入集群的機(jī)器都創(chuàng)建一個(gè)節(jié)點(diǎn)，寫入自己的狀態(tài)。監(jiān)控父節(jié)點(diǎn)的用戶會(huì)受到通知，進(jìn)行相應(yīng)的處理。離開(kāi)時(shí)刪除節(jié)點(diǎn)，監(jiān)控父節(jié)點(diǎn)的用戶同樣會(huì)收到通知。

Zookeeper 從設(shè)計(jì)模式角度來(lái)看，是一個(gè)基于觀察者模式設(shè)計(jì)的分布式服務(wù)管理框架，它負(fù)責(zé)存儲(chǔ)和管理大家都關(guān)心的數(shù)據(jù)，然后接受觀察者的注冊(cè)，一旦這些數(shù)據(jù)的狀態(tài)發(fā)生變化，Zookeeper 就將負(fù)責(zé)通知已經(jīng)在 Zookeeper 上注冊(cè)的那些觀察者做出相應(yīng)的反應(yīng)，從而實(shí)現(xiàn)集群中類似 Master/Slave 管理模式。從一個(gè)直觀感覺(jué)上說(shuō)，這是一個(gè)分布式集群的管理工具，通過(guò)什么來(lái)管理呢？就是它的數(shù)據(jù)結(jié)構(gòu)和機(jī)制。

4、Zookeeper的應(yīng)用場(chǎng)景

1）統(tǒng)一命名服務(wù)（Name Service）
分布式應(yīng)用中，通常需要有一套完整的命名規(guī)則，既能夠產(chǎn)生唯一的名稱又便于人識(shí)別和記住，通常情況下用樹(shù)形的名稱結(jié)構(gòu)是一個(gè)理想的選擇，樹(shù)形的名稱結(jié)構(gòu)是一個(gè)有層次的目錄結(jié)構(gòu)，既對(duì)人友好又不會(huì)重復(fù)。說(shuō)到這里你可能想到了 JNDI，沒(méi)錯(cuò) Zookeeper 的 Name Service 與 JNDI 能夠完成的功能是差不多的，它們都是將有層次的目錄結(jié)構(gòu)關(guān)聯(lián)到一定資源上，但是 Zookeeper 的 Name Service 更加是廣泛意義上的關(guān)聯(lián)，也許你并不需要將名稱關(guān)聯(lián)到特定資源上，你可能只需要一個(gè)不會(huì)重復(fù)名稱，就像數(shù)據(jù)庫(kù)中產(chǎn)生一個(gè)唯一的數(shù)字主鍵一樣。
Name Service 已經(jīng)是 Zookeeper 內(nèi)置的功能，你只要調(diào)用 Zookeeper 的 API 就能實(shí)現(xiàn)。如調(diào)用 create 接口就可以很容易創(chuàng)建一個(gè)目錄節(jié)點(diǎn)。

2）配置管理（Configuration Management）
配置的管理在分布式應(yīng)用環(huán)境中很常見(jiàn)，例如同一個(gè)應(yīng)用系統(tǒng)需要多臺(tái) PC Server 運(yùn)行，但是它們運(yùn)行的應(yīng)用系統(tǒng)的某些配置項(xiàng)是相同的，如果要修改這些相同的配置項(xiàng)，那么就必須同時(shí)修改每臺(tái)運(yùn)行這個(gè)應(yīng)用系統(tǒng)的 PC Server，這樣非常麻煩而且容易出錯(cuò)。
像這樣的配置信息完全可以交給 Zookeeper 來(lái)管理，將配置信息保存在 Zookeeper 的某個(gè)目錄節(jié)點(diǎn)中，然后將所有需要修改的應(yīng)用機(jī)器監(jiān)控配置信息的狀態(tài)，一旦配置信息發(fā)生變化，每臺(tái)應(yīng)用機(jī)器就會(huì)收到 Zookeeper 的通知，然后從 Zookeeper 獲取新的配置信息應(yīng)用到系統(tǒng)中。

配置管理結(jié)構(gòu)圖

3）集群管理（Group Membership）
Zookeeper 能夠很容易的實(shí)現(xiàn)集群管理的功能，如有多臺(tái) Server 組成一個(gè)服務(wù)集群，那么必須要一個(gè)“總管”知道當(dāng)前集群中每臺(tái)機(jī)器的服務(wù)狀態(tài)，一旦有機(jī)器不能提供服務(wù)，集群中其它集群必須知道，從而做出調(diào)整重新分配服務(wù)策略。同樣當(dāng)增加集群的服務(wù)能力時(shí)，就會(huì)增加一臺(tái)或多臺(tái) Server，同樣也必須讓“總管”知道。
Zookeeper 不僅能夠幫你維護(hù)當(dāng)前的集群中機(jī)器的服務(wù)狀態(tài)，而且能夠幫你選出一個(gè)“總管”，讓這個(gè)總管來(lái)管理集群，這就是 Zookeeper 的另一個(gè)功能 Leader Election。
它們的實(shí)現(xiàn)方式都是在 Zookeeper 上創(chuàng)建一個(gè) EPHEMERAL 類型的目錄節(jié)點(diǎn)，然后每個(gè) Server 在它們創(chuàng)建目錄節(jié)點(diǎn)的父目錄節(jié)點(diǎn)上調(diào)用 getChildren(String path, boolean watch) 方法并設(shè)置 watch 為 true，由于是 EPHEMERAL 目錄節(jié)點(diǎn)，當(dāng)創(chuàng)建它的 Server 死去，這個(gè)目錄節(jié)點(diǎn)也隨之被刪除，所以 Children 將會(huì)變化，這時(shí) getChildren上的 Watch 將會(huì)被調(diào)用，所以其它 Server 就知道已經(jīng)有某臺(tái) Server 死去了。新增 Server 也是同樣的原理。
Zookeeper 如何實(shí)現(xiàn) Leader Election，也就是選出一個(gè) Master Server。和前面的一樣每臺(tái) Server 創(chuàng)建一個(gè) EPHEMERAL 目錄節(jié)點(diǎn)，不同的是它還是一個(gè) SEQUENTIAL 目錄節(jié)點(diǎn)，所以它是個(gè) EPHEMERAL_SEQUENTIAL 目錄節(jié)點(diǎn)。之所以它是 EPHEMERAL_SEQUENTIAL 目錄節(jié)點(diǎn)，是因?yàn)槲覀兛梢越o每臺(tái) Server 編號(hào)，我們可以選擇當(dāng)前是最小編號(hào)的 Server 為 Master，假如這個(gè)最小編號(hào)的 Server 死去，由于是 EPHEMERAL 節(jié)點(diǎn)，死去的 Server 對(duì)應(yīng)的節(jié)點(diǎn)也被刪除，所以當(dāng)前的節(jié)點(diǎn)列表中又出現(xiàn)一個(gè)最小編號(hào)的節(jié)點(diǎn)，我們就選擇這個(gè)節(jié)點(diǎn)為當(dāng)前 Master。這樣就實(shí)現(xiàn)了動(dòng)態(tài)選擇 Master，避免了傳統(tǒng)意義上單 Master 容易出現(xiàn)單點(diǎn)故障的問(wèn)題。

集群管理結(jié)構(gòu)圖

4）共享鎖（Locks）
共享鎖在同一個(gè)進(jìn)程中很容易實(shí)現(xiàn)，但是在跨進(jìn)程或者在不同 Server 之間就不好實(shí)現(xiàn)了。Zookeeper 卻很容易實(shí)現(xiàn)這個(gè)功能，實(shí)現(xiàn)方式也是需要獲得鎖的 Server 創(chuàng)建一個(gè) EPHEMERAL_SEQUENTIAL 目錄節(jié)點(diǎn)，然后調(diào)用 getChildren方法獲取當(dāng)前的目錄節(jié)點(diǎn)列表中最小的目錄節(jié)點(diǎn)是不是就是自己創(chuàng)建的目錄節(jié)點(diǎn)，如果正是自己創(chuàng)建的，那么它就獲得了這個(gè)鎖，如果不是那么它就調(diào)用 exists(String path, boolean watch) 方法并監(jiān)控 Zookeeper 上目錄節(jié)點(diǎn)列表的變化，一直到自己創(chuàng)建的節(jié)點(diǎn)是列表中最小編號(hào)的目錄節(jié)點(diǎn)，從而獲得鎖，釋放鎖很簡(jiǎn)單，只要?jiǎng)h除前面它自己所創(chuàng)建的目錄節(jié)點(diǎn)就行了。

Zookeeper 實(shí)現(xiàn) Locks 的流程圖

5）隊(duì)列管理
Zookeeper 可以處理兩種類型的隊(duì)列：
當(dāng)一個(gè)隊(duì)列的成員都聚齊時(shí)，這個(gè)隊(duì)列才可用，否則一直等待所有成員到達(dá)，這種是同步隊(duì)列。
隊(duì)列按照 FIFO 方式進(jìn)行入隊(duì)和出隊(duì)操作，例如實(shí)現(xiàn)生產(chǎn)者和消費(fèi)者模型。
同步隊(duì)列用 Zookeeper 實(shí)現(xiàn)的實(shí)現(xiàn)思路如下：
創(chuàng)建一個(gè)父目錄 /synchronizing，每個(gè)成員都監(jiān)控標(biāo)志（Set Watch）位目錄 /synchronizing/start 是否存在，然后每個(gè)成員都加入這個(gè)隊(duì)列，加入隊(duì)列的方式就是創(chuàng)建 /synchronizing/member_i 的臨時(shí)目錄節(jié)點(diǎn)，然后每個(gè)成員獲取 / synchronizing 目錄的所有目錄節(jié)點(diǎn)，也就是 member_i。判斷 i 的值是否已經(jīng)是成員的個(gè)數(shù)，如果小于成員個(gè)數(shù)等待 /synchronizing/start 的出現(xiàn)，如果已經(jīng)相等就創(chuàng)建 /synchronizing/start。
用下面的流程圖更容易理解：

同步隊(duì)列流程圖

FIFO 隊(duì)列用 Zookeeper 實(shí)現(xiàn)思路如下：
實(shí)現(xiàn)的思路也非常簡(jiǎn)單，就是在特定的目錄下創(chuàng)建 SEQUENTIAL 類型的子目錄 /queue_i，這樣就能保證所有成員加入隊(duì)列時(shí)都是有編號(hào)的，出隊(duì)列時(shí)通過(guò) getChildren( ) 方法可以返回當(dāng)前所有的隊(duì)列中的元素，然后消費(fèi)其中最小的一個(gè)，這樣就能保證 FIFO。

5、總結(jié)

?Zoopkeeper 提供了一套分布式集群管理的機(jī)制，基于層次型的目錄樹(shù)的數(shù)據(jù)結(jié)構(gòu)，并對(duì)樹(shù)中的節(jié)點(diǎn)進(jìn)行有效管理，從而可以設(shè)計(jì)出多種多樣的分布式的數(shù)據(jù)管理模型。這種數(shù)據(jù)結(jié)構(gòu)及其機(jī)制是實(shí)現(xiàn)分布式集群管理的基礎(chǔ)，自然在這個(gè)之上還有很多的應(yīng)用場(chǎng)合和想象空間。在分布式生產(chǎn)環(huán)境中，資源的最大化和各項(xiàng)工作的步調(diào)一致是很重要，需要Zookeeper這種工具的參與。

總結(jié)

以上是生活随笔為你收集整理的Zookeeper应用场景理解的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。