当前位置:主页 > java教程 > java获取rabbitmq消息总数详解

java获取rabbitmq消息总数是多少

发布:2019-07-04 11:47:10 123


给大家整理了相关的编程文章,网友郝修谨根据主题投稿了本篇教程内容,涉及到java、rabbitmq、消息总数、java获取rabbitmq消息总数详解相关内容,已被215网友关注,下面的电子资料对本篇知识点有更加详尽的解释。

java获取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理论基础Stream API终端操作示例解析

    java理论基础Stream API终端操作示例解析

    发布:2022-09-07

    给网友朋友们带来一篇关于java的教程,这篇文章主要为大家介绍了java理论基础Stream API终端操作示例解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪


  • 史上最通俗理解的Java死锁代码演示

    发布:2023-01-13

    给网友朋友们带来一篇关于Java的教程,这篇文章主要给大家介绍了关于Java死锁代码演示的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧


  • Java单例模式与破坏单例模式概念原理深入讲解

    发布:2023-03-28

    单例模式(Singleton Pattern)是 Java 中最简单的设计模式之一。这种类型的设计模式属于创建型模式,它提供了一种创建对象的最佳方式。这种模式涉及到一个单一的类,该类负责创建自己的对象,同时确保只有单个对象被创建


  • Java结构型模式之门面模式详解

    发布:2023-03-30

    门面模式又叫外观模式(Facade Pattern),主要用于隐藏系统的复杂性,并向客户端提供了一个客户端可以访问系统的接口,本文通过实例代码给大家介绍下java门面模式的相关知识,感兴趣的朋友一起看看吧


  • Java synchronized同步关键字工作原理

    发布:2023-04-06

    synchronized作为Java程序员最常用同步工具,很多人却对它的用法和实现原理一知半解,以至于还有不少人认为synchronized是重量级锁,性能较差,尽量少用。但不可否认的是synchronized依然是并发首选工具,本文就来详细讲讲


  • 基于Java网上购物系统的设计与实现

    发布:2020-02-19

    这篇文章主要为大家详细介绍了Java购物系统设计与实现,具有一定的参考价值,感兴趣的小伙伴们可以参考一下


  • java agent用法及实例代码

    发布:2019-06-13

    java agent的作用可以在字节码这个层面对类和方法进行修改的技术,能够在不影响编译的情况下,修改字节码。本文主要给大家讲解java agent 使用及实现代码,感兴趣的朋友一起看看吧


  • Java泛型类、泛型方法的理解

    发布:2020-02-27

    这篇文章主要介绍了Java泛型类与泛型方法的定义,结合实例形式详细分析了java泛型类与泛型方法定义、用法及相关操作注意事项,需要的朋友可以参考下


网友讨论