Springboot整合RabbitMq測試TTL的方法詳解
什么是TTL？
在RabbitMq中，存在一種高級特性 TTL。
TTL即Time To Live的縮寫，含義為存活時間或者過期時間。即：
設定消息在隊列中存活的時間。
當指定時間內(nèi)，消息依舊未被消費，則由隊列自動將其刪除。
如何設置TTL？
既然涉及到設定消息的存活時間，在RabbitMq中，存在兩種設置方式：
- 設置整個隊列的過期時間。
- 設置單個消息的過期時間。
設定整個隊列的過期時間
按照上一篇文章的依賴導入和配置編寫方式進行。
配置類編寫
在原有基礎之上，新創(chuàng)建幾個配置的bean類，申明bean對象，并進行交換機與隊列的關聯(lián)，如下所示：、
package cn.linkpower.config;
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
import java.util.Map;
@Configuration
public class MQConfiguration {
// =========================== Direct 直連模式 ==================================
//隊列名稱
public static final String QUEUQ_NAME = "xiangjiao.queue";
//交換器名稱
public static final String EXCHANGE = "xiangjiao.exchange";
//路由key
public static final String ROUTING_KEY = "xiangjiao.routingKey";
// =========================== Direct 普通隊列申明 和 交換機綁定 ===================
//創(chuàng)建隊列
@Bean(value = "getQueue")
public Queue getQueue(){
//QueueBuilder.durable(QUEUQ_NAME).build();
return new Queue(QUEUQ_NAME);
}
//實例化交換機
@Bean(value = "getDirectExchange")
public DirectExchange getDirectExchange(){
//DirectExchange(String name, boolean durable, boolean autoDelete)
/**
* 參數(shù)一：交換機名稱；<br>
* 參數(shù)二：是否永久；<br>
* 參數(shù)三：是否自動刪除；<br>
*/
//ExchangeBuilder.directExchange(EXCHANGE).durable(true).build();
return new DirectExchange(EXCHANGE, true, false);
//綁定消息隊列和交換機
@Bean
public Binding bindExchangeAndQueue(@Qualifier(value = "getDirectExchange") DirectExchange exchange,
@Qualifier(value = "getQueue") Queue queue){
return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
// =========================== TTL ================================
public static final String ttl_queue_name = "xiangjiao.ttl.queue";
public static final String ttl_exchange_name = "xiangjiao.ttl.exchange";
public static final String ttl_routing_key = "xiangjiao.ttl.routingKey";
@Bean(value = "getTtlQueue")
public Queue getTtlQueue(){
// 設置 ttl 隊列，并設定 x-message-ttl 參數(shù)，表示 消息存活最大時間，單位 ms
//return QueueBuilder.durable(ttl_queue_name).withArgument("x-message-ttl",10000).build();
Map<String, Object> arguments = new HashMap<>();
arguments.put("x-message-ttl",10000);
return new Queue(ttl_queue_name,true,false,false,arguments);
@Bean(value = "getTTlExchange")
public DirectExchange getTTlExchange(){
// 設置交換機屬性，并保證交換機持久化
return new DirectExchange(ttl_exchange_name, true, false);
public Binding bindExchangeAndQueueTTL(@Qualifier(value = "getTTlExchange") DirectExchange getTTlExchange,
@Qualifier(value = "getTtlQueue") Queue queue){
return BindingBuilder.bind(queue).to(getTTlExchange).with(ttl_routing_key);
}對比原有的配置類，不難發(fā)現(xiàn)區(qū)別：
對
隊列設置過期屬性，只需要傳遞一個x-message-ttl的屬性值即可。（單位：ms）
Map<String, Object> arguments = new HashMap<>();
arguments.put("x-message-ttl",10000);
return new Queue(ttl_queue_name,true,false,false,arguments);
然后定義交換機類型，并將指定的交換機和隊列進行綁定。
為了測試效果，暫未定義任何該隊列的消費者信息。
測試
為了便于測試，需要定義一個接口，生產(chǎn)新的數(shù)據(jù)信息，并將數(shù)據(jù)向對應的Exchange中傳遞。
/**
* 發(fā)送消息，指定ttl參數(shù)信息（隊列）
* @return
*/
@RequestMapping("/sendQueueTtl")
@ResponseBody
public String sendQueueTtl(){
//發(fā)送10條消息
for (int i = 0; i < 10; i++) {
String msg = "msg"+i;
System.out.println("發(fā)送消息 msg："+msg);
rabbitmqService.sendMessage(MQConfiguration.ttl_exchange_name,MQConfiguration.ttl_routing_key,msg);
//每兩秒發(fā)送一次
try {
Thread.sleep(8000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return "send ok";
}
兩條消息之間的過期時間為
8s。
請求鏈接進行測試，查看Rabbitmq web視圖信息：
http://localhost/sendQueueTtl
查看控制臺輸出日志：
消息正常發(fā)送到了Exchange，同時Exchange 也將消息推送到了指定的隊列 ！
設置有
Confirm和Return監(jiān)聽。
【說明：】
給隊列設定時間后，單位時間內(nèi)的消息如果未被消費，則隊列會將其中的數(shù)據(jù)進行刪除處理。
對單個消息設定過期時間
上面的操作和測試，已經(jīng)驗證對隊列設定過期時間，會導致所有的消息過期時間都是一樣的現(xiàn)象。
但實際開發(fā)中，可能一個隊列需要存放不同過期時間的消息信息，如果需要進行實現(xiàn)，就不能再設定隊列的過期時間信息了，需要采取下面要說到的針對單個消息，設置不同過期時間。
配置
既然是針對單個消息設定不同的過期時間操作，則需要去掉隊列過期設置。
為了測試的簡單化，此處采取直連 Direct 交換機類型，進行交換機和隊列數(shù)據(jù)的綁定方式。如下所示：
// =========================== Direct 直連模式 ==================================
//隊列名稱
public static final String QUEUQ_NAME = "xiangjiao.queue";
//交換器名稱
public static final String EXCHANGE = "xiangjiao.exchange";
//路由key
public static final String ROUTING_KEY = "xiangjiao.routingKey";
// =========================== Direct 普通隊列申明 和 交換機綁定 ===================
//創(chuàng)建隊列
@Bean(value = "getQueue")
public Queue getQueue(){
//QueueBuilder.durable(QUEUQ_NAME).build();
return new Queue(QUEUQ_NAME);
}
//實例化交換機
@Bean(value = "getDirectExchange")
public DirectExchange getDirectExchange(){
//DirectExchange(String name, boolean durable, boolean autoDelete)
/**
* 參數(shù)一：交換機名稱；<br>
* 參數(shù)二：是否永久；<br>
* 參數(shù)三：是否自動刪除；<br>
*/
//ExchangeBuilder.directExchange(EXCHANGE).durable(true).build();
return new DirectExchange(EXCHANGE, true, false);
}
//綁定消息隊列和交換機
@Bean
public Binding bindExchangeAndQueue(@Qualifier(value = "getDirectExchange") DirectExchange exchange,
@Qualifier(value = "getQueue") Queue queue){
return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
}
對于消息的發(fā)送，依舊沿用之前寫的發(fā)送處理方式
設定
confirm和return監(jiān)聽，保證消息能夠正常到達指定的隊列中。
測試
編寫一個測試的接口，設定單個消息的過期時間屬性，保證不同消息具備不同的過期時間。
在之前博客中，針對消息的持久化設置，需要保證消息向隊列設定屬性時，傳遞一個deliveryMode參數(shù)值信息。
同理，設定每個消息的過期時間，也需要設定對應的屬性信息。如下所示：
/**
* 發(fā)送消息，指定ttl參數(shù)信息（單個消息）;
* 測試需要將消息消費者關閉監(jiān)聽
* @return
*/
@RequestMapping("/sendTtl")
@ResponseBody
public String sendTtl(){
//發(fā)送10條消息
for (int i = 0; i < 10; i++) {
String msg = "msg"+i;
System.out.println("發(fā)送消息 msg："+msg);
MessageProperties messageProperties = new MessageProperties();
messageProperties.setExpiration("5000"); // 針對消息設定時限
// 將消息數(shù)據(jù)和設置屬性進行封裝，采取消息發(fā)送模板，將消息數(shù)據(jù)推送至指定的交換機 exchange 中
Message message = new Message(msg.getBytes(), messageProperties);
rabbitmqService.sendMessage(MQConfiguration.EXCHANGE, MQConfiguration.ROUTING_KEY,message);
//每兩秒發(fā)送一次
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return "send ok";
}
上面代碼的編寫核心為將消息內(nèi)容體和消息對象屬性進行封裝。
MessageProperties messageProperties = new MessageProperties();
messageProperties.setExpiration("5000"); // 針對消息設定時限
// 將消息數(shù)據(jù)和設置屬性進行封裝，采取消息發(fā)送模板，將消息數(shù)據(jù)推送至指定的交換機 exchange 中
Message message = new Message(msg.getBytes(), messageProperties);
引申一點：消息的持久化
Springboot 2.x ——RabbitTemplate為什么會默認消息持久化？
請求連接進行測試：
http://localhost/sendTtl
查看控制臺打印日志情況：
總結
1、設置隊列過期時間使用參數(shù)：x-message-ttl，單位：ms(毫秒)，會對整個隊列消息統(tǒng)一過期。
2、設置消息過期時間使用參數(shù)：expiration。單位：ms(毫秒)，當該消息在隊列頭部時（消費時），會單獨判斷這一消息是否過期。
3、如果兩者都進行了設置，以時間短的為準。
代碼下載
到此這篇關于Springboot整合RabbitMq測試TTL的文章就介紹到這了,更多相關Springboot整合RabbitMq內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
利用Intellij Idea連接遠程服務器實現(xiàn)遠程上傳部署功能
大家在使用Intellij Idea開發(fā)程序的時候，是不是需要部署到遠程SSH服務器運行呢，當然也可以直接在idea軟件內(nèi)容實現(xiàn)配置部署操作，接下來通過本文給大家分享利用Intellij Idea連接遠程服務器實現(xiàn)遠程上傳部署功能，感興趣的朋友跟隨小編一起看看吧2021-05-05
SpringBoot中間件ORM框架實現(xiàn)案例詳解(Mybatis)
這篇文章主要介紹了SpringBoot中間件ORM框架實現(xiàn)案例詳解(Mybatis),本篇文章提煉出mybatis最經(jīng)典、最精簡、最核心的代碼設計，來實現(xiàn)一個mini-mybatis,從而熟悉并掌握ORM框架的涉及實現(xiàn)，需要的朋友可以參考下2023-07-07
在創(chuàng)建新的SpringBoot項目時,始終卡在"正在解析Maven依賴項…",本文小編給大家介紹了幾種相關的解決方案,具有一定的參考價值,需要的朋友可以參考下2023-11-11
SpringBoot中的MongoTemplate的各種條件查詢示例詳解
這篇文章主要介紹了SpringBoot中的MongoTemplate的各種條件查詢示例詳解,本文通過示例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借價值,需要的朋友參考下吧2024-01-01
這篇文章主要為大家詳細介紹了Java23種設計模式中的單例模式，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-02-02
這篇文章主要介紹了Java AES256加密解密示例代碼，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-10-10
這篇文章主要介紹了C++/java 繼承類的多態(tài)詳解及實例代碼的相關資料,需要的朋友可以參考下2017-02-02
springboot+vue實現(xiàn)登錄功能的最新方法整理
最近做項目時使用到了springboot+vue實現(xiàn)登錄功能的技術,所以下面這篇文章主要給大家介紹了關于springboot+vue實現(xiàn)登錄功能的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2022-06-06
這篇文章主要介紹了通過實例了解spring使用構造器注入的原因,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12
Mybatis-Plus開發(fā)提速器generator的使用
本文就介紹這款基于Mybatis-Plus的代碼自助生成器，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-07-07