,,

MQ如何實現，消息必達到？

當前位置：點晴教程→知識管理交流 →『技術文檔交流』

admin

2025年1月6日 10:44 本文熱度 954

MQ能不能實現消息必達？

要想消息必達，架構設計上有兩個核心設計點：

1. 消息落地；

2. 消息超時、重傳、確認；

更具體的，要從MQ的架構與流程談起。

MQ的核心架構如何？

如上圖所示，MQ的核心架構圖分為三大塊：

1. 發送方 -> 左側粉色部分；

2. MQ核心集群 -> 中間藍色部分；

3. 接收方 -> 右側黃色部分；

粉色發送方又由兩部分構成：

1. 業務調用方；

2. MQ-client-sender；

其中，后者向前者提供了兩個核心API：

SendMsg(bytes[] msg)

SendCallback()

藍色MQ核心集群由MQ-server，zk，db，管理后臺web等一系列子系統組成。

黃色接收方也由兩部分構成：

1. 業務接收方；

2. MQ-client-receiver

其中，后者向前者也提供了兩個核心API：

RecvCallback(bytes[] msg)

SendAck()

MQ是一個系統間解耦的利器，它能夠很好的解除發布訂閱者之間的耦合，它將上下游的消息投遞解耦成兩個部分，如上述架構圖中的箭頭1和箭頭2：

箭頭1，上半場：發送方將消息投遞給MQ；

箭頭2，下半場：MQ將消息投遞給接收方；

MQ既然將消息投遞拆成了上下半場，為了保證消息的可靠投遞，上下半場都必須盡量保證消息必達。

上半場，消息投遞流程如何？

MQ消息投遞上半場，流程見上圖123：

1. sender將消息發送給MQ-server；

2. MQ-server將消息落地；

3. MQ-server回調sender；

上半場，如果消息丟了怎么辦？

答：超時與重傳。

MQ上半場的123如果丟失或者超時，sender內置的timer會重發消息，直到收到3。如果重傳N次后還未收到3，則SendCallback向業務方回調發送失敗。

下半場，消息投遞流程如何？

MQ消息投遞下半場，流程見上圖456：

4. MQ-server回調reciever；

5. reciever收到消息，處理業務邏輯，將ACK發送給MQ-server；

6. MQ-server收到ACK，將之前已經落地的消息刪除，流程結束；

下半場，如果消息丟了怎么辦？

答：還是超時與重傳。

MQ下半場的456如果丟失或者超時，MQ-server內置的timer會重發消息，直到收到5并且成功執行6。

上下半場都要超時重發，策略如何？

常見的策略有兩種：

1. 定時重發，每隔10秒發一次，直到超出次數；

2. 指數退避，先隔x秒重發，2x秒重發，4x秒重發，以此類推；

總結

1. MQ是系統之間的解耦利器，它能解除消息發送方與接收方的直接耦合；

2. MQ將消息投遞解耦成了上下兩個半場；

3. MQ消息必達，架構上有兩個核心設計點：

- 消息落庫

- 消息超時、重傳、確認

未盡事宜

消息重發可能導致收到重復的消息，如何進行架構冪等性設計，下次撰文另述。

知其然，知其所以然。

思路比結論更重要。

補充閱讀材料：

《MQ系統設計》

https://www.geeksforgeeks.org/message-queues-system-design/

==全文完==

該文章在 2025/1/6 10:44:29 編輯過

關鍵字查詢

實現

消息

正在查詢...

點晴ERP是一款針對中小制造業的專業生產管理軟件系統,系統成熟度和易用性得到了國內大量中小企業的青睞。

點晴PMS碼頭管理系統主要針對港口碼頭集裝箱與散貨日常運作、調度、堆場、車隊、財務費用、相關報表等業務管理，結合碼頭的業務特點，圍繞調度、堆場作業而開發的。集技術的先進性、管理的有效性于一體，是物流碼頭及其他港口類企業的高效ERP管理信息系統。

點晴WMS倉儲管理系統提供了貨物產品管理,銷售管理,采購管理,倉儲管理,倉庫管理,保質期管理,貨位管理,庫位管理,生產管理,WMS管理系統,標簽打印,條形碼,二維碼管理,批號管理軟件。

點晴免費OA是一款軟件和通用服務都免費，不限功能、不限時間、不限用戶的免費OA協同辦公管理系統。

公交车上荫蒂添的好舒服的电影-公用玩物(np双xing总受)-公用小荡货芊芊-公与妇仑乱hd-攻把受做哭边走边肉楼梯play-古装一级淫片a免费播放口

MQ如何實現，消息必達到？