在Java中如何使用DatagramSocket进行UDP通信

Java中UDP通信基于DatagramSocket和DatagramPacket,服务端绑定端口如8888,客户端自动分配端口,通过send()和receive()发送接收数据包,需处理异常并设计应用层协议以弥补UDP无连接、不可靠的缺陷。

在Java中使用DatagramSocket进行UDP通信,主要依赖java.net.DatagramSocketjava.net.DatagramPacket两个类。UDP是无连接的协议,适合对实时性要求高、能容忍少量丢包的场景,比如

音视频传输或心跳检测。

创建DatagramSocket并绑定端口

要进行UDP通信,首先需要创建一个DatagramSocket实例。服务端通常绑定到指定端口,客户端可以不绑定或由系统自动分配。

说明:
  • 服务端通过指定端口号监听数据:new DatagramSocket(8888);
  • 客户端可使用无参构造函数:new DatagramSocket();,系统自动分配可用端口
  • 若端口被占用会抛出SocketException,需做好异常处理

发送和接收数据(使用DatagramPacket)

UDP数据以数据包形式传输,所有数据都封装在DatagramPacket中。发送和接收都要用这个类。

操作步骤:
  • 将字符串转为字节数组:byte[] data = "Hello".getBytes();
  • 创建发送包,需目标地址和端口:new DatagramPacket(data, data.length, InetAddress.getByName("127.0.0.1"), 8888);
  • 调用socket.send(packet)发送
  • 接收时先准备缓冲区:byte[] buf = new byte[1024];
  • 创建空包:DatagramPacket packet = new DatagramPacket(buf, buf.length);
  • 调用socket.receive(packet)阻塞等待数据
  • 从接收到的包中提取数据:String received = new String(packet.getData(), 0, packet.getLength());

简单示例:实现双向通信

下面是一个简化版的服务端和客户端交互逻辑。

服务端代码片段:
DatagramSocket socket = new DatagramSocket(8888);
byte[] buffer = new byte[1024];
DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
socket.receive(packet); // 阻塞等待
String msg = new String(packet.getData(), 0, packet.getLength());
System.out.println("收到:" + msg);

// 回复客户端
byte[] reply = "已收到".getBytes();
DatagramPacket replyPacket = new DatagramPacket(reply, reply.length, packet.getAddress(), packet.getPort());
socket.send(replyPacket);
socket.close();
客户端代码片段:
DatagramSocket socket = new DatagramSocket();
byte[] sendData = "请求连接".getBytes();
InetAddress serverAddr = InetAddress.getByName("127.0.0.1");
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, serverAddr, 8888);
socket.send(sendPacket);

// 接收回复
byte[] recvBuf = new byte[1024];
DatagramPacket recvPacket = new DatagramPacket(recvBuf, recvBuf.length);
socket.receive(recvPacket);
String reply = new String(recvPacket.getData(), 0, recvPacket.getLength());
System.out.println("回复:" + reply);
socket.close();

基本上就这些。UDP通信不保证顺序和可靠性,但实现简单、开销小。只要注意数据包大小(一般不超过65507字节)、正确处理IO异常,并合理设计应用层协议(如加序号、校验),就能在合适场景中稳定使用。