想用c写一个Httpserver，大家给点思路啊！！

nicle

想写个最简单的多线程httpserver，只要能实现文件传送的功能，大家有什么思路或类似的代码么？小弟在这先谢了！！！

mirnshi

到网上找一个，小的httpd很多

mengwg

早些年写的，供参考。

1. 
   
2. #include <system.h>;
   
3. #include <stdio.h>;
   
4. #include <string.h>;
   
5. #include <stdlib.h>;
   
6. #include <sys/stat.h>;
   
7. #ifndef WINDOW_SYS
   
8.   #include <unistd.h>;
   
9.   #include <sys/socket.h>;
   
10.   #include <netinet/in.h>;
    
11.   #include <arpa/inet.h>;
    
12.   #include <sys/select.h>;
    
13.   #include <sys/times.h>;
    
14.   #include <sys/time.h>;
    
15.   #include <strings.h>;
    
16.   #include <signal.h>;
    
17. #endif
    
18. #include <asyncapi.h>;
    
19. #include <tbase.h>;
    
20. #include <paramgr.h>;
    
21. #include <cini.h>;
    
22. 
    
23. char * Gen_Head[] =
    
24.   {"Cache-Control",            // Section 14.9
    
25.    "Connection",               // Section 14.10
    
26.    "Date",                     // Section 14.19
    
27.    "Pragma",                   // Section 14.32
    
28.    "Transfer-Encoding",        // Section 14.40
    
29.    "Upgrade",                  // Section 14.41
    
30.    "Via"};                     // Section 14.44
    
31. #define Gen_Head_Num 7
    
32. 
    
33. int GetGen_HeadType(char * type)
    
34. {
    
35. int id;
    
36.   for(id=0;id<Gen_Head_Num;id++)
    
37.     if(!strcmp(Gen_Head[id],type))
    
38.       return id;
    
39.   return -1;
    
40. }
    
41. 
    
42. char * Req_Method[] =
    
43.   {"OPTIONS",                  // Section 9.2
    
44.    "GET",                      // Section 9.3
    
45.    "HEAD",                     // Section 9.4
    
46.    "POST",                     // Section 9.5
    
47.    "PUT",                      // Section 9.6
    
48.    "DELETE",                   // Section 9.7
    
49.    "TRACE"};                   // Section 9.8
    
50. #define Req_Method_Num 7
    
51. 
    
52. int GetReq_MethodType(char * type)
    
53. {
    
54. int id;
    
55.   for(id=0;id<Req_Method_Num;id++)
    
56.     if(!strcmp(Req_Method[id],type))
    
57.       return id;
    
58.   return -1;
    
59. }
    
60. 
    
61. char * Req_Head[] =
    
62.   {"Accept",                   // Section 14.1
    
63.    "Accept-Charset",           // Section 14.2
    
64.    "Accept-Encoding",          // Section 14.3
    
65.    "Accept-Language",          // Section 14.4
    
66.    "Authorization",            // Section 14.8
    
67.    "From",                     // Section 14.22
    
68.    "Host",                     // Section 14.23
    
69.    "If-Modified-Since",        // Section 14.24
    
70.    "If-Match",                 // Section 14.25
    
71.    "If-None-Match",            // Section 14.26
    
72.    "If-Range",                 // Section 14.27
    
73.    "If-Unmodified-Since",      // Section 14.28
    
74.    "Max-Forwards",             // Section 14.31
    
75.    "Proxy-Authorization",      // Section 14.34
    
76.    "Range",                    // Section 14.36
    
77.    "Referer",                  // Section 14.37
    
78.    "User-Agent"};              // Section 14.42
    
79. 
    
80. #define Req_Head_Num 17
    
81. 
    
82. int GetReq_HeadType(char * type)
    
83. {
    
84. int id;
    
85.   for(id=0;id<Req_Head_Num;id++)
    
86.     if(!strcmp(Req_Head[id],type))
    
87.       return id;
    
88.   return -1;
    
89. }
    
90. 
    
91. char * Res_Head[] =
    
92.   {"Age",                      // Section 14.6
    
93.    "Location",                 // Section 14.30
    
94.    "Proxy-Authenticate",       // Section 14.33
    
95.    "Public",                   // Section 14.35
    
96.    "Retry-After",              // Section 14.38
    
97.    "Server",                   // Section 14.39
    
98.    "Vary",                     // Section 14.43
    
99.    "Warning",                  // Section 14.45
    
100.    "WWW-Authenticate"};        // Section 14.46
     
