高并发高性能的静态Web服务器 + 完成端口部分源码 (修正)

xinglp

附件已经修正

1.基于完称端口的静态Web服务器.
2.适合用于高并发高负荷的静态页面场合,特别适用于图片服务器.
3.为了满足高性能的要求以及保持灵活性,动态内容采用预留接口实现.
4.配置说明
  1)配置文件为当前目录下的config.ini
  2)ListenPort:指定绑定端口
  3)WWWRoot:静态页面内容所在目录
  4)AcceptExNum:可承受的突然并发连接(建议采用默认值)
  5)MaxWorkThread:工作线程数目(0代表根据CPU数目指定最佳值)
  6)ServiceName:安装后服务的名称

较1.0.0.1有多处改进,在17000个并发持续连接的情况下仍有良好的性能,改天放Linux下基于epoll模型的

1. 
   
2. //完成端口的部分代码
   
3. 
   
4. //主线程
   
5. 
   
6. //创建原始完成端口句柄
   
7. hIOCP=CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,0,0);
   
8. if(NULL==hIOCP)
   
9. {
   
10.     //错误处理
    
11. }
    
12. 
    
13. //创建监听套节字 ListenPort()封装了bind listen等函数
    
14. SocketListen=ListenPort();
    
15. 
    
16. //绑定原始完成端口句柄到监听套节字SocketListen
    
17. if(NULL==CreateIoCompletionPort((HANDLE)SocketListen,hIOCP,0,0))
    
18. {
    
19.     //错误处理
    
20. }
    
21. 
    
22. //投递AcceptEx
    
23. {
    
24.     unsigned long Num;
    
25.     unsigned long AcceptExNum;
    
26. 
    
27.     //GetConfigInt封装了读取配置文件
    
28.     AcceptExNum=GetConfigInt("Httpd","AcceptExNum",2000);
    
29. 
    
30.     //投递多个AccpetEx,PostAccpetEx封装了AccpetEx
    
31.     for(Num=0;Num<AcceptExNum;Num++)
    
32.     {
    
33.         PostAccpetEx(NULL);
    
34.     }
    
35. }
    
36. 
    
37. {    //启动工作线程
    
38.    
    
39.     unsigned long    MaxWorkThread;
    
40.     unsigned long    threadcount;
    
41.     DWORD            dwThreadId;
    
42.     HANDLE*            hThread;
    
43. 
    
44.     //读取配置文件中开启线程的数目
    
45.     MaxWorkThread=GetConfigInt("Httpd","MaxWorkThread",2);
    
46.    
    
47.     //0代表根据CPU数目设置线程数目 CPU数目*2+2
    
48.     if(MaxWorkThread<1)
    
49.     {
    
50.         SYSTEM_INFO systemInfo;
    
51.         GetSystemInfo(&systemInfo);
    
52.         MaxWorkThread=systemInfo.dwNumberOfProcessors*2+2;
    
53.     }
    
54. 
    
55.     hThread=HeapAlloc(GetProcessHeap(),0,sizeof(HANDLE)*MaxWorkThread);
    
56. 
    
57.     for(threadcount=0;threadcount<MaxWorkThread;threadcount++)
    
58.     {
    
59.         hThread[threadcount]=CreateThread(NULL,0,WorkerThread,hIOCP,0,&dwThreadId);
    
60.     }
    
61. 
    
62.     //等待工作线程退出,主线程进入阻塞状态
    
63.     WaitForMultipleObjects(MaxWorkThread,hThread,TRUE,INFINITE);
    
64.    
    
65.     for(threadcount=0;threadcount<MaxWorkThread;threadcount++)
    
66.     {
    
67.         CloseHandle(hThread);
    
68.     }
    
69.    
    
70.     HeapFree(GetProcessHeap(),0,hThread);
    
71. 
    
72. }
    
73. 
    
74. 
    
75. 
    
76. //工作线程
    
77. 
    
78. //LOOP循环条件,根据情况设定相应的条件
    
79. while(LOOP)
    
