Springboot?2.x?RabbitTemplate默認(rèn)消息持久化的示例分析

這篇文章主要為大家展示了“Springboot 2.x RabbitTemplate默認(rèn)消息持久化的示例分析”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Springboot 2.x RabbitTemplate默認(rèn)消息持久化的示例分析”這篇文章吧。

前言

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

//消息持久化測試
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;//優(yōu)先級
        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測試

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

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

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

測試現(xiàn)象

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

源碼分析

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

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

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

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

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

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

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

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

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

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

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

聯(lián)想

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

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

以上是“Springboot 2.x RabbitTemplate默認(rèn)消息持久化的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！