[C++ 网络协议] 重叠I/O模型

目录

1. 什么是重叠I/O模型

2. 重叠I/O模型的实现

2.1 创建重叠非阻塞I/O模式的套接字

2.2 执行重叠I/O的Send函数

2.3 执行重叠I/O的Recv函数

2.4 获取执行I/O重叠的函数的执行结果

2.5 重叠I/O的I/O完成确认

2.5.1 使用事件对象（使用重叠I/O函数的第六个参数）

2.5.2 使用Completion Routine函数（使用重叠I/O的第七个参数）

3. 用重叠I/O实现回声服务器端

1. 什么是重叠I/O模型

重叠I/O模型：

重叠I/O：同一线程内部向多个目标传输(或从多个目标接收)数据引起的I/O重叠现象。

所以为了完成这一功能，要求套接字的I/O函数要立即返回，以便于后面的套接字的I/O处理。这就有点像是异步I/O模型。如图：

异步I/O模型： 

所以，从结果上来看，重叠I/O的前提条件就是异步I/O。

非阻塞I/O、异步I/O、重叠I/O之间的关系：重叠I/O离不开异步I/O，异步I/O离不开非阻塞I/O，三者之间应该是层层递进的关系。

2. 重叠I/O模型的实现

重叠I/O的重点不在于I/O，因为只要是非阻塞I/O就都能调用并立即返回，我们要关注的是在I/O返回后，我们怎么确认它的执行结果，怎么知道它什么时候读取/发送数据结束，怎么知道它读取/发送了多少数据？这些问题。

2.1 创建重叠非阻塞I/O模式的套接字

#include<winsock2.h>SOCKET WSASocket(
int af,                                //协议族信息
int type,                              //套接字数据传输方式
int protocol,                          //使用的协议信息
LPWSAPROTOCOL_INFO lpProtocolInfo,     //包含创建的套接字信息的WSAPROTOCOL_INFO结构体变量地址值//不需要时传NULL
GROUP g,                               //为扩展函数而预约的参数，可以使用0
DWORD dwFlags                          //套接字属性信息
);
成功返回套接字句柄
失败返回INVALID_SOCKET

创建进行重叠I/O模式的套接字：

hSocket=WSASocket(PF_INET,SOCK_STREAM,IPPROTO_TCP,NULL,0,WSA_FLAG_OVERLAPPED);

第五个参数传WSA_FLAG_OVERLAPPED。 

将套接字改为非阻塞I/O模式： 

int mode=1;
ioctlsocket(hSocket,FIONBIO,(u_long*)&mode);    //非阻塞I/O的设置

将hSocket句柄引用的套接字I/O模式(FIONBIO)改为变量mode中指定的形式。

当设置为非阻塞模式后：

  • 如果在没有客户端请求连接的情况下，调用accpet函数，将直接返回INVALID_SOCKET，调用WSAGetLastError函数，将返回WSAEWOULDBLOCK
  • 调用accpet函数时创建的套接字同样具有非阻塞属性。

所以如果针对非阻塞套接字调用accept函数时，要判断返回INVALID_SOCKET的理由。有可能是accpet函数未成功，也有可能是没有客户端请求连接。

2.2 执行重叠I/O的Send函数

#include<winsock2.h>int WSASend(
SOCKET s,     //套接字句柄
LPWSABUF lpBuffers,    //WSABUF结构体变量数组的地址值
DWORD dwBufferCount,   //第二个参数中数组长度
LPDWORD lpNumberOfBytesSent,    //保存实际发送字节数的变量地址值
DWORD dwFlags,    //用于更改数据传输特性，如传递MSG_OOB时发送OOB模式的数据
LPWSAOVERLAPPED lpOverlapped,    //WSAOVERLAPPED结构体变量地址值，使用事件对象，用于确认完成数据传输
LPWSAOVERLAPPED_COMPLETION_ROUTING lpCompletionRoutine //传入Completion Routine函数的入口//地址值，可以通过该函数确认是否完成数据传输
);
成功返回0
失败返回SOCKET_ERROR

第二个参数，lpBuffers：

