分布式隊(duì)列

• 接觸到不少分布式隊(duì)列的產(chǎn)品，比如，ActiveMq，RocketMQ，kafka等消息中間價(jià)，現(xiàn)在我們看看Zookeeper實(shí)現(xiàn)的分布式隊(duì)列。
• 分布式隊(duì)列簡(jiǎn)單講就可以分兩個(gè)部分，一種是先進(jìn)先出，另外一種是等所有元素都到齊都會(huì)統(tǒng)一執(zhí)行的Barrier模型

FIFO先入先出

• FIFO（First in First out,先入先出）的算法思想在計(jì)算機(jī)里面用的比較多，比如隊(duì)列里面，先進(jìn)入的能先執(zhí)行，在Zookeeper的實(shí)現(xiàn)中，FIFO類似一個(gè)共享鎖模型，所有客戶端在節(jié)點(diǎn)/queue_fifo下創(chuàng)建臨時(shí)節(jié)點(diǎn)/queue_fifo/192.168.1.1/1-00000001，/queue_fifo/192.168.1.1/1-00000002，/queue_fifo/192.168.1.1/1-00000003，依次安id遞增的關(guān)系創(chuàng)建，創(chuàng)建后依據(jù)以下幾個(gè)步驟
• 通過getChildren接口獲取/queue_fifo下所有子節(jié)點(diǎn)
• 確認(rèn)字節(jié)的節(jié)點(diǎn)序號(hào)在所有子節(jié)點(diǎn)中的順序
• 如果字節(jié)不是最小的節(jié)點(diǎn)，那么進(jìn)入等待，同時(shí)向比字節(jié)小的最后一個(gè)節(jié)點(diǎn)注冊(cè)Watcher，如果字節(jié)是最小的節(jié)點(diǎn)則執(zhí)行邏輯
• 接受Watcher通知重復(fù)1中步驟

Barrier：分布式屏障

• Birrier在分布式系統(tǒng)中特指一個(gè)協(xié)調(diào)條件，規(guī)定一個(gè)隊(duì)列中的元素都到達(dá)指定條件的時(shí)候才能夠執(zhí)行，大致的如下：創(chuàng)建屏障個(gè)數(shù)節(jié)點(diǎn)/queue_barrier并且賦值10，表示10個(gè)子節(jié)點(diǎn)同時(shí)滿足，接著所有客戶端在/queue_barrier下創(chuàng)建臨時(shí)子節(jié)點(diǎn)，/queue_barrier/host1，/queue_barrier/host2，/queue_barrier/host3，創(chuàng)建后，依據(jù)如下步驟執(zhí)行：

通過getData獲取/queue_barrier下節(jié)點(diǎn)的數(shù)據(jù)內(nèi)容：10

通過getChildren獲取/queue_barrier下所有子節(jié)點(diǎn)，同時(shí)對(duì)子節(jié)點(diǎn)列表添加變化監(jiān)聽Watcher

統(tǒng)計(jì)子節(jié)點(diǎn)個(gè)數(shù)

如果子節(jié)點(diǎn)個(gè)數(shù)不足10，進(jìn)入等待，否則進(jìn)入業(yè)務(wù)處理

接受watcher通知后重復(fù)步驟2

• 整個(gè)過程如下：
  

上一篇Zookeeper–分布式鎖實(shí)現(xiàn)

總結(jié)

以上是生活随笔為你收集整理的Zookeepe实践与应用--分布队列的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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