http请求get

创建epoll树得到树根描述符epfd——epoll_create()

将监听文件描述符lfd上树——epoll_ctr(epfd,epoll_CTL_ADD…)\

while(1)

SIG_IGN;sigemptyset(act.sa_mask);act.sa_flags

0;sigaction(SIGPIPE,

webpath);chdir(path);//创建socket--设置端口复用---bindint

lfd

epoll_create(1024);if(epfd0){perror(epoll_create

epoll_event

events[1024];while(1){//等待事件发生nready

epoll_wait(epfd,

-1);if(nready0){if(errnoEINTR){continue;}break;}for(i0;

inready;

events[i].data.fd;//有客户端连接请求if(sockfdlfd){//接受新的客户端连接cfd

Accept(lfd,

{//有客户端数据发来http_request(sockfd,

epfd);}

fileType);if(len0){sprintf(bufstrlen(buf),

len);}strcat(buf,

sizeof(buf));if(n0){break;}else

{Write(cfd,

sizeof(buf));if(n0){//printf(read

error

n);//关闭连接close(cfd);//将文件描述符从epoll树上删除epoll_ctl(epfd,

EPOLL_CTL_DEL,

fileName;if(strlen(fileName)1){strcpy(pFile,

./);}else

fileName1;}//转换汉字编码strdecode(pFile,

pFile);//循环读取完剩余的数据,避免产生粘包while((nReadline(cfd,

buf,

sizeof(buf)))0);//判断文件是否存在struct

stat

exist\n);//发送头部信息send_header(cfd,

404,

//若文件存在{//判断文件类型//普通文件if(S_ISREG(st.st_mode)){printf(file

exist\n);//发送头部信息send_header(cfd,

200,

st.st_size);//发送文件内容send_file(cfd,

pFile);}//文件\n);char

buffer[1024];//发送头部信息send_header(cfd,

200,

0){perror(scandir);close(cfd);epoll_ctl(epfd,

EPOLL_CTL_DEL,

namelist[num]-d_name);memset(buffer,

0x00,

sizeof(buffer));if(namelist[num]-d_typeDT_DIR){sprintf(buffer,

lia

namelist[num]-d_name);}else{sprintf(buffer,

lia

namelist[num]-d_name);}free(namelist[num]);Write(cfd,

buffer,

strlen(buffer));}free(namelist);}//发送html尾部sleep(10);send_file(cfd,

html/dir_tail.html);

buf[4096]{0};sprintf(buf,HTTP/1.1

%s\r\n,op,msg);sprintf(buf,%sContent-Type:

%s\r\n,buf,filetype);if(filesize

0){sprintf(buf,%sContent-Length:%ld\r\n,buf,filesize);}strcat(buf,\r\n);bufferevent_write(bev,buf,strlen(buf));return

int

){bufferevent_write(bev,buf,ret);}close(fd);return

int

{//需要拼出来一个html页面发送给客户端copy_file(bev,_DIR_PREFIX_FILE_);//send

dir

sb;stat(dent-d_name,sb);if(dent-d_type

DT_DIR){//目录文件

hrefdirname/dirname/apsize/pptime/p/brmemset(bufline,0x00,sizeof(bufline));sprintf(bufline,lia

href%s/%32s/a

%8ld/li,dent-d_name,dent-d_name,sb.st_size);bufferevent_write(bev,bufline,strlen(bufline));}else

if(dent-d_type

直接显示列表即可memset(bufline,0x00,sizeof(bufline));sprintf(bufline,lia

href%s%32s/a

%8ld/li,dent-d_name,dent-d_name,sb.st_size);bufferevent_write(bev,bufline,strlen(bufline));}}closedir(dir);copy_file(bev,_DIR_TAIL_FILE_);//bufferevent_free(bev);return

int

path);//将中文问题转码成utf-8格式的字符串char

*strPath

FOUND,get_mime_type(error.html),-1);copy_file(bev,error.html);return

-1;}if(S_ISDIR(sb.st_mode)){//处理目录copy_header(bev,200,OK,get_mime_type(ww.html),sb.st_size);send_dir(bev,strPath);}if(S_ISREG(sb.st_mode)){//处理文件//写头copy_header(bev,200,OK,get_mime_type(strPath),sb.st_size);//写文件内容copy_file(bev,strPath);}return

}void

method[10],path[256],protocol[10];int

ret

\r\n],method,path,protocol);if(strcasecmp(method,get)

bufline[256];write(STDOUT_FILENO,buf,ret);//确保数据读完while(

(ret

0){write(STDOUT_FILENO,bufline,ret);}http_request(bev,path);//处理请求}}

void

BEV_EVENT_EOF){//客户端关闭printf(client

closed\n);bufferevent_free(bev);}else

if(what

closed\n);bufferevent_free(bev);}else

if(what

BEV_EVENT_CONNECTED){//连接成功printf(client

connect

BEV_OPT_CLOSE_ON_FREE);bufferevent_setcb(bev,read_cb,NULL,bevent_cb,base);//设置回调bufferevent_enable(bev,EV_READ|EV_WRITE);//启用读和写

}int

{0};sprintf(workdir,_WORK_DIR_,getenv(HOME));//HOME/home/itheima

event_base

htons(9999);serv.sin_addr.s_addr

evconnlistener

evconnlistener_new_bind(base,listen_cb,

base,

LEV_OPT_CLOSE_ON_FREE|LEV_OPT_REUSEABLE,

-1,(struct

sizeof(serv));//连接监听器event_base_dispatch(base);//循环event_base_free(base);

//释放根节点evconnlistener_free(listener);//释放链接监听器return