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

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();  //关闭发送端
    }
}

运行截图：