101. 
     
102. #define Res_Head_Num 17
     
103. 
     
104. int GetRes_HeadType(char * type)
     
105. {
     
106. int id;
     
107.   for(id=0;id<Res_Head_Num;id++)
     
108.     if(!strcmp(Res_Head[id],type))
     
109.       return id;
     
110.   return -1;
     
111. }
     
112. 
     
113. char * Res_Entity[] =
     
114.    {"Allow",                   // Section 14.7
     
115.     "Content-Base",            // Section 14.11
     
116.     "Content-Encoding",        // Section 14.12
     
117.     "Content-Language",        // Section 14.13
     
118.     "Content-Length",          // Section 14.14
     
119.     "Content-Location",        // Section 14.15
     
120.     "Content-MD5",             // Section 14.16
     
121.     "Content-Range",           // Section 14.17
     
122.     "Content-Type",            // Section 14.18
     
123.     "ETag",                    // Section 14.20
     
124.     "Expires",                 // Section 14.21
     
125.     "Last-Modified"};          // Section 14.29
     
126. 
     
127. #define Res_Entity_Num 12
     
128. 
     
129. int GetRes_EntityType(char * type)
     
130. {
     
131. int id;
     
132.   for(id=0;id<Res_Entity_Num;id++)
     
133.     if(!strcmp(Res_Entity[id],type))
     
134.       return id;
     
135.   return -1;
     
136. }
     
137. 
     
138. typedef struct
     
139. {
     
140.   int  Code;
     
141.   char Msg[40];
     
142. }StatusCodeStru;
     
143. 
     
144. StatusCodeStru StatusCode[]=
     
145.   {{100,"Continue"},
     
146.    {101,"Switching Protocols"},
     
147.    {200,"OK"},                                       /* 成功 */
     
148.    {201,"Created"},                                  /* 成功 新的资源建立(POST) */
     
149.    {202,"Accepted"},                                 /* 请求被接受，但处理未完成 */
     
150.    {203,"Non-Authoritative Information"},
     
151.    {204,"No Content"},                               /* 成功，但无信息返回 */
     
152.    {205,"Reset Content"},
     
153.    {206,"Partial Content"},
     
154.    {300,"Multiple Choices"},
     
155.    {301,"Moved Permanently"},                        /* 所请求的资源已经被指派为新的固定 URL */
     
156.    {302,"Moved Temporarily"},
     
157.    {303,"See Other"},                                /* 文档没有修改 (GET) */
     
158.    {304,"Not Modified"},
     
159.    {305,"Use Proxy"},
     
160.    {400,"Bad Request"},                              /* 错误的请求 */
     
161.    {401,"Unauthorized"},                             /* 未被授权，该请求要求用户认证 */
     
162.    {402,"Payment Required"},
     
163.    {403,"Forbidden"},                                /* 不明原因的禁止 */
     
164.    {404,"Not Found"},                                /* 没有找到 */
     
165.    {405,"Method Not Allowed"},
     
166.    {406,"Not Acceptable"},
     
167.    {407,"Proxy Authentication Required"},
     
168.    {408,"Request Time-out"},
     
169.    {409,"Conflict"},
     
170.    {410,"Gone"},
     
171.    {411,"Length Required"},
     
172.    {412,"Precondition Failed"},
     
173.    {413,"Request Entity Too Large"},
     
174.    {414,"Request-URI Too Large"},
     
175.    {415,"Unsupported Media Type"},
     
176.    {500,"Internal Server Error"},                    /* 内部服务器差错 */
     
177.    {501,"Not Implemented"},                          /* 没有实现 */
     
178.    {502,"Bad Gateway"},                              /* 错误的网关 */
     
179.    {503,"Service Unavailable"},                      /* 服务暂时失效 */
     
180.    {504,"Gateway Time-out"},
     
181.    {505,"HTTP Version not supported"}};
     
182. 
     
183. //定义文件类型配对信息
     
184. typedef struct
     
185. {
     
186.   char  Ext[8];
     
187.   char  Type[32];
     
188. }FileTypeStru;
     
189. 
     
190. FileTypeStru File_Type[]={
     
191.             {"","*/*"},
     
192.             {"htm","text/html"},
     
193.             {"txt","text/text"},
     
194.             {"html","text/html"},
     
195.             {"gif","image/gif"},
     
196.             {"jpg","image/jpg"},
     
197.             {"png","image/png"},
     
198.     };
     
