TCP流式套接字的事件对象I/O管理WSAEventSelect编程

绝地灬酷狼 2022-02-19 05:13 190阅读 0赞

WSAEventSelect()函数和WSAAsyncSelect()函数类似，它们的区别在于当一个FD\_XXX网络事件发生时，WSAEventSelect()函数将导致一个应用程序指定的事件对象将被设置，即将网络事件投递到一个事件对象句柄，而不是将网络事件（消息）投递至一个窗口句柄。

WSAEventSelect()函数原型如下：

int WSAEventSelect(  
    SOCKET s,  //一个标识套接口的描述字  
    WSAEVENT hEventObject,  //是一个由WSACreateEvent(?)函数创建的事件对象句柄，用于标识与所提供的FD\_XXX网络事件集合相关的一个事件对象  
    long lNetworkEvents //指定应用程序感兴趣的各种网络事件(FD\_XXX)的组合  
);

以下为测试WSAEventSelect()函数的程序，一个服务器端两个客户端

下面是服务器端程序：

<table style="background-color:rgb(239,239,239); width:1129px; font-family:'Courier New'"> 
 <tbody> 
 <tr> 
 <td style="text-align:center; width:21px; font-family:Consolas; white-space:nowrap; color:rgb(187,187,187); font-size:13px; vertical-align:text-top"> 001 002 003 004 005 006 007 008 009 010 011 012 013 014 015 016 017 018 019 020 021 022 023 024 025 026 027 028 029 030 031 032 033 034 035 036 037 038 039 040 041 042 043 044 045 046 047 048 049 050 051 052 053 054 055 056 057 058 059 060 061 062 063 064 065 066 067 068 069 070 071 072 073 074 075 076 077 078 079 080 081 082 083 084 085 086 087 088 089 090 091 092 093 094 095 096 097 098 099 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171</td> 
 <td style="background-color:rgb(108,226,108); width:1px"> 
 <table> 
 <tbody></tbody> 
 </table> </td> 
 <td style="font-family:Consolas; font-size:13px; vertical-align:text-top">/************************************************************************/&nbsp; /*&nbsp;事件对象I/O管理程序实例&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/&nbsp; /************************************************************************/&nbsp; &nbsp; #include&nbsp;&lt;WINSOCK2.H&gt;&nbsp; #pragma&nbsp;comment(lib,"ws2_32")&nbsp; #include&nbsp;&lt;stdio.h&gt;&nbsp; &nbsp; int&nbsp;main()&nbsp; {&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;printf("服务端程序\n");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//------①加载----------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;WSADATA&nbsp;wsaData;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(WSAStartup(MAKEWORD(2,2),&amp;wsaData)!=0)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("WSAStartup&nbsp;Failed,Error=【%d】\n",WSAGetLastError());&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("①加载成功\n");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//-------②创建流式套接字------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;SOCKET&nbsp;s=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(s==INVALID_SOCKET)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("socket()&nbsp;Failed,Error=【%d】\n",WSAGetLastError());&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("②已创建监听套接口：【%d】\n",s);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//将套接口s置于”非阻塞模式“&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;u_long&nbsp;u1=1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;ioctlsocket(s,FIONBIO,(u_long*)&amp;u1);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//-----------③绑定本地地址---------------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;struct&nbsp;sockaddr_in&nbsp;Sadd;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;Sadd.sin_family=AF_INET;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;Sadd.sin_port=htons(5555);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;Sadd.sin_addr.S_un.S_addr=inet_addr("192.168.31.1");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(bind(s,(sockaddr*)&amp;Sadd,sizeof(Sadd))==SOCKET_ERROR)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("bind()&nbsp;Failed,Error=【%d】\n",WSAGetLastError());&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("③绑定成功，本地IP地址：【%s】,端口号：【%d】\n",inet_ntoa(Sadd.sin_addr),ntohs(Sadd.sin_port));&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//--------------④进入监听状态-----------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(listen(s,5)==SOCKET_ERROR)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("listen&nbsp;Failed,Error=【%d】\n",WSAGetLastError());&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("④进入监听状态\n");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//--------------⑤创建事件对象-----------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;WSAEVENT&nbsp;NewEvent=WSACreateEvent();&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(NewEvent==WSA_INVALID_EVENT)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("WSACreateEvent()&nbsp;Failed,Error=【%d】\n",WSAGetLastError());&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("⑤创建一个事件对象，返回的事件对象句柄NewEvent=%d\n",NewEvent);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//--------------⑥网络事件注册------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;WESerror=WSAEventSelect(s,NewEvent,FD_ACCEPT|FD_CLOSE);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(WESerror==INVALID_SOCKET)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("WSAEventSelect()&nbsp;Failed,Error=【%d】\n",WSAGetLastError());&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;-1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("⑥套接口【%d】、事件对象【%d】和网络事件FD_ACCEPT|FD_CLOSE已关联\n",s,NewEvent);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//-----------准备工作---------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;t=1;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;WSAEVENT&nbsp;eventArray[WSA_MAXIMUM_WAIT_EVENTS];&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;SOCKET&nbsp;sockArray[WSA_MAXIMUM_WAIT_EVENTS];&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;n=0;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;eventArray[n]=NewEvent;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;sockArray[n]=s;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;n++;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//------------循环处理-------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;while&nbsp;(true)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//---------------⑦等待事件对象--------------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;nIndex=WSAWaitForMultipleEvents(n,eventArray,FALSE,40000,FALSE);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("nIndex=%d\n",nIndex);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(nIndex==WSA_WAIT_FAILED)//------7.1调用失败---------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("调用失败\n");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;if&nbsp;(nIndex==WSA_WAIT_TIMEOUT)//-------7.2超时---------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(t&lt;3)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("第【%d】次超时\n",t);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t++;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;continue;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("第【%d】次超时，退出\n",t);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//---------------7.3网络事件触发事件对象句柄的工作状态--------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;WSANETWORKEVENTS&nbsp;event;//该结构记录网络事件和对应出错代码&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//---------⑧网络事件查询-----------&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;WSAEnumNetworkEvents(sockArray[nIndex-WSA_WAIT_EVENT_0],NULL,&amp;event);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;WSAResetEvent(eventArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((event.lNetworkEvents&amp;FD_ACCEPT)!=0)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//------8.1处理FD_ACCEPT通知消息&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(event.iErrorCode[FD_ACCEPT_BIT]==0)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(n&gt;WSA_MAXIMUM_WAIT_EVENTS)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("Too&nbsp;many&nbsp;connections!\n");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SOCKET&nbsp;sNew=accept(sockArray[nIndex-WSA_WAIT_EVENT_0],NULL,NULL);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;NewEvent=WSACreateEvent();&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;WSAEventSelect(sNew,NewEvent,FD_READ|FD_CLOSE);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;eventArray[n]=NewEvent;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sockArray[n]=sNew;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;n++;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;if&nbsp;(event.lNetworkEvents&amp;FD_READ)&nbsp;&nbsp;&nbsp;&nbsp;//-------8.2处理FD_READ通知消息&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(event.iErrorCode[FD_READ_BIT]==0)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;buf[256];&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;memset(buf,0,256);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;nRecv=recv(sockArray[nIndex-WSA_WAIT_EVENT_0],buf,sizeof(buf),0);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(nRecv&gt;0)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("接收到客户端【%d】数据：%s\n",sockArray[nIndex-WSA_WAIT_EVENT_0],buf);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;if&nbsp;(event.lNetworkEvents&amp;FD_CLOSE)&nbsp;&nbsp;//---------8.3处理FD_CLOSE通知消息&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(event.iErrorCode[FD_CLOSE_BIT]==0)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;closesocket(sockArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;WSACloseEvent(eventArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("套接字为【%d】的已关闭连接\n",sockArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(event.iErrorCode[FD_CLOSE_BIT]==10053)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;closesocket(sockArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;WSACloseEvent(eventArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("客户端【%d】非法关闭连接\n",sockArray[nIndex-WSA_WAIT_EVENT_0]);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for&nbsp;(int&nbsp;j=nIndex-WSA_WAIT_EVENT_0;j&lt;n-1;j++)&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sockArray[j]=sockArray[j+1];&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;eventArray[j]=eventArray[j+1];&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;n--;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}//&nbsp;end&nbsp;网络事件触发&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;}//end&nbsp;while&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;printf("退出服务器程序\n");&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;closesocket(s);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;WSACleanup();&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;0;&nbsp; }&nbsp;</td> 
 </tr> 
 </tbody> 
