問題由來 假設在一個訂單系統中（以火車票訂單系統為例），用戶A，用戶B都要預定從成都到北京的火車票，A、B在不同的售票窗口均同時查詢到了某車廂卧鋪中、下鋪位有空位。用戶A正在猶豫訂中鋪還是下鋪，這時用戶B果斷訂購了下鋪。當用戶A決定訂下鋪時，系統提示下鋪已經被預訂，請重新選擇鋪位。在這 ...

RocketMQ 冪等性主要分為生產端和消費端冪等性 備注：這里只討論生產者 和消費者集群部署下的情況 生產者端冪等性保證： 　　1RocketMQ 為消息生產者提供了消息查詢的API，在消息發送之前，可以查詢該條消息是否發送過，注意但是該方法在2020年5月之后的版本，已經被廢掉 ...

前情 出現了重復消費的問題，同一個消息被重復消費了多次，導致了用戶端收到了多條重復的消息，最終排查發現，是因為消費者在處理消息的方法onMessage中有異常沒有捕獲到，導致異常上拋，被consumeMessage捕獲並判定為消費失敗，從而放到了重試隊列當中進行重試，下面我們就來看看 ...

之所以想聊一聊這個話題，是因為在剛開始使用rocketmq時，Consumer服務寫的有問題的情況下，消息隊列會重發，這是因為消費失敗會導致消息被放入RETRY重試隊列，根據用戶配置的重試次數（默認16次）進行重試，這部分我們已經在之前的 RocketMQ存儲機制與確認重傳機制一文中討論 ...

一、為什么出現消息重復 從 Product 看 Rocketmq 提供三種發送消息模式 同步發送：Producer 向 broker 發送消息，阻塞當前線程等待 broker 響應 發送結果。DefaultMQProducerImpl 中如果沒有設置 超時、發送失敗，就會重發。 異步發送 ...

前言 在之前的MQ專題中，我們已經解決了消息中間件的一大難題，消息丟失問題。 但MQ在實際應用中不是說保證消息不丟失就萬無一失了，它還有兩個令人頭疼的問題：重復消費和亂序。 今天我們就來聊一聊這兩個常見的問題，看看RocketMQ是如何解決這兩個問題的。 為什么會重復消費 ...

消息重復消費，會造成數據混亂，特別是在涉及消費和財務系統里，此問題的解決顯得尤為重要。 以kafka為例 關鍵字：消費端自動提交offset；寫庫或者redis時，先去查一下主鍵、key等是否存在 上圖中，最頂上的文本框丟失的文字：並通知kafka當前最大offset； 最右邊的文本框 ...

　　近期工作中遇到用戶重復提交表單信息情況，尤其是在網絡延時的情況下，用戶點擊提交按鈕后，頁面遲遲未響應，於是就會再次點擊提交按鈕。這樣就導致產生重復數據，會對后續的業務帶來一定問題。為此，查了一些資料，學習總結了下相關問題的解決思路。 　　首先，重復提交的問題，專業點的說法叫做接口冪等性問題 ...