JMX监测ActiveMQ中队列的状态
ref:
http://activemq.apache.org/jmx.html
http://my.oschina.net/jinghaichao/blog/57318
http://blog.csdn.net/hjxgood/article/details/18706759
1.enable JMX support useJmx="true"
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" useJmx="true">
...
2.enable createConnector,set connectorPort and jmxDomainName
<managementContext>
<managementContext createConnector="true" connectorPort="11099" jmxDomainName="jmx-broker"/>
</managementContext>
3.java code
public class TestMqStatus {
public static void main(String[] args) {
//JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:"+RunServer.connectorPort+RunServer.connectorPath);
JMXServiceURL url;
try {
url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:11099/jmxrmi"); //jmxrmi is connectorPah
JMXConnector connector = JMXConnectorFactory.connect(url, null);
connector.connect();
MBeanServerConnection connection = connector.getMBeanServerConnection();
// 需要注意的是,这里的jmx-broker必须和上面配置的名称相同
//ObjectName name = new ObjectName(RunServer.jmxDomain+":BrokerName=localhost,Type=Broker");
//ObjectName name = new ObjectName("jmx-broker:BrokerName=localhost,Type=Broker");//Windows下不区分大小写
ObjectName name = new ObjectName("jmx-broker:BrokerName=localhost,Type=Broker");//Linux下区分大小写
BrokerViewMBean mBean = (BrokerViewMBean)MBeanServerInvocationHandler.newProxyInstance(connection, name, BrokerViewMBean.class, true);
// System.out.println(mBean.getBrokerName());
for(ObjectName queueName : mBean.getQueues()) {
QueueViewMBean queueMBean = (QueueViewMBean)MBeanServerInvocationHandler.newProxyInstance(connection, queueName, QueueViewMBean.class, true);
System.out.println("\n------------------------------\n");
System.out.println("States for queue --- " + queueMBean.getName());// 消息队列名称
System.out.println("Size --- " + queueMBean.getQueueSize());// 队列中剩余的消息数
System.out.println("Number of consumers --- " + queueMBean.getConsumerCount());// 消费者数
System.out.println("Number of enqueue ---" + queueMBean.getEnqueueCount() );// 入队数
System.out.println("Number of dequeue ---" + queueMBean.getDequeueCount() );// 出队数
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
相关推荐
ActiveMQ_in_Action_中文ActiveMQ_in_Action_中文ActiveMQ_in_Action_中文ActiveMQ_in_Action_中文
activeMQ+spring的简单案例
Habari_ActiveMQ_Client-2.1.rar
ActiveMQ_实践之路(一)ActiveMQ_实践之路(二)ActiveMQ_实践之路(三)ActiveMQ_实践之路(四)
spring集成ActiveMQ的配置过程
activemq与spring的整合 demo 望大家采纳与交流
activemq程序,高效的消息中间件,主要用于异步消息传输
ActiveMQ_使用failover模式进行连接切换时,线程断开 ,ActiveMQ_使用failover模式进行连接切换时,线程断开
ActiveMQ请求应答(request-response)通信DEMO
ActiveMQ_in_Action_中文.zip
activemq生产者,消费者api,以及activemq整合spring配置
activeMQ的demo案例,下载用idea导入即可,记得先把环境搭好,再运行代码喔!重要的就是JMS的开发步骤,一定要好好消化!
ActiveMQ_in_Action.pdf 教程文档
activemq_cpp动态库
ActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action.pdfActiveMQ_in_Action....
利用activeMq实现的消息数据转发服务器端实现
activeMQ开启jmx固定rmi端口,穿透防火墙,用了一天的时间,踩了无数的坑,拿出来共享.
JMS_ActiveMQ_Spring
activemq_CPP_2018最新版本全部所需文件附 expat文件 , 如果不是C++的同学,请绕道.