web server code

shihyu

1. #include <stdio.h>
   
2. #include <sys/socket.h>
   
3. #include <netinet/in.h>
   
4. #include <errno.h>
   
5. #include <netdb.h>  
   
6. #include <sys/types.h>   
   
7. #include <stdio.h>   
   
8. #include <errno.h>   
   
9. #include <sys/ioctl.h>   
   
10. #include <net/if.h>   
    
11. #include <netinet/ip.h>   
    
12. #include <netinet/in.h>   
    
13. #include <string.h>   
    
14. #include <arpa/inet.h>   
    
15. #include <netinet/tcp.h>   
    
16. #include <pthread.h>     
    
17. #include <signal.h>   
    
18. #include <fcntl.h>  
    
19. #include <sys/types.h>   
    
20. #include <sys/stat.h>   
    
21. #include <unistd.h>
    
22. #include <glib.h>
    
23. #include <gtk/gtk.h>
    
24. 
    
25. #define SERVER_PORT 80
    
26. #define MAX_BUF 8192
    
27. 
    
28. #define GET_COMMON   0
    
29. #define GET_CGI   1
    
30. #define HEAD   2
    
31. #define POST   3
    
32. #define BAD_REQUEST -1
    
33. 
    
34. int gServerStatus = 0;
    
35. int gIsRun = 0;
    
36. 
    
37. FILE *pfilelog = NULL;
    
38. 
    
39. /* 程序執行流程為基於請求鏈的傳遞，具體流程為通過解析函數，解析本次請求鏈；
    
40.   分析本次請求鏈，調用相關模塊執行，生成響應頭信息，以及定位文件信息
    
41.   發送響應頭信息以及文件，更新日誌記錄
    
42. */
    
43. typedef struct HttpRequest
    
44. {
    
45.         char method[20]; // 請求方法
    
46.         char *path; // 請求路徑及資源名，若為CGI則為請求的可執行程序路徑
    
47.         char *content; //　請求內容，面向POST和GET CGI請求
    
48.         int contentlength; //　請求內容的長度
    
49.         int                        contenttype;        /* 迴響的內容類型: */
    
50.         int                        rangeflag;     /* 以下用於斷點續傳，分別表示斷點起始點，結束點以及總長度*/
    
51.         long                rangestart;
    
52.         long                rangeend;
    
53.         long                rangetotal;       
    
54.         char            prefix[20];
    
55.         int  responsecode; //響應碼
    
56. }HR;
    
57. 
    
58. /*
    
59.   解析請求，　順次解析各行
    
60. */
    
61. FILE* isexistfile(char *filename)
    
62. {
    
63.         FILE *fp = NULL;
    
64.         fp = fopen(filename,"r");
    
65.         return fp;
    
66. }
    
67. 
    
68. int getrequest(char *requestbuf,struct HttpRequest *prequest)
    
69. {
    
70.         char protocol[20];       
    
71.         char path[200];
    
72.         int i = 0;
    
73.         if(sscanf(requestbuf, "%s %s %s", prequest->method, path, protocol)!=3)
    
74.                 return BAD_REQUEST;
    
75.         if(strcmp(prequest->method,"GET") == 0)
    
76.         {
    
77.                 if(strchr(path, '?') == NULL)
    
78.                 {
    
79.                         // 先判斷是否最後一個字符為/,如果為/則，掛加index.htm
    
80.                         if(path[strlen(path)-1] == '/')
    
81.                                 strcat(path,"index.htm");
    
82.                         //在之前添加./web 這是默認目錄
    
83.                         sprintf(prequest->path,"./web%s",path);
    
84.                         // 求後綴信息，若沒有，則置為*
    
85.                         if(sscanf(path, "%s.%s", path, prequest->prefix)!=2)
    
86.                                 strcpy(prequest->prefix,"*");
    
87.                        
    
88.                         printf("GET path:%s\nprefix:%s\n",prequest->path,prequest->prefix);
    
89.                         return GET_COMMON;
    
90.                 }
    
91.                 else
    
92.                 {
    
93.                         prequest->content = (char *)malloc(strlen(prequest->path));
    
94.                         printf("run ?  \n");
    
95.                         sscanf(prequest->path,"%s?%s",prequest->path, prequest->content);
    
96.                         printf("run ?  %s|%s \n",prequest->path, prequest->content);
    
97.                         return GET_CGI;
    
98.                 }       
    
99.         }               
    
100.         else if(strcmp(prequest->method,"POST") == 0)
     
101.         {
     
102.                 return POST;
     
103.         }
     
104.         else if(strcmp(prequest->method,"HEAD") == 0)
     
105.         {
     
106.                 return HEAD;
     
107.         }
     
108.         else if(strcmp(prequest->method,"TRACR") == 0)
     
109.         {
     
110.                 return TRACR;
     
111.         }
     
112.         return -1;
     
113. }
     
