DongHao's 个人在线文档库

基于`Socket`的`UDP`编程

基本介绍：

DatagramSocket和DtagramPacket（数据包/报）类实现了基于UDP协议网络程序
UDP数据通过数据报套接字DatagramSocket发送和接受，系统不保证UDP数据报一定能够安全送到目的地，也不确定什么时候可以抵达
DtagramPacket对象封装了UDP数据报，在数据报中包含了发送端的IP地址和端口号以及接收端的IP地址和端口号
UDP协议中每个数据报都给出了完整的地址信息，因此无需建立发送方和接收方的连接

基于Socket的UDP编程的基本流程：

核心的两个类/对象DatagramSocket和DtagramPacket
建立发送端和接受端（没有服务端和客户端的概念了）
1. 在发送数据之前，建立数据包/报，即DtagramPacket对象
调用DatagramSocket的发送、接收方法
关闭DatagramSocket

发送端可以变成接收端，接收端也可以变成发送端，没有服务端和客户端的概念了

应用案例：

编写一个接收端A和一个发送端B
接收端A在9999端口等待接收数据（receive）
发送端B向接收端A发送数据"hello"
接收端A接收到发送端B发送的数据，回复“好的”，再退出
发送端接收回复的数据，再退出

接收端A的代码实现：

java

package com.test.udp;

public class UDPReceiverA {
    public static void main(String[] args) throws IOException {
        // 1.创建一个 DatagramSocket 对象，准备在9999端口接收数据
        DatagramSocket socket = new DatagramSocket(9999);
        // 2.创建一个 DtagramPacket 对象，准备接收数据
        byte[] buf = new byte[1024];  // UDP协议传输时一个数据包最大是64k
        DtagramPacket packet = new DtagramPacket(buf, buf.length);
        // 3.调用接收方法，将通过网络传输的DtagramPacket对象填充到空的packet对象中
        System.out.println("接收端A等待接收数据");
        socket.receive(packet);  // 当有数据包发送到本机的9999端口是，就会接收数据，否则就会阻塞
        // 4.把packet进行拆包，取出数据，并显示
        int length = packet.getLength();   // 实际接收到的数据字节长度
        byte[] data = packet.getData();   // 接收到的数据
        String s = new String(data, 0, length);
        System.out.println(s);
        // 5.发送回复给A端
        data = "好的".getBytes();  // 字节数组
        // 传入主机（通过IP地址获取主机）和端口
        packet = new DtagramPacket(data, data.length, InetAddress.getByName("10.20.18.73"), 9998);
        // 6.发送数据
        socket.send(packet);
        // 7.关闭资源
        socket.close();
        System.out.println("A端退出");
    }
}

发送端B的代码实现：

java

package com.test.udp;

public class UDPSenderB {
    public static void main(String[] args) throws IOException {
        // 1.创建一个 DatagramSocket 对象，准备在9998端口接收数据（发送端后续也可以变成接收端接收数据）
        DatagramSocket socket = new DatagramSocket(9998);
        // 2.创建一个 DtagramPacket 对象
        byte[] data = "hello".getBytes();  // 字节数组
        // 传入主机（通过IP地址获取主机）和端口
        DtagramPacket packet = new DtagramPacket(data, data.length, InetAddress.getByName("10.20.18.73"), 9999);
        // 3.发送数据
        socket.send(packet);
        // 4.接收回复的数据
        byte[] buf = new byte[1024];  // UDP协议传输时一个数据包最大是64k
        packet = new DtagramPacket(buf, buf.length);
        // 5.调用接收方法，将通过网络传输的DtagramPacket对象填充到空的packet对象中
        socket.receive(packet);  // 当有数据包发送到本机的9999端口是，就会接收数据，否则就会阻塞
        // 6.把packet进行拆包，取出数据，并显示
        int length = packet.getLength();   // 实际接收到的数据字节长度
        data = packet.getData();   // 接收到的数据
        String s = new String(data, 0, length);
        System.out.println(s);
        // 7.关闭资源
        socket.close();
        System.out.println("B端退出");
    }
}

基于Socket的UDP编程 ​

基于`Socket`的`UDP`编程