Java中的UDP编程
Java为我们提供了DatagramSocket对象作为基于UDP协议的Socket,可以使用DatagramPacket代表DatagramSocket发送或接收数据报。
DatagramSocket
DatagramSocket本身只是码头,不维护状态,不能产生I/O流,它的唯一作用就是接收和发送数据报:
- send();发送数据包
- receive();接收数据包
Java使用DatagramPacket来代表数据报,DatagramSocket接收和发送的数据都是通过DatagramPacket对象完成的。
DatagramPacket的构造函数:
//成员变量
byte[] buf;
int offset;
int length;
int bufLength;
InetAddress address;
int port;
//创建一个用于接收length长度包的DatagramPacket对象。
public DatagramPacket(byte buf[], int length) {
this (buf, 0, length);
}
//创建一个用于接收length长度包的DatagramPacket对象,并设置相应的偏移量。
public DatagramPacket(byte buf[], int offset, int length) {
setData(buf, offset, length);
}
//构造一个数据报包,用于将长度为length的数据包发送到指定主机上的指定端口号,length参数必须小于或等于buf的长度。
public DatagramPacket(byte buf[], int length,
InetAddress address, int port) {
this(buf, 0, length, address, port);
}
//构造一个数据报包,用于将长度为length偏移量为offset的数据包发送到指定主机上的指定端口号,length参数必须小于或等于buf的长度.
public DatagramPacket(byte buf[], int offset, int length,
InetAddress address, int port) {
setData(buf, offset, length);
setAddress(address);
setPort(port);
}
//构造一个数据报包,用于将长度为length的数据包发送到指定主机上的指定端口号,length参数必须小于或等于buf的长度。
public DatagramPacket(byte buf[], int length, SocketAddress address) {
this(buf, 0, length, address);
}
//构造一个数据报包,用于将长度为length偏移量为offset的数据包发送到指定主机上的指定端口号,length参数必须小于或等于buf的长度.
public DatagramPacket(byte buf[], int offset, int length, SocketAddress address) {
setData(buf, offset, length);
setSocketAddress(address);
}
接收数据:应该采用上面的第一个或第二个构造函数生成一个DatagramPacket对象,给出接收数据的字节数组及其长度。然后调用DatagramSocket中的receive()方法等待数据报的到来,此方法将一直等待(也就是说会阻塞调用该方法的线程),直到收到一个数据报为止。
发送数据:调用后面4个构造函数创建DatagramPacket对象,此时的字节数组里存放了想发送的数据。除此之外,还要给出完整的目的地址,包括IP地址和端口号。发送数据是通过DatagramSocket的方法send()实现的,方法send()根据数据报的目的地址来寻径以传递数据报。
客户端实例
Client.java
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class Client {
public static void main(String[] args) throws IOException{
DatagramSocket socket = new DatagramSocket();
InetAddress address = InetAddress.getByName("localhost");
int port = 20000;
// 发送数据给服务器
byte[] data= "你好我是客户端".getBytes();
DatagramPacket packet = new DatagramPacket(data,data.length,address,port);
socket.send(packet);//发送UDP数据包
// 接收服务器的数据
byte[] buffer = new byte[1024];
DatagramPacket packet2 = new DatagramPacket(buffer, buffer.length);
socket.receive(packet2);//接收UDP数据包
System.out.println("服务器响应:");
System.out.println("数据:"+new String(packet2.getData())+" 偏移量"+packet2.getOffset()+" 长度"+packet2.getLength());
socket.close();
}
}
服务器端实例
Server.java
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class Server{
public static void main(String[] args) throws IOException{
DatagramSocket socket = new DatagramSocket(20000); // 监听指定端口
while(true) {
// 接收客户端的数据
byte[] buffer = new byte[1024];
DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
System.out.println("启动服务器,等待接收数据");
socket.receive(packet); // 收取一个UDP数据包
System.out.println("客户端响应:");
System.out.println("数据:"+new String(packet.getData())+" 偏移量"+packet.getOffset()+" 长度"+packet.getLength());
// 发送数据给客户端
byte[] data = "你好我是服务器,谢谢你的连接".getBytes();
InetAddress address = packet.getAddress();
int port = packet.getPort();
DatagramPacket packet2 = new DatagramPacket(data, data.length, address, port);
socket.send(packet2);//发送UDP数据包
}
}
}
客户端运行结果
服务器响应:
数据:你好我是服务器,谢谢你的连接 偏移量0 长度42
服务器端运行结果
启动服务器,等待接收数据
客户端响应:
数据:你好我是客户端 偏移量0 长度21
结尾
感谢看到最后的朋友,都看到最后了,点个赞再走啊,如有不对之处还请多多指正。