基于iocp的socket通讯软件的设计

《基于iocp的socket通讯软件的设计》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、基于iocp的SOCKET通讯软件的设计　　完成端口基本上公认为一种在windows服务平台上比较成熟和高效的IO方法，利用完成端口进行重叠I/O的技术在WindowsNT和WIndows2000上提供了真正的可扩展性。完成端口和WindowsSocket2.0结合可以开发出支持大量连接的网络服务程序。　　首先来看看重叠I/O(OverlappedI/O)：　　重叠I/O(OverlappedI/O)机制允许发起一个操作，然后在操作完成之后接受到信息。对于那种需要很长时间才能完成的操作来说，重叠IO机制尤其有用，因为发起重叠操作的线程在重

2、叠请求发出后就可以自由的做别的事情了。　　在WinNT和Win2000上，提供的真正的可扩展的I/O模型就是使用完成端口（CompletionPort）的重叠I/O。　　接下来看看完成端口（CompletionPorts）　　其实可以把完成端口看成系统维护的一个队列，操作系统把重叠IO操作完成的事件通知放到该队列里，由于是暴露“操作完成”的事件通知，所以命名为“完成端口”（COmpletionPorts）。一个socket被创建后，可以在任何时刻和一个完成端口联系起来。　　一般来说，一个应用程序可以创建多个工作线程来处理完成端口上的通知事

3、件。工作线程的数量依赖于程序的具体需要。但是在理想的情况下，应该对应一个CPU创建一个线程。因为在完成端口理想模型中，每个线程都可以从系统获得一个“原子”性的时间片，轮番运行并检查完成端口，线程的切换是额外的开销。在实际开发的时候，还要考虑这些线程是否牵涉到其他堵塞操作的情况。如果某线程进行堵塞操作，系统则将其挂起，让别的线程获得运行时间。因此，如果有这样的情况，可以多创建几个线程来尽量利用时间。　　总之，开发一个可扩展的Winsock服务器并非十分困难的。主要是开始一个监听socket,接收连接，并且进行重叠发送和接收的IO操作。最大的

4、挑战就是管理系统资源，限制重叠Io的数量，避免内存危机。遵循这几个原则，就能帮助你开发高性能，可扩展的服务程序。　　socket的接收缓冲，因为接收事件仅仅在AcceptEx调用中发生。保证每个socket都有一个接收缓冲不会造成什么危害。一旦客户端/服务器在最初的一次请求（由AcceptEx完成）之后进行交互，发送更多的数据，那么取消接收缓冲更是一个很不好的做法。除非你能保证这些数据都是在每个连接的重叠IO接收里完成的。　　服务器器端程序代码如下：　　#include　　#include　　#p

5、ragmacomment(lib,"ws2_32.lib")　　typedefstruct_OVERLAPPEDPLUS　　{　　OVERLAPPEDol;　　SOCKETsocket;　　intnOpCode;　　WSABUFwsaBuf;　　DWORDdwFlags;　　DWORDdwBytes;　　charpBuf[4096];　　}OVERLAPPEDPLUS,*POVERLAPPEDPLUS;　　DWORDWINAPIServerWorkerThread(LPVOIDCompletionPortID);　　voidmain()　

6、　{　　WORDwVersionRequested;　　WSADATAwsaData;　　interr;　　wVersionRequested=MAKEWORD(2,2);　　err=WSAStartup(wVersionRequested,&wsaData);　　if(err!=0)　　{　　printf("WSAStartuperrors!");　　return;　　}　　if(LOBYTE(wsaData.wVersion)!=2

7、

8、　　HIBYTE(wsaData.wVersion)!=2)　　{　　WSACleanup();

9、　　return;　　}　　SOCKETsockSvr=WSASocket(AF_INET,SOCK_STREAM,0,0,0,WSA_FLAG_OVERLAPPED);　　if(INVALID_SOCKET==sockSvr)　　{　　printf("WSASocketerrors!");　　return;　　}　　SOCKADDR_INaddrSvr;　　ZeroMemory(&addrSvr,sizeof(SOCKADDR_IN));　　addrSvr.sin_family=AF_INET;　　addrSvr.sin_port=

10、htons(6000);　　addrSvr.sin_addr.S_un.S_addr=htonl(INADDR_ANY);　　intnRet=bind(sockSvr,(SOCKADDR*)&