RocketMQ消息存储

一、基本流程 分布式队列因为有高可靠性的要求，所以数据要进行持久化存储。 消息生成者发送消息 MQ收到消息，将消息进行持久化，在存储中新增一条记录 返回 ACK给生产者 MQ push 消息给对应的消费者，然后等待消费者返回 ACK 如果消息消费者在指定时间内成功返回 ACK，那么 MQ认为消息消费成功，在存储中删除消息，即执行第6步；如果 MQ在指定时间内没有收到 ACK，则认为消息消费失败，会

>>阅读原文<<