Springboot|Springboot 2.x RabbitTemplate默认消息持久化的原因解析 Springboot2.xRabbitTemplate默认消息

前言
springboot测试

测试现象
源码分析

联想

前言之前在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 extendscom.rabbitmq.client.impl.AMQBasicProperties {private String contentType; //消息类型如：text/plainprivate String contentEncoding; //编码private Map 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之手动消息确认(ACK)

测试现象
首先将消息消费者代码进行注释。执行接口，创建消息存入队列中。

Springboot|Springboot 2.x RabbitTemplate默认消息持久化的原因解析

文章图片

文章图片

源码分析
要想知道为什么消息会自动持久化，则需要关注rabbitTemplate.convertAndSend(exchange,routingKey,msg)这个方法。
从源码执行逻辑可以看出：

文章图片

rabbitTemplate提供的消息加载至队列中，采取的数据类型为Object，但在其源码逻辑中，又将Object消息类型，进行了this.convertMessageIfNecessary(object)处理，将object对象类型转化为Message对象类型。

文章图片

从此处可以看出，rabbitTemplate为了让开发者处理数据更简单，将消息持久化等操作默认进行了配置。
现在，一起来看convertMessageIfNecessary(object)做了什么？

文章图片

判断当前的数据类型，是否是Message类型。

如果是Message类型，则直接将其强转Message。
如果不是，则执行了新的方法，将其转换了一次。

转换过程如下所示：

文章图片

文章图片

后面的就不深入了。那持久化的默认配置在哪进行的？
回到最初的convertAndSend执行方法。

文章图片

文章图片

该参数由类创建加载时生成，其数据如下所示：

文章图片

文章图片

联想也就是说，在convertMessageIfNecessary时，会判断传递的参数类型是否为Message类型，如果不是则需要再包装一次。

如果不想设定消息持久化，传递的数据类型为Message类型即可！

【Springboot|Springboot 2.x RabbitTemplate默认消息持久化的原因解析】到此这篇关于Springboot 2.x RabbitTemplate默认消息持久化的原因解析的文章就介绍到这了,更多相关Springboot 2.x RabbitTemplate默认消息持久化内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！