import sun.management.jdp.JdpException; //导入依赖的package包/类
private void checkFieldPresence(JdpJmxPacket p)
        throws IOException, JdpException {

    byte[] b = p.getPacketData();

    JdpPacketReader reader = new JdpPacketReader(b);
    Map<String, String> pMap = reader.getDiscoveryDataAsMap();

    get(pMap, JdpJmxPacket.UUID_KEY);
    get(pMap, JdpJmxPacket.MAIN_CLASS_KEY);
    get(pMap, JdpJmxPacket.JMX_SERVICE_URL_KEY);
    // get(pMap, JdpJmxPacket.INSTANCE_NAME_KEY);
    get(pMap, JdpJmxPacket.PROCESS_ID_KEY);
    get(pMap, JdpJmxPacket.BROADCAST_INTERVAL_KEY);
    get(pMap, JdpJmxPacket.RMI_HOSTNAME_KEY);
}
 

import sun.management.jdp.JdpException; //导入依赖的package包/类
public static void compaireJdpPacketEx(JdpJmxPacket p1, JdpJmxPacket p2)
        throws JdpException {

    if (!Objects.equals(p1, p1)) {
        throw new JdpException("Packet mismatch error");
    }

    if (!Objects.equals(p1.getMainClass(), p2.getMainClass())) {
        throw new JdpException("Packet mismatch error (main class)");
    }

    if (!Objects.equals(p1.getInstanceName(), p2.getInstanceName())) {
        throw new JdpException("Packet mismatch error (instance name)");
    }
}
 

import sun.management.jdp.JdpException; //导入依赖的package包/类
private void get(Map<?, ?> map, String key)
        throws JdpException {

    if (map.get(key) == null) {
        throw new JdpException("Test failed, packet field " + key + " missed");
    }
}
 

import sun.management.jdp.JdpException; //导入依赖的package包/类
public static void startFakeDiscoveryService()
        throws IOException, JdpException {

    String discoveryPort = System.getProperty("com.sun.management.jdp.port");
    String discoveryAddress = System.getProperty("com.sun.management.jdp.address");
    InetAddress address = InetAddress.getByName(discoveryAddress);
    int port = Integer.parseInt(discoveryPort);
    JdpController.startDiscoveryService(address, port, "FakeDiscovery", "fake://unit-test");
}
 

import sun.management.jdp.JdpException; //导入依赖的package包/类
public static void compaireJdpPacketEx(JdpJmxPacket p1, JdpJmxPacket p2)
throws JdpException {

    if (!Objects.equals(p1, p1)) {
        throw new JdpException("Packet mismatch error");
    }

    if (!Objects.equals(p1.getMainClass(), p2.getMainClass())) {
        throw new JdpException("Packet mismatch error (main class)");
    }

    if (!Objects.equals(p1.getInstanceName(), p2.getInstanceName())) {
        throw new JdpException("Packet mismatch error (instance name)");
    }
}
 

import sun.management.jdp.JdpException; //导入依赖的package包/类
private static synchronized void startRemoteManagementAgent(String args) throws Exception {
    if (jmxServer != null) {
        throw new RuntimeException(getText(INVALID_STATE, "Agent already started"));
    }

    try {
        Properties argProps = parseString(args);
        configProps = new Properties();

        // Load the management properties from the config file
        // if config file is not specified readConfiguration implicitly
        // reads <java.home>/conf/management/management.properties

        String fname = System.getProperty(CONFIG_FILE);
        readConfiguration(fname, configProps);

        // management properties can be overridden by system properties
        // which take precedence
        Properties sysProps = System.getProperties();
        synchronized (sysProps) {
            configProps.putAll(sysProps);
        }

        // if user specifies config file into command line for either
        // jcmd utilities or attach command it overrides properties set in
        // command line at the time of VM start
        String fnameUser = argProps.getProperty(CONFIG_FILE);
        if (fnameUser != null) {
            readConfiguration(fnameUser, configProps);
        }

        // arguments specified in command line of jcmd utilities
        // override both system properties and one set by config file
        // specified in jcmd command line
        configProps.putAll(argProps);

        // jcmd doesn't allow to change ThreadContentionMonitoring, but user
        // can specify this property inside config file, so enable optional
        // monitoring functionality if this property is set
        final String enableThreadContentionMonitoring =
                configProps.getProperty(ENABLE_THREAD_CONTENTION_MONITORING);

        if (enableThreadContentionMonitoring != null) {
            ManagementFactory.getThreadMXBean().
                    setThreadContentionMonitoringEnabled(true);
        }

        String jmxremotePort = configProps.getProperty(JMXREMOTE_PORT);
        if (jmxremotePort != null) {
            jmxServer = ConnectorBootstrap.
                    startRemoteConnectorServer(jmxremotePort, configProps);

            startDiscoveryService(configProps);
        } else {
            throw new AgentConfigurationError(INVALID_JMXREMOTE_PORT, "No port specified");
        }
    } catch (JdpException e) {
        error(e);
    } catch (AgentConfigurationError err) {
        error(err);
    }
}
 

import sun.management.jdp.JdpException; //导入依赖的package包/类
private static synchronized void startRemoteManagementAgent(String args) throws Exception {
    if (jmxServer != null) {
        throw new RuntimeException(getText(INVALID_STATE, "Agent already started"));
    }

    try {
        Properties argProps = parseString(args);
        configProps = new Properties();

        // Load the management properties from the config file
        // if config file is not specified readConfiguration implicitly
        // reads <java.home>/conf/management/management.properties

        String fname = System.getProperty(CONFIG_FILE);
        readConfiguration(fname, configProps);

        // management properties can be overridden by system properties
        // which take precedence
        Properties sysProps = System.getProperties();
        synchronized (sysProps) {
            configProps.putAll(sysProps);
        }

        // if user specifies config file into command line for either
        // jcmd utilities or attach command it overrides properties set in
        // command line at the time of VM start
        String fnameUser = argProps.getProperty(CONFIG_FILE);
        if (fnameUser != null) {
            readConfiguration(fnameUser, configProps);
        }

        // arguments specified in command line of jcmd utilities
        // override both system properties and one set by config file
        // specified in jcmd command line
        configProps.putAll(argProps);

        // jcmd doesn't allow to change ThreadContentionMonitoring, but user
        // can specify this property inside config file, so enable optional
        // monitoring functionality if this property is set
        final String enableThreadContentionMonitoring =
                configProps.getProperty(ENABLE_THREAD_CONTENTION_MONITORING);

        if (enableThreadContentionMonitoring != null) {
            ManagementFactory.getThreadMXBean().
                    setThreadContentionMonitoringEnabled(true);
        }

        String jmxremotePort = configProps.getProperty(JMXREMOTE_PORT);
        if (jmxremotePort != null) {
            jmxServer = ConnectorBootstrap.
                    startRemoteConnectorServer(jmxremotePort, configProps);

            startDiscoveryService(configProps);
        } else {
            throw new AgentConfigurationError(INVALID_JMXREMOTE_PORT, "No port specified");
        }
    } catch (JdpException e) {
        error(e);
    } catch (AgentConfigurationError err) {
        error(err.getError(), err.getParams());
    }
}