ActiveMQ：如何以编程方式监控嵌入式代理

我想从代码内部监控嵌入式 ActiveMQ 5.8 代理。

• 如何才能做到这一点？
• 我需要 JMX 连接吗？我想防止暴露 JMX
• 有没有办法访问org.apache.activemq.broker.jmx http://activemq.apache.org/maven/5.8.0/apidocs/org/apache/activemq/broker/jmx/package-summary.html没有 JMX 的 Bean？
• 是否有 Hooks、Listeners、Events...可以附加到代理本身？
• 如果这确实是个坏主意，为什么呢？

您可以从具有嵌入式代理的进程内访问所有标准 JMX MBean，而无需创建将它们暴露给外界的 JMX 连接器。首先，您需要告诉嵌入式代理启用 JMX 但不创建连接器。

    brokerService = new BrokerService();
    brokerService.setPersistent(false);
    brokerService.setAdvisorySupport(false);
    brokerService.setSchedulerSupport(true);
    brokerService.setPopulateJMSXUserID(true);
    brokerService.setSchedulerSupport(true);
    brokerService.getManagementContext().setCreateConnector(false);

然后在代码中您可以正常访问 JMS MBean，例如获取 BrokerViewMBean：

protected BrokerViewMBean getProxyToBroker() throws MalformedObjectNameException, JMSException {
    ObjectName brokerViewMBean = new ObjectName(
        "org.apache.activemq:type=Broker,brokerName=localhost");
    BrokerViewMBean proxy = (BrokerViewMBean) brokerService.getManagementContext()
            .newProxyInstance(brokerViewMBean, BrokerViewMBean.class, true);
    return proxy;
}

或者获取 QueueViewMBean：

protected QueueViewMBean getProxyToQueue(String name) throws MalformedObjectNameException, JMSException {
    ObjectName queueViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName="+name);
    QueueViewMBean proxy = (QueueViewMBean) brokerService.getManagementContext()
            .newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true);
    return proxy;
}

类似地还有一个 TopicViewMBean。

protected TopicViewMBean getProxyToTopic(String name) throws MalformedObjectNameException, JMSException {
    ObjectName topicViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Topic,destinationName="+name);
    TopicViewMBean proxy = (TopicViewMBean) brokerService.getManagementContext()
            .newProxyInstance(topicViewMBeanName, TopicViewMBean.class, true);
    return proxy;
}