【网络编程】基于UDP数据报实现回显服务器/客户端程序

不念不忘少年蓝@ 2024-04-27 07:11 15阅读 0赞

> 个人主页：[兜里有颗棉花糖][Link 1]  
> 欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 [兜里有颗棉花糖][Link 1] 原创  
> 收录于专栏【[网络编程][Link 2]】【[Java系列][Java]】  
> 本专栏旨在分享学习网络编程的一点学习心得，欢迎大家在评论区交流讨论💌

**前言**

我们如果想让应用程序进行网络通信的话，就需要调用传输层为应用层提供的API。传输层提供的协议主要有两个：UDP和TCP，这两个协议提供了两套不同的API。操作系统给这些应用程序提供的这些用于网络通信的API起了一个名字，即`socket api`。

#### 目录 ####

*  一、UDP和TCP特点对比
 *  二、UDP数据报套接字编程
 *  三、DatagramSocket
 *  四、DatagramPacket
 *  五、通过UDP数据报实现回显服务器（echo server）
 *   *  5.1服务器端
     *  服务器端代码
     *  5.2客户端
     *  客户端代码

## 一、UDP和TCP特点对比 ##

UDP特点：无连接、不可靠传输、面向数据报，全双工。  
TCP特点：有连接、可靠传输、面向字节流，全双工。

*  **`连接`：我们知道JDBC编程中先创建DataSource，然后再通过DataSource创建Connection。对于TCP编程的话来存在像JDBC类似的连接方式。**
 *  **`可靠传输/不可靠传输`：可靠传输就是主机A尽可能的将消息传给zhujiB，并且当消息传输失败的时候主机A可以感知到，当然当消息传输成功的时候主机A可以得知自己发送的消息传输完毕。`TCP是可靠传输但是与此同时TCP付出的代价就是TCP在进行信息传输的时候传输效率有所降低`、`UDP是不可靠传输但是UDP在进行信息传输的时候，传输效率得到了提供。`**

> **网络安全方面（网络安指的是如果我们传输的数据被黑客）：有的地方提出TCP比UDP更加安全，这种说法是错误的。**

*  **- 面向字节流：TCP和文件操作是类似的，都是**流式**的操作。这里传输的单位是字节，我们称之为字节流。TCP协议的数据传输可以传输任意长度的字节流数据，但是，一次读写的数据数量通常是由发送方和接收方的缓冲区大小决定的（比如我们可以一次性读写50字节的数据，可以一次性读写100字节的数据。）。**
 *  **面向数据报：UDP是面向数据报读写的基本单位，单位是一个UDP数据包。在UDP协议中，数据被封装在UDP数据报中，每个UDP数据报包含一些列的数据和属性。**
 *  **全双工：全双工即一个通道可以双向通信，而半双工意思就是一个通道只能偶单向通信。我们家里使用的网线就是全双工的。**

## 二、UDP数据报套接字编程 ##

**UDP数据报套接字编程是使用UDP协议进行网络通信的一种编程方式。**

在Java中，UDP是通过`java.net.DatagramSocket`类和`java.net.DatagramPacket`类来提供API的。

**`java.net.DatagramSocket`类代表一个UDP套接字对象（`Socket对象`）**

> **操作系统使用文件这样的概念来管理软硬件资源（其实文件对于操作系统来说是一个非常广义的概念，不仅仅可以代表硬盘上的文件，也可以代表着其它情况的文件；文件这个概念其实有很多种含义：不仅仅是针对硬盘上的文件，也可以是其它的设备（比如键盘接入到计算机之后，计算机也是把键盘当作文件去进行处理，显示器接入到计算机之后，显示器也会被当作文件来处理））。**  
> **对于网卡来说操作系统也是使用文件的方式来管理网卡的，`表示网卡的这类文件我们就称之为socket文件`。**  
> **在Java中，`socker对象`就对应系统中的`socker文件`，而socker文件又是用来管理网卡的（即最终依然是落到网卡，我们要想进行网络通信的话必须要通过socker对象把网卡关联起来，然后我们才能基于网卡来发送接收数据）**

**在java中，`java.net.DatagramPacket`用来表示UDP数据报。**

> **`DatagramPacket对象`可以代表系统中设定的UDP数据报的二进制结构。**

**以上`java.net.DatagramSocket`类和`java.net.DatagramPacket`类是我们进行UDP编程中必不可少了两个类。**

## 三、DatagramSocket ##

**`DatagramSocket`是`UDP Socket`，用于发送和接收UDP数据报。**

**`DatagramSocket`构造方法（分为有参和无参）如下：**

