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

目前創(chuàng)新互聯(lián)建站已為上1000+的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)站空間、網(wǎng)站運(yùn)營、企業(yè)網(wǎng)站設(shè)計(jì)、紫金網(wǎng)站維護(hù)等服務(wù)，公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。

首先需要?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)容就是JAVA中怎么獲取rabbitmq消息總數(shù)，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

當(dāng)前名稱：JAVA中怎么獲取rabbitmq消息總數(shù)-創(chuàng)新互聯(lián)
標(biāo)題來源：http://m.jcarcd.cn/article/csdspg.html