【大数据】学习笔记 1 Java SE 第15章网络编程 15.6 UDP网络编程

谁践踏了优雅 2024-03-22 14:31 79阅读 0赞

### 【大数据】学习笔记 ###

#### 文章目录 ####

*   *  【大数据】学习笔记
     *   *  1 Java SE
         *   *  第15章 网络编程
             *   *  15.6 UDP网络编程
                 *   *  15.6.1 通信模型
                     *  15.6.2 开发步骤
                     *  15.6.3 演示发送和接收消息

![在这里插入图片描述][9a9de81357984774b7ef36c38c134f10.png_pic_center]

#### 1 Java SE ####

##### 第15章 网络编程 #####

###### 15.6 UDP网络编程 ######

UDP(User Datagram Protocol，用户数据报协议)：是一个无连接的传输层协议、提供面向事务的简单不可靠的信息传送服务，类似于短信。

###### 15.6.1 通信模型 ######

UDP协议是一种**面向非连接**的协议，面向非连接指的是在正式通信前不必与对方先建立连接，不管对方状态就直接发送，至于对方是否可以接收到这些数据内容，UDP协议无法控制，因此说，UDP协议是一种**不可靠的**协议。无连接的好处就是快，省内存空间和流量，因为维护连接需要创建大量的数据结构。UDP会尽最大努力交付数据，但不保证可靠交付，没有TCP的确认机制、重传机制，如果因为网络原因没有传送到对端，UDP也不会给应用层返回错误信息。

UDP协议是面向数据报文的信息传送服务。UDP在发送端没有缓冲区，对于应用层交付下来的报文在添加了首部之后就直接交付于ip层，不会进行合并，也不会进行拆分，而是一次交付一个完整的报文。比如我们要发送100个字节的报文，我们调用一次send()方法就会发送100字节，接收方也需要用receive()方法一次性接收100字节，不能使用循环每次获取10个字节，获取十次这样的做法。

UDP协议没有拥塞控制，所以当网络出现的拥塞不会导致主机发送数据的速率降低。虽然UDP的接收端有缓冲区，但是这个缓冲区只负责接收，并不会保证UDP报文的到达顺序是否和发送的顺序一致。因为网络传输的时候，由于网络拥塞的存在是很大的可能导致先发的报文比后发的报文晚到达。如果此时缓冲区满了，后面到达的报文将直接被丢弃。这个对实时应用来说很重要，比如：视频通话、直播等应用。

因此UDP适用于一次只传送少量数据、对可靠性要求不高的应用环境，数据报大小限制在64K以下。

![在这里插入图片描述][96a34b5cfd0541c9a229123cb56a3825.png_pic_center]

###### 15.6.2 开发步骤 ######

发送端程序包含以下四个基本的 步骤：

*  创建DatagramSocket ：默认使用系统随机分配端口号。
 *  创建DatagramPacket：将要发送的数据用字节数组表示，并指定要发送的数据长度，接收方的IP地址和端口号。
 *  调用 该DatagramSocket 类对象的 send方法 ：发送数据报DatagramPacket对象。
 *  关闭DatagramSocket 对象：发送端程序结束，关闭通信套接字。

接收端程序包含以下四个基本的步骤 ：

*  创建DatagramSocket ：指定监听的端口号。
 *  创建DatagramPacket：指定接收数据用的字节数组，起到临时数据缓冲区的效果，并指定最大可以接收的数据长度。
 *  调用 该DatagramSocket 类对象的receive方法 ：接收数据报DatagramPacket对象。。
 *  关闭DatagramSocket ：接收端程序结束，关闭通信套接字。

###### 15.6.3 演示发送和接收消息 ######

基于UDP协议的网络编程仍然需要在通信实例的两端各建立一个Socket，但这两个Socket之间并没有虚拟链路，这两个Socket只是发送、接收数据报的对象，Java提供了DatagramSocket对象作为基于UDP协议的Socket，使用DatagramPacket代表DatagramSocket发送、接收的数据报。

【1】发送端示例代码

package com.dingjiaxiong.udp;
    
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;
    import java.util.ArrayList;
    
    /**
     * @Projectname: BigDataStudy
     * @Classname: Send
     * @Author: Ding Jiaxiong
     * @Date:2023/4/28 14:05
     */
    
    public class Send {
        
    
        public static void main(String[] args) throws Exception {
        
    //		1、建立发送端的DatagramSocket
            DatagramSocket ds = new DatagramSocket();
    
            //要发送的数据
            ArrayList<String> all = new ArrayList<String>();
            all.add("尚硅谷让天下没有难学的技术！");
            all.add("学高端前沿的IT技术来尚硅谷！");
            all.add("尚硅谷让你的梦想变得更具体！");
            all.add("尚硅谷让你的努力更有价值！");
    
            //接收方的IP地址
            InetAddress ip = InetAddress.getByName("127.0.0.1");
            //接收方的监听端口号
            int port = 9999;
            //发送多个数据报
            for (int i = 0; i < all.size(); i++) {
        
    //			2、建立数据包DatagramPacket
                byte[] data = all.get(i).getBytes();
                DatagramPacket dp = new DatagramPacket(data, 0, data.length, ip, port);
    //			3、调用Socket的发送方法
                ds.send(dp);
            }
    
    //		4、关闭Socket
            ds.close();
        }
    }

【2】接收端示例代码

package com.dingjiaxiong.udp;
    
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    
    /**
     * @Projectname: BigDataStudy
     * @Classname: Receive
     * @Author: Ding Jiaxiong
     * @Date:2023/4/28 14:05
     */
    
    public class Receive {
        
    
        public static void main(String[] args) throws Exception {
        
    //		1、建立接收端的DatagramSocket，需要指定本端的监听端口号
            DatagramSocket ds = new DatagramSocket(9999);
    
            //一直监听数据
            while (true) {
        
                //2、建立数据包DatagramPacket
                byte[] buffer = new byte[1024 * 64];
                DatagramPacket dp = new DatagramPacket(buffer, buffer.length);
    
                //3、调用Socket的接收方法
                ds.receive(dp);
    
                //4、拆封数据
                String str = new String(dp.getData(), 0, dp.getLength());
                System.out.println(str);
            }
    
    //        ds.close();
        }
    }

运行结果

![在这里插入图片描述][4c1146ee89c04c479ca80b514f6abb69.png_pic_center]

![在这里插入图片描述][f34e1cdb66cd4420b576b156d433f6ac.png_pic_center]

[9a9de81357984774b7ef36c38c134f10.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/b6ea09bbb44a4b1bb7282a4e3633a9ac.png
[96a34b5cfd0541c9a229123cb56a3825.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/7967de843216487f9cedb30eb59fb415.png
[4c1146ee89c04c479ca80b514f6abb69.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/d01659718af349aea81c515e91ac925d.png
[f34e1cdb66cd4420b576b156d433f6ac.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/162cc9c7dba04d28b62553bf67612381.png