RabbitMQ如何确保消息的可靠性、幂等处理及消费顺序性？

本文共计1255个文字，预计阅读时间需要6分钟。

RabbitMQ如何确保消息的可靠性？RabbitMQ消息丢失的三种情况及生产者丢弃消息时的解决方案：方法一：生产者在发送数据前开启RabbitMQ的事务（采用事务机制，可降低吞吐量）。

RabbitMQ如何保证消息的可靠性

RabbitMQ消息丢失的三种情况

生产者弄丢消息时的解决方法

• 方法一：生产者在发送数据之前开启RabbitMQ的事务(采用该种方法由于事务机制，会导致吞吐量下降，太消耗性能。)
• 方法二：开启confirm模式(使用springboot时在application.yml配置文件中做如下配置，实现confirm回调接口，生产者发送消息时设置confirm回调)
• 小结： 事务机制和 confirm机制最大的不同在于，事务机制是同步的，你提交一个事务之后会阻塞在那儿，但是 confirm机制是异步的，你发送个消息之后就可以发送下一个消息，RabbitMQ 接收了之后会异步回调confirm接口通知你这个消息接收到了。一般在生产者这块避免数据丢失，建议使用用 confirm 机制。

MQ自身弄丢消息时的解决方法

• 第一步： 创建queue时设置为持久化队列，这样可以保证RabbitMQ持久化queue的元数据，此时还是不会持久化queue里的数据。
• 第二步： 发送消息时将消息的deliveryMode设置为持久化，此时queue中的消息才会持久化到磁盘。