struct __WSABUF
{u_long len;    //待传输数据大小char FAR* buf; //缓冲地址值
}WSABUF,*LPWSABUF;

第四个参数，lpNumberOfBytesSent：

填写了第四个参数会有如下两种情况：

        1.当传输数据不大，函数调用后可以立即完成数据传输时，WSASend函数将返回0，lpNumberOfBytesSent中保存实际传输的数据大小。

        2.当传输数据过大，函数调用后不能立即完成数据传输时，WSASend函数将返回SOCKET_ERROR，并将WSA_IO_PENDING注册为错误代码。该代码通过函数WSAGetLastError函数得到：

#include<winsock2.h>int WSAGetLastError(void);
返回错误代码(表示错误原因)

第六个参数，lpOverlapped：

struct __WSAOVERLAPPED
{DWORD Internal;DWORD InternalHigh;DWORD Offset;DWORD offsetHigh;WSAEVENT hEvent;
}WSAOVERLAPPED,*LPWSAOVERLAPPED;

 其中Internal、InternalHigh成员是进行重叠I/O时操作系统内部使用成员，Offset、OffsetHigh是属于具有特殊用途的成员。所以只需关注hEvent成员，前四个成员置零即可。

注意：

        1.为了进行重叠I/O，WSASend函数的lpOverlapped参数中应该传递有效的结构体变量地址值，而不是NULL。否则，SOCKET s将以阻塞模式工作。

        2.向多个目标传输数据时，要分别构建lpOverlapped参数。但如果是同一个目标的接收/发送，就只需构建一次lpOvrelapped参数即可。

第七个参数， lpCompletionRoutine：

这是传入lpCompletionRoutine的函数原型：

void CALLBACK CompletionROUTING(
DWORD dwError,                    //写入错误信息，正常结束写入0
DWORD bdTransferred,              //写入实际收发的字节数
LPWSAOVERLAPPED lpOverlapped,     //写入WSASend\WSARecv函数的参数lpOverlapped
DWORD dwFlags                     //写入调用I/O时传入的特性信息或0
);

其中void返回值类型后面必须要有CALLBACK关键字。

2.3 执行重叠I/O的Recv函数

#include<winsock2.h>int WSARecv(
SOCKET s,     //套接字句柄
LPWSABUF lpBuffers,    //WSABUF结构体变量数组的地址值
DWORD dwBufferCount,   //第二个参数中数组长度
LPDWORD lpNumberOfBytesSent,    //保存实际接收字节数的变量地址值
LPDWORD dwFlags,    //用于设置或读取数据传输特性，如接收MSG_OOB时发送的OOB模式的数据
LPWSAOVERLAPPED lpOverlapped,    //WSAOVERLAPPED结构体变量地址值，使用事件对象，用于确认完成数据接收
LPWSAOVERLAPPED_COMPLETION_ROUTING lpCompletionRoutine //传入Completion Routine函数的入口//地址值，可以通过该函数确认是否完成数据接收
);
成功返回0
失败返回SOCKET_ERROR

 这个和WSASend函数没什么区别。

2.4 获取执行I/O重叠的函数的执行结果

#include<winsock2.h>BOOL WSAGetOverlappedResult(
SOCKET s,                        //进行重叠I/O的套接字句柄
LPWSAOVERLAPPED lpOverlapped,    //进行重叠I/O时传递的WSAOVERLAPPED结构体变量的地址值
LPDWORD lpcbTransger,            //保存实际传输的字节数的变量地址值
BOOL fWait,                      //如果调用该函数仍在进行I/O，则//填TRUE时，等待I/O完成//填FALSE时，函数退出并返回FALSE
LPDWORD lpdwFlags                //调用WSARecv函数时，用于获取附加信息(如OOB消息)。//不需要，可以传NULL
);
成功返回TRUE
失败返回FALSE

可以获取实际的传输数据大小。同时还可以通过第四个参数验证接收数据的状态。

2.5 重叠I/O的I/O完成确认

2.5.1 使用事件对象（使用重叠I/O函数的第六个参数）

第六个参数：WSAOVERLAPPED结构体。

