Python 官方文档:入门教程 => 点击学习
目录前言SpringBoot测试测试现象源码分析联想前言 之前在Java直接测试MQ消息持久化时,采取如下的配置实现消息的持久化: //消息持久化测试 Builder builder
之前在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)以及消息持久化
上面的配置是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默认消息持久化内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!
--结束END--
本文标题: Springboot 2.x RabbitTemplate默认消息持久化的原因解析
本文链接: https://www.lsjlt.com/news/140874.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-03-01
2024-03-01
2024-03-01
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0