2019独角兽企业重金招聘Python工程师标准>>>

头儿让整一个jar包干这活,学了一下rabbitmq,但这东西中文文档很少,就认真读了读官方的英文文档。官方文档提供了两种方法去监控rabbitmq中的信息,一个是web页面形式的,这个只能看,不能用,另一个是linux命令,在/cli目录下的下的一些命令。

当时第一个想法是既然有web,那采用相同的方法去调用,获取数据,后来发现其实底层也是用命令搞的,就放弃了。

然后就去rabbitmq对应的java client api看了看,发现了一个检测队列存活的方法queueDeclarePassive.

 ConnectionFactory factory=new ConnectionFactory();Connection connection;String result = null;try {connection=factory.newConnection(Address.parseAddresses(getHost()));Channel channel=connection.createChannel();//获取队列中的信息数量,用正则表达式完善String queueValue= channel.queueDeclarePassive(queueName).toString();result=this.getResult(queueName,queueValue);channel.close();connection.close();}catch (IOException e){return "fail";//example 1,no queue 2,Connection refused}

同时也发现了个问题。。ConnectionFactory.newConection()默认的guest用户和5672端口,如果自己创建的用户,不知道怎么连接。。。

转载于:https://my.oschina.net/u/1454202/blog/348147

rabbitmq监控queue中message数量相关推荐

  1. MQ介绍,RabbitMQ在SpringAMQP中的使用

    同步调用 优点:时效性强,可以立即得到结果 缺点: 耦合度高,每次加入新需求都要该原来的代码 性能和吞吐能力下降,调用者需要等待提供者响应后才能继续下一步操作 有额外资源消耗,调用者在等待服务响应过程 ...

  2. RabbitMQ指南(中)

    原文出处: Listen 在上一篇文章中,介绍了使用RabbitMQ的Hello World例子, 以及如何创建一个work queue.在work queue的例子中每条消息都只会被传递到一个wor ...

  3. php订单模块解耦,PHP快速使用RabbitMQ实现项目中部分业务的解耦

    PHP快速使用RabbitMQ实现项目中部分业务的解耦 步骤: 1. Linux安装完rabbitMQ后,没有配置文件,需要去github(https://github.com/rabbitmq/ra ...

  4. RabbitMQ的Queue详解;

    一.前言 Queue(队列)是RabbitMQ的内部对象,用于存储消息队列,并将它们转发给消费者: 二.Queue队列 队列跟交换机共享某些属性,但是队列也有一些另外的属性 Name:队列的名称 Du ...

  5. 18_小米监控Open-Falcon:Rabbitmq监控

    小米监控Open-Falcon:Rabbitmq监控 更多干货 分布式实战(干货) spring cloud 实战(干货) mybatis 实战(干货) spring boot 实战(干货) Reac ...

  6. RabbitMQ Exchange Queue RoutingKey BindingKey解析

    许多新手在刚接触RabbitMQ的时候,会被各种名词弄晕,包括ConnectionFactory .Connection .Channel.Exchange.Queue.RoutingKey.Bind ...

  7. Spark Streaming 实时计算在甜橙金融监控系统中的应用、性能优化、任务监控

    1 写在前面 目前公司对实时性计算的需要及应用越来越多,本文选取了其中之一的 Spark Streaming 来介绍如何实现高吞吐量并具备容错机制的实时流应用.在甜橙金融监控系统项目中,需要对每天亿万 ...

  8. Android 中Message,MessageQueue,Looper,Handler详解+实例

    一.几个关键概念 1.MessageQueue:是一种数据结构,见名知义,就是一个消息队列,存放消息的地方.每一个线程最多只可以拥有一个MessageQueue数据结构. 创建一个线程的时候,并不会自 ...

  9. c++ 多key_详解Zabbix自定义Key监控Rabbitmq(监控特定队列)

    概述 今天主要介绍一下zabbix怎么去自定义key来监控rabbitmq队列. 一.环境准备脚本 1.每秒钟插入一个观察队列情况(queues.py) # -*- coding: utf-8 -*- ...

最新文章

  1. python自动测试p-Python自动化测试
  2. php记录代码执行时间
  3. Sichuan University Programming Contest 2011 Preliminary(for Non-SCUers) / M A Simple Problem
  4. springMVC通过spring.xml对属性注入bean值(工厂模式)
  5. 为Windows Server 2012 R2指定授权服务器
  6. myeclipse左侧的目录树没了或不是竖向而是横向显示了
  7. 国士无双:卖掉美国房子,回国创办姚班,他只为培养一流的程序员!
  8. 小程序毕设作品之微信二手交易小程序毕业设计成品(6)开题答辩PPT
  9. 5款常用的数据可视化工具推荐!
  10. SPSS中字符串转为数值后数据消失的解决办法
  11. 国企安逸?我笑了……
  12. Word怎么删除空白页?这3种方法:适用于所有版本Word!
  13. Excel中如何快速地将成绩按比例来划分为等级?
  14. Could not compile initialization script ‘C:\Users\***\AppData\Local\Temp\wrapper_init1.gradle‘.
  15. java json utf-8_java读取json数据发生中文乱码的解决方法
  16. [LiteratureReview]PointNet Deep Learning on Point Sets for 3D Classification and Segmentation
  17. (讲解)用java实现简单选择排序
  18. Arm GPU Mali简介
  19. sql server替换函数
  20. 可以制造各种东西的游戏_制造可怕的东西

热门文章

  1. HTTP之Cookie
  2. A Juggling Algorithm (旋转交换)
  3. linux上TCP connection timeout的原因查找
  4. 高可用集群HA之双机集群
  5. App界面交互设计规范(转)
  6. 20非常有用的Java程序片段(11-15)
  7. 图床上传系统设计分析
  8. PipedInputStream类 和 PipedOutputStream类 的简单介绍和代码演示
  9. 手机发送验证码的业务逻辑探究-主要是安全性,响应性
  10. 框架源码专题:Mybatis启动和执行流程、源码级解析