网络 http服务器-v1-多线程版本
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了网络 http服务器-v1-多线程版本相关的知识，希望对你有一定的参考价值。
http服务器-v1-多线程版本
一、http协议分析
来源：http://www.cnblogs.com/li0803/archive/2008/11/03/1324746.html
引言
HTTP是一个属于应用层的面向对象的协议，由于其简捷、快速的方式，适用于分布式超媒体信息系统。它于1990年提出，经过几年（http/0.9 http/1.0）的使用与发展，得到不断地完善和扩展。目前在WWW中HTTP/1.1已经广泛使用，而且HTTP-NG(Next Generation of HTTP)的建议已经提出。
HTTP协议的主要特点可概括如下：
1.支持客户/服务器模式。
2.简单快速：客户向服务器请求服务时，只需传送请求方法和路径。请求方法常用的有GET、HEAD、POST。每种方法规定了客户与服务器联系的类型不同。由于HTTP协议简单，使得HTTP服务器的程序规模小，因而通信速度很快。
3.灵活：HTTP允许传输任意类型的数据对象。正在传输的类型由Content-Type加以标记。
4.无连接：无连接的含义是限制每次连接只处理一个请求。服务器处理完客户的请求，并收到客户的应答后，即断开连接。采用这种方式可以节省传输时间。
5.无状态：HTTP协议是无状态协议。无状态是指协议对于事务处理没有记忆能力。缺少状态意味着如果后续处理需要前面的信息，则它必须重传，这样可能导致每次连接传送的数据量增大。另一方面，在服务器不需要先前信息时它的应答就较快。
1.HTTP协议详解之URL篇
http（超文本传输协议）是一个基于请求与响应模式的、无状态的、应用层的协议，常基于TCP的连接方式，HTTP1.1版本中给出一种持续连接的机制，绝大多数的Web开发，都是构建在HTTP协议之上的Web应用。
HTTP URL (URL是一种特殊类型的URI，包含了用于查找某个资源的足够的信息)的格式如下：
http://host[":"port][abs_path]
http表示要通过HTTP协议来定位网络资源；host表示合法的Internet主机域名或者IP地址；port指定一个端口号，为空则使用缺省端口80；abs_path指定请求资源的URI；如果URL中没有给出abs_path，那么当它作为请求URI时，必须以“/”的形式给出，通常这个工作浏览器自动帮我们完成。
eg:
1、输入：www.guet.edu.cn
浏览器自动转换成：http://www.guet.edu.cn/
2、http:192.168.0.116:8080/index.jsp （用到DNS域名解析协议）
2.HTTP协议详解之请求篇
http请求由三部分组成，分别是：请求行、消息报头、请求正文
1、请求行以一个方法符号开头，以空格分开，后面跟着请求的URI和协议的版本，格式如下：Method Request-URI HTTP-Version CRLF
其中 Method表示请求方法；Request-URI是一个统一资源标识符；HTTP-Version表示请求的HTTP协议版本；CRLF表示回车和换行（除了作为结尾的CRLF外，不允许出现单独的CR或LF字符）。
请求方法（所有方法全为大写）有多种，各个方法的解释如下：
GET 请求获取Request-URI所标识的资源
POST 在Request-URI所标识的资源后附加新的数据
HEAD 请求获取由Request-URI所标识的资源的响应消息报头
PUT 请求服务器存储一个资源，并用Request-URI作为其标识
DELETE 请求服务器删除Request-URI所标识的资源
TRACE 请求服务器回送收到的请求信息，主要用于测试或诊断
CONNECT 保留将来使用
OPTIONS 请求查询服务器的性能，或者查询与资源相关的选项和需求
应用举例：
GET方法：在浏览器的地址栏中输入网址的方式访问网页时，浏览器采用GET方法向服务器获取资源，eg:GET /form.html HTTP/1.1 (CRLF)
POST方法要求被请求服务器接受附在请求后面的数据，常用于提交表单。
eg：POST /reg.jsp HTTP/ (CRLF)
Accept:image/gif,image/x-xbit,... (CRLF)
...
HOST:www.guet.edu.cn (CRLF)
Content-Length:22 (CRLF)
Connection:Keep-Alive (CRLF)
Cache-Control:no-cache (CRLF)
(CRLF) //空行 该CRLF表示消息报头已经结束，在此之前为消息报头
user=jeffrey&pwd=1234 //此行以下为提交的数据
HEAD方法与GET方法几乎是一样的，对于HEAD请求的回应部分来说，它的HTTP头部中包含的信息与通过GET请求所得到的信息是相同的。利用这个方法，不必传输整个资源内容，就可以得到Request-URI所标识的资源的信息。该方法常用于测试超链接的有效性，是否可以访问，以及最近是否更新。
2、请求报头后述
3、请求正文(略)
3.HTTP协议详解之响应篇
在接收和解释请求消息后，服务器返回一个HTTP响应消息。
HTTP响应也是由三个部分组成，分别是：状态行、消息报头、响应正文
1、状态行格式如下：
HTTP-Version Status-Code Reason-Phrase CRLF
其中，HTTP-Version表示服务器HTTP协议的版本；Status-Code表示服务器发回的响应状态代码；Reason-Phrase表示状态代码的文本描述。
状态代码有三位数字组成，第一个数字定义了响应的类别，且有五种可能取值：
1xx：指示信息--表示请求已接收，继续处理
2xx：成功--表示请求已被成功接收、理解、接受
3xx：重定向--要完成请求必须进行更进一步的操作
4xx：客户端错误--请求有语法错误或请求无法实现
5xx：服务器端错误--服务器未能实现合法的请求
常见状态代码、状态描述、说明：
200 OK //客户端请求成功
400 Bad Request //客户端请求有语法错误，不能被服务器所理解
401 Unauthorized //请求未经授权，这个状态代码必须和WWW-Authenticate报头域一起使用
403 Forbidden //服务器收到请求，但是拒绝提供服务
404 Not Found //请求资源不存在，eg：输入了错误的URL
500 Internal Server Error //服务器发生不可预期的错误
503 Server Unavailable //服务器当前不能处理客户端的请求，一段时间后可能恢复正常
eg：HTTP/1.1 200 OK （CRLF）
2、响应报头后述
3、响应正文就是服务器返回的资源的内容
4.HTTP协议详解之消息报头篇
HTTP消息由客户端到服务器的请求和服务器到客户端的响应组成。请求消息和响应消息都是由开始行（对于请求消息，开始行就是请求行，对于响应消息，开始行就是状态行），消息报头（可选），空行（只有CRLF的行），消息正文（可选）组成。
HTTP消息报头包括普通报头、请求报头、响应报头、实体报头。
每一个报头域都是由名字+“：”+空格+值 组成，消息报头域的名字是大小写无关的。
1、普通报头
在普通报头中，有少数报头域用于所有的请求和响应消息，但并不用于被传输的实体，只用于传输的消息。
eg：
Cache-Control 用于指定缓存指令，缓存指令是单向的（响应中出现的缓存指令在请求中未必会出现），且是独立的（一个消息的缓存指令不会影响另一个消息处理的缓存机制），HTTP1.0使用的类似的报头域为Pragma。
请求时的缓存指令包括：no-cache（用于指示请求或响应消息不能缓存）、no-store、max-age、max-stale、min-fresh、only-if-cached;
响应时的缓存指令包括：public、private、no-cache、no-store、no-transform、must-revalidate、proxy-revalidate、max-age、s-maxage.
eg：为了指示IE浏览器（客户端）不要缓存页面，服务器端的JSP程序可以编写下： response.sehHeader("Cache-Control","no-cache");
//response.setHeader("Pragma","no-cache");作用相当于上述代码，通常两者//合用
这句代码将在发送的响应消息中设置普通报头域：Cache-Control:no-cache
Date普通报头域表示消息产生的日期和时间
Connection普通报头域允许发送指定连接的选项。例如指定连接是连续，或者指定“close”选项，通知服务器，在响应完成后，关闭连接
2、请求报头
请求报头允许客户端向服务器端传递请求的附加信息以及客户端自身的信息。
常用的请求报头
Accept
Accept请求报头域用于指定客户端接受哪些类型的信息。eg：Accept：image/gif，表明客户端希望接受GIF图象格式的资源；Accept：text/html，表明客户端希望接受html文本。
Accept-Charset
Accept-Charset请求报头域用于指定客户端接受的字符集。eg：Accept-Charset:iso-8859-1,gb2312.如果在请求消息中没有设置这个域，缺省是任何字符集都可以接受。
Accept-Encoding
Accept-Encoding请求报头域类似于Accept，但是它是用于指定可接受的内容编码。eg：Accept-Encoding:gzip.deflate.如果请求消息中没有设置这个域服务器假定客户端对各种内容编码都可以接受。
Accept-Language
Accept-Language请求报头域类似于Accept，但是它是用于指定一种自然语言。eg：Accept-Language:zh-cn.如果请求消息中没有设置这个报头域，服务器假定客户端对各种语言都可以接受。
Authorization
Authorization请求报头域主要用于证明客户端有权查看某个资源。当浏览器访问一个页面时，如果收到服务器的响应代码为401（未授权），可以发送一个包含Authorization请求报头域的请求，要求服务器对其进行验证。
Host（发送请求时，该报头域是必需的）
Host请求报头域主要用于指定被请求资源的Internet主机和端口号，它通常从HTTP URL中提取出来的，eg：
我们在浏览器中输入：http://www.guet.edu.cn/index.html
浏览器发送的请求消息中，就会包含Host请求报头域，如下：
Host：www.guet.edu.cn
此处使用缺省端口号80，若指定了端口号，则变成：Host：www.guet.edu.cn:指定端口号
User-Agent
我们上网登陆论坛的时候，往往会看到一些欢迎信息，其中列出了你的操作系统的名称和版本，你所使用的浏览器的名称和版本，这往往让很多人感到很神奇，实际上，服务器应用程序就是从User-Agent这个请求报头域中获取到这些信息。User-Agent请求报头域允许客户端将它的操作系统、浏览器和其它属性告诉服务器。不过，这个报头域不是必需的，如果我们自己编写一个浏览器，不使用User-Agent请求报头域，那么服务器端就无法得知我们的信息了。
请求报头举例：
GET /form.html HTTP/1.1 (CRLF)
Accept:image/gif,image/x-xbitmap,image/jpeg,application/x-shockwave-flash,application/vnd.ms-excel,application/vnd.ms-powerpoint,application/msword,*/* (CRLF)
Accept-Language:zh-cn (CRLF)
Accept-Encoding:gzip,deflate (CRLF)
If-Modified-Since:Wed,05 Jan 2007 11:21:25 GMT (CRLF)
If-None-Match:W/"80b1a4c018f3c41:8317" (CRLF)
User-Agent:Mozilla/4.0(compatible;MSIE6.0;Windows NT 5.0) (CRLF)
Host:www.guet.edu.cn (CRLF)
Connection:Keep-Alive (CRLF)
(CRLF)（空行）
3、响应报头
响应报头允许服务器传递不能放在状态行中的附加响应信息，以及关于服务器的信息和对Request-URI所标识的资源进行下一步访问的信息。
常用的响应报头
Location
Location响应报头域用于重定向接受者到一个新的位置。Location响应报头域常用在更换域名的时候。
Server
Server响应报头域包含了服务器用来处理请求的软件信息。与User-Agent请求报头域是相对应的。下面是
Server响应报头域的一个例子：
Server：Apache-Coyote/1.1
WWW-Authenticate
WWW-Authenticate响应报头域必须被包含在401（未授权的）响应消息中，客户端收到401响应消息时候，并发送Authorization报头域请求服务器对其进行验证时，服务端响应报头就包含该报头域。
eg：WWW-Authenticate:Basic realm="Basic Auth Test!" //可以看出服务器对请求资源采用的是基本验证机制。
4、实体报头
请求和响应消息都可以传送一个实体。一个实体由实体报头域和实体正文组成，但并不是说实体报头域和实体正文要在一起发送，可以只发送实体报头域。实体报头定义了关于实体正文（eg：有无实体正文）和请求所标识的资源的元信息。
常用的实体报头
Content-Encoding
Content-Encoding实体报头域被用作媒体类型的修饰符，它的值指示了已经被应用到实体正文的附加内容的编码，因而要获得Content-Type报头域中所引用的媒体类型，必须采用相应的解码机制。Content-Encoding这样用于记录文档的压缩方法，eg：Content-Encoding：gzip
Content-Language
Content-Language实体报头域描述了资源所用的自然语言。没有设置该域则认为实体内容将提供给所有的语言阅读者。
eg：Content-Language:da
Content-Length
Content-Length实体报头域用于指明实体正文的长度，以字节方式存储的十进制数字来表示。
Content-Type
Content-Type实体报头域用语指明发送给接收者的实体正文的媒体类型。
eg：Content-Type:text/html;charset=ISO-8859-1
Content-Type:text/html;charset=GB2312
Last-Modified
Last-Modified实体报头域用于指示资源的最后修改日期和时间。
Expires
Expires实体报头域给出响应过期的日期和时间。为了让代理服务器或浏览器在一段时间以后更新缓存中(再次访问曾访问过的页面时，直接从缓存中加载，缩短响应时间和降低服务器负载)的页面，我们可以使用Expires实体报头域指定页面过期的时间。
eg：Expires：Thu，15 Sep 2006 16:23:12 GMT
HTTP1.1的客户端和缓存必须将其他非法的日期格式（包括0）看作已经过期。
eg：为了让浏览器不要缓存页面，我们也可以利用Expires实体报头域，设置为0，jsp中程序如下：
response.setDateHeader("Expires","0");
二、http服务器的实现逻辑
1.实现基于 tcp 协议的服务器端（创建监听套接字 bind； listen ）
注：http协议属于应用层协议，其功能的实现依赖于下层结构提供的服务。它的无连接特性决定了它的下层必须保证 单次交互的可靠性（否则 本来就一次性，还不知道可靠不可靠（获取的数据是否正确有序），谁用？）。而tcp协议刚好提供了这种可靠性。但是tcp协议是面向连接的，因此 ，在后续的逻辑中，在一次交互完成后，需要关闭连接。
2.主线程循环 accept 建立连接，成功后创建子线程处理后续逻辑。主线程继续accept
3.子线程 处理：
1>获取请求行 分别 截取 method url version ，在此要通过判断是不是\r\n 表示一行结尾。用到recv函数中的MSG_PEEK方法
2>对正确的 请求行 进行处理
CGI：绝大多数的CGI程序被用来解释处理来自表单的输入信息，并在服务器产生相应的处理，或将相应的信息反馈给浏览器。CGI程序使网页具有交互功能。
（1）get方法无参数（非 CGI） 回复 请求资源。（在此用sendfile函数提高效率）
（2）get方法有参数（url中含‘？’之后为参数（从含表单的网页页面获取）），先将参数作为环境变量。fork子进程（子进程共享父进程的环境变量）。子进程 程序 替换 为 真实的 可执行程序 （‘？’之前的url） 对参数做处理得到执行结果，通过管道 传给 父进程，父进程对数据做差错检测后，发送给客户端。
注：将参数作为环境变量 使用：
putenv（char*）；上传环境变量
getenv （char*）；获取环境变量
（3）post方法 一定含有参数。参数的有效长度包含在消息报头中
例：Content-Length:22 (CRLF)
将其作为换境变量，fork子进程。子进程exec 为 请求的可执行程序，通过管道 在sock中的请求正文中读取给定数量的字符，并处理。将处理结果通过管道发送给父进程，父进程 检测后 发送给客户端
CGI处理逻辑图：
3> 清理sock的缓存。并清理子线程的资源，关闭sock。子线程退出。
三、关键 程序实例
//主程序，包含tcp 服务端的bind listen
#include <stdio.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <pthread.h>
#include "httpd.h"
#include <netdb.h>
#include <sys/utsname.h>
#include <net/if.h>
#include <sys/ioctl.h>
#define ERRORIP -1
int startup(char* ip,int port)
{
// printf("%s %d\n",ip,port);
int sock=socket(AF_INET,SOCK_STREAM,0);
struct sockaddr_in server;
server.sin_family=AF_INET;
server.sin_addr.s_addr=inet_addr(ip);
server.sin_port=htons(port);
int flag=1;
if( setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag)) == -1)
{
perror("setsockopt");
exit(1);
}
if(bind(sock,(struct sockaddr *)&server,sizeof(server))<0){
perror("bind");
exit(-2);
}
if(listen(sock,5)<0){
perror("listen");
exit(-3);
}
//printf("%d\n",sock);
return sock;
}
void usage(char* arg)
{
printf("usage %s [ip] [port]\n",arg);
}
void http_start(int listen_sock){
int done=0;
int client_sock=-1;
// printf("http_start\n");
struct sockaddr_in client;
socklen_t len=sizeof(client);
while(!done){
// printf("循环\n");
if((client_sock=accept(listen_sock,(struct sockaddr *)&client,&len))<0){
printf("connect error!\n");
//做访问记录 存入数据库
continue;
}
pthread_t tid;
// printf("client:%d\n",client_sock);
int ret=pthread_create(&tid,NULL,http_action,(void*)client_sock);
if(ret!=0){
// printf("create thread error!\n");
printf("%s\n",strerror(errno));
continue;
}
else{
pthread_detach(tid);
}
}
}
int main(int argc,char* argv[]){
if(argc!=3){
usage(argv[0]);
exit(-1);
}
int listen_sock=0;
char* ip=NULL;
int port=atoi(argv[2]);
if(strcmp(argv[1],"any")==0){
int sfd, intr;
struct ifreq buf[16];
struct ifconf ifc;
sfd = socket (AF_INET, SOCK_DGRAM, 0);
if (sfd < 0)
return ERRORIP;
ifc.ifc_len = sizeof(buf);
ifc.ifc_buf = (caddr_t)buf;
if (ioctl(sfd, SIOCGIFCONF, (char *)&ifc))
return ERRORIP;
intr = ifc.ifc_len / sizeof(struct ifreq);
while (intr-- > 0 && ioctl(sfd, SIOCGIFADDR, (char *)&buf[intr]));
close(sfd);
ip= inet_ntoa(((struct sockaddr_in*)(&buf[intr].ifr_addr))-> sin_addr);
printf("%s\n",ip);
listen_sock=startup(ip,port);
}
else
listen_sock=startup(argv[1],port);
// printf("%d\n",listen_sock);
http_start(listen_sock);
close(listen_sock);
return 0;
}
//httpd.h
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <pthread.h>
#include <sys/stat.h>
#define _SIZE_ 1024
char* get_text(int fd,char* buf);
void error_all(int fd,int err,char* reason);
void cgi_action(int fd,char* method,char* url,char* parameter);
char* get_length(int fd,char * content_length);
void* http_action(void* client_sock);
void echo_error(int fd,int _errno);
void echo_html(int fd,const char* url,int size );
#endif
//httpd.c 包括后续非 exec 逻辑
#include "httpd.h"
#define DEFAULT "src_html/default.html"
#define IMG "src_html"
#define CGI "src_cgi"
int times=0;
void echo_error(int fd,int _errno)
{
switch(_errno){
case 400://Bad Request //客户端请求有语法错误，不能被服务器所理解
break;
case 404:////请求资源不存在，eg：输入了错误的URL
//printf("*******404\n");
error_all(fd,404,"NOT_FIND!!");
break;
case 401://请求未经授权，这个状态代码必须和WWW-Authenticate报头域一起使用
break;
case 403://服务器收到请求，但是拒绝提供服务
break;
case 500:// Internal Server Error //服务器发生不可预期的错误
break;
case 503://Server Unavailable //服务器当前不能处理客户端的请求，一段时间后可能恢复正常
break;
default:
break;
}
close(fd);
}
void error_all(int fd,int err,char* reason)
{
char buf[_SIZE_]="";
char error[_SIZE_]="";
sprintf(buf,"HTTP/1.1 %d %s\r\n\r\n",err,reason);
sprintf(error," %d %s\n",err,reason);
// printf("err buf:%s\n",buf);
write(fd,buf,strlen(buf));
write(fd,"<html>\n",strlen("<html>\n"));
write(fd,"<head>\n",strlen("<head>\n"));
write(fd,"<h1> HELLO PPH!!!</h1>\n",strlen("<h1> HELLO PPH!!!</h1>\n"));
write(fd,"<h2>\n",strlen("<h2>\n"));
write(fd,error,strlen(error));
write(fd,"</h2>\n",strlen("</h2>\n"));
write(fd,"</head>\n",strlen("</head>\n"));
write(fd,"</html>\n",strlen("</html>\n"));
// echo_html(fd,"src_html/1.html",102400000);
}
int get_line(int sock_fd,char * line){
int index=0;
ssize_t size=1;
char ch=0;
while(ch!=‘\n‘){
if((size=read(sock_fd,&ch,1))<0){
perror("read_get_line");
return -1;
}
if(ch==‘\r‘){
char tmp=0;
if(recv(sock_fd,&tmp,1,MSG_PEEK)>0){
if(tmp==‘\n‘){
line[index++]=tmp;
read(sock_fd,&ch,1);
continue;
}
}
}
if(index==1024){
line[1023]=0;
return -1;
}
line[index++]=ch;
}
line[index]=0;
printf("line :%d,%d,%d,%s",index,strlen(line),line[0],line);
if(strcmp(line,"\n")==0){
// printf("*****************");
return 0;
}
return 1;
}
void echo_html(int fd,const char* url,int fd_size ){
char buf[_SIZE_]="HTTP/1.1 200 OK\r\n\r\n";
if(url==NULL){
int rfd=-1;
off_t set=0;
ssize_t size=0;
if((rfd=open(DEFAULT, O_RDONLY))<0){
echo_error(fd,500);
exit(0);
}
// printf("%d %d\n",fd,rfd);
write(fd,buf,strlen(buf));
size=sendfile(fd,rfd,&set,fd_size);
if(size<0){
close(rfd);
printf("senfile error!\n");
return;
}
printf("size: %d\n",size);
close(rfd);
}else{
int rfd=-1;
off_t set=0;
ssize_t size=0;
//printf("url:%s\n",url);
if((rfd=open(url, O_RDONLY))<0){
echo_error(fd,500);
// exit(0);
}
write(fd,buf,strlen(buf));
size=sendfile(fd,rfd,NULL,fd_size);
if(size<0){
printf("senfile error!\n");
return;
}
// printf("size: %d\n",size);
close(rfd);
return;
}
}
//清除client_sock
int clear_buf(int fd)
{
char buf[_SIZE_]="";
ssize_t size=1;
size=read(fd,buf,_SIZE_);
if(size<0){
perror("clear_buf_read");
return -1;
}
return 0;
}
//获取post正文 参数
char* get_length(int fd,char* content_length)
{
int size=1;
int tag=0;
int index=0;
while(size!=0){//通过持续读取一行 直到读到空行结束
size=get_line(fd,content_length);
if(strncasecmp(content_length,"content-length: ",16)==0){
break;
}
if(size==-1){
printf("get line出错\n");
return NULL;
}
}
content_length[strlen(content_length)-1]=0;
strcpy(content_length,content_length+16);
printf("con end: %s\n",content_length);
return content_length;
}
void cgi_action(int fd,char* method,char* url ,char* parameter)
{
char env[20]="METHOD=";
char par[_SIZE_]="PARAMETER=";
int pwrite[2];
if((pipe(pwrite)<0)){
perror("pipe");
return;
}
strcat(env,method);
strcat(par,parameter);
printf(" act url:%s\n",url);
printf("parameter:%s\n",par);
if(putenv(env)<0){
perror("putenv");
return;
}
if(putenv(par)<0){
perror("putenv par");
return;
}
// printf("fork qian\n");
pid_t id=fork();
if(id<0){
perror("fork");
return;
}
else if(id==0){//子进程
close(pwrite[0]);
//printf("child\n");
if(dup2(pwrite[1],1)<0){
perror("dup2.1");
return;
}
if(dup2(fd,0)<0){
perror("dup2.2");
return;
}
if(execl(url,NULL)<0){
perror("execl");
printf("exit url:\n",url);
exit(-2);
}
}
else{//父进程
printf("father start\n");
close(pwrite[1]);
char buf[_SIZE_]="";
int count=0;
int i=0;
ssize_t size=1;
while(size>0){
size=read(pwrite[0],buf,_SIZE_);
if(size<0){
echo_error(fd,500);
break;
}
if(size==0)
break;
write(fd,buf,strlen(buf));
printf("if end?\n");
}
waitpid(0,NULL,0);
close(pwrite[0]);
}
}
void* http_action(void * client_sock){
int fd=(int)client_sock;
struct stat stat_buf;
char line[_SIZE_];
char* method=NULL;
char* version=NULL;
char* url=NULL;
char* parameter=NULL;//get方法 参数
char text[_SIZE_]="";
int cgi=0;
if(get_line(fd,line)==-1){
printf("this is a cache requset , so can‘t process!\n");
return NULL;
}
int index=strlen(line)-1;
//printf("%d \n",index);
//GET / HTTP/1.1
printf("%d\n index ",index);
while(index>0){//提取method url
if(line[index]==‘ ‘&&version==NULL){
version=((char*)line)+index+1;
line[index]=0;
}
if(line[index]==‘ ‘&&url==NULL){
url=line+index+1;
line[index]=0;
}
--index;
}
method=line;
char real_url[128]=CGI;
//判断请求方法
if(strcasecmp("POST",method)==0){
printf("real_url :%s\n",real_url);
strcat(real_url,url);
printf("start:%s %s %s",method,url ,version);
get_length(fd,text);
cgi_action(fd,method,real_url,text);
printf("fork ...end!\n");
}
else if(strcasecmp("GET",method)==0){
index=0;
while(url[index]){
if(url[index]==‘?‘){
cgi=1;
parameter=url+index+1;
url[index]=0;
printf(" get url:%s\n",url);
break;
}
++index;
}
if(cgi==1){
//cgi;
strcat(real_url,url);
printf("start:%s %s %s",method,url ,version);
cgi_action(fd,method,real_url,parameter);
printf("ret cgi\n");
}
else{
if(strcmp("/",url)==0){
if(stat(DEFAULT, &stat_buf)<0){
echo_error(fd,500);
close(fd);
return ;
}
echo_html(fd, NULL,stat_buf.st_size);
}
else{
char real_url[128]="src_html";
strcat(real_url,url);
printf("real_url :%s\n",real_url);
if(stat(real_url, &stat_buf)<0){
echo_error(fd,404);
//printf("times:%d end!\n",times++);
//close(fd);
//return;
}
else{
printf("fd以上是关于网络 http服务器-v1-多线程版本的主要内容，如果未能解决你的问题，请参考以下文章