C++网络编程之IO多路复用（一）

概述

        在C++网络编程中，处理并发连接是一个非常关键的核心问题。为了有效管理来自多个客户端的请求，服务器需要能够同时监听多个套接字上的事件，这通常通过IO多路复用来实现。

        IO多路复用是一种工作机制，它可以让程序监视多个文件描述符（通常是套接字），等待其中一个或多个文件描述符变为就绪状态。一旦某个文件描述符就绪，即该文件描述符上可以进行无阻塞读写操作，操作系统就会通知应用程序。然后，应用程序就可以对该文件描述符进行相应的读写操作。

        使用IO多路复用后，不需要为每个连接创建一个独立的线程，节省了资源。同时，也避免了频繁的上下文切换开销，提高了效率。常见的IO多路复用技术主要有三种，分别为：select、poll、epoll。在本篇中，我们将重点介绍select，后续文章将介绍poll和epoll。

select

        select是最古老的IO多路复用API，几乎支持所有类型的Unix系统（包括：Windows、Linux、Mac等）。它的基本工作原理是：用户态进程将一组文件描述符传递给内核，由内核来检查这些文件描述符的状态变化；当调用返回时，会告诉用户哪些文件描述符已经准备好了读写操作。

        select函数的接口原型如下。

int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout);

        各个参数和返回值的含义如下。

        nfds：指定要监视的最大文件描述符值加1。

        readfds：指向一个集合，该集合包含了想要监视读就绪状态的文件描述符。

        writefds：指向一个集合，该集合包含了想要监视写就绪状态的文件描述符。

        exceptfds：指向一个集合，该集合包含了想要监视异常条件的文件描述符。

        timeout：一个时间结构体，指定了等待超时的时间。如果设置为NULL，则会一直阻塞，直到至少有一个文件描述符准备好。如果设置了具体时间，则在指定时间内没有事件发生将返回0。

        返回值：如果返回正数，这意味着至少有一个文件描述符已经准备好执行请求的操作（读、写或异常条件）。返回的具体数值，表示有多少个文件描述符已就绪。如果返回 0，这意味着在指定的超时时间内没有任何文件描述符准备好，并且超时时间已过。如果返回负数，这意味着调用过程中发生了错误。常见的原因包括传入了无效的参数或者系统本身遇到了问题。

        在Windows系统和Linux系统下使用select函数时，它们之间存在一些细微的差异，具体如下。

        1、头文件和库不同。

        Windows：需要包含winsock2.h头文件，且链接到Winsock库ws2_32.lib。

        Linux：需要包含sys/select.h头文件，不需要链接额外的库，因为select是标准POSIX库的一部分。

        2、类型不同。

        Windows：Socket类型为套接字句柄。

        Linux：Socket类型为文件描述符，这是所有IO操作的基础。

        3、FD_SETSIZE的定义不同。

        Windows：默认的FD_SETSIZE是64。

        Linux：默认的FD_SETSIZE是1024。

        4、错误码不同。

        Windows：返回SOCKET_ERROR，表示发生了错误。可通过WSAGetLastError函数获取更具体的错误值，比如：WSAEINTR（被信号中断）、WSAEINVAL（无效参数）等。

        Linux：返回-1，表示发生了错误。可通过errno获取更具体的错误值，比如：EINTR（被信号中断）、EINVAL（无效参数）等。

        注意：select只能处理有限数量的文件描述符，通常这个数量由上面介绍的FD_SETSIZE定义。当监视大量的文件描述符时，select的性能会显著下降。每次调用select都需要复制所有文件描述符集合到内核空间，然后在内核中进行线性扫描。这种机制对于少量的文件描述符是可行的，但对于大规模并发应用则效率低下。

实战代码

        在Windows系统下如何使用select进行IO多路复用，可参考下面的TCP服务器的示例代码。

        首先，我们使用WSAStartup初始化Winsock库，并检查是否成功。接着，创建一个监听套接字，将其绑定到指定的端口8888，并调用listen开始监听连接请求。

        然后，我们使用fd_set类型的变量masterSet来存储所有需要监控的套接字，包括：监听套接字、所有已连接的客户端套接字；workingSet则用于临时存储select检查的结果。

        紧接着，在无限循环中，我们使用select函数来等待IO事件的发生。如果select返回新的连接请求，接受新连接，并将新连接的套接字添加到masterSet和activeSockets向量中。对于每个已连接的客户端套接字，检查是否有数据可读。如果有，则读取数据并回显给客户端。如果客户端断开连接，则关闭相应的套接字，并从masterSet和activeSockets中移除该套接字。

        最后，当程序退出时，关闭所有打开的套接字，并清理Winsock库。