199. #define File_Type_Num   7
     
200. 
     
201. char * GetFile_Type(char * ext)
     
202. {
     
203. int id;
     
204.   for(id=0;id<File_Type_Num;id++)
     
205.     if(!strcmp(File_Type[id].Ext,ext))
     
206.       return File_Type[id].Type;
     
207.   return File_Type[0].Type;
     
208. }
     
209. 
     
210. 
     
211. /*定义配置信息*/
     
212. struct HttpSetStru
     
213. {
     
214.   /* 存放信息的路径 */
     
215.   char  DocPath[128];
     
216.   /* 基础路径 */
     
217.   char  BasePath[128];
     
218.   /* 显示的默认文档 */
     
219.   char  DefaultDoc[128];
     
220.   /* 用于存放临时文件的路径 */
     
221.   char  TmpPath[128];
     
222.   /* 用于存放CGI程序的路径 */
     
223.   char  CgiPath[128];
     
224.   /* 服务端口编号 */
     
225.   short Port;
     
226.   /* 主机名称 */
     
227.   char  HostName[128];
     
228. }HttpSet;
     
229. 
     
230. /*
     
231. 函数功能：判断该路径是否CGI路径
     
232. 传入参数：
     
233.   path: 要判断的路径
     
234. 返回参数：
     
235.   1：是CGI路径
     
236.   0：不是CGI路径
     
237. */
     
238. int IsCgiPath(char * path)
     
239. {
     
240.   if(!strcmp(path,HttpSet.CgiPath)) return 1;
     
241.   return 0;
     
242. }
     
243. 
     
244. /*定义HTTP请求头结构*/
     
245. class TRequest_HTTP
     
246. {
     
247. public:
     
248.   /* 客户端的连接 */
     
249.   int  mClientSocket;
     
250.   /* 客户端的 IP 地址 */
     
251.   char mClientIp[30];
     
252.   /* 存储的信息 */
     
253.   char mLine[5120];
     
254.   /* 存储的字节数 */
     
255.   char mBytes;
     
256.   /* 请求类型 */
     
257.   char mType[30];
     
258.   /* 请求的 URI */
     
259.   char mUri[300];
     
260.   /* 版本标识 */
     
261.   char mVersion[200];
     
262.   /* 存放请求头传入的参数 */
     
263.   TParaMgr mReqHead;
     
264.   /* 存放返回的参数 */
     
265.   TParaMgr mRetHead;
     
266.   /* 状态编码 */
     
267.   int mStatusCode;
     
268.   /* 错误编码 */
     
269.   int mErrorCode;
     
270. private:
     
271.   /* 是不是第一行 */
     
272.   int  mIsFirstLine;
     
273.   /* 文件名称 */
     
274.   char mFileName[200];
     
275.   /* 路径名称 */
     
276.   char mPathName[200];
     
277. public:
     
278.   /* 构造函数 */
     
279.   TRequest_HTTP();
     
280.   /* 返回信息给客户端 */
     
281.   void RetToClient();
     
282.   /* 添加信息 */
     
283.   void BrowseDataCome(char * line,int bytes);
     
284.   /* 分析每个实体域 */
     
285.   int  AnalysisHeadLine(char * line);
     
286.   /* 分析请求的信息 */
     
287.   int  AnalysisRequestLine(char * line);
     
288.   /* 分析URI */
     
289.   void AnalysisUri(char * uri);
     
290.   /* 设置状态码及信息 */
     
291.   void SetStatusCode(int code,char * msg);
     
292.   /* 设置客户端的信 息 */
     
293.   void SetClientInfo(int socket,char * ip);
     
294.   /* 压缩生成返回的头 */
     
295.   char * PackRetHead(int * size);
     
296.   /* 处理 GET 的请求句柄 */
     
297.   void Process_Get();
     
298.   /* 处理请求的句柄 */
     
299.   void Process_Request();
     
300. };
     
301. 
     
302. class T_Http
     
