高并发高性能的静态Web服务器+完成端口部分代码

xinglp

SmartHttpd 1.0.0.2

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.         if(Succes&&NULL!=lpWsaOverlapped&&TransByte)//完全正常
    
98.         {
    
99.                 IOCPData=(P_IOCPDATA)lpWsaOverlapped;
    
100. 
     
101.                 //根据不同的I/O类型进行不同的处理
     
102.                 switch(IOCPData->IOType)
     
103.                 {
     
104.                         //AcceptEx具有连接和接受的功能
     
105.                         case AcptDone:
     
106.                         {
     
107.                                 //有一个AccpetEx完成,再投递一个AccpetEx
     
108.                                 PostAccpetEx(NULL);
     
109.                                 {
     
110.                                         //此段代码可以不调用,未发生错误,不知道为什么,
     
111.                                         //如果不调用的话,句柄不会很多,不会超出限制
     
112.                                         /*
     
113.                                         //更行AccpetEx返回的套节字状态
     
114.                                         int        ErrorCode;
     
115.                                         ErrorCode=
     
116.                                         setsockopt(
     
117.                                         IOCPData->Socket,
     
118.                                         SOL_SOCKET,
     
119.                                         SO_UPDATE_ACCEPT_CONTEXT,
     
120.                                         (char*)&SocketListen,
     
121.                                         sizeof(SocketListen)
     
122.                                         );
     
123.                                         if(SOCKET_ERROR==ErrorCode)
     
124.                                         {
     
125.                                                 Test();
     
126.                                                 FreeIOCPData(IOCPData);
     
127.                                                 continue;
     
128.                                         }
     
129.                                         */
     
130.                                 }
     
131.                                 //绑定AccpetEx返回的套节字到hIOCP
     
132.                                 if(hIOCP!=CreateIoCompletionPort((HANDLE)IOCPData->Socket,hIOCP,(unsigned long)IOCPData,0))
     
133.                                 {
     
134.                                         Test();
     
135.                                         FreeIOCPData(IOCPData);
     
136.                                         continue;
     
137.                                 }
     
138.                                 //我写的是一个Web服务器,下面的是Http消息头的分析处理
     
139.                                 if(HttpParseHead(IOCPData))
     
140.                                 {
     
141.                                         Respons(IOCPData);
     
142.                                 }
     
143.                                 break;
     
144. 
     
145.                         }
     
146.                         //...... 其他处理情况
     
147.                 }
     
148.         }
     
149.         //.... 出现错误情况下的处理
     
150. }
     
151. //做人要厚道
     
152. //转载请保留连接http://hi.baidu.com/xinglp
     
153. //xlp1119@163.com,漫步黄昏
     

复制代码

晨想

什么叫做 基于完称端口？新名词我想学习。

xinglp

就是一种I/O模型,比较高效的,和Linux得epoll差不多

guiguiaiwawa

好高深呀！看不懂，需要好好学习一下！！！

drivel

为什么带的是个W32文件？