</table>

客户端程序有两个，代码差不多，只是IP变了，这里给出一个，点击展开就可以看到

> **\[cpp\]**  [view plain][] [copy][view plain]
> 
> 1. //Client 1  
> 2. \#include <winsock2.h>  
> 3. \#pragma comment(lib,"WS2\_32")  
> 4. \#include <stdio.h>  
> 5. **int** main()  
> 6. \{   printf("客户端程序/n");    
> 7. //----------------①加载---------------------------------------------------------  
> 8.     WSADATA wsaData;  
> 9.     **WORD** wVersionRequested=MAKEWORD(2,2);    
> 10.     **if**(WSAStartup(wVersionRequested,&wsaData)!=0)             
> 11.     \{   printf("WSAStartup() Failed,Error=/n",WSAGetLastError());     
> 12.         **return** 1;  
> 13.     \}  
> 14.     **else**   
> 15.         printf("①加载成功/n");        
> 16. //----------------②创建流式套节字------------------------------------------------    
> 17.     SOCKET c1;  
> 18.     c1 = socket(AF\_INET, SOCK\_STREAM,0);  
> 19.     **if**(c1 == INVALID\_SOCKET)      
> 20.     \{   printf("socket() Failed,Error=/n",WSAGetLastError());  
> 21.         **return** 1;  
> 22.     \}  
> 23.     **else**   
> 24.         printf("②已创建连接套接字:【 %d 】/n",c1);      
> 25. //----------------绑定本地地址------------------------------------------------  
> 26.     **struct**  sockaddr\_in  C1add;    
> 27.     C1add.sin\_family=AF\_INET;  
> 28.     C1add.sin\_port=htons(2222);  
> 29.     C1add.sin\_addr.s\_addr=inet\_addr("192.168.31.2");      
> 30.     **if**(bind(c1,(sockaddr\*)&C1add,**sizeof**(C1add))==SOCKET\_ERROR)    
> 31.     \{   printf("bind() Failed,Error=/n",WSAGetLastError());   
> 32.         **return** 1;  
> 33.     \}  
> 34.     **else**   
> 35.         printf("绑定成功,本地IP地址:【 %s 】,端口号:【 %d 】/n",inet\_ntoa(C1add.sin\_addr),ntohs(C1add.sin\_port));    
> 36. //------------------③连接请求------------------------------------------------         
> 37.     **struct**  sockaddr\_in  Sadd;    
> 38.     Sadd.sin\_family=AF\_INET;  
> 39.     Sadd.sin\_port=htons(5555);    
> 40.     Sadd.sin\_addr.s\_addr=inet\_addr("192.168.31.1");   
> 41.     **if**(connect(c1, (sockaddr\*)&Sadd, **sizeof**(Sadd)) == -1)  
> 42.     \{   printf(" Failed connect(),Error=【 %d 】/n",WSAGetLastError());         
> 43.         **return** 1;  
> 44.     \}  
> 45.     **else** //\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*连接成功,可以 开始发送、接收\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*  
> 46.     \{   printf("③连接成功,服务器IP地址:【 %s 】,端口号:【 %d 】/n",inet\_ntoa(Sadd.sin\_addr),ntohs(Sadd.sin\_port));  
> 47.         **int** a;  
> 48.         printf("希望发送数据吗？(键入“1”发送)");  
> 49.         scanf("%d",&a);               
> 50.         **while**(a==1)  //------循环处理------  
> 51.         \{   //-----发送------                       
> 52.             **char** S\_buf\[\] = "Hello!I am a client 1";   
> 53.             **int**  isend=send(c1,S\_buf,strlen(S\_buf),0);        
> 54.             **if**(isend==SOCKET\_ERROR)   
> 55.             \{  printf("Failed  send(),Error=【 %d 】,或者服务器意外关闭/n",WSAGetLastError());  
> 56.                **return** 1;  
> 57.             \}  
> 58.             **else** **if**(isend!=0)  
> 59.                printf("信息【 %s 】已发送/n",S\_buf);              
> 60.             **else**  
> 61.                printf("信息无法发送给服务端/n");  
> 62.   
> 63.             printf("希望继续发送数据吗？(键入“1”继续发送)");  
> 64.                 scanf("%d",&a);  
> 65.                 **if**(a!=1)              
> 66.                 **break**;  
> 67.         \} //------end 循环处理------         
> 68.     \} //\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*end 开始发送、接收\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*  
> 69. //------------------④关闭、释放------------------------------------------------    
> 70.     closesocket(c1);          
> 71.     WSACleanup();  
> 72.     printf("④与服务器连接完毕/n");  
> 73.     **return** 0;  
> 74.       
> 75. \}  
> 
>

先启动服务器端，再启动1号客户端，接着启动2号客户端，就会看到如图所示：

![0_1275015429v6Vi.gif][]

[view plain]: http://blog.csdn.net/akof1314/article/details/5630090#
[0_1275015429v6Vi.gif]: /images/20220219/e90cd125d0c147c7ab3f819373cd9a8c.png