day-04 基于UDP的服务器端/客户端

一.理解UDP

（一）UDP套接字的特点

UDP套接字具有以下特点：

  • 无连接性：UDP是一种无连接的协议，这意味着在发送数据之前，不需要在发送方和接收方之间建立连接。每个UDP数据包都是独立的，它们可以独立地发送和接收，而不需要维护连接状态。

  • 不可靠性：UDP是一种不可靠的协议，这意味着它不提供数据传输的可靠性保证。UDP数据包在发送过程中可能会丢失、重复、乱序或损坏，而UDP协议本身不提供任何机制来检测和纠正这些问题。因此，应用程序需要自行处理这些问题。

  • 高效性：由于UDP不需要建立连接和维护连接状态，它的开销比TCP更小，传输效率更高。UDP适用于那些对实时性要求较高，但对数据可靠性要求相对较低的应用场景，如音频和视频流传输。

  • 面向数据报：UDP是一种面向数据报的协议，每个UDP数据包都是一个独立的数据报，具有固定的大小。UDP数据包的大小限制为64KB，超过这个大小的数据需要进行分片和重新组装。

  • 支持多播和广播：UDP支持多播和广播功能，可以将数据同时发送给多个接收方。多播是一种一对多的通信方式，广播是一种一对所有的通信方式。

        总的来说，UDP套接字具有无连接性、不可靠性、高效性、面向数据报和支持多播和广播等特点。它适用于那些对实时性要求较高，但对数据可靠性要求相对较低的应用场景。

（二）UDP内部工作原理

UDP的内部工作原理如下：

  • 创建套接字：在UDP通信之前，需要创建UDP套接字。套接字是一个网络通信的端点，用于发送和接收数据。通过调用操作系统提供的套接字API，可以创建一个UDP套接字。

  • 绑定端口：在创建UDP套接字后，需要将套接字绑定到一个特定的端口上。这样，其他应用程序就可以通过指定该端口来与UDP套接字进行通信。

  • 发送数据：要发送数据，应用程序将数据写入UDP套接字的发送缓冲区。操作系统将从发送缓冲区中获取数据，并将其封装成UDP数据包。然后，操作系统将UDP数据包发送到目标IP地址和端口。

  • 接收数据：要接收数据，应用程序需要监听UDP套接字。当有UDP数据包到达时，操作系统将从网络中接收数据包，并将其放入UDP套接字的接收缓冲区。应用程序可以从接收缓冲区中读取数据。

  • 处理数据：应用程序可以从接收缓冲区中读取数据，并对数据进行处理。由于UDP是无连接的协议，每个UDP数据包都是独立的，应用程序需要自行处理数据包的顺序、丢失、重复和损坏等问题。

  • 关闭套接字：当UDP通信结束时，应用程序可以关闭UDP套接字，释放相关资源。

        总的来说，UDP的内部工作原理涉及创建套接字、绑定端口、发送数据、接收数据和处理数据等步骤。UDP是一种简单的协议，不提供连接状态维护和可靠性保证，但具有较低的开销和较高的传输效率。

（三）UDP的高效使用

要高效使用UDP，可以考虑以下几点：

  • 数据包大小：UDP数据包的大小限制为64KB，超过这个大小的数据需要进行分片和重新组装。为了提高传输效率，可以尽量减小数据包的大小，避免数据分片和重新组装的开销。

  • 数据压缩：对于需要传输的数据，可以考虑使用数据压缩算法进行压缩，减小数据包的大小。常见的数据压缩算法包括gzip、zlib等。

  • 并发处理：UDP是无连接的协议，每个UDP数据包都是独立的。为了提高处理效率，可以使用多线程或多进程的方式，并发处理接收到的UDP数据包。

  • 丢包处理：由于UDP是不可靠的协议，数据包在传输过程中可能会丢失。为了提高可靠性，可以在应用层实现丢包检测和重传机制。例如，可以使用序列号和确认应答的方式来检测丢包，并进行重传。

  • 超时设置：为了避免数据包长时间滞留在网络中，可以设置合适的超时时间。如果在超时时间内没有收到对应的确认应答，可以进行重传。

  • 流量控制：为了避免发送方发送过多的数据导致接收方无法及时处理，可以实现流量控制机制。例如，可以使用滑动窗口的方式控制发送方的发送速率。

  • 多播和广播：UDP支持多播和广播功能，可以将数据同时发送给多个接收方。通过合理使用多播和广播，可以提高数据传输的效率。

        总的来说，要高效使用UDP，可以考虑数据包大小、数据压缩、并发处理、丢包处理、超时设置、流量控制和多播/广播等方面的优化策略。根据具体的应用场景和需求，可以选择适合的优化方法。