303. {
     
304. public:
     
305.   TMemList * mSiteLst;
     
306. 
     
307. public:
     
308.   T_Http();
     
309.   ~T_Http();
     
310. 
     
311.   TRequest_HTTP * GetSite(int socketid);
     
312.   int AddSite(int socketid,char * address);
     
313.   int DeleteSite(int socketid);
     
314.   int Disconnect_Handle(int sock,char * ip);
     
315.   int DataArrived_Handle(int sock,char * buf,int length);
     
316.   int ConnectIn_Handle(int sock,char * ip,int servsocket);
     
317.   int LoadHttpSet();
     
318.   void ShowHttpSet();
     
319. };
     
320. 
     
321. T_Http IHttp;
     
322. 
     
323. /*******************************************************************
     
324. *                    下面是T_Http类的成员函数
     
325. *******************************************************************/
     
326. T_Http::T_Http()
     
327. {
     
328.   mSiteLst=new TMemList();
     
329. };
     
330. 
     
331. T_Http::~T_Http()
     
332. {
     
333. TRequest_HTTP * obj;
     
334. 
     
335.   while(mSiteLst->;GoHead())
     
336.   {
     
337.     obj = (TRequest_HTTP * )mSiteLst->;GetPtr();
     
338.     mSiteLst->;Remove(obj);
     
339.     delete obj;
     
340.   };
     
341.   delete mSiteLst;
     
342. };
     
343. 
     
344. /*
     
345. 函数功能：获取1个存储信息的数组编号，如果目前不存在，则把它加进去，当然不应当超过限制
     
346. 传入参数：
     
347. 返回参数：
     
348. */
     
349. TRequest_HTTP * T_Http::GetSite(int socketid)
     
350. {
     
351. TRequest_HTTP * obj;
     
352. 
     
353.   mSiteLst->;GoHead();
     
354.   while(1)
     
355.   {
     
356.     obj = (TRequest_HTTP * )mSiteLst->;GetPtr();
     
357.     if(obj==NULL) break;
     
358.     if(obj->;mClientSocket==socketid)
     
359.       return obj;
     
360.     if(!mSiteLst->;Next())
     
361.       break;
     
362.   };
     
363.   return NULL;
     
364. };
     
365. 
     
366. int T_Http::AddSite(int socketid,char * address)
     
367. {
     
368. TRequest_HTTP * obj;
     
369. 
     
370.   obj=new TRequest_HTTP();
     
371.   obj->;mClientSocket=socketid;
     
372.   strcpy(obj->;mClientIp,address);
     
373.   mSiteLst->;AddTail(obj);
     
374.   return 1;
     
375. };
     
376. 
     
377. /*
     
378. 函数功能：删除一个连接
     
379. 传入参数：
     
380. 返回参数：
     
381. */
     
382. int T_Http::DeleteSite(int socketid)
     
383. {
     
384. TRequest_HTTP * obj;
     
385. 
     
386.   obj=GetSite(socketid);
     
387.   if(obj==NULL)
     
388.     return 0;
     
389.   mSiteLst->;Remove(obj);
     
390.   delete obj;
     
391.   return 1;
     
392. };
     
393. 
     
394. int T_Http::Disconnect_Handle(int sock,char * ip)
     
395. {
     
396.   return DeleteSite(sock);
     
397. };
     
398. 
     
399. int T_Http::DataArrived_Handle(int sock,char * buf,int length)
     
400. {
     
401. TRequest_HTTP * obj;
     
402. 
     
403.   obj=GetSite(sock);
     
404.   if(obj==NULL)
     
405.     return 0;
     
406.   obj->;BrowseDataCome(buf,length);
     
407.   return 1;
     
408. };
     
409. 
     
410. int T_Http::ConnectIn_Handle(int sock,char * ip,int servsocket)
     
411. {
     
412.   return AddSite(sock,ip);
     
413. };
     
414. 
     
415. /*
     
416. 函数功能：提取webserver的配置参数
     
417. 传入参数：
     
418. 返回参数：
     
419.   1：成功
     
420.   0：失败
     
421. 
     
422. [system]
     
423. port = 88
     
424. docpath = doc
     
425. basepath = /bill1/goddess/goddess/http
     
426. tmppath = tmp
     
427. cgipath = cgi
     
428. defaultdoc = index.html
     
429. */
     
430. int T_Http::LoadHttpSet()
     