114. char* getcontenttype(char *type)
     
115. {
     
116.         // 返回內容type
     
117.         char ContentType[][27] ={
     
118.                         "jpeg", "image/jpeg",
     
119.                         "png", "image/png",
     
120.                         "mpg", "video/mpeg",
     
121.                         "asf", "video/x-ms-asf",
     
122.                         "avi", "video/x-msvideo",
     
123.                         "bmp", "image/bmp",
     
124.                         "doc", "application/msword",
     
125.                         "exe", "application/octet-stream",//14, 15
     
126.                         "rar", "application/octet-stream",
     
127.                         "zip", "application/zip",
     
128.                         "jpg", "image/jpeg",
     
129.                         "gif", "image/gif",
     
130.                         "txt", "text/plain",
     
131.                         "c", "text/plain",
     
132.                         "cpp", "text/plain",
     
133.                         "cxx", "text/plain",
     
134.                         "h", "text/plain",
     
135.                         "ico", "image/x-icon",
     
136.                         "css", "text/css",
     
137.                         "htm", "text/html",
     
138.                         "html", "text/html"
     
139.                         "*", "application/octet-stream"
     
140.         };       
     
141.         int nType = sizeof(ContentType)/27;
     
142.         int i;
     
143.         for(i=0; i<nType; i+=2)
     
144.         {
     
145.                 if(strcmp(ContentType[i], type) == 0)
     
146.                         return ContentType[i+1];
     
147.         }
     
148.     return "application/octet-stream";
     
149. }
     
150. char* getcurrenttime()
     
151. {
     
152. /*        char timebuf[30];
     
153.         struct tm *p;
     
154.         long ltime;
     
155.         time(&ltime);
     
156.         p=localtime(&ltime);
     
157.         strftime(timebuf,25,"%a %d %b %Y %H:%M:%S",p);
     
158.         /*
     
159.         time_t now;
     
160.         struct tm *timenow;
     
161.         char localvalue[30];
     
162.         time(&now);
     
163.         timenow = localtime(&now);
     
164.         sprintf(localvalue,"%s",asctime(&now));
     
165. //        localvalue[strlen(localvalue)-1] = '\0';
     
166.         printf("localtime :%s\n",localvalue);
     
167.         */
     
168.         time_t timep;
     
169.         char localvalue[30];
     
170.         time (&timep);
     
171. 
     
172.         sprintf(localvalue,"%s",asctime(gmtime(&timep)));
     
173.         printf("localtime :%s",localvalue);
     
174.         return localvalue;
     
175. }
     
176. // 構建響應碼，發送響應碼信息
     
177. void responsecode(int s,int code,struct HttpRequest *prequest)
     
178. {
     
179. 
     
180.         char buffer[2048];
     
181.         char contenttype[200];
     
182.         char content[1023];
     
183.        
     
184.         prequest->responsecode = code;
     
185.         // 構建響應報文頭
     
186.         switch(code)
     
187.         {
     
188.         case 200:
     
189.                 sprintf(buffer,
     
190.                         "HTTP/1.1 200 OK\r\n"
     
191.                         "Server: LiuServer/1.0\r\n"
     
192.                         "Date: %s\r\n"
     
193.                         "Content-Type: %s\r\n"
     
194.                         "Accept-Ranges: bytes\r\n"                       
     
195.                         "Content-Length: %d\r\n"
     
196.                         "Connection: close\r\n"
     
197.                         //"\r\n",date,contenttype,prequest->rangetotal);
     
198.                         "\r\n",getcurrenttime(),getcontenttype(prequest->prefix),prequest->rangetotal);
     
199.                 break;
     
200.         case 404:
     
201.                 strcpy(content,"<html><head><title>Object Not Found</title></head><body><h1>Object Not Found</h1>File Not Found.</body></html>");
     
202.                 sprintf(buffer,
     
203.                         "HTTP/1.1 404 Object Not Found\r\n"
     
204.                         "Server: LiuServer/1.0\r\n"
     
205.                         "Date: %s\r\n"                       
     
206.                         "Content-Type: %s\r\n"
     
207.                         "Content-Length: %d\r\n"
     
208.                         "Connection: close\r\n"
     
209.                         "\r\n"
     
210.                         "%s", getcurrenttime(),getcontenttype(prequest->prefix),strlen(content), content);
     
211.                 break;
     
212.         case 505:
     
213.                 break;
     
214.         default:
     
215.                 break;
     
216.         }
     
217.         sendsegment(s,buffer,strlen(buffer));
     
218. }
     
