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

 更新时间:2019年07月03日 10:23:29   转载 作者:美队大战蜘蛛仔  
这篇文章主要介绍了JAVA获取rabbitmq消息总数过程详解,公司使用的是rabbitMQ,需要做监控预警的job去监控rabbitMQ里面的堆积消息个数,如何使用rabbitMQ获取监控的队列里面的队列消息个数呢,需要的朋友可以参考下

公司使用的是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],其中分别是上述的三个队列。

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

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Springboot2集成pagehelper过程图解

    Springboot2集成pagehelper过程图解

    这篇文章主要介绍了springboot2集成pagehelper过程图解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-03-03
  • 在logback.xml中自定义动态属性的方法

    在logback.xml中自定义动态属性的方法

    这篇文章主要介绍了在logback.xml中自定义动态属性的方法,非常不错,具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-08-08
  • Java实现从jar包中读取指定文件的方法

    Java实现从jar包中读取指定文件的方法

    这篇文章主要介绍了Java实现从jar包中读取指定文件的方法,涉及java针对jar文件的读取及查找相关操作技巧,需要的朋友可以参考下
    2017-08-08
  • Mybatis查询语句结果集的总结大全

    Mybatis查询语句结果集的总结大全

    这篇文章主要给大家总结介绍了关于Mybatis查询语句结果集的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2018-08-08
  • java多线程读写文件示例

    java多线程读写文件示例

    这篇文章主要介绍了java多线程读写文件示例,需要的朋友可以参考下
    2014-04-04
  • SpringMVC结合天气api实现天气查询

    SpringMVC结合天气api实现天气查询

    这篇文章主要为大家详细介绍了SpringMVC结合天气api实现天气查询,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-05-05
  • Java实现文件读取和写入过程解析

    Java实现文件读取和写入过程解析

    这篇文章主要介绍了Java实现文件读取和写入过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值。,需要的朋友可以参考下
    2019-10-10
  • java时间日期使用与查询代码详解

    java时间日期使用与查询代码详解

    这篇文章主要介绍了java时间日期使用与查询代码详解,具有一定借鉴价值,需要的朋友可以参考下。
    2017-11-11
  • 浅谈Java线程Thread之interrupt中断解析

    浅谈Java线程Thread之interrupt中断解析

    这篇文章主要介绍了Java线程Thread之interrupt中断解析,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-01-01
  • java中数组的应用及方法

    java中数组的应用及方法

    本篇文章介绍了,java中数组的应用及方法。需要的朋友参考下
    2013-04-04

最新评论