2. 程式人生 > 其它 >淺談 RabbitMQ（二）解決訊息丟失

淺談 RabbitMQ（二）解決訊息丟失

阿新 • • 發佈：2021-08-16

淺談 RabbitMQ（一）工作模型與 Exchange 型別

目錄

一、訊息傳遞分析

RabbitMQ的具體結構圖參考筆者上一篇文章，下面畫個訊息傳遞的簡圖

從上圖可知，要確保一個訊息正確的傳遞，需要在四個傳遞階段都能正確傳遞：

  1. 確保訊息成功由生產者傳送到RabbitMQ伺服器
  2. 確保訊息被交換機路由到正確的佇列
  3. 確保訊息在佇列中不丟失
  4. 確保訊息成功被消費者消費

二、訊息丟失的幾種情況

知道了訊息如何傳遞，自然也就知道了訊息丟失的情況了：

  1. 在生產者傳送到RabbitMQ伺服器時丟失
  2. 在交換機路由到佇列時丟失
  3. 在佇列中丟失
  4. 在消費時丟失

三、訊息丟失解決方案

那麼解決訊息丟失自然也是根據這幾種情況來分析了：

（1）解決生產者傳送訊息到MQ的丟失

1. 服務端確認-事務模式

生產者每傳送一次訊息，MQ就響應一次。這種模式效率低，不推薦

2. 服務端確認-確認模式

生產者傳送訊息後，伺服器傳送確認ACK給生產者，根據確認的方式又分為三種：

  1. 單條確認：生產者每傳送一次訊息，伺服器傳送確認一次，類似於事務模式，效率低
  2. 批量確認：設定傳送訊息次數後，伺服器傳送確認
  3. 非同步確認：生產者監聽伺服器傳送的確認事件，由伺服器決定何時確認

（2）解決在交換機路由時的訊息丟失

  1. 在無法路由到佇列時將訊息回發給生產者

  2. 建立交換機時指定一個備份交換機，路由失敗時將訊息傳送到備份交換機

（3）解決在佇列時的訊息丟失

  1. 建立佇列時設定佇列持久化
  2. 訊息持久化

（4）解決在消費時的訊息丟失

消費者消費訊息時預設為自動確認，即消費者剛收到訊息時就給MQ傳送ACK確認，此時MQ會將訊息出隊；如果想要在消費的邏輯處理完成後再確認訊息，就需要消費者設定手動確認ACK，假如在消費過程中發生異常，無法傳送確認給MQ伺服器，訊息將無法出隊，導致堆積，所以需要在finally塊中設定unAck或者將訊息回發給MQ伺服器

（5）其它保證訊息正確消費的情況

  1. 補償機制

比如生產者在傳送訊息到MQ時，始終收不到確認，那麼就需要重發訊息，但是重發也不能一直髮送，會導致重複訊息堆積。所以有兩種解決方案：① 設定等待確認超時，超時後再重發訊息；② 重發時控制次數

  1. 訊息冪等

假如在消費過程中同一訊息被消費多次，在特定場景中將產生重大影響，比如轉賬等，所以需要保證同一條訊息在消費多次後保證操作一致（類似於介面冪等性：重複呼叫時保證資料一致）

END


作者：金木研King
轉載請註明原文連結：https://www.cnblogs.com/jinzlblog/p/15147420.html

相關推薦

淺談 RabbitMQ（二）解決訊息丟失

淺談 RabbitMQ（一）工作模型與 Exchange 型別 目錄一、訊息傳遞分析二、訊息丟失的幾種情況三、訊息丟失解決方案（1）解決生產者傳送訊息到MQ的丟失1. 服務端確認-事務模式2. 服務端確認-確認模式（2）解決在交換機

淺談 RabbitMQ（一）工作模型與 Exchange 型別

目錄為什麼要使用MQ非同步解耦削峰RabbitMQ工作模型Exchange路由型別Direct Exchange（直連）Topic Exchange（主題）Fanout Exchange（廣播）

RocketMQ入門到入土（二）事務訊息&順序訊息

接上一篇：RocketMQ入門到入土（一）新手也能看懂的原理和實戰！ 一、事務訊息的由來

rabbitMq（一）內部訊息分發

pom檔案 <dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId>

