Java UDP 網路程式設計完整指南：DatagramSocket 與 DatagramPacket 實戰

UDP 協議基礎認知

什麼是 UDP？

UDP (User Datagram Protocol，用戶資料報協議) 工作於 OSI 第 4 層 (傳輸層)，位於 IP 協議之上。特點：

• 無連線：無需建立連線即可發送資料
• 不可靠：不保證送達、不重傳、不排序、不流控
• 低延遲、低開銷：無連線建立/維護成本，適合即時性要求高、容忍丟包的場景

適用場景

• 即時音視訊串流 (VoIP、視訊會議、直播)
• 遊戲狀態同步 (位置、動作等高頻小封包)
• DNS 查詢、SNMP 監控、DHCP
• 廣播/多播通訊
• 日誌/遙測資料傳輸 (允許丟失)

不適用：檔案傳輸、金融交易、指令控制等要求可靠交付的場景。

Java 核心 API：java.net 套件

InetAddress：IP 位址封裝

DatagramSocket：收發端點

建構子：

• DatagramSocket()：客戶端模式，系統分配臨時埠口
• DatagramSocket(int port)：伺服器模式，綁定固定埠口
• DatagramSocket(int port, InetAddress localAddr)：多網卡環境指定綁定介面

核心方法：

異常處理：建構子可能拋出 SocketException (埠口衝突/權限不足)，必須捕獲。

DatagramPacket：資料封包

發送用建構子：

• DatagramPacket(byte[] buf, int length, InetAddress addr, int port)
• DatagramPacket(byte[] buf, int offset, int length, InetAddress addr, int port)

接收用建構子：

• DatagramPacket(byte[] buf, int length)
• DatagramPacket(byte[] buf, int offset, int length)

重要限制：

• 理論最大 65,507 位元組 (IPv4)，實務建議 ≤ 8KB 避免分片
• getData() 取得原始位元組陣列
• getLength()/getOffset() 取得有效資料範圍

完整範例：UDP 時間伺服器與客戶端

伺服器端 (TimeServer.java)

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

public class TimeServer {
    final private static int DAYTIME_PORT = 13;

    public static void main(String args[]) throws IOException {
        DatagramSocket socket = new DatagramSocket(DAYTIME_PORT);
        System.out.println("Time Server started on port " + DAYTIME_PORT);

        while (true) {
            byte buffer[] = new byte[256];
            DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
            socket.receive(packet); // 阻塞等待請求

            String date = new Date().toString();
            buffer = date.getBytes();

            // 從請求封包取得客戶端位址/埠口回覆
            InetAddress address = packet.getAddress();
            int port = packet.getPort();
            packet = new DatagramPacket(buffer, buffer.length, address, port);
            socket.send(packet);
        }
    }
}

客戶端 (GetTime.java)

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

public class GetTime {
    final private static int DAYTIME_PORT = 13;

    public static void main(String args[]) throws IOException {
        if (args.length == 0) {
            System.err.println("Usage: java GetTime ");
            System.exit(-1);
        }

        String host = args[0];
        byte message[] = new byte[256];
        InetAddress address = InetAddress.getByName(host);
        System.out.println("Querying: " + address);

        DatagramPacket packet = new DatagramPacket(message, message.length, address, DAYTIME_PORT);
        DatagramSocket socket = new DatagramSocket(); // 臨時埠口
        socket.send(packet);

        packet = new DatagramPacket(message, message.length);
        socket.receive(packet); // 阻塞等待回覆

        String time = new String(packet.getData(), 0, packet.getLength());
        System.out.println("Time at " + host + " is: " + time);
        socket.close();
    }
}

進階主題與最佳實踐

1. 非阻塞/多執行緒架構

生產環境建議使用 NIO DatagramChannel 或執行緒池處理並發請求，避免單執行緒阻塞成為瓶頸。

2. 可靠性補強模式

• 應用層 ACK/重傳：關鍵資料加入序號、ACK 機制
• 冗餘發送：重要封包重複發送 2-3 次
• FEC (前向錯誤修正)：音視訊常用

3. 廣播與多播

// 廣播
socket.setBroadcast(true);
InetAddress broadcast = InetAddress.getByName("255.255.255.255");
socket.send(new DatagramPacket(data, data.length, broadcast, port));

// 多播
InetAddress group = InetAddress.getByName("239.255.0.1");
MulticastSocket ms = new MulticastSocket(port);
ms.joinGroup(group);
// 收發使用 ms
ms.leaveGroup(group);

4. 緩衝區大小調優

socket.setReceiveBufferSize(64 * 1024); // 64KB 接收緩衝
socket.setSendBufferSize(64 * 1024);    // 64KB 發送緩衝

5. IPv6 支援

使用 Inet6Address、DatagramSocket(InetSocketAddress) 等 API，雙棧環境下自動處理。

常見錯誤與除錯技巧

總結

Java DatagramSocket/DatagramPacket 提供簡潔的 UDP 程式介面。掌握無連線特性、封包大小限制、阻塞模型與異常處理是開發高效網路應用的關鍵。實務中請根據業務可靠性需求決定是否在應用層補強確認機制。