ActiveMQ错误 javax.management.InstanceNotFoundException: org.apache.activemq:brokerName=,type=Broker

青旅半醒 2023-02-14 10:39 101阅读 0赞

> 最近发现环境出现ActiveMQ经常挂，报错的内存溢出，原因差不多应该是队列里面的消费放的太多，内存设置的比较小，因为这个ActiveMQ只是辅助系统运行的，所以也没怎么在意ActiveMQ的设置相关。

### 目的 ###

然后想着希望写个程序或者脚本来监控生产的消息条数，当消息条数超过一次的条数就直接清空，然后发现ActiveMQ可以启动JMX，配置JMX之后就可以连接了。

#### 连接代码 ####

#### 注意点 ####

`String url = "service:jmx:rmi:///jndi/rmi://192.168.1.134:1099/jmxrmi";`这里需要输入自己ActiveMQ的IP和JMX的端口。  
`ObjectName name = new ObjectName("org.apache.activemq:brokerName=localhost,type=Broker");`**这里的localhost是指当前ActiveMQ的节点名称，不是队列名称**，刚开始我输入了的是队列名称，一直报错，brokerName的名字可以在activemq的配置文件里面看，也可以从activemq的控制里面找，如下图。  
还有一个问题就是这里的**brokerName、type**首字母必须小写，  
[ActiveMQ 5.8.0 Release 这个版本修改了名称][ActiveMQ 5.8.0 Release]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzMTYxODg_size_16_color_FFFFFF_t_70]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzMTYxODg_size_16_color_FFFFFF_t_70 1]

public class MonitorActiveMQ { 
    
        public static void main(String[] args) throws Exception { 
            String url = "service:jmx:rmi:///jndi/rmi://192.168.1.134:1099/jmxrmi";
            JMXServiceURL urls = new JMXServiceURL(url);
            JMXConnector connector = JMXConnectorFactory.connect(urls, null);
            connector.connect();
            MBeanServerConnection conn = connector.getMBeanServerConnection();
            ObjectName name = new ObjectName("org.apache.activemq:brokerName=localhost,type=Broker");
            BrokerViewMBean mBean = (BrokerViewMBean) MBeanServerInvocationHandler.newProxyInstance(conn, name, BrokerViewMBean.class, true);
            for (ObjectName na : mBean.getQueues()) { 
                QueueViewMBean queueBean = (QueueViewMBean) MBeanServerInvocationHandler.newProxyInstance(conn, na, QueueViewMBean.class, true);
                System.out.println("******************************");
                System.out.println("队列的名称：" + queueBean.getName());
                System.out.println("队列中剩余的消息数：" + queueBean.getQueueSize());
                System.out.println("消费者数：" + queueBean.getConsumerCount());
                System.out.println("出队列的数量：" + queueBean.getDequeueCount());
                queueBean.purge();
            }
            connector.close();
        }
    }

#### 异常代码 ####

Exception in thread "main" java.lang.reflect.UndeclaredThrowableException
    	at com.sun.proxy.$Proxy0.getQueues(Unknown Source)
    	at com.imobpay.monitor.services.task.MonitorActiveMQ.main(MonitorActiveMQ.java:26)
    Caused by: javax.management.InstanceNotFoundException: org.apache.activemq:brokerName=localhost2,type=Broker
    	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1095)
    	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getAttribute(DefaultMBeanServerInterceptor.java:643)
    	at com.sun.jmx.mbeanserver.JmxMBeanServer.getAttribute(JmxMBeanServer.java:678)
    	at javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImpl.java:1445)
    	at javax.management.remote.rmi.RMIConnectionImpl.access$300(RMIConnectionImpl.java:76)
    	at javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIConnectionImpl.java:1309)
    	at javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMIConnectionImpl.java:1401)
    	at javax.management.remote.rmi.RMIConnectionImpl.getAttribute(RMIConnectionImpl.java:639)
    	at sun.reflect.GeneratedMethodAccessor37.invoke(Unknown Source)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:498)
    	at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:357)
    	at sun.rmi.transport.Transport$1.run(Transport.java:200)
    	at sun.rmi.transport.Transport$1.run(Transport.java:197)
    	at java.security.AccessController.doPrivileged(Native Method)
    	at sun.rmi.transport.Transport.serviceCall(Transport.java:196)
    	at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:573)
    	at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:834)
    	at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:688)
    	at java.security.AccessController.doPrivileged(Native Method)
    	at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:687)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    	at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:283)
    	at sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:260)
    	at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:161)
    	at com.sun.jmx.remote.internal.PRef.invoke(Unknown Source)
    	at javax.management.remote.rmi.RMIConnectionImpl_Stub.getAttribute(Unknown Source)
    	at javax.management.remote.rmi.RMIConnector$RemoteMBeanServerConnection.getAttribute(RMIConnector.java:903)
    	at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:273)
    	... 2 more
    
    Process finished with exit code 1

#### 总结 ####

虽然这个问题挺简单的，面向百度编程也很容易解决，主要是粗心，拷贝也不注意看。

[ActiveMQ 5.8.0 Release]: http://activemq.apache.org/activemq-580-release.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzMTYxODg_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200602151850541.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzMTYxODg=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzMTYxODg_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200602150729921.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzMTYxODg=,size_16,color_FFFFFF,t_70