1. rocketmq源碼安裝參考官方文檔：http://rocketmq.apache.org/docs/quick-start/安裝好jdk和maven rocketmq安裝包：https://pan.baidu.com/s/1I3CqWaxFnxtUX1kJpIJkcQ 密碼: vu5m ...

發送丟失 　　我們發送消息時，broker寫入到cache后就返回成功了，而producer只要獲取到ACK就說明消息發送成功了，反之肯定會收到一個異常，比如網絡錯誤、請求超時之內的。而當我們發送失敗后一直重試發送，能保證消息一定到達MQ嗎？比如這樣： 　　 　　本地事務執行完之后、數據庫 ...

前言 上篇文章，王子通過一個小案例和小伙伴們一起分析了一下消息是如何丟失的，但沒有提出具體的解決方案。 我們已經知道發生消息丟失的原因大體上分為三個部分： 1.生產者發送消息到MQ這一過程導致消息丟失 2.MQ自己發生故障導致消息丟失 3.消費者拿到消息后，由於操作不當導致消息丟失 ...

作者：Jaskey Lam 來源：https://jaskey.github.io/blog/2020/06/08/rocketmq-message-dedup/ 消息中間件是分布式系統常用的組件，無論是異步化、解耦、削峰等都有廣泛的應用價值。我們通常會認為，消息中間件是一個可靠的組件 ...

消息中間件是分布式系統常用的組件，無論是異步化、解耦、削峰等都有廣泛的應用價值。我們通常會認為，消息中間件是一個可靠的組件——這里所謂的可靠是指，只要我把消息成功投遞到了消息中間件，消息就不會丟失，即消息肯定會至少保證消息能被消費者成功消費一次，這是消息中間件最基本的特性之一，也就是我們常說 ...

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

冪等性要求的場景： 1、表單提交，重復點擊問題，產生兩條相同數據。 2、接口超時重試，出現重復操作數據問題。 3、mq消費者讀取消息，讀取重復消息問題。 接口冪等性是指用戶對於同一操作發起的一次請求或者多次請求的結果是一致。 如何解決請求重復，就需要接口的冪等 冪等解決方案： 1、insert ...

消費者接收重復消息冪等性解決方案： 1.利用數據庫唯一性約束去實現冪等性創建消息去重表，把全局唯一ID作為主鍵，做唯一性約束，如果插入成功就表示沒有消費過這條消息，可以進行消費了，插入失敗表示消息已經被消費了。 2.利用Redis的原子性去實現冪等性我們都知道redis是單線程 ...