zoukankan      html  css  js  c++  java
  • 使用jolokia api监控ActiveMQ

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

    #!/usr/bin/env python
    # -*- coding:utf-8 -*-
    import requests
    import json
    import re
    import time
    import sys
    n = 1
    while 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)
    

      

  • 相关阅读:
    fused multiply and add
    gcc优化选项解析
    gcc的搜索路径,头文件和库
    使用-Wl直接向ld传递参数
    ldd LD_TRACE_LOADED_OBJECTS
    linux下库的使用
    在RedHat 5下安装Oracle 10g详解(转)
    Centos下安装X Window+GNOME Desktop+FreeNX
    oracle exp direct 执行机制
    详解Oracle的unlimited tablespace系统权限
  • 原文地址:https://www.cnblogs.com/Peter2014/p/8404895.html
Copyright © 2011-2022 走看看