Springboot整合RabbitMQ（四）——設定訊息過期時間TTL

主要有2種方式： 指定一條訊息的過期時間。 給佇列設定訊息過期時間，佇列中的所有訊息都有同樣的過期時間。

geoserver釋出地圖服務_Python獲取 bing 地圖釋出自己的 TMS 服務（二）解決海量瓦片存取問題...

技術標籤：geoserver釋出地圖服務 金字塔結構的瓦片數量有多大 以目前網際網路常用的WebMecator為例

淺談MySQL（一）：儲存引擎與索引

淺談MySQL（一）：儲存引擎與索引 目錄淺談MySQL（一）：儲存引擎與索引一、儲存引擎InnoDBMyISAM二、索引1、B+Tree 索引B-TreeB+Tree2、全文索引3、雜湊索引4、空間資料索引

【RabbitMQ（二）】佇列使用

技術標籤：訊息佇列rabbitmq訊息確認迴圈排程streadway/amqp 引言 在上一節【RabbitMQ（一）】docker-compose安裝rabbitmq及簡單使用Hello World中，我們介紹了Rabbitmq的安裝和簡單操作。達到了生產者傳送一個H

【前端 · 面試 】HTTP 總結（二）—— HTTP 訊息

HTTP 訊息是伺服器和客戶端之間交換資料的方式。 HTTP 訊息分為請求訊息和響應訊息，完整的訊息由四部分組成。

【原創】淺談指標（一）

前言 如今的很多開發人員，對指標或多或少都有一些畏懼心理，都認為“指標經常會在一些不起眼的地方讓程式崩潰”。確實，很多錯誤都是由於指標引起的。指標和記憶體密切相關，難免會由於地址或是陣列越界，沒有初始

【原創】淺談指標（三）

上期連結 https://www.cnblogs.com/jisuanjizhishizatan/p/15365823.html 前言 我寫本文的初衷是為了讓更多的人瞭解指標。最近一直有人在我的博文點反對，我也不想點名，只是想說：不要對指標懷有偏見。你可以認為本

【原創】淺談指標（四）

前幾篇文章的連結： 淺談指標（一）https://www.cnblogs.com/jisuanjizhishizatan/p/15365167.html

淺談機（J）慘（C）技巧——從入門到精通（?)

JC總是無聊的機房中有意思的一個瞬間。。。 比如： 這個傑作由 ZSWBWYX 完成 你認為這只是AK-IOI嗎？不！注意使用者名稱。。。也是此人的傑作。

【原創】淺談指標（七）字串相關（詳細版本）與指標運算

本文原創，僅在部落格園釋出，若在其他平臺發現均為盜取！！！ 目錄-1、寫作目的0、前言1、字串的比較1.1.歷史原因1.2.陣列1.3.比較函式2、strcmp函式2.1.函式規範2.2.自制strcmp函式2.3.指標運算3、strlen函式3.1.

剛哥談架構 （二） 我眼中的架構師

之前在公司，有小夥伴在向別人介紹我的時候，經常會有人這麼說：“剛哥是我們的architecture”，如果來人是老外，心中一定是一驚，心中暗歎，“這位匪首看上去貌不驚人，難道已經做到了架構和本人天人合一和最高境界

淺談Kotlin（四）: 靜態變數&靜態方法

Java中定義靜態變數和方法： public class XUtils { // utils版本號 public static String utilVersion=\"1.0\";

淺談Kotlin（六）：lateinit、by lazy 使用

Kotlin中有兩種延遲初始化的方式。一種是lateinit var，一種是by lazy。 一、lateinit的使用

【原創】淺談指標（十）連結串列的寫法

前言 最近我又來更新這個系列了，其實感覺指標對於我們還是非常重要的存在。指標之所以是初學者們的“噩夢”，它的難度源於它的靈活性。

淺談DFS（上）

前言 到底有什麼前言呢？ 板子 void dfs(int x) { if (x == 某個條件) { //輸出 puts(\"\"); return;

RabbitMQ（二） ——工作佇列

RabbitMQ（二）——工作佇列 （原創內容，轉載請註明來源，謝謝） 一、概述 工作佇列模式（work queue），是有多個消費者的情況下，可以共同消費佇列內的內容，加快訊息處理速度。這是RabbitMQ的基本工作模式。