Java中的UDP编程

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

结尾

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