最近收到好幾個類似的問題：使用Spring Cloud Stream操作RabbitMQ或Kafka的時候，出現消息重復消費的問題。通過溝通與排查下來主要還是用戶對消費組的認識不夠。其實，在之前的博文以及《Spring Cloud微服務實戰》一書中都有提到關於消費組的概念以及作用 ...

如果要你實現一個支付寶向余額寶轉賬的功能，比如：賬戶a從支付寶轉出5000余額寶轉入5000，該怎么做呢？ 可能有些人會說，這還不簡單，直接上圖 支付寶先給賬戶a減50 ...

一、前言 首先，rabbitMQ並沒有為消息的重復消費而設計一種解決方法，這個解決方法需要我們來根據業務自己實現，我整理了幾種常見的解決方法。 二、消息重復發送導致消息被重復消費的場景 第一個場景，在生產者發送消息給rabbitMQ服務器的時候，有可能因為網絡波動等情況，導致生產者 ...

關於 Kafka 消息丟失、重復消費和順序消費的問題 消息丟失，消息重復消費，消息順序消費等問題是我們使用 MQ 時不得不考慮的一個問題，下面我結合實際的業務來和你分享一下解決方案。 消息丟失問題 比如我們使用 Kakfa 時，以下場景都會發生消息丟失： producer ...

保證消息不被重復消費的關鍵是保證消息隊列的冪等性，這個問題針對業務場景來答分以下幾點： 一、比如，你拿到這個消息做數據庫的insert操作。那就容易了，給這個消息做一個唯一主鍵，那么就算出現重復消費的情況，就會導致主鍵沖突，避免數據庫出現臟數據。 二、再比如，你拿到這個消息做redis的set ...

1、在海量訂單產生的業務高峰期，如何避免消息的重復消費問題？ 消費端實現冪等性： 即消費端永遠不會消費多次，即使收到了多條一樣的消息。 2、業界主流冪等性操作 唯一ID + 指紋碼機制，利用數據主鍵去重 利用Redis的原子性去實現 1) 唯一ID + 指紋碼機制 　　唯一ID ...

撰寫中... ...

一、rabbitmq出現消息重復的場景 Broker的消息重新由unack變為ready,並發送給其他消費者 解決方案、 ...