标签：其他 功能 contex host exception 应该 gets rip 导入
近期项目中应用到了ActiveMQ，本次和大家分享下ActiveMQ的远程监控，希望对大家有帮助。
因某需求，需要获取一个队列（Queue）下有几个消费者，及每个消费者的使用情况。
找了很久没找到资料，后来发现官方提供的管理界面上有类似功能，真是踏破铁鞋无觅处，问题搞定了哈哈哈
然而……我需要是获取消费者的代码，光有界面有个毛用；然后我想到官方既然提供了界面，那肯定也是个web工程；就在安装目录下有个webapps的项目，就是管理界面的web工程。
导入web项目一番寻找后，终于锁定了一个类RemoteJMXBrokerFacade，能够获取某个队列下的消费者情况。
springboot如何整合activemq的不说明了，不懂的童鞋请自行百度哈。
RemoteJMXBrokerFacade类需要引入activemq-web包，但是此包依赖了一大堆其他的东东，用<exclusions>排除掉就可以了。
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-web</artifactId>
<exclusions>
<exclusion>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
</exclusion>
<exclusion>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-continuation</artifactId>
</exclusion>
<exclusion>
<groupId>org.eclipse.jetty.websocket</groupId>
<artifactId>websocket-server</artifactId>
</exclusion>
</exclusions>
</dependency>
在安装目录的conf路径下找到activemq.xml
打开文件，找到managementContext并修改为true；看注释的意思应该就是暴露一个JMX端口来监控ActiveMQ，默认端口1099
<!-- The managementContext is used to configure how ActiveMQ is exposed in JMX. By default, ActiveMQ uses the MBean server that is started by the JVM. For more information, see: http://activemq.apache.org/jmx.html --> <managementContext> <managementContext createConnector="true"/> </managementContext>
@Configuration @EnableJms public class JmsConfiguration { @Bean public RemoteJMXBrokerFacade remoteJMXBrokerFacade() { RemoteJMXBrokerFacade brokerFacade = new RemoteJMXBrokerFacade(); System.setProperty("webconsole.jmx.url", "service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi"); SystemPropertiesConfiguration configuration = new SystemPropertiesConfiguration(); brokerFacade.setConfiguration(configuration); return brokerFacade; } }
@Resource private RemoteJMXBrokerFacade brokerFacade; public void test() throws Exception { QueueConsumerQuery consumerQuery = new QueueConsumerQuery(brokerFacade); consumerQuery.setJMSDestination("test.queue"); Collection<SubscriptionViewMBean> consumers = consumerQuery.getConsumers(); for(SubscriptionViewMBean consumer : consumers) { System.out.println("消费者信息：" + consumer.getConnectionId() + " " + consumer.getSelector()); } }
这样就能以代码的形式监控ActiveMQ，获取消费者的情况；消费者的其他信息请查看SubscriptionViewMBean的源码。
标签：其他 功能 contex host exception 应该 gets rip 导入
原文地址：https://www.cnblogs.com/ZRyouChin/p/10073977.html
