import sun.management.jdp.JdpJmxPacket; //导入依赖的package包/类
public static void printJdpPacket(JdpJmxPacket p) {
    if (getVerbose()) {
        try {
            RandomAccessFile f = new RandomAccessFile("out.dmp", "rw");
            f.write(p.getPacketData());
            f.close();
        } catch (IOException e) {
            System.out.println("Can't write a dump file: " + e);
        }

        System.out.println("Id: " + p.getId());
        System.out.println("Jmx: " + p.getJmxServiceUrl());
        System.out.println("Main: " + p.getMainClass());
        System.out.println("InstanceName: " + p.getInstanceName());
        System.out.println("ProccessId: " + p.getProcessId());
        System.out.println("BroadcastInterval: " + p.getBroadcastInterval());
        System.out.println("Rmi Hostname: " + p.getRmiHostname());

        System.out.flush();
    }
}
 

import sun.management.jdp.JdpJmxPacket; //导入依赖的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.JdpJmxPacket; //导入依赖的package包/类
public static void printJdpPacket(JdpJmxPacket p) {
    if (getVerbose()) {
        try {
            RandomAccessFile f = new RandomAccessFile("out.dmp", "rw");
            f.write(p.getPacketData());
            f.close();
        } catch (IOException e) {
            System.out.println("Can't write a dump file: " + e);
        }

        System.out.println("Id: " + p.getId());
        System.out.println("Jmx: " + p.getJmxServiceUrl());
        System.out.println("Main: " + p.getMainClass());
        System.out.println("InstanceName: " + p.getInstanceName());

        System.out.flush();
    }
}
 

import sun.management.jdp.JdpJmxPacket; //导入依赖的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.JdpJmxPacket; //导入依赖的package包/类
/**
 * Assert that this Jdp packet contains the required two keys.
 * <p/>
 * We expect zero packet corruption and thus fail on the first corrupted packet.
 * This might need revision.
 */
protected Map<String, String> checkStructure(byte[] packet) throws UnsupportedEncodingException {
    Map<String, String> payload = JdpTestUtil.readPayload(packet);
    assertTrue(payload.size() >= 2, "JDP should have minimun 2 entries.");
    assertTrue(payload.get(JdpJmxPacket.UUID_KEY).length() > 0);
    assertTrue(payload.get(JdpJmxPacket.JMX_SERVICE_URL_KEY).length() > 0);
    return payload;
}
 

import sun.management.jdp.JdpJmxPacket; //导入依赖的package包/类
@Test
public void testAllEntries() throws IOException {
    byte[] rawData = createFullPacket().getPacketData();
    Map<String, String> payload = JdpTestUtil.readPayload(rawData);

    assertEquals(4, payload.size());
    assertEquals(mainClass, payload.get(JdpJmxPacket.MAIN_CLASS_KEY));
    assertEquals(id.toString(), payload.get(JdpJmxPacket.UUID_KEY));
    assertEquals(jmxServiceUrl, payload.get(JdpJmxPacket.JMX_SERVICE_URL_KEY));
    assertEquals(instanceName, payload.get(JdpJmxPacket.INSTANCE_NAME_KEY));
}
 

import sun.management.jdp.JdpJmxPacket; //导入依赖的package包/类
public void testDefaultEntries() throws IOException {
    byte[] rawData = createDefaultPacket().getPacketData();
    Map<String, String> payload = JdpTestUtil.readPayload(rawData);

    assertEquals(2, payload.size());
    assertEquals(id.toString(), payload.get(JdpJmxPacket.UUID_KEY));
    assertEquals(jmxServiceUrl, payload.get(JdpJmxPacket.JMX_SERVICE_URL_KEY));
}