公司使用的是rabbitMQ,需要做监控预警的工作去监控rabbitMQ里面的堆积消息个数,如何使用rabbitMQ获取监控的队列里面的队列消息个数呢?
首先需要创建一个连接,配置文件注入相关的值,然后设置连接的相关信息,创建链接。
导入的包是使用:
进口com.rabbitmq。客户
@ value (" $ {spring.rabbitmq.host} ")
私人字符串主机;
@ value (" $ {spring.rabbitmq.port} ")
私人整数端口;
@ value (" $ {spring.rabbitmq.username} ")
私人字符串的用户名;
@ value (" $ {spring.rabbitmq.password} ")
私人密码字符串;
ConnectionFactory工厂=new ConnectionFactory ();//设置ip、端口、用户名和秘密
factory.setHost(主机);
factory.setPort(港口);
factory.setUsername(用户名);
factory.setPassword(密码);//创建链接
连接连接=factory.newConnection ();//创建信道
频道频道=connection.createChannel ();//创建一个type=直接持久化的非自动删除的交换器
通道。exchangeDeclare (EXCHANGE_NAME,“直接”,真的,假的,null);
而我使用的是直接创建一个DeclareOK:
String []=queueNames.split队列(",");
(字符串队列:队列){
DeclareOk DeclareOk=channel.queueDeclarePassive(队列);//获取队列中的消息个数
int num=declareOk.getMessageCount ();
如果(num比;100){//当队列数超过100的时候,进行操作
}
}
这样就可以根据获取到每个队列的堆积数,然后进行应急处理。
说个题外话:
@ value (" $ {business.consumerQueue} ")
私人字符串queueNames;
String []=queueNames.split队列(",");
在配置文件中配置:business.consumerQueue=nameQueue numberQueue, phoneQueue
那么获取到的那个字符串数组队列就是为字符串[3],其中分别是上述的三个队列。
这样做的话就可以不用改代码,遵循封闭-开放原则,不用改原来的代码,只需要修改配置文件中的代码,用”、“相隔开,获取到需要操作的队列名字数组。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
