java jmx操作示例源码

package jmx; import javax.management.MBeanServerConnection; import javax.management.Notification; import javax.management.NotificationListener; import javax.management.ObjectName; import javax.management.openmbean.CompositeData; import javax.management.openmbean.CompositeDataSupport; import javax.management.openmbean.CompositeType; import javax.management.openmbean.OpenType; import javax.management.openmbean.SimpleType; import javax.management.remote.JMXConnector; import javax.management.remote.JMXConnectorFactory; import javax.management.remote.JMXServiceURL; public class Client implements NotificationListener { public static void main(String[] args) { try { new Client().start(); } catch (Exception e) { e.printStackTrace(); } } public void start() throws Exception { JMXServiceURL url = new JMXServiceURL("service:jmx:rmi://localhost/jndi/rmi://localhost:9999/jmxrmi"); JMXConnector jmxc = JMXConnectorFactory.connect(url, null); MBeanServerConnection server = jmxc.getMBeanServerConnection(); ObjectName mbeanName = new ObjectName("com.example:type=MessageEngine"); server.addNotificationListener(mbeanName, this, null, null); boolean paused = (Boolean)server.getAttribute(mbeanName, "Paused"); System.out.println(paused); if (!paused) { server.invoke(mbeanName, "pause", new Object[]{true}, new String[]{"boolean"}); } CompositeType msgType = new CompositeType("jmx.Message", "Message Class Name", new String[]{"title","body", "by"}, new String[]{"title","body", "by"}, new OpenType[]{SimpleType.STRING,SimpleType.STRING,SimpleType.STRING}); CompositeData msgData = new CompositeDataSupport(msgType, new String[]{"title","body","by"}, new Object[]{"Hello", "This is a new message.", "xpbug"}); server.invoke(mbeanName, "changeMessage", new Object[]{msgData}, new String[]{CompositeData.class.getName()}); server.invoke(mbeanName, "pause", new Object[]{false}, new String[]{"boolean"}); msgData = (CompositeData)server.getAttribute(mbeanName, "Message"); System.out.println("The message changes to:"); System.out.println(msgData.get("title")); System.out.println(msgData.get("body")); System.out.println(msgData.get("by")); Thread.sleep(1000*10); } @Override public void handleNotification(Notification notification, Object handback) { System.out.println("*** Handling new notification ***"); System.out.println("Message: " + notification.getMessage()); System.out.println("Seq: " + notification.getSequenceNumber()); System.out.println("*********************************"); } }