RabbitMQ --- 消息可靠性-Toy模板网

这篇具有很好参考价值的文章主要介绍了RabbitMQ --- 消息可靠性。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

消息队列在使用过程中，面临着很多实际问题需要思考：

rabbitmq消息可靠性,RabbitMQ,rabbitmq,分布式

一、消息可靠性

消息从发送，到消费者接收，会经理多个过程：

rabbitmq消息可靠性,RabbitMQ,rabbitmq,分布式

其中的每一步都可能导致消息丢失，常见的丢失原因包括：

针对这些问题，RabbitMQ分别给出了解决方案：

RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程中丢失。这种机制必须给每个消息指定一个唯一ID。消息发送到MQ以后，会返回一个结果给发送者，表示消息是否处理成功。

返回结果有两种方式：

rabbitmq消息可靠性,RabbitMQ,rabbitmq,分布式

首先，修改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：则直接丢弃消息