公司使用的是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进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。