如何保证消息队列的可靠性传输?

消息丢失分成三种情况,可能出现生产者、RabbitMQ、消费者。
如何保证消息队列的可靠性传输?_第1张图片

生产者丢失数据

首先要确保写入 RabbitMQ 的消息别丢,消息队列通过请求确认机制,保证消息的可靠传输。生产开启 comfirm 模式,在生产者开启 comfirm 模式之后,每次发送消息都会分配一个唯一的id。

  • 如果写入了 RabbitMQ 中,RabbitMQ 会回传一个 ack 消息
  • 如果没能写入 RabbitMQ,会回调一个 nack 接口, 可以重新发送消息

一般在生产者这块避免数据丢失,都是用 confirm 机制的

RabbitMQ丢失数据

RabbitMQ 丢失数据,需要开启 RabbitMQ 持久化,开启持久化之后,生产者发送的消息会持久化到磁盘,RabbitMQ 就算是挂了,恢复启动后也会读取之前存储的数据。
还有一种少见的情况,就是RabbitMQ还没将消息持久化,自己就挂了。这种情况需要生产者那边的确认机制结合起来。只有消息被持久化到磁盘以后,才会回传 ack 消息。生产者没有接收到 ack,也可以自己重发。

消费者丢失数据

消费丢失数据,刚消费到 RabbitMQ 发送的数据,消费进程就挂了,重启进程后,RabbitMQ 也不会重新发送消息。
这个时候需要关闭 RabbitMQ 关闭自动的 ack 机制。每次在消费端处理后,再在程序里做 ack 确认,这样的话,如果没有处理完,就没有 ack 确认,那 RabbitMQ 就认为你还没有处理完,这个时候 RabbitMQ 会重新发送消息给消费者。

总结

  • 生产者
    • 开启确认 comfirm 机制
  • MQ
    • 开启 RabbitMQ 持久化
  • 消费者
    • 关闭RabbitMQ 自动 ack 确认

如果觉得文章对你有帮助的话,请点个推荐吧!

你可能感兴趣的