Java中UDP通信基于DatagramSocket和DatagramPacket,服务端绑定端口如8888,客户端自动分配端口,通过send()和receive()发送接收数据包,需处理异常并设计应用层协议以弥补UDP无连接、不可靠的缺陷。
在Java中使用DatagramSocket进行UDP通信,主要依赖java.net.DatagramSocket和java.net.DatagramPacket两个类。UDP是无连接的协议,适合对实时性要求高、能容忍少量丢包的场景,比如音视频传输或心跳检测。
要
进行UDP通信,首先需要创建一个DatagramSocket实例。服务端通常绑定到指定端口,客户端可以不绑定或由系统自动分配。
new DatagramSocket(8888);
new DatagramSocket();,系统自动分配可用端口SocketException,需做好异常处理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异常,并合理设计应用层协议(如加序号、校验),就能在合适场景中稳定使用。