431. {
     
432.   int   port;
     
433.   TIni  ini;
     
434. 
     
435.   if(!ini.LoadFile("webserver.ini"))
     
436.     return 0;
     
437.   sscanf(ini.GetKey("system","port"),"%d",&port);
     
438.   HttpSet.Port=(short)port;
     
439.   strcpy(HttpSet.DocPath,ini.GetKey("system","docpath"));
     
440.   strcpy(HttpSet.BasePath,ini.GetKey("system","basepath"));
     
441.   strcpy(HttpSet.DefaultDoc,ini.GetKey("system","defaultdoc"));
     
442.   strcpy(HttpSet.TmpPath,ini.GetKey("system","tmppath"));
     
443.   strcpy(HttpSet.CgiPath,ini.GetKey("system","cgipath"));
     
444.   return 1;
     
445. }
     
446. 
     
447. /*
     
448. 函数功能：显示webserver的配置参数
     
449. 传入参数：
     
450. 返回参数：
     
451. */
     
452. void T_Http::ShowHttpSet()
     
453. {
     
454.   printf("PORT: %d\n",HttpSet.Port);
     
455.   printf("DOC PATH:%s\n",HttpSet.DocPath);
     
456.   printf("BASE PATH:%s\n",HttpSet.BasePath);
     
457.   printf("DEFAULT DOC:%s\n",HttpSet.DefaultDoc);
     
458.   printf("TMP PATH:%s\n",HttpSet.TmpPath);
     
459.   printf("CGI PATH:%s\n",HttpSet.CgiPath);
     
460. }
     
461. 
     
462. /*******************************************************************
     
463. *                    下面是TRequest_HTTP类的成员函数
     
464. *******************************************************************/
     
465. /*
     
466. 函数功能：构造函数
     
467. 传入参数：
     
468. 返回参数：
     
469. */
     
470. TRequest_HTTP::TRequest_HTTP()
     
471. {
     
472.   mBytes = 0;
     
473.   mIsFirstLine = 1;
     
474.   mRetHead.SetValidCheck(0);
     
475. }
     
476. 
     
477. /*
     
478. 函数功能：请求信息的处理
     
479.   每一行都已0x0d0x0a结尾，连续的2个0x0d0xa表示客户端请求数据完毕
     
480. 传入参数：
     
481.   line: 到达的请求数据
     
482.   bytes：到达数据的字节数
     
483. 返回参数：
     
484. */
     
485. void TRequest_HTTP::BrowseDataCome(char * line,int bytes)
     
486. {
     
487. int    id;
     
488. 
     
489.   for(id=0;id<bytes;id++)
     
490.   {
     
491.     //凡是0x0d都忽略掉
     
492.     if(line[id]==0x0d)
     
493.       continue;
     
494.     if(mBytes==0)
     
495.     {
     
496.       mLine[mBytes++] = line[id];
     
497.       continue;
     
498.     };
     
499.     //如果是0x0a则需要判断是否是请求结束标志
     
500.     if(line[id]==0x0a)
     
501.     {
     
502.       if(mLine[0]==0x0a)
     
503.       {
     
504.         //连续的2个0x0a,这里已经是最后一行了
     
505.         Process_Request();
     
506.         //处理结束
     
507.         mBytes = 0;
     
508.         mIsFirstLine = 1;
     
509.         return;
     
510.       };
     
511.       //一行结束，进行处理
     
512.       mLine[mBytes] = 0;
     
513.       if(mIsFirstLine)
     
514.       {
     
515.         //第一行中包含了请求类型
     
516.         AnalysisRequestLine(mLine);
     
517.         mIsFirstLine = 0;
     
518.       }
     
519.       else
     
520.       {
     
521.         //后面行中为其它信息
     
522.         AnalysisHeadLine(mLine);
     
523.       };
     
524.       mBytes=0;
     
525.       mLine[mBytes++] = line[id];
     
526.       continue;
     
527.     };
     
528.     if(mLine[0]==0x0a)
     
529.       mBytes=0;
     
530.     mLine[mBytes++] = line[id];
     
531.   };
     
532. }
     
533. 
     
534. /*
     
535. 函数功能：设置客户端的信 息
     
536. 传入参数：
     
537. 返回参数：
     
538. */
     
539. void TRequest_HTTP::SetClientInfo(int socket,char * ip)
     
540. {
     
541.   mClientSocket = socket;
     
542.   strcpy(mClientIp,ip);
     
543. }
     
544. 
     
545. /*
     
546. 函数功能：设置状态码及信息
     
547. 传入参数：
     
548. 返回参数：
     
549. */
     
550. void TRequest_HTTP::SetStatusCode(int code,char * msg)
     
551. {
     
552.   mStatusCode = code;
     
553. }
     
