消息中間件:RoketMQ

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