【Java 网络编程】UDP 服务器 客户端 通信 ( DatagramSocket | DatagramPacket | UDP 发送数据包 | UDP 接收数据包 | 端口号分配使用机制 )

//I. 创建 DatagramSocket 对象 , 用于 UDP 数据包的发送和接收
            //1. UDP 数据包套接字 , 客户端 ,
            //      无需指定端口 , 让系统直接分配一个端口 , 使用该端口发送和接收数据
            DatagramSocket datagramSocket = new DatagramSocket();
            //II. 发送 UDP 数据包
            //2. 客户端发送给服务器端的端口号
            String sendMessage = "你好, 服务器 !";
            //3. 将字符串转为 byte[] 数组
            byte[] sendData = sendMessage.getBytes();
            //4. 创建发送数据包 , 需要传入的参数 1> 数据 2> 数据长度 3> 接收者的地址 4> 接收者的端口号
            //      向服务器端发送数据 , 发送的端口是自动分配的
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length,
                    InetAddress.getLocalHost(), 8888);
            //5. 将数据包发送出去
            datagramSocket.send(sendPacket);

//I. 创建 DatagramSocket 对象 , 用于 UDP 数据包的发送和接收
            //1. UDP 数据包接收者 , 监听 8888 端口
            //      该 DatagramSocket 既可以接收数据包 , 也可以发送数据包
            DatagramSocket datagramSocket = new DatagramSocket(8888);
            //II. 接收 UDP 数据包
            //2. 接收数据包使用的缓冲区
            byte[] receiveBuffer = new byte[1024];
            //3. 接收 UDP 数据包使用的 DatagramPacket 对象
            DatagramPacket receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
            //4. 接收 UDP 数据包
            datagramSocket.receive(receivePacket);

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class UDPServer {
    public static void main(String[] args){
        try {
            System.out.println("服务器 开始运行");
            //I. 创建 DatagramSocket 对象 , 用于 UDP 数据包的发送和接收
            //1. UDP 数据包接收者 , 监听 8888 端口
            //      该 DatagramSocket 既可以接收数据包 , 也可以发送数据包
            DatagramSocket datagramSocket = new DatagramSocket(8888);
            //II. 接收 UDP 数据包
            //2. 接收数据包使用的缓冲区
            byte[] receiveBuffer = new byte[1024];
            //3. 接收 UDP 数据包使用的 DatagramPacket 对象
            DatagramPacket receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
            //4. 接收 UDP 数据包
            datagramSocket.receive(receivePacket);
            //5. 获取发送端的 IP 地址
            String sendIP = receivePacket.getAddress().getHostAddress();
            //6. 获取发送端的端口号
            int sendPort = receivePacket.getPort();
            //7. 获取接收到的数据的长度
            int receiveLen = receivePacket.getLength();
            //8. 获取接收到的数据 , 并转为字符串
            String receiveData = new String(receivePacket.getData(), 0, receiveLen);
            //9. 打印接收到的数据包信息
            System.out.println("服务器 接收到 " + sendIP + " : " + sendPort + " 发送的数据 : " + receiveData);
            //III. 发送 UDP 数据包
            //10. 将接收到的数据长度回送给发送者
            String response = "服务器端 收到客户端发送的 " + receiveLen + " Byte 数据";
            //11. 将字符串转为 byte[] 数组
            byte[] responseData = response.getBytes();
            //12. 创建发送数据包 , 需要传入的参数 1> 数据 2> 数据长度 3> 接收者的地址 4> 接收者的端口号
            DatagramPacket responsePacket = new DatagramPacket(responseData, responseData.length,
                    receivePacket.getAddress(), receivePacket.getPort());
            //13. 将数据包发送出去
            datagramSocket.send(responsePacket);
            System.out.println("服务器 向客户端 " + sendIP + " : " + sendPort + " 发送的数据 : " + response);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            System.out.println("服务器 运行结束");
        }
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
public class UDPClient {
    public static void main(String[] args){
        try {
            System.out.println("客户端 开始运行");
            //I. 创建 DatagramSocket 对象 , 用于 UDP 数据包的发送和接收
            //1. UDP 数据包套接字 , 客户端 ,
            //      无需指定端口 , 让系统直接分配一个端口 , 使用该端口发送数据
            DatagramSocket datagramSocket = new DatagramSocket();
            //II. 发送 UDP 数据包
            //2. 客户端发送给服务器端的端口号
            String sendMessage = "你好, 服务器 !";
            //3. 将字符串转为 byte[] 数组
            byte[] sendData = sendMessage.getBytes();
            //4. 创建发送数据包 , 需要传入的参数 1> 数据 2> 数据长度 3> 接收者的地址 4> 接收者的端口号
            //      向服务器端发送数据 , 发送的端口是自动分配的
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length,
                    InetAddress.getLocalHost(), 8888);
            //5. 将数据包发送出去
            datagramSocket.send(sendPacket);
            System.out.println("客户端 向服务器 : " +
                    InetAddress.getLocalHost() + " : " + 8888 + " 发送的数据 : " + sendMessage);
            //III. 接收 UDP 数据包
            //6. 接收数据包使用的缓冲区
            byte[] receiveBuffer = new byte[1024];
            //7. 接收 UDP 数据包使用的 DatagramPacket 对象
            DatagramPacket receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
            //8. 接收 UDP 数据包
            datagramSocket.receive(receivePacket);
            //9. 获取发送端的 IP 地址
            String sendIP = receivePacket.getAddress().getHostAddress();
            //10. 获取发送端的端口号
            int sendPort = receivePacket.getPort();
            //11. 获取接收到的数据的长度
            int receiveLen = receivePacket.getLength();
            //12. 获取接收到的数据 , 并转为字符串
            String receiveData = new String(receivePacket.getData(), 0, receiveLen);
            //13. 打印接收到的数据包信息
            System.out.println("客户端 接收到服务器端反馈信息 : " +
                    sendIP + " : " + sendPort + " 发送的数据 : " + receiveData);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            System.out.println("客户端 运行结束");
        }
    }
}