消息队列 避免消息丢失

本文将介绍消息队列中避免消息丢失的方式。

消息从生产到消费共需要经历三个阶段,在这三个阶段中避免消息丢失的方法如下:

  • 生产阶段:通过 ACK 机制确保消息从 Producer 发送到 MQ 中
  • 存储阶段:在存储阶段,可以通过多节点共同存储、落盘等方式避免消息丢失
  • 消费阶段:通过 ACK 机制确保消息已经消费完成,Consumer 应该在执行完所有的消费逻辑后再发送 ACK 确认

参考