RabbitMQ消息可靠性投遞
點(diǎn)擊上方藍(lán)色字體，選擇“標(biāo)星公眾號(hào)”
優(yōu)質(zhì)文章，第一時(shí)間送達(dá)
76套java從入門到精通實(shí)戰(zhàn)課程分享
一般的消息中間件（MQ）只能保證消息不丟，但是不能保證重復(fù)發(fā)送等問題。
比如在使用Rabbitmq過程中，如何保證消息都能正確的投遞被消費(fèi)，這個(gè)是要考慮的問題。
那么可靠性投遞所面臨的問題有哪些？
1. 如果發(fā)送的消息重復(fù)怎么辦。
2. 如果消息發(fā)送過程中丟了怎么辦。
3. 如何保證MQ節(jié)點(diǎn)成功收到消息。
針對(duì)這個(gè)問題RabbitMQ提供了以下幾個(gè)機(jī)制來解決：
生產(chǎn)者確認(rèn)
持久化
手動(dòng)Ack
下圖是Rabbitmq一個(gè)完整的消息可靠投遞的一個(gè)方案。
我們來分析下。
Step1：Producer所發(fā)送的數(shù)據(jù)是我們的業(yè)務(wù)數(shù)據(jù)，比如訂單信息。Producer在發(fā)送消息之前給我們的訂單信息寫入我們的本地?cái)?shù)據(jù)庫(kù)（BIZ DB)中，BIZ DB是我們的業(yè)務(wù)數(shù)據(jù)庫(kù)，接著將要發(fā)送到消息存儲(chǔ)到消息記錄數(shù)據(jù)庫(kù)中(MSG DB)，這個(gè)MSG DB就是存儲(chǔ)所有發(fā)送給Rabbitmq的消息記錄用的，寫入消息記錄表中該記錄字段status(狀態(tài))會(huì)有幾個(gè)值，比如0表示消息發(fā)送中，1表示發(fā)送成功，2表示消息發(fā)送失敗，。
Step2：應(yīng)用程序要消息發(fā)送給Rabbitmq的Broker，這個(gè)發(fā)送的消息屬于confirm模式，發(fā)送后需要Rabbitmq確認(rèn)。
Step3：Rabbitmq Broker收到消息后會(huì)給Producer一個(gè)應(yīng)答來確認(rèn)信息，說我已經(jīng)收到消息了。
Step4：緊跟上一步，Producer一直在監(jiān)聽（Listener）Broker所確認(rèn)的信息，在收到消息之后，根據(jù)收到消息的結(jié)果再去更新MSG DB中的消息發(fā)送狀態(tài)，將記錄status字段更新為1。
Step 5：但是在消息確認(rèn)這個(gè)過程中可能由于網(wǎng)絡(luò)閃斷、MQ Broker端異常等原因?qū)е?回送消息失敗或者異常。這個(gè)時(shí)候就需要發(fā)送方（生產(chǎn)者）對(duì)消息進(jìn)行可靠性投遞了，保障消息不丟失，100%的投遞成功?。ㄓ幸环N極限情況是閃斷，Broker返回的成功確認(rèn)消息，但是生產(chǎn)端由于網(wǎng)絡(luò)閃斷沒收到，這個(gè)時(shí)候重新投遞可能會(huì)造成消息重復(fù)，需要消費(fèi)端去做冪等處理）所以我們需要有一個(gè)定時(shí)任務(wù)，（比如每5分鐘拉取一下處于中間狀態(tài)的消息，當(dāng)然這個(gè)消息可以設(shè)置一個(gè)超時(shí)時(shí)間，比如超過1分鐘 Status = 0 ，也就說明了1分鐘這個(gè)時(shí)間窗口內(nèi)，我們的消息沒有被確認(rèn)，那么會(huì)被定時(shí)任務(wù)拉取出來）。
Step 6：接下來我們把中間狀態(tài)的消息進(jìn)行重新投遞 retry send，繼續(xù)發(fā)送消息到MQ ，當(dāng)然也可能有多種原因?qū)е掳l(fā)送失敗
Step 7：我們可以采用設(shè)置最大努力嘗試次數(shù)，比如投遞了3次，還是失敗，那么我們可以將最終狀態(tài)設(shè)置為Status = 2 ，最后 交由人工解決處理此類問題（或者把消息轉(zhuǎn)儲(chǔ)到失敗表中）。
作者：阿神
鏈接：https://www.imooc.com/article/49814
來源：慕課網(wǎng)
本文原創(chuàng)發(fā)布于慕課網(wǎng) ，轉(zhuǎn)載請(qǐng)注明出處，謝謝合作
粉絲福利：Java從入門到入土學(xué)習(xí)路線圖
??????
??長(zhǎng)按上方微信二維碼 2 秒
感謝點(diǎn)贊支持下哈 