0

私はMulticastSocketに取り組んでいます。AIX7でのWebsphere8.0.0.5を使用したテスト。問題は、送信者から間違ったメッセージを受け取ることです。テストシナリオは次のとおりです。1。sendMulticast(新しいスレッド)を実行します。2。receiveMulticast(新しいスレッド)を実行します。3。receiveMulticast(新しいスレッド)を実行します。

最初のレシーバースレッドは常に正しいメッセージを受信します。セカンダリレシーバスレッドが間違ったメッセージを受信します。

しかし、興味深いのは、コンソールアプリケーションとしてJava 6を使用する同じマシン(AIX 7)でこれを試したところ、すべて問題ありません。

コードは次のとおりです。

    static final int port = 9999;
    static final String multicastAddress = "224.2.2.3";


    public static void sendMulticast()  {
        MulticastSocket socket = null;
        DatagramPacket outPacket = null;
        byte[] outBuf;

        long t= System.currentTimeMillis();

        //run 60 seconds
        long end = t+60000;

        try {
            socket = new MulticastSocket();
            String msg;

            while(System.currentTimeMillis() < end) {
                msg = "//172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA";
                outBuf = msg.getBytes();

                InetAddress address = InetAddress.getByName(multicastAddress);
                outPacket = new DatagramPacket(outBuf, outBuf.length, address, port);

                socket.setTimeToLive(32);
                socket.send(outPacket);


                System.out.println("Server sends : " + msg);
                try {
                    Thread.sleep(500);
                } catch (InterruptedException ie) {
                }
            }
        } catch (IOException ioe) {
            ioe.printStackTrace();
        }
        socket.close();
    }


    public static void receiveMulticast() {
        MulticastSocket socket = null;
        DatagramPacket packet = null;
        byte[] inBuf = new byte[1500];

        long t= System.currentTimeMillis();

        //run 60 seconds
        long end = t+60000;

        try {
            // Prepare to join multicast group
            socket = new MulticastSocket(port);
            InetAddress address = InetAddress.getByName(multicastAddress);
            socket.joinGroup(address);

            while(System.currentTimeMillis() < end) {
                packet = new DatagramPacket(inBuf, inBuf.length);
                socket.receive(packet);
                byte[] payload = packet.getData();
                String msg = new String(payload);
                System.out.println("From " + packet.getAddress() + " Msg : " + msg);
            }
        } catch (IOException ioe) {
            ioe.printStackTrace();
        }

        socket.close();
    }

そしてここにログがあります:あなたは10:39:47:675と10:39:48:177で行方不明の文字列がレシーバーに来ているのを見ることができます。

何が問題なのですか?

[2/20/13 10:39:45:162 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:45:163 EET] 0000003b SystemOut     O From /172.21.131.242 Msg : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:45:665 EET] 0000003b SystemOut     O From /172.21.131.242 Msg : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:45:665 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:46:167 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:46:168 EET] 0000003b SystemOut     O From /172.21.131.242 Msg : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:46:672 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:46:673 EET] 0000003b SystemOut     O From /172.21.131.242 Msg : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:47:173 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:47:174 EET] 0000003b SystemOut     O From /172.21.131.242 Msg : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:47:674 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:47:675 EET] 0000003b SystemOut     O From /46.50.52.50 Msg : CE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA131.242:51860/REFERENCE_DATA
[2/20/13 10:39:47:676 EET] 0000003c SystemOut     O From /172.21.131.242 Msg : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:48:176 EET] 0000003a SystemOut     O Server sends : //172.21.131.242:51860/SERVICE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA
[2/20/13 10:39:48:177 EET] 0000003b SystemOut     O From /46.50.52.50 Msg : CE_EXECUTION_CACHE|//172.21.131.242:51860/ERROR_CODES_CACHE|//172.21.131.242:51860/ACCOUNTING_CACHE|//172.21.131.242:51860/CONFIGURATION_ITEMS_CACHE|//172.21.131.242:51860/REFERENCE_DATA131.242:51860/REFERENCE_DATA
4

0 に答える 0