RmiConnector.java 文件源码

@Override
public JmxConnection connect() {
    try {
        Stopwatch sw = Stopwatch.createStarted();
        // TODO - timeout
        // https://community.oracle.com/blogs/emcmanus/2007/05/23/making-jmx-connection-timeout

        JMXServiceURL jmxUrl = new JMXServiceURL( String.format( "service:jmx:rmi:///jndi/rmi://:%d/jmxrmi", jmxPort ) );
        logger.info( "Connecting to JVM via {}", jmxUrl );

        JMXConnector connector = JMXConnectorFactory.connect( jmxUrl );
        final MBeanServerConnection mbeanServerConnection = connector.getMBeanServerConnection();

        sw.stop();
        logger.info( "Connected to '{}' in {}ms", jmxUrl, sw.elapsed( TimeUnit.MILLISECONDS ) );

        return new JmxConnection( connector, mbeanServerConnection, createConnectionMetaData( jmxPort ) );
    } catch( Exception e ) {
        throw Throwables.propagate( e );
    }
}