mq系列文章

對mq了解不是很多的，可以看一下下面兩篇文章:

為龍州等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù)，及龍州網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站制作、成都做網(wǎng)站、外貿(mào)營銷網(wǎng)站建設(shè)、龍州網(wǎng)站設(shè)計，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會得到認(rèn)可，從而選擇與我們長期合作。這樣，我們也可以走得更遠(yuǎn)！

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

本章內(nèi)容

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

1. push方式
2. pull方式

push方式

消息消費的過程：

1. mq接收到消息

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

mq屬于主動方，消費者屬于一種被動消費，一旦有消息到達(dá)mq，會觸發(fā)mq推送機制，將消息推送給消費者，不管消費者處于何種狀態(tài)。

優(yōu)點：

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

2. 消息實時性比較高：對于消費者來說，消息一旦到達(dá)mq，mq會立即推送給消費者

缺點：

1.消費者屬于被動方，消息量比較大時，對消費者性能要求比較高；若消費者機器資源有限，可能會導(dǎo)致壓力過載，引發(fā)宕機的情況。

2.對消費者可用性要求比較高：當(dāng)消費者不可用時，會導(dǎo)致很push失敗，在mq方需要考慮至少推送成功一次，這塊的設(shè)計下章節(jié)會做說明。

pull方式

消息消費的過程：

1.消費端采用輪詢的方式，從mq服務(wù)中拉取消息進行消費

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

3.繼續(xù)拉取消息消費

對于消費者來說，是主動方，可以采用線程池的方式，根據(jù)機器的性能來增加或縮小線程池的大小，控制拉取消息的速度，可以很好的控制自身的壓力。

優(yōu)點：

1.消費者可以根據(jù)自己的性能主動控制消息拉去的速度，控制自己的壓力，不至于把自己弄跨

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

3.消費者屬于主動方，控制權(quán)更大一些

缺點：

1.消費方需要實現(xiàn)消息拉取的代碼

2.消費速度較慢時，可能導(dǎo)致mq中消息積壓，消息消費延遲等

總結(jié)

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

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

3. 整體上來說，主要在于消費者的性能，機器的性能如果沒有問題，push和pull都是可以的

4. 大家有什么看法，可以留言一起討論，希望本文對你有所幫助

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務(wù)器，動態(tài)BGP最優(yōu)骨干路由自動選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機房獨有T級流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動現(xiàn)已開啟，新人活動云服務(wù)器買多久送多久。

網(wǎng)頁標(biāo)題：聊聊mq中消息消費的幾種方式-創(chuàng)新互聯(lián)
URL地址：http://aaarwkj.com/article38/cogdpp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站制作、外貿(mào)建站、網(wǎng)站設(shè)計公司、網(wǎng)站制作、ChatGPT、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)