Java中UDP通信基于DatagramSocket和DatagramPacket,服务端绑定端口如8888,客户端自动分配端口,通过send()和receive()发送接收数据包,需处理异常并设计应用层协议以弥补UDP无连接、不可靠的缺陷。
在Java中使用
进行UDP通信,主要依赖
和
两个类。UDP是无连接的协议,适合对实时性要求高、能容忍少量丢包的场景,比如音视频传输或心跳检测。
创建DatagramSocket并绑定端口
要进行UDP通信,首先需要创建一个
实例。服务端通常绑定到指定端口,客户端可以不绑定或由系统自动分配。
说明:
服务端通过指定端口号监听数据:
客户端可使用无参构造函数:
,系统自动分配可用端口
若端口被占用会抛出
,需做好异常处理
发送和接收数据(使用DatagramPacket)
UDP数据以数据包形式传输,所有数据都封装在
中。发送和接收都要用这个类。
操作步骤:
将字符串转为
字节
数组:
创建发送包,需目标地址和端口:
调用
发送
接收时先准备缓冲区:
创建空包:
调用
阻塞等待数据
从接收到的包中提取数据:
简单示例:实现双向通信
下面是一个简化版的服务端和客户端交互逻辑。
Eclipse导入Android或其他的JAVA项目的正确方法 WORD版
本文档主要讲述的是Eclipse导入Android或其他的JAVA项目的正确方法;希望本文档会给有需要的朋友带来帮助;感兴趣的朋友可以过来看看
下载
立即学习
“
Java免费学习笔记(深入)
”;
服务端代码片段:
客户端代码片段:
基本上就这些。UDP通信不保证顺序和可靠性,但实现简单、开销小。只要注意数据包大小(一般不超过65507字节)、正确处理IO异常,并合理设计应用层协议(如加序号、校验),就能在合适场景中稳定使用。
DatagramSocketjava.net.DatagramSocketjava.net.DatagramPacketDatagramSocketnew DatagramSocket(8888);new DatagramSocket();SocketExceptionDatagramPacketbyte[] 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();
