Java 基於 Socket 實作簡易 UDP 聊天室範例

Java 基於 Socket 實作簡易 UDP 聊天室範例。本站提醒廣大學習愛好者：此文章僅供參考，不一定能完全符合您的需求。以下是完整範例正文

本文範例說明如何使用 Java Socket 實作簡易的 UDP 聊天室。分享給大家供參考。具體實作方式如下：

ChatRoomDemo.java

package com.socket.demo;
import java.io.IOException;
import java.net.DatagramSocket;

public class ChatRoomDemo {
    public static void main(String[] args) throws IOException {
        System.out.println("----進入聊天室----");
        DatagramSocket send = new DatagramSocket();
        DatagramSocket rece = new DatagramSocket(10001);
        new Thread(new SendDemo(send)).start(); // 啟動發送執行緒
        new Thread(new ReceiveDemo(rece)).start(); // 啟動接收執行緒
    }
}

SendDemo.java

package com.socket.demo;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class SendDemo implements Runnable {
    private DatagramSocket ds;

    public SendDemo(DatagramSocket ds) {
        this.ds = ds;
    }

    @Override
    public void run() {
        try {
            BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
            String line = null;
            while ((line = bufr.readLine()) != null) {
                byte[] buf = line.getBytes();
                // 192.168.1.255 為廣播地址，該網段所有主機皆可收到
                DatagramPacket dp = new DatagramPacket(buf, buf.length,
                        InetAddress.getByName("192.168.1.255"), 10001);
                ds.send(dp);
                if ("886".equals(line)) break;
            }
            ds.close();
        } catch (Exception e) {
        }
    }
}

ReceiveDemo.java

package com.socket.demo;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class ReceiveDemo implements Runnable {
    private DatagramSocket ds;

    public ReceiveDemo(DatagramSocket ds) {
        this.ds = ds;
    }

    @Override
    public void run() {
        try {
            while (true) {
                byte[] buf = new byte[1024];
                DatagramPacket dp = new DatagramPacket(buf, buf.length);
                ds.receive(dp); // 阻塞式接收
                String ip = dp.getAddress().getHostAddress();
                int port = dp.getPort();
                System.out.println("----port-----" + port);
                String text = new String(dp.getData(), 0, dp.getLength());
                System.out.println(ip + "::" + text);
                if (text.equals("886")) {
                    System.out.println(ip + "....離開聊天室");
                }
            }
        } catch (Exception e) {
        }
    }
}

執行結果圖如下：

希望本文所述對大家的 Java 程式設計有所幫助。