博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
使用jolokia api监控ActiveMQ
阅读量:5096 次
发布时间:2019-06-13

本文共 1928 字,大约阅读时间需要 6 分钟。

jolokia api提供了一种通过HTTP访问JMX获得AMQ后台数据的一种方式,即Restful Api

#!/usr/bin/env python# -*- coding:utf-8 -*-import requestsimport jsonimport reimport timeimport sysn = 1while True:    queues = requests.get("http://172.16.1.15:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=activemq_server01/Queues",auth=("admin","admin"))    listQueue = json.loads(queues.content)["value"]    for queue in listQueue:        data = queue['objectName'].encode('unicode-escape').split(r',')[1]        queueName = data.split(r'=')[1]        enqueue1 = requests.get("http://172.16.1.15:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=activemq_server01,destinationType=Queue,destinationName="+queueName+"/EnqueueCount",auth=("admin","admin"))        dequeue1 = requests.get(            "http://172.16.1.15:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=activemq_server01,destinationType=Queue,destinationName=" + queueName + "/DequeueCount",            auth=("admin", "admin"))        queueSize1 = requests.get(            "http://172.16.1.15:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=activemq_server01,destinationType=Queue,destinationName=" + queueName + "/QueueSize",            auth=("admin", "admin"))        consumer1 = requests.get(            "http://172.16.1.15:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=activemq_server01,destinationType=Queue,destinationName=" + queueName + "/ConsumerCount",            auth=("admin", "admin"))        enqueue = json.loads(enqueue1.content)['value']        dequeue = json.loads(dequeue1.content)['value']        queueSize = json.loads(queueSize1.content)['value']        consumer = json.loads(consumer1.content)['value']        print("第%d次采集:%-20s 待消费 %-5d 入队量 %-5d 出队量 %-5d 消费者 %-5d"% (n,queueName,queueSize,enqueue,dequeue,consumer))    n=n+1    time.sleep(5)

  

转载于:https://www.cnblogs.com/Peter2014/p/8404895.html

你可能感兴趣的文章
EOS生产区块:解析插件producer_plugin
查看>>
排球积分程序(三)——模型类的设计
查看>>
HDU 4635 Strongly connected
查看>>
格式化输出数字和时间
查看>>
页面中公用的全选按钮,单选按钮组件的编写
查看>>
java笔记--用ThreadLocal管理线程,Callable<V>接口实现有返回值的线程
查看>>
(旧笔记搬家)struts.xml中单独页面跳转的配置
查看>>
不定期周末福利:数据结构与算法学习书单
查看>>
关于TFS2010使用常见问题
查看>>
URL编码与解码
查看>>
Eclipse 安装SVN插件
查看>>
阿里云服务器CentOS6.9安装Mysql
查看>>
剑指offer系列6:数值的整数次方
查看>>
js 过滤敏感词
查看>>
poj2752 Seek the Name, Seek the Fame
查看>>
软件开发和软件测试,我该如何选择?(蜗牛学院)
查看>>
基本封装方法
查看>>
生活大爆炸之何为光速
查看>>
[Typescript] Specify Exact Values with TypeScript’s Literal Types
查看>>
Illustrated C#学习笔记(一)
查看>>