RocketMQ如何保證消息零丟失呢？ Producer消息零丟失的解決方案： 1、事務消息機制：使用事務消息能保證生產者一定會將消息寫入MQ，但是會降低吞吐量。 2、同步消息重試機制：發送同步消息，如果發生異常，則重試，如果重試超過一定次數仍然失敗，則可以先入庫，后續再補 ...

RocketMQ 是一個來自阿里巴巴的分布式消息中間件，於 2012 年開源，並在 2017 年正式成為 Apache 頂級項目。據了解，包括阿里雲上的消息產品以及收購的子公司在內，阿里集團的消息產品全線都運行在 RocketMQ 之上，並且最近幾年的雙十一大促中，RocketMQ 都有搶眼表現 ...

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

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

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

用戶U1從A銀行系統轉賬給B銀行系統的用戶U2的處理過程如下：第一步：A銀行系統生成一條轉賬消息，以事務消息的方式寫入RocketMQ，此時B銀行系統不可見這條消息(Prepare階段) 第二步：寫入MQ成功后，回調A銀行系統，對T1，T2表進行操作（很顯然需要是一個事務）我們重點關注下T2 ...

一、可靠消息最終一致性事務概述 可靠消息最終一致性方案是指當事務發起方執行完成本地事務后並發出一條消息，事務參與方(消息消費者)一定能夠接收消息並處理事務成功，此方案強調的是只要消息發給事務參與方最終事務要達到一致。 此方案是利用消息中間件完成，如下圖：​ 事務發起方（消息生產方）將消息 ...

從“消息”到“消息、事件、流”的大融合 消息隊列作為當代應用的通信基礎設施，微服務架構應用的核心依賴，通過異步解耦能力讓用戶更高效地構建分布式、高性能、彈性健壯的應用程序。 從數據價值和業務價值角度來看，消息隊列的價值不斷深化。消息隊列中流動的業務核心數據涉及集成傳輸、分析計算和處理 ...