生產者丟數據

RabbitMQ提供transaction和confirm模式來確保生產者不丟消息。

transaction機制就是說，發送消息前，開啟事務（channel.txSelect()）,然后發送消息，如果發送過程中出現什么異常，事務就會回滾（channel.txRollback()）,如果發送成功則提交事務（channel.txCommit()）。

消息隊列丟數據

處理消息隊列丟數據的情況，一般是開啟持久化磁盤的配置。這個持久化配置可以和confirm機制配合使用，你可以在消息持久化磁盤后，再給生產者發送一個Ack信號。這樣，如果消息持久化磁盤之前，rabbitMQ陣亡了，那么生產者收不到Ack信號，生產者會自動重發。

那么如何持久化呢，這里順便說一下吧，其實也很容易，就下面兩步

將queue的持久化標識durable設置為true,則代表是一個持久的隊列

發送消息的時候將deliveryMode=2

這樣設置以后，即使rabbitMQ掛了，重啟后也能恢復數據.

消費者丟數據

消費者丟數據一般是因為采用了自動確認消息模式。這種模式下，消費者會自動確認收到信息。這時rabbitMQ會立即將消息刪除，這種情況下，如果消費者出現異常而未能處理消息，就會丟失該消息。

總結

以上是生活随笔為你收集整理的RabbitMQ应对不同阶段丢失消息的处理方案的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。