手把手教你玩转SOCKET模型之重叠I/O篇（上）

typedefstruct_WSAOVERLAPPED[/b]{

DWORD[/b]Internal;[/i]

DWORD[/b]InternalHigh;[/i]

DWORD[/b]Offset;[/i]

DWORD[/b]OffsetHigh;[/i]

WSAEVENT[/b]hEvent;[/i]//唯一需要关注的参数，用来关联WSAEvent对象

}WSAOVERLAPPED,*LPWSAOVERLAPPED;

我们需要把WSARecv等操作投递到一个重叠结构上，而我们又需要一个与重叠结构“绑定”在一起的事件对象来通知我们操作的完成，看到了和hEvent参数，不用我说你们也该知道如何来来把事件对象绑定到重叠结构上吧？大致如下：

WSAEVENTevent;//定义事件

WSAOVERLAPPEDAcceptOverlapped;//定义重叠结构

event=WSACreateEvent();//建立一个事件对象句柄

ZeroMemory(&AcceptOverlapped,sizeof(WSAOVERLAPPED));//初始化重叠结构

AcceptOverlapped.hEvent=event;//Done!！

[/b]intWSARecv(

SOCKETs,//当然是投递这个操作的套接字

LPWSABUFlpBuffers,//接收缓冲区，与Recv函数不同

//这里需要一个由WSABUF结构构成的数组

DWORDdwBufferCount,//数组中WSABUF结构的数量

LPDWORDlpNumberOfBytesRecvd,//如果接收操作立即完成，这里会返回函数调用

//所接收到的字节数

LPDWORDlpFlags,//说来话长了，我们这里设置为0即可

LPWSAOVERLAPPEDlpOverlapped,//“绑定”的重叠结构

LPWSAOVERLAPPED_COMPLETION_ROUTINElpCompletionRoutine

//完成例程中将会用到的参数，我们这里设置为NULL

);

返回值：

WSA_IO_PENDING：最常见的返回值，这是说明我们的WSARecv操作成功了，但是

I/O操作还没有完成，所以我们就需要绑定一个事件来通知我们操作何时完成

举个例子：(变量的定义顺序和上面的说明的顺序是对应的，下同)

SOCKETs;

WSABUFDataBuf;//定义WSABUF结构的缓冲区

//初始化一下DataBuf

#defineDATA_BUFSIZE5096

charbuffer[DATA_BUFSIZE];

ZeroMemory(buffer,DATA_BUFSIZE);

DataBuf.len=DATA_BUFSIZE;

DataBuf.buf=buffer;

DWORDdwBufferCount=1,dwRecvBytes=0,Flags=0;

//建立需要的重叠结构

WSAOVERLAPPEDAcceptOverlapped;//如果要处理多个操作，这里当然需要一个

//WSAOVERLAPPED数组

WSAEVENTevent;//如果要多个事件，这里当然也需要一个WSAEVENT数组

//需要注意的是可能一个SOCKET同时会有一个以上的重叠请求，

//也就会对应一个以上的WSAEVENT

Event=WSACreateEvent();

ZeroMemory(&AcceptOverlapped,sizeof(WSAOVERLAPPED));

AcceptOverlapped.hEvent=event;//关键的一步，把事件句柄“绑定”到重叠结构上

//作了这么多工作，终于可以使用WSARecv来把我们的请求投递到重叠结构上了，呼。。。。

WSARecv(s,&DataBuf,dwBufferCount,&dwRecvBytes,

&Flags,&AcceptOverlapped,NULL);

其他的函数我这里就不一一介绍了，因为我们毕竟还有MSDN这么个好帮手，而且在讲后面的完成例程和完成端口的时候我还会讲到一些^_^

DWORDWSAWaitForMultipleEvents(

DWORDcEvents,//等候事件的总数量

constWSAEVENT*lphEvents,//事件数组的指针

BOOLfWaitAll,//这个要多说两句：

//如果设置为TRUE，则事件数组中所有事件被传信的时候函数才会返回

//FALSE则任何一个事件被传信函数都要返回

//我们这里肯定是要设置为FALSE的

DWORDdwTimeout,//超时时间，如果超时，函数会返回WSA_WAIT_TIMEOUT

//如果设置为0，函数会立即返回

//如果设置为WSA_INFINITE只有在某一个事件被传信后才会返回

//在这里不建议设置为WSA_INFINITE，因为。。。后面再讲吧..-_-b

BOOLfAlertable//在完成例程中会用到这个参数，这里我们先设置为FALSE

);

返回值：

WSA_WAIT_TIMEOUT：最常见的返回值，我们需要做的就是继续Wait

WSA_WAIT_FAILED：出现了错误，请检查cEvents和lphEvents两个参数是否有效

如果事件数组中有某一个事件被传信了，函数会返回这个事件的索引值，但是这个索引值需要减去预定义值WSA_WAIT_EVENT_0才是这个事件在事件数组中的位置。

具体的例子就先不在这里举了，后面还会讲到

注意：WSAWaitForMultipleEvents函数只能支持由WSA_MAXIMUM_WAIT_EVENTS对象定义的一个最大值，是64，就是说WSAWaitForMultipleEvents只能等待64个事件，如果想同时等待多于64个事件，就要创建额外的工作者线程，就不得不去管理一个线程池，这一点就不如下一篇要讲到的完成例程模型了。

BOOLWSAGetOverlappedResult(

SOCKETs,//SOCKET，不用说了

LPWSAOVERLAPPEDlpOverlapped,//这里是我们想要查询结果的那个重叠结构的指针

LPDWORDlpcbTransfer,//本次重叠操作的实际接收(或发送)的字节数

BOOLfWait,//设置为TRUE，除非重叠操作完成，否则函数不会返回

//设置FALSE，而且操作仍处于挂起状态，那么函数就会返回FALSE

//错误为WSA_IO_INCOMPLETE

//不过因为我们是等待事件传信来通知我们操作完成，所以我们这里设

//置成什么都没有作用…..-_-b别仍鸡蛋啊，我也想说得清楚一些…

LPDWORDlpdwFlags//指向DWORD的指针，负责接收结果标志[/i]

);

这个函数没什么难的，这里我们也不需要去关注它的返回值，直接把参数填好调用就可以了，这里就先不举例了

唯一需要注意一下的就是如果WSAGetOverlappedResult完成以后，第三个参数返回是0，则说明通信对方已经关闭连接，我们这边的SOCKET,Event之类的也就可以关闭了。