聊聊mq中消息消費的幾種方式

mq系列文章

對mq瞭解不是不少的，能夠看一下下面兩篇文章:

1. 聊聊mq的使用場景
2. 聊聊業務系統中投遞消息到mq的幾種方式
3. 聊聊消息消費的幾種方式
4. 如何確保消息至少消費一次
5. 如何保證消息消費的冪等性

本章內容

從消費者的角度出發，分析一下消息消費的兩種方式：

1. push方式
2. pull方式

push方式

消息消費的過程：

1. mq接收到消息

2. mq主動將消息推送給消費者（消費者需提供一個消費接口）

mq屬於主動方，消費者屬於一種被動消費，一旦有消息到達mq，會觸發mq推送機制，將消息推送給消費者，無論消費者處於何種狀態。

優勢：

1. 消費者代碼較少：對於消費者來講，只需提供一個消費接口給mq便可；mq將接收到的消息，隨即推送到指定的消費接口

2. 消息實時性比較高：對於消費者來講，消息一旦到達mq，mq會當即推送給消費者

缺點：

1.消費者屬於被動方，消息量比較大時，對消費者性能要求比較高；若消費者機器資源有限，可能會致使壓力過載，引起宕機的狀況。

2.對消費者可用性要求比較高：當消費者不可用時，會致使很push失敗，在mq方須要考慮至少推送成功一次，這塊的設計下章節會作說明。

pull方式

消息消費的過程：

1.消費端採用輪詢的方式，從mq服務中拉取消息進行消費

2.消費完成通知mq刪除已消費成功的消息

3.繼續拉取消息消費

對於消費者來講，是主動方，能夠採用線程池的方式，根據機器的性能來增長或縮小線程池的大小，控制拉取消息的速度，能夠很好的控制自身的壓力。

優勢：

1.消費者能夠根據本身的性能主動控制消息拉去的速度，控制本身的壓力，不至於把本身弄跨

2.實時性相對於push方式會低一些

3.消費者屬於主動方，控制權更大一些

缺點：

1.消費方須要實現消息拉取的代碼

2.消費速度較慢時，可能致使mq中消息積壓，消息消費延遲等

總結

1. 消費者性能較好，對實時性要求比較高的，能夠採用push的方式

2. 消費者性能有限，建議採用pull的方式

3. 總體上來講，主要在於消費者的性能，機器的性能若是沒有問題，push和pull都是能夠的

4. 你們有什麼見解，能夠留言一塊兒討論，但願本文對你有所幫助