UDP网络通信编程

• 基本介绍

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

• 基本流程

  1. 核心的两个类/对象 DatagramSocket/DatagramPacket
  2. 建立发送端，接收端
  3. 建立数据包
  4. 调用DatagramSocket的发送和接收方法
  5. 关闭DatagramSocket

  

• UDP网络编程原理示意图

  

• 注意事项

  1. 没有明确的服务端和客户端，演变成数据的发送端和接收端；
  2. 接收数据和发送数据是通过DatagramSocket对象完成的；
  3. 将数据封装到DatagramPacket对象/装包；
  4. 当接收到DatagramPacket对象，需要进行拆包，取出数据；
  5. DatagramSocket可以指定在哪个端口接收数据；

• 代码演示

  package com.hspedu.udp;
  
  import java.io.IOException;
  import java.net.DatagramPacket;
  import java.net.DatagramSocket;
  import java.net.InetAddress;
  
  
  /**
   * @author: 86199
   * @date: 2023/5/17 17:49
   * @description: UDP
   */
  public class UDPReceiverA {
      public static void main(String[] args) throws IOException {
          //1. 创建一个DatagramSocket 对象，准备在9999接收数据
          DatagramSocket socket = new DatagramSocket(9999);
  
          //2. 构建一个DatagramPacket对象，用来接收数据
          //    UDP，一个数据包最大64K
          byte[] bytes = new byte[1024];
          DatagramPacket packet = new DatagramPacket(bytes, bytes.length);
  
          //3. 调用接受方法，将通过网络传输的 DatagramPacket 对象填充到packet对象
          //   注意：当有数据发送到 本机的9999端口时，就会接收到数据
          //        如果没有数据包发送到 本机的9999端口，就会阻塞等待
          System.out.println("接收端A 等待接收数据……");
          socket.receive(packet);
  
          int length = packet.getLength();
          byte[] data = packet.getData();
  
          String s = new String(data, 0, length);
          System.out.println(s);
  
          //a端作发送端
          byte[] data2 = "好的，明天见".getBytes();
          DatagramPacket packet1 =
                  new DatagramPacket(data2, data2.length, InetAddress.getByName("10.15.205.153"), 9998);
  
          socket.send(packet1);
  
          //关闭资源
          socket.close();
          System.out.println("A端退出...");
      }
  }
  
  

  package com.hspedu.udp;
  
  import java.io.IOException;
  import java.net.DatagramPacket;
  import java.net.DatagramSocket;
  import java.net.InetAddress;
  
  
  /**
   * @author: 86199
   * @date: 2023/5/17 17:50
   * @description: UDP
   */
  public class UDPSenderB {
      public static void main(String[] args) throws IOException {
          //1. 创建 DatagramSocket 对象，准备在9998端口 发送数据
          DatagramSocket socket = new DatagramSocket(9998);
  
          //2. 将需要发送的数据，封装到 DatagramPacket对象
          byte[] data = "hello，明天去吃火锅吧".getBytes();
  
          //说明：封装 DatagramPacket对象 data 内容字节数组，data.length，主机（IP），端口
          DatagramPacket packet =
                  new DatagramPacket(data, data.length, InetAddress.getByName("10.15.205.153"), 9999);
  
          socket.send(packet);
  
          //B端作接收端
          byte[] bytes = new byte[1024];
          DatagramPacket packet1 = new DatagramPacket(bytes, bytes.length);
  
          System.out.println("接收端B 等待接收数据……");
          socket.receive(packet1);
  
          int length = packet1.getLength();
          byte[] data1 = packet1.getData();
  
          String s = new String(data1, 0, length);
          System.out.println(s);
  
  
          //关闭资源
          socket.close();
          System.out.println("B端退出...");
      }
  }