JAVA获取rabbitmq消息总数过程详解

JAVA获取rabbitmq消息总数过程详解

公司使用的是rabbitMQ，需要做监控预警的job去监控rabbitMQ里面的堆积消息个数，如何http://使用rabbitMQ获取监控的队列里面的队列消息个数呢？

首先需要创建一个连接，配置文件注入相关的值，然后设置连接的相关信息，创建链接。

导入的包是使用：

import com.rabbitmq.client

@Value("${spring.rabbitmq.MhpNyYhost}")

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);

factorhttp://y.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){

Declarehttp://Ok 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]，其中分别是上述的三个队列。

这样做的话就可以不用改代码，遵循封闭-开放原则，不用改原来的代码，只需要修改配置文件中的代码，用 “,” 相隔开，获取到需要操作的队列名字数组。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。