JAVA獲取rabbitmq消息總數(shù)過程詳解
公司使用的是rabbitMQ，需要做監(jiān)控預(yù)警的job去監(jiān)控rabbitMQ里面的堆積消息個(gè)數(shù)，如何使用rabbitMQ獲取監(jiān)控的隊(duì)列里面的隊(duì)列消息個(gè)數(shù)呢？
首先需要?jiǎng)?chuàng)建一個(gè)連接，配置文件注入相關(guān)的值，然后設(shè)置連接的相關(guān)信息，創(chuàng)建鏈接。
導(dǎo)入的包是使用：
import com.rabbitmq.client
@Value("${spring.rabbitmq.host}")
private String host;
@Value("${spring.rabbitmq.port}")
private Integer port;
@Value("${spring.rabbitmq.username}")
private String username;
@Value("${spring.rabbitmq.password}")
private String password;
ConnectionFactory factory = new ConnectionFactory();
//設(shè)置ip，port，用戶名和秘密
factory.setHost(host);
factory.setPort(port);
factory.setUsername(username);
factory.setPassword(password);
//創(chuàng)建鏈接
Connection connection = factory.newConnection();
//創(chuàng)建信道
Channel channel = connection.createChannel();
//創(chuàng)建一個(gè)type=direct 持久化的 非自動(dòng)刪除的交換器
channel.exchangeDeclare(EXCHANGE_NAME, "direct", true, false, null);
而我使用的是直接創(chuàng)建一個(gè)DeclareOK：
String []queues = queueNames.split(",");
for(String queue : queues){
DeclareOk declareOk = channel.queueDeclarePassive(queue);
//獲取隊(duì)列中的消息個(gè)數(shù)
int num = declareOk.getMessageCount();
if(num > 100) {
//當(dāng)隊(duì)列數(shù)超過100的時(shí)候，進(jìn)行操作
}
}
這樣就可以根據(jù)獲取到每個(gè)隊(duì)列的堆積數(shù)，然后進(jìn)行應(yīng)急處理。
說個(gè)題外話：
@Value("${business.consumerQueue}")
private String queueNames;
String []queues = queueNames.split(",");
在配置文件中配置：business.consumerQueue=nameQueue,numberQueue,phoneQueue
那么獲取到的那個(gè)字符串?dāng)?shù)組queues就是為String[3]，其中分別是上述的三個(gè)隊(duì)列。
這樣做的話就可以不用改代碼，遵循封閉-開放原則，不用改原來的代碼，只需要修改配置文件中的代碼，用 “,” 相隔開，獲取到需要操作的隊(duì)列名字?jǐn)?shù)組。
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
java的log4j框架出現(xiàn)了一個(gè)大漏洞對(duì)服務(wù)器案例引起了不小的影響，如果你使用的是spring框架，用的是logback，不受這個(gè)問題的影響，下面跟著小編看下Java RMI引起的log4j漏洞問題重現(xiàn)，感興趣的朋友一起看看吧2021-12-12
Spring Data MongoDB 數(shù)據(jù)庫批量操作的方法
在項(xiàng)目開發(fā)中經(jīng)常會(huì)批量插入數(shù)據(jù)和更新數(shù)據(jù)的操作，這篇文章主要介紹了Spring Data MongoDB 數(shù)據(jù)庫批量操作的方法，非常具有實(shí)用價(jià)值，需要的朋友可以參考下2018-11-11
這篇文章主要介紹了淺談Java多線程處理中Future的妙用（附源碼），還是比較不錯(cuò)的，需要的朋友可以參考下。2017-10-10
Java數(shù)據(jù)結(jié)構(gòu)中的HashMap和HashSet詳解
HashMap和HashSet都是存儲(chǔ)在哈希桶之中,通過本文我們可以先了解一些哈希桶是什么,本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),需要的朋友參考下吧2023-10-10
本文主要介紹了Java中EnvironmentAware 接口的作用，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06
IDEA運(yùn)行SSM項(xiàng)目的超詳細(xì)圖解教程
SSM項(xiàng)目部署其實(shí)很簡(jiǎn)單,下面這篇文章主要給大家介紹了關(guān)于IDEA運(yùn)行SSM項(xiàng)目的超詳細(xì)圖解教程,文中通過圖文介紹的非常詳細(xì),需要的朋友可以參考下2023-10-10
基于HTML5+js+Java實(shí)現(xiàn)單文件文件上傳到服務(wù)器功能
應(yīng)公司要求，在HTML5頁面上實(shí)現(xiàn)上傳文件到服務(wù)器功能，對(duì)于我這樣的菜鳥，真是把我難住了，最后還是請(qǐng)教大神搞定的，下面小編把例子分享到腳本之家平臺(tái)，供大家參考2017-08-08
里氏代換原則_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要為大家詳細(xì)介紹了里氏代換原則的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-08-08
官宣了最近網(wǎng)傳的Spring漏洞。攻擊者利用該漏洞，可在未授權(quán)的情況下遠(yuǎn)程執(zhí)行命令，今天通過本文給大家普及下漏洞分析影響范圍及解決方案，感興趣的朋友跟隨小編一起看看吧2022-04-04
本篇文章小編為大家介紹，java socket 詳細(xì)介紹。需要的朋友參考下2013-04-04