【Message Queue - RabbitMQ】消費者分發制度
更新於 發佈於 閱讀時間約 1 分鐘
假設我們每個Queue都只對應一個消費者，那麼就不會有分配問題，但如果今天我們有多個消費者的時候，這時候要怎麼分發？如何做到公平？
一、輪流分發
預設採輪流分發，假設有三個消費者同時消費，則如下圖，訊息平均分配給各個消費者處理。
這種分發方式並未考慮到Consumer的處理能力，假設Consumer1處理較慢，那麼被分配到訊息後勢必會堆積很多訊息在記憶體，如此一來會比較沒有效率一點，當有新的Consumer加入時那些堆積的訊息因為已經被分發到Consumer1了，所以新的Consumer也無法幫忙處理。
二、公平分發(依照處理能力)
上述的狀況下，只要Queue有訊息就立即往Consumer丟，此時如果能夠限制每個Consumer能夠處理的數量，那麼訊息就比較容易被依照處理能力分配，而RabbitMQ正好提供了這種Qos的配置，讓Consumer來告訴Server端自己一次能處理的量。
channel.basicQos($prefetchCount, $prefetchSize, $global)
- $prefetchCount: 代表消費者一次能處理的量，在還沒回傳ack訊號前不會派發新的訊息。
- $prefetchSize: 代表消費者一次能處理的訊息大小。
- $global: true代表套用到整個connection， false則僅限於該channel，通常都配置為false。
延伸閱讀:
為什麼會看到廣告
118會員
266內容數
哈囉，我是阿Han，是一位 👩💻 軟體研發工程師，喜歡閱讀、學習、撰寫文章及教學，擅長以圖代文，化繁為簡，除了幫助自己釐清思路之外，也希望藉由圖解的方式幫助大家共同學習，甚至手把手帶您設計出高品質的軟體產品。
留言0
查看全部你可能也想看
Google News 追蹤
隨著理財資訊的普及，越來越多台灣人不再將資產侷限於台股，而是將視野拓展到國際市場。特別是美國市場，其豐富的理財選擇，讓不少人開始思考將資金配置於海外市場的可能性。
然而，要參與美國市場並不只是盲目跟隨標的這麼簡單，而是需要策略和方式，尤其對新手而言，除了選股以外還會遇到語言、開戶流程、Ap
嘿，大家新年快樂~ 新年大家都在做什麼呢？
跨年夜的我趕工製作某個外包設計案，在工作告一段落時趕上倒數。
然後和兩個小孩過了一個忙亂的元旦。在深夜時刻，看到朋友傳來的解籤網站，興致勃勃熬夜體驗了一下，覺得非常好玩，或許有人玩過了，但還是想寫上來分享紀錄一下~
RabbitMQ 和 Kafka 是兩種流行的消息處理工具，各自擅長不同的應用場景。RabbitMQ 以低延遲和靈活的消息路由著稱，適合即時通信和微服務；Kafka 則專注於高吞吐量和數據持久化，適用於大規模數據流和實時分析。本文比較了它們的性能、擴展性和安全性，幫助你選擇最符合需求的解決方案。
Message Queue 和 Streaming Process 是分佈式系統中最重要的技術之一，但它們的應用場景和特性有明顯區別。消息隊列適合可靠的低延遲通信，而流處理專注於大規模數據流的實時分析。本文深入比較兩者特性，幫助你根據需求選擇合適的技術，打造更高效的系統架構！
本文介紹如何使用 Docker 安裝 RabbitMQ，並將其與 Node.js 結合，實現訊息的生產與消費。這個架構可以應用於分佈式系統或事件驅動架構中，幫助讀者理解如何整合 RabbitMQ 與 Node.js。
※ 生產者和消費者模式
定義：
生產者和消費者在同一時間內共同存取某一個資料空間。生產者負責生成數據並將其放入共享空間，消費者負責從共享空間中取走數據進行處理。兩者之間互不相干，也不須互相知道對方的存在。
共同存取資料空間：生產者和消費者共享同一個資料空間。這個空間通常是緩衝區或隊列，用於在它
最近在Threads看到AA制又被炒起來，到底男方要不要為女方買單？
我認為AA制根本不是重點，重點在於對方是否什麼都要跟你計較，每一次的算清楚都在提醒你：「我們是分離的個體」，不要在我身上投入太多感情。
感情是用來談的，而人是互相的，當你感受到對方跟你計較，你也會陷入「計較」的循環
理論上市場的供需應該是平衡的……
通常當需求增加時，有利可圖的狀況下，增加生產線或有其他供應商進入市場是顯而易見的。
而當需求減少時，裁撤生產線或較弱小的供應商退出市場，最終市場供需也會達到平衡。
然而凡事總有意外……
在Python中，queue是一個非常有用的模块。
它提供了多種佇列（queue）實現，用於在多線程環境中安全地交換信息或者數據。
佇列（queue）是一種先進先出（FIFO）的數據結構，允許在佇列的一端插入元素，另一端取出元素。(FIFO 是First In, First Out 的縮寫)
■什麼是區塊鏈技術？
區塊鏈是透過點對點(P2P)運行的網路，這個網路由分散式節點組成，可以把它想成是共享的數據庫，也就是分散式帳本(DLT)，分散式帳本技術是一種去中心化的帳本，儲存著網路上進行的所有交易。
中心化帳本：也稱為集中式帳本，由一個中心化的機構去做驗證、記帳、訂立規則。
隨著理財資訊的普及，越來越多台灣人不再將資產侷限於台股，而是將視野拓展到國際市場。特別是美國市場，其豐富的理財選擇，讓不少人開始思考將資金配置於海外市場的可能性。
然而，要參與美國市場並不只是盲目跟隨標的這麼簡單，而是需要策略和方式，尤其對新手而言，除了選股以外還會遇到語言、開戶流程、Ap
嘿，大家新年快樂~ 新年大家都在做什麼呢？
跨年夜的我趕工製作某個外包設計案，在工作告一段落時趕上倒數。
然後和兩個小孩過了一個忙亂的元旦。在深夜時刻，看到朋友傳來的解籤網站，興致勃勃熬夜體驗了一下，覺得非常好玩，或許有人玩過了，但還是想寫上來分享紀錄一下~
RabbitMQ 和 Kafka 是兩種流行的消息處理工具，各自擅長不同的應用場景。RabbitMQ 以低延遲和靈活的消息路由著稱，適合即時通信和微服務；Kafka 則專注於高吞吐量和數據持久化，適用於大規模數據流和實時分析。本文比較了它們的性能、擴展性和安全性，幫助你選擇最符合需求的解決方案。
Message Queue 和 Streaming Process 是分佈式系統中最重要的技術之一，但它們的應用場景和特性有明顯區別。消息隊列適合可靠的低延遲通信，而流處理專注於大規模數據流的實時分析。本文深入比較兩者特性，幫助你根據需求選擇合適的技術，打造更高效的系統架構！
本文介紹如何使用 Docker 安裝 RabbitMQ，並將其與 Node.js 結合，實現訊息的生產與消費。這個架構可以應用於分佈式系統或事件驅動架構中，幫助讀者理解如何整合 RabbitMQ 與 Node.js。
※ 生產者和消費者模式
定義：
生產者和消費者在同一時間內共同存取某一個資料空間。生產者負責生成數據並將其放入共享空間，消費者負責從共享空間中取走數據進行處理。兩者之間互不相干，也不須互相知道對方的存在。
共同存取資料空間：生產者和消費者共享同一個資料空間。這個空間通常是緩衝區或隊列，用於在它
最近在Threads看到AA制又被炒起來，到底男方要不要為女方買單？
我認為AA制根本不是重點，重點在於對方是否什麼都要跟你計較，每一次的算清楚都在提醒你：「我們是分離的個體」，不要在我身上投入太多感情。
感情是用來談的，而人是互相的，當你感受到對方跟你計較，你也會陷入「計較」的循環
理論上市場的供需應該是平衡的……
通常當需求增加時，有利可圖的狀況下，增加生產線或有其他供應商進入市場是顯而易見的。
而當需求減少時，裁撤生產線或較弱小的供應商退出市場，最終市場供需也會達到平衡。
然而凡事總有意外……
在Python中，queue是一個非常有用的模块。
它提供了多種佇列（queue）實現，用於在多線程環境中安全地交換信息或者數據。
佇列（queue）是一種先進先出（FIFO）的數據結構，允許在佇列的一端插入元素，另一端取出元素。(FIFO 是First In, First Out 的縮寫)
■什麼是區塊鏈技術？
區塊鏈是透過點對點(P2P)運行的網路，這個網路由分散式節點組成，可以把它想成是共享的數據庫，也就是分散式帳本(DLT)，分散式帳本技術是一種去中心化的帳本，儲存著網路上進行的所有交易。
中心化帳本：也稱為集中式帳本，由一個中心化的機構去做驗證、記帳、訂立規則。