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

网友投稿 898 2022-10-26

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

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

目录前言springboot测试测试现象源码分析联想

前言

之前在java直接测试mq消息持久化时,采取如下的配置实现消息的持久化:

//消息持久化测试

Builder builder = new Builder();

builder.deliveryMode(2);

BasicProperties properties = builder.build();

channel.basicPublish("", queue_name, properties, string.getBytes());

其中WYcCqu针对BasicProperties中的源码信息为:

public static class BasicProperties extends

com.rabbitmq.client.impl.AMQBasicProperties {

private String contentType;//消息类型如:text/plain

private 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实现消息确认机制

测试现象

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

源码分析

要想知道为什么消息会自动持久化,则需要关注rabbitTemplate.convertAndSend(exchange,routingKey,msg)这个方法。

从源码执行逻辑可以看出:

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

从此处可以看出,rabbitTemplate为了让开发者处理数据更简单,将消息持久化等操作默认进行了配置。

现在,一起来看convertMessageIfNecessary(object)做了什么?

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

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

转换过程如下所示:

后面的就不深入了。那持久化的默认配置在哪进行的?

回到最初的convertAndSend执行方法。

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

联想

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

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

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:Deepo- 包含深度学习框架的 Docker 镜像
下一篇:基于token的身份认证 -- jwt实践
相关文章

 发表评论

暂时没有评论,来抢沙发吧~