当重叠I/O完成时：

  • WSAOVERLAPPED结构体里的事件对象将变为signaled状态。
  • 验证I/O的完成结果需要调用WSAGetOverlappedResult函数。

如：

if(SOCKET_ERROR==WSASend(hSocket,&dataBuf,1,&sendBytes,0,&overlapped,NULL))
{if(WSAGetLastError()==WSA_IO_PENDING)    //说明数据还未传输完成{WSAWaitForMultipleEvents(1,&evObj,TRUE,WSA_INFINITE,FALSE);    //等待事件对象结束WSAGetOverlappedResult(hSocket,&overlapped,&sendBytes,FALSE,NULL); //得到结果}else{......}
}
//说明数据传输完成
......

2.5.2 使用Completion Routine函数（使用重叠I/O的第七个参数）

规则：只有请求I/O的线程处于alertable wait状态时才能调用Completion Routine函数。

alertable wait状态指：等待接收操作系统消息的线程状态。

调用以下函数将进入alertable wait状态：

  • WaitForSingleObjectEx
  • WaitForMultipleObjectsEx
  • WSAWaitForMultipleEvents
  • SleepEx
  • WSA为前缀的上述函数

上述函数和去掉Ex的函数相同，只是上述函数增加了一个参数，为TURE那么就进入alertable wait状态，反之，则不进入。

为什么设定了这个规则？

因为：如果在执行重要任务时，突然调用Completion Routine函数，将破坏程序的正常执行流，所以要定义这个规则。

所以你可以在执行完重要任务后，调用上述任一函数，验证I/O完成与否，如果有已完成的I/O，则操作系统会调用响应的Completion Routine函数。调用结束后，上述函数会返回WAIT_IO_COMPLETION，并继续执行。

int main()
{......//进入alertable wait状态，调用CompRoutine函数int idx=WSAWaitForMultipleEvents(1,&evObj,FALSE,WSA_INFINITE,TRUE);if(inx==WAIT_TO_COMPLETION){}......
}void CALLBACK CompRoutine(......)
{......
}

使用Completion Routine方式的一个小知识点：

        使用Completion Routine就可以无需事件对象了，所以在WSASend/WSARecv的第六个参数填写WSAOVERLAPPED结构体时，里面的事件对象(hEvent)，可以存储写入其他信息，这个数据类型会被传送到CALLBACK的函数里的第三个参数，此时直接对hEvent进行强制转换，就可以得到相应的信息了。

struct message
{......;
}
message msg;
overlapped.hEvent=(HANDLE)&msg;    //HANDLE是指针类型
//记住使用的是Completion Routine方式哦void CALLBACK Completion(DWORD error, DWORD transfer, LPWSAOVERLAPPED lpOverlapped, DWORD flags)
{message mesg=(message)(lpOverlapped->hEvent);......
}

3. 用重叠I/O实现回声服务器端

实现一：使用事件对象的方式来完成确认

这个比较简单，故省略。

实现二：使用Completion Routine的方式来完成确认

变量：

EventMessage结构体：用以存储连接的SOCKET套接字和对应客户端发送过来的消息内容。

为什么要创建一个这样的结构体？

因为：程序的运行是异步的，在while循环里，每连接一个客户端，SOCKET对应的客户端套接字变量，就会被重新赋值，就会导致写的RecvCompletion和SendCompletion函数里的SOCKET值会变化，这样发送的套接字就不正确了。所以必须要一个套接字对应一个客户端发送来的内容。

思路要点：

  1. 要保证客户端与服务器之间不只是发送一次数据，就要在RecvCompletion里面调用WSASend函数，在SendCompletion里面调用WSARecv函数，来达成循环。
  2. 使用EventMessage结构体，存储套接字和消息内容，把结构体地址值写入WSAOVERLAPPED的hEvent变量里，就可以在RecvCompletion和SendComplition里传递套接字和消息内容信息。
