消息队列在使用过程中，面临着很多实际问题需要思考：
一、消息可靠性
消息从发送，到消费者接收，会经理多个过程：
其中的每一步都可能导致消息丢失，常见的丢失原因包括：
-
发送时丢失：
-
生产者发送的消息未送达exchange
-
消息到达exchange后未到达queue
-
-
MQ宕机，queue将消息丢失
-
consumer接收到消息后未消费就宕机
针对这些问题，RabbitMQ分别给出了解决方案：
-
生产者确认机制
-
mq持久化
-
消费者确认机制
-
失败重试机制
二、生产者消息确认
RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程中丢失。这种机制必须给每个消息指定一个唯一ID。消息发送到MQ以后，会返回一个结果给发送者，表示消息是否处理成功。
返回结果有两种方式：
-
publisher-confirm，发送者确认
-
消息成功投递到交换机，返回ack
-
消息未投递到交换机，返回nack
-
-
publisher-return，发送者回执
-
消息投递到交换机了，但是没有路由到队列。返回ACK，及路由失败原因。
-
2.1、修改配置
首先，修改publisher服务中的application.yml文件，添加下面的内容：
spring:
rabbitmq:
publisher-confirm-type: correlated
publisher-returns: true
template:
mandatory: true
说明：
-
publish-confirm-type：开启publisher-confirm，这里支持两种类型：-
simple：同步等待confirm结果，直到超时 -
correlated：异步回调，定义ConfirmCallback，MQ返回结果时会回调这个ConfirmCallback
-
-
publish-returns：开启publish-return功能，同样是基于callback机制，不过是定义ReturnCallback -
template.mandatory：定义消息路由失败时的策略。true，则调用ReturnCallback；false：则直接丢弃消息
2.2、定义Return回调
每个RabbitTemplate只能配置一个ReturnCallback，因此需要在项目加载时配置：文章来源：https://www.toymoban.com/news/detail-622077.html
修改publis文章来源地址https://www.toymoban.com/news/detail-622077.html
到了这里，关于RabbitMQ --- 消息可靠性的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
