溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
公司使用的是rabbitMQ，需要做監控預警的job去監控rabbitMQ里面的堆積消息個數，如何使用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]，其中分別是上述的三個隊列。
這樣做的話就可以不用改代碼，遵循封閉-開放原則，不用改原來的代碼，只需要修改配置文件中的代碼，用 “,” 相隔開，獲取到需要操作的隊列名字數組。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
