![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221327-6802ce877f085.png\")
<\/p>\n\u4e3a\u4ec0\u4e48\u8981\u7528\u7ebf\u7a0b\u6c60\u548c\u4e92\u65a5\u9501？<\/p>\n
：\u521b\u5efa\u7ebf\u7a0b&\u9500\u6bc1\u7ebf\u7a0b\u4f1a\u8017\u8d39\u8ba1\u7b97\u673a\u8d44\u6e90，\u91c7\u7528\u7ebf\u7a0b\u6c60\u53ef\u4ee5\u89e3\u51b3\u8ba1\u7b97\u673a\u65e0\u9650\u5236\u521b\u5efa\u7ebf\u7a0b\u7684\u60c5\u51b5\u3002\u5f53\u6709\u65b0\u7684\u4efb\u52a1\u5230\u6765\u65f6\u53ef\u4ee5\u53bb\u7ebf\u7a0b\u6c60\u4e2d\u5bfb\u627e\u7a7a\u95f2\u7ebf\u7a0b\u53bb\u670d\u52a1\u3002\u9501\u673a\u5236\u7528\u6765\u786e\u4fdd\u7ebf\u7a0b\u5b89\u5168\u3002<\/p>\n
<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221327-6802ce87acb88.png\")
<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221327-6802ce87e0431.png\")
<\/p>\n<\/p>\n
#ifndef LOCKER_H
\n#define LOCKER_H<\/p>\n
#include <pthread.h>
\n#include <exception> \/\/ \u5f02\u5e38
\n#include <semaphore.h><\/p>\n
\/\/ \u7ebf\u7a0b\u540c\u6b65\u673a\u5236\u5206\u88c5\u7c7b<\/p>\n
\/\/ \u4e92\u65a5\u9501\u7c7b
\nclass locker {
\npublic:
\n \/\/ \u6784\u9020\u51fd\u6570
\n locker(){
\n if(pthread_mutex_init(&m_mutex, NULL) != 0){
\n throw std::exception();
\n }
\n }<\/p>\n
\/\/ \u4e0a\u9501
\n bool lock() {
\n return pthread_mutex_lock(&m_mutex) == 0;
\n }<\/p>\n
\/\/ \u89e3\u9501
\n bool unlock() {
\n return pthread_mutex_unlock(&m_mutex) == 0;
\n }<\/p>\n
pthread_mutex_t * get() {
\n return &m_mutex;
\n }<\/p>\n
\/\/ \u6790\u6784\u51fd\u6570
\n ~locker() {
\n pthread_mutex_destroy(&m_mutex);
\n }
\nprivate:
\n pthread_mutex_t m_mutex; \/\/ \u4e92\u65a5\u9501
\n};<\/p>\n
\/\/ \u6761\u4ef6\u53d8\u91cf\u7c7b
\nclass cond {
\npublic:
\n cond() {
\n if(pthread_cond_init(&m_cond, NULL) != 0){
\n throw std::exception();
\n }
\n }<\/p>\n
~cond() {
\n pthread_cond_destroy(&m_cond);
\n }<\/p>\n
bool wait(pthread_mutex_t * mutex) {
\n return pthread_cond_wait(&m_cond, mutex) == 0;
\n }<\/p>\n
bool timewait(pthread_mutex_t * mutex, struct timespec t) {
\n return pthread_cond_timedwait(&m_cond, mutex, &t) == 0;
\n }<\/p>\n
bool signal() {
\n return pthread_cond_signal(&m_cond) == 0;
\n }<\/p>\n
bool broadcast() {
\n return pthread_cond_broadcast(&m_cond) == 0;
\n }
\nprivate:
\n pthread_cond_t m_cond;
\n};<\/p>\n
\/\/ \u4fe1\u53f7\u91cf\u7c7b
\nclass sem {
\npublic:
\n sem() {
\n if(sem_init(&m_sem, 0, 0) != 0) {
\n throw std::exception();
\n }
\n }<\/p>\n
sem(int num) {
\n if(sem_init(&m_sem, 0, num) != 0) {
\n throw std::exception();
\n }
\n } <\/p>\n
~sem() {
\n sem_destroy(&m_sem);
\n }<\/p>\n
\/\/ \u7b49\u5f85\u4fe1\u53f7\u91cf
\n bool wait() {
\n return sem_wait(&m_sem) == 0;
\n }<\/p>\n
\/\/ \u589e\u52a0\u4fe1\u53f7\u91cf
\n bool post() {
\n return sem_post(&m_sem) == 0;
\n }
\nprivate:
\n sem_t m_sem;
\n};<\/p>\n
#endif <\/p>\n
#ifndef THREADPOOL_H
\n#define THREADPOOL_H<\/p>\n
#include <pthread.h>
\n#include <list>
\n#include "locker.h"
\n#include <exception>
\n#include <cstdio><\/p>\n
\/\/ \u7ebf\u7a0b\u6c60\u7c7b \u5b9a\u4e49\u6210\u6a21\u677f\u7c7b：\u4e3a\u4e86\u4ee3\u7801\u7684\u590d\u7528
\ntemplate<typename T>
\nclass threadpool {
\npublic:
\n threadpool(int thread_number = 8, int m_max_requests = 10000);
\n ~threadpool();
\n \/\/ \u6dfb\u52a0\u4efb\u52a1
\n bool append(T * request);<\/p>\n
private:
\n static void* worker(void * arg);
\n void run();<\/p>\n
private:
\n \/\/ \u7ebf\u7a0b\u6570\u91cf
\n int m_thread_number;<\/p>\n
\/\/ \u5bb9\u5668：\u7ebf\u7a0b\u6c60\u6570\u7ec4，\u5927\u5c0f\u4e3a\u7ebf\u7a0b\u6570\u91cf
\n pthread_t * m_threads;<\/p>\n
\/\/ \u8bf7\u6c42\u961f\u5217\u4e2d\u6700\u591a\u5141\u8bb8\u7684\u7b49\u5f85\u5904\u7406\u7684\u8bf7\u6c42\u6570\u91cf
\n int m_max_requests;<\/p>\n
\/\/ \u8bf7\u6c42\u961f\u5217
\n std::list< T*> m_workqueue;<\/p>\n
\/\/ \u4e92\u65a5\u9501
\n locker m_queuelocker;<\/p>\n
\/\/ \u4fe1\u53f7\u91cf：\u7528\u6765\u5224\u65ad\u662f\u5426\u6709\u4efb\u52a1\u8981\u5904\u7406
\n sem m_queuestat;<\/p>\n
\/\/ \u662f\u5426\u7ed3\u675f\u7ebf\u7a0b
\n bool m_stop;<\/p>\n
};<\/p>\n
\/\/ \u6784\u9020\u51fd\u6570
\ntemplate<typename T>
\nthreadpool<T>::threadpool(int thread_number, int m_max_requests):
\n m_thread_number(thread_number),m_max_requests(m_max_requests),
\n m_stop(false), m_threads(NULL) {<\/p>\n
if((thread_number <= 0) || (m_max_requests <= 0) ) {
\n throw std::exception();
\n }<\/p>\n
\/\/ new\u4e00\u4e2a\u6570\u7ec4\u7a7a\u95f4
\n m_threads = new pthread_t[m_thread_number];
\n \/\/ \u4ece\u5806\u4e2d\u5206\u914d m_thread_number \u4e2a pthread_t \u7c7b\u578b\u7684\u5185\u5b58，\u8fd4\u56de\u5230\u6307\u9488 m_thread \u4e2d
\n if(!m_thread_number) {
\n throw std::exception();
\n }<\/p>\n
\/\/ \u521b\u5efathread_num\u4e2a\u7ebf\u7a0b，\u5e76\u5c06\u5b83\u4eec\u8bbe\u7f6e\u4e3a\u7ebf\u7a0b\u8131\u79bb
\n for(int i = 0; i < thread_number; ++i) {
\n printf("create the %dth thread\\\\n", i);<\/p>\n
\/\/ \u521b\u5efa\u7ebf\u7a0b：\u5728C++\u4e2d，\u7b2c\u4e09\u4e2a\u53c2\u6570worker\u9700\u8981\u8bbe\u7f6e\u4e3a\u9759\u6001\u51fd\u6570
\n if(pthread_create(m_threads + i, NULL, worker, this) != 0) {
\n delete [] m_threads;
\n throw std::exception();
\n }<\/p>\n
\/\/ \u8bbe\u7f6e\u7ebf\u7a0b\u5206\u79bb
\n if(pthread_detach(m_threads[i])) {
\n delete[] m_threads;
\n throw std::exception();
\n }
\n }<\/p>\n
}<\/p>\n
\/\/ \u6790\u6784\u51fd\u6570
\ntemplate<typename T>
\nthreadpool<T>::~threadpool() {
\n delete[] m_threads;
\n m_stop = true;
\n}<\/p>\n
\/\/ \u6dfb\u52a0\u4efb\u52a1\u51fd\u6570：\u7b49\u5f85\u5904\u7406\u8bf7\u6c42\u6570\u91cf
\ntemplate<typename T>
\nbool threadpool<T>::append(T * request) {<\/p>\n
m_queuelocker.lock(); \/\/ \u4e0a\u9501，\u5f00\u59cb\u64cd\u4f5c
\n if(m_workqueue.size() > m_max_requests) {
\n m_queuelocker.unlock();
\n return false;
\n }<\/p>\n
m_workqueue.push_back(request); \/\/ \u5c06\u5143\u7d20\u6dfb\u52a0\u5230\u5bb9\u5668\u672b\u5c3e
\n m_queuelocker.unlock(); \/\/ \u89e3\u9501，\u505c\u6b62\u64cd\u4f5c
\n m_queuestat.post(); \/\/ \u89e3\u9501，\u4fe1\u53f7\u91cf+1
\n return true;
\n}<\/p>\n
\/\/ \u9759\u6001worker — \u5728\u521b\u5efa\u7ebf\u7a0b\u51fd\u6570\u4e2d\u4e3a\u53c2\u6570
\ntemplate<typename T>
\nvoid* threadpool<T>::worker(void * arg) {
\n threadpool * pool = (threadpool *) arg;
\n pool->run(); \/\/ \u8c03\u7528private\u4e2d\u7684\u65b9\u6cd5run()
\n return pool; \/\/ \u8fd4\u56de\u8be5\u5bf9\u8c61
\n}<\/p>\n
template<typename T>
\nvoid threadpool<T>::run() {
\n while(!m_stop) {
\n m_queuestat.wait(); \/\/ \u82e5\u8be5\u4fe1\u53f7\u91cf\u6709\u503c，\u5219\u4e0d\u4f1a\u963b\u585e，\u4fe1\u53f7\u91cf-1；\u82e5\u4e3a0，\u5219\u963b\u585e\u7b49\u5f85
\n m_queuelocker.lock(); \/\/ \u4e0a\u9501，\u5f00\u59cb\u64cd\u4f5c
\n if(m_workqueue.empty()) {
\n m_queuelocker.unlock();
\n continue;
\n }<\/p>\n
T* requests = m_workqueue.front(); \/\/ \u53d6\u51fa\u961f\u9996\u5143\u7d20
\n m_workqueue.pop_front(); \/\/ \u53d6\u51fa\u7b2c\u4e00\u4e2a\u5143\u7d20
\n m_queuelocker.unlock();<\/p>\n
if(!requests) {
\n continue;
\n }<\/p>\n
requests->process(); \/\/\u8fd0\u884c\u4efb\u52a1
\n }<\/p>\n
}<\/p>\n
#endif <\/p>\n
#ifndef HTTPCONNECTION_H
\n#define HTTPCONNECTION_H<\/p>\n
#include <sys\/epoll.h>
\n#include <stdio.h>
\n#include <stdlib.h>
\n#include <unistd.h>
\n#include <signal.h>
\n#include <sys\/types.h>
\n#include <fcntl.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include <sys\/stat.h>
\n#include <sys\/mman.h> \/\/
\n#include <stdarg.h> \/\/
\n#include <errno.h>
\n#include "locker.h"
\n#include <sys\/uio.h><\/p>\n
class http_conn {
\npublic:<\/p>\n
static int m_epollfd; \/\/ \u6240\u6709\u7684socket\u4e0a\u7684\u4e8b\u4ef6\u90fd\u88ab\u6ce8\u518c\u5230\u540c\u4e00\u4e2aepoll\u5bf9\u8c61\u4e2d，\u6240\u4ee5\u8bbe\u7f6e\u6210\u9759\u6001\u7684
\n static int m_user_count; \/\/ \u7edf\u8ba1\u7528\u6237\u7684\u6570\u91cf<\/p>\n
http_conn() {<\/p>\n
}
\n ~http_conn() {<\/p>\n
}
\n void process(); \/\/ \u5904\u7406\u5ba2\u6237\u7aef\u8bf7\u6c42
\n void init(int sockfd, const sockaddr_in & addr); \/\/ \u521d\u59cb\u5316\u65b0\u63a5\u6536\u7684\u8fde\u63a5
\n void close_conn(); \/\/ \u5173\u95ed\u8fde\u63a5
\n bool read(); \/\/ \u975e\u963b\u585e\u7684\u8bfb
\n bool write(); \/\/ \u975e\u963b\u585e\u7684\u5199<\/p>\n
private:
\n int m_sockfd; \/\/ \u8be5http\u8fde\u63a5\u7684socket\u5957\u63a5\u5b57
\n sockaddr_in m_address; \/\/ \u901a\u4fe1\u7684socket\u5730\u5740<\/p>\n
};<\/p>\n
#endif <\/p>\n
#include "http_conn.h"<\/p>\n
int http_conn::m_epollfd = -1;
\nint http_conn::m_user_count = 0;<\/p>\n
\/\/ \u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u975e\u963b\u585e
\nint setnonblocking(int fd) {
\n int old_flag = fcntl(fd, F_GETFL);
\n int new_flag = old_flag | O_NONBLOCK;
\n fcntl(fd, F_SETFL, new_flag);
\n}<\/p>\n
\/\/ \u7528\u6765\u5411epoll\u4e2d\u6dfb\u52a0\u9700\u8981\u76d1\u542c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\nvoid addfd(int epollfd, int fd, bool one_shot) {
\n epoll_event event;
\n event.data.fd = fd;
\n event.events = EPOLLIN | EPOLLRDHUP;<\/p>\n
if(one_shot) {
\n event.events |= EPOLLONESHOT; \/\/ \u6309\u4f4d\u6216\u5e76\u8d4b\u503c
\n }<\/p>\n
epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &event);<\/p>\n
\/\/ \u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u975e\u963b\u585e
\n setnonblocking(fd); \/\/**
\n}<\/p>\n
\/\/ \u4eceepoll\u4e2d\u79fb\u9664\u76d1\u542c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\nvoid removefd(int epollfd, int fd) {
\n epoll_ctl(epollfd, EPOLL_CTL_DEL, fd, 0);
\n close(fd);
\n}<\/p>\n
\/\/ \u4fee\u6539\u6587\u4ef6\u63cf\u8ff0\u7b26，\u91cd\u7f6esocket\u4e0a\u7684EPOLLONESHOT\u4e8b\u4ef6，\u4ee5\u786e\u4fdd\u4e0b\u4e00\u6b21\u53ef\u8bfb\u65f6，EPOLLIN\u4e8b\u4ef6\u53ef\u88ab\u89e6\u53d1
\nvoid modfd(int epollfd, int fd, int ev) {
\n epoll_event event;
\n event.data.fd = fd;
\n event.events = ev | EPOLLONESHOT | EPOLLRDHUP;
\n epoll_ctl(epollfd, EPOLL_CTL_MOD, fd, &event);
\n}<\/p>\n
\/\/ \u521d\u59cb\u5316\u8fde\u63a5
\nvoid http_conn::init(int sockfd, const sockaddr_in & addr) {
\n m_sockfd = sockfd;
\n m_address = addr;<\/p>\n
\/\/ \u8bbe\u7f6esockfd\u7684\u7aef\u53e3\u590d\u7528
\n int reuse = 1;
\n setsockopt(m_sockfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));<\/p>\n
\/\/ \u6dfb\u52a0\u5230epoll\u5bf9\u8c61\u4e2d
\n addfd(m_epollfd, m_sockfd, true); \/\/\u6dfb\u52a0EPOLLEPOLLONESHOT\u4e8b\u4ef6
\n m_user_count++; \/\/ \u603b\u7528\u6237\u6570+1
\n}<\/p>\n
\/\/ \u5173\u95ed\u8fde\u63a5
\nvoid http_conn::close_conn() {
\n if(m_sockfd != -1) {
\n \/\/ \u5220\u9664
\n removefd(m_epollfd, m_sockfd);
\n m_sockfd = -1; \/\/ \u5f53sockfd\u4e3a-1\u65f6，\u5c31\u6ca1\u6709\u7528\u4e86
\n m_user_count–; \/\/ \u5173\u95ed\u8fde\u63a5，\u5ba2\u6237\u603b\u6570\u91cf-1
\n }
\n}<\/p>\n
\/\/ \u5faa\u73af\u8bfb\u53d6\u5ba2\u6237\u6570\u636e，\u76f4\u5230\u65e0\u6570\u636e\u53ef\u8bfb\u6216\u8005\u5bf9\u65b9\u5173\u95ed\u8fde\u63a5
\nbool http_conn::read() {
\n printf("read data\\\\n");
\n return true;
\n}<\/p>\n
bool http_conn::write() {
\n printf("write data\\\\n");
\n return true;
\n}<\/p>\n
\/\/ \u4e1a\u52a1\u903b\u8f91
\n\/\/ \u7531\u7ebf\u7a0b\u6c60\u4e2d\u7684\u5de5\u4f5c\u7ebf\u7a0b\u8c03\u7528，\u8fd9\u662f\u5904\u7406HTTP\u8bf7\u6c42\u7684\u5165\u53e3\u51fd\u6570
\nvoid http_conn::process() {
\n \/\/ \u89e3\u6790HTTP\u8bf7\u6c42<\/p>\n
printf("parse request, create response\\\\n");<\/p>\n
\/\/ \u751f\u6210\u54cd\u5e94<\/p>\n
} <\/p>\n
#include <stdio.h>
\n#include <stdlib.h>
\n#include <string.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include <unistd.h>
\n#include <errno.h>
\n#include <fcntl.h>
\n#include <sys\/epoll.h>
\n#include "locker.h"
\n#include "threadpool.h"
\n#include <signal.h>
\n#include "http_conn.h"<\/p>\n
#define MAX_FD 65535 \/\/ \u6700\u5927\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e2a\u6570
\n#define MAX_EVENT_NUMBER 10000 \/\/ \u4e00\u6b21\u76d1\u542c\u7684\u6700\u5927\u7684\u65f6\u95f4\u6570\u91cf<\/p>\n
\/\/ \u6dfb\u52a0\u4fe1\u53f7\u6355\u6349
\nvoid addsig(int sig, void(handler)(int)) {
\n struct sigaction sa; \/\/ \u521b\u5efa\u4e00\u4e2asigaction\u7ed3\u6784\u4f53\u53d8\u91cfsa
\n memset(&sa, '\\\\0', sizeof(sa));
\n sa.sa_handler = handler; \/\/ \u51fd\u6570\u6307\u9488 \u6307\u5411\u7684\u51fd\u6570\u5c31\u662f\u4fe1\u53f7\u6355\u6349\u5230\u4e4b\u540e\u7684\u5904\u7406\u51fd\u6570
\n sigfillset(&sa.sa_mask); \/\/ \u5c06\u4fe1\u53f7\u96c6\u4e2d\u7684\u6240\u6709\u6807\u5fd7\u4f4d\u90fd\u7f6e\u4e3a1
\n sigaction(sig, &sa, NULL); \/\/ \u68c0\u67e5\u6216\u6539\u53d8\u4fe1\u53f7\u7684\u5904\u7406，\u8fdb\u884c\u4fe1\u53f7\u6355\u6349
\n \/\/ \u9700\u8981\u6355\u6349\u7684\u4fe1\u53f7\u7f16\u53f7\u6216\u5b8f\u503c，\u6355\u6349\u540e\u7684\u5904\u7406\u52a8\u4f5c，\u5bf9\u4e0a\u4e00\u6b21\u6355\u6349\u76f8\u5173\u7684\u8bbe\u7f6e<\/p>\n
}<\/p>\n
\/\/ \u6dfb\u52a0\u6587\u4ef6\u63cf\u8ff0\u7b26\u5230epoll\u4e2d
\nextern void addfd(int epollfd, int fd, bool oneshot);
\n\/\/ \u4eceepoll\u4e2d\u5220\u9664\u6587\u4ef6\u63cf\u8ff0\u7b26
\nextern void removefd(int epollfd, int fd);
\n\/\/ \u4fee\u6539\u6587\u4ef6\u63cf\u8ff0\u7b26
\nextern void modfd(int epollfd, int fd, int ev);<\/p>\n
\/*
\n \u4f20\u9012\u53c2\u6570：argc — \u7aef\u53e3\u53f7
\n*\/
\nint main(int argc, char * argv[]) {<\/p>\n
if( argc <= 1) {
\n printf("\u6309\u7167\u5982\u4e0b\u683c\u5f0f\u8fd0\u884c：%s port_number\\\\n", basename(argv[0]));
\n exit(-1);
\n }<\/p>\n
\/\/ \u83b7\u53d6\u7aef\u53e3\u53f7
\n int port = atoi(argv[1]);<\/p>\n
\/\/ \u5bf9SIGPIPE\u4fe1\u53f7\u8fdb\u884c\u5904\u7406
\n addsig(SIGPIPE, SIG_IGN); \/\/\u5ffd\u7565\u8be5\u4fe1\u53f7<\/p>\n
\/\/ \u521b\u5efa\u7ebf\u7a0b\u6c60\u5e76\u521d\u59cb\u5316
\n threadpool<http_conn> * pool = NULL;
\n try {
\n pool = new threadpool<http_conn>;
\n } catch(…) {
\n exit(-1);
\n }<\/p>\n
\/\/ \u521b\u5efa\u4e00\u4e2a\u6570\u7ec4，\u7528\u4e8e\u4fdd\u5b58\u6240\u6709\u7684\u5ba2\u6237\u7aef\u4fe1\u606f
\n http_conn * users = new http_conn[ MAX_FD ];<\/p>\n
int listenfd = socket(PF_INET, SOCK_STREAM, 0); \/\/ \u521b\u5efa\u4e00\u4e2a\u76d1\u542c\u7684\u5957\u63a5\u5b57
\n \/*
\n if(listenfd = -1) {
\n printf("error socket\\\\n");
\n perror("socket");
\n exit(-1);
\n }
\n *\/
\n \/\/ \u8bbe\u7f6e\u7aef\u53e3\u590d\u7528
\n int reuse = 1;
\n setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));<\/p>\n
\/\/ \u7ed1\u5b9a
\n struct sockaddr_in address;
\n address.sin_family = AF_INET;
\n address.sin_addr.s_addr = INADDR_ANY; \/\/ \u4efb\u4f55\u53ef\u4ee5\u7ed1\u5b9a\u7684
\n address.sin_port = htons(port); \/\/ \u76d1\u542c\u7aef\u53e3 \u4e3b\u673a\u5b57\u8282\u5e8f–>\u7f51\u7edc\u5b57\u8282\u5e8f<\/p>\n
bind(listenfd, (struct sockaddr*)&address, sizeof(address));
\n \/*
\n if(ret = -1) {
\n perror("bind");
\n exit(-1);
\n }
\n *\/<\/p>\n
\/\/ \u76d1\u542c
\n listen(listenfd, 5);
\n \/*
\n if(ret == -1) {
\n perror("listen");
\n exit(-1);
\n }
\n *\/<\/p>\n
\/\/ \u521b\u5efaepoll\u5bf9\u8c61，\u4e8b\u4ef6\u6570\u7ec4，\u6dfb\u52a0\u76d1\u542c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n epoll_event events[ MAX_EVENT_NUMBER ];
\n int epollfd = epoll_create(5);<\/p>\n
\/\/ \u5c06\u76d1\u542c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u6dfb\u52a0\u5230epoll\u5bf9\u8c61\u4e2d
\n addfd(epollfd, listenfd, false); \/\/ \u76d1\u542c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e0d\u9700\u8981\u6dfb\u52a0EPOLLONESHOT\u4e8b\u4ef6
\n http_conn::m_epollfd = epollfd;<\/p>\n
\/\/\u4e3b\u7ebf\u7a0b\u4e0d\u65ad\u5faa\u73af\u68c0\u67e5\u6709\u54ea\u4e9b\u4e8b\u4ef6\u53d1\u751f
\n while(true) {
\n \/\/ \u68c0\u6d4b\u5230\u4e86\u51e0\u4e2a\u4e8b\u4ef6
\n int num = epoll_wait(epollfd, events, MAX_EVENT_NUMBER, -1);
\n if((num < 0) && (errno != EINTR)) {
\n \/\/ \u8c03\u7528\u5931\u8d25
\n printf("epoll failure\\\\n");
\n break;
\n }<\/p>\n
\/\/ \u5faa\u73af\u904d\u5386\u4e8b\u4ef6\u6570\u7ec4
\n for(int i = 0; i < num; i++) {
\n \/\/ \u83b7\u53d6\u76d1\u542c\u5230\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n int sockfd = events[i].data.fd;
\n if(sockfd == listenfd) {
\n \/\/ \u6709\u5ba2\u6237\u7aef\u8fde\u63a5\u8fdb\u6765
\n struct sockaddr_in client_address;
\n socklen_t client_addrlen = sizeof(client_address);<\/p>\n
\/\/ \u8fde\u63a5\u5ba2\u6237\u7aef
\n int connfd = accept(listenfd, (struct sockaddr*)&client_address, &client_addrlen);<\/p>\n
if(http_conn::m_user_count >= MAX_FD) {
\n \/\/ \u8bf4\u660e\u76ee\u524d\u8fde\u63a5\u6570\u6ee1\u4e86
\n \/\/ \u7ed9\u5ba2\u6237\u7aef\u5199\u4e00\u4e2a\u4fe1\u606f：\u670d\u52a1\u5668\u6b63\u5fd9（\u3002\u3002\u3002）
\n close(connfd);
\n continue;
\n }<\/p>\n
\/\/ \u5c06\u65b0\u7684\u5ba2\u6237\u6570\u636e\u521d\u59cb\u5316，\u653e\u5165\u6570\u7ec4\u4e2d(\u628aconnfd\u4f5c\u4e3ausers\u7684\u7d22\u5f15)
\n users[connfd].init(connfd, client_address); \/\/ \u521d\u59cb\u5316<\/p>\n
} else if(events[i].events & (EPOLLRDHUP | EPOLLHUP | EPOLLERR)) {<\/p>\n
\/\/ \u5bf9\u65b9\u5f02\u5e38\u65ad\u5f00\u6216\u8005\u9519\u8bef\u7b49\u4e8b\u4ef6
\n \/\/ \u5173\u95ed\u8fde\u63a5
\n users[sockfd].close_conn();<\/p>\n
} else if(events[i].events & EPOLLIN) {<\/p>\n
\/\/ \u5224\u65ad\u8bfb\u4e8b\u4ef6
\n if(users[sockfd].read()) {
\n \/\/ \u4e00\u6b21\u6027\u628a\u6240\u6709\u6570\u636e\u90fd\u8bfb\u51fa\u6765
\n pool->append(users + sockfd); \/\/**
\n } else {
\n users[sockfd].close_conn();
\n }<\/p>\n
} else if(events[i].events & EPOLLOUT) {<\/p>\n
\/\/ \u5224\u65ad\u5199\u4e8b\u4ef6
\n if( !users[sockfd].write() ){
\n \/\/ \u4e00\u6b21\u6027\u5199\u5b8c\u6240\u6709\u6570\u636e
\n users[sockfd].close_conn();
\n }
\n }
\n }
\n }<\/p>\n
close(epollfd);
\n close(listenfd);
\n delete [] users;
\n delete pool;<\/p>\n
return 0;
\n} <\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u2460 \u7f16\u8bd1\u540e\u751f\u6210\u201ca.out\u201d\u7684exe\u6587\u4ef6，\u8f93\u5165\u547d\u4ee4\u8fd0\u884c（\u6211\u7684Linux\u7684ip\u5730\u5740\u4e3a192.168.200.133）<\/p>\n
.\/a.out 10000 \/\/ 10000\u662f\u7aef\u53e3\u53f7 <\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u2461 \u5728Windows\u7f51\u9875\u4e2d（\u6216Linux\u7684\u706b\u72d0\u6d4f\u89c8\u5668）\u8f93\u5165\u7f51\u5740\u8fde\u63a5<\/p>\n
http:\/\/192.168.200.133:10000 <\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u6b64\u65f6xshell\u4e2d\u663e\u793a\u8fd0\u884c\u7ed3\u679c<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221328-6802ce8864e21.png\")
<\/p>\n<\/p>\n
\u4e3b\u8981\u662f\u5bf9http_conn\u4e2d\u7684\u5177\u4f53\u5b9e\u73b0\u8fdb\u884c\u7f16\u5199<\/p>\n
\u5728\u7c7b\u4e2d\u589e\u52a0\u5982\u4e0b\u4fe1\u606f：![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221328-6802ce8882f5a.png\")
<\/p>\n
\u5c06\u6dfb\u52a0\u76d1\u542c\u6587\u4ef6\u6539\u6210\u8fb9\u6cbf\u89e6\u53d1：（\u5b58\u5728\u95ee\u9898：listenfd\u4e5f\u53d8\u6210\u4e86\u8fb9\u6cbf\u89e6\u53d1）![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221329-6802ce89013b5.png\")
<\/p>\n
read() :\u00a0<\/p>\n
\/\/ \u5faa\u73af\u8bfb\u53d6\u5ba2\u6237\u6570\u636e，\u76f4\u5230\u65e0\u6570\u636e\u53ef\u8bfb\u6216\u8005\u5bf9\u65b9\u5173\u95ed\u8fde\u63a5
\nbool http_conn::read() {<\/p>\n
if(m_read_idx >= READ_BUFFER_SIZE) {
\n return false;
\n }<\/p>\n
\/\/ \u5b9a\u4e49\u4e00\u4e2a\u8bfb\u53d6\u5230\u7684\u5b57\u8282
\n int bytes_read = 0;
\n while (1)
\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 if(errno == EAGAIN || errno == EWOULDBLOCK) {
\n \/\/ \u975e\u963b\u585e\u7684\u8bfb\u7684\u65f6\u5019\u4f1a\u51fa\u73b0\u8fd9\u4e24\u4e2a\u9519\u8bef — \u6ca1\u6709\u6570\u636e\u7684\u60c5\u51b5
\n break; \/\/ \u5df2\u8bfb\u5b8c，\u9000\u51fa\u5faa\u73af
\n }
\n return false;
\n } else if(bytes_read == 0) {
\n \/\/ \u5bf9\u65b9\u5173\u95ed\u8fde\u63a5
\n return false;
\n }
\n m_read_idx += bytes_read;
\n }<\/p>\n
printf("read data:%s\\\\n",m_read_buf);
\n return true;
\n} <\/p>\n
\u6d4b\u8bd5\u8fd0\u884c：\u8bfb\u53d6\u5230\u7684\u8bf7\u6c42\u62a5\u6587![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221329-6802ce8934068.png\")
<\/p>\n
（http_conn.h）\u5229\u7528\u679a\u4e3e\u8bbe\u7f6e\u72b6\u6001（\u8bf7\u6c42\u65b9\u6cd5\u3001\u4e3b\u72b6\u6001\u673a\u3001\u4ece\u72b6\u6001\u673a）：<\/p>\n
\/\/ HTTP\u8bf7\u6c42\u65b9\u6cd5，\u8fd9\u91cc\u53ea\u652f\u6301GET
\n enum METHOD {GET = 0, POST, HEAD, PUT, DELETE, TRACE, OPTIONS, CONNECT};<\/p>\n
\/*
\n \u89e3\u6790\u5ba2\u6237\u7aef\u8bf7\u6c42\u65f6，\u4e3b\u72b6\u6001\u673a \u7684\u72b6\u6001
\n CHECK_STATE_REQUESTLINE:\u5f53\u524d\u6b63\u5728\u5206\u6790 \u8bf7\u6c42\u884c
\n CHECK_STATE_HEADER:\u5f53\u524d\u6b63\u5728\u5206\u6790 \u5934\u90e8\u5b57\u6bb5
\n CHECK_STATE_CONTENT:\u5f53\u524d\u6b63\u5728\u89e3\u6790 \u8bf7\u6c42\u4f53
\n *\/
\n enum CHECK_STATE { CHECK_STATE_REQUESTLINE = 0, CHECK_STATE_HEADER, CHECK_STATE_CONTENT };<\/p>\n
\/\/ \u4ece\u72b6\u6001\u673a \u7684\u4e09\u79cd\u53ef\u80fd\u72b6\u6001，\u5373\u884c\u7684\u8bfb\u53d6\u72b6\u6001，\u5206\u522b\u8868\u793a
\n \/\/ 1.\u8bfb\u53d6\u5230\u4e00\u4e2a\u5b8c\u6574\u7684\u884c 2.\u884c\u51fa\u9519 3.\u884c\u6570\u636e\u5c1a\u4e14\u4e0d\u5b8c\u6574
\n enum LINE_STATUS { LINE_OK = 0, LINE_BAD, LINE_OPEN };<\/p>\n
\/*
\n \u670d\u52a1\u5668\u5904\u7406HTTP\u8bf7\u6c42\u7684\u53ef\u80fd\u7ed3\u679c，\u62a5\u6587\u89e3\u6790\u7684\u7ed3\u679c
\n NO_REQUEST : \u8bf7\u6c42\u4e0d\u5b8c\u6574，\u9700\u8981\u7ee7\u7eed\u8bfb\u53d6\u5ba2\u6237\u6570\u636e
\n GET_REQUEST : \u8868\u793a\u83b7\u5f97\u4e86\u4e00\u4e2a\u5b8c\u6210\u7684\u5ba2\u6237\u8bf7\u6c42
\n BAD_REQUEST : \u8868\u793a\u5ba2\u6237\u8bf7\u6c42\u8bed\u6cd5\u9519\u8bef
\n NO_RESOURCE : \u8868\u793a\u670d\u52a1\u5668\u6ca1\u6709\u8d44\u6e90
\n FORBIDDEN_REQUEST : \u8868\u793a\u5ba2\u6237\u5bf9\u8d44\u6e90\u6ca1\u6709\u8db3\u591f\u7684\u8bbf\u95ee\u6743\u9650
\n FILE_REQUEST : \u6587\u4ef6\u8bf7\u6c42,\u83b7\u53d6\u6587\u4ef6\u6210\u529f
\n INTERNAL_ERROR : \u8868\u793a\u670d\u52a1\u5668\u5185\u90e8\u9519\u8bef
\n CLOSED_CONNECTION : \u8868\u793a\u5ba2\u6237\u7aef\u5df2\u7ecf\u5173\u95ed\u8fde\u63a5\u4e86
\n *\/
\n enum HTTP_CODE { NO_REQUEST, GET_REQUEST, BAD_REQUEST, NO_RESOURCE, FORBIDDEN_REQUEST, FILE_REQUEST, INTERNAL_ERROR, CLOSED_CONNECTION };<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0throw \u5173\u952e\u5b57\u7528\u6765\u663e\u5f0f\u5730\u629b\u51fa\u5f02\u5e38；C++\u4e2d\u7684 throw\u8be6\u89e3_c++ throw-CSDN\u535a\u5ba2<\/p>\n
#include <exception><\/p>\n
throw std::exception(); <\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u4ece\u5806\u4e2d\u5206\u914d\u5185\u5b58，\u5e76\u8fd4\u56de\u4e00\u4e2a\u6307\u5411\u6240\u5206\u914d\u5185\u5b58\u7684\u6307\u9488<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u6307\u5411\u5f53\u524d\u5bf9\u8c61\u7684\u5730\u5740（\u8c03\u7528\u8be5\u6210\u5458\u51fd\u6570\u7684\u5bf9\u8c61\u7684\u5730\u5740）<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u83b7\u53d6\u5f53\u524d\u8def\u5f84\u6700\u540e\u4e00\u4e2a<\/p>\n
memset(\u6307\u5411\u5185\u5b58\u533a\u57df\u7684\u6307\u9488，\u8981\u8bbe\u7f6e\u7684\u7279\u5b9a\u503c，\u8981\u8bbe\u7f6e\u7684\u5b57\u8282\u6bb5);<\/p>\n
try {<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \/\/ \u53ef\u80fd\u53d1\u751f\u5f02\u5e38\u7684\u8bed\u53e5<\/p>\n
} catch {<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \/\/ \u5904\u7406\u5f02\u5e38\u8bed\u53e5<\/p>\n
}<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728\u522b\u7684\u6587\u4ef6\u4e2d\u5b9a\u4e49\u4e86，\u63d0\u9192\u7f16\u8bd1\u5668\u53bb\u627e<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5982\u672c\u9879\u76ee，\u5728http_conn.h\u4e2d\u5b9a\u4e49\u4e86\u4e00\u4e9b\u679a\u4e3e\u7c7b，\u5b9a\u4e49\u4e86\u4e00\u4e9b\u6210\u5458\u51fd\u6570\u8fd4\u56de\u8fd9\u4e9b\u679a\u4e3e\u7c7b\u3002（\u7c7b\u5185\u5b9a\u4e49）<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728\u7c7b\u5916\u5b9e\u73b0\u65f6（http_conn.cpp）\u9700\u5728\u679a\u4e3e\u7c7b\u548c\u6210\u5458\u51fd\u6570\u540d\u524d\u90fd\u52a0\u4e0a\u7c7b\u7684\u4f5c\u7528\u57df，\u4e0d\u7136\u4f1a\u62a5\u9519\u3002<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221329-6802ce896903a.png\")
<\/p>\n
\u53c2\u8003\u8d44\u6599：<\/p>\n
\u3010C++\u3011C++\u4e2d\u5185\u8054\u51fd\u6570\u8be6\u89e3（\u641e\u6e05\u5185\u8054\u7684\u672c\u8d28\u53ca\u7528\u6cd5）-CSDN\u535a\u5ba2<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728\u5b8c\u6210\u4e3b\u4f53\u6846\u67b6\u540e\u8fdb\u884c\u7f16\u8bd1（gcc *.cpp -pthread）\u63d0\u793a\u9519\u8bef\u5982\u4e0b：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221329-6802ce8986487.png\")
<\/p>\n
\u89e3\u51b3\u53c2\u8003\u8d44\u6599：\u4f7f\u7528gcc\u7f16\u8bd1c++\u7a0b\u5e8f\u65f6\u51fa\u73b0\u7c7b\u4f3c\u5bf9\u2018operator new[](unsigned long)\u2019\u672a\u5b9a\u4e49\u7684\u5f15\u7528_\u5bf9\u2018operator new(unsigned long)\u2019\u672a\u5b9a\u4e49\u7684\u5f15\u7528-CSDN\u535a\u5ba2<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u6dfb\u52a0-lstdc++，\u5373\u53ef\u7f16\u8bd1\u6210\u529f<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418221329-6802ce89ea81e.png\")
<\/p><\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e28\u6b21\uff0c\u6536\u85cf10\u6b21\u3002\u2460 \u7f16\u8bd1\u540e\u751f\u6210\u201ca.out\u201d\u7684exe\u6587\u4ef6\uff0c\u8f93\u5165\u547d\u4ee4\u8fd0\u884c\uff08\u6211\u7684Linux\u7684ip\u5730\u5740\u4e3a192.168.200.133\uff09\u5982\u672c\u9879\u76ee\uff0c\u5728http_conn.h\u4e2d\u5b9a\u4e49\u4e86\u4e00\u4e9b\u679a\u4e3e\u7c7b\uff0c\u5b9a\u4e49\u4e86\u4e00\u4e9b\u6210\u5458\u51fd\u6570\u8fd4\u56de\u8fd9\u4e9b\u679a\u4e3e\u7c7b\u3002\u5728\u7c7b\u5916\u5b9e\u73b0\u65f6\uff08http_conn.cpp\uff09\u9700\u5728\u679a\u4e3e\u7c7b\u548c\u6210\u5458\u51fd\u6570\u540d\u524d\u90fd\u52a0\u4e0a\u7c7b\u7684\u4f5c\u7528\u57df\uff0c\u4e0d\u7136\u4f1a\u62a5\u9519\u3002\u2461 \u5728Windows\u7f51\u9875\u4e2d\uff08\u6216Linux\u7684\u706b\u72d0\u6d4f\u89c8\u5668\uff09\u8f93\u5165\u7f51\u5740\u8fde\u63a5\u3002memset(\u6307\u5411\u5185\u5b58\u533a\u57df\u7684\u6307\u9488\uff0c\u8981\u8bbe\u7f6e\u7684\u7279\u5b9a\u503c\uff0c\u8981\u8bbe\u7f6e\u7684\u5b57\u8282\u6bb5);\u6307\u5411\u5f53\u524d\u5bf9\u8c61\u7684\u5730\u5740\uff08\u8c03\u7528\u8be5\u6210\u5458\u51fd\u6570\u7684\u5bf9\u8c61\u7684\u5730\u5740\uff09\/\/ \u53ef\u80fd\u53d1\u751f\u5f02\u5e38\u7684\u8bed\u53e5\u3002_\u9ad8\u5e76\u53d1\u670d\u52a1\u5668\u9879\u76ee<\/p>\n","protected":false},"author":2,"featured_media":22670,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[190],"topic":[],"class_list":["post-22680","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-190"],"yoast_head":"\n