80. {
    
81.     BOOL            Succes;
    
82.     P_IOCPDATA        IOCPData;//自己定义的数据结构
    
83.     unsigned long    TransByte;
    
84.     LPWSAOVERLAPPED    lpWsaOverlapped;
    
85. 
    
86.     //获取完成通知
    
87.     //完成端口的精华就在这里
    
88.     //通过调用GetQueuedCompletionStatus,线程可以获得原子性的时间段,避免了线程切换的开销
    
89.     Succes=
    
90.     GetQueuedCompletionStatus(
    
91.     hIOCP,
    
92.     &TransByte,
    
93.     (unsigned long*)&IOCPData,
    
94.     &lpWsaOverlapped,
    
95.     INFINITE
    
96.     );
    
97. 
    
98.     if(Succes&&NULL!=lpWsaOverlapped&&TransByte)//完全正常
    
99.     {
    
100.         IOCPData=(P_IOCPDATA)lpWsaOverlapped;
     
101. 
     
102.         //根据不同的I/O类型进行不同的处理
     
103.         switch(IOCPData->IOType)
     
104.         {
     
105.             //AcceptEx具有连接和接受的功能
     
106.             case AcptDone:
     
107.             {
     
108.                 //有一个AccpetEx完成,再投递一个AccpetEx
     
109.                 PostAccpetEx(NULL);
     
110.                 {
     
111.                     //此段代码可以不调用,未发生错误,不知道为什么,
     
112.                     //如果不调用的话,句柄不会很多,不会超出限制
     
113.                     /*
     
114.                     //更行AccpetEx返回的套节字状态
     
115.                     int    ErrorCode;
     
116.                     ErrorCode=
     
117.                     setsockopt(
     
118.                     IOCPData->Socket,
     
119.                     SOL_SOCKET,
     
120.                     SO_UPDATE_ACCEPT_CONTEXT,
     
121.                     (char*)&SocketListen,
     
122.                     sizeof(SocketListen)
     
123.                     );
     
124.                     if(SOCKET_ERROR==ErrorCode)
     
125.                     {
     
126.                         Test();
     
127.                         FreeIOCPData(IOCPData);
     
128.                         continue;
     
129.                     }
     
130.                     */
     
131.                 }
     
132.                 //绑定AccpetEx返回的套节字到hIOCP
     
133.                 if(hIOCP!=CreateIoCompletionPort((HANDLE)IOCPData->Socket,hIOCP,(unsigned long)IOCPData,0))
     
134.                 {
     
135.                     Test();
     
136.                     FreeIOCPData(IOCPData);
     
137.                     continue;
     
138.                 }
     
139.                 //我写的是一个Web服务器,下面的是Http消息头的分析处理
     
140.                 if(HttpParseHead(IOCPData))
     
141.                 {
     
142.                     Respons(IOCPData);
     
143.                 }
     
144.                 break;
     
145. 
     
146.             }
     
147.             //...... 其他处理情况
     
148.         }
     
149.     }
     
150.     //.... 出现错误情况下的处理
     
151. }
     
152. 
     
153. //做人要厚道
     
154. //转载请保留连接http://hi.baidu.com/xinglp
     
155. //xlp1119@163.com,漫步黄昏
     
156. 
     

复制代码

[ 本帖最后由 xinglp 于 2007-4-6 18:49 编辑 ]

llzqq

期待LINUX版本的

LuckSnail

这个要顶~，，那天出来linux 的测试一把

powerv_cu

期待，希望尽快放出。谢谢

xinglp

＞回复楼上，epoll模型到是完成了，但是根据＊＊＊＊条例，这属于公司机密（分明是我完成的），话说回来也没什么技术含量，无非就是用I/O事件通知机制实现多路复用，用线程池提高SMP系统上的处理器利用率，至于稳定性和安全性那就是编码设计的问题了，在加上良好的缓存算法，吞吐量饱和千兆网卡不成问题，也就是目前瓶颈不在程序了。很可惜为了我的饭碗，我只能说这些了，如果你的linux服务器撑不住，可以变相的试试2003的IIS，仅供参考。

powerv_cu

哈哈。理解。不过说的就简单，像我这样的级别，领悟不到那份简单。我只能支持您的现成品。昨天测试一下，确实不错。