void CALLBACK RecvCompletion(DWORD error, DWORD transfer, LPWSAOVERLAPPED lpOverlapped, DWORD flags);
void CALLBACK SendCompletion(DWORD error, DWORD transfer, LPWSAOVERLAPPED lpOverlapped, DWORD flags);struct EventMessage
{WSABUF recvBuf;SOCKET client;
};int main()
{......//这里和方式一都是一样的while (1){SleepEx(100, TRUE);    //进入alertable wait状态sockaddr_in clientAddr;memset(&clientAddr, 0, sizeof(clientAddr));int clientAddrLen = sizeof(clientAddr);SOCKET client = accept(server, (sockaddr*)&clientAddr, &clientAddrLen);if (INVALID_SOCKET == client){if (WSAGetLastError() == WSAEWOULDBLOCK){std::cout << "没有客户端连接" << std::endl;}else{std::cout << "accept fail!" << std::endl;}continue;}EventMessage eventMsg;char buff[1024];eventMsg.recvBuf.buf = buff;eventMsg.recvBuf.len = sizeof(buff);eventMsg.client = client;WSAOVERLAPPED recvOverlapeed;memset(&recvOverlapeed, 0, sizeof(recvOverlapeed));recvOverlapeed.hEvent = (HANDLE)&eventMsg;DWORD recvLen;DWORD recvFlag=0;WSARecv(client, &eventMsg.recvBuf, 1, &recvLen, &recvFlag, &recvOverlapeed, RecvCompletion);}
}void CALLBACK RecvCompletion(DWORD error, DWORD transfer, LPWSAOVERLAPPED lpOverlapped, DWORD flags)
{if (error == 0)		//说明是正确结束{EventMessage eventMsg =*(EventMessage*)lpOverlapped->hEvent;int recvLen = transfer;	//获取接收的字节数if (recvLen == 0){std::cout << "客户端已断开!" << std::endl;closesocket(eventMsg.client);return;}std::cout << "客户端发来的信息:" << eventMsg.recvBuf.buf << std::endl;WSASend(eventMsg.client, &eventMsg.recvBuf, 1, &transfer, flags, lpOverlapped, SendCompletion);}
}void CALLBACK SendCompletion(DWORD error, DWORD transfer, LPWSAOVERLAPPED lpOverlapped, DWORD flags)
{if (error == 0){EventMessage eventMsg = *(EventMessage*)lpOverlapped->hEvent;char buff[1024];eventMsg.recvBuf.buf = buff;eventMsg.recvBuf.len = sizeof(buff);DWORD recvLen;DWORD recvFlag = 0;WSARecv(eventMsg.client, &eventMsg.recvBuf, 1, &recvLen, &recvFlag, lpOverlapped, RecvCompletion);}
}

执行结果：

因为是异步执行的，所以线程不会等待，会持续往下执行，当有消息传来时，就会执行Complition函数进行处理，线程不会阻塞住。

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

距离矢量路由协议RIP(含Cisco模拟器实验命令配置)

距离矢量路由协议RIP(含Cisco模拟器实验命令配置)

距离矢量路由协议RIP(含Cisco模拟器实验命令配置) 简介 距离矢量路由协议&#xff08;Routing Information Protocol, RIP&#xff09;是一种内部网关协议&#xff0c;它位于应用层&#xff0c;使用520 UDP端口。RIP基于距离矢量算法&#xff08;Bellham-Ford&#xff09;根据…
阅读更多...
专业图像处理软件DxO PhotoLab 7 mac中文特点和功能

专业图像处理软件DxO PhotoLab 7 mac中文特点和功能

DxO PhotoLab 7 mac是一款专业的图像处理软件&#xff0c;它为摄影师和摄影爱好者提供了强大而全面的照片处理和编辑功能。 DxO PhotoLab 7 mac软件特点和功能 强大的RAW和JPEG格式处理能力&#xff1a;DxO PhotoLab 7可以处理来自各种相机的RAW格式图像&#xff0c;包括佳能、…
阅读更多...
Python3数据科学包系列(三):数据分析实战

Python3数据科学包系列(三):数据分析实战

Python3中类的高级语法及实战 Python3(基础|高级)语法实战(|多线程|多进程|线程池|进程池技术)|多线程安全问题解决方案 Python3数据科学包系列(一):数据分析实战 Python3数据科学包系列(二):数据分析实战 Python3数据科学包系列(三):数据分析实战 一: 数据分析与挖掘认知…
阅读更多...
【大模型和智能问答系统】

