扩展 Spring 的 JMX 支持(2)(3)

 

     

package com.claudeduguay.jmx.demo.client; 



import java.util.*; 



import javax.management.*; 

import javax.management.remote.*; 



public class SpringJmxClient implements NotificationListener 

{ 

  public void handleNotification( 

    Notification notification, Object handback)  

  { 

    System.out.println( 

      "Notification: "   notification.getMessage()); 

  } 

   

  public static void main(String[] args) 

    throws Exception 

  { 

    SpringJmxClient listener = new SpringJmxClient(); 

     

    String address = 

      "service:jmx:rmi:///jndi/rmi://localhost:8999/jmxrmi"; 

    JMXServiceURL serviceURL = new JMXServiceURL(address); 

    Map＜String,Object＞ environment = null; 

    JMXConnector connector = 

      JMXConnectorFactory.connect(serviceURL, environment); 

    MBeanServerConnection mBeanConnection = 

      connector.getMBeanServerConnection(); 

     

    ObjectName exampleServiceName = 

      ObjectName.getInstance("Services:name=ExampleService"); 

    mBeanConnection.addNotificationListener( 

      exampleServiceName, listener, null, null); 

     

    mBeanConnection.invoke( 

      exampleServiceName, "startService", null, null); 

    mBeanConnection.setAttribute(exampleServiceName, 

      new Attribute("propertyValue", "new value")); 

    System.out.println(mBeanConnection.getAttribute( 

      exampleServiceName, "propertyValue")); 

    mBeanConnection.invoke( 

      exampleServiceName, "stopService", null, null); 

  } 

}