Java网络编程-UDP协议-DatagramPacket与DatagramSocket

1. UDP协议

    UDP是无连接通信协议，即在数据传输时，数据的发送端和接收端不建立逻辑连接

• 当一台 计算机向另外一台计算机发送数据时，发送端不会确认接收端是否存在，就会发出数据，同样接收端在 收到数据时，也不会向发送端反馈是否收到数据。

• 使用UDP协议消耗资源小，通信效率高，通常会用于音频、视频和普通数据的传输

  例如视频会议通常采用UDP协议，因为这种情况即使偶尔丢失一两个数据包，也不会对接收结果产生太大影响

• 由于UDP的面向无连接性，不能保证数据的完整性，因此在传输重要数据时不建议使用UDP协议

2. DatagramSocket类

DatagramSocket类的构造方法和常用方法：

构造方法	说明
DatagramSocket()	默认使用本地地址和一个随机的端口号
DatagramSocket(int port)	使用本地地址、并指定端口号
DatagramSocket(int port, InetAddress iad)	指定地址和端口号
DatagramSocket(SocketAddress sad)	使用特定的Socket地址

常用方法	说明
send(DatagramPacket dp)	发送数据报
recevie(DatagramPacket dp)	接收数据报
close()	关闭socket

3. DatagramPacket类

DatagramPacket类的常用构造方法：

常用构造方法	说明
DatagramPacket(byte[] buf, int length)	用于接收数据 (即数据存于字节数组buf中)
DatagramPacket(byte[] buf, int leng, InetAddress addr, int port)	用于封装数据报、发送数据
DatagramPacket(byte[] buf, int length, SocketAddress address)	同上，但地址和端口号采用SocketAddress

4. 【案例】实现简单的收发信息

使用java实现使用UDP协议的发送、接收客户端

1. 发送数据客户端：可以一直接收键盘录入并发送数据，q退出

2. 接收数据客户端：使用死循环，接收客户端的数据并打印到控制台

public class ReceiveClient {
    public static void main(String[] args) throws IOException {
        DatagramSocket datagramSocket = new DatagramSocket(11111);

        while (true) {
            // 创建用于接收数据的数据包
            byte[] bytes = new byte[1024];
            DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);
            datagramSocket.receive(datagramPacket);
            // 解析数据并输出
            String content = new String(datagramPacket.getData(), 0, datagramPacket.getLength());
            System.out.println(content);
        }
    }
}

public class SendClient {
    public static void main(String[] args) throws Exception {
        DatagramSocket datagramSocket = new DatagramSocket();

        // 自行封装键盘录入
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
        String content;
        while ((content = bufferedReader.readLine())!= null){
            if("q".equals(content)) break;  // 输入q退出
            // 封装待发送的数据包
            byte[] bytes = content.getBytes();
            DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length, 
                                                InetAddress.getByName("127.0.0.1"), 11111);
            datagramSocket.send(datagramPacket);  //调用DatagramSocket对象的方法发送数据
        }
        datagramSocket.close();  //关闭发送端
    }
}

运行截图：