![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250506233618-681a9cf27377e.png\")
<\/p>\n\u4e0a\u4e00\u7bc7：TingWebServer\u670d\u52a1\u5668\u4ee3\u7801\u89e3\u8bfb01<\/p>\n
TingWebServer\u670d\u52a1\u5668\u4ee3\u7801\u89e3\u8bfb01-CSDN\u535a\u5ba2<\/p>\n
<\/p>\n
\u6211\u4eec\u5c06\u8ddf\u968f\u8fd9\u4e2a\u5934\u6587\u4ef6\u5305\u542b\u56fe，\u7ee7\u7eed\u9010\u7ea7\u89e3\u8bfb\u4ee3\u7801，\u6211\u4eec\u89e3\u8bfb\u7684\u987a\u5e8f\u8fd8\u662f\u4ece\u4e0a\u5f80\u4e0b\u7684，\u8fd9\u6837\u80fd\u6e05\u695a\u7684\u4e86\u89e3tingwebserver\u7684\u670d\u52a1\u5668\u7684\u6846\u67b6\u5305\u542b\u7ed3\u6784，\u4f46\u5728\u89e3\u8bfb\u4e0a\u4e00\u7ea7\u6587\u4ef6\u7684\u65f6\u5019\u5f80\u5f80\u4f1a\u8fd0\u7528\u5230\u4e0b\u4e00\u7ea7\u7684\u5305\u542b\u4ee3\u7801，\u56e0\u6b64\u5e0c\u671b\u8bfb\u8005\u5728\u7ffb\u9605\u4ee3\u7801\u89e3\u8bfb\u7684\u65f6\u5019\u591a\u5f00\u51e0\u4e2a\u7a97\u53e3，\u4ee5\u4fbf\u5728\u8bfb\u5230\u76f8\u5173\u5b50\u96c6\u4ee3\u7801\u7684\u65f6\u5019\u80fd\u8fc5\u901f\u627e\u5230\u5bf9\u4e8e\u4ee3\u7801\u89e3\u6790\u3002<\/p>\n
\u8fd9\u7bc7\u5c06\u8fdb\u5165TingWebserver\u7684\u6587\u4ef6\u5939\u4e2d\u89e3\u8bfb\u76f8\u5173\u6587\u4ef6，\u4ecethereadpool\u548chttp_conn.h\u89e3\u8bfb\u5230\u6700\u540e\u7684\u65e5\u5fd7\u6587\u4ef6\u3002<\/p>\n
\u534a\u540c\u6b65\/\u534a\u53cd\u5e94\u5806\u7ebf\u7a0b\u6c60<\/p>\n
\u4f7f\u7528\u4e00\u4e2a\u5de5\u4f5c\u961f\u5217\u5b8c\u5168\u89e3\u9664\u4e86\u4e3b\u7ebf\u7a0b\u548c\u5de5\u4f5c\u7ebf\u7a0b\u7684\u8026\u5408\u5173\u7cfb：\u4e3b\u7ebf\u7a0b\u5f80\u5de5\u4f5c\u961f\u5217\u4e2d\u63d2\u5165\u4efb\u52a1，\u5de5\u4f5c\u7ebf\u7a0b\u901a\u8fc7\u7ade\u4e89\u6765\u53d6\u5f97\u4efb\u52a1\u5e76\u6267\u884c\u5b83\u3002<\/p>\n
\u8df3\u8fc7\u5934\u6587\u4ef6<\/p>\n
template <typename T>
\nclass threadpool
\n{
\npublic:
\n \/\/\u6784\u9020\u51fd\u6570，\u4f20\u53c2：\u5de5\u4f5c\u6a21\u5f0f，\u6570\u636e\u5e93\u8fde\u63a5\u6c60，\u7ebf\u7a0b\u6570，\u6700\u5927\u8bf7\u6c42\u91cf
\n threadpool(int actor_model, connection_pool *connPool, int thread_number = 8, int max_request = 10000);
\n ~threadpool();
\n \/\/\u628a\u8bf7\u6c42\u6dfb\u52a0\u5230\u5de5\u4f5c\u961f\u5217\u5f53\u4e2d
\n bool append(T *request, int state);
\n bool append_p(T *request);<\/p>\n
private:
\n static void *worker(void *arg);
\n void run();<\/p>\n
private:
\n int m_thread_number; \/\/ \u7ebf\u7a0b\u6c60\u4e2d\u7684\u7ebf\u7a0b\u6570
\n int m_max_requests; \/\/ \u8bf7\u6c42\u961f\u5217\u4e2d\u5141\u8bb8\u7684\u6700\u5927\u8bf7\u6c42\u6570
\n pthread_t *m_threads; \/\/ \u7ebf\u7a0b\u6c60\u7684\u7ebf\u7a0b\u6570\u7ec4
\n std::list<T *> m_workqueue; \/\/ \u8bf7\u6c42\u961f\u5217，\u5b58\u50a8\u5f85\u5904\u7406\u7684\u8bf7\u6c42
\n locker m_queuelocker; \/\/ \u4fdd\u62a4\u8bf7\u6c42\u961f\u5217\u7684\u4e92\u65a5\u9501
\n sem m_queuestat; \/\/ \u4fe1\u53f7\u91cf，\u8868\u793a\u8bf7\u6c42\u961f\u5217\u4e2d\u7684\u4efb\u52a1\u6570\u91cf
\n connection_pool *m_connPool; \/\/ \u6570\u636e\u5e93\u8fde\u63a5\u6c60
\n int m_actor_model; \/\/ \u5de5\u4f5c\u6a21\u578b，\u652f\u6301\u4e0d\u540c\u7684\u8bf7\u6c42\u5904\u7406\u6a21\u5f0f
\n};<\/p>\n
template <typename T>
\nthreadpool<T>::threadpool(int actor_model, connection_pool *connPool, int thread_number, int max_requests)
\n : m_actor_model(actor_model), m_thread_number(thread_number), m_max_requests(max_requests), m_threads(NULL), m_connPool(connPool)
\n\/\/\u7c7b\u5185\u6210\u5458\u521d\u59cb\u5316
\n{
\n if (thread_number <= 0 || max_requests <= 0)
\n throw std::exception(); \/\/ \u5982\u679c\u7ebf\u7a0b\u6570\u6216\u6700\u5927\u8bf7\u6c42\u6570\u4e0d\u5408\u6cd5，\u629b\u51fa\u5f02\u5e38
\n m_threads = new pthread_t[m_thread_number]; \/\/ \u521b\u5efa\u7ebf\u7a0b\u6c60
\n if (!m_threads)
\n throw std::exception();<\/p>\n
\/\/ \u521b\u5efa\u5de5\u4f5c\u7ebf\u7a0b
\n for (int i = 0; i < thread_number; ++i)
\n {
\n if (pthread_create(m_threads + i, NULL, worker, this) != 0)
\n {
\n delete[] m_threads;
\n throw std::exception(); \/\/ \u521b\u5efa\u7ebf\u7a0b\u5931\u8d25，\u629b\u51fa\u5f02\u5e38
\n }
\n if (pthread_detach(m_threads[i])) \/\/ \u5206\u79bb\u7ebf\u7a0b
\n {
\n delete[] m_threads;
\n throw std::exception(); \/\/ \u5206\u79bb\u7ebf\u7a0b\u5931\u8d25，\u629b\u51fa\u5f02\u5e38
\n }
\n }
\n}<\/p>\n
template <typename T>
\nthreadpool<T>::~threadpool()
\n{
\n delete[] m_threads; \/\/ \u91ca\u653e\u7ebf\u7a0b\u6c60\u7684\u5185\u5b58
\n}<\/p>\n
template <typename T>
\nbool threadpool<T>::append(T *request, int state)
\n{
\n m_queuelocker.lock();\/\/\u5148\u52a0\u9501，\u518d\u64cd\u4f5c
\n if (m_workqueue.size() >= m_max_requests) \/\/ \u5982\u679c\u8bf7\u6c42\u961f\u5217\u5df2\u6ee1，\u8fd4\u56de false
\n {
\n m_queuelocker.unlock();
\n return false;
\n }
\n request->m_state = state; \/\/ \u8bbe\u7f6e\u8bf7\u6c42\u7684\u72b6\u6001
\n m_workqueue.push_back(request); \/\/ \u5c06\u8bf7\u6c42\u6dfb\u52a0\u5230\u961f\u5217
\n m_queuelocker.unlock();\/\/\u7ed3\u675f\u64cd\u4f5c，\u89e3\u9501
\n m_queuestat.post(); \/\/ \u901a\u77e5\u6709\u65b0\u7684\u8bf7\u6c42
\n return true;
\n}<\/p>\n
append_p\u662f\u4e00\u4e2a\u4e0d\u7528state\u53c2\u6570\u7684\u52a0\u5165\u8bf7\u6c42\u961f\u5217\u51fd\u6570\u00a0<\/p>\n
template <typename T>
\nbool threadpool<T>::append_p(T *request)
\n{
\n m_queuelocker.lock();
\n if (m_workqueue.size() >= m_max_requests) \/\/ \u5982\u679c\u8bf7\u6c42\u961f\u5217\u5df2\u6ee1，\u8fd4\u56de false
\n {
\n m_queuelocker.unlock();
\n return false;
\n }
\n m_workqueue.push_back(request); \/\/ \u5c06\u8bf7\u6c42\u6dfb\u52a0\u5230\u961f\u5217
\n m_queuelocker.unlock();
\n m_queuestat.post(); \/\/ \u901a\u77e5\u6709\u65b0\u7684\u8bf7\u6c42
\n return true;
\n}<\/p>\n
\u5728\u591a\u7ebf\u7a0b\u7f16\u7a0b\u4e2d，\u7ebf\u7a0b\u7684\u6267\u884c\u51fd\u6570（\u5373\u7ebf\u7a0b\u5165\u53e3\u51fd\u6570）\u5fc5\u987b\u662f\u4e00\u4e2a\u7b26\u5408\u64cd\u4f5c\u7cfb\u7edf\u8981\u6c42\u7684\u683c\u5f0f\u3002\u5728 POSIX \u7ebf\u7a0b（pthread）\u4e2d，\u7ebf\u7a0b\u5165\u53e3\u51fd\u6570\u7684\u539f\u578b\u662f：\u00a0<\/p>\n
void* thread_func(void* arg);<\/p>\n
\u76f4\u63a5\u4f7f\u7528run\u51fd\u6570，\u56e0\u4e3arun\u51fd\u6570\u6ca1\u6709\u4f20\u5165\u53c2\u6570void*，\u6240\u4ee5\u521b\u5efa\u4e00\u4e2a\u4e2d\u4ecb\u51fd\u6570worker，\u5c06\u4f20\u9012\u7ed9\u7ebf\u7a0b\u7684\u53c2\u6570\u4ecevoid*\u8f6c\u5316\u4e3athreadpool*\u7c7b\u578b，\u4ece\u800c\u53ef\u4ee5\u8c03\u7528run\u51fd\u6570，\u4e0a\u9762\u7684pthread_create\u4f20\u5165\u4e86this（\u672c\u7ebf\u7a0b），\u5f53\u4f5cworker\u7684\u4f20\u5165\u53c2\u6570void*arg，\u4ece\u800c\u8c03\u7528pool\u7684run\u51fd\u6570<\/p>\n
template <typename T>
\nvoid *threadpool<T>::worker(void *arg)
\n{
\n threadpool *pool = (threadpool *)arg;
\n pool->run(); \/\/ \u6bcf\u4e2a\u7ebf\u7a0b\u8c03\u7528 run \u51fd\u6570
\n return pool;
\n}<\/p>\n
\u8fdb\u5165\u5faa\u73af，\u7136\u540e\u4fe1\u53f7m_queuestat\u8fdb\u884c\u963b\u585e\u76f4\u5230\u6709\u65b0\u4efb\u52a1，\u4e0a\u9501，\u5224\u65ad\u961f\u5217\u662f\u5426\u4e3a\u7a7a，\u662f\u5219\u89e3\u9501\u7ee7\u7eed\u7b49\u5f85，\u5426\u5219\u8fdb\u884c\u5904\u7406，\u83b7\u53d6\u7b2c\u4e00\u4e2a\u8bf7\u6c42，（\u5728wait\u5230\u4e86\u4fe1\u53f7\u540e，\u8fdb\u884c\u00a0m_queuestat\u5185\u90e8\u7684\u4fe1\u53f7\u5904\u7406，m_wirkqueue\u961f\u5217+1)，\u8bfb\u53d6\u8bf7\u6c42\u540e\u79fb\u9664，\u8fdb\u884c\u89e3\u9501，\u7136\u540e\u6839\u636e\u4e0d\u540c\u7684\u64cd\u4f5c\u6a21\u5f0f\u8fdb\u884c\u4e0d\u540c\u7684\u64cd\u4f5c<\/p>\n<\/p>\n
Reactor \u6a21\u5f0f：\u5f53 m_actor_model \u4e3a 1 \u65f6，\u8868\u793a\u7ebf\u7a0b\u6c60\u91c7\u7528\u7684\u662f Reactor \u6a21\u5f0f\u3002<\/p>\n
\u8bfb\u53d6\u8bf7\u6c42：\u5982\u679c\u8bf7\u6c42\u7684\u72b6\u6001 request->m_state \u4e3a 0，\u8868\u793a\u8be5\u8bf7\u6c42\u662f\u8bfb\u53d6\u64cd\u4f5c\u3002\u6b64\u65f6，\u8c03\u7528 request->read_once() \u8bfb\u53d6\u6570\u636e：<\/p>\n
\u5199\u5165\u8bf7\u6c42：\u5982\u679c\u8bf7\u6c42\u7684\u72b6\u6001\u662f\u5199\u5165\u64cd\u4f5c（request->m_state \u4e3a 1），\u8c03\u7528 request->write() \u5199\u5165\u6570\u636e：<\/p>\n
Proactor \u6a21\u5f0f：\u5f53 m_actor_model \u4e0d\u4e3a 1 \u65f6，\u8868\u793a\u7ebf\u7a0b\u6c60\u91c7\u7528\u7684\u662f Proactor \u6a21\u5f0f\u3002<\/p>\n
\u5728 Proactor \u6a21\u5f0f\u4e0b，\u7ebf\u7a0b\u6c60\u4f1a\u76f4\u63a5\u4ece\u8bf7\u6c42\u961f\u5217\u4e2d\u53d6\u51fa\u8bf7\u6c42\u5e76\u8fdb\u884c\u5904\u7406\u3002connectionRAII \u662f\u7528\u4e8e\u7ba1\u7406\u6570\u636e\u5e93\u8fde\u63a5\u7684\u667a\u80fd\u6307\u9488，\u786e\u4fdd\u6570\u636e\u5e93\u8fde\u63a5\u5728\u8bf7\u6c42\u5904\u7406\u5b8c\u540e\u81ea\u52a8\u91ca\u653e\u3002<\/p>\n<\/li>\n
\u7136\u540e\u8c03\u7528 request->process() \u5904\u7406\u8bf7\u6c42\u3002<\/p>\n<\/li>\n<\/ul>\n
template <typename T>
\nvoid threadpool<T>::run()
\n{
\n while (true)\/\/\u8fdb\u884c\u5faa\u73af
\n {
\n m_queuestat.wait(); \/\/ \u7b49\u5f85\u4efb\u52a1
\n m_queuelocker.lock();\/\/\u4e0a\u9501
\n if (m_workqueue.empty()) \/\/ \u5982\u679c\u8bf7\u6c42\u961f\u5217\u4e3a\u7a7a，\u5219\u7ee7\u7eed\u7b49\u5f85
\n {
\n m_queuelocker.unlock();
\n continue;
\n }
\n T *request = m_workqueue.front(); \/\/ \u83b7\u53d6\u961f\u5217\u4e2d\u7684\u7b2c\u4e00\u4e2a\u8bf7\u6c42
\n m_workqueue.pop_front(); \/\/ \u4ece\u961f\u5217\u4e2d\u79fb\u9664\u8bf7\u6c42
\n m_queuelocker.unlock();<\/p>\n
\/\/\u5982\u679c\u8bf7\u6c42\u4e3a\u7a7a，\u8df3\u8fc7\u5f53\u524d\u5faa\u73af\u8fdb\u5165\u4e0b\u4e00\u6b21，\u9632\u6b62\u7a0b\u5e8f\u5d29\u6e83
\n if (!request)
\n continue;<\/p>\n
\/\/ \u6839\u636e actor_model \u9009\u62e9\u4e0d\u540c\u7684\u5904\u7406\u65b9\u5f0f
\n if (1 == m_actor_model) \/\/ Reactor \u6a21\u5f0f
\n {
\n if (0 == request->m_state) \/\/ \u8bfb\u53d6\u8bf7\u6c42
\n {
\n if (request->read_once()) \/\/ \u8bfb\u53d6\u6210\u529f
\n {
\n request->improv = 1; \/\/ \u8bbe\u7f6e\u8bf7\u6c42\u6539\u4e3a\u6539\u8fdb\u72b6\u6001
\n connectionRAII mysqlcon(&request->mysql, m_connPool); \/\/ \u83b7\u53d6\u6570\u636e\u5e93\u8fde\u63a5
\n request->process(); \/\/ \u5904\u7406\u8bf7\u6c42
\n }
\n else
\n {
\n request->improv = 1;
\n request->timer_flag = 1; \/\/ \u8bf7\u6c42\u8bfb\u53d6\u5931\u8d25，\u8bbe\u7f6e\u8d85\u65f6\u6807\u5fd7
\n }
\n }
\n else \/\/ \u5199\u5165\u8bf7\u6c42
\n {
\n if (request->write()) \/\/ \u5199\u5165\u6210\u529f
\n {
\n request->improv = 1;
\n }
\n else
\n {
\n request->improv = 1;
\n request->timer_flag = 1; \/\/ \u8bf7\u6c42\u5199\u5165\u5931\u8d25，\u8bbe\u7f6e\u8d85\u65f6\u6807\u5fd7
\n }
\n }
\n }
\n else \/\/ Proactor \u6a21\u5f0f
\n {
\n connectionRAII mysqlcon(&request->mysql, m_connPool);
\n request->process(); \/\/ \u5904\u7406\u8bf7\u6c42
\n }
\n }
\n}<\/p>\n
http\u8fde\u63a5\u5904\u7406\u7c7b<\/p>\n
\u6839\u636e\u72b6\u6001\u8f6c\u79fb,\u901a\u8fc7\u4e3b\u4ece\u72b6\u6001\u673a\u5c01\u88c5\u4e86http\u8fde\u63a5\u7c7b\u3002\u5176\u4e2d,\u4e3b\u72b6\u6001\u673a\u5728\u5185\u90e8\u8c03\u7528\u4ece\u72b6\u6001\u673a,\u4ece\u72b6\u6001\u673a\u5c06\u5904\u7406\u72b6\u6001\u548c\u6570\u636e\u4f20\u7ed9\u4e3b\u72b6\u6001\u673a<\/p>\n
#ifndef HTTPCONNECTION_H
\n#define HTTPCONNECTION_H<\/p>\n
\/\/ \u5305\u542b\u5934\u6587\u4ef6，\u63d0\u4f9b\u7cfb\u7edf\u8c03\u7528\u3001\u7f51\u7edc\u529f\u80fd\u548c\u5176\u4ed6\u64cd\u4f5c\u6240\u9700\u7684\u5e93
\n#include <unistd.h>
\n#include <signal.h>
\n#include <sys\/types.h>
\n#include <sys\/epoll.h>
\n#include <fcntl.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include <assert.h>
\n#include <sys\/stat.h>
\n#include <string.h>
\n#include <pthread.h>
\n#include <stdio.h>
\n#include <stdlib.h>
\n#include <sys\/mman.h>
\n#include <stdarg.h>
\n#include <errno.h>
\n#include <sys\/wait.h>
\n#include <sys\/uio.h>
\n#include <map><\/p>\n
#include "..\/lock\/locker.h" \/\/ \u9501\u7684\u64cd\u4f5c
\n#include "..\/CGImysql\/sql_connection_pool.h" \/\/ MySQL\u8fde\u63a5\u6c60
\n#include "..\/timer\/lst_timer.h" \/\/ \u5b9a\u65f6\u5668
\n#include "..\/log\/log.h" \/\/ \u65e5\u5fd7\u7ba1\u7406<\/p>\n
class http_conn
\n{
\npublic:
\n \/\/ \u5b9a\u4e49\u5e38\u91cf
\n static const int FILENAME_LEN = 200; \/\/ \u6587\u4ef6\u540d\u6700\u5927\u957f\u5ea6
\n static const int READ_BUFFER_SIZE = 2048; \/\/ \u8bfb\u7f13\u51b2\u533a\u5927\u5c0f
\n static const int WRITE_BUFFER_SIZE = 1024; \/\/ \u5199\u7f13\u51b2\u533a\u5927\u5c0f<\/p>\n
\/\/ HTTP\u8bf7\u6c42\u7684\u65b9\u6cd5
\n enum METHOD
\n {
\n GET = 0,
\n POST,
\n HEAD,
\n PUT,
\n DELETE,
\n TRACE,
\n OPTIONS,
\n CONNECT,
\n PATH
\n };<\/p>\n
\/\/ \u68c0\u67e5\u8bf7\u6c42\u7684\u4e0d\u540c\u72b6\u6001
\n enum CHECK_STATE
\n {
\n CHECK_STATE_REQUESTLINE = 0, \/\/ \u8bf7\u6c42\u884c\u68c0\u67e5\u72b6\u6001
\n CHECK_STATE_HEADER, \/\/ \u8bf7\u6c42\u5934\u68c0\u67e5\u72b6\u6001
\n CHECK_STATE_CONTENT \/\/ \u8bf7\u6c42\u5185\u5bb9\u68c0\u67e5\u72b6\u6001
\n };<\/p>\n
\/\/ HTTP\u72b6\u6001\u7801
\n enum HTTP_CODE
\n {
\n NO_REQUEST, \/\/ \u6ca1\u6709\u8bf7\u6c42
\n GET_REQUEST, \/\/ GET \u8bf7\u6c42
\n BAD_REQUEST, \/\/ \u9519\u8bef\u8bf7\u6c42
\n NO_RESOURCE, \/\/ \u65e0\u8d44\u6e90
\n FORBIDDEN_REQUEST, \/\/ \u7981\u6b62\u8bf7\u6c42
\n FILE_REQUEST, \/\/ \u6587\u4ef6\u8bf7\u6c42
\n INTERNAL_ERROR, \/\/ \u5185\u90e8\u9519\u8bef
\n CLOSED_CONNECTION \/\/ \u5173\u95ed\u8fde\u63a5
\n };<\/p>\n
\/\/ \u884c\u7684\u89e3\u6790\u72b6\u6001
\n enum LINE_STATUS
\n {
\n LINE_OK = 0, \/\/ \u884c\u683c\u5f0f\u6b63\u786e
\n LINE_BAD, \/\/ \u884c\u683c\u5f0f\u9519\u8bef
\n LINE_OPEN \/\/ \u884c\u672a\u5b8c\u5168\u63a5\u6536
\n };<\/p>\n
public:
\n http_conn() {} \/\/ \u6784\u9020\u51fd\u6570
\n ~http_conn() {} \/\/ \u6790\u6784\u51fd\u6570<\/p>\n
public:
\n \/\/ \u521d\u59cb\u5316 HTTP \u8fde\u63a5
\n void init(int sockfd, const sockaddr_in &addr, char *root, int trigmode, int close_log, string user, string passwd, string sqlname);
\n \/\/ \u5173\u95ed\u8fde\u63a5
\n void close_conn(bool real_close = true);
\n \/\/ \u5904\u7406\u8bf7\u6c42
\n void process();
\n \/\/ \u8bfb\u53d6\u8bf7\u6c42\u6570\u636e
\n bool read_once();
\n \/\/ \u5199\u54cd\u5e94\u6570\u636e
\n bool write();
\n \/\/ \u83b7\u53d6\u5ba2\u6237\u7aef\u7684\u5730\u5740
\n sockaddr_in *get_address()
\n {
\n return &m_address;
\n }
\n \/\/ \u521d\u59cb\u5316\u6570\u636e\u5e93\u8fde\u63a5
\n void initmysql_result(connection_pool *connPool);<\/p>\n
\/\/ \u5b9a\u65f6\u5668\u6807\u5fd7\u548c\u6539\u8fdb\u6807\u5fd7
\n int timer_flag;
\n int improv;<\/p>\n
private:
\n \/\/ \u5185\u90e8\u521d\u59cb\u5316\u51fd\u6570
\n void init();
\n \/\/ \u5904\u7406\u8bfb\u53d6\u8bf7\u6c42\u7684\u51fd\u6570
\n HTTP_CODE process_read();
\n \/\/ \u5904\u7406\u5199\u5165\u54cd\u5e94\u7684\u51fd\u6570
\n bool process_write(HTTP_CODE ret);
\n \/\/ \u89e3\u6790\u8bf7\u6c42\u884c
\n HTTP_CODE parse_request_line(char *text);
\n \/\/ \u89e3\u6790\u8bf7\u6c42\u5934
\n HTTP_CODE parse_headers(char *text);
\n \/\/ \u89e3\u6790\u8bf7\u6c42\u5185\u5bb9
\n HTTP_CODE parse_content(char *text);
\n \/\/ \u6267\u884c\u8bf7\u6c42
\n HTTP_CODE do_request();
\n \/\/ \u83b7\u53d6\u5f53\u524d\u884c\u7684\u6307\u9488
\n char *get_line() { return m_read_buf + m_start_line; };
\n \/\/ \u89e3\u6790\u4e00\u884c\u6570\u636e
\n LINE_STATUS parse_line();
\n \/\/ \u89e3\u9664\u5185\u5b58\u6620\u5c04
\n void unmap();
\n \/\/ \u6dfb\u52a0\u54cd\u5e94\u5934
\n bool add_response(const char *format, …);
\n \/\/ \u6dfb\u52a0\u54cd\u5e94\u5185\u5bb9
\n bool add_content(const char *content);
\n \/\/ \u6dfb\u52a0\u72b6\u6001\u884c
\n bool add_status_line(int status, const char *title);
\n \/\/ \u6dfb\u52a0\u54cd\u5e94\u5934
\n bool add_headers(int content_length);
\n \/\/ \u6dfb\u52a0\u5185\u5bb9\u7c7b\u578b
\n bool add_content_type();
\n \/\/ \u6dfb\u52a0\u5185\u5bb9\u957f\u5ea6
\n bool add_content_length(int content_length);
\n \/\/ \u6dfb\u52a0\u8fde\u63a5\u72b6\u6001
\n bool add_linger();
\n \/\/ \u6dfb\u52a0\u7a7a\u884c
\n bool add_blank_line();<\/p>\n
public:
\n \/\/ \u9759\u6001\u6210\u5458\u53d8\u91cf，\u6240\u6709 http_conn \u5bf9\u8c61\u5171\u4eab
\n static int m_epollfd; \/\/ epoll \u6587\u4ef6\u63cf\u8ff0\u7b26，\u7528\u4e8e\u4e8b\u4ef6\u901a\u77e5
\n static int m_user_count; \/\/ \u5f53\u524d\u8fde\u63a5\u7684\u7528\u6237\u6570<\/p>\n
MYSQL *mysql; \/\/ MySQL \u6570\u636e\u5e93\u8fde\u63a5
\n int m_state; \/\/ \u8bf7\u6c42\u7684\u72b6\u6001（\u8bfb\u4e3a 0，\u5199\u4e3a 1）<\/p>\n
private:
\n int m_sockfd; \/\/ \u5ba2\u6237\u7aef socket \u6587\u4ef6\u63cf\u8ff0\u7b26
\n sockaddr_in m_address; \/\/ \u5ba2\u6237\u7aef\u5730\u5740\u4fe1\u606f
\n char m_read_buf[READ_BUFFER_SIZE]; \/\/ \u8bfb\u7f13\u51b2\u533a
\n long m_read_idx; \/\/ \u5f53\u524d\u8bfb\u53d6\u5230\u7f13\u51b2\u533a\u7684\u5b57\u8282\u6570
\n long m_checked_idx; \/\/ \u5df2\u68c0\u67e5\u7684\u5b57\u8282\u6570
\n int m_start_line; \/\/ \u5f53\u524d\u884c\u7684\u8d77\u59cb\u4f4d\u7f6e
\n char m_write_buf[WRITE_BUFFER_SIZE]; \/\/ \u5199\u7f13\u51b2\u533a
\n int m_write_idx; \/\/ \u5f53\u524d\u5199\u5165\u7684\u5b57\u8282\u6570
\n CHECK_STATE m_check_state; \/\/ \u5f53\u524d\u8bf7\u6c42\u7684\u68c0\u67e5\u72b6\u6001
\n METHOD m_method; \/\/ \u8bf7\u6c42\u65b9\u6cd5（GET\u3001POST\u7b49）
\n char m_real_file[FILENAME_LEN]; \/\/ \u8bf7\u6c42\u7684\u6587\u4ef6\u8def\u5f84
\n char *m_url; \/\/ \u8bf7\u6c42\u7684URL
\n char *m_version; \/\/ HTTP\u7248\u672c
\n char *m_host; \/\/ Host\u5934
\n long m_content_length; \/\/ \u5185\u5bb9\u957f\u5ea6
\n bool m_linger; \/\/ \u662f\u5426\u4fdd\u6301\u8fde\u63a5
\n char *m_file_address; \/\/ \u6587\u4ef6\u5185\u5b58\u5730\u5740
\n struct stat m_file_stat; \/\/ \u6587\u4ef6\u72b6\u6001
\n struct iovec m_iv[2]; \/\/ \u7528\u4e8ewritev\u7684\u5199\u7f13\u51b2\u533a
\n int m_iv_count; \/\/ \u5199\u7f13\u51b2\u533a\u6570\u91cf
\n int cgi; \/\/ \u662f\u5426\u542f\u7528POST\u65b9\u6cd5
\n char *m_string; \/\/ \u5b58\u50a8\u8bf7\u6c42\u5934\u6570\u636e
\n int bytes_to_send; \/\/ \u8981\u53d1\u9001\u7684\u5b57\u8282\u6570
\n int bytes_have_send; \/\/ \u5df2\u53d1\u9001\u7684\u5b57\u8282\u6570
\n char *doc_root; \/\/ \u7f51\u7ad9\u6839\u76ee\u5f55<\/p>\n
\/\/ \u5b58\u50a8\u7528\u6237\u4fe1\u606f\u7684map
\n map<string, string> m_users;<\/p>\n
\/\/ \u914d\u7f6e\u76f8\u5173
\n int m_TRIGMode; \/\/ \u89e6\u53d1\u6a21\u5f0f
\n int m_close_log; \/\/ \u662f\u5426\u5173\u95ed\u65e5\u5fd7<\/p>\n
\/\/ \u6570\u636e\u5e93\u8fde\u63a5\u7684\u914d\u7f6e\u4fe1\u606f
\n char sql_user[100];
\n char sql_passwd[100];
\n char sql_name[100];
\n};<\/p>\n
#endif<\/p>\n
\u5e38\u91cf\u5b9a\u4e49：<\/p>\n
\u679a\u4e3e\u7c7b\u578b：<\/p>\n
\u51fd\u6570：<\/p>\n
MySQL\u76f8\u5173：<\/p>\n
\u6587\u4ef6\u76f8\u5173：<\/p>\n
\u5b9a\u65f6\u5668\u548c\u89e6\u53d1\u6a21\u5f0f：<\/p>\n
#include "http_conn.h"<\/p>\n
#include <mysql\/mysql.h>
\n#include <fstream><\/p>\n
\/\/ \u5b9a\u4e49 HTTP \u54cd\u5e94\u7684\u4e00\u4e9b\u72b6\u6001\u4fe1\u606f
\nconst char *ok_200_title = "OK"; \/\/ \u72b6\u6001\u7801 200 \u7684\u54cd\u5e94\u6807\u9898
\nconst char *error_400_title = "Bad Request"; \/\/ \u72b6\u6001\u7801 400 \u7684\u54cd\u5e94\u6807\u9898
\nconst char *error_400_form = "Your request has bad syntax or is inherently impossible to satisfy.\\\\n"; \/\/ \u72b6\u6001\u7801 400 \u9519\u8bef\u4fe1\u606f
\nconst char *error_403_title = "Forbidden"; \/\/ \u72b6\u6001\u7801 403 \u7684\u54cd\u5e94\u6807\u9898
\nconst char *error_403_form = "You do not have permission to get file from this server.\\\\n"; \/\/ \u72b6\u6001\u7801 403 \u9519\u8bef\u4fe1\u606f
\nconst char *error_404_title = "Not Found"; \/\/ \u72b6\u6001\u7801 404 \u7684\u54cd\u5e94\u6807\u9898
\nconst char *error_404_form = "The requested file was not found on this server.\\\\n"; \/\/ \u72b6\u6001\u7801 404 \u9519\u8bef\u4fe1\u606f
\nconst char *error_500_title = "Internal Error"; \/\/ \u72b6\u6001\u7801 500 \u7684\u54cd\u5e94\u6807\u9898
\nconst char *error_500_form = "There was an unusual problem serving the request file.\\\\n"; \/\/ \u72b6\u6001\u7801 500 \u9519\u8bef\u4fe1\u606f<\/p>\n
\u628a\u6570\u636e\u5e93\u4e2d\u4fdd\u5b58\u7684user\u548cpassword\u6620\u5c04\u5012map\u4e2d，map\u7684\u7ed3\u6784\u4e3a：<\/p>\n
map<string, string> users; <\/p>\n
string \u7c7b\u578b\u7684 key \u8868\u793a\u7528\u6237\u540d，value \u8868\u793a\u5bc6\u7801\u3002\u8fd9\u6837\u5c31\u53ef\u4ee5\u901a\u8fc7\u7528\u6237\u540d\u5728 users map \u4e2d\u67e5\u627e\u5bf9\u5e94\u7684\u5bc6\u7801，\u4ece\u800c\u5b9e\u73b0\u7b80\u5355\u7684\u7528\u6237\u9a8c\u8bc1\u673a\u5236<\/p>\n
connectionRAII mysqlcon(&mysql, connPool) \u662f\u4e00\u4e2a\u6808\u5bf9\u8c61，\u5b83\u7684\u6784\u9020\u51fd\u6570\u4f1a\u4ece\u6570\u636e\u5e93\u8fde\u63a5\u6c60 connPool \u4e2d\u83b7\u53d6\u4e00\u4e2a MySQL \u8fde\u63a5，\u5e76\u5c06\u5176\u8d4b\u503c\u7ed9 mysql\u3002connectionRAII \u53ef\u80fd\u662f\u4e00\u4e2a\u81ea\u5b9a\u4e49\u7684 RAII（\u8d44\u6e90\u83b7\u53d6\u5373\u521d\u59cb\u5316）\u7c7b，\u786e\u4fdd\u5728\u4f5c\u7528\u57df\u7ed3\u675f\u65f6\u81ea\u52a8\u91ca\u653e\u6570\u636e\u5e93\u8fde\u63a5\u3002<\/p>\n
mysql_query \u662f MySQL C API \u4e2d\u7684\u51fd\u6570，\u7528\u4e8e\u6267\u884c SQL \u67e5\u8be2\u3002\u5b83\u6267\u884c\u67e5\u8be2 "SELECT username,passwd FROM user"，\u5373\u4ece user \u8868\u4e2d\u9009\u62e9 username \u548c passwd \u5b57\u6bb5\u00a0<\/p>\n
mysql_store_result(mysql) \u83b7\u53d6\u67e5\u8be2\u7ed3\u679c\u5e76\u8fd4\u56de MYSQL_RES \u7c7b\u578b\u7684\u6307\u9488 result\u3002\u8fd9\u4e2a\u6307\u9488\u6307\u5411\u5b58\u50a8\u4e86 SQL \u67e5\u8be2\u7ed3\u679c\u7684\u7ed3\u6784\u4f53\u3002\u00a0<\/p>\n
mysql_num_fields(result) \u8fd4\u56de\u7ed3\u679c\u96c6\u4e2d\u7684\u5b57\u6bb5（\u5217）\u6570，\u5373 user \u8868\u4e2d\u7684\u5217\u6570\u3002\u00a0<\/p>\n
mysql_fetch_fields(result) \u8fd4\u56de\u4e00\u4e2a MYSQL_FIELD \u6570\u7ec4，\u5305\u542b\u6bcf\u4e2a\u5b57\u6bb5\u7684\u5143\u6570\u636e（\u4f8b\u5982\u5b57\u6bb5\u540d\u3001\u6570\u636e\u7c7b\u578b\u7b49）\u3002\u00a0<\/p>\n
void http_conn::initmysql_result(connection_pool *connPool)
\n{
\n \/\/\u5148\u4ece\u8fde\u63a5\u6c60\u4e2d\u53d6\u4e00\u4e2a\u8fde\u63a5
\n MYSQL *mysql = NULL;
\n connectionRAII mysqlcon(&mysql, connPool);<\/p>\n
\/\/\u5728user\u8868\u4e2d\u68c0\u7d22username，passwd\u6570\u636e，\u6d4f\u89c8\u5668\u7aef\u8f93\u5165
\n if (mysql_query(mysql, "SELECT username,passwd FROM user"))
\n {
\n LOG_ERROR("SELECT error:%s\\\\n", mysql_error(mysql));
\n }<\/p>\n
\/\/\u4ece\u8868\u4e2d\u68c0\u7d22\u5b8c\u6574\u7684\u7ed3\u679c\u96c6
\n MYSQL_RES *result = mysql_store_result(mysql);<\/p>\n
\/\/\u8fd4\u56de\u7ed3\u679c\u96c6\u4e2d\u7684\u5217\u6570
\n int num_fields = mysql_num_fields(result);<\/p>\n
\/\/\u8fd4\u56de\u6240\u6709\u5b57\u6bb5\u7ed3\u6784\u7684\u6570\u7ec4
\n MYSQL_FIELD *fields = mysql_fetch_fields(result);<\/p>\n
\/\/\u4ece\u7ed3\u679c\u96c6\u4e2d\u83b7\u53d6\u4e0b\u4e00\u884c，\u5c06\u5bf9\u5e94\u7684\u7528\u6237\u540d\u548c\u5bc6\u7801，\u5b58\u5165map\u4e2d
\n while (MYSQL_ROW row = mysql_fetch_row(result))
\n {
\n string temp1(row[0]);
\n string temp2(row[1]);
\n users[temp1] = temp2;
\n }
\n} <\/p>\n
\u8bbe\u7f6e\u975e\u963b\u585e<\/p>\n
\/\/\u5bf9\u6587\u4ef6\u63cf\u8ff0\u7b26\u8bbe\u7f6e\u975e\u963b\u585e
\nint setnonblocking(int fd)
\n{
\n int old_option = fcntl(fd, F_GETFL);
\n int new_option = old_option | O_NONBLOCK;
\n fcntl(fd, F_SETFL, new_option);
\n return old_option;
\n} <\/p>\n
\/\/\u5c06\u5185\u6838\u4e8b\u4ef6\u8868\u6ce8\u518c\u8bfb\u4e8b\u4ef6，ET\u6a21\u5f0f，\u9009\u62e9\u5f00\u542fEPOLLONESHOT
\nvoid addfd(int epollfd, int fd, bool one_shot, int TRIGMode)
\n{
\n epoll_event event;
\n event.data.fd = fd;<\/p>\n
if (1 == TRIGMode)\/\/\u6839\u636etrig\u6a21\u5f0f\u8bbe\u7f6e\u4e3aET\u6216\u8005LT\u89e6\u53d1\u6a21\u5f0f
\n event.events = EPOLLIN | EPOLLET | EPOLLRDHUP;\/\/ET
\n else
\n event.events = EPOLLIN | EPOLLRDHUP;\/\/LT<\/p>\n
if (one_shot)\/\/\u9009\u62e9\u5f00\u542foneshot
\n event.events |= EPOLLONESHOT;
\n epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &event);\/\/\u6302\u4e0a\u7ea2\u9ed1\u6811
\n setnonblocking(fd);\/\/\u8bbe\u7f6e\u975e\u963b\u585e
\n} <\/p>\n
\/\/\u4ece\u5185\u6838\u65f6\u95f4\u8868\u5220\u9664\u63cf\u8ff0\u7b26
\nvoid removefd(int epollfd, int fd)
\n{
\n epoll_ctl(epollfd, EPOLL_CTL_DEL, fd, 0);
\n close(fd);
\n} <\/p>\n
\u4e0d\u540c\u89e6\u53d1\u6a21\u5f0f\u4e0d\u540cevent<\/p>\n
void modfd(int epollfd, int fd, int ev, int TRIGMode)
\n{
\n epoll_event event;
\n event.data.fd = fd;<\/p>\n
if (1 == TRIGMode)
\n event.events = ev | EPOLLET | EPOLLONESHOT | EPOLLRDHUP;
\n else
\n event.events = ev | EPOLLONESHOT | EPOLLRDHUP;<\/p>\n
epoll_ctl(epollfd, EPOLL_CTL_MOD, fd, &event);
\n} <\/p>\n
\u7c7b\u5916\u521d\u59cb\u5316\u9759\u6001\u53d8\u91cf：<\/p>\n
int http_conn::m_user_count = 0;
\nint http_conn::m_epollfd = -1; <\/p>\n
m_user_count\u00a0\u7528\u4e8e\u8bb0\u5f55\u5f53\u524d\u6d3b\u52a8\u7684 http_conn \u5b9e\u4f8b\u7684\u6570\u91cf：\u8fde\u63a5\u7684\u7528\u6237\u6570\u3002<\/p>\n
m_epollfd \u662f\u4e0e epoll \u76f8\u5173\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26，\u901a\u5e38\u7528\u4e8e\u5904\u7406 I\/O \u591a\u8def\u590d\u7528\u3002-1 \u662f\u4e00\u4e2a\u5e38\u7528\u7684\u8868\u793a\u672a\u521d\u59cb\u5316\u6216\u51fa\u9519\u7684\u6807\u5fd7\u3002<\/p>\n
void http_conn::close_conn(bool real_close)\/\/real_close\u8868\u793a\u662f\u5426\u9700\u8981\u6267\u884c\u5173\u95ed\u64cd\u4f5c
\n{
\n if (real_close && (m_sockfd != -1))\/\/m_sockfd != -1\u8868\u793a\u5f53\u524d\u5957\u63a5\u5b57\u662f\u5426\u6709\u6548
\n {
\n printf("close %d\\\\n", m_sockfd);
\n removefd(m_epollfd, m_sockfd);\/\/\u79fb\u9664\u6587\u4ef6\u63cf\u8ff0\u7b26
\n m_sockfd = -1;\/\/\u8868\u793a\u8fde\u63a5\u5173\u95ed
\n m_user_count–;\/\/\u8fde\u63a5\u6570\u91cf-1
\n }
\n} <\/p>\n
\u521d\u59cb\u5316\u4e00\u4e2a\u65b0\u7684http\u8fde\u63a5\u5bf9\u8c61\u00a0，\u628a\u5957\u63a5\u5b57\u548c\u5730\u5740\u4f20\u7ed9\u6210\u5458\u53d8\u91cf，\u8c03\u7528addfd\u5c06\u5f53\u524d\u5957\u63a5\u5b57\u52a0\u5230epoll\u5b9e\u4f8b\u4e2d\u53bb，\u589e\u52a0\u6d3b\u8dc3\u8fde\u63a5\u6570，\u914d\u7f6e\u7f51\u7ad9\u6839\u76ee\u5f55\u3001\u89e6\u53d1\u6a21\u5f0f\u3001\u65e5\u5fd7\u6807\u5fd7\u3001\u6570\u636e\u5e93\u8fde\u63a5\u4fe1\u606f\u7b49，\u8c03\u7528 init \u51fd\u6570\u5b8c\u6210\u5176\u4ed6\u5185\u90e8\u521d\u59cb\u5316\u5de5\u4f5c\u3002<\/p>\n
void http_conn::init(int sockfd, const sockaddr_in &addr, char *root, int TRIGMode,
\n int close_log, string user, string passwd, string sqlname)
\n{
\n m_sockfd = sockfd;
\n m_address = addr;<\/p>\n
addfd(m_epollfd, sockfd, true, m_TRIGMode);\/\/\u6ce8\u518c\u8bfb\u4e8b\u4ef6
\n m_user_count++;\/\/\u8fde\u63a5\u6570\u91cf+1<\/p>\n
\/\/\u5f53\u6d4f\u89c8\u5668\u51fa\u73b0\u8fde\u63a5\u91cd\u7f6e\u65f6，\u53ef\u80fd\u662f\u7f51\u7ad9\u6839\u76ee\u5f55\u51fa\u9519\u6216http\u54cd\u5e94\u683c\u5f0f\u51fa\u9519\u6216\u8005\u8bbf\u95ee\u7684\u6587\u4ef6\u4e2d\u5185\u5bb9\u5b8c\u5168\u4e3a\u7a7a
\n doc_root = root;
\n m_TRIGMode = TRIGMode;
\n m_close_log = close_log;<\/p>\n
strcpy(sql_user, user.c_str());
\n strcpy(sql_passwd, passwd.c_str());\/\/passwd \u8d4b\u503c\u7ed9\u6210\u5458\u53d8\u91cf sql_passwd
\n strcpy(sql_name, sqlname.c_str());\/\/sqlname \u8d4b\u503c\u7ed9\u6210\u5458\u53d8\u91cf sql_name<\/p>\n
init();\/\/\u4e0b\u9762\u7684void init（）\u8fdb\u884c\u5269\u4e0b\u7684\u521d\u59cb\u5316\u5de5\u4f5c
\n} <\/p>\n
\u00a0\u4f5c\u7528\u4e8e\u524d\u9762\u7684init\u4e2d<\/p>\n
\/\/ HTTP\u8fde\u63a5\u7684\u521d\u59cb\u5316\u51fd\u6570，\u8bbe\u7f6e\u6240\u6709\u4e0eHTTP\u8bf7\u6c42\u76f8\u5173\u7684\u6210\u5458\u53d8\u91cf\u7684\u521d\u59cb\u72b6\u6001
\nvoid http_conn::init()
\n{
\n mysql = NULL; \/\/ \u5c06MySQL\u8fde\u63a5\u6307\u9488\u521d\u59cb\u5316\u4e3aNULL，\u8868\u793a\u5c1a\u672a\u8fde\u63a5\u5230\u6570\u636e\u5e93
\n bytes_to_send = 0; \/\/ \u8bbe\u7f6e\u5f85\u53d1\u9001\u7684\u5b57\u8282\u6570\u4e3a0
\n bytes_have_send = 0; \/\/ \u8bbe\u7f6e\u5df2\u53d1\u9001\u7684\u5b57\u8282\u6570\u4e3a0
\n m_check_state = CHECK_STATE_REQUESTLINE; \/\/ \u8bbe\u7f6e\u89e3\u6790\u72b6\u6001\u673a\u7684\u521d\u59cb\u72b6\u6001\u4e3a\u8bf7\u6c42\u884c\u5206\u6790\u72b6\u6001
\n m_linger = false; \/\/ \u8bbe\u7f6eHTTP\u8bf7\u6c42\u4e0d\u4f7f\u7528\u957f\u8fde\u63a5（\u9ed8\u8ba4\u4e3a\u77ed\u8fde\u63a5）
\n m_method = GET; \/\/ \u9ed8\u8ba4\u4e3aGET\u65b9\u6cd5
\n m_url = 0; \/\/ \u8bbe\u7f6eURL\u4e3aNULL，\u8868\u793a\u6ca1\u6709\u8bbe\u7f6e\u8bf7\u6c42\u7684URL
\n m_version = 0; \/\/ \u8bbe\u7f6eHTTP\u7248\u672c\u4e3aNULL，\u8868\u793a\u672a\u6307\u5b9aHTTP\u7248\u672c
\n m_content_length = 0; \/\/ \u8bbe\u7f6e\u5185\u5bb9\u957f\u5ea6\u4e3a0
\n m_host = 0; \/\/ \u8bbe\u7f6eHost\u5b57\u6bb5\u4e3aNULL
\n m_start_line = 0; \/\/ \u8bf7\u6c42\u884c\u7684\u8d77\u59cb\u4f4d\u7f6e\u4e3a0
\n m_checked_idx = 0; \/\/ \u5f53\u524d\u5206\u6790\u7684\u5b57\u7b26\u4f4d\u7f6e\u4e3a0
\n m_read_idx = 0; \/\/ \u5f53\u524d\u8bfb\u53d6\u7684\u5b57\u8282\u4f4d\u7f6e\u4e3a0
\n m_write_idx = 0; \/\/ \u5f53\u524d\u5199\u5165\u7684\u5b57\u8282\u4f4d\u7f6e\u4e3a0
\n cgi = 0; \/\/ \u9ed8\u8ba4\u4e0d\u542f\u7528CGI\u529f\u80fd（\u5982POST\u8bf7\u6c42）
\n m_state = 0; \/\/ \u8bf7\u6c42\u7684\u72b6\u6001\u521d\u59cb\u5316\u4e3a0
\n timer_flag = 0; \/\/ \u5b9a\u65f6\u5668\u6807\u5fd7\u521d\u59cb\u5316\u4e3a0，\u8868\u793a\u6ca1\u6709\u5b9a\u65f6\u5668\u6807\u8bb0
\n improv = 0; \/\/ \u6539\u8fdb\u6807\u5fd7\u521d\u59cb\u5316\u4e3a0，\u8868\u793a\u6ca1\u6709\u6539\u8fdb\u72b6\u6001<\/p>\n
memset(m_read_buf, '\\\\0', READ_BUFFER_SIZE); \/\/ \u6e05\u7a7a\u8bfb\u53d6\u7f13\u5b58\u533a，\u5c06\u5176\u521d\u59cb\u5316\u4e3a\u5168\u96f6
\n memset(m_write_buf, '\\\\0', WRITE_BUFFER_SIZE); \/\/ \u6e05\u7a7a\u5199\u5165\u7f13\u5b58\u533a，\u5c06\u5176\u521d\u59cb\u5316\u4e3a\u5168\u96f6
\n memset(m_real_file, '\\\\0', FILENAME_LEN); \/\/ \u6e05\u7a7a\u5b58\u50a8\u771f\u5b9e\u6587\u4ef6\u8def\u5f84\u7684\u5b57\u7b26\u6570\u7ec4
\n}<\/p>\n
char temp;
\nfor (; m_checked_idx < m_read_idx; ++m_checked_idx)
\n{
\n temp = m_read_buf[m_checked_idx]; \/\/ \u83b7\u53d6\u5f53\u524d\u8981\u68c0\u67e5\u7684\u5b57\u7b26
\n if (temp == '\\\\r') \/\/ \u68c0\u67e5\u662f\u5426\u9047\u5230\u56de\u8f66\u7b26 '\\\\r'
\n {
\n if ((m_checked_idx + 1) == m_read_idx) \/\/ \u5982\u679c\u56de\u8f66\u7b26\u540e\u6ca1\u6709\u6362\u884c\u7b26，\u5219\u5f53\u524d\u884c\u672a\u7ed3\u675f
\n return LINE_OPEN; \/\/ \u8fd4\u56de LINE_OPEN，\u8868\u793a\u8fd9\u4e00\u884c\u6ca1\u6709\u7ed3\u675f，\u4ecd\u7136\u5728\u8bfb\u53d6\u4e2d
\n else if (m_read_buf[m_checked_idx + 1] == '\\\\n') \/\/ \u5982\u679c\u56de\u8f66\u7b26\u540e\u7d27\u8ddf\u7740\u6362\u884c\u7b26 '\\\\n'
\n {
\n m_read_buf[m_checked_idx++] = '\\\\0'; \/\/ \u5c06\u56de\u8f66\u7b26 '\\\\r' \u7f6e\u4e3a '\\\\0'，\u6807\u8bb0\u884c\u7ed3\u675f
\n m_read_buf[m_checked_idx++] = '\\\\0'; \/\/ \u5c06\u6362\u884c\u7b26 '\\\\n' \u7f6e\u4e3a '\\\\0'，\u6807\u8bb0\u884c\u7ed3\u675f
\n return LINE_OK; \/\/ \u8fd4\u56de LINE_OK，\u8868\u793a\u6210\u529f\u89e3\u6790\u51fa\u5b8c\u6574\u7684\u4e00\u884c
\n }
\n return LINE_BAD; \/\/ \u5982\u679c\u56de\u8f66\u7b26\u540e\u6ca1\u6709\u6362\u884c\u7b26，\u5219\u8fd4\u56de LINE_BAD，\u8868\u793a\u8be5\u884c\u683c\u5f0f\u9519\u8bef
\n }
\n else if (temp == '\\\\n') \/\/ \u68c0\u67e5\u662f\u5426\u9047\u5230\u6362\u884c\u7b26 '\\\\n'
\n {
\n if (m_checked_idx > 1 && m_read_buf[m_checked_idx – 1] == '\\\\r') \/\/ \u5982\u679c\u6362\u884c\u7b26\u524d\u6709\u56de\u8f66\u7b26 '\\\\r'
\n {
\n m_read_buf[m_checked_idx – 1] = '\\\\0'; \/\/ \u5c06\u56de\u8f66\u7b26 '\\\\r' \u7f6e\u4e3a '\\\\0'，\u6807\u8bb0\u884c\u7ed3\u675f
\n m_read_buf[m_checked_idx++] = '\\\\0'; \/\/ \u5c06\u6362\u884c\u7b26 '\\\\n' \u7f6e\u4e3a '\\\\0'，\u6807\u8bb0\u884c\u7ed3\u675f
\n return LINE_OK; \/\/ \u8fd4\u56de LINE_OK，\u8868\u793a\u6210\u529f\u89e3\u6790\u51fa\u5b8c\u6574\u7684\u4e00\u884c
\n }
\n return LINE_BAD; \/\/ \u5982\u679c\u6ca1\u6709\u56de\u8f66\u7b26\u524d\u7f00，\u5219\u8fd4\u56de LINE_BAD，\u8868\u793a\u8be5\u884c\u683c\u5f0f\u9519\u8bef
\n }
\n}
\nreturn LINE_OPEN; \/\/ \u5982\u679c\u6ca1\u6709\u627e\u5230\u56de\u8f66\u6362\u884c\u7b26，\u5219\u8fd4\u56de LINE_OPEN，\u8868\u793a\u8be5\u884c\u8fd8\u672a\u7ed3\u675f<\/p>\n
bool http_conn::read_once()
\n{
\n if (m_read_idx >= READ_BUFFER_SIZE)\/\/\u68c0\u67e5\u7f13\u51b2\u533a\u662f\u5426\u5df2\u7ecf\u586b\u6ee1
\n {
\n return false;
\n }
\n int bytes_read = 0;\/\/\u8bb0\u5f55\u672c\u6b21\u8bfb\u53d6\u5b57\u8282\u6570<\/p>\n
\/\/LT\u8bfb\u53d6\u6570\u636e
\n if (0 == m_TRIGMode)
\n {
\n bytes_read = recv(m_sockfd, m_read_buf + m_read_idx, READ_BUFFER_SIZE – m_read_idx, 0);\/\/m_read_buf + m_read_idx\u4e3a\u672c\u6b21\u6570\u636e\u5b58\u50a8\u4e0b\u6807
\n m_read_idx += bytes_read;\/\/\u66f4\u65b0\u4e0b\u6807<\/p>\n
if (bytes_read <= 0)\/\/\u672a\u8bfb\u51fa\u6570\u636e
\n {
\n return false;
\n }<\/p>\n
return true;
\n }
\n \/\/ET\u8bfb\u6570\u636e
\n else
\n {
\n while (true)\/\/\u5faa\u73af\u8bfb\u53d6\u6570\u636e，\u76f4\u81f3\u6ca1\u6709
\n {
\n bytes_read = recv(m_sockfd, m_read_buf + m_read_idx, READ_BUFFER_SIZE – m_read_idx, 0);
\n if (bytes_read == -1)
\n {
\n if (errno == EAGAIN || errno == EWOULDBLOCK)\/\/\u6682\u65f6\u6ca1\u6709\u53ef\u8bfb\u53d6\u7684\u6570\u636e，\u8df3\u51fa\u8fdb\u884c\u4e0b\u4e00\u6b21\u5faa\u73af
\n break;
\n return false;\/\/\u5176\u4ed6\u9519\u8bef\u5219\u8fd4\u56de\u8bfb\u53d6\u5931\u8d25
\n }
\n else if (bytes_read == 0)\/\/\u8fde\u63a5\u5173\u95ed
\n {
\n return false;
\n }
\n m_read_idx += bytes_read;\/\/\u66f4\u65b0\u4e0b\u6807
\n }
\n return true;
\n }
\n} <\/p>\n
\u89e3\u6790\u4f20\u5165http\u8bf7\u6c42\u5934，\u5047\u8bbe\u4f20\u5165\u7684\u662f\u00a0GET \/index.html HTTP\/1.1<\/span>\u00a0，\u51fd\u6570\u662f\u4ece\u5176\u4e2d\u53d6\u51fa HTTP \u65b9\u6cd5（GET）\u3001URL（\/index.html）\u548c\u7248\u672c（HTTP\/1.1）<\/p>\n http_conn::HTTP_CODE http_conn::parse_request_line(char *text) if (strncasecmp(m_url, "https:\/\/", 8) == 0) if (!m_url || m_url[0] != '\/') \u4f20\u5165\u7684text\u662f\u4e0a\u9762parse_line\u51fd\u6570\u5207\u5272\u51fa\u6765\u7684\u6bcf\u4e00\u884c\u7684\u5185\u5bb9<\/p>\n \u8be5\u51fd\u6570\u63a5\u6536\u4e00\u4e2a\u6307\u5411 HTTP \u5934\u90e8\u5b57\u6bb5\u7684\u5b57\u7b26\u4e32 text，\u7136\u540e\u89e3\u6790：<\/p>\n \u5982\u679c text \u4e3a\u7a7a\u884c，\u5219\u610f\u5473\u7740\u8bf7\u6c42\u5934\u89e3\u6790\u7ed3\u675f：<\/p>\n http_conn::HTTP_CODE http_conn::parse_headers(char *text) \u5f53\u8bfb\u53d6\u957f\u5ea6\u5927\u4e8e\u7b49\u4e8e\u8bf7\u6c42\u4f53\u957f\u5ea6+http\u5934\u90e8\u957f\u5ea6，\u5224\u65ad\u4e3a\u8bf7\u6c42\u4f53\u5b8c\u6574，\u8fdb\u884c\u5904\u7406<\/p>\n http_conn::HTTP_CODE http_conn::parse_content(char *text) http_conn::HTTP_CODE http_conn::process_read() \/\/ \u89e3\u6790 HTTP \u8bf7\u6c42\u7684\u6240\u6709\u884c switch (m_check_state) http_conn::HTTP_CODE http_conn::do_request() \/\/\u5904\u7406cgi \/\/\u6839\u636e\u6807\u5fd7\u5224\u65ad\u662f\u767b\u5f55\u68c0\u6d4b\u8fd8\u662f\u6ce8\u518c\u68c0\u6d4b char *m_url_real = (char *)malloc(sizeof(char) * 200); \/\/\u5c06\u7528\u6237\u540d\u548c\u5bc6\u7801\u63d0\u53d6\u51fa\u6765 int j = 0; if (*(p + 1) == '3') if (users.find(name) == users.end()) if (!res) if (*(p + 1) == '0') free(m_url_real); free(m_url_real); free(m_url_real); free(m_url_real); free(m_url_real); if (stat(m_real_file, &m_file_stat) < 0) if (!(m_file_stat.st_mode & S_IROTH)) if (S_ISDIR(m_file_stat.st_mode)) int fd = open(m_real_file, O_RDONLY); void http_conn::unmap() bool http_conn::write() \/\/ \u5982\u679c\u6ca1\u6709\u6570\u636e\u8981\u53d1\u9001，\u4fee\u6539 epoll \u4e8b\u4ef6\u4e3a EPOLLIN，\u5e76\u521d\u59cb\u5316\u8fde\u63a5 while (1) if (temp < 0) \/\/ \u66f4\u65b0\u5df2\u53d1\u9001\u7684\u5b57\u8282\u6570，\u5e76\u51cf\u5c11\u5269\u4f59\u8981\u53d1\u9001\u7684\u5b57\u8282\u6570 \/\/ \u5982\u679c\u5df2\u7ecf\u53d1\u9001\u5b8c\u4e86 m_iv[0] \u7f13\u51b2\u533a\u7684\u5185\u5bb9 \/\/ \u5982\u679c\u6240\u6709\u6570\u636e\u90fd\u5df2\u7ecf\u53d1\u9001\u5b8c \/\/ \u5982\u679c\u8fde\u63a5\u4fdd\u6301\u6d3b\u52a8\u72b6\u6001（HTTP\/1.1），\u5219\u7ee7\u7eed\u5904\u7406\u540e\u7eed\u8bf7\u6c42 \u901a\u8fc7 vsnprintf \u5904\u7406\u53ef\u53d8\u53c2\u6570，\u786e\u4fdd\u4e0d\u4f1a\u8d85\u51fa\u7f13\u51b2\u533a\u7684\u5927\u5c0f\u9650\u5236，\u5e76\u66f4\u65b0 m_write_idx \u6765\u8bb0\u5f55\u5199\u5165\u7684\u4f4d\u7f6e\u3002\u5982\u679c\u6dfb\u52a0\u6210\u529f，\u8fd4\u56de true；\u5982\u679c\u5931\u8d25（\u4f8b\u5982\u7f13\u51b2\u533a\u4e0d\u8db3\u4ee5\u5bb9\u7eb3\u6570\u636e），\u5219\u8fd4\u56de false<\/p>\n bool http_conn::add_response(const char *format, …) va_list arg_list; \/\/ \u4f7f\u7528 vsnprintf \u6765\u683c\u5f0f\u5316\u6570\u636e\u5e76\u5199\u5165 m_write_buf \u4e2d \/\/ \u68c0\u67e5\u683c\u5f0f\u5316\u540e\u7684\u957f\u5ea6\u662f\u5426\u8d85\u51fa\u4e86\u5269\u4f59\u7684\u7f13\u51b2\u533a\u5927\u5c0f \/\/ \u66f4\u65b0\u5199\u5165\u6570\u636e\u7684\u7d22\u5f15 va_end(arg_list); \/\/ \u7ed3\u675f\u53ef\u53d8\u53c2\u6570\u7684\u5904\u7406<\/p>\n \/\/ \u8bb0\u5f55\u65e5\u5fd7，\u8bb0\u5f55\u8bf7\u6c42\u7684\u54cd\u5e94\u5185\u5bb9 return true; \/\/\u6784\u5efa\u5e76\u6dfb\u52a0 HTTP \u54cd\u5e94\u7684\u72b6\u6001\u884c \/\/\u6dfb\u52a0\u54cd\u5e94\u5934\u90e8 \/\/\u6dfb\u52a0 Content-Length \u54cd\u5e94\u5934，\u6307\u793a\u54cd\u5e94\u4f53\u7684\u957f\u5ea6 \/\/\u6dfb\u52a0 Content-Type \u54cd\u5e94\u5934，\u6307\u793a\u54cd\u5e94\u4f53\u7684\u7c7b\u578b \/\/\u6dfb\u52a0 Connection \u54cd\u5e94\u5934，\u6307\u793a\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u5668\u4e4b\u95f4\u7684\u8fde\u63a5\u662f\u5426\u6301\u7eed \/\/\u6dfb\u52a0\u4e00\u4e2a\u7a7a\u884c，\u8868\u793a HTTP \u54cd\u5e94\u5934\u7684\u7ed3\u675f \/\/\u6dfb\u52a0\u54cd\u5e94\u4f53\u7684\u5185\u5bb9 bool http_conn::process_write(HTTP_CODE ret) void http_conn::process() \u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.7k\u6b21\uff0c\u70b9\u8d5e31\u6b21\uff0c\u6536\u85cf56\u6b21\u3002\u7ee7\u7eed\u89e3\u8bfb\uff1athreadpool.h http_conn.h http_conn.cpp\u6587\u4ef6\uff0c\u4e86\u89e3\u9879\u76ee\u4e2d\u7684\u7ebf\u7a0b\u6c60\u548c\u4efb\u52a1\u7ed3\u6784\u4f53<\/p>\n","protected":false},"author":2,"featured_media":35868,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[1351,43,44],"topic":[],"class_list":["post-35869","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-tingwebserver","tag-43","tag-44"],"yoast_head":"\n
\n{
\n m_url = strpbrk(text, " \\\\t");\/\/\u8fd4\u56de\u7b2c\u4e00\u4e2a\u7a7a\u683c\u7684\u4f4d\u7f6e
\n if (!m_url)
\n {
\n return BAD_REQUEST;
\n }
\n *m_url++ = '\\\\0';\/\/\u5c06\u7a7a\u683c\u8f6c\u5316\u4e3a\u5b57\u7b26\u4e32\u7ec8\u6b62\u7b26'\/0'
\n char *method = text;\/\/mothod\u6307\u5411\u8bf7\u6c42\u884c\u5f00\u59cb
\n if (strcasecmp(method, "GET") == 0)\/\/\u5339\u914d\u8bf7\u6c42\u5b57\u7b26
\n m_method = GET;
\n else if (strcasecmp(method, "POST") == 0)
\n {
\n m_method = POST;
\n cgi = 1;
\n }
\n else
\n return BAD_REQUEST;\/\/\u8bf4\u660e\u8bf7\u6c42\u7684\u65b9\u6cd5\u4e0d\u652f\u6301
\n m_url += strspn(m_url, " \\\\t");\/\/\u8df3\u8fc7\u524d\u9762\u7684\u5b57\u7b26，\u5f00\u59cbhttp\u8bf7\u6c42\u5904\u7406
\n m_version = strpbrk(m_url, " \\\\t");\/\/\u67e5\u627e\u7b2c\u4e00\u4e2a\u7a7a\u683c\u4f4d\u7f6e
\n if (!m_version)
\n return BAD_REQUEST;
\n *m_version++ = '\\\\0';
\n m_version += strspn(m_version, " \\\\t");
\n if (strcasecmp(m_version, "HTTP\/1.1") != 0)
\n return BAD_REQUEST;
\n if (strncasecmp(m_url, "http:\/\/", 7) == 0)
\n {
\n m_url += 7;
\n m_url = strchr(m_url, '\/');
\n }<\/p>\n
\n {
\n m_url += 8;
\n m_url = strchr(m_url, '\/');
\n }<\/p>\n
\n return BAD_REQUEST;
\n \/\/\u5f53url\u4e3a\/\u65f6，\u663e\u793a\u5224\u65ad\u754c\u9762
\n if (strlen(m_url) == 1)
\n strcat(m_url, "judge.html");
\n m_check_state = CHECK_STATE_HEADER;
\n return NO_REQUEST;
\n} <\/p>\n\u89e3\u6790http\u8bf7\u6c42\u7684\u5934\u90e8\u4fe1\u606f\u51fd\u6570：parse_headers：<\/h4>\n
\n
\n
\n{
\n if (text[0] == '\\\\0')\/\/\u8bfb\u53d6\u5230\u7a7a\u884c
\n {
\n if (m_content_length != 0)\/\/\u8bf7\u6c42\u5e26\u6709\u8bf7\u6c42\u4f53（post\u8bf7\u6c42）
\n {
\n m_check_state = CHECK_STATE_CONTENT;
\n return NO_REQUEST;
\n }
\n return GET_REQUEST;\/\/get\u8bf7\u6c42，\u76f4\u63a5\u8fd4\u56de\u8868\u793a\u8bf7\u6c42\u5b8c\u6210
\n }
\n else if (strncasecmp(text, "Connection:", 11) == 0)
\n {
\n text += 11;
\n text += strspn(text, " \\\\t");
\n if (strcasecmp(text, "keep-alive") == 0)\/\/\u8868\u793aHTTP\u662f\u6301\u4e45\u8fde\u63a5
\n {
\n m_linger = true;\/\/\u8868\u793a\u8fde\u63a5\u4e0d\u4f1a\u7acb\u5373\u5173\u95ed
\n }
\n }
\n else if (strncasecmp(text, "Content-length:", 15) == 0)\/\/\u6307\u5b9a\u8bf7\u6c42\u4f53\u957f\u5ea6，\u901a\u5e38\u7528\u4e8ePOST
\n {
\n text += 15;
\n text += strspn(text, " \\\\t");
\n m_content_length = atol(text);\/\/\u5b57\u7b26\u4e32\u8f6c\u5316\u4e3along\u7c7b\u578b
\n }
\n else if (strncasecmp(text, "Host:", 5) == 0)\/\/\u8bfb\u5165\u7684\u662fhost
\n {
\n text += 5;
\n text += strspn(text, " \\\\t");
\n m_host = text;\/\/\u4e3b\u673a\u540d\u4fdd\u7559\u5230\u53d8\u91cf\u4e2d
\n }
\n else
\n {
\n LOG_INFO("oop!unknow header: %s", text);\/\/\u5176\u4ed6\u4fe1\u606f
\n }
\n return NO_REQUEST;
\n}<\/p>\n\u5224\u65adhttp\u8bf7\u6c42\u662f\u5426\u88ab\u5b8c\u6574\u8bfb\u5165\u51fd\u6570：parse_conte<\/h4>\n
\n{
\n if (m_read_idx >= (m_content_length + m_checked_idx))
\n {
\n text[m_content_length] = '\\\\0';\/\/\u624b\u52a8\u6dfb\u52a0\u5b57\u7b26\u4e32\u7ec8\u6b62\u7b26
\n \/\/POST\u8bf7\u6c42\u4e2d\u6700\u540e\u4e3a\u8f93\u5165\u7684\u7528\u6237\u540d\u548c\u5bc6\u7801
\n m_string = text;\/\/\u628a\u8bf7\u6c42\u4f53\u7684\u6570\u636e\u5b58\u5165 m_string \u53d8\u91cf
\n return GET_REQUEST;
\n }
\n return NO_REQUEST;
\n} <\/p>\n\u89e3\u6790http\u4e3b\u4f53\u51fd\u6570：process_read<\/h4>\n
\n
\n
\u6b65\u9aa4m_check_statetext \u89e3\u6790\u5185\u5bb9ret \u89e3\u6790\u7ed3\u679c\u4e0b\u4e00\u6b65<\/tr>\n \n\n 1<\/td>\n CHECK_STATE_REQUESTLINE<\/td>\n POST \/login HTTP\/1.1<\/td>\n NO_REQUEST<\/td>\n \u8fdb\u5165 CHECK_STATE_HEADER<\/td>\n<\/tr>\n \n 2<\/td>\n CHECK_STATE_HEADER<\/td>\n Host: www.example.com<\/td>\n NO_REQUEST<\/td>\n \u7ee7\u7eed\u89e3\u6790\u5934\u90e8<\/td>\n<\/tr>\n \n 3<\/td>\n CHECK_STATE_HEADER<\/td>\n Content-Length: 15<\/td>\n NO_REQUEST<\/td>\n \u7ee7\u7eed\u89e3\u6790<\/td>\n<\/tr>\n \n 4<\/td>\n CHECK_STATE_HEADER<\/td>\n （\u7a7a\u884c，\u8868\u793a\u5934\u90e8\u7ed3\u675f）<\/td>\n NO_REQUEST<\/td>\n \u8fdb\u5165 CHECK_STATE_CONTENT<\/td>\n<\/tr>\n \n 5<\/td>\n CHECK_STATE_CONTENT<\/td>\n user=admin&pwd=123<\/td>\n GET_REQUEST<\/td>\n \u8c03\u7528 do_request() \u5904\u7406<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
\n{
\n LINE_STATUS line_status = LINE_OK; \/\/ \u8bb0\u5f55\u5f53\u524d\u884c\u89e3\u6790\u72b6\u6001
\n HTTP_CODE ret = NO_REQUEST; \/\/ \u8bb0\u5f55 HTTP \u8bf7\u6c42\u7684\u89e3\u6790\u72b6\u6001
\n char *text = 0; \/\/ \u5b58\u50a8\u5f53\u524d\u89e3\u6790\u7684\u884c\u6587\u672c<\/p>\n
\n while ((m_check_state == CHECK_STATE_CONTENT && line_status == LINE_OK) || ((line_status = parse_line()) == LINE_OK))
\n {
\n text = get_line(); \/\/ \u83b7\u53d6\u5f53\u524d\u884c\u7684\u8d77\u59cb\u5730\u5740
\n m_start_line = m_checked_idx;
\n LOG_INFO("%s", text); \/\/ \u8bb0\u5f55\u65e5\u5fd7，\u8f93\u51fa\u5f53\u524d\u89e3\u6790\u7684\u6587\u672c\u884c<\/p>\n
\n {
\n case CHECK_STATE_REQUESTLINE:
\n {
\n ret = parse_request_line(text); \/\/ \u89e3\u6790\u8bf7\u6c42\u884c
\n if (ret == BAD_REQUEST)
\n return BAD_REQUEST;
\n break;
\n }
\n case CHECK_STATE_HEADER:
\n {
\n ret = parse_headers(text); \/\/ \u89e3\u6790\u8bf7\u6c42\u5934
\n if (ret == BAD_REQUEST)
\n return BAD_REQUEST;
\n else if (ret == GET_REQUEST)
\n {
\n return do_request(); \/\/ \u89e3\u6790\u5b8c\u6210，\u8c03\u7528 do_request() \u5904\u7406\u8bf7\u6c42
\n }
\n break;
\n }
\n case CHECK_STATE_CONTENT:
\n {
\n ret = parse_content(text); \/\/ \u89e3\u6790\u8bf7\u6c42\u4f53
\n if (ret == GET_REQUEST)
\n return do_request();
\n line_status = LINE_OPEN; \/\/ \u8bf7\u6c42\u4f53\u53ef\u80fd\u4e0d\u6b62\u4e00\u884c，\u7ee7\u7eed\u89e3\u6790
\n break;
\n }
\n default:
\n return INTERNAL_ERROR; \/\/ \u72b6\u6001\u5f02\u5e38，\u8fd4\u56de\u670d\u52a1\u5668\u5185\u90e8\u9519\u8bef
\n }
\n }
\n return NO_REQUEST; \/\/ \u5982\u679c\u89e3\u6790\u672a\u5b8c\u6210，\u5219\u7ee7\u7eed\u7b49\u5f85\u6570\u636e
\n}<\/p>\n\u5904\u7406\u9759\u6001\u6587\u4ef6\u8bf7\u6c42\u548c\u52a8\u6001\u8bf7\u6c42\u51fd\u6570：do_request\u00a0<\/h4>\n<\/p>\n
\n
\n{
\n strcpy(m_real_file, doc_root);
\n int len = strlen(doc_root);\/\/\u8bbe\u7f6e\u6587\u4ef6\u5b9e\u8d28\u8def\u5f84
\n \/\/printf("m_url:%s\\\\n", m_url);
\n const char *p = strrchr(m_url, '\/');<\/p>\n
\n if (cgi == 1 && (*(p + 1) == '2' || *(p + 1) == '3'))
\n {<\/p>\n
\n char flag = m_url[1];<\/p>\n
\n strcpy(m_url_real, "\/");
\n strcat(m_url_real, m_url + 2);
\n strncpy(m_real_file + len, m_url_real, FILENAME_LEN – len – 1);
\n free(m_url_real);<\/p>\n
\n \/\/user=123&passwd=123
\n char name[100], password[100];
\n int i;
\n for (i = 5; m_string[i] != '&'; ++i)
\n name[i – 5] = m_string[i];
\n name[i – 5] = '\\\\0';<\/p>\n
\n for (i = i + 10; m_string[i] != '\\\\0'; ++i, ++j)
\n password[j] = m_string[i];
\n password[j] = '\\\\0';<\/p>\n
\n {
\n \/\/\u5982\u679c\u662f\u6ce8\u518c，\u5148\u68c0\u6d4b\u6570\u636e\u5e93\u4e2d\u662f\u5426\u6709\u91cd\u540d\u7684
\n \/\/\u6ca1\u6709\u91cd\u540d\u7684，\u8fdb\u884c\u589e\u52a0\u6570\u636e
\n char *sql_insert = (char *)malloc(sizeof(char) * 200);
\n strcpy(sql_insert, "INSERT INTO user(username, passwd) VALUES(");
\n strcat(sql_insert, "'");
\n strcat(sql_insert, name);
\n strcat(sql_insert, "', '");
\n strcat(sql_insert, password);
\n strcat(sql_insert, "')");<\/p>\n
\n {
\n m_lock.lock();
\n int res = mysql_query(mysql, sql_insert);
\n users.insert(pair<string, string>(name, password));
\n m_lock.unlock();<\/p>\n
\n strcpy(m_url, "\/log.html");
\n else
\n strcpy(m_url, "\/registerError.html");
\n }
\n else
\n strcpy(m_url, "\/registerError.html");
\n }
\n \/\/\u5982\u679c\u662f\u767b\u5f55，\u76f4\u63a5\u5224\u65ad
\n \/\/\u82e5\u6d4f\u89c8\u5668\u7aef\u8f93\u5165\u7684\u7528\u6237\u540d\u548c\u5bc6\u7801\u5728\u8868\u4e2d\u53ef\u4ee5\u67e5\u627e\u5230，\u8fd4\u56de1，\u5426\u5219\u8fd4\u56de0
\n else if (*(p + 1) == '2')
\n {
\n if (users.find(name) != users.end() && users[name] == password)
\n strcpy(m_url, "\/welcome.html");
\n else
\n strcpy(m_url, "\/logError.html");
\n }
\n }<\/p>\n
\n {
\n char *m_url_real = (char *)malloc(sizeof(char) * 200);
\n strcpy(m_url_real, "\/register.html");
\n strncpy(m_real_file + len, m_url_real, strlen(m_url_real));<\/p>\n
\n }
\n else if (*(p + 1) == '1')
\n {
\n char *m_url_real = (char *)malloc(sizeof(char) * 200);
\n strcpy(m_url_real, "\/log.html");
\n strncpy(m_real_file + len, m_url_real, strlen(m_url_real));<\/p>\n
\n }
\n else if (*(p + 1) == '5')
\n {
\n char *m_url_real = (char *)malloc(sizeof(char) * 200);
\n strcpy(m_url_real, "\/picture.html");
\n strncpy(m_real_file + len, m_url_real, strlen(m_url_real));<\/p>\n
\n }
\n else if (*(p + 1) == '6')
\n {
\n char *m_url_real = (char *)malloc(sizeof(char) * 200);
\n strcpy(m_url_real, "\/video.html");
\n strncpy(m_real_file + len, m_url_real, strlen(m_url_real));<\/p>\n
\n }
\n else if (*(p + 1) == '7')
\n {
\n char *m_url_real = (char *)malloc(sizeof(char) * 200);
\n strcpy(m_url_real, "\/fans.html");
\n strncpy(m_real_file + len, m_url_real, strlen(m_url_real));<\/p>\n
\n }
\n else
\n strncpy(m_real_file + len, m_url, FILENAME_LEN – len – 1);<\/p>\n
\n return NO_RESOURCE;<\/p>\n
\n return FORBIDDEN_REQUEST;<\/p>\n
\n return BAD_REQUEST;<\/p>\n
\n m_file_address = (char *)mmap(0, m_file_stat.st_size, PROT_READ, MAP_PRIVATE, fd, 0);
\n close(fd);
\n return FILE_REQUEST;
\n} <\/p>\n\u89e3\u9664\u5185\u5b58\u6620\u5c04\u51fd\u6570：unmap<\/h4>\n
\n{
\n if (m_file_address)
\n {
\n munmap(m_file_address, m_file_stat.st_size);\/\/ \u89e3\u9664\u5185\u5b58\u6620\u5c04
\n m_file_address = 0;\/\/ \u6e05\u7a7a\u6587\u4ef6\u5730\u5740
\n }
\n} <\/p>\n\u53d1\u9001http\u54cd\u5e94\u51fd\u6570：write<\/h4>\n
\n{
\n int temp = 0;<\/p>\n
\n if (bytes_to_send == 0)
\n {
\n modfd(m_epollfd, m_sockfd, EPOLLIN, m_TRIGMode); \/\/ \u4fee\u6539 epoll \u4e8b\u4ef6\u4e3a EPOLLIN（\u53ef\u8bfb）
\n init(); \/\/ \u91cd\u7f6e\u8fde\u63a5\u72b6\u6001
\n return true;
\n }<\/p>\n
\n {
\n \/\/ \u4f7f\u7528 writev \u7cfb\u7edf\u8c03\u7528\u5c06\u591a\u4e2a\u7f13\u51b2\u533a\u7684\u6570\u636e\u5199\u5165\u5957\u63a5\u5b57
\n temp = writev(m_sockfd, m_iv, m_iv_count);<\/p>\n
\n {
\n \/\/ \u5982\u679c\u5199\u5165\u65f6\u8fd4\u56de\u9519\u8bef\u5e76\u4e14 errno \u4e3a EAGAIN，\u8868\u793a\u5f53\u524d\u7f13\u51b2\u533a\u4e0d\u53ef\u5199（\u975e\u963b\u585e）
\n if (errno == EAGAIN)
\n {
\n \/\/ \u4fee\u6539 epoll \u4e8b\u4ef6\u4e3a EPOLLOUT（\u53ef\u5199），\u8868\u793a\u7a0d\u540e\u53ef\u4ee5\u7ee7\u7eed\u5199
\n modfd(m_epollfd, m_sockfd, EPOLLOUT, m_TRIGMode);
\n return true;
\n }
\n \/\/ \u5982\u679c\u53d1\u751f\u5176\u4ed6\u9519\u8bef，\u89e3\u9664\u5185\u5b58\u6620\u5c04\u5e76\u8fd4\u56de\u5931\u8d25
\n unmap();
\n return false;
\n }<\/p>\n
\n bytes_have_send += temp;
\n bytes_to_send -= temp;<\/p>\n
\n if (bytes_have_send >= m_iv[0].iov_len)
\n {
\n \/\/ \u8bbe\u7f6e m_iv[0] \u4e0d\u518d\u9700\u8981\u5199\u5165
\n m_iv[0].iov_len = 0;
\n \/\/ \u66f4\u65b0 m_iv[1] \u4e3a\u5269\u4f59\u7684\u6570\u636e\u90e8\u5206
\n m_iv[1].iov_base = m_file_address + (bytes_have_send – m_write_idx);
\n m_iv[1].iov_len = bytes_to_send;
\n }
\n else
\n {
\n \/\/ \u5426\u5219\u7ee7\u7eed\u5199\u5165 m_iv[0] \u7f13\u51b2\u533a\u5269\u4f59\u90e8\u5206
\n m_iv[0].iov_base = m_write_buf + bytes_have_send;
\n m_iv[0].iov_len = m_iv[0].iov_len – bytes_have_send;
\n }<\/p>\n
\n if (bytes_to_send <= 0)
\n {
\n unmap(); \/\/ \u89e3\u9664\u5185\u5b58\u6620\u5c04
\n \/\/ \u4fee\u6539 epoll \u4e8b\u4ef6\u4e3a EPOLLIN（\u53ef\u4ee5\u7ee7\u7eed\u8bfb\u53d6）
\n modfd(m_epollfd, m_sockfd, EPOLLIN, m_TRIGMode);<\/p>\n
\n if (m_linger)
\n {
\n init(); \/\/ \u91cd\u7f6e\u8fde\u63a5\u72b6\u6001
\n return true;
\n }
\n else
\n {
\n return false; \/\/ \u5173\u95ed\u8fde\u63a5
\n }
\n }
\n }
\n}<\/p>\n\u7f13\u51b2\u533a\u6dfb\u52a0\u6570\u636e\u51fd\u6570：add_response<\/h4>\n
\n{
\n \/\/ \u68c0\u67e5\u5199\u7f13\u51b2\u533a\u662f\u5426\u5df2\u7ecf\u6ee1
\n if (m_write_idx >= WRITE_BUFFER_SIZE)
\n return false;<\/p>\n
\n va_start(arg_list, format);<\/p>\n
\n int len = vsnprintf(m_write_buf + m_write_idx, WRITE_BUFFER_SIZE – 1 – m_write_idx, format, arg_list);<\/p>\n
\n if (len >= (WRITE_BUFFER_SIZE – 1 – m_write_idx))
\n {
\n va_end(arg_list); \/\/ \u7ed3\u675f\u53ef\u53d8\u53c2\u6570\u7684\u5904\u7406
\n return false; \/\/ \u7f13\u51b2\u533a\u7a7a\u95f4\u4e0d\u8db3，\u8fd4\u56de false
\n }<\/p>\n
\n m_write_idx += len;<\/p>\n
\n LOG_INFO("request:%s", m_write_buf);<\/p>\n
\n}<\/p>\n\u6784\u9020\u62a5\u6587\u8f85\u52a9\u51fd\u6570\u5408\u96c6<\/h4>\n
\nbool http_conn::add_status_line(int status, const char *title)
\n{
\n return add_response("%s %d %s\\\\r\\\\n", "HTTP\/1.1", status, title);
\n}<\/p>\n
\nbool http_conn::add_headers(int content_len)
\n{
\n return add_content_length(content_len) && add_linger() &&
\n add_blank_line();
\n}<\/p>\n
\nbool http_conn::add_content_length(int content_len)
\n{
\n return add_response("Content-Length:%d\\\\r\\\\n", content_len);
\n}<\/p>\n
\nbool http_conn::add_content_type()
\n{
\n return add_response("Content-Type:%s\\\\r\\\\n", "text\/html");
\n}<\/p>\n
\nbool http_conn::add_linger()
\n{
\n return add_response("Connection:%s\\\\r\\\\n", (m_linger == true) ? "keep-alive" : "close");
\n}<\/p>\n
\nbool http_conn::add_blank_line()
\n{
\n return add_response("%s", "\\\\r\\\\n");
\n}<\/p>\n
\nbool http_conn::add_content(const char *content)
\n{
\n return add_response("%s", content);
\n} <\/p>\n\u6784\u9020\u54cd\u5e94\u62a5\u6587\u51fd\u6570：process_write<\/h4>\n
\n
\n{
\n switch (ret)
\n {
\n case INTERNAL_ERROR:\/\/\u5f53\u53d1\u751f\u670d\u52a1\u5668\u5185\u90e8\u9519\u8bef\u65f6（\u72b6\u6001\u7801 500）
\n {
\n add_status_line(500, error_500_title);
\n add_headers(strlen(error_500_form));
\n if (!add_content(error_500_form))
\n return false;
\n break;
\n }
\n case BAD_REQUEST:\/\/\u5f53\u8bf7\u6c42\u4e0d\u5408\u6cd5\u65f6（\u72b6\u6001\u7801 400）：
\n {
\n add_status_line(404, error_404_title);
\n add_headers(strlen(error_404_form));
\n if (!add_content(error_404_form))
\n return false;
\n break;
\n }
\n case FORBIDDEN_REQUEST:\/\/\u5f53\u8bbf\u95ee\u88ab\u62d2\u7edd\u65f6（\u72b6\u6001\u7801 403）：
\n {
\n add_status_line(403, error_403_title);
\n add_headers(strlen(error_403_form));
\n if (!add_content(error_403_form))
\n return false;
\n break;
\n }
\n case FILE_REQUEST:\/\/\u5f53\u8bf7\u6c42\u6210\u529f\u5e76\u4e14\u670d\u52a1\u5668\u80fd\u591f\u63d0\u4f9b\u6587\u4ef6\u65f6（\u72b6\u6001\u7801 200）：
\n {
\n add_status_line(200, ok_200_title);
\n if (m_file_stat.st_size != 0)
\n {
\n add_headers(m_file_stat.st_size);
\n m_iv[0].iov_base = m_write_buf;
\n m_iv[0].iov_len = m_write_idx;
\n m_iv[1].iov_base = m_file_address;
\n m_iv[1].iov_len = m_file_stat.st_size;
\n m_iv_count = 2;
\n bytes_to_send = m_write_idx + m_file_stat.st_size;
\n return true;
\n }
\n else
\n {
\n const char *ok_string = "<html><body><\/body><\/html>";
\n add_headers(strlen(ok_string));
\n if (!add_content(ok_string))
\n return false;
\n }
\n }
\n default:
\n return false;
\n }
\n m_iv[0].iov_base = m_write_buf;
\n m_iv[0].iov_len = m_write_idx;
\n m_iv_count = 1;
\n bytes_to_send = m_write_idx;
\n return true;
\n} <\/p>\nhttp\u5904\u7406\u6838\u5fc3\u51fd\u6570：process<\/h4>\n
\n
\n{
\n HTTP_CODE read_ret = process_read();\/\/ \u8bfb\u53d6\u548c\u89e3\u6790\u8bf7\u6c42
\n if (read_ret == NO_REQUEST)\/\/\u5224\u65ad\u662f\u5426\u9700\u8981\u8fdb\u4e00\u6b65\u5904\u7406\u8bf7\u6c42
\n {
\n modfd(m_epollfd, m_sockfd, EPOLLIN, m_TRIGMode);
\n return;
\n }
\n bool write_ret = process_write(read_ret);\/\/ \u5904\u7406\u8bf7\u6c42\u5e76\u751f\u6210\u54cd\u5e94
\n if (!write_ret)
\n {
\n close_conn();
\n }
\n modfd(m_epollfd, m_sockfd, EPOLLOUT, m_TRIGMode);\/\/\u4fee\u6539\u4e8b\u4ef6\u7c7b\u578b\u4e3a EPOLLOUT，\u51c6\u5907\u53d1\u9001\u54cd\u5e94
\n} <\/p>\n<\/h4><\/p>\n","protected":false},"excerpt":{"rendered":"