![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250517232602-68291b0aec4e5.png\")
<\/h3>\n\u6e90\u4ee3\u7801\u5730\u5740：TinyWebServer\/webserver.cpp at master \u00b7 qinguoyi\/TinyWebServer<\/p>\n
\u4f5c\u8005\u7684\u539f\u89e3\u8bfb：\u6700\u65b0\u7248Web\u670d\u52a1\u5668\u9879\u76ee\u8be6\u89e3 – 01 \u7ebf\u7a0b\u540c\u6b65\u673a\u5236\u5c01\u88c5\u7c7b<\/p>\n
Tingwebserver \u7684\u914d\u7f6e\u4e0e\u4f7f\u7528：c++ \u7ecf\u5178\u670d\u52a1\u5668\u5f00\u6e90\u9879\u76ee Tinywebserver\u7684\u4f7f\u7528\u4e0e\u914d\u7f6e(\u767e\u5ea6\u667a\u80fd\u4e91\u670d\u52a1\u5668\u5b89\u88c5ubuntu18.04\u53ef\u7528\u516c\u7f51ip\u8bbf\u95ee)-CSDN\u535a\u5ba2<\/p>\n
<\/h3>\n\u6211\u4eec\u5c06\u6309\u7167\u8fd9\u4e2a\u5173\u7cfb\u56fe\u9010\u7ea7\u89e3\u8bfb\u4ee3\u7801<\/p>\n
#include "config.h"<\/p>\n
int main(int argc, char *argv[])
\n{
\n \/\/\u9700\u8981\u4fee\u6539\u7684\u6570\u636e\u5e93\u4fe1\u606f,\u767b\u5f55\u540d,\u5bc6\u7801,\u5e93\u540d
\n string user = "root";
\n string passwd = "root";
\n string databasename = "qgydb";<\/p>\n
\/\/\u547d\u4ee4\u884c\u89e3\u6790
\n Config config;
\n config.parse_arg(argc, argv);<\/p>\n
WebServer server;<\/p>\n
\/\/\u521d\u59cb\u5316
\n server.init(config.PORT, user, passwd, databasename, config.LOGWrite,
\n config.OPT_LINGER, config.TRIGMode, config.sql_num, config.thread_num,
\n config.close_log, config.actor_model);<\/p>\n
\/\/\u65e5\u5fd7
\n server.log_write();<\/p>\n
\/\/\u6570\u636e\u5e93
\n server.sql_pool();<\/p>\n
\/\/\u7ebf\u7a0b\u6c60
\n server.thread_pool();<\/p>\n
\/\/\u89e6\u53d1\u6a21\u5f0f
\n server.trig_mode();<\/p>\n
\/\/\u76d1\u542c
\n server.eventListen();<\/p>\n
\/\/\u8fd0\u884c
\n server.eventLoop();<\/p>\n
return 0;
\n} <\/p>\n
\u00a0\u8fd9\u4e09\u884c\u662f\u5728\u7a0b\u5e8f\u7f16\u8bd1\u8fd0\u884c\u524d\u5c31\u9700\u8981\u4fee\u6539\u7684，\u786e\u4fdduser，password\u548cdatabase\u662f\u81ea\u5df1\u7684\u6570\u636e\u5e93\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/p>\n
string user = "root";
\n string passwd = "root";
\n string databasename = "qgydb"; <\/p>\n
\u00a0\u8fd9\u662fconfig\u89e3\u6790\u547d\u4ee4\u884c\u7684\u8fd0\u884c\u4ee3\u7801\u7684，\u4e00\u904d\u7684shell\u811a\u672c\u4ee3\u7801\u683c\u5f0f\u4e3a：<\/p>\n
.\/server [-p port] [-l LOGWrite] [-m TRIGMode] [-o OPT_LINGER] [-s sql_num] [-t thread_num] [-c close_log] [-a actor_model]<\/p>\n
\u800cconfig\u662f\u89e3\u6790\u540e\u9762\u7684-p,-l\u4e4b\u7c7b\u7684\u6307\u5b9a\u53c2\u6570，\u4ece\u800c\u5b9e\u73b0\u4e2a\u6027\u5316\u8fd0\u884c\u670d\u52a1\u5668\u00a0<\/p>\n
\/\/\u547d\u4ee4\u884c\u89e3\u6790
\n Config config;
\n config.parse_arg(argc, argv); <\/p>\n
\u540e\u9762\u5219\u662fwebserver\u7684\u521d\u59cb\u5316，\u4f20\u5165\u53c2\u6570\u662fconfig\u7684\u89e3\u6790\u547d\u4ee4，\u4e4b\u540e\u4fbf\u662f\u670d\u52a1\u5668\u542f\u52a8\u7684\u89c4\u8303\u6807\u51c6\u6d41\u7a0b：\u65e5\u5fd7->\u6570\u636e\u5e93->\u7ebf\u7a0b\u6c60-> \u89e6\u53d1\u6a21\u5f0f-> \u4e8b\u4ef6\u76d1\u542c-> \u4e8b\u4ef6\u5faa\u73af,\u670d\u52a1\u5668\u5f00\u59cb\u8fd0\u884c<\/p>\n
\u8fd9\u4e2a\u987a\u5e8f\u786e\u4fdd\u4e86\u6bcf\u4e2a\u7cfb\u7edf\u7ec4\u4ef6\u7684\u521d\u59cb\u5316\u90fd\u5728\u5176\u4f9d\u8d56\u7684\u7ec4\u4ef6\u4e4b\u524d\u8fdb\u884c，\u4ece\u800c\u907f\u514d\u51fa\u73b0\u8d44\u6e90\u4e0d\u53ef\u7528\u6216\u914d\u7f6e\u9519\u8bef\u7684\u95ee\u9898\u3002<\/p>\n
\u56e0\u4e3amain.cpp\u4e2d\u53ea\u662finclude\u4e86config .h\u8fd9\u4e2a\u5934\u6587\u4ef6，\u6211\u4eec\u5c31\u8ddf\u7740\u5f15\u7528\u5934\u6587\u4ef6\u5165\u624b\u00a0<\/p>\n
config.h\u975e\u5e38\u7b80\u5355\u5e76\u4e14\u53c2\u6570\u90fd\u7ed9\u4e86\u6ce8\u89e3，\u63d0\u4e00\u5634\u5b8f\u5b9a\u4e49\u5934\u6587\u4ef6，\u4e3a\u4e86\u9632\u6b62\u91cd\u590d\u7f16\u8bd1\u62a5\u9519，\u6240\u4ee5\u91c7\u7528\u8fd9\u79cd\u65b9\u5f0f<\/p>\n
\/\/ config.h #ifndef CONFIG_H #define CONFIG_H<\/p>\n
\/\/ \u5934\u6587\u4ef6\u7684\u5185\u5bb9<\/p>\n
#endif \/\/ CONFIG_H \u00a0<\/p>\n
\u73b0\u4ee3\u7f16\u8bd1\u5668\u901a\u5e38\u8fd8\u652f\u6301\u4e00\u79cd\u66f4\u7b80\u6d01\u7684\u65b9\u5f0f\u6765\u907f\u514d\u5934\u6587\u4ef6\u591a\u6b21\u5305\u542b，\u90a3\u5c31\u662f\u4f7f\u7528 #pragma once\u3002\u5b83\u7684\u6548\u679c\u4e0e #ifndef \/ #define \u914d\u5408\u4f7f\u7528\u7684\u5934\u6587\u4ef6\u4fdd\u62a4\u673a\u5236\u76f8\u540c，\u4f46\u5199\u6cd5\u66f4\u7b80\u6d01，\u4e14\u4e0d\u5bb9\u6613\u51fa\u9519<\/p>\n
\u5728config.cpp\u4e2d，\u6784\u9020\u51fd\u6570Config（）\u5b9a\u4e49\u4e86\u9ed8\u8ba4\u53c2\u6570，\u670d\u52a1\u5668\u7684\u521d\u59cb\u5b9a\u4e49\u72b6\u6001，\u9ed8\u8ba4\u7aef\u53e3\u53f7\u4e3a9006\u3002<\/p>\n
void Config::parse_arg(int argc, char*argv[])
\n{
\n int opt;
\n const char *str = "p:l:m:o:s:t:c:a:";
\n while ((opt = getopt(argc, argv, str)) != -1)
\n {
\n switch (opt)
\n {
\n case 'p':
\n {
\n PORT = atoi(optarg);
\n break;
\n }
\n …
\n default:
\n break;
\n }
\n}<\/p>\n
\u4f7f\u7528\u89e3\u6790\u547d\u4ee4\u884c\u51fd\u6570getopt（），\u8fd4\u56de\u7684opt\u6307\u5411\u5408\u6cd5\u547d\u4ee4\u884c\u9009\u9879，\u4f8b\u5982-p \u8fd4\u56de 'p'，\u800coptarg \u662f getopt \u89e3\u6790\u5230\u7684\u5f53\u524d\u9009\u9879\u7684\u53c2\u6570\u503c\u3002\u5b83\u662f\u4e00\u4e2a char* \u7c7b\u578b\u7684\u5168\u5c40\u53d8\u91cf，\u7528\u4e8e\u5b58\u50a8\u5f53\u524d\u9009\u9879\u5bf9\u5e94\u7684\u53c2\u6570\u3002<\/p>\n
getopt \u662f\u4e00\u4e2a\u6807\u51c6\u5e93\u51fd\u6570，\u7528\u4e8e\u89e3\u6790\u547d\u4ee4\u884c\u53c2\u6570\u3002\u5b83\u901a\u8fc7\u4e00\u4e2a\u9009\u9879\u5b57\u7b26\u4e32（\u6bd4\u5982 str）\u5b9a\u4e49\u7a0b\u5e8f\u652f\u6301\u7684\u547d\u4ee4\u884c\u53c2\u6570，\u5e76\u81ea\u52a8\u5904\u7406\u53c2\u6570\u89e3\u6790\u3002<\/p>\n
\u56e0\u4e3a\u662f\u4e3b\u4f53\u6587\u4ef6，include\u4e86\u5f88\u591a\u9700\u8981\u4f7f\u7528\u5230\u7684\u5934\u6587\u4ef6\u548c\u5e93，\u9664\u4e86main\u4e2d\u7528\u5230\u7684\u8fd0\u884c\u51fd\u6570\u548c\u521d\u59cb\u5316\u4e4b\u5916，public\u91cc\u8fd8\u6709\u5b9a\u65f6\u5668\u51fd\u6570\u548cepoll\u7684\u76f8\u5173\u914d\u7f6e<\/p>\n
void timer(int connfd, struct sockaddr_in client_address); \/\/ \u521b\u5efa\u5b9a\u65f6\u5668
\n void adjust_timer(util_timer *timer); \/\/ \u8c03\u6574\u5b9a\u65f6\u5668
\n void deal_timer(util_timer *timer, int sockfd); \/\/ \u5904\u7406\u5b9a\u65f6\u5668
\nbool dealclientdata(); \/\/ \u5904\u7406\u5ba2\u6237\u7aef\u6570\u636e<\/p>\n
\/\/ \u5b9a\u65f6\u5668\u914d\u7f6e
\n client_data *users_timer; \/\/ \u5b9a\u65f6\u5668\u76f8\u5173\u6570\u636e\u7ed3\u6784，\u7ba1\u7406\u8fde\u63a5\u7684\u8d85\u65f6
\n Utils utils; \/\/ \u5de5\u5177\u7c7b，\u7528\u4e8e\u5904\u7406\u5b9a\u65f6\u5668\u7b49
\n\/\/\u5b9a\u4e49\u5728timer\u7684lst_timer\u4e2d
\n\/\/epoll\u4e8b\u4ef6
\n bool dealwithsignal(bool& timeout, bool& stop_server); \/\/ \u5904\u7406\u4fe1\u53f7
\n void dealwithread(int sockfd); \/\/ \u5904\u7406\u8bfb\u64cd\u4f5c
\n void dealwithwrite(int sockfd); \/\/ \u5904\u7406\u5199\u64cd\u4f5c<\/p>\n
epoll_event events[MAX_EVENT_NUMBER]; \/\/ \u5b58\u653eepoll\u4e8b\u4ef6\u7684\u6570\u7ec4<\/p>\n
int m_listenfd; \/\/ \u76d1\u542c\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26
\n int m_OPT_LINGER; \/\/ SO_LINGER\u8bbe\u7f6e\u6807\u5fd7，\u662f\u5426\u5ef6\u8fdf\u5173\u95ed\u5957\u63a5\u5b57
\n int m_TRIGMode; \/\/ \u603b\u7684\u89e6\u53d1\u6a21\u5f0f（\u6c34\u5e73\u89e6\u53d1\/\u8fb9\u7f18\u89e6\u53d1）
\n int m_LISTENTrigmode; \/\/ \u76d1\u542c\u5957\u63a5\u5b57\u7684\u89e6\u53d1\u6a21\u5f0f（\u6c34\u5e73\u89e6\u53d1\/\u8fb9\u7f18\u89e6\u53d1）
\n int m_CONNTrigmode; \/\/ \u5ba2\u6237\u7aef\u8fde\u63a5\u7684\u89e6\u53d1\u6a21\u5f0f（\u6c34\u5e73\u89e6\u53d1\/\u8fb9\u7f18\u89e6\u53d1）<\/p>\n
\u6784\u9020\u51fd\u6570：\u00a0<\/p>\n
\/\/http_conn\u7c7b\u5bf9\u8c61
\n users = new http_conn[MAX_FD]; <\/p>\n
\u00a0http_conn \u7c7b\u662f Web \u670d\u52a1\u5668\u9879\u76ee\u4e2d\u4e0e\u6bcf\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\u76f8\u5173\u7684\u6838\u5fc3\u7c7b，\u627f\u62c5\u7740\u7ba1\u7406\u8fde\u63a5\u3001\u5904\u7406 HTTP \u8bf7\u6c42\u548c\u54cd\u5e94\u3001\u4ee5\u53ca\u4e0e\u4e8b\u4ef6\u9a71\u52a8\u673a\u5236（\u5982 epoll）\u534f\u540c\u5de5\u4f5c\u7b49\u4efb\u52a1\u3002\u901a\u8fc7\u8be5\u7c7b，\u670d\u52a1\u5668\u80fd\u591f\u9ad8\u6548\u5730\u5904\u7406\u5927\u91cf\u7684\u5e76\u53d1\u8fde\u63a5\u548c I\/O \u64cd\u4f5c\u3002<\/p>\n
\/\/root\u6587\u4ef6\u5939\u8def\u5f84
\n char server_path[200];
\n getcwd(server_path, 200);
\n char root[6] = "\/root";
\n m_root = (char *)malloc(strlen(server_path) + strlen(root) + 1);
\n strcpy(m_root, server_path);
\n strcat(m_root, root); <\/p>\n
\u8fd9\u6bb5\u4ee3\u7801\u7684\u76ee\u7684\u662f\u5728\u7a0b\u5e8f\u542f\u52a8\u65f6\u52a8\u6001\u6784\u5efa\u4e00\u4e2a\u8def\u5f84，\u8be5\u8def\u5f84\u662f\u5f53\u524d\u5de5\u4f5c\u76ee\u5f55\u8def\u5f84（\u901a\u8fc7 getcwd \u83b7\u53d6）\u52a0\u4e0a\u4e00\u4e2a\u56fa\u5b9a\u7684 \/root \u8def\u5f84\u3002\u4f8b\u5982，\u5982\u679c\u5f53\u524d\u5de5\u4f5c\u76ee\u5f55\u662f \/home\/user\/project，\u90a3\u4e48\u6784\u5efa\u51fa\u6765\u7684\u8def\u5f84\u4f1a\u662f \/home\/user\/project\/root\u3002<\/p>\n
WebServer::~WebServer()\u00a0<\/span> \u00a0 \u00a0 \u00a0<\/p>\n \u6790\u6784\u51fd\u6570，\u5173\u95edepoll,listen,\u548c\u7ba1\u9053pipe，delete\u91ca\u653eusers http_conn\u548cusers_timer\u5b9a\u65f6\u5668\u548c\u6c60\u7a7a\u95f4m_pool<\/p>\n main（）\u4e2d\u7684\u521d\u59cb\u5316server\u5bf9\u8c61<\/p>\n void WebServer::init(int port, string user, string passWord, string databaseName, int log_write, \u6839\u636e\u4f20\u5165\u7684m_TRIGMode\u503c\u6765\u8bbe\u5b9a\u670d\u52a1\u5668\u8fd0\u884c\u7684\u6a21\u5f0f，\u9ed8\u8ba4：LT+LT，\u901a\u8fc7\u6539\u53d8\u00a0m_LISTENTrigmode \u548cm_CONNTrigmode \u7684\u503c\u6765\u63a7\u5236\u3002<\/p>\n void WebServer::trig_mode() \u65e5\u5fd7\u51fd\u6570\u00a0<\/p>\n void WebServer::log_write() \u6570\u636e\u5e93\u521d\u59cb\u5316\u51fd\u6570\u00a0<\/p>\n void WebServer::sql_pool() \/\/\u521d\u59cb\u5316\u6570\u636e\u5e93\u8bfb\u53d6\u8868 \u7ebf\u7a0b\u6c60\u521d\u59cb\u5316\u51fd\u6570\u00a0<\/p>\n void WebServer::thread_pool() Server\u7684\u903b\u8f91\u4e2d\u5fc3，loop\u51fd\u6570，\u5904\u7406<\/p>\n \u91cd\u70b9<\/p>\n \u56e0\u4e3awebserver.cpp\u5728\u6784\u5efa\u7684\u65f6\u5019\u6d89\u53ca\u51fd\u6570\u95f4\u4f7f\u7528\u4f9d\u8d56\u7684\u95ee\u9898，eventLoop\u5199\u5728\u6e90\u4ee3\u7801\u7684\u6700\u4e0b\u9762，\u800c\u7b14\u8005\u628a\u672c\u51fd\u6570\u8c03\u5ea6\u5230\u6700\u4e0a\u9762\u8bb2\u89e3\u662f\u4ee5\u4e3aloop\u6d89\u53ca\u5927\u4f53\u6d41\u7a0b\u548c\u5176\u4ed6\u51fd\u6570，\u5728\u770bloop\u51fd\u6570\u7684\u540c\u65f6\u627e\u5230\u5bf9\u5e94\u7684\u4f7f\u7528\u51fd\u6570\u80fd\u66f4\u597d\u7406\u6e05\u601d\u8def\u7406\u89e3\u4ee3\u7801\u3002\u00a0<\/p>\n<\/p>\n void WebServer::eventLoop() while (!stop_server)\/\/\u5faa\u73af\u5904\u7406\u4e8b\u4ef6 for (int i = 0; i < number; i++)\/\/\u5904\u7406\u4e0d\u540c\u7684\u4e8b\u4ef6 \/\/\u5904\u7406\u65b0\u5230\u7684\u5ba2\u6237\u8fde\u63a5 LOG_INFO("%s", "timer tick");\u65e5\u5fd7\u8bb0\u5f55<\/p>\n timeout = false; \u7f51\u7edc\u7f16\u7a0b\u6b65\u9aa4，\u8bbe\u7acb\u76d1\u542c\u5668，socket listen，\u5224\u65ad\u662f\u5426\u4f18\u96c5\u5173\u95ed\u8fde\u63a5，\u8bbe\u7f6e\u00a0setsockopt<\/p>\n \u4f18\u96c5\u5173\u95ed\u9009\u9879：setsockopt(m_listenfd, SOL_SOCKET, SO_LINGER, &tmp, sizeof(tmp));<\/p>\n setsockopt\u51fd\u6570<\/span>：int setsockopt(int sockfd, int level, int optname, const void *optval, socklen_t optlen);<\/p>\n SO_LINGER<\/span>：\u8bbe\u7f6e\u5957\u63a5\u5b57\u5173\u95ed\u65f6\u7684\u5ef6\u8fdf\u65f6\u95f4\u3002<\/p>\n SO_LINGER \u9009\u9879\u5b9a\u4e49\u4e86\u5728\u5957\u63a5\u5b57\u88ab\u5173\u95ed\u65f6，\u5e94\u8be5\u5982\u4f55\u5904\u7406\u5269\u4f59\u6570\u636e\u3002\u5176\u7ed3\u6784\u4f53\u5b9a\u4e49\u5982\u4e0b：<\/p>\n struct linger { int l_onoff; \/\/ \u662f\u5426\u542f\u7528\u5ef6\u8fdf\u5173\u95ed（0\u4e3a\u4e0d\u542f\u7528，1\u4e3a\u542f\u7528） <\/p>\n \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0int l_linger; \/\/ \u5ef6\u8fdf\u5173\u95ed\u7684\u65f6\u95f4（\u5355\u4f4d\u4e3a\u79d2） };<\/p>\n<\/p>\n \u5f53 l_onoff \u8bbe\u7f6e\u4e3a 1 \u65f6，\u8868\u793a\u542f\u7528\u5ef6\u8fdf\u5173\u95ed，l_linger \u8bbe\u7f6e\u4e3a\u6307\u5b9a\u7684\u65f6\u95f4\u957f\u5ea6（\u5355\u4f4d\u662f\u79d2）\u3002\u5728\u6b64\u671f\u95f4，\u5957\u63a5\u5b57\u4e0d\u4f1a\u7acb\u5373\u5173\u95ed，\u800c\u662f\u7b49\u5f85\u6240\u6709\u672a\u53d1\u9001\u5b8c\u7684\u6570\u636e\u53d1\u9001\u5b8c\u6bd5\u540e\u518d\u5173\u95ed\u8fde\u63a5\u3002<\/p>\n \u5f53 l_onoff \u8bbe\u7f6e\u4e3a 0 \u65f6，\u8868\u793a\u7981\u7528\u5ef6\u8fdf\u5173\u95ed\u3002\u6b64\u65f6，\u8c03\u7528 close() \u51fd\u6570\u4f1a\u7acb\u5373\u5173\u95ed\u5957\u63a5\u5b57，\u5e76\u4e14\u4efb\u4f55\u672a\u53d1\u9001\u7684\u6570\u636e\u5c06\u4f1a\u88ab\u4e22\u5f03\u3002<\/p>\n \u5229\u7528setsockopt\u5b8c\u6210\u4f18\u96c5\u5173\u95ed\u64cd\u4f5c<\/p>\n \u6ce8：uilts\u7c7b\u4e3atimer\u6587\u4ef6\u5939lst_timer.cpp\u4e2d\u5b9a\u4e49\u7684\u7c7b\u6587\u4ef6，\u8fd9\u662f\u4e00\u4e2a\u5c01\u88c5\u7684\u5de5\u5177\u51fd\u6570，webserver.cpp\u548c\u5176\u4ed6\u6587\u4ef6\u4e2d\u4f1a\u5927\u91cf\u7528\u5230，\u770b\u5230\u65f6\u53ef\u4ee5\u53bblst_timer.cpp\u67e5\u9605\u5177\u4f53\u51fd\u6570\u5b9a\u4e49<\/p>\n void WebServer::eventListen() \/\/\u4f18\u96c5\u5173\u95ed\u8fde\u63a5 int ret = 0; int flag = 1; \/\/epoll\u521b\u5efa\u5185\u6838\u4e8b\u4ef6\u8868 \/\/\u5c06m_listenfd\u6302\u5728\u76d1\u542cm_epollfd\u7684epoll\u5b9e\u4f8b\u4e2d，m_LISTENTrigmode\u4e3a\u89e6\u53d1\u6a21\u5f0f \/\/\u521b\u5efa\u4e86\u7ba1\u9053m_pipefd\u7528\u4e8e\u8fdb\u7a0b\u95f4\u901a\u4fe1 \/\/\u5de5\u5177\u7c7b,\u4fe1\u53f7\u548c\u63cf\u8ff0\u7b26\u57fa\u7840\u64cd\u4f5c，\u5b58\u50a8\u5168\u5c40\u8d44\u6e90 \u4e3afd\u8bbe\u7f6e\u8ba1\u65f6\u5668，\u8ba1\u65f6\u5668\u51fd\u6570\u90fd\u5728timer\u76ee\u5f55\u7684lst_ timer\u4e0b，\u76f8\u5173\u51fd\u6570\u5b9a\u4e49\u53ef\u4ee5\u8df3\u8f6c\u7ffb\u770b<\/p>\n \/\/\u4e3a\u65b0\u8fde\u63a5\u8bbe\u7f6e\u8ba1\u65f6\u5668 \/\/\u521d\u59cb\u5316client_data\u6570\u636e \u8c03\u6574\u8ba1\u65f6\u5668，\u5ef6\u957f\u8fde\u63a5\u65f6\u95f4\u00a0<\/p>\n \/\/\u82e5\u6709\u6570\u636e\u4f20\u8f93，\u5219\u5c06\u5b9a\u65f6\u5668\u5f80\u540e\u5ef6\u8fdf3\u4e2a\u5355\u4f4d \u5173\u95ed\u8ba1\u65f6\u5668<\/p>\n \/\/\u5173\u95ed\u8ba1\u65f6\u5668 \u5904\u7406\u8fde\u63a5\u4e8b\u4ef6，\u6839\u636e\u4e0d\u540c\u7684\u89e6\u53d1\u6a21\u5f0f，accept\u521b\u5efa\u65b0\u7684\u5957\u63a5\u5b57\u5904\u7406\u540e\u7eed\u64cd\u4f5c<\/p>\n \/\/\u5904\u7406\u8fde\u63a5\u4e8b\u4ef6 else \/\/ET\u6a21\u5f0f\u8fdb\u884c\u5faa\u73af\u5224\u65ad \u5904\u7406\u4fe1\u53f7\u00a0<\/p>\n \/\/\u5904\u7406\u4fe1\u53f7，\u5224\u65ad\u6761\u4ef6：\u662f\u5426\u505c\u6b62\u670d\u52a1\u5668，\u662f\u5426\u8ba1\u65f6\u5668\u7ed3\u675f，\u5426->\u5904\u7406 \u8bfb\u4e8b\u4ef6\u5904\u7406\u51fd\u6570，\u6839\u636e\u8bbe\u5b9a\u6a21\u5f0f\u8fdb\u884c\u4e0d\u540c\u64cd\u4f5c，\u903b\u8f91\u76f8\u540c，\u90fd\u662f\u628a\u8bfb\u4e8b\u4ef6\u52a0\u5165\u8bf7\u6c42\u5904\u7406\u961f\u5217\u00a0<\/p>\n \/\/\u8bfb\u4e8b\u4ef6\u5904\u7406\u51fd\u6570 \/\/reactor \u5982\u679c\u8bbe\u5b9a\u4e3areactor\u6a21\u5f0f\u4e0b \/\/\u82e5\u76d1\u6d4b\u5230\u8bfb\u4e8b\u4ef6，\u5c06\u8be5\u4e8b\u4ef6\u653e\u5165\u8bf7\u6c42\u961f\u5217 while (true)\/\/\u5faa\u73af\u5224\u5b9a，\u76f4\u5230 \/\/\u82e5\u76d1\u6d4b\u5230\u8bfb\u4e8b\u4ef6，\u5c06\u8be5\u4e8b\u4ef6\u653e\u5165\u8bf7\u6c42\u961f\u5217 if (timer) \u5199\u4e8b\u4ef6\u5904\u7406，\u548c\u4e0a\u8ff0\u8bfb\u4e8b\u4ef6\u5904\u7406\u76f8\u540c\u00a0<\/p>\n \/\/\u5904\u7406\u5199\u4e8b\u4ef6，\u548c\u8bfb\u4e8b\u4ef6\u4ee3\u7801\u903b\u8f91\u76f8\u540c，\u5148\u5224\u65ad\u4f55\u79cd\u89e6\u53d1\u6a21\u5f0f，\u7136\u540e\u4ea4\u7ed9\u5904\u7406\u961f\u5217\u5904\u7406，\u5173\u95ed\u6216\u8005\u5ef6\u957f\u8ba1\u65f6\u5668 m_pool->append(users + sockfd, 1);<\/p>\n while (true) if (timer) \u5728\u770b\u5b8cwebserver\u7684\u4ee3\u7801\u540e，\u6211\u4eec\u77e5\u9053\u4e86\u670d\u52a1\u5668\u7684\u5927\u4f53\u6a21\u578b\u6846\u67b6\u4e3a：<\/p>\n \u5148\u521d\u59cb\u5316\u65e5\u5fd7，\u6570\u636e\u5e93，\u7ebf\u7a0b\u6c60，\u89e6\u53d1\u6a21\u5f0f，\u7136\u540eeventlisten\u521b\u5efa\u4e86socket\u5957\u63a5\u5b57，\u8fdb\u884c\u670d\u52a1\u5668\u7684\u5e38\u89c4\u5316\u6784\u5efa\u64cd\u4f5c，\u901a\u8fc7socket，bind，listen\u3002<\/p>\n \u7136\u540esetsocketopt\u8bbe\u7f6e\u662f\u5426\u4f18\u96c5\u5173\u95ed\u8fde\u63a5，\u63a5\u7740epoll\u521b\u5efa\u5185\u6838\u4e8b\u4ef6\u8868，\u5c06m_listenfd\u6302\u4e0a\u76d1\u542c\u6811，\u4e0e\u6b64\u540c\u65f6，\u521b\u5efam_pipe\u7ba1\u9053，\u5c06\u8bfb\u7aef\u4e00\u8d77\u6302\u4e0a\u76d1\u542c\u6811，\u4fe1\u53f7\u4f20\u8f93\u5c31\u662f\u5728\u7ba1\u9053\u95f4\u8fdb\u884c\u7684，\u7136\u540e\u8bbe\u7f6e\u4e8b\u4ef6\u4fe1\u53f7\u00a0，\u5982：\u8ba1\u65f6\u5668\u7ed3\u675f\u4fe1\u53f7，\u8fdb\u7a0b\u7ed3\u675f\u4fe1\u53f7，\u5e76\u5ffd\u7565pipe\u95f4\u901a\u4fe1\u7684\u5e38\u89c1\u9519\u8bef\u4fe1\u53f7\u4ee5\u514d\u5e72\u6270\u63a5\u53d7\u4fe1\u53f7\u7684\u51c6\u786e\u5ea6\u3002<\/p>\n \u63a5\u7740，\u5728\u670d\u52a1\u5668\u63a5\u6536\u5230\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u8bf7\u6c42\u65f6，loop\u5224\u65ad\u5904\u7406\u8bf7\u6c42\u4e3a\u8bf7\u6c42\u8fde\u63a5，\u8c03\u7528dealclient\u51fd\u6570\u5904\u7406，\u521b\u5efaclientfd\u5efa\u7acb\u5ba2\u6237\u7aef\u8fde\u63a5，\u7136\u540edealclient\u51fd\u6570\u8c03\u7528timer\u51fd\u6570\u8bbe\u7acb\u5b9a\u65f6\u5668，timer\u51fd\u6570\u4e2d\u53c8\u5c06client\u6570\u636e\u7ed9http_conn\u521d\u59cb\u5316，\u6302\u4e0a\u76d1\u542c\u6811\u3002<\/p>\n loop\u5faa\u73af\u5230pipe\u4e0a\u7684\u4fe1\u53f7\u65f6\u8fdb\u884c\u4fe1\u53f7\u5904\u7406，\u6536\u5230\u670d\u52a1\u7aef\u5173\u95ed\u8fde\u63a5\u65f6，\u5173\u95ed\u8ba1\u65f6\u5668\u3002<\/p>\n loop\u5faa\u73af\u5230\u6765\u81ea\u5ba2\u6237\u7aef\u7684\u8bf7\u6c42\u65f6，\u5224\u65ad\u4e8b\u4ef6\u4e3a\u8bfb\u6216\u5199\u4e8b\u4ef6，\u8fdb\u884cdealwithread\/dealwithwrite\u5904\u7406，\u6839\u636e\u4e0d\u540c\u7684\u8bbe\u5b9a\u6a21\u5f0f\u8fdb\u884creactor\/proactor\u5904\u7406，\u5c06\u4e8b\u4ef6\u9632\u653e\u5165\u8bf7\u6c42\u961f\u5217\u4e2d，\u8ba9\u7ebf\u7a0b\u6c60\u8fdb\u884c\u5904\u7406\u3002<\/p>\n \u6700\u540e\u5982\u8ba1\u65f6\u5668\u7ed3\u675f\u8c03\u7528utils.timer_handler\u5904\u7406\u8ba1\u65f6\u5668，while\u5faa\u73af\u7531\u670d\u52a1\u5668\u5173\u95ed\u8fde\u63a5，stop_server=true\u65f6\u8df3\u51fa，\u670d\u52a1\u5668\u505c\u6b62\u8fd0\u884c\u3002<\/p>\n<\/p>\n<\/p>\n<\/p>\n<\/p><\/p>\n","protected":false},"excerpt":{"rendered":" \u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb886\u6b21\uff0c\u70b9\u8d5e18\u6b21\uff0c\u6536\u85cf30\u6b21\u3002\u89e3\u8bfbmian.cpp config.h config.cpp webserver.h webserver.cpp\u6587\u4ef6\uff0c\u8bfb\u61c2\u9879\u76ee\u67b6\u6784_tingwebio\u5e93<\/p>\n","protected":false},"author":2,"featured_media":37861,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[58,1351,43],"topic":[],"class_list":["post-37862","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-linux","tag-tingwebserver","tag-43"],"yoast_head":"\nWebServer::init()<\/span><\/h4>\n
\n int opt_linger, int trigmode, int sql_num, int thread_num, int close_log, int actor_model)
\n{
\n m_port = port;
\n m_user = user;
\n m_passWord = passWord;
\n m_databaseName = databaseName;
\n m_sql_num = sql_num;
\n m_thread_num = thread_num;
\n m_log_write = log_write;
\n m_OPT_LINGER = opt_linger;\/\/\u4f18\u96c5\u5173\u95ed\u8fde\u63a5
\n m_TRIGMode = trigmode;\/\/\u89e6\u53d1\u6a21\u5f0f
\n m_close_log = close_log;\/\/\u662f\u5426\u5173\u95ed\u65e5\u5fd7
\n m_actormodel = actor_model;\/\/\u5e76\u53d1\u6a21\u578b\u9009\u62e9
\n} <\/p>\ntrig_mode()<\/span><\/h4>\n
\n{
\n \/\/LT + LT
\n if (0 == m_TRIGMode)
\n {
\n m_LISTENTrigmode = 0;
\n m_CONNTrigmode = 0;
\n }
\n \/\/LT + ET
\n else if (1 == m_TRIGMode)
\n {
\n m_LISTENTrigmode = 0;
\n m_CONNTrigmode = 1;
\n }
\n \/\/ET + LT
\n else if (2 == m_TRIGMode)
\n {
\n m_LISTENTrigmode = 1;
\n m_CONNTrigmode = 0;
\n }
\n \/\/ET + ET
\n else if (3 == m_TRIGMode)
\n {
\n m_LISTENTrigmode = 1;
\n m_CONNTrigmode = 1;
\n }
\n} <\/p>\nlog_write()\u00a0<\/h4>\n
\n{
\n if (0 == m_close_log) \/\/\u65e5\u5fd7\u6ca1\u6709\u88ab\u5173\u95ed
\n {
\n \/\/\u521d\u59cb\u5316\u65e5\u5fd7
\n if (1 == m_log_write) \/\/\u65e5\u5fd7\u53ef\u5199
\n Log::get_instance()->init(".\/ServerLog", m_close_log, 2000, 800000, 800);
\n else \/\/\u65e5\u5fd7\u4e0d\u53ef\u5199，\u6700\u540e\u76840\u8868\u793a\u65e5\u5fd7\u7684\u6761\u76ee
\n Log::get_instance()->init(".\/ServerLog", m_close_log, 2000, 800000, 0);
\n }
\n} <\/p>\nsql_pool（）<\/h4>\n
\n{
\n \/\/\u521d\u59cb\u5316\u6570\u636e\u5e93\u8fde\u63a5\u6c60
\n m_connPool = connection_pool::GetInstance();
\n m_connPool->init("localhost", m_user, m_passWord, m_databaseName, 3306, m_sql_num, m_close_log);<\/p>\n
\n users->initmysql_result(m_connPool);
\n} <\/p>\nthread_pool（）<\/h4>\n
\n{
\n \/\/\u521d\u59cb\u5316\u7ebf\u7a0b\u6c60
\n m_pool = new threadpool<http_conn>(m_actormodel, m_connPool, m_thread_num);
\n} <\/p>\neventLoop（）<\/h4>\n
\n
\n{
\n bool timeout = false;
\n bool stop_server = false;\/\/\u6807\u8bb0\u662f\u5426\u6709\u5b9a\u65f6\u5668\u8d85\u65f6\u4e8b\u4ef6\u548c\u670d\u52a1\u5668\u662f\u5426\u505c\u6b62\u8fd0\u884c<\/p>\n
\n {
\n \/\/\u963b\u585e\u6a21\u5f0f，\u7b49\u5f85\u4e8b\u4ef6\u53d1\u751f（io\u590d\u7528）
\n int number = epoll_wait(m_epollfd, events, MAX_EVENT_NUMBER, -1);
\n if (number < 0 && errno != EINTR)\/\/\u51fa\u73b0\u9519\u8bef\u5904\u7406
\n {
\n LOG_ERROR("%s", "epoll failure");\/\/\u8bb0\u5f55\u9519\u8bef\u5230\u65e5\u5fd7
\n break;
\n }<\/p>\n
\n {
\n int sockfd = events[i].data.fd;<\/p>\n
\n if (sockfd == m_listenfd)
\n {
\n bool flag = dealclientdata();\/\/\u5ba2\u6237\u7aef\u8fde\u63a5
\n if (false == flag)
\n continue;
\n }
\n else if (events[i].events & (EPOLLRDHUP | EPOLLHUP | EPOLLERR))
\n { \/\/\u8868\u793a\u5173\u95ed，\u5f02\u5e38\u6216\u9519\u8bef
\n \/\/\u670d\u52a1\u5668\u7aef\u5173\u95ed\u8fde\u63a5，\u79fb\u9664\u5bf9\u5e94\u7684\u5b9a\u65f6\u5668
\n util_timer *timer = users_timer[sockfd].timer;
\n deal_timer(timer, sockfd);
\n }
\n \/\/\u5904\u7406\u4fe1\u53f7，\u5728listen\u4e2d\u521b\u5efa\u4e86pipe\u7ba1\u9053\u5e76\u6302\u4e0a\u76d1\u542c，\u8fd9\u91cc\u662f\u76d1\u542c\u5230\u7ba1\u9053\u53ef\u8bfb\u6570\u636e\u65f6\u7684\u5904\u7406
\n else if ((sockfd == m_pipefd[0]) && (events[i].events & EPOLLIN))
\n {
\n bool flag = dealwithsignal(timeout, stop_server);\/\/\u5904\u7406\u4fe1\u53f7
\n if (false == flag)
\n LOG_ERROR("%s", "dealclientdata failure");
\n }
\n \/\/\u5904\u7406\u5ba2\u6237\u8fde\u63a5\u4e0a\u63a5\u6536\u5230\u7684\u6570\u636e
\n else if (events[i].events & EPOLLIN)\/\/\u8bfb\u4e8b\u4ef6
\n {
\n dealwithread(sockfd);
\n }
\n else if (events[i].events & EPOLLOUT)\/\/\u5199\u4e8b\u4ef6
\n {
\n dealwithwrite(sockfd);
\n }
\n }
\n if (timeout)\/\/\u8ba1\u65f6\u5668\u5173\u95ed
\n {
\n utils.timer_handler();<\/p>\n
\n }
\n }
\n} <\/p>\neventListen（）<\/h4>\n
\n
\n{
\n \/\/\u7f51\u7edc\u7f16\u7a0b\u57fa\u7840\u6b65\u9aa4
\n m_listenfd = socket(PF_INET, SOCK_STREAM, 0);
\n assert(m_listenfd >= 0);\/\/\u65ad\u8a00\u8bbe\u7f6e，\u5982\u679c\u5931\u8d25\u9000\u51fa<\/p>\n
\n if (0 == m_OPT_LINGER)
\n {
\n struct linger tmp = {0, 1};
\n setsockopt(m_listenfd, SOL_SOCKET, SO_LINGER, &tmp, sizeof(tmp));
\n }
\n else if (1 == m_OPT_LINGER)
\n {
\n struct linger tmp = {1, 1};
\n setsockopt(m_listenfd, SOL_SOCKET, SO_LINGER, &tmp, sizeof(tmp));
\n }<\/p>\n
\n struct sockaddr_in address;
\n bzero(&address, sizeof(address));
\n address.sin_family = AF_INET;
\n address.sin_addr.s_addr = htonl(INADDR_ANY);
\n address.sin_port = htons(m_port);<\/p>\n
\n setsockopt(m_listenfd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag));
\n \/\/\u8bbe\u7f6e\u7aef\u53e3\u590d\u7528
\n \/\/SO_REUSEADDR：\u5141\u8bb8\u91cd\u7528\u672c\u5730\u5730\u5740\u3002\u5e38\u7528\u4e8e\u5141\u8bb8\u591a\u4e2a\u670d\u52a1\u5668\u8fdb\u7a0b\u7ed1\u5b9a\u5230\u540c\u4e00\u7aef\u53e3，\u6216\u8005\u5728\u7a0b\u5e8f\u5f02\u5e38\u9000\u51fa \u540e\u5feb\u901f\u7ed1\u5b9a\u5230\u540c\u4e00\u7aef\u53e3\u3002
\n ret = bind(m_listenfd, (struct sockaddr *)&address, sizeof(address));
\n assert(ret >= 0);
\n ret = listen(m_listenfd, 5);
\n assert(ret >= 0);
\n \/\/\u521d\u59cb\u5316\u5b9a\u65f6\u5668
\n utils.init(TIMESLOT);<\/p>\n
\n epoll_event events[MAX_EVENT_NUMBER];\/\/\u521b\u5efaepoll\u6570\u7ec4
\n m_epollfd = epoll_create(5);\/\/\u521b\u5efaepoll\u5b9e\u4f8b\u7528\u4e8e\u76d1\u542c
\n assert(m_epollfd != -1);<\/p>\n
\n utils.addfd(m_epollfd, m_listenfd, false, m_LISTENTrigmode);
\n \/\/m_epollfd\u8d4b\u503c\u7ed9http\u8bf7\u6c42\u7c7b
\n http_conn::m_epollfd = m_epollfd;<\/p>\n
\n ret = socketpair(PF_UNIX, SOCK_STREAM, 0, m_pipefd);
\n assert(ret != -1);
\n \/\/\u8bbe\u7f6e\u5199\u64cd\u4f5c\u4e3a\u975e\u963b\u585e\u6a21\u5f0f
\n utils.setnonblocking(m_pipefd[1]);
\n \/\/\u76d1\u542c\u8bfb\u7aef\u53e3\u4e8b\u4ef6
\n utils.addfd(m_epollfd, m_pipefd[0], false, 0);
\n \/\/\u5ffd\u7565 SIGPIPE \u4fe1\u53f7，\u6709\u52a9\u4e8e\u907f\u514d\u8fdb\u7a0b\u56e0\u7ba1\u9053\u9519\u8bef\u800c\u610f\u5916\u9000\u51fa
\n utils.addsig(SIGPIPE, SIG_IGN);
\n \/\/\u8bbe\u7f6e SIGALRM \u4fe1\u53f7（\u5b9a\u65f6\u5668\u4fe1\u53f7），\u5b9a\u65f6\u5668\u5230\u671f\u65f6\u53d1\u9001
\n utils.addsig(SIGALRM, utils.sig_handler, false);
\n \/\/\u8bbe\u7f6e SIGTERM \u4fe1\u53f7（\u7ec8\u6b62\u4fe1\u53f7），\u5916\u90e8\u8bf7\u6c42\u7ec8\u6b62\u7a0b\u5e8f\u65f6\u53d1\u51fa
\n utils.addsig(SIGTERM, utils.sig_handler, false);
\n \/\/\u4fe1\u53f7\u8bbe\u5b9a\u540e\u89e6\u53d1\u8c03\u7528handler\u51fd\u6570，send\u8fdb\u7ba1\u9053\u7684\u5199\u7aef
\n \/\/\u5b9a\u65f6\u5668\u8bbe\u7f6e
\n alarm(TIMESLOT);<\/p>\n
\n Utils::u_pipefd = m_pipefd;
\n Utils::u_epollfd = m_epollfd;
\n} <\/p>\ntimer（）\u00a0<\/h4>\n
\nvoid WebServer::timer(int connfd, struct sockaddr_in client_address)
\n{
\n \/\/users\u662fwebserver.h\u91cchttp_conn *users;\u521d\u59cb\u5316http\u8bf7\u6c42\u6570\u636e
\n users[connfd].init(connfd, client_address, m_root, m_CONNTrigmode, m_close_log, m_user, m_passWord, m_databaseName);<\/p>\n
\n \/\/\u521b\u5efa\u5b9a\u65f6\u5668，\u8bbe\u7f6e\u56de\u8c03\u51fd\u6570\u548c\u8d85\u65f6\u65f6\u95f4，\u7ed1\u5b9a\u7528\u6237\u6570\u636e，\u5c06\u5b9a\u65f6\u5668\u6dfb\u52a0\u5230\u94fe\u8868\u4e2d
\n users_timer[connfd].address = client_address;
\n users_timer[connfd].sockfd = connfd;
\n \/\/\u8bbe\u7acb\u548c\u521b\u5efa\u5b9a\u65f6\u5668
\n util_timer *timer = new util_timer;
\n timer->user_data = &users_timer[connfd];
\n timer->cb_func = cb_func;\/\/\u56de\u8c03\u51fd\u6570，\u5904\u7406\u51fd\u6570
\n time_t cur = time(NULL);\/\/\u83b7\u53d6\u5f53\u524d\u7684\u65f6\u95f4\u6233
\n timer->expire = cur + 3 * TIMESLOT;\/\/\u8bbe\u7f6e\u5b9a\u65f6\u5668\u7684\u5230\u671f\u65f6\u95f4
\n users_timer[connfd].timer = timer;\/\/\u5b9a\u65f6\u5668\u5173\u8054
\n utils.m_timer_lst.add_timer(timer);\/\/\u5b9a\u65f6\u5668\u6302\u8f7d\u5217\u8868
\n}<\/p>\nadjust_timer（）<\/h4>\n
\n\/\/\u5e76\u5bf9\u65b0\u7684\u5b9a\u65f6\u5668\u5728\u94fe\u8868\u4e0a\u7684\u4f4d\u7f6e\u8fdb\u884c\u8c03\u6574
\nvoid WebServer::adjust_timer(util_timer *timer)
\n{
\n time_t cur = time(NULL);
\n timer->expire = cur + 3 * TIMESLOT;
\n utils.m_timer_lst.adjust_timer(timer);
\n \/\/\u65e5\u5fd7\u8bb0\u5f55\u8c03\u6574
\n LOG_INFO("%s", "adjust timer once");
\n} <\/p>\n\u00a0deal_timer（）<\/h4>\n
\nvoid WebServer::deal_timer(util_timer *timer, int sockfd)
\n{
\n timer->cb_func(&users_timer[sockfd]);
\n if (timer)
\n {
\n utils.m_timer_lst.del_timer(timer);
\n }
\n \/\/\u65e5\u5fd7\u8bb0\u5f55\u8ba1\u65f6\u5668\u5173\u95ed
\n LOG_INFO("close fd %d", users_timer[sockfd].sockfd);
\n} <\/p>\ndealclientdata（）<\/h4>\n
\nbool WebServer::dealclientdata()
\n{
\n struct sockaddr_in client_address;
\n socklen_t client_addrlength = sizeof(client_address);
\n if (0 == m_LISTENTrigmode) \/\/\u5982\u679c\u8bbe\u7f6eLT\u89e6\u53d1\u6a21\u5f0f
\n {
\n int connfd = accept(m_listenfd, (struct sockaddr *)&client_address, &client_addrlength);
\n if (connfd < 0)
\n {
\n LOG_ERROR("%s:errno is:%d", "accept error", errno);\/\/\u65e5\u5fd7
\n return false;
\n }
\n if (http_conn::m_user_count >= MAX_FD)\/\/\u8d85\u51fa\u4e0a\u9650
\n {
\n utils.show_error(connfd, "Internal server busy");
\n LOG_ERROR("%s", "Internal server busy");
\n return false;
\n }
\n timer(connfd, client_address)；\u8bbe\u7f6e\u5b9a\u65f6\u5668
\n }<\/p>\n
\n {
\n while (1)
\n {
\n int connfd = accept(m_listenfd, (struct sockaddr *)&client_address, &client_addrlength);
\n if (connfd < 0)
\n {
\n LOG_ERROR("%s:errno is:%d", "accept error", errno);
\n break;
\n }
\n if (http_conn::m_user_count >= MAX_FD)
\n {
\n utils.show_error(connfd, "Internal server busy");
\n LOG_ERROR("%s", "Internal server busy");
\n break;
\n }
\n timer(connfd, client_address);
\n }
\n return false;
\n }
\n return true;
\n}<\/p>\ndealwithsignal（）<\/h4>\n
\nbool WebServer::dealwithsignal(bool &timeout, bool &stop_server)
\n{
\n int ret = 0;
\n int sig;
\n char signals[1024];
\n ret = recv(m_pipefd[0], signals, sizeof(signals), 0);\/\/\u8bfb\u53d6\u7ba1\u9053\u5185\u4fe1\u606f
\n if (ret == -1)\/\/\u9519\u8bef\u5904\u7406
\n {
\n return false;
\n }
\n else if (ret == 0)
\n {
\n return false;
\n }
\n else
\n {
\n for (int i = 0; i < ret; ++i)
\n {
\n switch (signals[i])\/\/\u5904\u7406\u4fe1\u53f7
\n {
\n case SIGALRM:
\n {
\n timeout = true;\/\/\u8bbe\u7f6e\u5df2\u7ecf\u8d85\u65f6，\u9700\u8981\u8fdb\u884c\u5904\u7406
\n break;
\n }
\n case SIGTERM:
\n {
\n stop_server = true;\/\/\u8868\u793a\u9700\u8981\u505c\u6b62\u670d\u52a1
\n break;
\n }
\n }
\n }
\n }
\n return true;\/\/\u4fe1\u53f7\u5904\u7406\u5b8c\u6bd5
\n} <\/p>\ndealwithread（）<\/h4>\n
\nvoid WebServer::dealwithread(int sockfd)
\n{
\n \/\/\u6bcf\u4e2a\u5ba2\u6237\u7aef\u90fd\u6709\u4e00\u4e2a\u8ba1\u65f6\u5668，\u786e\u4fdd\u8fde\u63a5\u8d85\u65f6\u8fdb\u884c\u91ca\u653e\u8d44\u6e90\u64cd\u4f5c
\n util_timer *timer = users_timer[sockfd].timer;<\/p>\n
\n if (1 == m_actormodel)
\n {
\n if (timer)
\n {
\n adjust_timer(timer);\/\/\u8c03\u6574timer，\u4ee5\u4fbf\u5ba2\u6237\u7aef\u5728\u6709\u6d3b\u52a8\u671f\u95f4\u4e0d\u65ad\u5f00\u8fde\u63a5
\n }<\/p>\n
\n m_pool->append(users + sockfd, 0);<\/p>\n
\n {
\n if (1 == users[sockfd].improv)\/\/\u6709\u5176\u4ed6\u64cd\u4f5c\u8981\u6267\u884c
\n {
\n if (1 == users[sockfd].timer_flag)\/\/\u9700\u8981\u5904\u7406\u5b9a\u65f6\u5668\u903b\u8f91
\n {
\n deal_timer(timer, sockfd);
\n users[sockfd].timer_flag = 0;
\n }
\n users[sockfd].improv = 0;\/\/\u6807\u8bb0\u5df2\u7ecf\u5904\u7406，\u9000\u51fa\u5faa\u73af
\n break;
\n }
\n }
\n }
\n else
\n {
\n \/\/proactor
\n if (users[sockfd].read_once())\/\/\u670d\u52a1\u5668\u4e3b\u52a8\u4ece\u5ba2\u6237\u7aef\u8bfb\u53d6\u6570\u636e\u5e76\u8fdb\u884c\u5904\u7406
\n {
\n LOG_INFO("deal with the client(%s)", inet_ntoa(users[sockfd].get_address()->sin_addr));\/\/\u6253\u5370\u65e5\u5fd7，\u8bb0\u5f55\u5ba2\u6237\u7aefIP<\/p>\n
\n m_pool->append_p(users + sockfd);<\/p>\n
\n {
\n adjust_timer(timer);\/\/\u5ef6\u8fdf\u8fde\u63a5\u65f6\u95f4
\n }
\n }
\n else
\n {
\n deal_timer(timer, sockfd);\/\/\u5904\u7406\u5931\u8d25，\u5173\u95ed\u8fde\u63a5
\n }
\n }
\n} <\/p>\ndealwithwrite（）<\/h4>\n
\nvoid WebServer::dealwithwrite(int sockfd)
\n{
\n util_timer *timer = users_timer[sockfd].timer;
\n \/\/reactor
\n if (1 == m_actormodel)
\n {
\n if (timer)
\n {
\n adjust_timer(timer);
\n }<\/p>\n
\n {
\n if (1 == users[sockfd].improv)
\n {
\n if (1 == users[sockfd].timer_flag)
\n {
\n deal_timer(timer, sockfd);
\n users[sockfd].timer_flag = 0;
\n }
\n users[sockfd].improv = 0;
\n break;
\n }
\n }
\n }
\n else
\n {
\n \/\/proactor
\n if (users[sockfd].write())
\n {
\n LOG_INFO("send data to the client(%s)", inet_ntoa(users[sockfd].get_address()->sin_addr));<\/p>\n
\n {
\n adjust_timer(timer);
\n }
\n }
\n else
\n {
\n deal_timer(timer, sockfd);
\n }
\n }
\n} <\/p>\n\u603b\u7ed3webserver：<\/h2>\n