Windows Socket IO模型.doc

WindowsSocketI/O模型---重叠I/O模型、完成端口模型
四.重叠I/O模型Winsock2的发布使得SocketI/O有了和文件I/O统一的接口。我们可以通过使用Win32文件操纵函数ReadFile和WriteFile来进行SocketI/O。伴随而来的，用于普通文件I/O的重叠I/O模型和完成端口模型对SocketI/O也适用了。这些模型的优点是可以达到更佳的系统性能，但是实现较为复杂，里面涉及较多的C语言技巧。例如我们在完成端口模型中会经常用到所谓的“尾随数据”。
1.用事件通知方式实现的重叠I/O模型#include<winsock2.h>#include<stdio.h>
#definePORT5150#defineMSGSIZE1024
#pragmacomment(lib,"ws2_32.lib")
typedefstruct{WSAOVERLAPPEDoverlap;WSABUFBuffer;charszMessage[MSGSIZE];DWORDNumberOfBytesRecvd;DWORDFlags;}PER_IO_OPERATION_DATA,*LPPER_IO_OPERATION_DATA;
intg_iTotalConn=0;SOCKETg_CliSocketArr[MAXIMUM_WAIT_OBJECTS];WSAEVENTg_CliEventArr[MAXIMUM_WAIT_OBJECTS];LPPER_IO_OPERATION_DATAg_pPerIODataArr[MAXIMUM_WAIT_OBJECTS];
DWORDWINAPIWorkerThread(LPVOID);voidCleanup(int);
intmain(){WSADATAwsaData;SOCKETsListen,sClient;SOCKADDR_INlocal,client;DWORDdwThreadId;intiaddrSize=sizeof(SOCKADDR_IN);
//InitializeWindowsSocketlibraryWSAStartup(0x0202,&wsaData);
//CreatelisteningsocketsListen=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
//Bindlocal.sin_addr.S_un.S_addr=htonl(INADDR_ANY);local.sin_family=AF_INET;local.sin_port=htons(PORT);bind(sListen,(structsockaddr*)&local,sizeof(SOCKADDR_IN));
//Listenlisten(sListen,3);
//CreateworkerthreadCreateThread(NULL,0,WorkerThread,NULL,0,&dwThreadId);
while(TRUE){//AcceptaconnectionsClient=accept(sListen,(structsockaddr*)&client,&iaddrSize);printf("Acceptedclient:%s:%d\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port));
g_CliSocketArr[g_iTotalConn]=sClient;//AllocateaPER_IO_OPERATION_DATAstructureg_pPerIODataArr[g_iTotalConn]=(LPPER_IO_OPERATION_DATA)HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,sizeof(PER_IO_OPERATION_DATA));g_pPerIODataArr[g_iTotalConn]->Buffer.len=MSGSIZE;g_pPerIODataArr[g_iTotalConn]->Buffer.buf=g_pPerIODataArr[g_iTotalConn]->szMessage;g_CliEventArr[g_iTotalConn]=g_pPerIODataArr[g_iTotalConn]->overlap.hEvent=WSACreateEvent();
//LaunchanasynchronousoperationWSARecv(g_CliSocketArr[g_iTotalConn],&g_pPerIODataArr[g_iTotalConn]->Buffer,1,&g_pPerIODataArr[g_iTota