Java UDP 協議編程實戰：DatagramSocket 與 DatagramPacket 核心 API 深度解析

UDP 協議本質：簡單、不可靠、無連接

• 位置：OSI 第 4 層 (傳輸層)，IP 之上。
• 特徵：無握手、無序列號、無確認、無重傳、無流控、無擁塞控制。**發即棄**，不保證送達、順序、不重複。
• 封包大小：理論最大 65,507 字節 (65,535 - IP頭 20 - UDP頭 8)；**實踐建議 ≤ 1,472 字節 (MTU 1500 - IP/UDP頭) 避免分片**，或應用層自行分片重組。
• 典型場景：即時音視頻 (RTP/RTCP)、遊戲狀態同步、DNS 查詢、SNMP 監控、廣播/組播發現、日志傳輸 (syslog)、IoT 心跳上報。

核心類架構

Socket 構造器選擇指南

// 1. 客戶端/發送端：臨時端口，系統自動分配
DatagramSocket clientSocket = new DatagramSocket();

// 2. 服務端/接收端：固定監聽端口
DatagramSocket serverSocket = new DatagramSocket(9999);

// 3. 多網卡綁定：指定本地 IP (如內網 192.168.1.100 僅接收內網流量)
DatagramSocket multiNicSocket = new DatagramSocket(9999, InetAddress.getByName("192.168.1.100"));

異常處理：端口佔用拋 SocketException，**必須 try-catch 並關閉資源**。

發送端完整代碼

public class UdpSender {
    public static void main(String[] args) throws IOException {
        InetAddress target = InetAddress.getByName("192.168.1.200"); // 目標 IP
        int port = 9999;                                            // 目標端口

        try (DatagramSocket socket = new DatagramSocket()) {       // try-with-resources 自動 close
            String message = "Hello UDP at " + Instant.now();
            byte[] buf = message.getBytes(StandardCharsets.UTF_8);

            DatagramPacket packet = new DatagramPacket(buf, buf.length, target, port);
            socket.send(packet);
            System.out.println("Sent: " + message);
        }
    }
}

接收端完整代碼 (含超時與線程安全)

public class UdpReceiver {
    private static final int PORT = 9999;
    private static final int BUFFER_SIZE = 8192; // 8KB 緩衝區

    public static void main(String[] args) throws IOException {
        try (DatagramSocket socket = new DatagramSocket(PORT)) {
            socket.setSoTimeout(5000); // 5秒無數據拋 SocketTimeoutException，避免永久阻塞
            byte[] buffer = new byte[BUFFER_SIZE];
            DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

            System.out.println("UDP Server listening on port " + PORT);
            while (true) {
                try {
                    socket.receive(packet); // 阻塞直到收到數據
                    int length = packet.getLength();
                    String received = new String(packet.getData(), 0, length, StandardCharsets.UTF_8);
                    InetAddress clientAddr = packet.getAddress();
                    int clientPort = packet.getPort();

                    System.out.printf("From %s:%d - %s%n", clientAddr.getHostAddress(), clientPort, received);

                    // 回射確認 (可選)
                    String ack = "ACK: " + received;
                    byte[] ackBuf = ack.getBytes(StandardCharsets.UTF_8);
                    DatagramPacket ackPacket = new DatagramPacket(ackBuf, ackBuf.length, clientAddr, clientPort);
                    socket.send(ackPacket);

                    // 重置 length 供下次接收 (關鍵！否則後續數據截斷)
                    packet.setLength(BUFFER_SIZE);
                } catch (SocketTimeoutException e) {
                    System.out.println("Heartbeat: no data in 5s, still alive...");
                }
            }
        }
    }
}

關鍵細節：緩衝區重用與長度重置

DatagramPacket 內部維護 offset 和 length。**接收後必須 packet.setLength(buffer.length) 重置**，否則下次接收數據長度受限於上次實際長度，導致數據截斷 Bug。**生產環境建議每次接收 new DatagramPacket() 或顯式重置**。

進階主題

連接模式 socket.connect(address, port)

• UDP 本無連接，但 connect() 將 Socket 綁定到特定遠端地址/端口。
• 後續 send(packet) **無需在 Packet 中指定地址/端口**，內部自動填充。
• receive() **只接收該遠端發來的數據**，自動過濾其他來源 (內核級過濾，性能優於應用層判斷)。
• 適用於**客戶端長期與固定服務端通信**場景。

廣播與組播

// 廣播發送 (需網卡支持、路由器允許)
socket.setBroadcast(true);
InetAddress broadcastAddr = InetAddress.getByName("255.255.255.255"); // 或子網廣播 192.168.1.255
DatagramPacket bcPacket = new DatagramPacket(buf, buf.length, broadcastAddr, PORT);
socket.send(bcPacket);

// 組播加入 (IGMP)
InetAddress group = InetAddress.getByName("239.255.0.1");
NetworkInterface ni = NetworkInterface.getByInetAddress(InetAddress.getLocalHost());
MulticastSocket ms = new MulticastSocket(PORT);
ms.joinGroup(new InetSocketAddress(group, PORT), ni);
// 接收組播數據...
ms.leaveGroup(new InetSocketAddress(group, PORT), ni);

可靠性補償：應用層實現

• 序列號 + ACK + 重傳：簡易可靠 UDP (RUDP)。
• FEC (前向糾錯)：冗余編碼 (Reed-Solomon/RaptorQ)，接收端自動恢復丟包，**零 RTT 延遲**，適合直播/視頻會議。
• QUIC / HTTP/3：基於 UDP 實現可靠、有序、多路復用、加密傳輸，**現代可靠傳輸首選**。

總結

Java UDP 編程核心三件套：**InetAddress 定址、DatagramSocket 端點、DatagramPacket 載體**。掌握要點：

1. 無連接 = 自己負責可靠性：序列號、ACK、重傳、FEC、冪等設計。
2. 緩衝區重用必重置 length：packet.setLength(buf.length) 避免截斷。
3. 超時機制防阻塞死循環：setSoTimeout() + 捕獲 SocketTimeoutException。
4. 連接模式簡化固定對端通信：connect() 內核過濾 + 發送簡化。
5. 大數據分片 / MTU 感知：應用層分片重組，避免 IP 分片丟包導致整包丟失。

UDP 以**極致簡單**換取**極致可控**，是高性能網絡編程的基石。理解其語義邊界，才能在 QUIC、gRPC、WebRTC、IoT 協議棧中游刃有餘。