#include <iostream>
#include <winsock2.h>
#include <vector>
using namespace std;#pragma comment(lib, "ws2_32.lib")#define TCP_LISTEN_PORT                   8888
#define BUFFER_SIZE                       1024int main()
{// 初始化Winsock库WSADATA wsaData;int result = WSAStartup(MAKEWORD(2, 2), &wsaData);if (result != 0){cout << "WSAStartup failed: " << result << endl;return 1;}SOCKET listenSocket = INVALID_SOCKET;struct sockaddr_in serverAddr;// 创建监听 socketlistenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if (listenSocket == INVALID_SOCKET){cout << "Socket creation failed: " << WSAGetLastError() << endl;WSACleanup();return 1;}// 设置服务器地址serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = INADDR_ANY;serverAddr.sin_port = htons(TCP_LISTEN_PORT);if (bind(listenSocket, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR){cout << "Bind failed: " << WSAGetLastError() << endl;closesocket(listenSocket);WSACleanup();return 1;}// 开始监听if (listen(listenSocket, SOMAXCONN) == SOCKET_ERROR){cout << "Listen failed: " << WSAGetLastError() << endl;closesocket(listenSocket);WSACleanup();return 1;}cout << "Server listening on port " << TCP_LISTEN_PORT << endl;fd_set masterSet;FD_ZERO(&masterSet);FD_SET(listenSocket, &masterSet);fd_set workingSet;// 存储新连接的套接字句柄vector<SOCKET> activeSockets;activeSockets.push_back(listenSocket);while (true){workingSet = masterSet;// 调用selectint selectResult = select(0, &workingSet, NULL, NULL, NULL);if (selectResult == SOCKET_ERROR){cout << "Select failed: " << WSAGetLastError() << endl;break;}// 检查是否有新的连接请求if (FD_ISSET(listenSocket, &workingSet)){SOCKET clientSocket = accept(listenSocket, NULL, NULL);if (clientSocket == INVALID_SOCKET){cout << "Accept failed: " << WSAGetLastError() << endl;continue;}cout << "New connection: " << clientSocket << endl;FD_SET(clientSocket, &masterSet);activeSockets.push_back(clientSocket);}// 检查其他已连接的客户端是否有数据可读for (const auto &sock : activeSockets){// 跳过监听Socketif (sock == listenSocket){continue;}if (FD_ISSET(sock, &workingSet)){char buffer[BUFFER_SIZE] = { 0 };int bytesReceived = recv(sock, buffer, BUFFER_SIZE, 0);if (bytesReceived > 0){cout << "Received from client " << sock << ": " << buffer << endl;// 回显消息给客户端send(sock, buffer, bytesReceived, 0);}else if (bytesReceived == 0){cout << "Client disconnected: " << sock << endl;closesocket(sock);FD_CLR(sock, &masterSet);// 移除断开的连接auto it = find(activeSockets.begin(), activeSockets.end(), sock);if (it != activeSockets.end()){activeSockets.erase(it);}}else{cout << "Recv failed: " << WSAGetLastError() << endl;closesocket(sock);FD_CLR(sock, &masterSet);// 移除断开的连接auto it = find(activeSockets.begin(), activeSockets.end(), sock);if (it != activeSockets.end()){activeSockets.erase(it);}}}}}// 释放资源for (const auto &sock : activeSockets){closesocket(sock);}closesocket(listenSocket);WSACleanup();return 0;
}

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

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

相关文章

【优选算法 — 双指针】双指针小专题

【优选算法 — 双指针】双指针小专题

和为 s 的两个数 和为s的两个数 题目描述 解法一&#xff1a;暴力枚举 暴力枚举&#xff0c;先固定一个数&#xff0c;然后让这个数和另一个数匹配相加&#xff0c; 如果当前的数 所有剩余的数 target&#xff0c;则返回这两个数&#xff0c;否则固定下一个数&#…
阅读更多...
并查集（基础学习与应用）

并查集（基础学习与应用）

