第6章 Socket 编程(pdf).pdf

《第6章 Socket 编程(pdf).pdf》由会员分享，可在线阅读，更多相关《第6章 Socket 编程(pdf).pdf（85页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、 1 6.3.4 Winsock 编程编程 Winsock 是一个基于是一个基于 Socket 模型的模型的 API，在，在 Windows 系统中广泛系统中广泛使用。它在使用。它在 Berkeley 接口函数的基础上，还增加了基于消息驱动机制的接口函数的基础上，还增加了基于消息驱动机制的Windows 扩展函数。扩展函数。Winsock1.1 只支持只支持 TCP/IP 网络，网络，Winsock2.2 增增加了对更多协议的支持。加了对更多协议的支持。需要包含头文件需要包含头文件 Winsock2.h，需要使用库，需要使用库 ws2_32.lib。2 TCP 客户端客户端程序工作流程程序工作

2、流程 使用使用 WSAStartup()函数检查系统协议栈安装情况；函数检查系统协议栈安装情况；使用使用 socket()函数创建客户端套接口；函数创建客户端套接口；使用使用 connect()函数发出也服务器建立连接的请求；函数发出也服务器建立连接的请求；连接建立后使用连接建立后使用 send()函数发送数据，或使用函数发送数据，或使用 recv()函数接收数据；函数接收数据；使用使用 closesocet()函数关闭套接口；函数关闭套接口；最后调用最后调用 WSACleanup()函数，结束函数，结束 Winsock Sockets API。3#include#include#pragma

3、 comment(lib,ws2_32.lib)#define SERVER_ADDRESS 192.168.0.100#define PORT 5150#define MSGSIZE 1024 int main()WSADATA wsaData;SOCKET sClient;SOCKADDR_IN server;4 struct sockaddr_in short sin_family;u_short sin_port;struct in_addr sin_addr;char sin_zero8;5 char szMessageMSGSIZE;int ret;WSAStartup(0 x02

