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

成都創新互聯專注于企業全網整合營銷推廣、網站重做改版、開原網站定制設計、自適應品牌網站建設、H5建站、成都商城網站開發、集團公司官網建設、成都外貿網站建設公司、高端網站制作、響應式網頁設計等建站業務，價格優惠性價比高，為開原等各大城市提供網站開發制作服務。

首先需要創建一個連接，配置文件注入相關的值，然后設置連接的相關信息，創建鏈接。

導入的包是使用：

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();//設置ip，port，用戶名和秘密factory.setHost(host);factory.setPort(port);factory.setUsername(username);factory.setPassword(password); //創建鏈接Connection connection = factory.newConnection(); //創建信道Channel channel = connection.createChannel(); //創建一個type=direct 持久化的 非自動刪除的交換器channel.exchangeDeclare(EXCHANGE_NAME, "direct", true, false, null);

而我使用的是直接創建一個DeclareOK：

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

這樣就可以根據獲取到每個隊列的堆積數，然后進行應急處理。

說個題外話：

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

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

那么獲取到的那個字符串數組queues就是為String[3]，其中分別是上述的三個隊列。

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

上述內容就是JAVA中怎么獲取rabbitmq消息總數，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注創新互聯行業資訊頻道。

網頁標題：JAVA中怎么獲取rabbitmq消息總數
文章源于：http://www.yijiale78.com/article42/pchehc.html

成都網站建設公司_創新互聯，為您提供網站建設、品牌網站設計、軟件開發、標簽優化、做網站、Google

廣告

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