二.实现基于UDP的服务器端/客户端

1.UDP中的服务器端和客户端没有连接

2.UDP服务器端和客户端均只需一个套接字

3.基于UDP的数据I/O函数

基于UDP的数据I/O函数通常使用以下两个函数：

1.sendto()：该函数用于向指定的目标地址发送UDP数据包。它的函数原型如下：

ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen);

        参数说明：

  • sockfd：UDP套接字的文件描述符。
  • buf：要发送的数据的指针。
  • len：要发送的数据的字节数。
  • flags：发送标志，通常设置为0。
  • dest_addr：目标地址的结构体指针，包括IP地址和端口号。
  • addrlen：目标地址结构体的长度。

        该函数将指定的数据发送到目标地址。如果发送成功，返回发送的字节数；如果发送失败，返回-1，并设置相应的错误码。

2.recvfrom()：该函数用于从指定的源地址接收UDP数据包。它的函数原型如下：

ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);

        参数说明：

  • sockfd：UDP套接字的文件描述符。
  • buf：接收数据的缓冲区指针。
  • len：接收数据的最大字节数。
  • flags：接收标志，通常设置为0。
  • src_addr：源地址的结构体指针，用于存储发送方的IP地址和端口号。
  • addrlen：源地址结构体的长度。

        该函数从指定的UDP套接字接收数据，并将数据存储到指定的缓冲区中。如果接收成功，返回接收的字节数；如果接收失败，返回-1，并设置相应的错误码。

4.基于UDP的回声服务器端/客户端

uecho_server.cpp
#include <iostream>
#include <cstring>
#include <arpa/inet.h>
#include <sys/socket.h>#define BUFFER_SIZE 1024int main() {// 创建UDP套接字int server_socket = socket(AF_INET, SOCK_DGRAM, 0);// 绑定服务器地址和端口struct sockaddr_in server_address{};server_address.sin_family = AF_INET;server_address.sin_addr.s_addr = htonl(INADDR_ANY);server_address.sin_port = htons(8888);bind(server_socket, (struct sockaddr*)&server_address, sizeof(server_address));std::cout << "服务器已启动，等待客户端连接..." << std::endl;while (true) {// 接收数据char buffer[BUFFER_SIZE];struct sockaddr_in client_address{};socklen_t client_address_length = sizeof(client_address);ssize_t received_bytes = recvfrom(server_socket, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&client_address, &client_address_length);buffer[received_bytes] = '\0';std::cout << "接收到来自客户端 " << inet_ntoa(client_address.sin_addr) << " 的数据：" << buffer << std::endl;// 发送数据回客户端sendto(server_socket, buffer, strlen(buffer), 0, (struct sockaddr*)&client_address, client_address_length);}return 0;
}
uecho_client.cpp
#include <iostream>
#include <cstring>
#include <arpa/inet.h>
#include <sys/socket.h>#define BUFFER_SIZE 1024int main() {// 创建UDP套接字int client_socket = socket(AF_INET, SOCK_DGRAM, 0);// 服务器地址和端口struct sockaddr_in server_address{};server_address.sin_family = AF_INET;server_address.sin_addr.s_addr = inet_addr("127.0.0.1");server_address.sin_port = htons(8888);while (true) {// 输入要发送的数据char message[BUFFER_SIZE];std::cout << "请输入要发送的数据：";std::cin.getline(message, BUFFER_SIZE);// 发送数据到服务器sendto(client_socket, message, strlen(message), 0, (struct sockaddr*)&server_address, sizeof(server_address));// 接收服务器返回的数据char buffer[BUFFER_SIZE];socklen_t server_address_length = sizeof(server_address);ssize_t received_bytes = recvfrom(client_socket, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&server_address, &server_address_length);buffer[received_bytes] = '\0';std::cout << "接收到服务器返回的数据：" << buffer << std::endl;}return 0;
}