4、02,&wsaData);sClient=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);memset(&server,0,sizeof(SOCKADDR_IN);server.sin_family=AF_INET;server.sin_addr.S_un.S_addr=inet_addr(SERVER_ADDRESS);server.sin_port=htons(PORT);connect(sClient,(struct sockaddr*)&server,sizeof(SOCKADDR_IN);6 while(TRUE)gets(szMessage);sen

5、d(sClient,szMessage,strlen(szMessage),0);ret=recv(sClient,szMessage,MSGSIZE,0);if(SOCKET_ERROR!=ret)szMessageret=0;printf(Received%d bytes:%sn,ret,szMessage);7 else printf(Received Error!n);closesocket(sClient);WSACleanup();return 0;8 TCP 服务器端服务器端的工作流程。的工作流程。1.使用使用 WSAStartup()函数检查系统协议栈安装情况；函数检查系统协议

6、栈安装情况；2.使用使用 socket()函数创建服务器端通信套接口；函数创建服务器端通信套接口；3.使用使用 bind()函数将创建的套接口与服务器地址绑定；函数将创建的套接口与服务器地址绑定；4.使用使用 listen()函数使服务器套接口做好接收连接请求准备；函数使服务器套接口做好接收连接请求准备；5.使用使用 accept()接收来自客户端由接收来自客户端由 connect()函数发出的连接请求；函数发出的连接请求；6.根据连接请求建立连接后，使用根据连接请求建立连接后，使用 send()函数发送数据，或者使用函数发送数据，或者使用recv()函数接收数据；函数接收数据；7.使用使用

7、closesocket()函数关闭套接口（可以先用函数关闭套接口（可以先用 shutdown()函数先关函数先关闭读写通道）；闭读写通道）；8.最后调用最后调用 WSACleanup()函数。函数。9 6.3.5 阻塞通信与非阻塞通信阻塞通信与非阻塞通信 阻塞方式：套接字进行阻塞方式：套接字进行 I/O 操作时，函数要等待到相关的操作完成以操作时，函数要等待到相关的操作完成以后才能返回，对提高处理机的利用率不利，但编程简单。后才能返回，对提高处理机的利用率不利，但编程简单。非阻塞方式：套接字进行非阻塞方式：套接字进行 I/O 操作时，无论操作成功与否，调用都会操作时，无论操作成功与否，调用都会

8、立即返回。立即返回。阻塞方式编程简单，一个套接口的默认操作模式为阻塞，可以调用函阻塞方式编程简单，一个套接口的默认操作模式为阻塞，可以调用函数数 ioctlsocket()进行设置。进行设置。10 6.3.6 高级网络编程高级网络编程 API MFC 编程技术定义了用于网络编程的编程技术定义了用于网络编程的 Winsock 类，类名为类，类名为CAsyncSocket；还定义了一个派生于；还定义了一个派生于 CAsyncSocket 的的 CSocket 类。类。这两个类简单实用，用户可以使用它们来实现自己的网络程序（为了与别这两个类简单实用，用户可以使用它们来实现自己的网络程序（为了与别的平

9、台兼容，最好是使用伯克利的平台兼容，最好是使用伯克利 socket）。）。与前面的介绍相似，使用与前面的介绍相似，使用 MFC 的的 Winsock 类进行操作时需要使用类进行操作时需要使用Winsock2.h、Winsock32.dll 和和 ws2_32.lib 三个文件。三个文件。11 6.4 Socket IO 模型模型 一、选择（一、选择（select）模型）模型 Select（选择）模型是（选择）模型是 Winsock 中最常见的中最常见的 I/O 模型。模型。老陈非常想看到女儿的信。以至于他每隔老陈非常想看到女儿的信。以至于他每隔 10 分钟就分钟就下楼检查信箱，看是否下楼检查信

10、箱，看是否有女儿的信。在这种情况下，有女儿的信。在这种情况下，下楼检查信箱下楼检查信箱然后回到楼上耽误了老陈太多的时然后回到楼上耽误了老陈太多的时间，以至于老陈无法做其他工作。间，以至于老陈无法做其他工作。int g_iTotalConn=0;SOCKET g_CliSocketArrFD_SETSIZE;int main()sListen=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);12 bind(sListen,(struct sockaddr*)&local,sizeof(SOCKADDR_IN);listen(sListen,3);CreateThr

11、ead(NULL,0,WorkerThread,NULL,0,&dwThreadId);while(TRUE)sClient=accept(sListen,(struct sockaddr*)&client,&iaddrSize);printf(Accepted client:%s:%dn,inet_ntoa(client.sin_addr),ntohs(client.sin_port);g_CliSocketArrg_iTotalConn+=sClient;DWORD WINAPI WorkerThread(LPVOID lpParam)13 fd_set fdread;int ret;st

12、ruct timeval tv=1,0;/秒，微妙秒，微妙 char szMessageMSGSIZE;while(TRUE)FD_ZERO(&fdread);for(i=0;i g_iTotalConn;i+)FD_SET(g_CliSocketArri,&fdread);ret=select(0,&fdread,NULL,NULL,&tv);14 if(ret=0)continue;for(i=0;i g_iTotalConn;i+)if(FD_ISSET(g_CliSocketArri,&fdread)ret=recv(g_CliSocketArri,szMessage,MSGSIZE,

13、0);if(ret=0|(ret=SOCKET_ERROR&WSAGetLastError()=WSAECONNRESET)/Client socket closed 15 else /ECHO return 0;16 服务器的几个主要动作如下：服务器的几个主要动作如下：1.创建监听套接字，绑定，监听；创建监听套接字，绑定，监听；2.创建工作者线程；创建工作者线程；3.创建一个套接字数组，用来存放当前所有活动的客户端套接字，每创建一个套接字数组，用来存放当前所有活动的客户端套接字，每 accept一个连接就更新一次数组；一个连接就更新一次数组；4.接受客户端的连接。接受客户端的连接。工作者线程

14、里面是一个死循环，一次循环完成的动作是：工作者线程里面是一个死循环，一次循环完成的动作是：1.将当前所有的客户端套接字加入到读集将当前所有的客户端套接字加入到读集 fdread 中；中；2.调用调用 select 函数；函数；3.查看某个套接字是否仍然处于读集中，如果是，则接收数据。如果接收的查看某个套接字是否仍然处于读集中，如果是，则接收数据。如果接收的数据长度为数据长度为 0，或者发生，或者发生 WSAECONNRESET 错误，则表示客户端套接字主动关错误，则表示客户端套接字主动关 17 闭，这时需要将服务器中闭，这时需要将服务器中对应的套接字所绑定的资源释放掉，然后调整套接字数对应的套

15、接字所绑定的资源释放掉，然后调整套接字数组。组。18 二、异步选择（二、异步选择（AsyncSelect)模型模型 后来，老陈使用了微软公司的新式信箱。这种信箱非常先进，一旦信箱里有后来，老陈使用了微软公司的新式信箱。这种信箱非常先进，一旦信箱里有新的信件，盖茨就会给老陈打电话：喂，大爷，你有新的信件了！从此，老陈再新的信件，盖茨就会给老陈打电话：喂，大爷，你有新的信件了！从此，老陈再也不必频繁上下楼检查信箱了。也不必频繁上下楼检查信箱了。利用这个模型，应用程序可在一个套接字上，接收以利用这个模型，应用程序可在一个套接字上，接收以 Windows 消息为基础消息为基础的网络事件通知。具体的做法

16、是在建好一个套接字后，调用的网络事件通知。具体的做法是在建好一个套接字后，调用 WSAAsyncSelect 函函数。数。19 LRESULT CALLBACK WndProc(HWND hwnd,UINT message,WPARAM wParam,LPARAM lParam)WSADATA wsd;static SOCKET sListen;SOCKET sClient;SOCKADDR_IN local,client;int ret,iAddrSize=sizeof(client);char szMessageMSGSIZE;switch(message)case WM_CREATE:2

17、0 WSAStartup(0 x0202,&wsd);sListen=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);bind(sListen,(struct sockaddr*)&local,sizeof(local);listen(sListen,3);/Associate listening socket with FD_ACCEPT event WSAAsyncSelect(sListen,hwnd,WM_SOCKET,FD_ACCEPT);return 0;case WM_DESTROY:closesocket(sListen);WSACleanup(

18、);PostQuitMessage(0);return 0;case WM_SOCKET:21 if(WSAGETSELECTERROR(lParam)closesocket(wParam);break;switch(WSAGETSELECTEVENT(lParam)case FD_ACCEPT:sClient=accept(wParam,(struct sockaddr*)&client,&iAddrSize);/Associate client socket with FD_READ and FD_CLOSE event WSAAsyncSelect(sClient,hwnd,WM_SOC

19、KET,FD_READ|FD_CLOSE);break;22 case FD_READ:ret=recv(wParam,szMessage,MSGSIZE,0);if(ret=0|ret=SOCKET_ERROR&WSAGetLastError()=WSAECONNRESET)closesocket(wParam);else szMessageret=0;send(wParam,szMessage,strlen(szMessage),0);23 break;case FD_CLOSE:closesocket(wParam);break;return 0;return DefWindowProc

20、(hwnd,message,wParam,lParam);24 WSAAsyncSelect 是最简单的一种是最简单的一种 Winsock I/O 模型。我们需要做的仅仅模型。我们需要做的仅仅是：是：1.在在 WM_CREATE 消息处理函数中，初始化消息处理函数中，初始化 Windows Socket library，创，创建监听套接字，绑定，监听，并且调用建监听套接字，绑定，监听，并且调用 WSAAsyncSelect 函数表示我们关心在监函数表示我们关心在监听套接字上发生的听套接字上发生的 FD_ACCEPT 事件；事件；2.自定义一个消息自定义一个消息 WM_SOCKET，一旦在我们所

21、关心的套接字（监听套接，一旦在我们所关心的套接字（监听套接字和客户端套接字）上发生了某个事件，系统就会调用字和客户端套接字）上发生了某个事件，系统就会调用 WndProc 并且并且 message参数被设置为参数被设置为 WM_SOCKET；3.在在 WM_SOCKET 的消息处理函数中，分别对的消息处理函数中，分别对 FD_ACCEPT、FD_READ和和 FD_CLOSE 事件进行处理；事件进行处理；4.在窗口销毁消息在窗口销毁消息(WM_DESTROY)的处理函数中，的处理函数中，关闭监听套接字，清除关闭监听套接字，清除 25 Windows Socket library。下面下面是是用

22、于用于 WSAAsyncSelect 函数的网络事件类型函数的网络事件类型定义定义：FD_READ：应用程序想要接收有关是否可读的通知，以便读入数据应用程序想要接收有关是否可读的通知，以便读入数据 FD_WRITE：应用程序想要接收有关是否可写的通知，以便写入数据应用程序想要接收有关是否可写的通知，以便写入数据 FD_ACCEPT：应用程序想接收与进入连接有关的通知应用程序想接收与进入连接有关的通知 FD_CONNECT：应用程应用程序想接收与一次连接或者多点序想接收与一次连接或者多点 join 操作完成的通知操作完成的通知 FD_CLOSE：应用程序想接收与套接字关闭有关的通知应用程序想接收

23、与套接字关闭有关的通知 26 三、事件选择三、事件选择(EventSelect)模型模型 后来，微软的信箱非常畅销，购买微软信箱的人以百万计数后来，微软的信箱非常畅销，购买微软信箱的人以百万计数以至于盖茨以至于盖茨每天每天 24 小时给客户打电话，累得腰酸背痛，喝蚁力神都不好使小时给客户打电话，累得腰酸背痛，喝蚁力神都不好使。微软改进。微软改进了他们的信箱：在客户的家中添加一个附加装置，这个装置会监视客户的信箱，了他们的信箱：在客户的家中添加一个附加装置，这个装置会监视客户的信箱，每当新的信件来临，此装置会发出每当新的信件来临，此装置会发出新信件到达新信件到达声，提醒老陈去收信。声，提醒老陈去

24、收信。重点：重点：WSAEventSelect：把网络事件和一个事件对象连接：把网络事件和一个事件对象连接。WSAWaitForMultipleEvents：阻塞多个事件对象，只要指定事件对象中的：阻塞多个事件对象，只要指定事件对象中的一个或全部处于有信号状态，或者超时间隔到，则返回。一个或全部处于有信号状态，或者超时间隔到，则返回。27 DWORD WSAAPI WSAWaitForMultipleEvents(DWORD cEvents,const WSAEVENT FAR*lphEvents,BOOL fWaitAll,DWORD dwTimeout,BOOL fAlertable);c

25、Events：指出：指出 lphEvents 所指数组中事件对象句柄的数目。事件对象句柄的所指数组中事件对象句柄的数目。事件对象句柄的最大值为最大值为 WSA_MAXIMUM_WAIT_EVENTS。lphEvents：指向一个事件对象句柄数组的指针。：指向一个事件对象句柄数组的指针。fWaitAll：指定等待类型。若为真：指定等待类型。若为真 TRUE，则当，则当 lphEvents 数组中的所有事数组中的所有事件对象同时有信号时，函数返回。若为假件对象同时有信号时，函数返回。若为假 FALSE，则当任意一个事件对象有信，则当任意一个事件对象有信号时函数即返回。在后一种情况下，返回值指出是哪

26、一个事件对象造成函数返号时函数即返回。在后一种情况下，返回值指出是哪一个事件对象造成函数返回。回。28 dwTimeout：指定超时时间间隔（以毫秒计）。当超时间隔到，函数即返：指定超时时间间隔（以毫秒计）。当超时间隔到，函数即返回，不论回，不论 fWaitAll 参数所指定的条件是否满足。如果参数所指定的条件是否满足。如果 dwTimeout 为零，则函数为零，则函数测 试 指 定 的 时 间 对 象 的 状测 试 指 定 的 时 间 对 象 的 状 态，并 立 即 返 回。如 果态，并 立 即 返 回。如 果dwTimeout 是是WSA_INFINITE，则函数的超时间隔永远不会到。，则

27、函数的超时间隔永远不会到。fAlertable：指定当系统将一个输入：指定当系统将一个输入/输出完成例程放入队列以供执行时，函输出完成例程放入队列以供执行时，函数是否返回。若为真数是否返回。若为真 TRUE，则函数返回且执行完成例程。若为假，则函数返回且执行完成例程。若为假 FALSE，函，函数不返回，不执行完成例程。数不返回，不执行完成例程。返回值：返回值：29 WSAEnumNetworkEvents：检测所指定套接口上网络事件的发生。：检测所指定套接口上网络事件的发生。int WSAAPI WSAEnumNetworkEvents(SOCKET s,WSAEVENT hEventObje

28、ct,LPWSANETWORKEVENTS lpNetworkEvents,LPINT lpiCount);s：标识套接口的描述字。：标识套接口的描述字。hEventObject：（可选）句柄，用于标识需要复位的相应事件对象。：（可选）句柄，用于标识需要复位的相应事件对象。lpNetworkEvents：一个：一个 WSANETWORKEVENTS 结构的数组，每一个元素记录结构的数组，每一个元素记录了一个网络事件和相应的事件代码（如果是正常返回则了一个网络事件和相应的事件代码（如果是正常返回则 NetworkEvents 的值减去的值减去WSA_WAIT_EVENT_0 即是发生的网络事件代

29、码）。即是发生的网络事件代码）。lpiCount：数组中的元素数目。在返回时，本参数表示数组中的实际元素数：数组中的元素数目。在返回时，本参数表示数组中的实际元素数目；目；如果返回值是如果返回值是 WSAENOBUFS，则表示为获取所有网络事件所需的元素数目。，则表示为获取所有网络事件所需的元素数目。30 int g_iTotalConn=0;SOCKET g_CliSocketArrMAXIMUM_WAIT_OBJECTS;WSAEVENT g_CliEventArrMAXIMUM_WAIT_OBJECTS;DWORD WINAPI WorkerThread(LPVOID);void Cle

30、anup(int index);int main()sListen=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);bind(sListen,(struct sockaddr*)&local,sizeof(SOCKADDR_IN);listen(sListen,3);CreateThread(NULL,0,WorkerThread,NULL,0,&dwThreadId);while(TRUE)31 /Accept a connection sClient=accept(sListen,(struct sockaddr*)&client,&iaddrSize);p

31、rintf(Accepted client:%s:%dn,inet_ntoa(client.sin_addr),ntohs(client.sin_port);/Associate socket with network event g_CliSocketArrg_iTotalConn=sClient;g_CliEventArrg_iTotalConn=WSACreateEvent();WSAEventSelect(g_CliSocketArrg_iTotalConn,g_CliEventArrg_iTotalConn,FD_READ|FD_CLOSE);g_iTotalConn+;32 ret

32、urn 0;DWORD WINAPI WorkerThread(LPVOID lpParam)int ret,index;WSANETWORKEVENTS NetworkEvents;char szMessageMSGSIZE;while(TRUE)ret=WSAWaitForMultipleEvents(g_iTotalConn,g_CliEventArr,FALSE,33 1000,FALSE);if(ret=WSA_WAIT_FAILED|ret=WSA_WAIT_TIMEOUT)continue;index=ret-WSA_WAIT_EVENT_0;WSAEnumNetworkEven

33、ts(g_CliSocketArrindex,g_CliEventArrindex,&NetworkEvents);if(NetworkEvents.lNetworkEvents&FD_READ)/Receive message from client 34 ret=recv(g_CliSocketArrindex,szMessage,MSGSIZE,0);if(ret=0|(ret=SOCKET_ERROR&WSAGetLastError()=WSAECONNRESET)Cleanup(index);else szMessageret=0;send(g_CliSocketArrindex,s

34、zMessage,strlen(szMessage),0);35 if(NetworkEvents.lNetworkEvents&FD_CLOSE)Cleanup(index);return 0;void Cleanup(int index)closesocket(g_CliSocketArrindex);WSACloseEvent(g_CliEventArrindex);if(index Buffer.len=MSGSIZE;g_pPerIODataArrg_iTotalConn-Buffer.buf=g_pPerIODataArrg_iTotalConn-szMessage;g_CliEv

35、entArrg_iTotalConn=g_pPerIODataArrg_iTotalConn-overlap.hEvent=WSACreateEvent();/Launch an asynchronous operation WSARecv(g_CliSocketArrg_iTotalConn,&g_pPerIODataArrg_iTotalConn-Buffer,1,&g_pPerIODataArrg_iTotalConn-NumberOfBytesRecvd,44&g_pPerIODataArrg_iTotalConn-Flags,&g_pPerIODataArrg_iTotalConn-

36、overlap,NULL);g_iTotalConn+;closesocket(sListen);WSACleanup();return 0;DWORD WINAPI WorkerThread(LPVOID lpParam)45 int ret,index;DWORD cbTransferred;while(TRUE)/因为我们把事件和因为我们把事件和Overlapped绑定在一起，重叠操作完成后我们会接到事绑定在一起，重叠操作完成后我们会接到事件通知件通知 ret=WSAWaitForMultipleEvents(g_iTotalConn,g_CliEventArr,FALSE,1000,F

37、ALSE);if(ret=WSA_WAIT_FAILED|ret=WSA_WAIT_TIMEOUT)46 continue;/注意这里返回的注意这里返回的ret并非是事件在数组里的并非是事件在数组里的Index，而是需要减去，而是需要减去WSA_WAIT_EVENT_0 index=ret-WSA_WAIT_EVENT_0;/事件已经被触发了之后，它对于我们来说已经没有利用价值了，所以要将事件已经被触发了之后，它对于我们来说已经没有利用价值了，所以要将它重置一下留待下一次使用，很简单，就一步，连返回值都不用考虑它重置一下留待下一次使用，很简单，就一步，连返回值都不用考虑 WSAResetEve

38、nt(g_CliEventArrindex);WSAGetOverlappedResult(g_CliSocketArrindex,&g_pPerIODataArrindex-overlap,&cbTransferred,47 TRUE,&g_pPerIODataArrg_iTotalConn-Flags);/先检查通信对方是否已经关闭连接先检查通信对方是否已经关闭连接 /如果如果=0则表示连接已经关闭，则关闭套接字则表示连接已经关闭，则关闭套接字 if(cbTransferred=0)Cleanup(index);else /如果程序执行到了这里，那么就说明一切正常，如果程序执行到了这里，那

39、么就说明一切正常，WSABUF结构里面就存结构里面就存有我们有我们WSARecv来的数据了！来的数据了！48 g_pPerIODataArrindex-szMessagecbTransferred=0;send(g_CliSocketArrindex,g_pPerIODataArrindex-szMessage,cbTransferred,0);/Launch another asynchronous operation WSARecv(g_CliSocketArrindex,&g_pPerIODataArrindex-Buffer,1,&g_pPerIODataArrindex-Number

40、OfBytesRecvd,&g_pPerIODataArrindex-Flags,&g_pPerIODataArrindex-overlap,NULL);49 return 0;void Cleanup(int index)closesocket(g_CliSocketArrindex);WSACloseEvent(g_CliEventArrindex);HeapFree(GetProcessHeap(),0,g_pPerIODataArrindex);if(index overlap.hEvent；51 使 得 与 该 套 接 字 相 关 联 的使 得 与 该 套 接 字 相 关 联 的 W

41、SAEVENT 对 象 也 被对 象 也 被 Signaled，所 以，所 以WSAWaitForMultipleEvents 的调用操作成功返回。我们现在应该做的就是用与的调用操作成功返回。我们现在应该做的就是用与调 用调 用WSARecv相 同 的相 同 的WSAOVERLAPPED结 构 为 参 数 调 用结 构 为 参 数 调 用WSAGetOverlappedResult，从而得到本次，从而得到本次 I/O 传送的字节数等相关信息。在取得传送的字节数等相关信息。在取得接收的数据后，把数据原封不动的发送到客户端，然后重新激活一个接收的数据后，把数据原封不动的发送到客户端，然后重新激活一

42、个 WSARecv异步操作。异步操作。52 2.用完成例程方式实现的重叠用完成例程方式实现的重叠 I/O 模型模型 老陈接收到新的信件后，一般的程序是：打开信封老陈接收到新的信件后，一般的程序是：打开信封-掏出信纸掏出信纸-阅读信件阅读信件-回复信件回复信件.为了进一步减轻用户负担，微软又开发了一种新的技术：用户只为了进一步减轻用户负担，微软又开发了一种新的技术：用户只要告诉微软对信件的操作步骤，微软信箱将按照这些步骤去处理信件，不再需要要告诉微软对信件的操作步骤，微软信箱将按照这些步骤去处理信件，不再需要用户亲自拆信用户亲自拆信/阅读阅读/回复了！回复了！概括一点说，基于事件通知的重概括一点

43、说，基于事件通知的重叠叠 I/O 模型，在你投递了一个请求以后模型，在你投递了一个请求以后(比比如如 WSARecv)，系统在完成以后是用事件来通知你的，而在完成例程中，系统在，系统在完成以后是用事件来通知你的，而在完成例程中，系统在网络操作完成以后会自动调用你提供的回调函数，区别仅此而已，是不是很简单网络操作完成以后会自动调用你提供的回调函数，区别仅此而已，是不是很简单呢？呢？53 从图中可以看到，服务器端存在一个明显的从图中可以看到，服务器端存在一个明显的异步过程，也就是说我们把客户异步过程，也就是说我们把客户端连入的端连入的 SOCKET 与一个重叠结构绑定之后，便可以将通讯过程全权交给

44、系统与一个重叠结构绑定之后，便可以将通讯过程全权交给系统内部自己去帮我们调度处理了，我们在主线程中就可以去做其他的事情，边等候内部自己去帮我们调度处理了，我们在主线程中就可以去做其他的事情，边等候 54 系统完成的通知就系统完成的通知就 OK，这也就是完成例程高性能的原因所在。，这也就是完成例程高性能的原因所在。完成例程回调函数原型及传递方式完成例程回调函数原型及传递方式 void CALLBACK _CompletionRoutineFunc(DWORD dwError,/标志咱们投递的重叠操作，比如标志咱们投递的重叠操作，比如WSARecv，完成的状，完成的状态是什么态是什么 DWORD

45、cbTransferred,/指明了在重指明了在重叠操作期间，实际传输的字节量是多叠操作期间，实际传输的字节量是多大大 LPWSAOVERLAPPED lpOverlapped,/参数指明传递到最初的参数指明传递到最初的IO调用内的调用内的一个重叠结构一个重叠结构 DWORD dwFlags /返回操作结束时可能用的标志返回操作结束时可能用的标志(一般没用一般没用);55 int WSARecv(SOCKET s,/当然是投递这个操作的套接字当然是投递这个操作的套接字 LPWSABUF lpBuffers,/接收缓冲区，与接收缓冲区，与Recv函数不同函数不同 /这里需要一个由这里需要一个由W

46、SABUF结构构成的数组结构构成的数组 DWORD dwBufferCount,/数组中数组中WSABUF结构的数量，设置为结构的数量，设置为1即可即可 LPDWORD lpNumberOfBytesRecvd,/如果接收操作立即完成，这里会返回函如果接收操作立即完成，这里会返回函数调用数调用 /所接收到的字节数所接收到的字节数 LPDWORD lpFlags,/说来话长了，我们这里设置为说来话长了，我们这里设置为0 即可即可 LPWSAOVERLAPPED lpOverlapped,/“绑定绑定”的重叠结构的重叠结构 LPWSAOVERLAPPED_COMPLETION_ROUTINE lp

47、CompletionRoutine/我我 56 们的完成例程函数的指针们的完成例程函数的指针);57#define PORT 5150#define MSGSIZE 1024 typedef struct WSAOVERLAPPED overlap;WSABUF Buffer;char szMessageMSGSIZE;DWORD NumberOfBytesRecvd;DWORD Flags;SOCKET sClient;PER_IO_OPERATION_DATA,*LPPER_IO_OPERATION_DATA;DWORD WINAPI WorkerThread(LPVOID);void C

48、ALLBACK CompletionROUTINE(DWORD,DWORD,LPWSAOVERLAPPED,DWORD);SOCKET g_sNewClientConnection;BOOL g_bNewConnectionArrived=FALSE;58 int main()sListen=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);bind(sListen,(struct sockaddr*)&local,sizeof(SOCKADDR_IN);listen(sListen,3);CreateThread(NULL,0,WorkerThread,NULL

49、,0,&dwThreadId);while(TRUE)/Accept a connection g_sNewClientConnection=accept(sListen,(struct sockaddr*)&client,&iaddrSize);g_bNewConnectionArrived=TRUE;printf(Accepted client:%s:%dn,inet_ntoa(client.sin_addr),ntohs(client.sin_port);59 return 0;DWORD WINAPI WorkerThread(LPVOID lpParam)LPPER_IO_OPERA

50、TION_DATA lpPerIOData=NULL;while(TRUE)if(g_bNewConnectionArrived)/Launch an asynchronous operation for new arrived connection lpPerIOData=(LPPER_IO_OPERATION_DATA)HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,sizeof(PER_IO_OPERATION_DATA);lpPerIOData-Buffer.len=MSGSIZE;lpPerIOData-Buffer.buf=lpPerIODa