219. void processgetcommon(int s,struct HttpRequest *prequest)
     
220. {
     
221.         //　先判斷文件是否存在
     
222.         FILE *fp = isexistfile(prequest->path);
     
223.         printf("%s\n",prequest->path);
     
224.         struct stat finfo;
     
225.         if(fp == NULL)
     
226.         {
     
227.                 responsecode(s,404,prequest);
     
228.         }
     
229.         else
     
230.         {               
     
231.                 if(prequest->rangeflag == 0)
     
232.                 {                       
     
233.                         stat(prequest->path,&finfo);
     
234.                         prequest->rangetotal = finfo.st_size;
     
235.                 }
     
236.                 responsecode(s,200,prequest);
     
237.                 transferfile(s,fp,prequest->rangeflag,prequest->rangestart,prequest->rangetotal);
     
238.                 fclose(fp);
     
239.         }
     
240. }
     
241. void processgetcgi(int s,struct HttpRequest *prequest)
     
242. {
     
243.         system("hello");
     
244.        
     
245. }
     
246. void processpost(int s,struct HttpRequest *prequest)
     
247. {
     
248. 
     
249. }
     
250. void processhead(int s,struct HttpRequest *prequest)
     
251. {
     
252. 
     
253. }
     
254. // 參數的含義為
     
255. int transferfile(int s,FILE *fp,int type,int rangstart,int totallength)
     
256. {
     
257.         if(type == 1)
     
258.         {
     
259.                 //　為1　則表示當前從指定的位置傳送文件
     
260.                 fseek(fp,rangstart,0);               
     
261.         }
     
262.         int sendnum = 0;
     
263.         int segment = 1024;
     
264.         while(!feof(fp)&&sendnum < totallength)
     
265.         {
     
266.                 char buf[segment];
     
267.                 memset(buf,0,1024);
     
268.                 int i = 0;
     
269.                 while(!feof(fp) && i < segment && sendnum+i < totallength)
     
270.                 {               
     
271.                         buf[i++] = fgetc(fp);                                       
     
272.                 }
     
273.                 if(sendsegment(s,buf,i) == 0)
     
274.                         return 0;
     
275.                 sendnum += i;
     
276.         }
     
277.         return 1;
     
278. }
     
279. int sendsegment(int s, char *buffer,int length)
     
280. {
     
281.         if(length <= 0)
     
282.                 return 0;
     
283.         printf("%s\n",buffer);
     
284.         int result = send(s,buffer,length,0);
     
285.         if(result < 0)
     
286.                 return 0;
     
287.         return 1;
     
288. }
     
289. 
     
290. // 日誌文件採用XML格式存儲
     
291. FILE* openlogfile(FILE *fp)
     
292. {
     
293.         char filename[200];
     
294.         sprintf(filename,"./log/%s.xml",getcurrenttime());
     
295.         fp = fopen(filename,"ab+");
     
296.         if(fp == NULL)
     
297.         {
     
298.                 printf("can't open this file[%s]\n",filename);
     
299.                 return NULL;
     
300.         }
     
301.         fputs("<?xml version=\"1.0\" encoding=\"GB2312\"?>",fp);
     
302.         fputs("<Log>",fp);
     
303.         fflush(fp);
     
304.         return fp;
     
305. }
     
306. void closelogfile(FILE *fp)
     
