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

news/2024/2/28 2:18:20

目录

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.ppmy.cn/news/1129951.html

相关文章

WebGL 渲染三维图形作为纹理贴到另一个三维物体表面

目录 渲染到纹理 帧缓冲区对象和渲染缓冲区对象 帧缓冲区对象 帧缓冲区对象的结构 如何实现渲染到纹理 示例程序&#xff08;FramebufferObject.js&#xff09; 创建帧缓冲区对象&#xff08;gl.createFramebuffer&#xff08;&#xff09;&#xff09; gl.createFra…

广州华锐互动:VR结绳逃生训练模拟真实火灾场景,增强训练沉浸感

随着科技的发展&#xff0c;虚拟现实&#xff08;VR&#xff09;技术已被广泛应用到各个领域&#xff0c;其中包括消防训练。VR消防结绳训练是一种创新的消防训练方式&#xff0c;它通过虚拟现实技术模拟真实的灭火场景&#xff0c;使消防人员能够在无风险的环境中进行高强度的…

年度顶级赛事来袭:2023 CCF大数据与计算智能大赛首批赛题上线!

久等了&#xff01; 大数据与人工智能领域年度顶级盛事——2023 CCF大数据与计算智能大赛——首批赛题已上线&#xff0c;大赛火力全开&#xff0c;只等你来挑战&#xff01; 大赛介绍 CCF大数据与计算智能大赛&#xff08;CCF Big Data & Computing Intelligence Contes…

Caddy Web服务器深度解析与对比:Caddy vs. Nginx vs. Apache

&#x1f337;&#x1f341; 博主猫头虎 带您 Go to New World.✨&#x1f341; &#x1f984; 博客首页——猫头虎的博客&#x1f390; &#x1f433;《面试题大全专栏》 文章图文并茂&#x1f995;生动形象&#x1f996;简单易学&#xff01;欢迎大家来踩踩~&#x1f33a; &a…

【owt-server】fix : node-gyp configure 报错:Error: read ECONNRESET

npm已经设置了registry 还报错 npm config set registry http://registry.npmmirror.comnode-gyp configure 指令 node-gyp configure 报错 read ECONNRESET root@k8s-master-2K4G:~/p2p/zdsvr-20201229# ./scripts/build.js -t mcu --check /root/p2p/zdsvr-20201229/build/li…

postgresql实现单主单从

实现步骤 1.主库创建一个有复制权限的用户 CREATE ROLE 用户名login # 有登录权限的角色即是用户replication #复制权限 encrypted password 密码;2.主库配置开放从库外部访问权限 修改 pg_hba.conf 文件 &#xff08;相当于开放防火墙&#xff09; # 类型 数据库 …

【小余送书第二期】《MLOps工程实践:工具、技术与企业级应用》参与活动,即有机会中奖哦!!!祝各位铁铁们双节快乐!

目录 1、背景介绍 2、内容简介 3、读者对象 4、专家推荐 5、书籍目录 目  录 作者简介 前言 第1章 全面了解MLOps1 1.1 人工智能的趋势和现状 1 1.1.1 趋势1&#xff1a;人工智能在企业中加速落地&#xff0c;彰显更多业务价值 1 1.1.2 趋势2&#xff1a;人…

c语言常用语法,长时间不用容易忘。

关键字 auto 声明自动变量const 定义常量&#xff0c;如果一个变量被 const 修饰&#xff0c;那么它的值就不能再被改变extern 声明变量或函数是在其它文件或本文件的其他位置定义register 声明寄存器变量signed 声明有符号类型变量或函数static 声明静态变量&#xff0c;修饰…