<table> 
 <thead> 
  <tr> 
   <th>方法签名</th> 
   <th>方法说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>DatagramSocket()</td> 
   <td>创建一个UDP数据报套接字的Socket对象，绑定到本机任意一个随机端口（一般用于客户端）</td> 
  </tr> 
  <tr> 
   <td>DatagramSocket(int port)</td> 
   <td>创建一个UDP数据报套接字的Socket对象，绑定到本机指定的端口（一般用于服务端）</td> 
  </tr> 
 </tbody> 
</table>

![在这里插入图片描述][a8da062e406f42e6b95bf7aea357bd45.png]

**`DatagramSocket类方法`：**

<table> 
 <thead> 
  <tr> 
   <th>方法签名</th> 
   <th>方法说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>void receive(DatagramPacket p)</td> 
   <td>从此套接字接收数据报（如果没有接收到数据报，该方法会阻塞等待）</td> 
  </tr> 
  <tr> 
   <td>void send(DatagramPacket p)</td> 
   <td>从此套接字发送数据报包（不会阻塞等待，直接发送）</td> 
  </tr> 
  <tr> 
   <td>void close()</td> 
   <td>关闭此数据报套接字</td> 
  </tr> 
 </tbody> 
</table>

**我们可以看到前两个方法的参数都是`DatagramPacket`，UDP是一种面向数据报的传输层协议，传输数据的基本单位就是数据报，即`DatagramPacket对象`。**

## 四、DatagramPacket ##

**`DatagramPacket构造方法`：**

<table> 
 <thead> 
  <tr> 
   <th>方法签名</th> 
   <th>方法说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>DatagramPacket(byte[] buf, int length)</td> 
   <td>构造一个DatagramPacket以用来<code>接收数据报</code>，接收的数据保存在字节数组（第一个参数buf）中，接收指定长度（第二个参数length）</td> 
  </tr> 
  <tr> 
   <td>DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)</td> 
   <td>构造一个DatagramPacket以用来<code>发送数据报</code>，发送的数据为字节数组（第一个参数buf）中，从0到指定长度（第二个参数length）。<code>address指定目的主机的IP和端口号</code></td> 
  </tr> 
 </tbody> 
</table>

> **`DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)`：我们知道`DatagramPacket`表示一个UDP数据报，则这个数据报就必须承载一定的数据，通过手动指定的`byte[]`数组来作为存储数据的空间，然后通过`SocketAddress address`来指定目的ip和目的端口。**

**`DatagramPacket 方法`：**

<table> 
 <thead> 
  <tr> 
   <th>方法签名</th> 
   <th>方法说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>InetAddress getAddress()</td> 
   <td>从接收的数据报中，获取发送端主机IP地址；或从发送的数据报中，获取接收端主机IP地址</td> 
  </tr> 
  <tr> 
   <td>int getPort()</td> 
   <td>从接收的数据报中，获取发送端主机的端口号；或从发送的数据报中，获取接收端主机端口号</td> 
  </tr> 
  <tr> 
   <td>byte[] getData()</td> 
   <td>获取数据报中的数据，即<strong>获取的是UDP数据报中的载荷部分（即完整的应用层数据报）</strong></td> 
  </tr> 
 </tbody> 
</table>

## 五、通过UDP数据报实现回显服务器（echo server） ##

**Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么**

> **现在我们编写一个回显服务器程序：**

### 5.1服务器端 ###

> **先来看服务器端的代码编写：**![在这里插入图片描述][39ffecec94db4297bfbaa505c3a4be29.png]  
> **上图代码中有时候创建对象的时候会失败，最典型的创建对象失败的原因就是`端口号被占用`。**  
> **关于端口号：端口号是用来区分主机上应用程序的，一个应用程序可以占据主机上多个端口，`通常情况下`一个端口只能被一个进程占用（当然这样说有些太过于绝对了，因为存在一些特殊情况，这里不展开讨论）。**  
> **所以当端口已经被别的进程占用时，此时如果我们再创建socket对象来占用此端口的话就会报错。**

**对于一个服务器来说要做的工作主要有三个主要环节：**

*  **1.读取请求，并对请求进行解析**
 *  **2.根据请求计算出响应**
 *  **3.把相应返回给客户端**

**上述的三个环节对于第一步和第三步来说一般都是固定的流程和套路**

*  **`第一步：读取请求并对请求进行解析`：**

> ![在这里插入图片描述][f55de811043644319fe4d90f66f0774f.png]  
> DatagramSocket类方法中的receive(DatagramPacket p)方法中的`参数DatagramPacket p`是一个`输出型参数`，传入receive方法中的对象是一个空的对象，reveive内部就会对传入receive方法中的空的对象给`填充上`，当reveive方法执行完毕之后，就会得到一个充满内容的DatagramPacket