并查集 基本原理&#xff1a; 对于多个集合&#xff0c;每个集合中的多个元素用一颗树的形式表示&#xff0c;根节点的编号即为整个集合的编号&#xff0c;每个树上节点存储其父节点&#xff0c;使得当前集合的每个子节点都可以通过对父节点的询问来找到根节点&#xff0c;根…
阅读更多...
003-Kotlin界面开发之声明式编程范式

003-Kotlin界面开发之声明式编程范式

概念本源 在界面程序开发中&#xff0c;有两个非常典型的编程范式&#xff1a;命令式编程和声明式编程。命令式编程是指通过编写一系列命令来描述程序的运行逻辑&#xff0c;而声明式编程则是通过编写一系列声明来描述程序的状态。在命令式编程中&#xff0c;程序员需要关心程…
阅读更多...
Spring Boot 与 Vue 共筑地方特色美食分享卓越平台

Spring Boot 与 Vue 共筑地方特色美食分享卓越平台

作者介绍&#xff1a;✌️大厂全栈码农|毕设实战开发&#xff0c;专注于大学生项目实战开发、讲解和毕业答疑辅导。 &#x1f345;获取源码联系方式请查看文末&#x1f345; 推荐订阅精彩专栏 &#x1f447;&#x1f3fb; 避免错过下次更新 Springboot项目精选实战案例 更多项目…
阅读更多...
react使用Fullcalendar 实战用法

react使用Fullcalendar 实战用法

使用步骤请参考&#xff1a;react使用Fullcalendar 卡片式的日历&#xff1a; 需求图&#xff1a; 卡片式的日历&#xff0c;其实我是推荐 antd的&#xff0c;我两个都写了一下都能实现。 antd 的代码&#xff1a; antd的我直接用的官网示例&#xff1a;antd 日历示例 i…
阅读更多...
Apache Solr 身份认证绕过导致任意文件读取漏洞复现(CVE-2024-45216)

Apache Solr 身份认证绕过导致任意文件读取漏洞复现(CVE-2024-45216)

0x01 产品简介 Apache Solr是一个开源的搜索平台，基于流行的Apache Lucene库构建。它提供了一个强大的全文搜索功能，能够快速处理大量数据，并支持复杂的搜索操作。并且是一个独立的企业级搜索应用服务器，它采用Java开发，并基于Apache Lucene实现。Solr提供了类似于Web-Se…
阅读更多...
Flutter 正在切换成 Monorepo 和支持 workspaces

Flutter 正在切换成 Monorepo 和支持 workspaces

其实关于 Monorepo 和 workspaces 相关内容在之前《Dart 3.5 发布&#xff0c;全新 Dart Roadmap Update》 和 《Flutter 之 ftcon24usa 大会&#xff0c;创始人分享 Flutter 十年发展史》 就有简单提到过&#xff0c;而目前来说刚好看到 flaux 这个新进展&#xff0c;所以就再…
阅读更多...
在做题中学习（74）：比较含退格的字符串

在做题中学习（74）：比较含退格的字符串

解法&#xff1a;用栈来模拟 思路&#xff1a;不用真的定义一个栈,用字符串string来模拟栈的行为 入栈&#xff1a;s[i] ! #时 push_back(s[i]) 出栈:s[i] # 的时候&#xff0c;并且s.size() > 0&#xff0c;pop_back(s[i])循环结束得到结果 注意&#xff1a;如果真的…
阅读更多...
前后端交互通用排序策略

前后端交互通用排序策略

目录 排序场景 排序实现思路 1. 静态代码排序实现 2.数据库驱动排序实现 3. 基于Java反射的动态排序实现 通用排序工具 SortListUtil 结语 排序场景 在面向前端数据展示的应用场景中&#xff0c;我们旨在实现一个更加灵活的排序机制&#xff0c;该机制能够支持对从后端传递…
阅读更多...
java 中List 的使用

java 中List 的使用

List集合是Collection接口的子接口&#xff0c;其下有两个实现类分别为ArrayList和 LinkedList List是一个接口&#xff0c;不能用new创建对象&#xff0c;需要用 ArrayList类 和 LinkedList类 来创建 特点 有序&#xff1a;存储元素的顺序和取出元素的顺序一致可以重复&…
阅读更多...
MD5（Crypto）

MD5（Crypto）

解题思路 打开文件发现一串代码&#xff0c;结合题目提示&#xff0c;应该是 MD5 加密。 找个在线的 MD5 解密网站&#xff0c;行云流水得到 flag。 题目设计原理 题目设计&#xff1a;无他&#xff0c;MD5 加密。 题目原理&#xff1a; MD5&#xff08;Message-Digest Algo…
阅读更多...
跟李沐学AI：BERT

