Java UDP网络通信实现：DatagramSocket与DatagramPacket使用详解

1. UDP网络通信核心原理

第1步：理解UDP的特性与数据报模型

在Java中，UDP通信主要依赖 java.net.DatagramSocket 和 java.net.DatagramPacket 两个核心类。与TCP不同，UDP是面向非连接的协议，系统不保证数据一定能送达目的地，也不保证送达顺序。这意味着：

• 无持久连接：不存在传统意义上的“服务端”和“客户端”，只有数据的“发送端”和“接收端”。同一程序可根据逻辑同时承担两种角色。
• 数据完整性独立：DatagramPacket 对象不仅封装了待传输的数据字节数组，还包含了完整的源IP地址、源端口、目标IP地址和目标端口号。每个数据报都是独立的，发送方需提供完整的地址信息。

第2步：掌握UDP通信的基本流程

实现UDP通信通常遵循以下标准步骤，这些步骤构成了所有UDP程序的基础骨架：

1. 创建套接字：实例化 DatagramSocket，若需指定本地端口（如接收端），需在构造函数中传入端口号；若仅作为发送端且未指定端口，系统将自动分配临时端口。
2. 封装数据包：创建 DatagramPacket 对象，将需要传输的字节数据、长度以及目标地址信息（IP+Port）打包。
3. 执行收发操作：调用 DatagramSocket.send() 发送数据包；调用 DatagramSocket.receive() 阻塞等待并填充接收到的数据到已有的Packet对象中。
4. 资源清理：通信结束后，务必调用 DatagramSocket.close() 释放端口和网络资源。

2. Java UDP通信实战案例

为了直观展示上述原理，我们构建一个双向通信场景：接收端A监听在 9999 端口，发送端B在 9998 端口。流程如下：

1. 启动接收端A：在9999端口等待消息。
2. 启动发送端B：向A的地址（localhost）和9999端口发送 "你好！接收端"。
3. A接收并回复：A收到数据后打印日志，并构造回复包发送给B的9998端口，内容为 "你好！发送端"。
4. B接收并退出：B收到A的回复后打印日志，随后两者均关闭资源。

第3步：编写接收端A (UDPReceiverA)

接收端的核心在于先绑定端口再阻塞接收。注意：接收前必须准备足够大的缓冲区和对应的Packet对象，receive() 方法会将网络传来的数据填充进这个Packet。

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPReceiverA {
    public static void main(String[] args) throws IOException {
        // 1. 创建 DatagramSocket，绑定本地端口 9999
        DatagramSocket socket = new DatagramSocket(9999);

        // 2. 准备缓冲区与数据包容器
        byte[] buf = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buf, buf.length);

        System.out.println("接收端A 等待接收数据...");
        // 3. 阻塞式接收数据
        socket.receive(packet);

        // 4. 解包：获取实际数据长度和数据内容
        int length = packet.getLength();
        byte[] data = packet.getData();
        String receivedMsg = new String(data, 0, length);
        System.out.println("接收到: " + receivedMsg);

        // 5. 构造回复数据
        String replyMsg = "你好！发送端";
        byte[] replyData = replyMsg.getBytes();
        // 回复给 localhost (即发送端B)，端口为 B 的发送端口 9998
        InetAddress address = InetAddress.getLocalHost();
        DatagramPacket replyPacket = new DatagramPacket(
                replyData, replyData.length, address, 9998);

        // 6. 发送回复
        socket.send(replyPacket);

        // 7. 关闭资源
        socket.close();
    }
}

第4步：编写发送端B (UDPSenderB)

发送端可以先构造目标数据包直接发送。由于本例中B也需要接收A的回复，因此B也需要创建一个Socket监听本地端口（代码中使用9998）。需要注意的是，DatagramPacket 对象在发送后可被复用用于接收，但接收时必须确保缓冲区容量足够。

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

public class UDPSenderB {
    public static void main(String[] args) throws IOException {
        // 1. 创建 DatagramSocket，绑定本地端口 9998，用于后续接收回复
        DatagramSocket socket = new DatagramSocket(9998);

        // 2. 准备要发送的数据和目标信息
        String sendMessage = "你好！接收端";
        byte[] data = sendMessage.getBytes();
        // 发送到 localhost 的 9999 端口
        DatagramPacket sendPacket = new DatagramPacket(
                data, data.length, InetAddress.getLocalHost(), 9999);

        // 3. 发送数据
        socket.send(sendPacket);

        // 4. 准备接收回复的数据包容器
        // 注意：这里复用了变量名，实际项目中建议区分
        byte[] buffer = new byte[1024];
        DatagramPacket receivePacket = new DatagramPacket(buffer, buffer.length);

        // 5. 阻塞接收 A 的回复
        socket.receive(receivePacket);

        // 6. 解析回复内容
        int length = receivePacket.getLength();
        byte[] responseData = receivePacket.getData();
        String replyMsg = new String(responseData, 0, length);
        System.out.println("收到回复: " + replyMsg);

        // 7. 关闭资源
        socket.close();
    }
}

3. 关键注意事项

• 异常处理：在生产环境中，socket.receive() 和 socket.send() 可能抛出 IOException，应添加适当的 try-catch 块或声明抛出。
• 防火墙设置：由于示例使用了固定端口 9999 和 9998，如果运行在远程服务器或受保护的网络环境中，请确保操作系统防火墙允许这些端口的UDP入站和出站流量。
• 缓冲区大小：DatagramPacket 的构造函数中指定的长度是最大可接收长度。如果发送的数据超过此限制，多余部分将被丢弃。对于常规文本通信，1024字节通常足够。