基于UDP的套接字通信

udp是一个面向无连接的,不安全的,报式传输层协议,udp的通信过程默认也是阻塞的。使用UDP进行通信,服务器和客户端的处理步骤比TCP要简单很多,并且两端是对等的 (通信的处理流程几乎是一样的),也就是说并没有严格意义上的客户端和服务器端。

UDP通信不需要建立连接 ,因此不需要进行connect()操作,在通信过程中,每次都需要指定数据接收端的IP和端口。UDP不对收到的数据进行排序,在UDP报文的首部中并没有关于数据顺序的信息。
UDP对接收到的数据报不回复确认信息,发送端不知道数据是否被正确接收,也不会重发数据。如果发生了数据丢失,不存在丢一半的情况,如果丢当前这个数据包就全部丢失了 

UDP通信过程虽然默认还是阻塞的,但是通信函数和TCP不同,操作函数原型如下:

// 接收数据, 如果没有数据,该函数阻塞
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);

参数:

  • sockfd: 基于udp的通信的文件描述符
  • buf: 指针指向的地址用来存储接收的数据
  • len: buf指针指向的内存的容量, 最多能存储多少字节
  • flags: 设置套接字属性,一般使用默认属性,指定为0即可
  • src_addr: 发送数据的一端的地址信息,IP和端口都存储在这里边, 是大端存储的,如果这个参数中的信息对当前业务处理没有用处, 可以指定为NULL, 不保存这些信息
  • addrlen: 类似于accept() 函数的最后一个参数, 是一个传入传出参数,传入的是src_addr参数指向的内存的大小, 传出的也是这块内存的大小。如果src_addr参数指定为NULL, 这个参数也指定为NULL即可
  • 返回值:成功返回接收的字节数,失败返回-1
// 发送数据函数
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: 参数 dest_addr 指向的内存大小
  • 返回值:函数调用成功返回实际发送的字节数,调用失败返回-1 

服务端代码示例:

在UDP通信过程中,服务器和客户端都可以作为数据的发送端和数据接收端,假设服务器端是被动接收数据,客户端是主动发送数据,那么在服务器端就必须绑定固定的端口了。

#include <iostream>
#include <arpa/inet.h>
#include <unistd.h>
#include <cstring>int main() {int fd = socket(AF_INET, SOCK_DGRAM, 0);if (fd == -1) {perror("socket");return -1;}// 初始化服务器地址sockaddr_in server_addr;server_addr.sin_family = AF_INET;server_addr.sin_port = htons(9999);  server_addr.sin_addr.s_addr = INADDR_ANY;if (bind(fd, (struct sockaddr*)&server_addr, sizeof(server_addr)) == -1) {perror("bind failed");exit(EXIT_FAILURE);
}char buffer[8888];sockaddr_in client_addr;socklen_t client_addr_len = sizeof(client_addr);while (1) {// 接收客户端数据ssize_t recv_len = recvfrom(fd, buffer, sizeof(buffer)-1, 0,(struct sockaddr*)&client_addr,&client_addr_len);if (recv_len == -1) {perror("recvfrom failed");continue;}buffer[recv_len] = '\0';  // 确保字符串终止// 打印客户端信息char client_ip[INET_ADDRSTRLEN];inet_ntop(AF_INET, &client_addr.sin_addr, client_ip, INET_ADDRSTRLEN);std::cout << "Client (" << client_ip << ":" << ntohs(client_addr.sin_port) << "): " << buffer << std::endl;// 构造响应(添加前缀)char prefix[] = "server say:";char response[sizeof(buffer)];sprintf(response, "%s%s", prefix, buffer);// 发送响应(使用正确的长度)ssize_t send_len = sendto(fd, response, strlen(response), 0,(const struct sockaddr*)&client_addr,client_addr_len);if (send_len == -1) {perror("sendto failed");continue;}}close(fd);return 0;
}

作为数据接收端,服务器端通过bind()函数绑定了固定的端口,然后基于这个固定的端口通过recvfrom()函数接收客户端发送的数据,同时通过这个函数也得到了数据发送端的地址信息(recvfrom的第三个参数),这样就可以通过得到的地址信息通过sendto()函数给客户端回复数据了。

客户端代码示例:

#include <iostream>
#include <arpa/inet.h>
#include <string>
#include <unistd.h>
#include <pthread.h>  int main() {int fd = socket(AF_INET, SOCK_DGRAM, 0);if (fd == -1) {perror("socket");return -1;}// 初始化服务器地址sockaddr_in server_addr;server_addr.sin_family = AF_INET;server_addr.sin_port = htons(9999);  inet_pton(AF_INET, "192.168.175.130", &server_addr.sin_addr);  int num = 0;std::string t = std::to_string(pthread_self());std::string s = ":Hello World!!!";while (1) {std::string S = t + s + std::to_string(++num);// 发送数据到服务器ssize_t send_len = sendto(fd, S.data(), S.size(), 0,(const struct sockaddr*)&server_addr,sizeof(server_addr));if (send_len == -1) {perror("sendto failed");continue;}// 接收服务器响应sockaddr_in server_response_addr;socklen_t addr_len = sizeof(server_response_addr);char buffer[1024] = {0};ssize_t recv_len = recvfrom(fd, buffer, sizeof(buffer)-1, 0,(struct sockaddr*)&server_response_addr,&addr_len);if (recv_len == -1) {perror("recvfrom failed");continue;}// 打印服务器地址和响应char str[INET_ADDRSTRLEN];std::cout << "Server (" << inet_ntop(AF_INET, &server_response_addr.sin_addr, str, INET_ADDRSTRLEN)<< ":" << ntohs(server_response_addr.sin_port) << "): " << buffer << std::endl;sleep(1);}close(fd);return 0;
}

