【RocketMQ】RocketMQ 高可用分析

一、消息存儲機制 1.1 介紹 由於消息隊列有高可靠性的要求,故要對隊列中的數據進行持久化存儲。 如圖: 消息生產者先向 MQ 發送消息 MQ 收到消息,將消息進行持久化,並在存儲系統中新增一條記錄 返回ACK(確認字符)給生產者 MQ 推送消息給對應的消費者,等待消費者返回ACK(確認字符,確認消費) 若這條消息的消費者在等待時間內成功返回ACK,則 MQ 認爲消息消費成功,刪除存儲中的消息 若
相關文章
相關標籤/搜索