ConnectorClientTest.java 文件源码

/**
 * Test perfom operation with connector client through RMI protocol
 */
public Result testRMIConnectorClient() throws Exception {
    try {

        log.info("Create JMX Service URL");
        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi://");

        // Create a JMXConnectorServer
        log.info("Create JMXConnectorServer");
        JMXConnectorServer server = JMXConnectorServerFactory.newJMXConnectorServer(url, enviroment, mbeanServer);

        log.info("Start the server");
        server.start();
        JMXConnector client = server.toJMXConnector(enviroment);

        log.info("Connect client to the server");
        client.connect(enviroment);
        client.getClass();
        log.info("Connection id - " + client.getConnectionId());
        MBeanServerConnection mbsc = client.getMBeanServerConnection();

         //Add than remove notification listener on MBean
        log.info("Add than remove notification listener on MBean");
        Listener listener = new Listener();
        Object obj = new Object();
        NotificationFilterSupport filter = new NotificationFilterSupport();
        client.addConnectionNotificationListener(listener,filter,obj );
        client.removeConnectionNotificationListener(listener);
        client.addConnectionNotificationListener(listener,filter,obj );
        client.removeConnectionNotificationListener(listener,filter,obj );

        log.info("Close client connection");
        client.close();
        log.info("Stop the server");
        server.stop();

    } catch (Exception e) {
        e.printStackTrace();
        return failed("Unexpected exception");
    }

    return result();
}