Java 网络编程：UDP 数据报套接字编程

4.1.1.2 主要方法

4.1.2 DatagramPacket 类

DatagramPacket 是 UDP Socket 发送和接收的数据报。

4.1.2.1 构造方法

4.1.2.2 主要方法

4.1.3 使用上述类创建回显服务器 - 客户端

回显：请求是啥，响应就是啥。

4.1.3.1 回显服务器 UdpEchoServer

1. 先创建一个成员变量：Socket 对象，用于接收发送数据报。private DatagramSocket socket = null;
2. 构造方法，指定一个固定端口号给服务器使用，将 Socket 使用这个端口号实例化。

public UdpEchoServer(int port) throws SocketException {
    socket = new DatagramSocket(port);
}

3. 接下来在 start 方法中编写服务器实现逻辑。由于服务器是要 7*24 小时工作的，所以在一个死循环中实现。
4. 读取请求并解析； 4.1 构造一个 DatagramPacket 对象，初始化为 0（不是 null），用于保存 UDP 的载荷部分。 DatagramPacket requestPacket = new DatagramPacket(new byte[2024], 2024); 4.2 读取请求 socket.receive(requestPacket); 4.3 把读取到有效数据的解析为字符串。 通过 getData 方法获取 DatagramPacket 中的字节数组，getLength 方法获取 DatagramPacket 有效数据长度，根据字节数组构造字符串。 String request = new String(requestPacket.getData(), 0, requestPacket.getLength());
5. 根据请求计算响应，由于是回显服务器，直接请求就是响应。

String response = process(request);
private String process(String request) {
    return request;
}

6. 把响应返回给客户端，通过 getBytes 方法拿到字符串中的字节数据，getBytes().length 拿到字节长度，getSocketAddress 方法拿到客户端的端口和 IP。

socket.send(new DatagramPacket(request.getBytes(), request.getBytes().length, requestPacket.getSocketAddress()));

7. 打印一个日志记录此次交互过程。

System.out.printf("[%s : %d], request:%s , response:%s\n", requestPacket.getAddress().toString(), requestPacket.getPort(), request, response);

8. 总代码

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class UdpEchoServer {
    // 先创建一个成员变量：Socket 对象，用于接收发送数据报
    private DatagramSocket socket = null;

    // 构造方法，指定一个固定端口号给服务器使用，将 Socket 使用这个端口号实例化
    public UdpEchoServer(int port) throws SocketException {
        socket = new DatagramSocket(port);
    }

    public void start() throws IOException {
        while (true) {
            // 构造一个 DatagramPacket 对象，初始化为 0（不是 null），用于保存 UDP 的载荷部分。
            DatagramPacket requestPacket = new DatagramPacket(new byte[2024], 2024);
            // 接收请求
            socket.receive(requestPacket);
            // 把读取到有效数据的解析为字符串
            String request = new String(requestPacket.getData(), 0, requestPacket.getLength());
            // 计算响应
            String response = process(request);
            // 把响应返回给客户端
            socket.send(new DatagramPacket(request.getBytes(), request.getBytes().length, requestPacket.getSocketAddress()));
            // 打印一个日志
            System.out.printf("[%s : %d], request:%s , response:%s\n", requestPacket.getAddress().toString(), requestPacket.getPort(), request, response);
        }
    }

    private String process(String request) {
        return request;
    }

    public static void main(String[] args) throws IOException {
        UdpEchoServer server = new UdpEchoServer(6666);
        server.start();
    }
}

4.1.3.2 回显客户端 UdpEchoClient

1. 先创建一个成员变量：Socket 对象，用于接收发送数据报 private DatagramSocket socket = null;
2. UDP 本身不保存对端的信息，就自己的代码中保存一下。

private String serverIp;
private int port;

3. 构造方法是要指定访问的服务器的地址。

public UdpEchoClient(String serverIp, int port) throws SocketException {
    this.serverIp = serverIp;
    this.port = port;
    socket = new DatagramSocket();
}

4. 从控制台读取用户输入的内容。

System.out.println("请输入要传输的内容");
Scanner scanner = new Scanner(System.in);
if (!scanner.hasNext()) {
    break;
}
String request = scanner.next();

5. 发送数据报，把请求发送给服务器，需要构造 DatagramPacket 对象。构造过程中，不光要构造载荷，还要设置服务器的 IP 和端口号。

socket.send(new DatagramPacket(request.getBytes(), request.getBytes().length, InetAddress.getByName(serverIp), port));

6. 接收服务器的响应

DatagramPacket responsePacket = new DatagramPacket(new byte[2024], 2024);
socket.receive(responsePacket);

7. 从服务器读取的数据进行解析，打印出来。

String response = new String(responsePacket.getData(), 0, responsePacket.getData().length);
System.out.println(response);

8. 总代码

import java.io.IOException;
import java.net.*;
import java.util.Scanner;

public class UdpEchoClient {
    // 先创建一个成员变量：Socket 对象，用于接收发送数据报
    private DatagramSocket socket = null;
    // UDP 本身不保存对端的信息，自己的代码中保存一下
    private String serverIp;
    private int port;

    public UdpEchoClient(String serverIp, int port) throws SocketException {
        this.serverIp = serverIp;
        this.port = port;
        socket = new DatagramSocket();
    }

    public void start() throws IOException {
        while (true) {
            // 1. 从控制台读取用户输入的内容。
            System.out.println("请输入要传输的内容");
            Scanner scanner = new Scanner(System.in);
            if (!scanner.hasNext()) {
                break;
            }
            String request = scanner.next();
            // 发送数据报。把请求发送给服务器，需要构造 DatagramPacket 对象。构造过程中，不光要构造载荷，还要设置服务器的 IP 和端口号。
            socket.send(new DatagramPacket(request.getBytes(), request.getBytes().length, InetAddress.getByName(serverIp), port));
            // 接收服务器的响应
            DatagramPacket responsePacket = new DatagramPacket(new byte[2024], 2024);
            socket.receive(responsePacket);
            // 从服务器读取的数据进行解析，打印出来。
            String response = new String(responsePacket.getData(), 0, responsePacket.getData().length);
            System.out.println(response);
        }
    }

    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1", 6666);
        client.start();
    }
}