脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → JAVA获取rabbitmq消息总数

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

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

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

您可能感兴趣的文章:

相关文章

  • java的socket请求和响应方式

    java的socket请求和响应方式

    这篇文章主要介绍了java的socket请求和响应方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • Spring Security基于JWT实现SSO单点登录详解

    Spring Security基于JWT实现SSO单点登录详解

    这篇文章主要介绍了Spring Security基于JWT实现SSO单点登录详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-09-09
  • 浅谈Spring Cloud Netflix-Ribbon灰度方案之Zuul网关灰度

    浅谈Spring Cloud Netflix-Ribbon灰度方案之Zuul网关灰度

    这篇文章主要介绍了浅谈Spring Cloud Netflix-Ribbon灰度方案之Zuul网关灰度，想了解Ribbon灰度的同学可以参考下
    2021-04-04
  • Java实现扫雷游戏的代码分享

    Java实现扫雷游戏的代码分享

    windows自带的游戏《扫雷》是陪伴了无数人的经典游戏，本文将利用Java语言实现这一经典的游戏，文中的示例代码讲解详细，感兴趣的可以学习一下
    2022-05-05
  • Java中IdentityHashMap与HashMap区别详解

    Java中IdentityHashMap与HashMap区别详解

    这篇文章主要介绍了Java中IdentityHashMap与HashMap区别详解,很多人不晓得IdentityHashMap的存在,其中不乏工作很多年的Java开发者,他们看到就说是第三方jar包,实际上它是Jdk源码自带的集合类,需要的朋友可以参考下
    2023-11-11
  • Mybatis的一级缓存和二级缓存原理分析与使用

    Mybatis的一级缓存和二级缓存原理分析与使用

    mybatis-plus 是一个 Mybatis 的增强工具，在 Mybatis 的基础上只做增强不做改变，为简化开发、提高效率而生，这篇文章带你了解Mybatis的一级和二级缓存
    2021-11-11
  • 浅谈Spring 的Controller 是单例or多例

    浅谈Spring 的Controller 是单例or多例

    这篇文章主要介绍了浅谈Spring 的Controller 是单例or多例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • 浅谈Spring自定义注解从入门到精通

    浅谈Spring自定义注解从入门到精通

    这篇文章主要介绍了浅谈Spring自定义注解从入门到精通，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-09-09
  • Java 中引入内部类的意义？

    Java 中引入内部类的意义？

    这篇文章主要介绍了Java 中引入内部类的意义？文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，,需要的朋友可以参考下
    2019-06-06
  • 自主配置数据源,mybatis/plus不打印sql日志问题

    自主配置数据源,mybatis/plus不打印sql日志问题

    这篇文章主要介绍了自主配置数据源,mybatis/plus不打印sql日志问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12

最新评论