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

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

前言

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

socket api

。

目录

一、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

构造方法（分为有参和无参）如下：**
方法签名方法说明DatagramSocket()创建一个UDP数据报套接字的Socket对象，绑定到本机任意一个随机端口（一般用于客户端）DatagramSocket(int port)创建一个UDP数据报套接字的Socket对象，绑定到本机指定的端口（一般用于服务端）

**

DatagramSocket类方法

：**
方法签名方法说明void receive(DatagramPacket p)从此套接字接收数据报（如果没有接收到数据报，该方法会阻塞等待）void send(DatagramPacket p)从此套接字发送数据报包（不会阻塞等待，直接发送）void close()关闭此数据报套接字
**我们可以看到前两个方法的参数都是

DatagramPacket

，UDP是一种面向数据报的传输层协议，传输数据的基本单位就是数据报，即

DatagramPacket对象

。**

四、DatagramPacket

**

DatagramPacket构造方法

：**
方法签名方法说明DatagramPacket(byte[] buf, int length)构造一个DatagramPacket以用来

接收数据报

，接收的数据保存在字节数组（第一个参数buf）中，接收指定长度（第二个参数length）DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)构造一个DatagramPacket以用来

发送数据报

，发送的数据为字节数组（第一个参数buf）中，从0到指定长度（第二个参数length）。

address指定目的主机的IP和端口号

**

DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)

：我们知道

DatagramPacket

表示一个UDP数据报，则这个数据报就必须承载一定的数据，通过手动指定的

byte[]

数组来作为存储数据的空间，然后通过

SocketAddress address

来指定目的ip和目的端口。**

**

DatagramPacket 方法

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

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

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

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

5.1服务器端

先来看服务器端的代码编写：
**上图代码中有时候创建对象的时候会失败，最典型的创建对象失败的原因就是

端口号被占用

。**
**关于端口号：端口号是用来区分主机上应用程序的，一个应用程序可以占据主机上多个端口，

通常情况下

一个端口只能被一个进程占用（当然这样说有些太过于绝对了，因为存在一些特殊情况，这里不展开讨论）。**
所以当端口已经被别的进程占用时，此时如果我们再创建socket对象来占用此端口的话就会报错。

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

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

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

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

DatagramSocket类方法中的receive(DatagramPacket p)方法中的

参数DatagramPacket p

是一个

输出型参数

，传入receive方法中的对象是一个空的对象，reveive内部就会对传入receive方法中的空的对象给

填充上

，当reveive方法执行完毕之后，就会得到一个充满内容的DatagramPacket

这里的DatagramPacker对象是用来保存数据的内存空间，其中这里内存空间的申请是需要我们手动进行申请的。
然后我们就可以将requestPacket传入到receive方法中，如下：

这里有异常直接抛出即可。

当服务器一旦启动之后并进入到while循环中，接着就会立即执行到receive方法。
我们知道，服务器并不知道什么时候发出请求，所以服务器要随时做好就接收来自客户端请求的信息。
**

但是当客户端的请求还没有达到服务器时。

此时服务器这边就会进入到

阻塞等待的状态

，直到阻塞等待到有请求到达客户端。**

**

requestPacket

是一个

DatagramPacket

对象，它通过

DatagramSocket

的

receive

方法接收到的数据报会被存储在这个对象中。

requestPacket.getData()

返回的是一个byte数组，代表接收到的数据报的内容。

requestPacket.getLength()

返回的是接收到的数据报的长度。
然后，通过String类的构造函数

String(byte[] bytes, int offset, int length)

将接收到的数据报的内容转换成字符串。在这个例子中，使用了读取到的数据报的内容作为字节数组，偏移量为0，长度为接收到的数据报的长度。
最终，request变量中存储的就是从数据报中提取出来的字符串内容。**

**

requestPacket.getSocketAddress()

：当前我们要把数据报发送给客户端，所以此时我们就需要知道客户端的ip和端口是什么，此类信息均在

DatagramPacket对象

中包含着，即

DatagramPacket

中就包含着通信双方的ip和端口号（即客户端的ip、端口；服务器端的ip、端口均在

DatagramPacket

中保存着），所以我们就可以通过

getSocketAddress()方法

获取到

当前客户端的ip和端口

。**

服务器端代码

importjava.io.IOException;importjava.net.DatagramPacket;importjava.net.DatagramSocket;importjava.net.SocketException;// Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么publicclassUdpEchoServer{privateDatagramSocket socket =null;// 构造方法publicUdpEchoServer(int port)throwsSocketException{
        socket =newDatagramSocket(port);}publicvoidstart()throwsIOException{System.out.println("服务器启动!!!");while(true){// 服务器需要长期反复的执行针对客户端请求处理的逻辑// 对于一个服务器来说要做的工作主要有三个主要环节"// 1.读取请求，并对请求进行解析DatagramPacket requestPacket =newDatagramPacket(newbyte[4096],4096);
            socket.receive(requestPacket);// 可以将DatagramPacket对象中的字节数组转换成字符串,这样的转字符串的前提时后续客户端发送的数据是一个文本字符串// 如果客户端发送的数据是一个二进制,这里就不合适了// 大体梳理一下:通过DatagramSocket类中的receive方法来读取到requestPacket（数据报对象）中的内容,// 然后再进一步的将数据报中的载荷提取并转换为字符串String request =newString(requestPacket.getData(),0, requestPacket.getLength());// 2.根据请求计算出响应String response =process(request);// 3.把相应返回给客户端// 此时要告知网卡要发送的内容以及，要发给谁两部分内容DatagramPacket responsePacket =newDatagramPacket(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);}}// 第二步:根据请求计算响应,由于我们写的程序是一个回显服务器,所以响应内容和请求是一致的,即请求是什么响应就是什么publicStringprocess(String request){return request;}publicstaticvoidmain(String[] args)throwsIOException{UdpEchoServer server =newUdpEchoServer(9090);
        server.start();}}

5.2客户端

客户端代码

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

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

**程序运行结果如下（

注意一定是服务器先开始运行

）：**


如果我们启动多个客户端的话，此时服务器依然是可以应对的。
此时我们需要对我们的IDEA进行一些设置，请看：



可以看到两个客户端同时在跑。

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