554. 
     
555. /*
     
556. 函数功能：解析URI
     
557. 传入参数：
     
558.   uri: 要解析的文件名
     
559. 返回参数：
     
560. */
     
561. void TRequest_HTTP::AnalysisUri(char * uri)
     
562. {
     
563. char * pos;
     
564. char tmpbuf[512];
     
565. 
     
566.   printf("uri is '%s'\n",uri);
     
567.   //pos=uri;
     
568.   /*
     
569.   pos = strstr(uri,HttpSet.HostName);
     
570.   if(pos==NULL)
     
571.     pos = uri;
     
572.   else
     
573.   {
     
574.     pos += strlen(HttpSet.HostName);
     
575.     sprintf(tmpbuf,"%s/%s",HttpSet.BasePath,pos);
     
576.   };
     
577.   pos = strstr(tmpbuf,HttpSet.CgiPath);
     
578.   if(pos!=NULL)
     
579.   {
     
580.     strcpy(mPathName,HttpSet.CgiPath);
     
581.     strcpy(mFileName,pos+strlen(HttpSet.CgiPath));
     
582.     return;
     
583.   };
     
584.   pos = strstr(tmpbuf,HttpSet.DocPath);
     
585.   if(pos!=NULL)
     
586.   {
     
587.     strcpy(mPathName,HttpSet.DocPath);
     
588.     strcpy(mFileName,pos+strlen(HttpSet.DocPath));
     
589.     return;
     
590.   };
     
591.   */
     
592.   if(*uri=='/')
     
593.   {
     
594.     strcpy(mPathName,HttpSet.DocPath);
     
595.     strcpy(mFileName,uri+1);
     
596.   };
     
597.   if(mFileName[0]==0)
     
598.     strcpy(mFileName,HttpSet.DefaultDoc);
     
599.   printf("path is '%s'\n",mPathName);
     
600.   printf("file is '%s'\n",mFileName);
     
601.   printf("------------------------------------\n");
     
602. }
     
603. 
     
604. /*
     
605. 函数功能：分析每个实体域
     
606. 传入参数：
     
607. 返回参数：
     
608. */
     
609. int TRequest_HTTP::AnalysisHeadLine(char * line)
     
610. {
     
611. char * pos;
     
612. char type[201];
     
613. int id=0;
     
614. 
     
615.   printf("head line: '%s'\n",line);
     
616.   pos = line;
     
617.   while(*pos==' '||*pos==9)
     
618.     pos++;
     
619.   while(*pos!=':'&&*pos!=0&&id<200)
     
620.     type[id++]=*pos++;
     
621.   type[id]=0;
     
622.   while(*pos==':')
     
623.     pos++;
     
624.   while(*pos==' ')
     
625.     pos++;
     
626.   if(GetGen_HeadType(type))
     
627.   {
     
628.     mReqHead.PushPara(type,pos);
     
629.     return 1;
     
630.   };
     
631.   if(GetReq_HeadType(type))
     
632.     mReqHead.PushPara(type,pos);
     
633.   else
     
634.     return 0;
     
635.   return 1;
     
636. }
     
637. 
     
638. /*
     
639. 函数功能：分析请求的信息
     
640. 传入参数：
     
641. 返回参数：
     
642. */
     
643. int TRequest_HTTP::AnalysisRequestLine(char * line)
     
644. {
     
645. char type[120],uri[300],version[100];
     
646. 
     
647.   sscanf(line,"%s %s %s",type,uri,version);
     
648.   // 请求类型
     
649.   if(GetReq_MethodType(type)<0)
     
650.   {
     
651.     SetStatusCode(400,"Bad Request");
     
652.     return 0;
     
653.   };
     
654.   strcpy(mType,type);
     
655.   strcpy(mUri,uri);
     
656.   AnalysisUri(mUri);
     
657.   strcpy(mVersion,version);
     
658.   return 1;
     
659. }
     
660. 
     
661. /*
     
662. 函数功能： 压缩生成返回的头
     
663. 传入参数：
     
664.   size: 返回型参数，用于存放生成的buf的大小
     
665. 返回参数：
     
666.   压缩生成的内存空间指针
     
667. */
     
668. char * TRequest_HTTP::PackRetHead(int * size)
     