5.UDP的数据传输特性和调用connect函数

        UDP存在数据边界，所以调用几次 sendto 函数去发送，就调用几次 recvfrom 函数去接收。

（1）已连接（connected）UDP套接字和未连接（unconnected）UDP套接字

        sendto 函数的传输阶段

  •         向UDP套接字注册目标IP和端口号
  •         传输数据
  •         删除UDP套接字中注册的目标地址信息

        UDP套接字默认属于未连接套接字。但在对同一主机进行通信时，过多的增删套接字中目标地址信息，很明显显得多余。所以将UDP套接字变成已连接套接字会提高效率。

三.总结

1.UDP为什么比TCP速度快？为什么TCP数据传输可靠而UDP数据传输不可靠？

        UDP和TCP不同，不进行流量控制。由于该控制涉及到套接字的连接和结束，以及整个数据收发过程，因此，TCP传输的数据是可以信赖的。相反，UDP不进行这种控制，因此无法信任数据的传输，但正因UDP不进行流量传输，所以比TCP更快。

2.UDP数据包向对方主机的UDP套接字传递过程中，IP和UDP分别负责哪些部分？

IP负责链路选择。UDP负责端到端的传输

3.UDP一般比TCP快，但更具交换数据的特点，其差异可大可小。请说明何种情况下UDP的性能优于TCP？

UDP和TCP不同，不经过连接以及断开SOCKET的过程。因此，在频繁的连接及断开的情况下，UDP的数据收发能力会凸显出更好的性能。

4.客户端TCP套接字调用connect函数时自动分配IP和端口号。UDP不调用bind函数，那什么时候分配IP和端口号？

首次调用sendto函数时，发现未分配信息，则给对应的套接字自动分配IP和端口号。

5.TCP客户端必须调用connect函数，而UDP中可以选择性调用。请问，在UDP中调用connect函数有哪些好处？

每当以UDP套接字为对象调用connect函数时，都要经过以下过程：

第一阶段：为目标UDP注册端口和IP

第二阶段：数据传输

第三阶段：删除UDP注册的IP和端口信息

其中，只要调用connect函数，就可以忽略每次传输数据时反复进行的第一阶段和第三阶段。然而，每次调用connect函数并不意味着经过连接过程，只是将IP地址和端口号指定在UDP的发送对象上。这样connect函数使用后，还可以使用write、read函数进行数据处理，而不必使用sendto、recvfrom函数。

6.收发的信息打印在控制台。

uecho_server.cpp

