网络编程 p5 UDP编程

UDP网络通信编程

• 基本介绍
  
  
  
  • 类DatagramSocket和DatagramPacket实现了基于UDP协议网络程序。
    
  • UDP数据报通过数据报套接字DatagramSocket发送和接收，系统不保证UDP数据报一定能够安全送到目的地，也不能确定什么时候可以抵达。
    
  • DatagramPacket对象封装了UDP数据报，在数据报中包含了发送端的IP地址和端口号以及接收端的IP地址和端口号。
    
  • UDP协议中每个数据报都给出了完整的地址信息，因此无须建立发送方和接送方的连接。
    
  
  
• 基本流程
  
  
  
  • 核心的两个类/对象 DatagramSocket/DatagramPacket
    
  • 建立发送端，接收端
    
  • 建立数据包
    
  • 调用DatagramSocket的发送和接收方法
    
  • 关闭DatagramSocket
    
  
  
  
• UDP网络编程原理示意图
  
  
• 注意事项
  
  
  
  • 没有明确的服务端和客户端，演变成数据的发送端和接收端；
    
  • 接收数据和发送数据是通过DatagramSocket对象完成的；
    
  • 将数据封装到DatagramPacket对象/装包；
    
  • 当接收到DatagramPacket对象，需要进行拆包，取出数据；
    
  • DatagramSocket可以指定在哪个端口接收数据；
    
  
  
• 代码演示
  1. package com.hspedu.udp;
  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  9. /**
  10. * @author: 86199
  11. * @date: 2023/5/17 17:49
  12. * @description: UDP
  13. */
  14. public class UDPReceiverA {
  15.     public static void main(String[] args) throws IOException {
  16.         //1. 创建一个DatagramSocket 对象，准备在9999接收数据
  17.         DatagramSocket socket = new DatagramSocket(9999);
  19.         //2. 构建一个DatagramPacket对象，用来接收数据
  20.         //    UDP，一个数据包最大64K
  21.         byte[] bytes = new byte[1024];
  22.         DatagramPacket packet = new DatagramPacket(bytes, bytes.length);
  24.         //3. 调用接受方法，将通过网络传输的 DatagramPacket 对象填充到packet对象
  25.         //   注意：当有数据发送到 本机的9999端口时，就会接收到数据
  26.         //        如果没有数据包发送到 本机的9999端口，就会阻塞等待
  27.         System.out.println("接收端A 等待接收数据……");
  28.         socket.receive(packet);
  30.         int length = packet.getLength();
  31.         byte[] data = packet.getData();
  33.         String s = new String(data, 0, length);
  34.         System.out.println(s);
  36.         //a端作发送端
  37.         byte[] data2 = "好的，明天见".getBytes();
  38.         DatagramPacket packet1 =
  39.                 new DatagramPacket(data2, data2.length, InetAddress.getByName("10.15.205.153"), 9998);
  41.         socket.send(packet1);
  43.         //关闭资源
  44.         socket.close();
  45.         System.out.println("A端退出...");
  46.     }
  47. }

  复制代码
  1. package com.hspedu.udp;
  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  9. /**
  10. * @author: 86199
  11. * @date: 2023/5/17 17:50
  12. * @description: UDP
  13. */
  14. public class UDPSenderB {
  15.     public static void main(String[] args) throws IOException {
  16.         //1. 创建 DatagramSocket 对象，准备在9998端口 发送数据
  17.         DatagramSocket socket = new DatagramSocket(9998);
  19.         //2. 将需要发送的数据，封装到 DatagramPacket对象
  20.         byte[] data = "hello，明天去吃火锅吧".getBytes();
  22.         //说明：封装 DatagramPacket对象 data 内容字节数组，data.length，主机（IP），端口
  23.         DatagramPacket packet =
  24.                 new DatagramPacket(data, data.length, InetAddress.getByName("10.15.205.153"), 9999);
  26.         socket.send(packet);
  28.         //B端作接收端
  29.         byte[] bytes = new byte[1024];
  30.         DatagramPacket packet1 = new DatagramPacket(bytes, bytes.length);
  32.         System.out.println("接收端B 等待接收数据……");
  33.         socket.receive(packet1);
  35.         int length = packet1.getLength();
  36.         byte[] data1 = packet1.getData();
  38.         String s = new String(data1, 0, length);
  39.         System.out.println(s);
  42.         //关闭资源
  43.         socket.close();
  44.         System.out.println("B端退出...");
  45.     }
  46. }

  复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

继续阅读请点击广告