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
