在我们使用AcceptEx并随着AcceptEx投递一个BUFFER后会带来一个副作用：比如某个客户端只执行一个connect操作，并不执行send操作，那么AcceptEx这个请求不会完成，相应的，我们用GetQueuedCompletionStatus在完成端口中得不到操作结果，这样，如果有很多个这样的连接，对程序性能会造成巨大的影响，我们需要用一种方法来定时检测，当某个连接已经建立并且连接时间超过我们规定的时间而且没有收发过数据，那么我们就把它关闭。检测连接时间可以用SO_CONNECT_TIME来调用getsockopt得到。
还有一个值得注意的地方：就是我们不能一下子发出很多AcceptEx调用等待客户连接，这样对程序的性能有影响，同时，在我们发出的AcceptEx调用耗尽的时候需要新增加AcceptEx调用，我们可以把FD_ACCEPT事件和一个EVENT关联起来，然后用WaitForSingleObject等待这个Event，当已经发出AccpetEx调用数目耗尽而又有新的客户端需要连接上来，FD_ACCEPT事件将被触发，EVENT变为已传信状态，
WaitForSingleObject返回，我们就重新发出足够的AcceptEx调用。
关于完成端口模型就介绍到这里。下面介绍我封装的类，这个类写完后，我用这个类做了个ECHOSERVER。
void main()
{
CompletionPortModel p;
p.Init();
p.AllocEventMessage();
if (FALSE == p.PostAcceptEx())
{
return;
}
p.ThreadLoop();
return;
}
我在我自己的机器上测试，
客户端的代码是
for (int i=0; i<10000; i++)
{
SOCKET s = socket(….);
connect(….);
send(…);
recv(…..)
cout << buffer << endl;
}
结果客户端程序在循环到3000多次的时候死掉，但是服务端程序运行良好，重新启动客户端程序，发送接收数据正常。
使用的时候，只需要从这个类派生一个子类，并改写HandleData和DataAction这两个虚函数，对于那些需要连续发送相关联的数据应用（比如传送文件），使用者需要自己扩展这两个函数，比如创建一个全局队列，每次从完成端口里得到数据后插入队列，然后用另外一个线程专门处理这个队列。。。
从结果来看，这个类还有不少需要改进的地方，比如没考虑多处理器上运行的情况。没有考虑完成端口线程阻塞情况，如果考虑完成端口阻塞情况，那么应该创建CPU数据*2个完成端口线程等等，，因为我同时正在做的毕业设计NDIS驱动防火墙开发正在一个比较难的地方卡住了，时间和精力有限，就没有对这个类进行进一步完善，程序中也许有不合理和错误的地方，请高手多多指教。对于高性能的服务端程序开发是比较难的，记得有次和腾讯一个技术人员聊天，他说，像腾讯QQ的开发，难点不在客户端，而在服务端各个服务器之间的通信和同步。服务端程程序的集群和负载平衡是一个很复杂的问题，我在这方面刚接触，希望能有更多的高手出来共享自己的经验。
封装这个类的时候，我把最新的PLATFORM SDK里的例子看了一遍，借鉴了其中很多思路和方法，在此对写这个例子的微软程序员表示感谢：）
类的详细代码可以[点这里]下载
DEMO就是一个ECHOSERVER，记得使用Release模式编译。
说明：本教程来源互联网或网友上传或出版商，仅为学习研究或媒体推广，wanshiok.com不保证资料的完整性。
2/2 首页 上一页 1 2 |
