RocketMQ：消息存儲

通常來說我們對分佈式隊列有高可靠性的要求，所以數據要進行持久化存儲。 消息生產者發送消息到MQ。 MQ收到消息，將消息進行持久化，即在存儲系統中新增一條記錄。 返回ACK確認消息給生產者。 然後MQ推送消息給對應的消費者，等待消費者返回ACK。 如果消息消費者在指定時間內成功返回ACK，那麼MQ認爲消息消費成功，在存儲系統中刪除消息，即執行第6步；如果MQ在指定時間內沒有收到ACK，則認爲消息消費

>>阅读原文<<