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

消息丢失分成三种情况,可能出现生产者、RabbitMQ、消费者。

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

生产者丢失数据

首先要确保写入 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 确认

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

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zzzzxd.html