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

感谢看到最后的朋友，都看到最后了，点个赞再走啊，如有不对之处还请多多指正。