【大模型和智能问答系统】

大模型和智能问答系统 大模型前的智能问答系统传统管道式架构存在的问题 大模型在任务型问答系统中应用NLU应用DM如何使用大模型NLG应用 大模型前的智能问答系统 大模型统一代指以ChatGPT为代表的&#xff0c;参数量相比以前模型有明显量级变化的生成模型。 智能问答系统&…
阅读更多...
初识Java 12-2 流

初识Java 12-2 流

目录 中间操作 跟踪与调试 对流元素进行排序 移除元素 将函数应用于每个流元素 在应用map()期间组合流 Optional类型 便捷函数 创建Optional Optional对象上的操作 由Optional组成的流 本笔记参考自&#xff1a; 《On Java 中文版》 中间操作 ||| 中间操作&#xf…
阅读更多...
Linux使用之xshell、xftp保姆教学（含安装包，详细使用方法，连接失败解决方法）

Linux使用之xshell、xftp保姆教学（含安装包，详细使用方法，连接失败解决方法）

前言 链接: FTP&#xff0c;SSH服务器介绍 这是我之前写的一篇博客&#xff0c;其中介绍了Ubuntu操作系统的一些常用命令以及服务器介绍&#xff0c;这篇文章就向大家详细介绍如何安装及应用这些服务器&#xff0c;我以xshell、xftp为例。 安装包&#xff0c;使用方法&#xf…
阅读更多...
华为云服务器内网vpc对等连接及微服务内网集群搭建处理

华为云服务器内网vpc对等连接及微服务内网集群搭建处理

最近需要举办一场活动&#xff0c;某个业务访问量上升&#xff0c;有一定并发场景&#xff0c;为了活动能够顺利举行&#xff0c;解决方案就是将业务进行分布式&#xff0c;分布式部署到不同服务器&#xff0c;平摊用户请求&#xff0c;微服务使用的是SpringCloud Alibabanacos…
阅读更多...
阿里云OSS图片存储

阿里云OSS图片存储

阿里云对象存储 OSS&#xff08;Object Storage Service&#xff09;是一款海量、安全、低成本、高可靠的云存储服务&#xff0c;提供最高可达 99.995 % 的服务可用性。多种存储类型供选择&#xff0c;全面优化存储成本。 视频介绍 创建bucket 开发文档 上传文件demo &#x…
阅读更多...
树的存储结构以及树，二叉树，森林之间的转换

树的存储结构以及树，二叉树，森林之间的转换

目录 1.双亲表示法 2.孩子链表 3.孩子兄弟表示法 4.树与二叉树的转换 &#xff08;1&#xff09;树转换为二叉树 &#xff08;2&#xff09;二叉树转换成树 5.二叉树与森林的转化 &#xff08;1&#xff09;森林转换为二叉树 以下树为例 1.双亲表示法 双亲表示法定义了…
阅读更多...
Ai4science学习、教育和更多

Ai4science学习、教育和更多

11 学习、教育和更多 人工智能的进步为加速科学发现、推动创新和解决各个领域的复杂问题提供了巨大的希望。然而&#xff0c;要充分利用人工智能为科学研究带来的潜力&#xff0c;我们需要面对教育、人才培养和公众参与方面的新挑战。在本节中&#xff0c;我们首先收集了关于每…
阅读更多...
Go-Ldap-Admin | openLDAP 同步钉钉、企业微信、飞书组织架构实践和部分小坑

Go-Ldap-Admin | openLDAP 同步钉钉、企业微信、飞书组织架构实践和部分小坑

目录 一、Docker-compose快速拉起demo测试环境 二、原生部署流程 安装MySQL&#xff1a;5.7数据库 安装openLDAP 修改域名&#xff0c;新增con.ldif 创建一个组织 安装OpenResty 下载后端 下载前端 部署后端 部署前端 三、管理动态字段 钉钉 企业微信 飞书 四、…
阅读更多...
Unity自用工具:基于种子与地块概率的开放世界2D地图生成

Unity自用工具:基于种子与地块概率的开放世界2D地图生成

