JAVA中怎么獲取rabbitmq消息總數

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

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

導入的包是使用：

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消息總數，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注億速云行業資訊頻道。