跟李沐学AI：BERT

什么是NLP中的迁移学习 使用预训练好的模型来抽取词、句子的特征&#xff1a;Word2Vec或者预训练好的语言模型。 使用预训练好的语言模型&#xff0c;一般不会再对语言模型进行微调&#xff0c;即不进行更新。 Word2Vec一般用于替代embedding层 但是Word2Vec往往忽略了时序…
阅读更多...
时间段比较与 SQL 实现：交集、并集与补集

时间段比较与 SQL 实现：交集、并集与补集

文章目录 时间段比较与 SQL 实现&#xff1a;交集、并集与补集时间段比较的六种基本情况SQL 实现&#xff1a;时间段的交集、并集和补集判断两个时间段是否有交集取两个时间段的交集取两个时间段的并集取两个时间段的补集处理多个时间段的交集和并集结合补集与交集 实际应用与优…
阅读更多...
单元/集成测试解决方案

单元/集成测试解决方案

在项目开发的前期针对软件单元/模块功能开展单元/集成测试&#xff0c;可以尽早地发现软件Bug&#xff0c;避免将Bug带入系统测试阶段&#xff0c;有效地降低HIL测试的测试周期&#xff0c;也能有效降低开发成本。单元/集成测试旨在证明被测软件实现其单元/架构设计规范、证明被…
阅读更多...
C语言复习第9章 字符串/字符/内存函数

C语言复习第9章 字符串/字符/内存函数

目录 一、字符串函数1.1 读取字符串gets函数原型Example 1.2 字符串拷贝strcpy函数原型模拟实现官方源码 1.3 求字符串长度strlen函数原型关于返回值size_与算术转换的一个易错点模拟实现:递归模拟实现:指针-指针模拟实现:暴力官方源码 1.4 字符串追加strcat函数原型注意自己给…
阅读更多...
WPF 特性------Binding

WPF 特性------Binding

工业控制中&#xff0c;经常会需要把一个bool 型输入信号的状态显示在面板上&#xff0c;使用wpf 绑定的办法&#xff0c;可简洁实现&#xff1a; 实现步骤&#xff1a; 1&#xff0c;定义类&#xff1a; using System; using System.Collections.Generic; using System.Com…
阅读更多...
在 Spring Boot 中使用分布式事务时，如何处理不同数据源之间的事务一致性问题？

在 Spring Boot 中使用分布式事务时，如何处理不同数据源之间的事务一致性问题？

在 Spring Boot 中使用分布式事务处理不同数据源之间的事务一致性问题&#xff0c;可以考虑以下几种方法&#xff1a; 一、使用分布式事务框架 Seata&#xff1a; Seata 是一款开源的分布式事务解决方案。它通过对业务无侵入的方式&#xff0c;提供了 AT&#xff08;Automatic …
阅读更多...
Docker Compose部署XXL-JOB

Docker Compose部署XXL-JOB

整个工具的代码都在Gitee或者Github地址内 gitee&#xff1a;solomon-parent: 这个项目主要是总结了工作上遇到的问题以及学习一些框架用于整合例如:rabbitMq、reids、Mqtt、S3协议的文件服务器、mongodb github&#xff1a;GitHub - ZeroNing/solomon-parent: 这个项目主要是…
阅读更多...
[spark面试]spark与mapreduce的区别---在DAG方面

[spark面试]spark与mapreduce的区别---在DAG方面

1、spark中的task是以线程实现的&#xff0c;而mapreduce中是以进程实现的。 进程的频繁启动和停止会增加资源的消耗。 2、spark中支持DAG&#xff0c;而mapreduce不支持DAG DAG的使用&#xff1a;为什么支持DAG会更加高效 1&#xff09;、在DAG图中&#xff0c;会将一个job…
阅读更多...
【React】react-app-env.d.ts 文件

【React】react-app-env.d.ts 文件

在使用 create-react-app 生成的 TypeScript 项目模板中&#xff0c;react-app-env.d.ts 文件的作用是为 React 应用中的全局变量和类型进行声明。 全局类型声明&#xff1a;react-app-env.d.ts 文件会引入 react-scripts 提供的全局类型定义&#xff0c;这些类型定义扩展了 Ty…
阅读更多...
最新文章

Copyright @ 2022~2023