public class BuildingGen : MonoBehaviour {public int[] Building;//存储要生成的地块代码public int[] Probability;//存储概率public double seed;public int width 100;public int height 100;public float noiseScale 0.1f; //噪声缩放倍数private int[,] frequencyM…
阅读更多...
InnoDB索引机制

InnoDB索引机制

导学&#xff1a;索引什么时候失效&#xff1f;为什么类型转换索引会失效&#xff1f;不满足最左匹配原则&#xff1f; 我们都知道&#xff0c;MySQL它主要有2大模快组成&#xff0c;第一块就是我们的MySQL服务&#xff0c;里面包含了像连接管理、解析器、预处理、优化器、执行…
阅读更多...
网络安全：个人信息保护，企业信息安全，国家网络安全的重要性

网络安全：个人信息保护，企业信息安全，国家网络安全的重要性

在当前的数字化时代&#xff0c;无论是个人&#xff0c;企业&#xff0c;还是国家&#xff0c;都会面临严重的网络安全威胁。网络安全不仅涉及我们的日常生活&#xff0c;也涉及到社会的稳定和国家的安全。这就需要我们高度重视网络安全&#xff0c;强化个人信息保护&#xff0…
阅读更多...
【算法|动态规划No.7】leetcode300. 最长递增子序列

【算法|动态规划No.7】leetcode300. 最长递增子序列

个人主页&#xff1a;兜里有颗棉花糖 欢迎 点赞&#x1f44d; 收藏✨ 留言✉ 加关注&#x1f493;本文由 兜里有颗棉花糖 原创 收录于专栏【手撕算法系列专栏】【LeetCode】 &#x1f354;本专栏旨在提高自己算法能力的同时&#xff0c;记录一下自己的学习过程&#xff0c;希望…
阅读更多...
云原生微服务 第六章 Spring Cloud Netflix Eureka集成远程调用、负载均衡组件OpenFeign

云原生微服务 第六章 Spring Cloud Netflix Eureka集成远程调用、负载均衡组件OpenFeign

系列文章目录 第一章 Java线程池技术应用 第二章 CountDownLatch和Semaphone的应用 第三章 Spring Cloud 简介 第四章 Spring Cloud Netflix 之 Eureka 第五章 Spring Cloud Netflix 之 Ribbon 第六章 Spring Cloud 之 OpenFeign 文章目录 系列文章目录前言1、OpenFeign的实现…
阅读更多...
Vue项目搭建图文详解教程

Vue项目搭建图文详解教程

版权声明 本文原创作者&#xff1a;谷哥的小弟作者博客地址&#xff1a;http://blog.csdn.net/lfdfhl 预备工作 请在本地创建文件夹用于存放Vue项目&#xff0c;例如&#xff1a;创建HelloWorld文件夹存放即将创建的Vue新项目。 创建Vue项目 首先&#xff0c;请在DOS中将目录…
阅读更多...
【生命周期】

【生命周期】

生命周期 1 引出生命周期2 分析生命周期3 总结生命周期 1 引出生命周期 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><meta …
阅读更多...
windows WSL配置cuda，pytorch和jupyter notebook

windows WSL配置cuda，pytorch和jupyter notebook

机器配置 GPU: NVIDIA Quadro K2000 与 NVIDIA 驱动程序捆绑的CUDA版本 但按照维基百科的描述&#xff0c;我的GPU对应的compute capability3.0&#xff0c;允许安装的CUDA最高只支持10.2&#xff0c;如下所示。 为什么本地会显示11.4呢&#xff1f;对此&#xff0c;GPT是这…
阅读更多...
【数据结构与算法】- 数组

【数据结构与算法】- 数组

数组 1.1 数组的定义1.2 数组的创建1.3 数组在内存中的情况2.1 初始化数组2.2 插入元素2.3 删除元素2.4 读取元素2.5 遍历数组 1.1 数组的定义 数组中的是在内存中是连续存储的&#xff0c;内存是由一个个内存单元组成的&#xff0c;每一个内存单元都有自己的地址&#xff0c;…
阅读更多...
最新文章

Copyright @ 2022~2023