JAVA中怎么獲取rabbitmq消息總數(shù)

本篇文章為大家展示了JAVA中怎么獲取rabbitmq消息總數(shù)，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細(xì)介紹希望你能有所收獲。

首先需要創(chuàng)建一個連接，配置文件注入相關(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)建一個type=direct 持久化的 非自動刪除的交換器channel.exchangeDeclare(EXCHANGE_NAME, "direct", true, false, null);

而我使用的是直接創(chuàng)建一個DeclareOK：

String []queues = queueNames.split(",");for(String queue : queues){  DeclareOk declareOk = channel.queueDeclarePassive(queue);  //獲取隊(duì)列中的消息個數(shù)  int num = declareOk.getMessageCount();  if(num > 100) {   //當(dāng)隊(duì)列數(shù)超過100的時候，進(jìn)行操作  }}

這樣就可以根據(jù)獲取到每個隊(duì)列的堆積數(shù)，然后進(jìn)行應(yīng)急處理。

說個題外話：

@Value("${business.consumerQueue}")private String queueNames;String []queues = queueNames.split(",");

在配置文件中配置：business.consumerQueue=nameQueue,numberQueue,phoneQueue

那么獲取到的那個字符串?dāng)?shù)組queues就是為String[3]，其中分別是上述的三個隊(duì)列。

這樣做的話就可以不用改代碼，遵循封閉-開放原則，不用改原來的代碼，只需要修改配置文件中的代碼，用 “,” 相隔開，獲取到需要操作的隊(duì)列名字?jǐn)?shù)組。

上述內(nèi)容就是JAVA中怎么獲取rabbitmq消息總數(shù)，你們學(xué)到知識或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識儲備，歡迎關(guān)注億速云行業(yè)資訊頻道。