記得上一次接觸socket這一塊還是在大三抓耳撓腮的整畢設的時候，兩年後的今天又用到了它，那就把Socket實現組播什麼的做一個記錄吧。

TcpServer

public class TcpServer {
    private static boolean isruning = true;

    public static void main(String[] args) {
        try {
            ServerSocket serverSocket = new ServerSocket(5583);
            while (isruning) {
                // 連線
 

                Socket socket = serverSocket.accept();
                System.out
                        .println("有新客戶端（" + socket.getInetAddress() + "）連線。。");
                OutputStream stream = socket.getOutputStream();
                OutputStreamWriter writer = new OutputStreamWriter(stream);
                writer.write("hello socket!"
 
);
                writer.flush();
                writer.close();
                System.out
                        .println("客戶端（" + socket.getInetAddress() + "）會話結束。。");
            }
            serverSocket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
 

            e.printStackTrace();
        }
    }
}

TcpClient

public class TcpClient {

    public static void main(String[] args) {
        String host = "localhost"; // 要連線的服務端IP地址
        int port = 5583; // 要連線的服務端對應的監聽埠
        try {
            // 與服務端建立連線
            Socket client = new Socket(host, port);
            InputStream inputStream = client.getInputStream();
            InputStreamReader reader = new InputStreamReader(inputStream);
            BufferedReader bufferedReader = new BufferedReader(reader);
            String message = bufferedReader.readLine();
            System.out.println(message);
            bufferedReader.close();
            client.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

UdpSend

public class UdpSend {
    public static void main(String[] args) {
        MulticastSocket socket;
        try {
            socket = new MulticastSocket(8842);
            socket.setTimeToLive(1);
            InetAddress address = InetAddress.getByName("233.0.0.0");
            socket.joinGroup(address);
            byte[] buf = "hello world!".getBytes();
            DatagramPacket p = new DatagramPacket(buf, buf.length, address,
                    8842);
            socket.send(p);
            System.out.println("廣播已經發出");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

UdpReceive

public class UdpReceive {

    public static void main(String[] args) {
        MulticastSocket socket;
        try {
            socket = new MulticastSocket(8842);
            socket.setTimeToLive(1);
            InetAddress address = InetAddress.getByName("233.0.0.0");
            socket.joinGroup(address);
            byte[] buf = new byte[3000];
            DatagramPacket p = new DatagramPacket(buf, buf.length);
            socket.receive(p);
            System.out.println("接受到" + p.getAddress() + "的廣播訊息"
                    + new String(p.getData()));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}