JAVA獲取rabbitmq消息總數(shù)過程詳解

發(fā)布時(shí)間：2020-09-12 13:51:54 來源：腳本之家閱讀：212 作者：美隊(duì)大戰(zhàn)蜘蛛仔欄目：編程語言

公司使用的是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í)有所幫助，也希望大家多多支持億速云。

向AI問一下細(xì)節(jié)

JAVA獲取rabbitmq消息總數(shù)過程詳解

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