> ![在这里插入图片描述][dc08eea560e84d088143f7a681d8fc85.png]  
> **这里的DatagramPacker对象是用来保存数据的内存空间，其中这里内存空间的申请是需要我们手动进行申请的。**  
> 然后我们就可以将requestPacket传入到receive方法中，如下：  
> ![在这里插入图片描述][614cbfc3d6af430cbcf5a74d1c196737.png]  
> 这里有异常直接抛出即可。  
> ![在这里插入图片描述][1a889b593c2d4faaa400697ca854c40a.png]  
> **当服务器一旦启动之后并进入到while循环中，接着就会立即执行到receive方法。**  
> **我们知道，服务器并不知道什么时候发出请求，所以服务器要随时做好就接收来自客户端请求的信息。**  
> **`但是当客户端的请求还没有达到服务器时。`此时服务器这边就会进入到`阻塞等待的状态`，直到阻塞等待到有请求到达客户端。**

> ![在这里插入图片描述][8b0f6cbfc8204a1e80215e56806b7231.png]  
> **`requestPacket`是一个`DatagramPacket`对象，它通过`DatagramSocket`的`receive`方法接收到的数据报会被存储在这个对象中。  
> `requestPacket.getData()`返回的是一个byte数组，代表接收到的数据报的内容。`requestPacket.getLength()`返回的是接收到的数据报的长度。  
> 然后，通过String类的构造函数`String(byte[] bytes, int offset, int length)`将接收到的数据报的内容转换成字符串。在这个例子中，使用了读取到的数据报的内容作为字节数组，偏移量为0，长度为接收到的数据报的长度。  
> 最终，request变量中存储的就是从数据报中提取出来的字符串内容。**

> ![4d7c0bffccb540f5863f7ea00f809c79.png][]  
> **`requestPacket.getSocketAddress()`：当前我们要把数据报发送给客户端，所以此时我们就需要知道客户端的ip和端口是什么，此类信息均在`DatagramPacket对象`中包含着，即`DatagramPacket`中就包含着通信双方的ip和端口号（即客户端的ip、端口；服务器端的ip、端口均在`DatagramPacket`中保存着），所以我们就可以通过`getSocketAddress()方法`获取到`当前客户端的ip和端口`。**

### 服务器端代码 ###

import java.io.IOException;
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.SocketException;
    
    // Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么
    public class UdpEchoServer {
        
        private DatagramSocket socket = null;
    
        // 构造方法
        public UdpEchoServer(int port) throws SocketException {
        
            socket = new DatagramSocket(port);
        }
    
        public void start() throws IOException {
        
            System.out.println("服务器启动!!!");
            while(true) {
        
                // 服务器需要长期反复的执行针对客户端请求处理的逻辑
                // 对于一个服务器来说要做的工作主要有三个主要环节"
                // 1.读取请求，并对请求进行解析
                DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);
                socket.receive(requestPacket);
                // 可以将DatagramPacket对象中的字节数组转换成字符串,这样的转字符串的前提时后续客户端发送的数据是一个文本字符串
                // 如果客户端发送的数据是一个二进制,这里就不合适了
                // 大体梳理一下:通过DatagramSocket类中的receive方法来读取到requestPacket（数据报对象）中的内容,
                // 然后再进一步的将数据报中的载荷提取并转换为字符串
                String request = new String(requestPacket.getData(),0, requestPacket.getLength());
    
                // 2.根据请求计算出响应
                String response = process(request);
                // 3.把相应返回给客户端
    
                // 此时要告知网卡要发送的内容以及，要发给谁两部分内容
                DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,
                        requestPacket.getSocketAddress());
                socket.send(responsePacket);
                // 而对于这里的回显服务器来说不需要关心具体的流程，因为回显服务器请求是什么返回的响应就是什么
                // 但是对于一个商业级的服务器来说，最主要的代码就是完成第二步的代码编写
                // 记录日志，方便观察
                System.out.printf("[%s:%d] req: %s, resp : %s\n",requestPacket.getSocketAddress().toString(),requestPacket.getPort(),
                        request,response);
            }
        }
        // 第二步:根据请求计算响应,由于我们写的程序是一个回显服务器,所以响应内容和请求是一致的,即请求是什么响应就是什么
        public String process(String request) {
        
            return request;
        }
        public static void main(String[] args) throws IOException {
        
            UdpEchoServer server = new UdpEchoServer(9090);
            server.start();
        }
    }

### 5.2客户端 ###

![在这里插入图片描述][5af839fb4e06493aa61f84039bf4852c.png]

### 客户端代码 ###