307. {
     
308.         if(fp == NULL)
     
309.                 return;
     
310.         fputs("</Log>",fp);
     
311.         fclose(fp);
     
312. }
     
313. 
     
314. void insertlognode(FILE *fp,struct HttpRequest *prequest)
     
315. {
     
316.         if(fp == NULL)
     
317.                 return;
     
318.         fputs("<record>",fp);
     
319.         fputs("<method>",fp);
     
320.         fputs(prequest->method,fp);
     
321.         fputs("</method>",fp);
     
322.         fputs("<path>",fp);
     
323.         fputs(prequest->path,fp);
     
324.         fputs("</path>",fp);
     
325.         char reponsecode[100];
     
326.         sprintf(reponsecode,"<reponsecode>%d</reponsecode>",prequest->responsecode);
     
327.         fputs(reponsecode,fp);
     
328.         fputs("</record>",fp);
     
329.         fflush(fp);
     
330. }
     
331. void* processthread(void *para)
     
332. {
     
333.         int clientsocket;
     
334.         char buffer[1024];
     
335.         int iDataNum =0;
     
336.         int recvnum=0;
     
337.         clientsocket = *((int *)para);
     
338.         printf("<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<BEGIN [%d]>>>>>>>>>>>>>>>>>>>>>>>\n",clientsocket);
     
339.         struct HttpRequest httprequest;
     
340.         httprequest.content = NULL;
     
341.         httprequest.path = NULL;
     
342.         httprequest.path = (char *)malloc(1024);
     
343.         httprequest.rangeflag = 0;
     
344.         httprequest.rangestart = 0;
     
345. 
     
346.         while(1)
     
347.         {
     
348.                 iDataNum = recv(clientsocket,buffer+recvnum,sizeof(buffer)-recvnum-1,0);
     
349.                 if(iDataNum <= 0)
     
350.                 {
     
351.                         close(clientsocket);
     
352.                         pthread_exit(NULL);
     
353.                         return 0;
     
354.                 }
     
355.                 recvnum += iDataNum;
     
356.                 buffer[recvnum]='\0';
     
357.                 if(strstr(buffer,"\r\n\r\n")!=NULL || strstr(buffer,"\n\n")!=NULL)
     
358.                         break;
     
359.         }
     
360.         printf("request: %s\n",buffer);
     
361.        
     
362.         //解析請求信息並處理請求信息
     
363.         switch(getrequest(buffer,&httprequest))
     
364.         {
     
365.         case GET_COMMON:
     
366.                 processgetcommon(clientsocket,&httprequest);
     
367.                 break;
     
368.         case GET_CGI:
     
369.                 processgetcgi(clientsocket,&httprequest);
     
370.                 break;
     
371.         case POST:
     
372.                 processpost(clientsocket,&httprequest);
     
373.                 break;
     
374.         case HEAD:
     
375.                 processhead(clientsocket,&httprequest);
     
376.                 break;
     
377.         default:
     
378.                 break;
     
379.         }                       
     
380.         insertlognode(pfilelog,&httprequest);
     
381.         if(httprequest.path != NULL)
     
382.                 free(httprequest.path);
     
383.         if(httprequest.content != NULL)
     
384.                 free(httprequest.content);
     
385.         close(clientsocket);
     
386.         printf("<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<END [%d]>>>>>>>>>>>>>>>>>>>>>>>\n",clientsocket);
     
387.         pthread_exit(NULL);       
     
388. }
     
389. void* server_process(void *p)
     