作为数据发送端,客户端不需要绑定固定端口,客户端使用的端口是随机绑定的(也可以调用bind()函数手动进行绑定)。

同时开启三个客户端一个服务端运行结果:

 

UDP是一种无连接的传输层协议,其特性天然支持多客户端同时通信,服务器不需要与每个客户端建立持久连接,只需接收来自不同源地址的数据包,每个客户端发送的 UDP 数据包都是独立的,服务器可以逐个处理,每个数据包都包含发送方的 IP 和端口信息,服务器可以据此区分不同客户端。

所以可以启动多个客户端与服务器进行通信,UDP 协议的特性会确保每个客户端的请求被正确路由和处理。

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

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

相关文章

华为CE交换机抓包

capture-packet interface 100GE1/0/5 destination file 001.cap packet-len 64 注&#xff1a;早期版本&#xff08;disp device&#xff09;可能在系统视图下&#xff08;sys&#xff09; 抓完包后可以看到对应文件&#xff08;早期版本在根目录下&#xff09;&#xff1a;…

Python 数据分析与可视化 Day 3 - Pandas 数据筛选与排序操作

&#x1f3af; 今日目标 掌握 DataFrame 的条件筛选&#xff08;布尔索引&#xff09;学会多条件筛选、逻辑运算熟练使用排序&#xff08;sort_values&#xff09;提升数据组织力结合列选择进行数据提取分析 &#x1f9ea; 一、列选择与基本筛选 ✅ 选择单列 / 多列 df[&quo…

Vite项目初始化与配置

下面,我们来系统的梳理关于 Vite 项目初始化与配置 的基本知识点: 一、Vite 核心概念与优势 1.1 什么是 Vite? Vite(法语意为 “快速”)是新一代的前端构建工具,由 Vue.js 作者尤雨溪开发。它解决了传统构建工具(如 Webpack)在开发环境中的性能瓶颈问题。 1.2 Vite …

Transformer中的核心问题 知识点汇总

Transformer架构图 transformer整体架构 1. Transformer 的参数配置 Transformer 的Encoder层和Decoder层都使用6个注意力模块&#xff0c;所有的子网络的输出维度均为512维&#xff0c;多头注意力部分使用了8个注意力头。 2. 归一化的方式 归一化的方式为LayerNorm&#xff0c…

python web开发-Flask数据库集成

Flask 数据库集成完全指南&#xff1a;Flask-SQLAlchemy 实践 1. 引言 数据库是现代Web应用的核心组件&#xff0c;Flask通过Flask-SQLAlchemy扩展提供了强大的数据库集成能力。本文将全面介绍如何在Flask应用中使用Flask-SQLAlchemy进行数据库操作&#xff0c;涵盖从基础配置…

一站式用AI编程神奇Cursor/Trae(VScode环境)开发运行Scala应用

平时开发时&#xff0c;我们常用 IDEA 搭配 Scala 来开发 Spark 或 Flink 等大数据应用。但如今像 Cursor 这样的编程神器层出不穷&#xff0c;它们只支持 VSCode。要是 Scala 应用能在 VSCode 环境下便捷运行&#xff0c;我们就无需在 VSCode 开发、却在 IDEA 运行&#xff0c…

【Django开发】django美多商城项目完整开发4.0第2篇:项目准备,配置【附代码文档】

教程总体简介&#xff1a;美多商城 商业模式介绍 1.B2B--企业对企业 2.C2C--个人对个人 5.O2O--线上到线下 开发流程 说明&#xff1a; 需求分析 1. 用户部分 注册 登录 个人信息 地址管理 修改密码 3. 购物车部分 购物车管理 项目架构 创建工程 1. 在git平台创建工程 2. 添加前…

基于 OpenCV 的图像亮度、对比度与锐度调节

图像亮度、对比度和锐度是图像质量感知的重要参数&#xff0c;调节这些属性常用于图像增强、图像美化或图像分析的预处理阶段。本文将基于 OpenCV 实现这三项基础图像处理功能&#xff0c;并提供滑动条交互界面与直方图可视化分析&#xff0c;方便调试和理解效果。 亮度调整 图…

WAF(web应用防火墙)的简单了解