import java.io.IOException;
    import java.net.*;
    import java.util.Scanner;
    
    public class UdpEchoClient {
        
        private DatagramSocket socket = null;
        private String serverIp;
        private int serverPort;
    
        // 服务器的ip和服务器的端口
        public UdpEchoClient(String ip,int port) throws SocketException {
        
            serverIp = ip;
            serverPort = port;
            // 下面的new操作就不需要再指定端口了,而是让系统随机分配一个空闲端口
            socket = new DatagramSocket();
        }
    
        // 让客户端反复的从控制台中读取用户输入的信息
        // 然后把这个内容构造成UDP请求发送给服务器，再读取服务器返回的UDP响应
        // 最终显示再客户端的屏幕上
        public void start() throws IOException {
        
            Scanner scanner = new Scanner(System.in);
            System.out.println("客户端启动!!!");
            while(true) {
        
                // 1.从控制台读取用户输入的用户输入的内容。
                System.out.printf("-->"); // 命令提示符来提示用户输入字符串
                String request = scanner.next();
                // 2.构造请求对象并发送给服务器
                DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,
                InetAddress.getByName(serverIp),serverPort);
                socket.send(requestPacket);
                // 3.读取服务器的响应,并解析出响应内容
                DatagramPacket responsePacket = new DatagramPacket(new byte[4096],4096);
                socket.receive(responsePacket);
                String response = new String(responsePacket.getData(),0,responsePacket.getLength());
                // 4.将结果打印到屏幕上
                System.out.println(response);
            }
        }
        public static void main(String[] args) {
        
        }
    }

> ![在这里插入图片描述][3f3f4b3ef41a4bbdb4c40e78424d46c4.png]![在这里插入图片描述][3d70d78702e14bd1938f456ebbd557fd.png]

**以上就是回显服务器程序的所有代码。**

> **程序运行结果如下（`注意一定是服务器先开始运行`）：**  
> ![在这里插入图片描述][bad106d738274e3b9e031394a719d043.png]  
> ![在这里插入图片描述][be51523b64734038ab4669f3520bc201.png]  
> **如果我们启动多个客户端的话，此时服务器依然是可以应对的。**  
> 此时我们需要对我们的IDEA进行一些设置，请看：  
> ![在这里插入图片描述][05803e92c33d42a0a2ea5557f1d130ad.png]  
> ![在这里插入图片描述][45f36daac8b04bc8bd3b9e56ffb1477f.png]  
> ![在这里插入图片描述][ad7b57da8a2c44e083e77d00bc868e2b.png]  
> **可以看到两个客户端同时在跑。**

**本文到这里就结束了，希望友友们可以支持一下一键三连哈。嗯，就到这里吧，再见啦！！！**

![在这里插入图片描述][9ea0d47836a34cab8d81f9ca2c82e87b.png]

[Link 1]: https://xiaofeizhu.blog.csdn.net/
[Link 2]: https://blog.csdn.net/m0_74352571/category_12535230.html?spm=1001.2014.3001.5482
[Java]: https://blog.csdn.net/m0_74352571/category_12520599.html?spm=1001.2014.3001.5482
[a8da062e406f42e6b95bf7aea357bd45.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/5defe0adb7a040e6beb6a6ccf86d57ce.png
[39ffecec94db4297bfbaa505c3a4be29.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/5d6bc44a575d47aa927f3188329d3af7.png
[f55de811043644319fe4d90f66f0774f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/af0ea25954d54f9c98128d2ab60e88e7.png
[dc08eea560e84d088143f7a681d8fc85.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/027f18ef7afa45268ac367edfd30a895.png
[614cbfc3d6af430cbcf5a74d1c196737.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/bd1a20288ef64102a64d7d652c0adc16.png
[1a889b593c2d4faaa400697ca854c40a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/553c25a0186a48d286ce1d900aab4ad8.png
[8b0f6cbfc8204a1e80215e56806b7231.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/856bfbcc01e6486d8efe56a04cb4a96f.png
[4d7c0bffccb540f5863f7ea00f809c79.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/3dd53974755b42b5872d9c19922844d7.png
[5af839fb4e06493aa61f84039bf4852c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/befe44e00b9f4ace9e9f43025bb85716.png
[3f3f4b3ef41a4bbdb4c40e78424d46c4.png]: https://img-blog.csdnimg.cn/direct/3f3f4b3ef41a4bbdb4c40e78424d46c4.png
[3d70d78702e14bd1938f456ebbd557fd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/e21b40794bcc44b292cb7d3351eff4be.png
[bad106d738274e3b9e031394a719d043.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/09f8cd11532b48959ceebee1d453e5c1.png
[be51523b64734038ab4669f3520bc201.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/f12609ca3fa14038a676962adb0a6693.png
[05803e92c33d42a0a2ea5557f1d130ad.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/fe34de4db7d046fda39e68ea520bd0b0.png
[45f36daac8b04bc8bd3b9e56ffb1477f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/2c5a21102b05465da70676d79d04eadf.png
[ad7b57da8a2c44e083e77d00bc868e2b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/aa773c06eade4da48dd5cc9cbb1533fc.png
[9ea0d47836a34cab8d81f9ca2c82e87b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/fe6f3773ec614f5f83cf06cee8c40b24.png