/********************************uchar_server.cpp***********************************/
#include <iostream>
#include <cstring>
#include <cstdlib>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define BUF_SIZE 30void error_handling(const char *message);int main(int argc, char *argv[])
{int serv_sock;char message[BUF_SIZE];int str_len;socklen_t clnt_adr_sz;struct sockaddr_in serv_adr, clnt_adr;if(argc != 2){std::cout << "Usage : " << argv[0] << " <port>" << std::endl;exit(1);}serv_sock = socket(PF_INET, SOCK_DGRAM, 0);if(serv_sock == -1)error_handling("UDP socket creation error");memset(&serv_adr, 0, sizeof(serv_adr));serv_adr.sin_family = AF_INET;serv_adr.sin_addr.s_addr = htonl(INADDR_ANY);serv_adr.sin_port = htons(atoi(argv[1]));if(bind(serv_sock, (struct sockaddr*)&serv_adr, sizeof(serv_adr)) == -1)error_handling("bind() error");clnt_adr_sz = sizeof(clnt_adr);while(1) {str_len = recvfrom(serv_sock, message, BUF_SIZE, 0, (struct sockaddr*)&clnt_adr, &clnt_adr_sz);message[str_len] = 0;std::cout << "Message from client: " << message<<std::endl;std::cout << "Insert message(q to quit): ";std::cin.getline(message, sizeof(message));if(!strcmp(message,"q") || !strcmp(message,"Q"))    break;sendto(serv_sock, message, strlen(message), 0, (struct sockaddr*)&clnt_adr, clnt_adr_sz);}   close(serv_sock);return 0;
}void error_handling(const char *message)
{std::cerr << message << std::endl;exit(1);
}

uecho_client.cpp

/********************************uchar_client.cpp***********************************/
#include <iostream>
#include <cstring>
#include <cstdlib>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>#define BUF_SIZE 30void error_handling(const char *message);int main(int argc, char *argv[])
{int sock;char message[BUF_SIZE];int str_len;socklen_t adr_sz;struct sockaddr_in serv_adr, from_adr;if(argc != 3){std::cout << "Usage : " << argv[0] << " <IP> <port>" << std::endl;exit(1);}sock = socket(PF_INET, SOCK_DGRAM, 0);   if(sock == -1)error_handling("socket() error");memset(&serv_adr, 0, sizeof(serv_adr));serv_adr.sin_family = AF_INET;serv_adr.sin_addr.s_addr = inet_addr(argv[1]);serv_adr.sin_port = htons(atoi(argv[2]));while(1){std::cout << "Insert message(q to quit): ";std::cin.getline(message, sizeof(message));     if(!strcmp(message,"q") || !strcmp(message,"Q"))    break;sendto(sock, message, strlen(message), 0, (struct sockaddr*)&serv_adr, sizeof(serv_adr));adr_sz = sizeof(from_adr);str_len = recvfrom(sock, message, BUF_SIZE, 0, (struct sockaddr*)&from_adr, &adr_sz);message[str_len] = 0;std::cout << "Message from server: " << message<<std::endl;}   close(sock);return 0;
}void error_handling(const char *message)
{std::cerr << message << std::endl;exit(1);
}

存在问题：

  • 1.在输入数据的过程中，如果时间间隔稍微长一点，就无法完整的传输数据
  • 2.无法确定是否结束传输

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/73384.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

FOXBORO FBM232 P0926GW 自动化控制模块

FOXBORO FBM232 P0926GW 自动化控制模块

Foxboro FBM232 P0926GW 是 Foxboro&#xff08;福克斯博罗&#xff09;自动化控制系统的一部分&#xff0c;通常用于监测和控制工业过程。以下是关于这种类型的自动化控制模块可能具有的一些常见功能&#xff1a; 数字输入通道&#xff1a; FBM232 P0926GW 控制模块通常具有多…
阅读更多...
【漏洞库】Fastjson_1.2.24_rce

【漏洞库】Fastjson_1.2.24_rce

文章目录 漏洞描述漏洞编号漏洞评级影响版本漏洞复现- 利用工具- 漏洞环境- 漏洞扫描- 漏洞验证- 深度利用- GetShell- EXP 编写 漏洞挖掘- 指纹信息 修复建议- 漏洞修复 漏洞原理 漏洞描述 Fastjson 存在反序列化远程代码执行漏洞&#xff0c;当应用或系统使用 Fastjson 对由…
阅读更多...
十一、做高并发内存池项目过程中遇到的bug以及调试bug的方法和心得

十一、做高并发内存池项目过程中遇到的bug以及调试bug的方法和心得

