消息中间件：RoketMQ

通常来说我们对分布式队列有高可靠性的要求，所以数据要进行持久化存储。 消息生产者发送消息到MQ。 MQ收到消息，将消息进行持久化，即在存储系统中新增一条记录。 返回ACK确认消息给生产者。 然后MQ推送消息给对应的消费者，等待消费者返回ACK。 如果消息消费者在指定时间内成功返回ACK，那么MQ认为消息消费成功，在存储系统中删除消息，即执行第6步；如果MQ在指定时间内没有收到ACK，则认为消息消费

>>阅读原文<<