在学习Linux高并发web服务器开发总结了笔记,并分享出来。有问题请及时联系博主:Alliswell_WP,转载请注明出处。
11_服务器开发-第03天(web服务器 - 3)
目录:
一、学习目标
二、 复习
三、strftime函数
四、libevent实现httpserver
五、线程池
1、线程池的原理
2、线程池各个函数分析
附—整体代码
一、学习目标
1、libevent实现httpserver
2、线程池
二、 复习
1、epoll服务器端代码
三、strftime函数
》使用:
char buf[1024];
strftime(buf, sizeof(buf), "%Y %b %d %H %M %S", st.st_mtime);//把st.st_mtime按双引号中格式 格式化到buf中。
》类似于QT中(QDateTime、QTime、QDate):如调用QDateTime后,然后toString("yy MM dd")把QDatetime转为特定格式
如获取本地时间:
QDateTime d(QDateTime::currentDateTime());
qDebug()<<d.toString("yy.MM.dd") ;
四、libevent实现httpserver
》技巧:在vim中点击“F4”查看所有函数,在右侧垂直分屏显示,点击“Ctrl+w+w”切换分屏到右侧函数。
>main.c
![](https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif)
#include <stdio.h> #include <unistd.h> #include <arpa/inet.h> #include <stdlib.h> #include <string.h> #include <signal.h> #include <event2/bufferevent.h> #include <event2/listener.h> #include <event2/event.h> #include "libevent_http.h" int main(int argc, char **argv) { if(argc < 3) { printf("./event_http port path "); return -1; } if(chdir(argv[2]) < 0) { printf("dir is not exists: %s ", argv[2]); perror("chdir err:"); return -1; } struct event_base *base; struct evconnlistener *listener; struct event *signal_event; struct sockaddr_in sin; base = event_base_new();//创建事件处理框架 if (!base) { fprintf(stderr, "Could not initialize libevent! "); return 1; } memset(&sin, 0, sizeof(sin)); sin.sin_family = AF_INET; sin.sin_port = htons(atoi(argv[1])); //服务器端创建2个套接字 // 创建监听的套接字,绑定,监听,接受连接请求 listener = evconnlistener_new_bind(base, listener_cb, (void *)base, LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE, -1, (struct sockaddr*)&sin, sizeof(sin)); if (!listener) { fprintf(stderr, "Could not create a listener! "); return 1; } // 创建信号事件, 捕捉并处理 signal_event = evsignal_new(base, SIGINT, signal_cb, (void *)base); if (!signal_event || event_add(signal_event, NULL)<0) { fprintf(stderr, "Could not create/add a signal event! "); return 1; } // 事件循环 event_base_dispatch(base); evconnlistener_free(listener); event_free(signal_event); event_base_free(base); printf("done "); return 0; }
>libevent_http.h
![](https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif)
#ifndef _LIBEVENT_HTTP_H #define _LIBEVENT_HTTP_H #include <event2/event.h> void conn_eventcb(struct bufferevent *bev, short events, void *user_data); void conn_readcb(struct bufferevent *bev, void *user_data); const char *get_file_type(char *name); int hexit(char c); void listener_cb(struct evconnlistener *listener, evutil_socket_t fd, struct sockaddr *sa, int socklen, void *user_data); int response_http(struct bufferevent *bev, const char *method, char *path); int send_dir(struct bufferevent *bev,const char *dirname); int send_error(struct bufferevent *bev); int send_file_to_http(const char *filename, struct bufferevent *bev); int send_header(struct bufferevent *bev, int no, const char* desp, const char *type, long len); void signal_cb(evutil_socket_t sig, short events, void *user_data); void strdecode(char *to, char *from); void strencode(char* to, size_t tosize, const char* from); #endif
>libevent_http.c
![](https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif)
#include <stdio.h> #include <unistd.h> #include <stdlib.h> #include <fcntl.h> #include <sys/types.h> #include <sys/socket.h> #include <arpa/inet.h> #include <sys/stat.h> #include <string.h> #include <dirent.h> #include <time.h> #include <signal.h> #include <ctype.h> #include <errno.h> #include <event2/bufferevent.h> #include <event2/buffer.h> #include <event2/listener.h> #include "libevent_http.h" #define _HTTP_CLOSE_ "Connection: close " int response_http(struct bufferevent *bev, const char *method, char *path) { if(strcasecmp("GET", method) == 0){ //get method ... strdecode(path, path); char *pf = &path[1]; if(strcmp(path, "/") == 0 || strcmp(path, "/.") == 0) { pf="./"; } printf("***** http Request Resource Path = %s, pf = %s ", path, pf); struct stat sb; if(stat(pf,&sb) < 0) { perror("open file err:"); send_error(bev); return -1; } if(S_ISDIR(sb.st_mode))//处理目录 { //应该显示目录列表 send_header(bev, 200, "OK", get_file_type(".html"), -1); send_dir(bev, pf); } else //处理文件 { send_header(bev, 200, "OK", get_file_type(pf), sb.st_size); send_file_to_http(pf, bev); } } return 0; } /* *charset=iso-8859-1 西欧的编码,说明网站采用的编码是英文; *charset=gb2312 说明网站采用的编码是简体中文; *charset=utf-8 代表世界通用的语言编码; * 可以用到中文、韩文、日文等世界上所有语言编码上 *charset=euc-kr 说明网站采用的编码是韩文; *charset=big5 说明网站采用的编码是繁体中文; * *以下是依据传递进来的文件名,使用后缀判断是何种文件类型 *将对应的文件类型按照http定义的关键字发送回去 */ const char *get_file_type(char *name) { char* dot; dot = strrchr(name, '.'); //自右向左查找‘.’字符;如不存在返回NULL if (dot == (char*)0) return "text/plain; charset=utf-8"; if (strcmp(dot, ".html") == 0 || strcmp(dot, ".htm") == 0) return "text/html; charset=utf-8"; if (strcmp(dot, ".jpg") == 0 || strcmp(dot, ".jpeg") == 0) return "image/jpeg"; if (strcmp(dot, ".gif") == 0) return "image/gif"; if (strcmp(dot, ".png") == 0) return "image/png"; if (strcmp(dot, ".css") == 0) return "text/css"; if (strcmp(dot, ".au") == 0) return "audio/basic"; if (strcmp( dot, ".wav") == 0) return "audio/wav"; if (strcmp(dot, ".avi") == 0) return "video/x-msvideo"; if (strcmp(dot, ".mov") == 0 || strcmp(dot, ".qt") == 0) return "video/quicktime"; if (strcmp(dot, ".mpeg") == 0 || strcmp(dot, ".mpe") == 0) return "video/mpeg"; if (strcmp(dot, ".vrml") == 0 || strcmp(dot, ".wrl") == 0) return "model/vrml"; if (strcmp(dot, ".midi") == 0 || strcmp(dot, ".mid") == 0) return "audio/midi"; if (strcmp(dot, ".mp3") == 0) return "audio/mpeg"; if (strcmp(dot, ".ogg") == 0) return "application/ogg"; if (strcmp(dot, ".pac") == 0) return "application/x-ns-proxy-autoconfig"; return "text/plain; charset=utf-8"; } int send_file_to_http(const char *filename, struct bufferevent *bev) { int fd = open(filename, O_RDONLY); int ret = 0; char buf[4096] = {0}; while( (ret = read(fd, buf, sizeof(buf)) ) ) { bufferevent_write(bev, buf, ret); memset(buf, 0, ret); } close(fd); return 0; } int send_header(struct bufferevent *bev, int no, const char* desp, const char *type, long len) { char buf[256]={0}; sprintf(buf, "HTTP/1.1 %d %s ", no, desp); //HTTP/1.1 200 OK bufferevent_write(bev, buf, strlen(buf)); // 文件类型 sprintf(buf, "Content-Type:%s ", type); bufferevent_write(bev, buf, strlen(buf)); // 文件大小 sprintf(buf, "Content-Length:%ld ", len); bufferevent_write(bev, buf, strlen(buf)); // Connection: close bufferevent_write(bev, _HTTP_CLOSE_, strlen(_HTTP_CLOSE_)); //send bufferevent_write(bev, " ", 2); return 0; } int send_error(struct bufferevent *bev) { send_header(bev,404, "File Not Found", "text/html", -1); send_file_to_http("404.html", bev); return 0; } int send_dir(struct bufferevent *bev,const char *dirname) { char encoded_name[1024]; char path[1024]; char timestr[64]; struct stat sb; struct dirent **dirinfo; char buf[4096] = {0}; sprintf(buf, "<html><head><meta charset="utf-8"><title>%s</title></head>", dirname); sprintf(buf+strlen(buf), "<body><h1>当前目录:%s</h1><table>", dirname); //添加目录内容 int num = scandir(dirname, &dirinfo, NULL, alphasort); for(int i=0; i<num; ++i) { // 编码 strencode(encoded_name, sizeof(encoded_name), dirinfo[i]->d_name); sprintf(path, "%s%s", dirname, dirinfo[i]->d_name); printf("############# path = %s ", path); if (lstat(path, &sb) < 0) { sprintf(buf+strlen(buf), "<tr><td><a href="%s">%s</a></td></tr> ", encoded_name, dirinfo[i]->d_name); } else { strftime(timestr, sizeof(timestr), " %d %b %Y %H:%M", localtime(&sb.st_mtime)); if(S_ISDIR(sb.st_mode)) { sprintf(buf+strlen(buf), "<tr><td><a href="%s/">%s/</a></td><td>%s</td><td>%ld</td></tr> ", encoded_name, dirinfo[i]->d_name, timestr, sb.st_size); } else { sprintf(buf+strlen(buf), "<tr><td><a href="%s">%s</a></td><td>%s</td><td>%ld</td></tr> ", encoded_name, dirinfo[i]->d_name, timestr, sb.st_size); } } bufferevent_write(bev, buf, strlen(buf)); memset(buf, 0, sizeof(buf)); } sprintf(buf+strlen(buf), "</table></body></html>"); bufferevent_write(bev, buf, strlen(buf)); printf("################# Dir Read OK !!!!!!!!!!!!!! "); return 0; } void conn_readcb(struct bufferevent *bev, void *user_data) { printf("******************** begin call %s......... ",__FUNCTION__); char buf[4096]={0}; char method[50], path[4096], protocol[32]; bufferevent_read(bev, buf, sizeof(buf)); printf("buf[%s] ", buf); sscanf(buf, "%[^ ] %[^ ] %[^ ]", method, path, protocol); printf("method[%s], path[%s], protocol[%s] ", method, path, protocol); if(strcasecmp(method, "GET") == 0) { response_http(bev, method, path); } printf("******************** end call %s......... ", __FUNCTION__); } void conn_eventcb(struct bufferevent *bev, short events, void *user_data) { printf("******************** begin call %s......... ", __FUNCTION__); if (events & BEV_EVENT_EOF) { printf("Connection closed. "); } else if (events & BEV_EVENT_ERROR) { printf("Got an error on the connection: %s ", strerror(errno)); } bufferevent_free(bev); printf("******************** end call %s......... ", __FUNCTION__); } void signal_cb(evutil_socket_t sig, short events, void *user_data) { struct event_base *base = user_data; struct timeval delay = { 1, 0 }; printf("Caught an interrupt signal; exiting cleanly in one seconds. "); event_base_loopexit(base, &delay); } //fd对应的是通信的文件描述符 void listener_cb(struct evconnlistener *listener, evutil_socket_t fd,struct sockaddr *sa, int socklen, void *user_data) { printf("******************** begin call-------%s ",__FUNCTION__); struct event_base *base = user_data; struct bufferevent *bev; printf("fd is %d ",fd); bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); if (!bev) { fprintf(stderr, "Error constructing bufferevent!"); event_base_loopbreak(base); return; } bufferevent_flush(bev, EV_READ | EV_WRITE, BEV_NORMAL); bufferevent_setcb(bev, conn_readcb, NULL, conn_eventcb, NULL); bufferevent_enable(bev, EV_READ | EV_WRITE); printf("******************** end call-------%s ",__FUNCTION__); } /* * 这里的内容是处理%20之类的东西!是"解码"过程。 * %20 URL编码中的‘ ’(space) * %21 '!' %22 '"' %23 '#' %24 '$' * %25 '%' %26 '&' %27 ''' %28 '('...... * 相关知识html中的‘ ’(space)是  */ void strdecode(char *to, char *from) { for ( ; *from != '