来自JDK1.6中ManagementFactory的托管Mbeans – NotCompliantMBeanException：

我使用ManagementFactory来获取JDK1.5和JBOSS 4.X中的ManagedMbeans。 现在想将我的相同代码移动到JDK 1.6。 Mbean部分打破抛出exception

引发者：javax.management.NotCompliantMBeanException：Class不公开管理接口：java.lang.Object引发者：java.lang.Exception：无法使用JBoss MBeanServer注册平台（JVM）MBean

Answer 1

这是两种方法：

1. 使JBossAS 使用平台MBeanServer 。
2. 创建自己的代理，实现MXBean接口（并在接口中具有* MBean兼容名称），并将调用委托给实际的MXBeans。

＃2的示例代码

这是一个JBoss ServiceMBean实现，它将平台代理MXBeans发布到JBoss MBeanServer。 （为简洁起见，删除了导入）。 这与我概述的方法略有不同，但在精神上 ，它是相同的。 那里有几个额外的hoo-has来管理通知的转发。

package org.helios.jboss.jmx.mxbean; public class MXBeanPublisher extends ServiceMBeanSupport implements MXBeanPublisherMBean { protected final Map published = new HashMap(); protected final ExecutorService executor = Executors.newCachedThreadPool(); public Set getPublishedNames() { return Collections.unmodifiableSet(published.keySet()); } public static interface DynamicMBeanNotifEnabled extends NotificationBroadcaster, NotificationEmitter, DynamicMBean, NotificationListener { public void startNotifications() throws InstanceNotFoundException; public void stopNotifications() throws InstanceNotFoundException, ListenerNotFoundException; } protected DynamicMBeanNotifEnabled publishMXBean(final ObjectName on, Class iface) throws InstanceAlreadyExistsException, MBeanRegistrationException, NotCompliantMBeanException, InstanceNotFoundException { final MBeanServer platformAgent = ManagementFactory.getPlatformMBeanServer(); DynamicMBeanNotifEnabled dmb = new DynamicMBeanNotifEnabled() { NotificationBroadcasterSupport bcaster = new NotificationBroadcasterSupport(executor); public Object getAttribute(String attribute)throws AttributeNotFoundException, MBeanException, ReflectionException { try { return platformAgent.getAttribute(on, attribute); } catch (InstanceNotFoundException e) { throw new MBeanException(e, "Instance [" + on + "] not found"); } } public void setAttribute(Attribute attribute)throws AttributeNotFoundException, InvalidAttributeValueException, MBeanException, ReflectionException { try { platformAgent.setAttribute(on, attribute); } catch (InstanceNotFoundException e) { throw new MBeanException(e, "Instance [" + on + "] not found"); } } public AttributeList getAttributes(String[] attributes) { try { return platformAgent.getAttributes(on, attributes); } catch (Exception e) { throw new RuntimeException("Failed to getAttributes on [" + on + "]", e); } } public AttributeList setAttributes(AttributeList attributes) { try { return platformAgent.setAttributes(on, attributes); } catch (Exception e) { throw new RuntimeException("Failed to setAttributes on [" + on + "]", e); } } public Object invoke(String actionName, Object[] params,String[] signature) throws MBeanException, ReflectionException { try { return platformAgent.invoke(on, actionName, params, signature); } catch (InstanceNotFoundException e) { throw new MBeanException(e, "Instance [" + on + "] not found"); } } public MBeanInfo getMBeanInfo() { try { return platformAgent.getMBeanInfo(on); } catch (Exception e) { throw new RuntimeException("Failed to get MBeanInfo for Instance [" + on + "]", e); } } public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) { bcaster.addNotificationListener(listener, filter, handback); } public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException { bcaster.removeNotificationListener(listener); } public void removeNotificationListener( NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException { bcaster.removeNotificationListener(listener, filter, handback); } public MBeanNotificationInfo[] getNotificationInfo() { return bcaster.getNotificationInfo(); } public void startNotifications() throws InstanceNotFoundException { ManagementFactory.getPlatformMBeanServer().addNotificationListener(on, this, null, null); } public void stopNotifications() throws InstanceNotFoundException, ListenerNotFoundException { ManagementFactory.getPlatformMBeanServer().removeNotificationListener(on, this, null, null); } @Override public void handleNotification(Notification notification, Object handback) { bcaster.sendNotification(notification); } }; if(server.isRegistered(on)) return null; server.registerMBean(dmb, on); published.put(on, dmb); dmb.startNotifications(); return dmb; } public void startService() throws Exception { try { publishMXBean(new ObjectName(ManagementFactory.OPERATING_SYSTEM_MXBEAN_NAME), OperatingSystemMXBean.class); } catch (Exception e) { log.error("Failed to publish OperatingSystemMXBean", e); }; try { publishMXBean(new ObjectName(ManagementFactory.CLASS_LOADING_MXBEAN_NAME), ClassLoadingMXBean.class); } catch (Exception e) { log.error("Failed to publish ClassLoadingMXBean", e); }; try { publishMXBean(new ObjectName(ManagementFactory.MEMORY_MXBEAN_NAME), MemoryMXBean.class); } catch (Exception e) { log.error("Failed to publish MemoryMXBean", e); }; try { publishMXBean(new ObjectName(ManagementFactory.RUNTIME_MXBEAN_NAME), RuntimeMXBean.class); } catch (Exception e) { log.error("Failed to publish RuntimeMXBean", e); }; try { publishMXBean(new ObjectName(ManagementFactory.THREAD_MXBEAN_NAME), ThreadMXBean.class); } catch (Exception e) { log.error("Failed to publish RuntimeMXBean", e); }; for(GarbageCollectorMXBean gc: ManagementFactory.getGarbageCollectorMXBeans()) { try { publishMXBean(new ObjectName(ManagementFactory.GARBAGE_COLLECTOR_MXBEAN_DOMAIN_TYPE + ",name=" + gc.getName()), GarbageCollectorMXBean.class); } catch (Exception e) { log.error("Failed to publish GarbageCollectorMXBean[" + gc.getName() + "]", e); }; } for(MemoryManagerMXBean mm: ManagementFactory.getMemoryManagerMXBeans()) { try { publishMXBean(new ObjectName(ManagementFactory.MEMORY_MANAGER_MXBEAN_DOMAIN_TYPE + ",name=" + mm.getName()), MemoryManagerMXBean.class); } catch (Exception e) { }; } for(MemoryPoolMXBean mp: ManagementFactory.getMemoryPoolMXBeans()) { try { publishMXBean(new ObjectName(ManagementFactory.MEMORY_POOL_MXBEAN_DOMAIN_TYPE + ",name=" + mp.getName()), MemoryPoolMXBean.class); } catch (Exception e) { log.error("Failed to publish MemoryPoolMXBean[" + mp.getName() + "]", e); }; } } public void stopService() { for(Map.Entry entry: published.entrySet()) { try { server.unregisterMBean(entry.getKey()); } catch (Exception e) {} try { entry.getValue().stopNotifications(); } catch (Exception e) {} } published.clear(); } } 

界面很简单

 package org.helios.jboss.jmx.mxbean; public interface MXBeanPublisherMBean extends ServiceMBean { public Set getPublishedNames(); } 

此MBean部署描述符将部署该服务：