【RocketMQ】RocketMQ 高可用分析

一、消息存储机制 1.1 介绍 由于消息队列有高可靠性的要求，故要对队列中的数据进行持久化存储。 如图： 消息生产者先向 MQ 发送消息 MQ 收到消息，将消息进行持久化，并在存储系统中新增一条记录 返回ACK(确认字符)给生产者 MQ 推送消息给对应的消费者，等待消费者返回ACK(确认字符，确认消费) 若这条消息的消费者在等待时间内成功返回ACK，则 MQ 认为消息消费成功，删除存储中的消息 若

>>阅读原文<<