课程咨询: 400-996-5531 / 投诉建议: 400-111-8989
认真做教育 专心促就业
消息队列机制的使用在许多软件编程开发项目中都是非常常见的一个编程用法,而本文我们就通过案例分析来简单了解一下,消息队列数据丢失原因都有哪些。
生产者丢失数据
先要确保写入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会重新发送消息给消费者。
【免责声明】:本内容转载于网络,转载目的在于传递信息。文章内容为作者个人意见,本平台对文中陈述、观点保持中立,不对所包含内容的准确性、可靠性与完整性提供形式地保证。请读者仅作参考。更多内容请加danei0707学习了解。欢迎关注“达内在线”参与分销,赚更多好礼。