669. {
     
670. char * pos=NULL,tmpbuf[300],paraval[300],* end;
     
671. int poolsize,len,id;
     
672. 
     
673.   *size=0;
     
674.   poolsize=2000;
     
675. 
     
676.   pos=(char *)IMem.Malloc(poolsize);
     
677.   end=pos;
     
678. 
     
679.   for(id=0;id<mRetHead.mParaNum;id++)
     
680.   {
     
681.     mRetHead.GetParaValue(id,paraval);
     
682.     if(id==0)
     
683.       sprintf(tmpbuf,"%s%s",mRetHead.GetParaName(id),paraval);
     
684.     else
     
685.       sprintf(tmpbuf,"%s: %s",mRetHead.GetParaName(id),paraval);
     
686.     len = strlen(tmpbuf);
     
687.     printf("len is %d tmp is '%s'\n",len,tmpbuf);
     
688.     if((*size+len+2) >; poolsize)
     
689.     {
     
690.       char * newbuf;
     
691.       newbuf=(char *)IMem.Malloc(poolsize+2000);
     
692.       memcpy(newbuf,pos,poolsize);
     
693.       IMem.Free(pos);
     
694.       pos=newbuf;
     
695. 
     
696.       poolsize+=2000;
     
697.       end = pos+(*size);
     
698.     };
     
699.     *size += (len+2);
     
700.     strcpy(end,tmpbuf);
     
701.     end += len;
     
702.     *end = 0x0d;
     
703.     end ++;
     
704.     *end = 0x0a;
     
705.     end ++;
     
706.   };
     
707.   //最后加上0x0d0x0a表示结束
     
708.   *size += (2);
     
709.   *end = 0x0d;
     
710.   end ++;
     
711.   *end = 0x0a;
     
712.   end ++;
     
713.   return pos;
     
714. }
     
715. 
     
716. /*
     
717. 函数功能：处理客户端 GET 请求的函数
     
718.     需要判断是否调用 CGI 的目录路径
     
719. 传入参数：
     
720. 返回参数：
     
721. */
     
722. void TRequest_HTTP::Process_Get()
     
723. {
     
724. char   fullname[512],cgicmd[512];
     
725. char   type[20];
     
726. char   ext[220],*headpool;
     
727. struct stat statbuf;
     
728. int    size,id;
     
729. FILE * fp;
     
730. #define MAXDATALEN  2038  //最大包长
     
731. int   datalen;
     
732. char  databuf[MAXDATALEN];
     
733. 
     
734.   printf("path is '%s'\n",mPathName);
     
735.   printf("file is '%s'\n",mFileName);
     
736. 
     
737.   #ifndef UNIX_SYS
     
738.   IString.ReplaceStr(mPathName,"/","\\");
     
739.   IString.ReplaceStr(mFileName,"/","\\");
     
740.   #endif
     
741. 
     
742.   #ifdef UNIX_SYS
     
743.   sprintf(fullname,"%s/%s",mPathName,mFileName);
     
744.   #else
     
745.   sprintf(fullname,"%s\\%s",mPathName,mFileName);
     
746.   #endif
     
747. 
     
748.   size=strlen(mFileName);
     
749.   headpool=mFileName;
     
750.   headpool+=(size-1);
     
751.   for(id=size;id>;0;id--)
     
752.   {
     
753.     if(*headpool=='.'||*headpool=='/'||headpool==mFileName)
     
754.       break;
     
755.     headpool--;
     
756.   };
     
757.   if(*headpool=='.')
     
758.     headpool++;
     
759.   strcpy(ext,headpool);
     
760.   if(IsCgiPath(mPathName))
     
761.   {
     
762.     sprintf(cgicmd,"system %s >;%s/%d.html",HttpSet.TmpPath,mClientSocket);
     
763.     system(cgicmd);
     
764.     #ifdef UNIX_SYS
     
765.     sprintf(fullname,"%s/%d.html",HttpSet.TmpPath,mClientSocket);
     
766.     #else
     
767.     sprintf(fullname,"%s\\%d.html",HttpSet.TmpPath,mClientSocket);
     
768.     #endif
     
769.   }
     
770.   else
     
771.     #ifdef UNIX_SYS
     
772.     sprintf(fullname,"%s/%s",mPathName,mFileName);
     
773.     #else
     
774.     sprintf(fullname,"%s\\%s",mPathName,mFileName);
     
775.     #endif
     
776.   if(stat(fullname,&statbuf))
     
777.   {
     
778.     SetStatusCode(404,"Not Found");
     
779.     mRetHead.PushPara("HTTP","/1.0 404 Not Found");
     
780.     return;
     
781.   }
     
782.   mRetHead.PushPara("HTTP","/1.0 200 OK");
     
783.   SetStatusCode(200,"OK");
     
784.   printf("cont leng is %d\n",statbuf.st_size);
     
785.   strcpy(type,GetFile_Type(ext));
     
786.   mRetHead.PushPara("Server","Orient WebServer");
     
787.   mRetHead.PushPara("Connection","keep-alive");
     
788.   mRetHead.PushPara("Content-Type",type);
     
789.   mRetHead.PushPara("Accept-Ranges","bytes");
     
790.   mRetHead.PushPara("Content-Length",statbuf.st_size);
     
791.   headpool=PackRetHead(&size);
     
792.   NetItf.SendData(mClientSocket,headpool,size);
     
793.   IMem.Free(headpool);
     
794.   fp=fopen(fullname,"rb");
     
795.   while((datalen=fread(databuf,1,MAXDATALEN,fp))>;0)
     
796.   {
     
797.     NetItf.SendData(mClientSocket,databuf,datalen);
     
798.     if(datalen<MAXDATALEN)
     
799.     {
     
800.       //所有数据都已经发送完了
     
801.       break;
     
802.     };
     
803.   }
     
804.   fclose(fp);
     
805. }
     
