前言
之前在Java直接测试mq消息持久化时，采取如下的配置实现消息的持久化：
//消息持久化测试
Builder builder = new Builder();
builder.deliveryMode(2);
BasicProperties properties = builder.build();
channel.basicPublish("", queue_name, properties, string.getBytes());
其中针对 BasicProperties 中的源码信息为：
public static class BasicProperties extends
com.rabbitmq.client.impl.AMQBasicProperties {
private String contentType;//消息类型如：text/plain
private String contentEncoding;//编码
private Map<String,Object> headers;
private Integer deliveryMode;//1:nonpersistent 不持久 2:persistent 持久
private Integer priority;//优先级
private String correlationId;
private String replyTo;//反馈队列
private String expiration;//expiration到期时间
private String messageId;
private Date timestamp;
private String type;
private String userId;
private String appId;
private String clusterId;
...
参照博客：消息应答(autoAck)、队列持久化(durable)以及消息持久化
springboot测试
上面的配置是Java直接测试时，所需要编写的代码逻辑，如果采取springboot配置，则会出现 默认消息持久化 的现象。
至于测试案例，可以参考下列博客：
SpringBoot整合RabbitMQ实现消息确认机制
测试现象
首先将 消息消费者 代码进行 注释 。执行接口，创建消息存入队列中。
源码分析
要想知道 为什么消息会自动持久化 ，则需要关注 rabbitTemplate.convertAndSend(exchange,routingKey,msg) 这个方法。
从源码执行逻辑可以看出：
rabbitTemplate 提供的消息加载至队列中，采取的数据类型为 Object ，但在其源码逻辑中，又将 Object 消息类型，进行了 this.convertMessageIfNecessary(object) 处理，将 object 对象类型转化为 Message 对象类型。
从此处可以看出， rabbitTemplate 为了让开发者处理数据更简单，将 消息持久化 等操作默认进行了 配置 。
现在，一起来看 convertMessageIfNecessary(object) 做了什么？
判断当前的数据类型， 是否是Message类型 。
如果是 Message 类型，则直接将其强转 Message 。
如果不是，则执行了新的方法，将其转换了一次。
转换过程如下所示：
后面的就不深入了。那 持久化的默认配置在哪进行的？
回到最初的 convertAndSend 执行方法。
该参数由类创建加载时生成，其数据如下所示：
联想
也就是说，在 convertMessageIfNecessary 时，会判断传递的参数类型是否为 Message 类型，如果不是则需要再包装一次。
如果 不想设定消息持久化 ，传递的数据类型为 Message 类型即可！
到此这篇关于 Springboot 2.x RabbitTemplate默认消息持久化的原因解析的文章就介绍到这了,更多相关Springboot 2.x RabbitTemplate默认消息持久化内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！
原文地址：https://writing-bugs.blog.csdn.net/article/details/122921878
查看更多关于Springboot 2.x RabbitTemplate默认消息持久化的原因解析的详细内容...