390. {
     
391.         int serverSocket;
     
392.         struct sockaddr_in server_addr;
     
393.         struct sockaddr_in clientAddr;
     
394.         int addr_len = sizeof(clientAddr);       
     
395. 
     
396.         if((serverSocket = socket(AF_INET,SOCK_STREAM,0)) < 0)
     
397.         {
     
398.                 perror( "error: create server socket!!!");
     
399.                 exit(1);
     
400.         }
     
401. 
     
402.         bzero(&server_addr,sizeof(server_addr));
     
403.         server_addr.sin_family =AF_INET;
     
404.         server_addr.sin_port = htons(SERVER_PORT);
     
405.         server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
     
406.         if(bind(serverSocket,(struct sockaddr *)&server_addr,sizeof(server_addr)) < 0)
     
407.         {
     
408.                 perror("error: bind address !!!!");
     
409.                 exit(1);
     
410.         }
     
411. 
     
412.         if(listen(serverSocket,5)<0)
     
413.         {
     
414.                 perror("error: listen !!!!");
     
415.                 exit(1);
     
416.         }
     
417.         gIsRun = 1;       
     
418.         printf("LiuServer is running.....\n");
     
419. 
     
420.         while(gIsRun)
     
421.         {               
     
422.                 int clientsocket;
     
423.                 clientsocket = accept(serverSocket,(struct sockaddr *)&clientAddr,(socklen_t*)&addr_len);
     
424.                 if(clientsocket < 0)
     
425.                 {
     
426.                         perror("error: accept client socket !!!");
     
427.                         continue;
     
428.                 }
     
429.                 if(gServerStatus == 0)
     
430.                 {
     
431.                         close(clientsocket);
     
432.                 }
     
433.                 else if(gServerStatus == 1)
     
434.                 {
     
435.                         pthread_t threadid;
     
436.                         int temp;
     
437.                         temp = pthread_create(&threadid, NULL, processthread, (void *)&clientsocket);   
     
438.                         /*if(threadid !=0)
     
439.                         {                  
     
440.                                  pthread_join(threadid,NULL);
     
441.                         }*/
     
442.                 }
     
443.         }       
     
444.         close(serverSocket);
     
445. }
     
446. 
     
447. void run_button( GtkWidget *widget,
     
448.                gpointer   data )
     
449. {
     
450.    // g_print ("run was pressed\n");
     
451.         if(gIsRun == 0)
     
452.         {
     
453.                 pthread_t threadid;
     
454.                 int temp;
     
455.                 temp = pthread_create(&threadid, NULL, server_process, NULL);  
     
456.                 gServerStatus = 1;
     
457.         }
     
458.         else
     
459.         {
     
460.                 if(gServerStatus == 0)
     
461.                         gServerStatus = 1;
     
462.                 else
     
463.                 {
     
464.                         printf("is runnning.....\n ");
     
465.                 }
     
466.         }
     
467.         gtk_label_set_text( (GtkLabel*)data,"Server Status: run....");
     
468. }
     
469. void pause_button( GtkWidget *widget,
     
470.                gpointer   data )
     
471. {
     
472.         if(gIsRun == 1)
     
473.         {
     
474.                 if(gServerStatus == 1)
     
475.                 {
     
476.                         gServerStatus = 0;
     
477.                 }
     
478.                 else
     
479.                 {
     
480.                         printf("is pause\n");
     
481.                 }
     
482.                 gtk_label_set_text( (GtkLabel*)data,"Server Status: pause");       
     
483.         }
     
484.         else
     
485.         {
     
486.                 printf("need run....\n");
     
487.         }
     
488.        
     
489. }
     
490. 
     
491. gint close_application( GtkWidget *widget,
     
492.                         GdkEvent  *event,
     
493.                         gpointer   data )
     
494. {
     
495. /*        if(gIsRun == 1)
     
496.         {
     
497.                 gIsRun = 0;               
     
498.                 while(!gIsRun)
     
499.                 {
     
500.                         sleep(1);
     
501.                         printf("waitting for end................\n");
     
502.                 }
     
503.         }
     
504. */
     
505.         closelogfile(pfilelog);
     
506.         gtk_main_quit ();
     
507.         return FALSE;
     
508. }
     
509. 
     
510. int main( int   argc,
     
511.           char *argv[] )
     
