标签：可靠性 持久 队列 ack RabbitMQ 传输 丢失 消息 生产者
消息丢失分成三种情况，可能出现生产者、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 确认
如果觉得文章对你有帮助的话，请点个推荐吧!
标签：可靠性,持久,队列,ack,RabbitMQ,传输,丢失,消息,生产者 来源： https://www.cnblogs.com/jeremylai7/p/15586970.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。