WAF称之为Web应用防火墙&#xff0c;是一种专门设计用于保护web应用程序免受恶意攻击的安全设备&#xff0c;能实时监控过滤和拦截可能对网站造成危害的网络流量&#xff0c;从而避免网络服务器被恶意入侵导致性能异常、数据泄露、服务中断这些问题 (WAF是通过执行一系列针对HT…

跟着AI学习C# Day28

&#x1f4c5; Day 28&#xff1a;C# 源生成器&#xff08;Source Generators&#xff09;与编译时元编程 ✅ 学习目标&#xff1a; 理解什么是 源生成器&#xff08;Source Generator&#xff09;&#xff1b;掌握如何在 编译阶段生成 C# 代码&#xff0c;而不是运行时动态处…

设计模式精讲 Day 4:建造者模式(Builder Pattern)

【设计模式精讲 Day 4】建造者模式&#xff08;Builder Pattern&#xff09; 文章简述&#xff1a; 在软件开发中&#xff0c;对象的构造过程往往复杂且容易出错&#xff0c;尤其是在对象包含多个可选参数或构建步骤时。建造者模式&#xff08;Builder Pattern&#xff09;正是…

如何轻松地将联系人从 iPhone 转移到 iPhone?

也许您升级到最新的 iPhone 型号&#xff0c;或者需要切换到另一部 iPhone 来工作。无论如何&#xff0c;您不能错过您的联系人&#xff0c;这对每个人来说都是最重要的数据。因此&#xff0c;今天我们将分享 5 种如何将联系人从 iPhone 转移到 iPhone 的方法&#xff0c;帮助您…

【51单片机简单的流水灯程序问题】2022-5-24

1.利用单片机的P2口接8个发光二极管。简单的流水灯程序问题-编程语言-CSDN问答 2&#xff0e;发光二极管自由闪烁&#xff08;自己设计两种模式&#xff09;。 3&#xff0e;可通过按键实现暂停、启动以及不用模式的切换。 4. 利用Proteus绘制电路原理图 5. 元件选型&#xff1…

第七节:Vben Admin 最新 v5.0 (vben5) 快速入门 - 用户管理(上)

Vben5 系列文章目录 💻 基础篇 ✅ 第一节:Vben Admin 最新 v5.0 (vben5) 快速入门 ✅ 第二节:Vben Admin 最新 v5.0 (vben5) 快速入门 - Python Flask 后端开发详解(附源码) ✅ 第三节:Vben Admin 最新 v5.0 (vben5) 快速入门 - 对接后端登录接口(上) ✅ 第四节:Vben Ad…

1572. 矩阵对角线元素的和

给你一个正方形矩阵 mat&#xff0c;请你返回矩阵对角线元素的和。 请你返回在矩阵主对角线上的元素和副对角线上且不在主对角线上元素的和。 示例 1&#xff1a; 输入&#xff1a;mat [[1,2,3],[4,5,6],[7,8,9]] 输出&#xff1a;25 解释&#xff1a;对角线的和为&#xf…

供应链场景使用ClickHouse最佳实践

一、概述 ClickHouse是一款由俄罗斯公司Yandex开发的开源列式数据库管理系统&#xff0c;以其高性能的分析查询能力和高压缩比著称。供应链场景中&#xff0c;数据量大且数据类型复杂&#xff0c;需要高效的数据存储和快速的查询性能&#xff0c;ClickHouse在这些方面具有显著…

RA4M2开发IOT(0)----安装e² studio

RA4M2开发IOT.0--安装e studio 概述视频教学样品申请安装 概述 瑞萨电子灵活配置软件包 (FSP) 是用于嵌入式系统设计的高质量增强型软件包&#xff0c;支持瑞萨电子 RA 产品家族 Arm 微控制器&#xff0c;提供用户友好的界面且可灵活扩展&#xff0c;确保从入门级到高性能的整…

【Ambari3.0.0 部署】Step2—免密登陆认证-适用于el8

如果有其他系统部署需求可以参考原文 戳我->所有组件编译教程 戳我->获取部署源代码 一、免密登录认证 &#x1f510; 在多台服务器协同工作的环境中&#xff0c;免密登录&#xff08;SSH 免密认证&#xff09;是一种常见的优化手段&#xff0c;能够极大地提升运维效率&…

网站自助广告投放系统源码 附安装教程(源码下载)

网站自助广告投放系统源码 全自动无人化出售网站广告位 站长必备 源码测试可用&#xff0c;部分加密。感兴趣自行下载 源码下载&#xff1a;https://download.csdn.net/download/m0_66047725/91093092 更多资源下载&#xff1a;关注我 图片&#xff1a;

日常运维问题汇总-15

42.SD开票计划产生的预收款在正式开票时未自动清账 统驭科目&#xff08;应收、预收&#xff09;对应的字段状态组中附加科目设置销售订单字段设置为了隐藏导致&#xff0c;更改为“可选输入项” 43.MIGO取消凭证时&#xff0c;用户反馈发现除一行外&#xff0c;其它都不能取消…