来自JDK1.6中ManagementFactory的托管Mbeans - NotCompliantMBeanException： [英] Managed Mbeans from ManagementFactory in JDK1.6 - NotCompliantMBeanException:

问题描述

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

I was using ManagementFactory to get ManagedMbeans in JDK1.5 and JBOSS 4.X. Now wanted to move my same code to JDK 1.6. The Mbean part breaks throwing the exception

引起：javax.management.NotCompliantMBeanException：类不公开管理接口：java.lang。对象
引起：java.lang.Exception：无法使用JBoss MBeanServer注册平台（JVM）MBean

Caused by: javax.management.NotCompliantMBeanException: Class does not expose a management interface: java.lang.Object Caused by: java.lang.Exception: Unable to register platform (JVM) MBeans with JBoss MBeanServer

推荐答案

这里有两种方法：

1. 使JBossAS 使用平台MBeanServer 。


2. 创建自己的代理，实现MXBean接口（并且具有符合* MBean的名称）接口）并将调用委托给实际的MXBeans。

＃2的示例代码

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

This is a JBoss ServiceMBean implementation that will cross publish platform agent MXBeans to the JBoss MBeanServer. (Imports removed for brevity). It is a slightly different approach to the one I outlined, but spiritually, it is the same. There's a couple of extra hoo-has in there to manage the forwarding of notifications.

package org.helios.jboss.jmx.mxbean;

public class MXBeanPublisher extends ServiceMBeanSupport implements MXBeanPublisherMBean {
    protected final Map<ObjectName, DynamicMBeanNotifEnabled> published = new HashMap<ObjectName, DynamicMBeanNotifEnabled>();
    protected final ExecutorService executor = Executors.newCachedThreadPool();
    public Set<ObjectName> 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<ObjectName, DynamicMBeanNotifEnabled> 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<ObjectName> getPublishedNames();
}

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

This MBean deployment descriptor will deploy the service:

<mbean code="org.helios.jboss.jmx.mxbean.MXBeanPublisher" name="jboss.deployer:service=MXBeanPublisher" />

这篇关于来自JDK1.6中ManagementFactory的托管Mbeans - NotCompliantMBeanException：的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！