Godot信号教程(使用C#语言)| 创建自定义信号 | 发出自定义信号 | 使用代码监听信号

文章目录 信号是什么连接信号使用编辑器连接信号使用代码连接信号Lambda 自定义信号声明信号发射信号带参数的信号 其他文章 信号是什么 在Godot游戏引擎中&#xff0c;信号是一种用于对象之间通信的重要机制。它允许一个对象发出信号&#xff0c;而其他对象可以连接到这个信号…

设计模式——7. 装饰者模式

1. 说明 装饰者模式(Decorator Pattern)是一种结构型设计模式,它允许你在不改变对象接口的前提下,动态地将新行为附加到对象上。这种模式是通过创建一个包装(或装饰)对象,将要被装饰的对象包裹起来,从而实现对原有对象功能的增强和扩展。 装饰者模式的主要特点包括:…

行为型设计模式——责任链模式

摘要 责任链模式(Chain of responsibility pattern): 通过责任链模式, 你可以为某个请求创建一个对象链. 每个对象依序检查此请求并对其进行处理或者将它传给链中的下一个对象。 一、责任链模式意图 职责链模式&#xff08;Chain Of Responsibility&#xff09; 是一种行为设…

趣解设计模式之《小王的披萨店》

〇、小故事 小王看到最近越来越多的人喜欢吃披萨了&#xff0c;所以&#xff0c;他决定自己也开一个披萨店。最初开的时候&#xff0c;他只提供了一种口味的披萨&#xff0c;因为这样先试试水&#xff0c;看看生意如何&#xff0c;如果生意不好&#xff0c;也可以快速止损。 没…

【Leetcode】162.寻找峰值

一、题目 1、题目描述 峰值元素是指其值严格大于左右相邻值的元素。 给你一个整数数组 nums,找到峰值元素并返回其索引。数组可能包含多个峰值,在这种情况下,返回 任何一个峰值 所在位置即可。 你可以假设 nums[-1] = nums[n] = -∞ 。 你必须实现时间复杂度为 O(log n…

C语言实现——简易通讯录

前言&#xff1a;小伙伴们又见面啦&#xff01;这几天通过我们对自定义数据类型的学习&#xff0c;我们已经掌握了如何同时对多种数据类型进行管理&#xff0c;那么今天这篇文章&#xff0c;我们就来干一件大事——实现简易的通讯录。 一.思路分析 先来想想通讯录有哪些功能&a…

ide unknown command (empty parse result): / 问题及解决方案

vs studio端口冲突了 在属性 web 修改端口号就能解决 搞定

了解和使用MinIO

MinIO 文章目录 MinIOMinIO简介MinIO概述 开箱使用基本概念 快速入门封装MinIO为starter在项目中集成 MinIO简介 MinIO 是一个开源的对象存储服务器&#xff0c;可以帮助用户构建高度可扩展的存储基础架构。它采用分布式架构&#xff0c;可以在多个节点上部署&#xff0c;实现…

Java中判断字符串是否为合法数字

问题 最近遇到需要将String转BigDecimal的场景。 解决思路 利用NumberUtils.isCreatable判断是否为合法数字&#xff0c;然后&#xff0c;对字符串进行数字转换。注意&#xff1a;这里的NumberUtils类是org.apache.commons.lang3.math库里面的类。 Java if (NumberUtils.i…

面试理论篇三

关于异常机制篇 异常描述 目录 关于异常机制篇异常描述 注&#xff1a;自用 1&#xff0c;Java中的异常分为哪几类&#xff1f;各自的特点是什么&#xff1f; Java中的异常 可以分为 可查异常(Checked Exception)、运行时异常(Runtime Exception) 和 错误(Error)三类。可查异…

.balckhoues-V-XXXXXXX勒索病毒数据怎么处理|数据解密恢复

引言&#xff1a; 随着网络犯罪的不断演进&#xff0c;勒索病毒已成为当前数字时代的威胁之一&#xff0c;其中包括.balckhoues-V-XXXXXXX勒索病毒。本文将深入介绍.balckhoues-V-XXXXXXX勒索病毒的特点、数据恢复方法以及预防措施&#xff0c;以帮助您更好地理解和应对这一威…

SpringCloud之NamedContextFactory

NamedContextFactory 可以创建一个子容器&#xff08;或者说子上下文&#xff09;&#xff0c;每个子容器可以通过 Specification 定义 Bean。 public abstract class NamedContextFactory<C extends NamedContextFactory.Specification>implements DisposableBean, App…
最新文章