512. {
     
513.     GtkWidget *window = NULL;
     
514.     GtkWidget *box1;
     
515.     GtkWidget *box2;
     
516.     GtkWidget *button;
     
517.         GtkWidget *label;
     
518.     GtkWidget *separator;
     
519. 
     
520.        
     
521.   
     
522.     gtk_init (&argc, &argv);   
     
523.       
     
524.     window = gtk_window_new (GTK_WINDOW_TOPLEVEL);
     
525.   
     
526.     g_signal_connect (G_OBJECT (window), "delete_event",
     
527.                       G_CALLBACK (close_application),
     
528.                       NULL);
     
529. 
     
530.     gtk_window_set_title (GTK_WINDOW (window), "LiuServer 1.0");
     
531.     gtk_container_set_border_width (GTK_CONTAINER (window), 20);
     
532. 
     
533.     box1 = gtk_vbox_new (FALSE, 0);
     
534.     gtk_container_add (GTK_CONTAINER (window), box1);
     
535.     gtk_widget_show (box1);
     
536. 
     
537.     box2 = gtk_vbox_new (FALSE, 10);
     
538.     gtk_container_set_border_width (GTK_CONTAINER (box2), 10);
     
539.     gtk_box_pack_start (GTK_BOX (box1), box2, TRUE, TRUE, 0);
     
540.     gtk_widget_show (box2);
     
541.        
     
542.         label = gtk_label_new ("Server Status: stop");
     
543. 
     
544.     button = gtk_button_new_with_label ("Run");
     
545.         g_signal_connect (G_OBJECT (button), "clicked",
     
546.                       G_CALLBACK (run_button), G_OBJECT(label));
     
547. 
     
548.     gtk_box_pack_start (GTK_BOX (box2), button, TRUE, TRUE, 0);
     
549.     gtk_widget_show (button);
     
550. 
     
551.    
     
552.     button = gtk_button_new_with_label ("Pause");
     
553.         g_signal_connect (G_OBJECT (button), "clicked",
     
554.                       G_CALLBACK (pause_button), G_OBJECT(label));
     
555.     gtk_box_pack_start (GTK_BOX (box2), button, TRUE, TRUE, 0);
     
556.     gtk_widget_show (button);
     
557. 
     
558.     button = gtk_button_new_with_label ("Stop");
     
559.     gtk_box_pack_start (GTK_BOX (box2), button, TRUE, TRUE, 0);
     
560.         g_signal_connect_swapped (G_OBJECT (button), "clicked",
     
561.                               G_CALLBACK (close_application),
     
562.                               window);
     
563.     gtk_widget_show (button);
     
564. 
     
565.     separator = gtk_hseparator_new ();
     
566.     gtk_box_pack_start (GTK_BOX (box1), separator, FALSE, TRUE, 0);
     
567.     gtk_widget_show (separator);
     
568. 
     
569.     box2 = gtk_vbox_new (FALSE, 10);
     
570.     gtk_container_set_border_width (GTK_CONTAINER (box2), 10);
     
571.     gtk_box_pack_start (GTK_BOX (box1), box2, FALSE, TRUE, 0);
     
572.     gtk_widget_show (box2);
     
573. 
     
574.    
     
575.    
     
576.     gtk_box_pack_start (GTK_BOX (box2), label, TRUE, TRUE, 0);
     
577.     GTK_WIDGET_SET_FLAGS (button, GTK_CAN_DEFAULT);
     
578.     gtk_widget_grab_default (button);
     
579.     gtk_widget_show (label);
     
580.     gtk_widget_show (window);
     
581.      
     
582.     gtk_main ();
     
583. 
     
584.     return 0;
     
585. }

复制代码

gcc webserver.c -o webserver  -lpthread  `pkg-config --cflags --libs gtk+-2.0`

webserver.c: In function ‘getrequest’:
webserver.c:93: warning: incompatible implicit declaration of built-in function ‘malloc’
webserver.c:110: error: ‘TRACR’ undeclared (first use in this function)
webserver.c:110: error: (Each undeclared identifier is reported only once
webserver.c:110: error: for each function it appears in.)
webserver.c: In function ‘getcurrenttime’:
webserver.c:174: warning: function returns address of local variable
webserver.c: In function ‘processthread’:
webserver.c:342: warning: incompatible implicit declaration of built-in function ‘malloc’
webserver.c:382: warning: incompatible implicit declaration of built-in function ‘free’
webserver.c: In function ‘server_process’:
webserver.c:399: warning: incompatible implicit declaration of built-in function ‘exit’
webserver.c:409: warning: incompatible implicit declaration of built-in function ‘exit’
webserver.c:415: warning: incompatible implicit declaration of built-in function ‘exit’



我是書上代碼 不過他TRACR 怎麼沒undeclared

lenky0401

根据你的POST GET
你是不是也应该定义一个TRACR的宏？

langue

1、TRACR => TRACE
2、#define TRACE 4