开发者社区> 杨俊明> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

ActiveMQ笔记(5):JMX监控

简介: 系统上线运行后,及时监控报警是很必要的手段,对于ActiveMQ而言,主要监控的指标有:MQ本身的健康状况、每个队列的生产者数量、消费者数量、队列的当前消息数等。 ActiveMQ支持JMX监控,使用步骤如下: 一、修改conf/activemq.
+关注继续查看

系统上线运行后,及时监控报警是很必要的手段,对于ActiveMQ而言,主要监控的指标有:MQ本身的健康状况、每个队列的生产者数量、消费者数量、队列的当前消息数等。

ActiveMQ支持JMX监控,使用步骤如下:

一、修改conf/activemq.xml

<broker … useJmx="true”>
    <managementContext>
        <managementContext createConnector="true" connectorPort=“jmx端口号” connectorHost=“本机ip地址" />         
    </managementContext>
</broker>

二、设置jmx.access、jmx.password的文件权限

chmod 400 conf/jmx.*

(即:将jmx.password, jmx.access这二个文件设置成只读权限,activemq出于安全考虑,要求这二个文件只读)

三、修改bin\activemq 启动shell脚本

找到invoke_start(){ 这段,然后在前面插入:

ACTIVEMQ_CONF=“jmx.password所在位置的物理路目录"
ACTIVEMQ_SUNJMX_START="-Dcom.sun.management.jmxremote.port=端口号 "
ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.password.file=${ACTIVEMQ_CONF}/jmx.password"
ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.access.file=${ACTIVEMQ_CONF}/jmx.access"
ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.ssl=false"

然后重启activemq即可。

然后在jconsole中,可以输入 ip地址:jmx端口号

 

其中username,password即jmx.password中定义的用户名和密码。

四、 spring中使用JMX

    <bean class="org.springframework.jmx.support.MBeanServerConnectionFactoryBean" id="mbeanServerConnection1">
        <property name="serviceUrl" value="${mq_jmx_url1}"/>
        <property name="connectOnStartup" value="false"/>
        <property name="environment">
            <props>
                <prop key="java.naming.security.principal">
                    ${mq_jmx_user1}
                </prop>
                <prop key="java.naming.security.credentials">
                    ${mq_jmx_passwor1}
                </prop>
            </props>
        </property>
    </bean>

其中serviceUrl的值类似:service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi

参考示例:

private List<ActiveMQData> getMonitorDataList(MBeanServerConnection conn, String objectName) {
        List<ActiveMQData> datas = new ArrayList<>();
        try {
            ObjectName objRootName = new ObjectName(objectName);

            String brokerName = (String) conn.getAttribute(objRootName, "BrokerName");
            String brokerId = (String) conn.getAttribute(objRootName, "BrokerId");
            String openWireUrl = (String) conn.getAttribute(objRootName, "OpenWireURL");

            //健康状态
            ObjectName healthObjName = new ObjectName(objectName + ",service=Health");
            String healthStatus = (String) conn.getAttribute(healthObjName, "CurrentStatus");

            //遍历队列
            ObjectName[] objectNames = (ObjectName[]) conn.getAttribute(objRootName, "Queues");
            Arrays.sort(objectNames);

            List<String> blackList = monitorConfig.getQueueBlackList();
            for (ObjectName queueName : objectNames) {
                ...
                Long queueSize = (Long) conn.getAttribute(queueName, "QueueSize");//队列消息数量
                Long producerCount = (Long) conn.getAttribute(queueName, "ProducerCount");//生产者数量
                Long consumerCount = (Long) conn.getAttribute(queueName, "ConsumerCount");//消费者数量
                Long enqueueCount = (Long) conn.getAttribute(queueName, "EnqueueCount");//入队消息总数
                Long dequeueCount = (Long) conn.getAttribute(queueName, "DequeueCount");//出队消息总数
                ...
            }
        } catch (Exception e) {
           ...
        }

        return datas;
    }

其中objectName值,可以在jconsole中查到 

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Qt开发Activex笔记(二):Qt调用Qt开发的Activex控件
Qt开发Activex笔记(二):Qt调用Qt开发的Activex控件
268 0
Qt开发Activex笔记(三):C#调用Qt开发的Activex控件
Qt开发Activex笔记(三):C#调用Qt开发的Activex控件
78 0
C++ activemq CMS 学习笔记
很早前就仓促的接触过activemq,但当时太赶时间.后面发现activemq 需要了解的东西实在是太多了. 关于activemq 一直想起一遍文章.但也一直缺少自己的见解.或许是网上这些文章太多了.也可能是自己知识还不足够.
1426 0
C++ activemq CMS 学习笔记
很早前就仓促的接触过activemq,但当时太赶时间.后面发现activemq 需要了解的东西实在是太多了. 关于activemq 一直想起一遍文章.但也一直缺少自己的见解.或许是网上这些文章太多了.也可能是自己知识还不足够.
2165 0
ActiveMQ笔记(1):编译、安装、示例代码
一、编译 虽然ActiveMQ提供了发布版本,但是建议同学们自己下载源代码编译,以后万一有坑,还可以尝试自己改改源码。 1.1 https://github.com/apache/activemq/releases 到这里下载最新的release版源码(当前最新版本为5.
938 0
孙鑫VC学习笔记:ActiveX 控件 .
孙鑫VC学习笔记:ActiveX 控件 作者:华仔 | 录入时间:2007-12-26 | 点击:313 次    打印此文章 | 字体:大 中 小 基本概念: 容器和服务器程序       容器应用程序时可以嵌入或链接对象的应用程序。
1179 0
+关注
杨俊明
菩提树下的杨过 http://yjmyzz.cnblogs.com/
文章
问答
文章排行榜
最热
最新
相关电子书
更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析
立即下载
Dataflow with Apache NiFi
立即下载
Apache NiFi Crash Course Intro
立即下载