Java UDP通信中DatagramPacket数据截断问题的完整解决方案-java教程-PHP中文网

Java UDP通信中DatagramPacket数据截断问题的完整解决方案

本文详解java udp客户端仅接收首字符的根本原因——datagrampacket未正确处理实际数据长度，导致服务端读取缓冲区溢出与截断，并提供带长度前缀的健壮通信实现方案。

本文详解java udp客户端仅接收首字符的根本原因——datagrampacket未正确处理实际数据长度，导致服务端读取缓冲区溢出与截断，并提供带长度前缀的健壮通信实现方案。

在使用 DatagramSocket 进行 Java UDP 通信时，一个常见却隐蔽的陷阱是：发送端与接收端对数据长度的认知不一致。您遇到的客户端仅打印 "T"（实为 "Result 123" 的首字母），正是这一问题的典型表现。

根本原因在于：

客户端调用 String.valueOf(add1).getBytes() 生成字节数组（如 "42" → byte[2]），但随后创建 DatagramPacket(buf, buf.length, ...) 时虽指定了真实长度，服务端却始终以固定 256 字节缓冲区接收：
```
byte[] buf = new byte[256];
DatagramPacket packet = new DatagramPacket(buf, buf.length); // ← 始终等待填满256字节！
socket.receive(packet);
```
UDP 协议本身不携带长度元信息，packet.getLength() 才是实际收到的字节数。而 new String(packet.getData()) 会将整个 256 字节数组（含大量 \0）转为字符串，导致后续解析（如 trim()）仍可能受干扰，且 Integer.parseInt() 在遇到非数字字符时易抛异常。

更严重的是，您的服务端代码存在逻辑缺陷：

第一次 socket.receive(packet) 后，add1 解析成功；
但第二次 socket.receive(packet) 复用了同一 packet 对象，其内部 buf 仍是原 256 字节数组，而 packet.getLength() 未重置 —— 实际上，第二次接收的数据被写入 buf[0..len-1]，但 new String(packet.getData()) 仍返回全部 256 字节，trim() 无法清除 buf[len..255] 中残留的旧数据（如前次 "Result 42" 的 'T'），最终 Integer.parseInt("T\0\0...") 失败或产生不可预测行为。

✅ 正确做法：显式传递有效载荷长度，并严格按需解析

以下是修复后的完整实现（含长度前缀协议）：

Java Maven Common

Java Maven 项目审查工作流的通用输入处理。当 Java Maven 项目以 ZIP压缩包或 GitLab 仓库 URL 形式提供且需要...时使用。

下载

客户端（Client.java）

public class Client {
    public static void main(String[] args) throws IOException {
        Scanner scan = new Scanner(System.in);
        InetAddress address = InetAddress.getByName("localhost");
        try (DatagramSocket socket = new DatagramSocket()) {
            // 发送第一个加数
            System.out.print("First adder: ");
            int add1 = scan.nextInt();
            sendInt(socket, add1, address, 8189);

            // 发送第二个加数
            System.out.print("Second adder: ");
            int add2 = scan.nextInt();
            sendInt(socket, add2, address, 8189);

            // 接收结果（带长度前缀）
            String response = receiveString(socket);
            System.out.println("Server response: " + response);
        }
    }

    private static void sendInt(DatagramSocket socket, int value, InetAddress addr, int port) 
            throws IOException {
        String data = String.valueOf(value);
        byte[] payload = data.getBytes(StandardCharsets.UTF_8);
        // 构造：[2字节长度][payload]
        ByteBuffer bb = ByteBuffer.allocate(2 + payload.length);
        bb.putShort((short) payload.length);
        bb.put(payload);
        DatagramPacket packet = new DatagramPacket(
            bb.array(), bb.position(), addr, port);
        socket.send(packet);
    }

    private static String receiveString(DatagramSocket socket) throws IOException {
        // 先读2字节长度
        byte[] lenBuf = new byte[2];
        DatagramPacket lenPacket = new DatagramPacket(lenBuf, lenBuf.length);
        socket.receive(lenPacket);
        short len = ByteBuffer.wrap(lenBuf).getShort();

        // 再读指定长度数据
        byte[] dataBuf = new byte[len];
        DatagramPacket dataPacket = new DatagramPacket(dataBuf, dataBuf.length);
        socket.receive(dataPacket);
        return new String(dataBuf, 0, dataPacket.getLength(), StandardCharsets.UTF_8);
    }
}

服务端（Server.java）

public class Server {
    public static void main(String[] args) {
        try (DatagramSocket socket = new DatagramSocket(8189)) {
            System.out.println("Server started on port 8189...");
            while (true) {
                // 接收第一个加数
                int add1 = receiveInt(socket);
                // 接收第二个加数
                int add2 = receiveInt(socket);

                int sum = add1 + add2;
                String result = "Result " + sum;
                sendString(socket, result);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private static int receiveInt(DatagramSocket socket) throws IOException {
        byte[] lenBuf = new byte[2];
        DatagramPacket lenPacket = new DatagramPacket(lenBuf, lenBuf.length);
        socket.receive(lenPacket);
        short len = ByteBuffer.wrap(lenBuf).getShort();

        byte[] dataBuf = new byte[len];
        DatagramPacket dataPacket = new DatagramPacket(dataBuf, dataBuf.length);
        socket.receive(dataPacket);

        String str = new String(dataBuf, 0, dataPacket.getLength(), StandardCharsets.UTF_8);
        return Integer.parseInt(str.trim());
    }

    private static void sendString(DatagramSocket socket, String msg) throws IOException {
        byte[] payload = msg.getBytes(StandardCharsets.UTF_8);
        ByteBuffer bb = ByteBuffer.allocate(2 + payload.length);
        bb.putShort((short) payload.length);
        bb.put(payload);

        // 注意：需从receiveInt中获取客户端地址和端口
        // 此处简化，实际应保存上一次packet的SourceAddress/port
        // 为演示清晰，假设客户端地址已知（生产环境必须动态获取）
        DatagramPacket packet = new DatagramPacket(
            bb.array(), bb.position(), 
            InetAddress.getByName("localhost"), 8189);
        socket.send(packet);
    }
}

⚠️ 关键注意事项：