前言

之前在Java直接測(cè)試mq消息持久化時(shí)，采取如下的配置實(shí)現(xiàn)消息的持久化：

//消息持久化測(cè)試
Builder builder = new Builder();
builder.deliveryMode(2);
BasicProperties properties = builder.build();
channel.basicPublish("", queue_name, properties, string.getBytes());

其中針對(duì)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;//優(yōu)先級(jí)
        private String correlationId;
        private String replyTo;//反饋隊(duì)列
        private String expiration;//expiration到期時(shí)間
        private String messageId;
        private Date timestamp;
        private String type;
        private String userId;
        private String appId;
        private String clusterId;
...

參照博客：消息應(yīng)答(autoAck)、隊(duì)列持久化(durable)以及消息持久化

springboot測(cè)試

上面的配置是Java直接測(cè)試時(shí)，所需要編寫的代碼邏輯，如果采取springboot配置，則會(huì)出現(xiàn)默認(rèn)消息持久化的現(xiàn)象。

至于測(cè)試案例，可以參考下列博客：

SpringBoot整合RabbitMQ實(shí)現(xiàn)消息確認(rèn)機(jī)制

測(cè)試現(xiàn)象

首先將消息消費(fèi)者代碼進(jìn)行注釋。執(zhí)行接口，創(chuàng)建消息存入隊(duì)列中。

源碼分析

要想知道為什么消息會(huì)自動(dòng)持久化，則需要關(guān)注rabbitTemplate.convertAndSend(exchange,routingKey,msg)這個(gè)方法。

從源碼執(zhí)行邏輯可以看出：

rabbitTemplate提供的消息加載至隊(duì)列中，采取的數(shù)據(jù)類型為Object，但在其源碼邏輯中，又將Object消息類型，進(jìn)行了this.convertMessageIfNecessary(object)處理，將object對(duì)象類型轉(zhuǎn)化為Message對(duì)象類型。

從此處可以看出，rabbitTemplate為了讓開(kāi)發(fā)者處理數(shù)據(jù)更簡(jiǎn)單，將消息持久化等操作默認(rèn)進(jìn)行了配置。

現(xiàn)在，一起來(lái)看convertMessageIfNecessary(object)做了什么？

判斷當(dāng)前的數(shù)據(jù)類型，是否是Message類型。

如果是Message類型，則直接將其強(qiáng)轉(zhuǎn)Message。
如果不是，則執(zhí)行了新的方法，將其轉(zhuǎn)換了一次。

轉(zhuǎn)換過(guò)程如下所示：

后面的就不深入了。那持久化的默認(rèn)配置在哪進(jìn)行的？

回到最初的convertAndSend執(zhí)行方法。

該參數(shù)由類創(chuàng)建加載時(shí)生成，其數(shù)據(jù)如下所示：

聯(lián)想

也就是說(shuō)，在convertMessageIfNecessary時(shí)，會(huì)判斷傳遞的參數(shù)類型是否為Message類型，如果不是則需要再包裝一次。

如果不想設(shè)定消息持久化，傳遞的數(shù)據(jù)類型為Message類型即可！

到此這篇關(guān)于Springboot 2.x RabbitTemplate默認(rèn)消息持久化的原因解析的文章就介紹到這了,更多相關(guān)Springboot 2.x RabbitTemplate默認(rèn)消息持久化內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！