RabbitMQ在面试的时候，绕不开的问题：

• RabbitMQ如何确保消息发送？消息接收？
• RabbitMQ如何保证消息的可靠性？
• 简述RabbitMQ的持久化机制。

---

网上的一些文章写的非常好：

• 解决RabbitMQ消息丢失问题和保证消息可靠性（一） https://juejin.cn/post/6844903906074427400
• RabbitMQ-如何保证消息在99.99%的情况下不丢失 https://javamana.com/2021/09/20210912132719181S.html
• RabbitMQ使用教程（三）如何保证消息99.99%被发送成功？ https://www.cnblogs.com/zwwhnly/p/10943340.html
• RabbitMQ：怎么保证消息100%被消费？https://juejin.cn/post/7083465447642759175

---

1. 消息丢失的情况

消息丢失的三大方面

2. 如何保证？

a. 生产者生产消息到Broker可靠性保证

• 发送方确认机制（publisher confirm）：串行confirm模式 \ 批量confirm模式 \ 异步confirm模式
• Alternate Exchange
• 实现ReturnCallback接口

b. Broker持久化Exchange, Queue, Message
c. Broker到消费者消息如何不丢

• Consumer端手动确认ack（acknowledge-mode=manual）

3. 生产者生产消息到Broker可靠性保证

关于消息的准备发送，单独写了一篇文章：【RabbitMQ的那点事】如何保证消息的正确发送：https://www.jianshu.com/p/15f0c1a105fb

发送方确认机制（Publisher Confirms）三种模式：同步机制下的串行确认，同步机制下的批量确认，异步确认。
综合对比可以选择异步确认，效率高，异步确认的核心是实现一个ConfirmCallBack的接口，在发送的时候使rabbitTemplate.setConfirmCallback设置自定义的接口后再发送消息。在发送消息的时候还能带上CorrelationData（id），在ConfirmCallBack接口中可以按这个id进行异步消息处理。

Publisher Confirm机制确保的是消息能够正确的发送至Broker，如果此交换器没有匹配的队列的话，那么消息也将会丢失，怎么办？
这里有两个解决方案，

• 利用备份交换机（Alternate Exchange）：实现没有路由到队列的消息
• 使用mandatory 设置true，即在Spring Boot中实现ReturnsCallback接口，并将publisher-returns设为true。

4. 持久化

持久化分三个方面：Exchange, Queue, Message

• 前两个可以在新建的时候选择durable，例如通过UI新建Exchange: Durable Exchange

或者是通过Spring boot代码新建的时候将durable set为true，例如：new DirectExchange("direct.exchange"); 在源码中可以看到第二个参数默认已经是true了。

    public AbstractExchange(String name) {
        this(name, true, false);
    }

Spring boot在新建Queue的时候需要手动set durable参数。

• 关于消息持久化：

官网上关于消息的属性介绍：https://www.rabbitmq.com/publishers.html#message-properties

// 在生产者中，将推送消息时的参数设置为MessageProperties.PERSISTENT_TEXT_PLAIN，就表示消息持久化
channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());

使用Spring Boot后，方法rabbitTemplate.convertAndSend()在发消息时可以set MessageDeliveryMode, 其中NON_PERSISTENT（1）表示非持久化，PERSISTENT（2）表示持久化，而在没有set的情况下，默认为持久化：

@Override
    public BasicProperties fromMessageProperties(final MessageProperties source, final String charset) {
        ...
        MessageDeliveryMode deliveryMode = source.getDeliveryMode();
        if (deliveryMode != null) {
            target.deliveryMode(MessageDeliveryMode.toInt(deliveryMode));
        }
        ...

默认的MessageDeliveryMode：

public class MessageProperties implements Serializable {
   ...
    private MessageDeliveryMode deliveryMode = DEFAULT_DELIVERY_MODE;
    public static final MessageDeliveryMode DEFAULT_DELIVERY_MODE = MessageDeliveryMode.PERSISTENT;
   ...
}

5. 消费端的可靠消费

另写了一篇文章：https://www.jianshu.com/p/e6a22770f178

---

参考：
RabbitMQ 消息可靠性处理：https://www.jianshu.com/p/7999c3e33f45