業務背景

消息隊列在數據傳輸的過程中，為了保證消息傳遞的可靠性，一般會對消息采用ack確認機制，如果消息傳遞失敗，消息隊列會進行重試，此時便可能存在消息重復消費的問題。

比如，用戶到銀行取錢后會收到扣款通知短信，如果用戶收到多條扣款信息通知則會有困惑。

解決方法一：send if not exist

首先將 RabbitMQ 的消息自動確認機制改為手動確認，然后每當有一條消息消費成功了，就把該消息的唯一ID記錄在Redis 上，然后每次發送消息時，都先去 Redis 上查看是否有該消息的 ID，如果有，表示該消息已經消費過了，不再處理，否則再去處理。

2.1 利用數據庫唯一約束實現冪等

解決方法二：insert if not exist

可以通過給消息的某一些屬性設置唯一約束，比如增加唯一uuid，添加的時候查詢是否存對應的uuid，存在不操作，不存在則添加，那樣對于相同的uuid只會存在一條數據

解決方法三：sql的樂觀鎖

比如給用戶發送短信，變成如果該用戶未發送過短信，則給用戶發送短信，此時的操作則是冪等性操作。但在實際上，對于一個問題如何獲取前置條件往往比較復雜，此時可以通過設置版本號version，每修改一次則版本號+1，在更新時則通過判斷兩個數據的版本號是否一致。

總結

以上是生活随笔為你收集整理的RabbitMQ消息重复消费问题的全部內容，希望文章能夠幫你解決所遇到的問題。

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