【转帖】对codeproject上一个IOCP框架的修改

转帖前言：此贴转自某人，对于原作者不公开源码行为不加评论。

原帖地址：http://www.doserver.net/post/iocp-core-1.php?page=1&part=1



首先非常感激作者的代码，由于自己对MFC比较抵触，所以花时间修改了一下这个代码。当然其中也参考了自己之前的IOCP的代码。

原文：http://www.codeproject.com/KB/IP/iocp_server_client.aspx

目前还未得到原文作者的许可，故只说明一下修改的地方：

1:将含有MFC的地方全部用C++的核心库处理，含map,list.

2:目前不需要MFC的支持可以单独编译。

3:完成一个测试服务器
端。

4:对于客户端拔线的情况，采用了RegisterWaitForSingleObject 的TimeOutCallback 函数进行处理

view plain
print
?

void
IOCPS::TimeOutCallback(PVOID
lpParameter,BOOLEAN
TimerOrWaitFired)

{

//超时


if
(TimerOrWaitFired)

{

SOCKET sock = (SOCKET)lpParameter;

iocpserver->DisconnectClient(sock);

}

}

void IOCPS::TimeOutCallback(PVOID lpParameter,BOOLEAN TimerOrWaitFired)
{
  //超时
  if(TimerOrWaitFired)
  {
    SOCKET sock = (SOCKET)lpParameter;
    iocpserver->DisconnectClient(sock);
  }
}

5:原作者系统对于WSASend的处理并不是非常完美，因为WSASend返回的发送大小会小于我们请求的大小，如果出现这种情况的时候，需要继续投递发送。

view plain
print
?

if
(dwIoSize < pOverlapBuff->GetUsed() && dwIoSize > 0)

{

if
(pOverlapBuff->Flush(dwIoSize) == TRUE)

{

pOverlapBuff->SetOperation(IOWrite);

ASend(pContext,pOverlapBuff);

}

}

if(dwIoSize < pOverlapBuff->GetUsed() && dwIoSize > 0)
{
  if(pOverlapBuff->Flush(dwIoSize) == TRUE)
  {
    pOverlapBuff->SetOperation(IOWrite);
    ASend(pContext,pOverlapBuff);
  }
}

6:对于WSARecv的处理，觉得原作者的不合理。

应该先投递0大小的WSARecv，如果返回，表示有数据可以读取，投递真正的WSARecv.

现在的逻辑改为：

在OnInitialize函数中：

view plain
print
?

for
(int
i=0;i<m_iNumberOfPendlingReads;i++)

{

EnterIOLoop(pContext); // One for each Read Loop


AZeroByteRead(pContext,pOverlapBuff);

//ARead(pContext);不投递ARead


}

for(int i=0;i<m_iNumberOfPendlingReads;i++)
{
                EnterIOLoop(pContext); // One for each Read Loop
  AZeroByteRead(pContext,pOverlapBuff);
  //ARead(pContext);不投递ARead
}

然后当ZeroByteReadCompleted完成的时候，投递真正的ARead

如果ReadCompleted完成的时候再投递AZeroByteRead(pContext,pOverlapBuff);

这样整个项目逻辑就更加合理了。

目前该代码已经运用一个项目中了，效率比select要高不少。稳定性也不错，spinoza写的代码对客户端释放做的还是比较好。

可执行程序以及测试端下载：



下载文件 (已下载 263 次)
点击这里下载文件: IOCPTestServerAndClient.rar



Tags: 服务器iocp , server
| 引用(0)
引用地址：


注意：
该地址仅在今日23:59:59之前有效



45h
2010/08/31 22:49

博主能不能给我也发一份呢？ 我想参考下 谢谢啦！~

a_s_h#qq点com







LQW
2010/08/31 13:50

WSASend返回的发送大小小于我们请求的大小时，未被发送的那部分数据会被系统锁定到非分页内存中，系统应该会在适当的时候直接发送该部分数据，为什么还需要自己手动再次发送呢？不解~







ET


2010/08/26 11:46

请博主也发我一份修改好的源码 et2009@gmail.com

我正在写一个 IOCP Server，想参考一下.

博主可能也会回我“目前没有原作者的回复，如果得到他的确认，我会在博客公开。”。

但我认为，发布在网络上的代码很多都要经过改造才能使用，既然个人使用要经过修改，作者也没有明确声明版权，那么我认为至少私下交流是没什么问题的。







zacpp
2010/08/18 19:33

if ( m_iMaxIOWorkers>1 ) // we have some sort of bug somewhere..

m_iNumberOfPendlingReads=1;

请问博主，这是如何理解的啊，在源码里的startup函数里。

huzhangyou2002
回复于 2010/08/20 10:32
作者原来的代码对于每个IO上面投递多个WSARecv是存在bug的，所以作者对于每个IO都只有一个WSARecv



hpking


2010/08/01 17:49

能否发我一份,今天改了一下午,搞得头昏脑胀的hpking2009@qq.com

huzhangyou2002
回复于 2010/08/06 11:23
目前没有原作者的回复，如果得到他的确认，我会在博客公开。