Socket closed錯誤

幾乎相同的代碼，運行后出現了不同的效果：

代碼1：

接收消息：

package com.wzz.test;

import java.io.*;
import java.net.*;

public class Service {
    public static void main(String[] args) throws IOException {
        DatagramSocket socket = new DatagramSocket(8800);

        while (true){
            //准備接收包裹
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container, 0, container.length);
            socket.receive(packet);//阻塞式接收包裹

            //斷開連接 bye
            String receiveData = new String(packet.getData(), 0, packet.getLength());
            System.out.println(receiveData);
            if (receiveData.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}

發送消息：

package com.wzz.test;

import com.sun.xml.internal.bind.v2.util.ByteArrayOutputStreamEx;
import org.apache.commons.io.IOUtils;

import java.io.*;
import java.net.*;

public class TestThread {
    public static void main(String[] args) throws IOException {
        DatagramSocket socket = new DatagramSocket(9900);

        //准備數據，控制台讀取 System.in
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        while (true){
            String data = reader.readLine();
            byte[] datas = data.getBytes();
            DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, InetAddress.getByName("127.0.0.1"), 8800);

            socket.send(packet);
            if (data.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}

結果：

代碼2：

接收消息：

package com.wzz.A04網絡編程.B05UDPChart;

import java.io.*;
import java.net.*;

public class C02UdpReceive01 {
    public static void main(String[] args) throws IOException {
        DatagramSocket socket = new DatagramSocket(8800);

        while (true){
            //准備接收包裹
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container, 0, container.length);
            socket.receive(packet);//阻塞式接收包裹

            //斷開連接 bye
            String receiveData = new String(packet.getData(), 0, packet.getLength());
            System.out.println(receiveData);

            if (receiveData.equals("bye")){
                break;
            }
            socket.close();
        }
    }
}

發送消息：

package com.wzz.A04網絡編程.B05UDPChart;

import java.io.*;
import java.net.*;

public class C01UdpSender01 {
    public static void main(String[] args) throws IOException {
        DatagramSocket socket = new DatagramSocket(9900);

        //准備數據，控制台讀取 System.in
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        while (true){
            String data = reader.readLine();
            byte[] datas = data.getBytes();
            DatagramPacket packet = new DatagramPacket(datas,0,datas.length, InetAddress.getByName("127.0.0.1"),8800);

            socket.send(packet);
            if (data.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}

結果：

原因分析：

socket 只要在 io流close的情況下 自動關閉，意思就是你想邊發送邊接受最正確的方式就是發送和 接受的操作都做完之后 再一起關閉IO流 完美解決。在代碼2的接收消息中提前將socket關閉，導致Socket closed。

解決方法：

將代碼socked.close();移出while(ture)循環。