806. 
     
807. /*
     
808. 函数功能：所有请求的处理句柄
     
809.   现在只处理GET请求
     
810. 传入参数：
     
811. 返回参数：
     
812. */
     
813. void TRequest_HTTP::Process_Request()
     
814. {
     
815.   Process_Get();
     
816.   mReqHead.ResetPara();
     
817.   mRetHead.ResetPara();
     
818. }
     
819. 
     
820. #include <asyncapi.h>;
     
821. 
     
822. int SocketDisconnect_Handle_Http(int sock,char * ip)
     
823. {
     
824.   return IHttp.DeleteSite(sock);
     
825. }
     
826. 
     
827. int DataArrived_Handle_Http(int sock,char * buf,int length)
     
828. {
     
829.   return IHttp.DataArrived_Handle(sock,buf,length);
     
830. }
     
831. 
     
832. int SocketConnectIn_Handle_Http(int sock,char * ip,int servsocket)
     
833. {
     
834.   IHttp.AddSite(sock,ip);
     
835.   NetItf.AddClient(sock,ip);
     
836.   NetItf.SetDisconnectHandle(sock,SocketDisconnect_Handle_Http);
     
837.   NetItf.SetDataArriveHandle(sock,DataArrived_Handle_Http);
     
838.   NetItf.SetRecvBufSize(sock,0);
     
839.   return 1;
     
840. }
     
841. 
     
842. void Exit_Handle_Http(int para)
     
843. {
     
844.   exit(0);
     
845. }
     
846. 
     
847. int main_Web(int argc, char **argv)
     
848. {
     
849. int socket;
     
850. 
     
851.   IHttp.LoadHttpSet();
     
852.   IHttp.ShowHttpSet();
     
853.   /*显示版权信息*/
     
854.   printf("*******************************************************************************\n");
     
855.   printf("                       Orient Simple Web Server startup\n");
     
856.   printf("                                 www.onlyit.cn\n");
     
857.   printf("                                  Version 1.0\n");
     
858.   printf("*******************************************************************************\n");
     
859.   socket=INet.Server(HttpSet.Port);
     
860.   if(socket<0)
     
861.   {
     
862.     puts("Unable to create sock for http serv");
     
863.     exit(0);
     
864.   };
     
865.   NetItf.AddServer(socket,"127.0.0.1");
     
866.   NetItf.BeginSocketAsync(socket);
     
867.   NetItf.SetRecvBufSize(socket,16384);
     
868.   NetItf.SetConnectInHandle(socket,SocketConnectIn_Handle_Http);
     
869.   NetItf.SetDisconnectHandle(socket,SocketDisconnect_Handle_Http);
     
870.   NetItf.SetDataArriveHandle(socket,DataArrived_Handle_Http);
     
871.   NetItf.NetEventMgr_Balance();
     
872.   return 1;
     
873. }
     
874. 
     

复制代码

mengwg

从后往前看简单一点。

windflowers1976

google thttpd

镖师甲

楼上是小鱼儿,哈哈.

suowei1979

看看apache源代码