十一、做高并发内存池项目过程中遇到的bug以及调试bug的方法和心得 第一个bug是内存问题&#xff0c;程序直接崩溃&#xff0c;问题出现在&#xff1a;GetOneSpan函数中的切分span的时候结尾的span1的next没有置空。 第二个bug是还小内存块给span的时候找不到小内存所属的spa…
阅读更多...
使用Android原生制作毛玻璃效果图片

使用Android原生制作毛玻璃效果图片

毛玻璃效果&#xff0c;也被称为模糊效果&#xff0c;是许多现代应用中流行的一种视觉效果。在 Android 中&#xff0c;我们可以通过多种方式实现该效果。本文将探讨如何使用 Android 原生的 Bitmap 类和 RenderScript 来实现毛玻璃效果。 1. 准备工作 首先&#xff0c;你需要…
阅读更多...
BLE Mesh蓝牙mesh网多跳大数据量高带宽传输数据方法

BLE Mesh蓝牙mesh网多跳大数据量高带宽传输数据方法

1、BLE Mesh数据传输现状 BLE Mesh网络技术是低功耗蓝牙的一个进阶版&#xff0c;Mesh扩大了蓝牙在应用中的规模和范围&#xff0c;因为它同时支持超过三万个网络节点&#xff0c;可以跨越大型建筑物&#xff0c;不仅可以使得医疗健康应用更加方便快捷&#xff0c;还能监测像学…
阅读更多...
IDea寻找冲突的依赖包

IDea寻找冲突的依赖包

场景&#xff1a;boot项目运行时&#xff0c;提示log4j2依赖包冲突。 SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/D:/maven/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar!/org/slf4j/impl/Stati…
阅读更多...
HTML5Plus

HTML5Plus

之前写过在 vue 中使用 mui 框架的方法&#xff0c;因为用 vue 开发后打包 5App 会有一些问题&#xff0c;所以当时用到了&#xff0c;最近又一次开发移动端&#xff0c;不同的是这次使用的是 vue3 开发的&#xff0c;导致之前使用的 vue-awesome-mui 依赖不能使用了&#xff0…
阅读更多...
快速完成工信部APP备案流程_以阿里云APP备案为例

快速完成工信部APP备案流程_以阿里云APP备案为例

阿里云APP备案流程分为6步&#xff0c;APP备案成功后应用可以上架&#xff0c;登录阿里云账号填写APP信息&#xff0c;等待阿里云初审&#xff0c;初审通过后进行工信部短信核验&#xff0c;管局审核通过后APP即可备案成功&#xff0c;最后移动APP应用可以分发平台上架&#xf…
阅读更多...
网络层重点协议-IP协议(结构分析)

网络层重点协议-IP协议(结构分析)

IP协议数据报格式 一.4位版本号 用来表示IP协议的版本&#xff0c;现有的IP协议只有两个版本IPv4和IPv6 二.4位首部长度 IP协议数据报报头的长度 三.8位服务类型 3位优先权字段&#xff08;已经弃用&#xff09;&#xff0c;4位TOS字段&#xff0c;和1位保留 字段&#xff08;必…
阅读更多...
企业的固定资产管理怎么操作

企业的固定资产管理怎么操作

企业是一家拥有多台大型设备的工厂&#xff0c;这些设备需要定期进行保养和维护&#xff0c;以确保其正常运转。而企业内部员工由于专业知识和技能的不同&#xff0c;需要分工协作才能更好地完成各项工作任务。因此&#xff0c;在设备资产管理方面&#xff0c;如何实现高效、便…
阅读更多...
SpringBoot常用注解

SpringBoot常用注解

SpringBoot常用注解 SpringBoot摒弃了xml配置方式&#xff0c;改为了全注解驱动。 准备 创建SpringBoot模块 pom.xml <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0" xmlns:xsi"ht…
阅读更多...
使用JS实现一个简单的观察者模式（Observer）

