我们在实际使用rocketmq的过程中,一个简单的生产-发送流程大致经过以下步骤

  • 1:生产者调用mq 消息发送api发送消息
  • 2:rocketmq broker接收到消息后,需要对消息落盘,不然的话,broker宕机或者服务器重启就会造成消息丢失
  • 3:消费者从broker端拉取消息消费

image.png

这个过程简单可以概括为:生产-存储-消费。每个阶段都有可能造成消息的丢失

一:消息丢失的场景

image.png

image.png

二:消息丢失解决方案

image.png

Q.E.D.

知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议