Springboot 2.x RabbitTemplate默认消息持久化的原因解析
前言
之前在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配置，则会出现默认消息持久化的现象。
至于测试案例，可以参考下列博客：
测试现象
首先将消息消费者代码进行注释。执行接口，创建消息存入队列中。
源码分析
要想知道为什么消息会自动持久化，则需要关注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默认消息持久化内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家详细介绍了java实现动态图片效果，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-03-03
这篇文章主要介绍了JavaWeb中Servlet的生命周期及线程安全问题详解,Servlet 生命周期可被定义为从创建直到毁灭的整个过程,Servlet体系结构是建立在Java多线程机制之上的,它的生命周期是由Web容器负责的,需要的朋友可以参考下2024-01-01
Java采用setAsciiStream方法检索数据库指定内容实例解析
这篇文章主要介绍了Java采用setAsciiStream方法检索数据库指定内容,是比较实用的功能,需要的朋友可以参考下2014-08-08
这篇文章主要介绍了spring中的注入list集合问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-11-11
这篇文章主要介绍了Java的Channel通道之FileChannel类详解,FileChannel类是Java NIO中的一个重要类,用于在文件中进行读写操作,它提供了一种高效的方式来处理大文件和随机访问文件的需求,需要的朋友可以参考下2023-10-10
这篇文章主要为大家详细介绍了Java实现滑动验证码生成功能中的后端工具类部分，文中的示例代码讲解详细，感兴趣的小伙伴可以跟随小编一起学习一下2022-10-10
本篇文章主要介绍了Java利用cors实现跨域请求实例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-05-05
这篇文章主要介绍了关于feign接口动态代理源码解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
这篇文章主要介绍了Java 中 Map 集合的三种遍历方式,每种遍历方式结合示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-12-12
Maven打包一般可以生成两种包一种是可以直接运行的包，一种是依赖包（只是编译包）。Maven默认打包时jar，如果需要修改其他类型，可以修改pom.xml。感兴趣的同学可以参考阅读2023-04-04
最新评论