分布式隊列

• 接觸到不少分布式隊列的產品，比如，ActiveMq，RocketMQ，kafka等消息中間價，現在我們看看Zookeeper實現的分布式隊列。
• 分布式隊列簡單講就可以分兩個部分，一種是先進先出，另外一種是等所有元素都到齊都會統一執行的Barrier模型

FIFO先入先出

• FIFO（First in First out,先入先出）的算法思想在計算機里面用的比較多，比如隊列里面，先進入的能先執行，在Zookeeper的實現中，FIFO類似一個共享鎖模型，所有客戶端在節點/queue_fifo下創建臨時節點/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遞增的關系創建，創建后依據以下幾個步驟
• 通過getChildren接口獲取/queue_fifo下所有子節點
• 確認字節的節點序號在所有子節點中的順序
• 如果字節不是最小的節點，那么進入等待，同時向比字節小的最后一個節點注冊Watcher，如果字節是最小的節點則執行邏輯
• 接受Watcher通知重復1中步驟

Barrier：分布式屏障

• Birrier在分布式系統中特指一個協調條件，規定一個隊列中的元素都到達指定條件的時候才能夠執行，大致的如下：創建屏障個數節點/queue_barrier并且賦值10，表示10個子節點同時滿足，接著所有客戶端在/queue_barrier下創建臨時子節點，/queue_barrier/host1，/queue_barrier/host2，/queue_barrier/host3，創建后，依據如下步驟執行：

通過getData獲取/queue_barrier下節點的數據內容：10

通過getChildren獲取/queue_barrier下所有子節點，同時對子節點列表添加變化監聽Watcher

統計子節點個數

如果子節點個數不足10，進入等待，否則進入業務處理

接受watcher通知后重復步驟2

• 整個過程如下：
  

上一篇Zookeeper–分布式鎖實現

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。