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)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了java的socket請求和響應(yīng)方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-09-09
Spring Security基于JWT實(shí)現(xiàn)SSO單點(diǎn)登錄詳解
這篇文章主要介紹了Spring Security基于JWT實(shí)現(xiàn)SSO單點(diǎn)登錄詳解，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
淺談Spring Cloud Netflix-Ribbon灰度方案之Zuul網(wǎng)關(guān)灰度
這篇文章主要介紹了淺談Spring Cloud Netflix-Ribbon灰度方案之Zuul網(wǎng)關(guān)灰度，想了解Ribbon灰度的同學(xué)可以參考下2021-04-04
windows自帶的游戲《掃雷》是陪伴了無數(shù)人的經(jīng)典游戲，本文將利用Java語言實(shí)現(xiàn)這一經(jīng)典的游戲，文中的示例代碼講解詳細(xì)，感興趣的可以學(xué)習(xí)一下2022-05-05
Java中IdentityHashMap與HashMap區(qū)別詳解
這篇文章主要介紹了Java中IdentityHashMap與HashMap區(qū)別詳解,很多人不曉得IdentityHashMap的存在,其中不乏工作很多年的Java開發(fā)者,他們看到就說是第三方j(luò)ar包,實(shí)際上它是Jdk源碼自帶的集合類,需要的朋友可以參考下2023-11-11
mybatis-plus 是一個(gè) Mybatis 的增強(qiáng)工具，在 Mybatis 的基礎(chǔ)上只做增強(qiáng)不做改變，為簡化開發(fā)、提高效率而生，這篇文章帶你了解Mybatis的一級和二級緩存2021-11-11
這篇文章主要介紹了淺談Spring 的Controller 是單例or多例，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
這篇文章主要介紹了淺談Spring自定義注解從入門到精通，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
這篇文章主要介紹了Java 中引入內(nèi)部類的意義？文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，,需要的朋友可以參考下2019-06-06
自主配置數(shù)據(jù)源,mybatis/plus不打印sql日志問題
這篇文章主要介紹了自主配置數(shù)據(jù)源,mybatis/plus不打印sql日志問題,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-12-12