使用JS实现一个简单的观察者模式（Observer）

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ 手撸Observer⭐ 写在最后 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅&#xff01;这个专栏是为那些对Web开发感兴趣、刚刚踏入前端领…
阅读更多...
Unity之3D物理导航系统

Unity之3D物理导航系统

一 介绍 Unity自带寻路(导航)系统是unity官方自带的一种寻路系统。我们可以通过它来制作简单的寻路&#xff0c;比如可以制作点击某个位置&#xff0c;让角色自动的绕开障碍走到目标点的效果&#xff0c;比如可以制作敌人AI&#xff0c;让它可以通过NavMesh绕开障碍追击我方单…
阅读更多...
深入理解 JVM 之——字节码指令与执行引擎

深入理解 JVM 之——字节码指令与执行引擎

更好的阅读体验 \huge{\color{red}{更好的阅读体验}} 更好的阅读体验 类文件结构 Write Once&#xff0c;Run Anywhere 对于 C 语言从程序到运行需要经过编译的过程&#xff0c;只有经历了编译后&#xff0c;我们所编写的代码才能够翻译为机器可以直接运行的二进制代码&#x…
阅读更多...
【web开发】4、JavaScript与jQuery

【web开发】4、JavaScript与jQuery

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 一、JavaScript与jQuery二、JavaScript常用的基本功能1.插入位置2.注释3.变量4.数组5.滚动字符 三、jQuery常用的基本功能1.引入jQuery2.寻找标签3.val、text、appe…
阅读更多...
笔记 | 排序算法实现（Python）

笔记 | 排序算法实现（Python）

排序算法 一、选择排序二、合并/归并排序三、快速排序四、计数排序 排序类型时间复杂度选择排序(Selection Sort) O ( n 2 ) O(n^{2} ) O(n2)合并/归并排序&#xff08;Merge Sort&#xff09; O ( n log ⁡ n ) O(n\log n ) O(nlogn)快速排序(Quick Sort)平均情况 O ( n log ⁡…
阅读更多...
帧动画实现

帧动画实现

背景&#xff1a; pag实现痛点 文档&#xff1a;libpag参考文档 1.打包依赖的类型缺失问题 2.pagview初始化文件过大,影响小程序打包 3.兼容性较差关键帧动画实现痛点: 当关键帧变化过多的时候&#xff0c;无法准确分辨出需要写出多少个关键帧&#xff0c;以及各个关键帧的具…
阅读更多...
视频监控/视频汇聚/安防视频监控平台EasyCVR如何将默认快照的raw格式改为jpg/base64格式？

视频监控/视频汇聚/安防视频监控平台EasyCVR如何将默认快照的raw格式改为jpg/base64格式？

视频监控/视频汇聚/安防视频监控平台EasyCVR可拓展性强、视频能力灵活、部署轻快&#xff0c;可支持的主流标准协议有国标GB28181、RTSP/Onvif、RTMP等&#xff0c;以及支持厂家私有协议与SDK接入&#xff0c;包括海康Ehome、海大宇等设备的SDK等。视频云存储EasyCVR平台能在复…
阅读更多...
身份识别与鉴权技术调研方案

身份识别与鉴权技术调研方案

对称加密算法 对称加密方式又称为私钥加密方式&#xff0c;该方式的加密和解密过程使用同一个密钥&#xff0c;因此该密钥又称为共享密钥。如图2.2所示&#xff0c;在对称加密方式中&#xff0c;发送方使用对称加密算法和共享密钥处理原始数据&#xff0c;得到一个加密后的密文…
阅读更多...
IDEA新建的Moudle失效显示为灰色

IDEA新建的Moudle失效显示为灰色

现象&#xff1a;IDEA新建的Moudle失效显示为灰色&#xff01;&#xff01;&#xff01; 解决方案&#xff1a; 1. 右键点击父模块&#xff0c;选择Open Moudle Settings&#xff1a; 2. 点击加号&#xff0c;选择Import Moudle - 导入模块&#xff1a; 3. 找到对应模块的po…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023