RocketMQ消息存儲

一、基本流程 分佈式隊列因爲有高可靠性的要求,所以數據要進行持久化存儲。 消息生成者發送消息 MQ收到消息,將消息進行持久化,在存儲中新增一條記錄 返回 ACK給生產者 MQ push 消息給對應的消費者,然後等待消費者返回 ACK 如果消息消費者在指定時間內成功返回 ACK,那麼 MQ認爲消息消費成功,在存儲中刪除消息,即執行第6步;如果 MQ在指定時間內沒有收到 ACK,則認爲消息消費失敗,會
相關文章
相關標籤/搜索