Java UDP通信：Java DatagramSocket类和DatagramPacket类

在 TCP/IP 协议的传输层除了一个 TCP 协议之外，还有一个 UDP 协议。UDP 协议是用户数据报协议的简称，也用于网络数据的传输。虽然 UDP 协议是一种不太可靠的协议，但有时在需要较快地接收数据并且可以忍受较小错误的情况下，UDP 就会表现出更大的优势。

下面是在 Java 中使用 UDP 协议发送数据的步骤。

1. 使用 DatagramSocket() 创建一个数据包套接字。
2. 使用 DatagramPacket() 创建要发送的数据包。
3. 使用 DatagramSocket 类的 send() 方法发送数据包。

接收 UDP 数据包的步骤如下：

• 使用 DatagramSocket 创建数据包套接字，并将其绑定到指定的端口。
• 使用 DatagramPacket 创建字节数组来接收数据包。
• 使用 DatagramPacket 类的 receive() 方法接收 UDP 包。

DatagramPacket 类

java.net 包中的 DatagramPacket 类用来表示数据报包，数据报包用来实现无连接包投递服务。每条报文仅根据该包中包含的信息从一台机器路由到另一台机器。从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。表 1 和表 2 简单介绍了 DatagramPacket 的构造方法和常用方法。

DatagramSocket 类

DatagramSocket 类用于表示发送和接收数据报包的套接字。数据报包套接字是包投递服务的发送或接收点。每个在数据报包套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。

DatagramSocket 类的常用构造方法如表 3 所示。

DatagramSocket 类的常用方法如表 4 所示。

例 1

编写 UDP 程序，要求客户端程序可以向服务器端发送多条数据，服务器端程序可以接收客户端发送的多条数据并将其信息输出在控制台，主要步骤如下所示。

(1) 创建一个类作为客户端，在 main() 方法定义一个 DatagramSocket 对象和一个 DatagramPacket 对象并初始化为 null。然后再定义一个 InetAddress 对象和一个端口号并分别进行初始化，代码如下所示。

public static void main(String[] args)
{
    DatagramSocket ds=null;
    DatagramPacket dpSend=null;
    InetAddress ia=InetAddress.getByName("127.0.0.1");
    int port=3021;
}

(2) 使用 DatagramSocket 的 send(DatagramPacket p) 方法向服务器端发送数据报包，使用循环的方式完成 5 次数据的发送，每发送 1 次数据线程休眠 1000 毫秒，数据发送完毕调用 close() 方法，关闭 DatagramSocket 对象，代码如下。

try
{
    ds=new DatagramSocket();
    for(int i=0;i<5;i++)
    {
        byte[] data=("我是 UDP 客户端"+i).getBytes();
        dpSend=new DatagramPacket(data,data.length,ia,port);
        ds.send(dpSend);
        Thread.sleep(1000);
    }
    ds.close();
}
catch(IOException | InterruptedException e)
{
    // TODO 自动生成的 catch 块
    e.printStackTrace();
}   

(3) 创建一个类作为服务器端，在 main() 方法中定义一个 DatagramSocket 对象和一个 DatagramPacket 对象并初始化为 null，再定义一个端口号，代码如下所示。

public static void main(String[] args)
{
    DatagramSocket ds=null;
    DatagramPacket dpReceive=null;
    int port=3021;
}

(4) 如果成功连接到 UDP 服务器则输出“UDP 服务器已启动。。。”。循环接收客户端发送的数据，并将其发送的内容以及IP地址等信息输出到控制台，代码如下所示。

try
{
    ds=new DatagramSocket(port);
    System.out.println("UDP服务器已启动。。。");
    byte[] b=new byte[1024];
    while(ds.isClosed()==false)
    {
        dpReceive=new DatagramPacket(b, b.length);
        try
        {
            ds.receive(dpReceive);
            byte[] Data=dpReceive.getData();
            int len=Data.length;
            System.out.println("UDP客户端发送的内容是：" + new String(Data, 0, len).trim());
            System.out.println("UDP客户端IP：" + dpReceive.getAddress());
            System.out.println("UDP客户端端口：" + dpReceive.getPort());
        }
        catch(IOException e)
        {
            e.printStackTrace();
        }
    }
    }
    catch(SocketException e1)
    {
        // TODO 自动生成的 catch 块
        e1.printStackTrace();
    }
}

(5) 最后关闭 DatagramSocket 对象。执行服务器端程序，运行结果如下所示。

(6) 再运行客户端程序，控制台的输出结果如下所示。