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

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

首先需要創(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);  //獲取隊列中的消息個數(shù)  int num = declareOk.getMessageCount();  if(num > 100) {   //當(dāng)隊列數(shù)超過100的時候，進(jìn)行操作  }}

這樣就可以根據(jù)獲取到每個隊列的堆積數(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]，其中分別是上述的三個隊列。

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

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

當(dāng)前標(biāo)題：JAVA中怎么獲取rabbitmq消息總數(shù)-創(chuàng)新互聯(lián)
當(dāng)前URL：http://jinyejixie.com/article36/csdspg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站策劃、企業(yè)網(wǎng)站制作、網(wǎng)站內(nèi)鏈、網(wǎng)站營銷、移動網(wǎng)站建設(shè)、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)