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

这篇具有很好参考价值的文章主要介绍了[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模型:

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

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

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

异步I/O模型: 

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

所以,从结果上来看,重叠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);
	}
}

执行结果:

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

[C++ 网络协议] 重叠I/O模型,网络协议,网络协议,c++因为是异步执行的,所以线程不会等待,会持续往下执行,当有消息传来时,就会执行Complition函数进行处理,线程不会阻塞住。文章来源地址https://www.toymoban.com/news/detail-730218.html

到了这里,关于[C++ 网络协议] 重叠I/O模型的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Java中网络的基本介绍。网络通信,网络,ip地址,域名,端口,网络通信协议,TCP/IP传输过程,网络通信协议模型,TCP协议,UDP协议

    - 网络通信 概念:网络通信是指 通过计算机网络进行信息传输的过程 ,包括数据传输、语音通话、视频会议等。在网络通信中,数据被分成一系列的数据包,并通过网络传输到目的地。在数据传输过程中,需要确保数据的完整性、准确性和安全性。常见的网络通信协议有T

    2024年02月10日
    浏览(69)
  • 【计算机网络】分层模型和应用协议

    1.1 五层网络模型 网络要解决的问题是: 两个程序之间如何交换数据 。 四层?五层?七层? 2.1 URL URL(uniform resource locator,统一资源定位符)用于定位网络服务 当协议是 http 端口为 80 时,端口可以省略 当协议是 https 端口为 443 时,端口可以省略 schema 、 domain 、 path 是必填

    2024年02月08日
    浏览(51)
  • 使用无人机 LiDAR 的重叠树冠的新型植被点云密度树分割模型

    Paper题目:A Novel Vegetation Point Cloud Density Tree-Segmentation Model for Overlapping Crowns Using UAV LiDAR 由于常用的冠层高度模型(CHM)的局限性,在具有高密度和重叠树冠的森林生态系统中检测和分割单个树木经常会导致偏差。针对这种局限性,本文提出了一种新的方法来分割单棵树和提取树

    2023年04月09日
    浏览(28)
  • 【网络原理】TCP/IP四层模型中的重点网络协议

    目录 🌟一、应用层协议 🌈1、XML协议  🌈 2、JSON 🌈 3、其他协议 🌟二、传输层协议(UDP与TCP重点) 🌈1、UDP协议格式 🌈 2、TCP协议格式 🎉TCP的10条机制(必会) 1、确认应答机制(可靠机制) 2、超时重传机制(可靠机制) 3、连接管理机制(三次握手,四次挥手)(

    2024年02月04日
    浏览(46)
  • [C++ 网络协议] 异步通知I/O模型

    如图是同步I/O函数的调用时间流: 如图是异步I/O函数的调用时间流: 可以看出,同异步的差别主要是在时间流上的不一致。select属于同步I/O模型。epoll不确定是不是属于异步I/O模型,这个在概念上有些混乱, 期望大佬的指点 。 这里说的异步通知I/O模型,实际上是select模型的

    2024年02月07日
    浏览(38)
  • 【网络原理】TCP/IP协议五层模型

    🥊作者:一只爱打拳的程序猿,Java领域新星创作者,CSDN、阿里云社区优质创作者。 🤼专栏收录于:计算机网络原理 本期讲解协议、OSI七层模型、TCP/IP五层模型、网络设备所在的分层、数据的封装和分佣。 目录 1. 什么要有协议? 2. 协议的分层 2.1 协议分层的好处 3. OSI七层

    2024年02月08日
    浏览(48)
  • 【JavaEE初阶】网络原理|认识协议|协议分层|TCP/IP模型|封装和分用

    目录 一、认识协议 1.概念 2.作用(为什么需要协议?) 二、协议分层 1.为什么需要⽹络协议的分层? 2. 协议分层是什么 3.分层带来的好处 三、TCP/IP五层(或四层)模型 (1)物理层 (2)数据链路层 (3)网络层 (4)传输层 (5)应用层 四、封装和分用(协议的层和层之间

    2024年04月23日
    浏览(40)
  • 网络编程——深入理解TCP/IP协议——OSI模型和TCP/IP模型:构建网络通信的基石

    TCP/IP协议,即 传输控制协议/互联网协议 ,是一组用于在计算机网络中实现通信的协议。它由两个主要的协议组成:TCP(传输控制协议)和IP(互联网协议)。TCP负责确保数据的可靠传输,而IP则负责路由数据包以在网络中传递。TCP/IP协议簇还包含其他辅助协议,如UDP(用户数

    2024年02月14日
    浏览(53)
  • 【网络基础】OSI参考模型和TCP/IP协议

    目录 一、分层的思想 1.1 分层的原因 1.2 分层的好处 二、OSI参考模型 2.1 七层的划分 2.2 各层原理 三、TCP/IP协议 3.1 五层模型 3.2 各层常用协议 四、数据封装和解封装过程 4.1 封装过程 4.2 解封装过程 硬件和软件没有统一标准,不同厂商之间的设备无法通信。 各层相互独立,每

    2024年04月14日
    浏览(49)
  • 程序猿眼中的协议:TCP / IP 五层网络模型

    哈喽,大家好~我是你们的老朋友: 保护小周ღ ,本期为大家带来的是 网络基础原理中的 TCP / IP 五层网络模型,主要从协议的概念,网络模型,数据分层传输的流程,几个方面讲解,看完之后可以轻松的理解数据是如何在网络中传输的,确定不来看看嘛~~ 更多精彩敬请期待

    2023年04月19日
    浏览(50)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包