I\/O\u591a\u8def\u590d\u7528\u5668（\u5982epoll）：\u76d1\u542c\u591a\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26（fd）\u7684\u4e8b\u4ef6（\u8bfb\u3001\u5199\u3001\u5f02\u5e38）\u3002<\/p>\n<\/li>\n
\u4e8b\u4ef6\u5206\u53d1\u5668：\u5c06\u5c31\u7eea\u4e8b\u4ef6\u5206\u53d1\u7ed9\u5bf9\u5e94\u7684\u5904\u7406\u5668\u3002<\/p>\n<\/li>\n
\u4e8b\u4ef6\u5904\u7406\u5668：\u6267\u884c\u5177\u4f53\u7684I\/O\u64cd\u4f5c\u548c\u4e1a\u52a1\u903b\u8f91<\/p>\n<\/li>\n<\/ul>\n
\u4e0b\u9762\u5b9e\u73b0\u4e00\u4e2a\u57fa\u4e8eepoll\u7684Reactor\u670d\u52a1\u5668，\u4e3b\u8981\u5206\u4e3a\u4e24\u90e8\u5206：<\/p>\n
- \n
- \n
Epoll\u7c7b：\u5c01\u88c5epoll\u7cfb\u7edf\u8c03\u7528（\u521b\u5efa\u3001\u6dfb\u52a0\u3001\u4fee\u6539\u3001\u5220\u9664fd）\u3002<\/p>\n<\/li>\n
- \n
TcpServer\u7c7b：\u5b9e\u73b0Reactor\u6838\u5fc3\u903b\u8f91（\u4e8b\u4ef6\u5faa\u73af\u3001\u56de\u8c03\u673a\u5236\u3001\u8fde\u63a5\u7ba1\u7406）\u3002<\/p>\n<\/li>\n<\/ul>\n
\u5173\u952e\u7ec4\u4ef6\u89e3\u6790<\/p>\n
1.\u00a0Epoll\u7c7b<\/p>\n
- \n
- \n
\u529f\u80fd：\u5c01\u88c5Linux\u7684epoll\u63a5\u53e3，\u63d0\u4f9b\u5bf9fd\u7684\u589e\u5220\u6539\u67e5\u3002<\/p>\n<\/li>\n
- \n
\u6838\u5fc3\u65b9\u6cd5：<\/p>\n
- \n
- \n
CreateEpoll()：\u521b\u5efaepoll\u5b9e\u4f8b\u3002<\/p>\n<\/li>\n
- \n
AddSockToEpoll()：\u6dfb\u52a0fd\u5230epoll\u76d1\u542c（\u9ed8\u8ba4\u76d1\u542c\u8bfb\u4e8b\u4ef6）\u3002<\/p>\n<\/li>\n
- \n
CtrlEpoll()：\u4fee\u6539fd\u7684\u76d1\u542c\u4e8b\u4ef6（\u5982\u5f00\u542f\u5199\u4e8b\u4ef6）\u3002<\/p>\n<\/li>\n
- \n
WaitEpoll()：\u963b\u585e\u7b49\u5f85\u5c31\u7eea\u4e8b\u4ef6（\u6838\u5fc3\u4e8b\u4ef6\u5faa\u73af\u8c03\u7528）\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
2.\u00a0Connection\u7c7b<\/p>\n
- \n
- \u529f\u80fd：\u4ee3\u8868\u4e00\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5，\u7ba1\u7406\u5176\u72b6\u6001\u548c\u7f13\u51b2\u533a\u3002<\/li>\n
- \u6838\u5fc3\u6210\u5458：\n
- \n
- \n
_sock：\u8fde\u63a5\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u3002<\/p>\n<\/li>\n
- \n
_inbuffer\/_outbuffer：\u8f93\u5165\/\u8f93\u51fa\u7f13\u51b2\u533a（\u5b58\u50a8\u672a\u5904\u7406\u7684\u6570\u636e\u6216\u5f85\u53d1\u9001\u7684\u6570\u636e）\u3002<\/p>\n<\/li>\n
- \n
\u56de\u8c03\u51fd\u6570：<\/p>\n
- \n
- \n
_recv_cb：\u8bfb\u4e8b\u4ef6\u56de\u8c03（\u5982\u63a5\u6536\u6570\u636e）\u3002<\/p>\n<\/li>\n
- \n
_send_cb：\u5199\u4e8b\u4ef6\u56de\u8c03（\u5982\u53d1\u9001\u6570\u636e）\u3002<\/p>\n<\/li>\n
- \n
_except_cb：\u5f02\u5e38\u56de\u8c03（\u5982\u8fde\u63a5\u65ad\u5f00）\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
3.\u00a0TcpServer\u7c7b<\/p>\n
- \n
- \n
\u529f\u80fd：Reactor\u7684\u6838\u5fc3\u5b9e\u73b0，\u7ba1\u7406\u76d1\u542c\u5957\u63a5\u5b57\u3001\u8fde\u63a5\u548c\u4e8b\u4ef6\u5faa\u73af\u3002<\/p>\n<\/li>\n
- \n
\u6838\u5fc3\u6d41\u7a0b：<\/p>\n
- \n
\u521d\u59cb\u5316：<\/p>\n
- \n
\u521b\u5efa\u76d1\u542c\u5957\u63a5\u5b57（_listensock）\u5e76\u6dfb\u52a0\u5230epoll\u3002<\/p>\n<\/li>\n
- \n
\u8bbe\u7f6eAccepter\u4e3a_listensock\u7684\u8bfb\u56de\u8c03（\u5904\u7406\u65b0\u8fde\u63a5）\u3002<\/p>\n<\/li>\n<\/li>\n
- \n
\u4e8b\u4ef6\u5faa\u73af：<\/p>\n
- \n
- \n
\u8c03\u7528WaitEpoll()\u83b7\u53d6\u5c31\u7eea\u4e8b\u4ef6\u3002<\/p>\n<\/li>\n
- \n
\u6839\u636e\u4e8b\u4ef6\u7c7b\u578b（EPOLLIN\/EPOLLOUT）\u89e6\u53d1\u5bf9\u5e94\u7684\u56de\u8c03（\u5982Recver\u6216Sender）\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
- \n
\u56de\u8c03\u51fd\u6570：<\/p>\n
- \n
- \n
Accepter：\u63a5\u53d7\u65b0\u8fde\u63a5，\u521b\u5efaConnection\u5bf9\u8c61\u5e76\u6ce8\u518c\u5230epoll\u3002<\/p>\n<\/li>\n
- \n
Recver：\u975e\u963b\u585e\u8bfb\u53d6\u6570\u636e\u5230_inbuffer，\u89e3\u6790\u540e\u8c03\u7528\u4e1a\u52a1\u56de\u8c03_cb\u3002<\/p>\n<\/li>\n
- \n
Sender：\u975e\u963b\u585e\u53d1\u9001_outbuffer\u4e2d\u7684\u6570\u636e，\u6309\u9700\u5f00\u542f\/\u5173\u95ed\u5199\u4e8b\u4ef6\u76d1\u542c\u3002<\/p>\n<\/li>\n
- \n
Excepter：\u5904\u7406\u8fde\u63a5\u5f02\u5e38（\u79fb\u9664fd\u3001\u91ca\u653e\u8d44\u6e90）\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/li>\n<\/ul>\n
Reactor\u5de5\u4f5c\u6d41\u7a0b<\/p>\n
- \n
\u542f\u52a8\u670d\u52a1\u5668：<\/p>\n
- \n
- \n
\u521b\u5efaepoll\u5b9e\u4f8b，\u76d1\u542c_listensock\u7684\u8bfb\u4e8b\u4ef6\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
- \n
\u63a5\u53d7\u65b0\u8fde\u63a5：<\/p>\n
- \n
- \n
\u5f53_listensock\u5c31\u7eea\u65f6，Accepter\u88ab\u8c03\u7528，\u901a\u8fc7accept\u83b7\u53d6\u65b0\u8fde\u63a5，\u6ce8\u518c\u5230epoll\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
- \n
\u5904\u7406I\/O\u4e8b\u4ef6：<\/p>\n
- \n
- \n
\u8bfb\u4e8b\u4ef6：Recver\u8bfb\u53d6\u6570\u636e\u5230\u7f13\u51b2\u533a，\u89e3\u6790\u540e\u4ea4\u7ed9\u4e1a\u52a1\u903b\u8f91（_cb）\u3002<\/p>\n<\/li>\n
- \n
\u5199\u4e8b\u4ef6：Sender\u53d1\u9001_outbuffer\u4e2d\u7684\u6570\u636e，\u53d1\u5b8c\u540e\u5173\u95ed\u5199\u4e8b\u4ef6\u76d1\u542c（\u907f\u514d\u5fd9\u7b49\u5f85）\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
- \n
\u5f02\u5e38\u5904\u7406：<\/p>\n
- \n
- \n
\u8fde\u63a5\u51fa\u9519\u6216\u5173\u95ed\u65f6，Excepter\u6e05\u7406\u8d44\u6e90（\u79fb\u9664fd\u3001\u5173\u95edsocket）<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
Log.hpp\u548c\u4ee5\u524d\u4e00\u6837，\u56e0\u4e3a\u4e0b\u9762\u8981\u5199ET\u6a21\u5f0f\u6240\u4ee5Sock.hpp\u52a0\u4e86\u4e00\u4e2a\u628asock\u8bbe\u7f6e\u6210\u975e\u963b\u585e\u7684\u51fd\u6570：（\u8981#include <fcntl.h>）<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141007-6988993f6b1a6.png\")
<\/p>\n\u5199\u5230TcpServer.hpp\u7684Accepter\u51fd\u6570\u518d\u6539\u4e00\u4e0bSock.hpp\u7684Accept：（\u52a0\u4e00\u4e2a\u8f93\u51fa\u9519\u8bef\u7801\u7684\u53c2\u6570）<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141007-6988993fa58f4.png\")
<\/p>\n1.1 Sock.hpp<\/h4>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <string>
\n#include <cstring>
\n#include <cerrno>
\n#include <unistd.h>
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <arpa\/inet.h>
\n#include <netinet\/in.h>
\n#include <ctype.h>
\n#include "Log.hpp"
\n#include <fcntl.h><\/p>\nclass Sock
\n{
\nprivate:
\n const static int gbacklog = 20; \/\/ listen\u7684\u7b2c\u4e8c\u4e2a\u53c2\u6570，\u73b0\u5728\u5148\u4e0d\u7ba1
\npublic:
\n Sock()
\n {}
\n ~Sock()
\n {}
\n static int Socket()
\n {
\n int listensock = socket(AF_INET, SOCK_STREAM, 0); \/\/ \u57df + \u7c7b\u578b + 0 \/\/ UDP\u7b2c\u4e8c\u4e2a\u53c2\u6570\u662fSOCK_DGRAM
\n if (listensock < 0)
\n {
\n logMessage(FATAL, "create socket error, %d:%s", errno, strerror(errno));
\n exit(2);
\n }
\n int opt = 1;
\n setsockopt(listensock, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt));
\n logMessage(NORMAL, "create socket success, listensock: %d", listensock);
\n return listensock;
\n }<\/p>\nstatic void Bind(int sock, uint16_t port, std::string ip = "0.0.0.0")
\n {
\n struct sockaddr_in local;
\n memset(&local, 0, sizeof local);
\n local.sin_family = AF_INET;
\n local.sin_port = htons(port);
\n inet_pton(AF_INET, ip.c_str(), &local.sin_addr);
\n if (bind(sock, (struct sockaddr *)&local, sizeof(local)) < 0)
\n {
\n logMessage(FATAL, "bind error, %d:%s", errno, strerror(errno));
\n exit(3);
\n }
\n }<\/p>\nstatic void Listen(int sock)
\n {
\n if (listen(sock, gbacklog) < 0)
\n {
\n logMessage(FATAL, "listen error, %d:%s", errno, strerror(errno));
\n exit(4);
\n }
\n logMessage(NORMAL, "init server success");
\n }<\/p>\n\/\/ \u4e00\u822c\u60c5\u51b5\u4e0b：
\n \/\/ const std::string &: \u8f93\u5165\u578b\u53c2\u6570
\n \/\/ std::string *: \u8f93\u51fa\u578b\u53c2\u6570
\n \/\/ std::string &: \u8f93\u5165\u8f93\u51fa\u578b\u53c2\u6570
\n static int Accept(int listensock, std::string *ip, uint16_t *port, int *accept_errno = nullptr)
\n {
\n struct sockaddr_in src;
\n socklen_t len = sizeof(src);
\n *accept_errno = 0;
\n int servicesock = accept(listensock, (struct sockaddr *)&src, &len);
\n if (servicesock < 0)
\n {
\n *accept_errno = errno;
\n \/\/ logMessage(ERROR, "accept error, %d:%s", errno, strerror(errno));
\n return -1;
\n }
\n if (port)
\n *port = ntohs(src.sin_port);
\n if (ip)
\n *ip = inet_ntoa(src.sin_addr);
\n return servicesock;
\n }<\/p>\nstatic bool Connect(int sock, const std::string &server_ip, const uint16_t &server_port)
\n {
\n struct sockaddr_in server;
\n memset(&server, 0, sizeof(server));
\n server.sin_family = AF_INET;
\n server.sin_port = htons(server_port);
\n server.sin_addr.s_addr = inet_addr(server_ip.c_str());<\/p>\nif (connect(sock, (struct sockaddr *)&server, sizeof(server)) == 0)
\n return true;
\n else
\n return false;
\n }<\/p>\nstatic bool SetNonBlock(int sock)
\n {
\n int fl = fcntl(sock, F_GETFL);
\n if(fl < 0)
\n return false;
\n fcntl(sock, F_SETFL, fl | O_NONBLOCK);
\n return true;
\n }
\n};<\/p>\n\u4e0b\u9762\u76f4\u63a5\u653e\u4e00\u90e8\u5206TcpServer.hpp\u4ee3\u7801\u8ddf\u7740\u6ce8\u91ca\u770b：（\u5efa\u8bae\u590d\u5236\u5230VSCode\u91cc\u770b）<\/p>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <functional>
\n#include <string>
\n#include <unordered_map>
\n#include "Sock.hpp"
\n#include "Log.hpp"
\n#include "Epoll.hpp"<\/p>\nclass TcpServer;
\nclass Connection;<\/p>\nusing func_t = std::function<void(Connection *)>;
\n\/\/ \u4e3a\u4e86\u80fd\u591f\u6b63\u5e38\u5de5\u4f5c，\u5e38\u89c4\u7684sock\u5fc5\u987b\u8981\u6709\u72ec\u7acb\u7684\u63a5\u6536\u7f13\u51b2\u533a\u548c\u53d1\u9001\u7f13\u51b2\u533a(\u5199\u5165)
\nclass Connection \/\/ \u4e00\u4e2a\u94fe\u63a5\u7c7b
\n{
\npublic:
\n Connection(int sock = -1)
\n : _sock(sock), _tsvr(nullptr)
\n {}
\n void SetCallBack(func_t recv_cb, func_t send_cb, func_t except_cb)
\n { \/\/ \u8bbe\u7f6e\u4e09\u4e2a\u56de\u8c03\u65b9\u6cd5
\n _recv_cb = recv_cb;
\n _send_cb = send_cb;
\n _except_cb = except_cb;
\n }
\n ~Connection()
\n {}
\npublic:
\n int _sock; \/\/ \u8d1f\u8d23\u8fdb\u884cIO\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n func_t _recv_cb; \/\/ \u4e09\u4e2a\u56de\u8c03\u65b9\u6cd5，\u662f\u5bf9_sock\u8fdb\u884c\u7279\u5b9a\u8bfb\u5199\u7684\u5bf9\u5e94\u65b9\u6cd5
\n func_t _send_cb;
\n func_t _except_cb;<\/p>\nstd::string _inbuffer; \/\/ \u63a5\u6536\u7f13\u51b2\u533a&&\u53d1\u9001\u7f13\u51b2\u533a
\n std::string _outbuffer; \/\/ \u8fd9\u4e24string\u6682\u65f6\u6ca1\u6709\u529e\u6cd5\u5904\u7406\u4e8c\u8fdb\u5236\u6d41，\u6587\u672c\u662f\u53ef\u4ee5\u7684<\/p>\nTcpServer *_tsvr; \/\/ \u8bbe\u7f6e\u5bf9TcpServer\u7684\u56de\u6307\u6307\u9488，\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u5fc3\u662f\u6309\u9700\u6253\u5f00
\n};<\/p>\nclass TcpServer
\n{
\n const static int gport = 8080;
\n const static int gnum = 128;
\npublic:
\n TcpServer(int port = gport)
\n : _port(port), _revs_num(gnum)
\n {
\n \/\/ 1. \u521b\u5efalistensock
\n _listensock = Sock::Socket();
\n Sock::Bind(_listensock, _port);
\n Sock::Listen(_listensock);<\/p>\n\/\/ 2. \u521b\u5efa\u591a\u8def\u8f6c\u63a5\u5bf9\u8c61
\n _poll.CreateEpoll();<\/p>\n\/\/ 3. \u6dfb\u52a0listensock\u5230\u670d\u52a1\u5668\u4e2d -> \u4e09\u6b65(\u7c7b\u7684\u6784\u9020\u51fd\u6570\u4e5f\u80fd\u8c03\u7528\u7c7b\u7684\u6210\u5458\u65b9\u6cd5，\u8d70\u5230\u51fd\u6570\u4f53\u4e2d\u5bf9\u8c61\u5df2\u7ecf\u5b58\u5728\u4e86)
\n \/\/ \u540e\u4e09\u4e2a\u53c2\u6570\u662f\u51fd\u6570\u5bf9\u8c61，\u8981bind\u7ed1\u5b9a\u8fd4\u56de\u4e00\u4e2a\u51fd\u6570\u5bf9\u8c61->\u7c7b\u5185\u51fd\u6570\u6709this\u6307\u9488，_1\u662f\u9884\u7559\u7684\u53c2\u6570
\n AddConnection(_listensock, std::bind(&TcpServer::Accepter, this, std::placeholders::_1), nullptr, nullptr);<\/p>\n\/\/ 4. \u6784\u5efa\u4e00\u4e2a\u83b7\u53d6\u5c31\u7eea\u4e8b\u4ef6\u7684\u7f13\u51b2\u533a
\n _revs = new struct epoll_event[_revs_num];
\n }
\n void AddConnection(int sock, func_t recv_cb, func_t send_cb, func_t except_cb) \/\/ \u628a\u4efb\u610fsock\u8fdb\u884c\u6dfb\u52a0\u5230TcpServer
\n {
\n Sock::SetNonBlock(sock); \/\/ ET\u6a21\u5f0f\u8981\u628asock\u8bbe\u7f6e\u6210\u975e\u963b\u585e -> \u5728Sock.hpp\u4e2d\u5199\u6210\u51fd\u6570<\/p>\n\/\/ \u9664\u4e86_listensock，\u540e\u9762\u8fd8\u4f1a\u5b58\u5728\u5927\u91cf\u7684socket，\u6bcf\u4e00\u4e2asock\u90fd\u5fc5\u987b\u88ab\u5c01\u88c5\u6210\u4e3a\u4e00\u4e2aConnection
\n \/\/ \u5f53\u670d\u52a1\u5668\u4e2d\u5b58\u5728\u5927\u91cf\u7684Connection\u65f6，TcpServer\u9700\u8981\u5c06\u6240\u6709Connection\u8fdb\u884c\u7ba1\u7406：\u4e0a\u9762\u63cf\u8ff0\u4e86，\u7ec4\u7ec7 -> unordered_map
\n \/\/ 3.1 \u6784\u5efaconn\u5bf9\u8c61，\u5c01\u88c5sock
\n Connection *conn = new Connection(sock);
\n conn->SetCallBack(recv_cb, send_cb, except_cb);
\n conn->_tsvr = this;<\/p>\n\/\/ 3.2 \u6dfb\u52a0sock\u5230epoll\u4e2d(\u4efb\u52a1\u901a\u77e5)->\u8981\u77e5\u9053sock\u548c\u4e8b\u4ef6(\u4efb\u4f55\u591a\u8def\u8f6c\u63a5\u7684\u670d\u52a1\u5668，\u4e00\u822c\u53ea\u4f1a\u6253\u5f00\u8bfb\u53d6\u4e8b\u4ef6，\u5199\u5165\u4e8b\u4ef6\u6309\u9700\u6253\u5f00)
\n _poll.AddSockToEpoll(sock, EPOLLIN | EPOLLET);<\/p>\n\/\/ 3.3 \u5c06\u5bf9\u5e94\u7684Connection*\u5bf9\u8c61\u6307\u9488\u6dfb\u52a0\u5230Connections\u6620\u5c04\u8868\u4e2d(\u4e1a\u52a1\u5904\u7406)
\n _connections.insert(std::make_pair(sock, conn));
\n }<\/p>\nvoid Accepter(Connection *conn)
\n {
\n logMessage(DEBUG, "Accepter been called");
\n }<\/p>\nvoid Dispather() \/\/ \u6839\u636e\u5c31\u7eea\u7684\u4e8b\u4ef6，\u8fdb\u884c\u7279\u5b9a\u4e8b\u4ef6\u7684\u6d3e\u53d1
\n {
\n while (true)
\n {
\n LoopOnce();
\n }
\n }
\n void LoopOnce()
\n {
\n int n = _poll.WaitEpoll(_revs, _revs_num);
\n for (int i = 0; i < n; i++) \/\/ \u83b7\u53d6\u4e8b\u4ef6
\n {
\n int sock = _revs[i].data.fd;
\n uint32_t revents = _revs[i].events;
\n if (revents & EPOLLIN) \/\/ \u8bfb\u5c31\u7eea
\n {
\n \/\/ if(Connection\u662f\u5b58\u5728\u5e76\u4e14_connections[sock]->_recv_cb\u88ab\u8bbe\u7f6e\u8fc7)
\n if (IsConnectionExists(sock) && _connections[sock]->_recv_cb != nullptr)
\n _connections[sock]->_recv_cb(_connections[sock]); \/\/ \u8c03\u7528\u8bfb\u4e8b\u4ef6\u7684\u56de\u8c03
\n }
\n if (revents & EPOLLOUT) \/\/ \u5199\u5c31\u7eea
\n {
\n \/\/ if(Connection\u662f\u5b58\u5728\u5e76\u4e14_connections[sock]->_send_cb\u88ab\u8bbe\u7f6e\u8fc7)
\n if (IsConnectionExists(sock) && _connections[sock]->_send_cb != nullptr)
\n _connections[sock]->_send_cb(_connections[sock]); \/\/ \u8c03\u7528\u5199\u4e8b\u4ef6\u7684\u56de\u8c03
\n }
\n }
\n }
\n bool IsConnectionExists(int sock) \/\/ \u5224\u5b9aConnection\u662f\u5426\u5b58\u5728
\n {
\n auto iter = _connections.find(sock);
\n if (iter == _connections.end())
\n return false;
\n else
\n return true;
\n }
\n ~TcpServer()
\n {
\n if (_listensock >= 0)
\n close(_listensock);
\n if (_revs)
\n delete[] _revs;
\n }
\nprivate:
\n int _listensock;
\n int _port;
\n Epoll _poll;
\n std::unordered_map<int, Connection *> _connections; \/\/ \u7ba1\u7406：sock\u6620\u5c04\u5230Connection
\n struct epoll_event *_revs; \/\/ \u5c31\u7eea\u4e8b\u4ef6\u7f13\u51b2\u533a,\u5c31\u7eea\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u6295\u9012\u5230\u8fd9\u91cc
\n int _revs_num; \/\/ \u5c31\u7eea\u4e8b\u4ef6\u7f13\u51b2\u533a\u5927\u5c0f
\n};<\/p>\n\u7f16\u8bd1\u8fd0\u884c：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141008-698899405ed70.png\")
<\/p>\n\u6b64\u65f6\u6210\u529f\u8c03\u7528\u4e86Accepter，\u56e0\u4e3a\u662fET\u6a21\u5f0f，\u6240\u4ee5\u662f\u963b\u585e\u7684，\u4e8b\u4ef6\u6ca1\u5904\u7406\u4e5f\u6ca1\u6709\u8fde\u7eed\u6253\u5370\u3002<\/p>\n
\u5199\u4e00\u4e0bAccepter\u518d\u6d4b\u8bd5\u4e00\u4e0b：<\/p>\n
void Accepter(Connection *conn)
\n {
\n \/\/ logMessage(DEBUG, "Accepter been called");
\n \/\/ \u4e00\u5b9a\u662flistensock\u5df2\u7ecf\u5c31\u7eea\u4e86，\u6b64\u6b21\u8bfb\u53d6\u4e0d\u4f1a\u963b\u585e，
\n \/\/ \u600e\u4e48\u4fdd\u8bc1，\u5e95\u5c42\u53ea\u6709\u4e00\u4e2a\u8fde\u63a5\u5c31\u7eea\u5462 -> \u5faa\u73af，\u76f4\u5230\u83b7\u53d6\u5931\u8d25
\n while (true)
\n {
\n std::string clientip;
\n uint16_t clientport;
\n int accept_errno = 0;
\n \/\/ sock\u4e00\u5b9a\u662f\u5e38\u89c4\u7684IO sock
\n int sock = Sock::Accept(conn->_sock, &clientip, &clientport, &accept_errno);
\n if (sock < 0) \/\/ \u83b7\u53d6\u5931\u8d25
\n {
\n if (accept_errno == EAGAIN || accept_errno == EWOULDBLOCK)
\n break;
\n else if (accept_errno == EINTR) \/\/ \u6982\u7387\u975e\u5e38\u4f4e
\n continue;
\n else \/\/ accept\u5931\u8d25
\n {
\n logMessage(WARNING, "accept error, %d : %s", accept_errno, strerror(accept_errno));
\n break;
\n }
\n }
\n else \/\/ (sock>=0)\u83b7\u53d6\u94fe\u63a5\u6210\u529f->\u5c06sock\u6258\u7ba1\u7ed9TcpServer
\n {
\n AddConnection(sock, std::bind(&TcpServer::Recver, this, std::placeholders::_1),
\n std::bind(&TcpServer::Sender, this, std::placeholders::_1),
\n std::bind(&TcpServer::Excepter, this, std::placeholders::_1));
\n logMessage(DEBUG, "accept client %s:%d success, add to epoll&&TcpServer success, sock: %d",\\\\
\n clientip.c_str(), clientport, sock);
\n }
\n }
\n }<\/p>\nvoid Recver(Connection *conn) \/\/ \u8bfb\u53d6\u4e00\u4e2a\u6b63\u5e38\u7684sock
\n {
\n logMessage(DEBUG, "Recver event exists, Recver() been called");
\n }<\/p>\nvoid Sender(Connection *conn)
\n {
\n }<\/p>\nvoid Excepter(Connection *conn)
\n {
\n }<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141008-69889940b83f9.png\")
<\/p>\n\u6210\u529f\u83b7\u53d6\u5230\u8bfb\u53d6\u4e8b\u4ef6，\u4e0b\u9762\u6765\u5904\u7406\u4e00\u4e0b：<\/p>\n
\u5148\u5199Recver\u7684\u7b2c\u4e00\u4e2a\u7248\u672c：\u76f4\u63a5\u9762\u5411\u5b57\u8282\u6d41，\u8fdb\u884c\u5e38\u89c4\u8bfb\u53d6：<\/p>\n
void Recver(Connection *conn) \/\/ \u8bfb\u53d6\u4e00\u4e2a\u6b63\u5e38\u7684sock
\n {
\n \/\/ logMessage(DEBUG, "Recver event exists, Recver() been called");
\n \/\/ v1: \u76f4\u63a5\u9762\u5411\u5b57\u8282\u6d41，\u5148\u8fdb\u884c\u5e38\u89c4\u8bfb\u53d6
\n const int num = 1024;
\n while (true)
\n {
\n char buffer[num];
\n ssize_t n = recv(conn->_sock, buffer, sizeof(buffer) – 1, 0);
\n if (n < 0)
\n {
\n if (errno == EAGAIN || errno == EWOULDBLOCK) \/\/ \u8bfb\u53d6\u5b8c\u6bd5\u4e86，\u6b63\u5e38\u7684
\n break;
\n else if (errno == EINTR) \/\/ \u8bfb\u53d6\u88ab\u4e2d\u65ad\u4e86，\u91cd\u65b0\u5f00\u59cb\u8bfb
\n continue;
\n else \/\/ \u771f\u6b63\u8bfb\u53d6\u5931\u8d25 -> \u4ea4\u7ed9\u5f02\u5e38\u56de\u8c03
\n {
\n logMessage(ERROR, "recv error, %d : %s", errno, strerror(errno));
\n conn->_except_cb(conn);
\n break;
\n }
\n }
\n else if (n == 0)
\n {
\n logMessage(DEBUG, "client[%d] quit, server close [%d]", conn->_sock, conn->_sock);
\n conn->_except_cb(conn);
\n break;
\n }
\n else \/\/ \u8bfb\u53d6\u6210\u529f
\n {
\n buffer[n] = 0;
\n conn->_inbuffer += buffer; \/\/ \u8bfb\u53d6\u5230\u7684\u6570\u636e\u5168\u90e8\u62fc\u63a5\u5230\u63a5\u6536\u7f13\u51b2\u533a
\n }
\n }
\n logMessage(DEBUG, "conn->_inbuffer[sock: %d]: %s", conn->_sock, conn->_inbuffer.c_str());
\n }<\/p>\n\u6bcf\u4e2a\u670d\u52a1\u7aef\u90fd\u6709\u81ea\u5df1\u7684\u63a5\u6536\u7f13\u51b2\u533a，\u4e92\u4e0d\u5f71\u54cd（\u8fd9\u91cc\u56de\u8f66\u4e5f\u88ab\u8f93\u5165\u8fdb\u53bb\u4e86\u53ea\u662ftelnet\u7684\u539f\u56e0，\u8fd9\u91cc\u4e0d\u5199\u5ba2\u6237\u7aef\u4e86\u5c31\u8fd9\u4e48\u7528\u4e86），\u4f46\u8fd8\u662f\u90a3\u53e5\u8bdd：\u600e\u4e48\u4fdd\u8bc1\u4f60\u8bfb\u5230\u7684\u662f\u4e00\u4e2a\u5b8c\u6574\u7684\u62a5\u6587\u5462？->\u5c31\u8981\u5b9a\u5236\u534f\u8bae\u4e86，\u5199\u4e00\u4e2aProtocol.hpp：<\/p>\n
1.2 \u52a0\u534f\u8bae\u5206\u5272\u62a5\u6587<\/h4>\n
\u5728\u524d\u9762\u52a0\u4e0a\u8fd9\u884c：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141009-6988994111a51.png\")
<\/p>\n\u52a0\u4e2a\u7c7b\u5185\u6210\u5458：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141009-6988994151d78.png\")
<\/p>\nDispather：<\/p>\n
void Dispather(callback_t cb) \/\/ \u6839\u636e\u5c31\u7eea\u7684\u4e8b\u4ef6，\u8fdb\u884c\u7279\u5b9a\u4e8b\u4ef6\u7684\u6d3e\u53d1
\n {
\n _cb = cb;
\n while (true)
\n {
\n LoopOnce();
\n }
\n }<\/p>\nmain.cc：<\/p>\n
#include "TcpServer.hpp"
\n#include <memory><\/p>\nvoid NetCal(Connection *conn, std::string &request)
\n{
\n logMessage(DEBUG, "NetCal been called, get request: %s", request.c_str());
\n}<\/p>\nint main()
\n{
\n std::unique_ptr<TcpServer> svr(new TcpServer());
\n svr->Dispather(NetCal);<\/p>\nreturn 0;
\n}<\/p>\n\u6539\u8fdb\u7684Recver：<\/p>\n
void Recver(Connection *conn) \/\/ \u8bfb\u53d6\u4e00\u4e2a\u6b63\u5e38\u7684sock
\n {
\n const int num = 1024;
\n bool err = false;
\n \/\/ logMessage(DEBUG, "Recver event exists, Recver() been called");
\n while (true)
\n {
\n char buffer[num];
\n ssize_t n = recv(conn->_sock, buffer, sizeof(buffer) – 1, 0);
\n if (n < 0)
\n {
\n if (errno == EAGAIN || errno == EWOULDBLOCK) \/\/ \u8bfb\u53d6\u5b8c\u6bd5\u4e86，\u6b63\u5e38\u7684
\n break;
\n else if (errno == EINTR) \/\/ \u8bfb\u53d6\u88ab\u4e2d\u65ad\u4e86，\u91cd\u65b0\u5f00\u59cb\u8bfb
\n continue;
\n else \/\/ \u771f\u6b63\u8bfb\u53d6\u5931\u8d25 -> \u4ea4\u7ed9\u5f02\u5e38\u56de\u8c03
\n {
\n logMessage(ERROR, "recv error, %d : %s", errno, strerror(errno));
\n conn->_except_cb(conn);
\n err = true;
\n break;
\n }
\n }
\n else if (n == 0)
\n {
\n logMessage(DEBUG, "client[%d] quit, server close [%d]", conn->_sock, conn->_sock);
\n conn->_except_cb(conn);
\n err = true;
\n break;
\n }
\n else \/\/ \u8bfb\u53d6\u6210\u529f
\n {
\n buffer[n] = 0;
\n conn->_inbuffer += buffer; \/\/ \u8bfb\u53d6\u5230\u7684\u6570\u636e\u5168\u90e8\u62fc\u63a5\u5230\u63a5\u6536\u7f13\u51b2\u533a
\n }
\n }
\n logMessage(DEBUG, "conn->_inbuffer[sock: %d]: %s", conn->_sock, conn->_inbuffer.c_str());
\n if (!err) \/\/ \u5982\u679c\u9519\u8bef\u7801\u8fd8\u662ffalse\u5c31\u662f\u6b63\u5e38break\u7684
\n {
\n std::vector<std::string> messages;
\n SpliteMessage(conn->_inbuffer, &messages);
\n \/\/ \u4fdd\u8bc1\u8d70\u5230\u8fd9\u91cc，\u5c31\u662f\u4e00\u4e2a\u5b8c\u6574\u62a5\u6587
\n for (auto &msg : messages)
\n { \/\/ \u53ef\u4ee5\u5728\u8fd9\u91cc\u5c06message\u5c01\u88c5\u6210\u4e3atask,\u7136\u540epush\u5230\u4efb\u52a1\u961f\u5217,\u4efb\u52a1\u5904\u7406\u4ea4\u7ed9\u540e\u7aef\u7ebf\u7a0b\u6c60,\u8fd9\u91cc\u4e0d\u5904\u7406
\n _cb(conn, msg);
\n }
\n }
\n }<\/p>\n\u4e00\u90e8\u5206Protocol.hpp：（\u8fd9\u91cc\u7528\u5927\u5199X\u4f5c\u4e3a\u5207\u5206）<\/p>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <cstring>
\n#include <string>
\n#include <vector><\/p>\n\/\/ 1. \u62a5\u6587\u548c\u62a5\u6587\u4e4b\u95f4，\u6211\u4eec\u91c7\u7528\u7279\u6b8a\u5b57\u7b26\u6765\u8fdb\u884c\u89e3\u51b3\u7c98\u5305\u95ee\u9898
\n\/\/ 2. \u83b7\u53d6\u4e00\u4e2a\u4e00\u4e2a\u72ec\u7acb\u5b8c\u6574\u7684\u62a5\u6587，\u5e8f\u5217\u548c\u53cd\u5e8f\u5217\u5316 — \u81ea\u5b9a\u4e49
\n\/\/ 100+19X100+19X100+19
\n#define SEP "X"
\n#define SEP_LEN strlen(SEP)<\/p>\n\/\/ \u8981\u628a\u4f20\u5165\u8fdb\u6765\u7684\u7f13\u51b2\u533a\u8fdb\u884c\u5207\u5206，\u8981\u6c42：
\n\/\/ 1. buffer\u88ab\u5207\u8d70\u7684，\u4e5f\u540c\u65f6\u8981\u4ecebuffer\u4e2d\u79fb\u9664
\n\/\/ 2. \u53ef\u80fd\u4f1a\u5b58\u5728\u591a\u4e2a\u62a5\u6587，\u591a\u4e2a\u62a5\u6587\u4f9d\u6b21\u653e\u5165out
\nvoid SpliteMessage(std::string &buffer, std::vector<std::string> *out) \/\/ \u5206\u5272\u62a5\u6587
\n{ \/\/ buffer: \u8f93\u5165\u8f93\u51fa\u578b\u53c2\u6570，out: \u8f93\u51fa\u578b\u53c2\u6570
\n while (true)
\n {
\n auto pos = buffer.find(SEP); \/\/ \u5728\u7f13\u51b2\u533a\u91cc\u627e\u5206\u9694\u7b26
\n if (std::string::npos == pos) \/\/ \u627e\u4e0d\u5230\u5c31break
\n break;
\n std::string message = buffer.substr(0, pos); \/\/ \u63d0\u53d6\u5b50\u4e32：\u524d\u95ed\u540e\u5f00\u533a\u95f4
\n buffer.erase(0, pos + SEP_LEN); \/\/ \u79fb\u9664\u5b50\u4e32\u548c\u8861\u5a25\u798f
\n out->push_back(message); \/\/ push_back\u5b8c\u6574\u7684\u5b50\u4e32
\n \/\/ std::cout << "debug: " << message << " : " << buffer << std::endl;
\n \/\/ sleep(1);
\n }
\n}<\/p>\n
\n1.3 \u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316<\/h4>\n
\u628a\u4ee5\u524d\u81ea\u5df1\u5199\u7684\u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316\u590d\u5236\u5230Protocol.hpp：<\/p>\n
Protocol.hpp<\/h5>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <cstring>
\n#include <string>
\n#include <vector><\/p>\n\/\/ 1. \u62a5\u6587\u548c\u62a5\u6587\u4e4b\u95f4，\u6211\u4eec\u91c7\u7528\u7279\u6b8a\u5b57\u7b26\u6765\u8fdb\u884c\u89e3\u51b3\u7c98\u5305\u95ee\u9898
\n\/\/ 2. \u83b7\u53d6\u4e00\u4e2a\u4e00\u4e2a\u72ec\u7acb\u5b8c\u6574\u7684\u62a5\u6587，\u5e8f\u5217\u548c\u53cd\u5e8f\u5217\u5316 — \u81ea\u5b9a\u4e49
\n\/\/ 100+19X100+19X100+19
\n#define SEP "X"
\n#define SEP_LEN strlen(SEP)<\/p>\n\/\/ \u8981\u628a\u4f20\u5165\u8fdb\u6765\u7684\u7f13\u51b2\u533a\u8fdb\u884c\u5207\u5206，\u8981\u6c42：
\n\/\/ 1. buffer\u88ab\u5207\u8d70\u7684，\u4e5f\u540c\u65f6\u8981\u4ecebuffer\u4e2d\u79fb\u9664
\n\/\/ 2. \u53ef\u80fd\u4f1a\u5b58\u5728\u591a\u4e2a\u62a5\u6587，\u591a\u4e2a\u62a5\u6587\u4f9d\u6b21\u653e\u5165out
\nvoid SpliteMessage(std::string &buffer, std::vector<std::string> *out) \/\/ \u5206\u5272\u62a5\u6587
\n{ \/\/ buffer: \u8f93\u5165\u8f93\u51fa\u578b\u53c2\u6570，out: \u8f93\u51fa\u578b\u53c2\u6570
\n while (true)
\n {
\n auto pos = buffer.find(SEP); \/\/ \u5728\u7f13\u51b2\u533a\u91cc\u627e\u5206\u9694\u7b26
\n if (std::string::npos == pos) \/\/ \u627e\u4e0d\u5230\u5c31break
\n break;
\n std::string message = buffer.substr(0, pos); \/\/ \u63d0\u53d6\u5b50\u4e32：\u524d\u95ed\u540e\u5f00\u533a\u95f4
\n buffer.erase(0, pos + SEP_LEN); \/\/ \u79fb\u9664\u5b50\u4e32\u548c\u8861\u5a25\u798f
\n out->push_back(message); \/\/ push_back\u5b8c\u6574\u7684\u5b50\u4e32
\n \/\/ std::cout << "debug: " << message << " : " << buffer << std::endl;
\n \/\/ sleep(1);
\n }
\n}<\/p>\n\/\/ \u81ea\u5df1\u624b\u5199\u5e8f\u5217\u53cd\u5e8f\u5217\u5316
\n#define SPACE " "
\n#define SPACE_LEN strlen(SPACE)<\/p>\nstd::string Encode(std::string& s)
\n{
\n return s + SEP;
\n}<\/p>\nclass Request
\n{
\npublic:
\n std::string Serialize()
\n {
\n std::string str;
\n str = std::to_string(_x);
\n str += SPACE;
\n str += _op;
\n str += SPACE;
\n str += std::to_string(_y);
\n return str;
\n }
\n bool Deserialized(const std::string& str) \/\/ 1 + 1
\n {
\n std::size_t left = str.find(SPACE);
\n if (left == std::string::npos)
\n return false;
\n std::size_t right = str.rfind(SPACE);
\n if (right == std::string::npos)
\n return false;
\n _x = atoi(str.substr(0, left).c_str());
\n _y = atoi(str.substr(right + SPACE_LEN).c_str());
\n if (left + SPACE_LEN > str.size())
\n return false;
\n else
\n _op = str[left + SPACE_LEN];
\n return true;
\n }<\/p>\npublic:
\n Request()
\n {}
\n Request(int x, int y, char op)
\n : _x(x), _y(y), _op(op)
\n {}
\n ~Request()
\n {}
\npublic:
\n int _x;
\n int _y;
\n char _op; \/\/ '+' '-' '*' '\/' '%'
\n};<\/p>\nclass Response
\n{
\npublic:
\n std::string Serialize() \/\/ "code_ result_"
\n {<\/p>\nstd::string s;
\n s = std::to_string(_code);
\n s += SPACE;
\n s += std::to_string(_result);<\/p>\nreturn s;
\n }
\n bool Deserialized(const std::string& s)
\n {
\n std::size_t pos = s.find(SPACE);
\n if (pos == std::string::npos)
\n return false;
\n _code = atoi(s.substr(0, pos).c_str());
\n _result = atoi(s.substr(pos + SPACE_LEN).c_str());
\n return true;
\n }
\npublic:
\n Response()
\n {}
\n Response(int result, int code)
\n : _result(result), _code(code)
\n {}
\n ~Response()
\n {}
\npublic:
\n int _result; \/\/ \u8ba1\u7b97\u7ed3\u679c
\n int _code; \/\/ \u8ba1\u7b97\u7ed3\u679c\u7684\u72b6\u6001\u7801
\n};<\/p>\nmain.cc<\/h5>\n
#include "TcpServer.hpp"
\n#include <memory><\/p>\nstatic Response calculator(const Request &req)
\n{
\n Response resp(0, 0);
\n switch (req.op_)
\n {
\n case '+':
\n resp.result_ = req.x_ + req.y_;
\n break;
\n case '-':
\n resp.result_ = req.x_ – req.y_;
\n break;
\n case '*':
\n resp.result_ = req.x_ * req.y_;
\n break;
\n case '\/':
\n if (0 == req.y_)
\n resp.code_ = 1;
\n else
\n resp.result_ = req.x_ \/ req.y_;
\n break;
\n case '%':
\n if (0 == req.y_)
\n resp.code_ = 2;
\n else
\n resp.result_ = req.x_ % req.y_;
\n break;
\n default:
\n resp.code_ = 3;
\n break;
\n }
\n return resp;
\n}<\/p>\nvoid NetCal(Connection *conn, std::string &request)
\n{
\n logMessage(DEBUG, "NetCal been called, get request: %s", request.c_str());
\n Request req; \/\/ 1. \u53cd\u5e8f\u5217\u5316，1 + 1 2 + 3
\n if(!req.Deserialized(request))
\n return;<\/p>\nResponse resp = calculator(req); \/\/ 2. \u4e1a\u52a1\u5904\u7406<\/p>\n
std::string sendstr = resp.Serialize(); \/\/ 3. \u5e8f\u5217\u5316,\u6784\u5efa\u5e94\u7b54
\n sendstr = Encode(sendstr);<\/p>\nconn->_outbuffer += sendstr; \/\/ 4. \u4ea4\u7ed9\u670d\u52a1\u5668conn<\/p>\n
\/\/ 5. \u60f3\u529e\u6cd5，\u8ba9\u5e95\u5c42\u7684TcpServer\u5f00\u59cb\u53d1\u9001 -> \u9700\u8981\u6709\u5b8c\u6574\u7684\u53d1\u9001\u903b\u8f91
\n \/\/ \u89e6\u53d1\u53d1\u9001\u7684\u52a8\u4f5c，\u4e00\u65e6\u5f00\u542fEPOLLOUT，epoll\u4f1a\u81ea\u52a8\u7acb\u9a6c\u89e6\u53d1\u4e00\u6b21\u53d1\u9001\u4e8b\u4ef6\u5c31\u7eea，\u5982\u679c\u540e\u7eed\u4fdd\u6301\u53d1\u9001\u7684\u5f00\u542f，epoll\u4f1a\u4e00\u76f4\u53d1\u9001
\n conn->_tsvr->EnableReadWrite(conn, true, true); \/\/ \u5199\u5b8cEnableReadWrite\u624d\u53d1\u73b0\u56de\u6307\u6307\u9488\u7684\u4f5c\u7528
\n}<\/p>\nint main()
\n{
\n std::unique_ptr<TcpServer> svr(new TcpServer());
\n svr->Dispather(NetCal);<\/p>\nreturn 0;
\n}<\/p>\nSender\u51fd\u6570：<\/p>\n
void Sender(Connection *conn)
\n {
\n while(true)
\n {
\n ssize_t n = send(conn->_sock, conn->_outbuffer.c_str(), conn->_outbuffer.size(), 0);
\n if(n > 0) \/\/ \u53d1\u9001\u6210\u529f -> \u79fb\u9664
\n {
\n conn->_outbuffer.erase(0, n);
\n if(conn->_outbuffer.empty()) \/\/ \u53d1\u5b8c\u4e86 -> break
\n break;
\n }
\n else
\n {
\n if(errno == EAGAIN || errno == EWOULDBLOCK) \/\/ \u7f13\u51b2\u533a\u6ee1\u4e86 -> break\u4e0b\u6b21\u518d\u53d1
\n break;
\n else if(errno == EINTR) \/\/ \u53d1\u9001\u88ab\u4e2d\u65ad -> \u91cd\u65b0\u53d1\u9001
\n continue;
\n else \/\/ \u771f\u6b63\u8bfb\u53d6\u5931\u8d25 -> \u4ea4\u7ed9\u5f02\u5e38\u56de\u8c03
\n {
\n logMessage(ERROR, "send error, %d : %s", errno, strerror(errno));
\n conn->_except_cb(conn);
\n break;
\n }
\n }
\n }
\n \/\/ \u4e0d\u786e\u5b9a\u6709\u6ca1\u6709\u53d1\u5b8c，\u4f46\u662f\u53ef\u4ee5\u4fdd\u8bc1，\u5982\u679c\u6ca1\u6709\u51fa\u9519，\u4e00\u5b9a\u662f\u8981\u4e48\u53d1\u5b8c，\u8981\u4e48\u53d1\u9001\u6761\u4ef6\u4e0d\u6ee1\u8db3，\u4e0b\u6b21\u518d\u53d1
\n if(conn->_outbuffer.empty())
\n EnableReadWrite(conn, true, false);
\n else
\n EnableReadWrite(conn, true, true);
\n }
\n void EnableReadWrite(Connection *conn, bool readable, bool writeable) \/\/ \u63a7\u5236\u8bfb\u5199\u5f00\u5173
\n {
\n uint32_t events = ((readable ? EPOLLIN : 0) | (writeable ? EPOLLOUT : 0));
\n bool res = _poll.CtrlEpoll(conn->_sock, events);
\n assert(res);
\n }<\/p>\nEpoll.hpp<\/h5>\n
\u52a0\u4e86\u6253\u5f00\u548c\u5220\u9664\u5c31\u5b8c\u6574\u4e86：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141009-69889941928e3.png\")
<\/p>\n#pragma once<\/p>\n
#include <iostream>
\n#include <sys\/epoll.h><\/p>\nclass Epoll
\n{
\n const static int gnum = 128;
\n const static int gtimeout = 5000;
\npublic:
\n Epoll(int timeout = gtimeout)
\n : _timeout(timeout)
\n {}
\n void CreateEpoll()
\n {
\n _epfd = epoll_create(gnum);
\n if (_epfd < 0)
\n exit(5);
\n }
\n bool DelFromEpoll(int sock) \/\/ \u79fb\u9664sock\u7684\u6240\u6709\u4e8b\u4ef6
\n {
\n int n = epoll_ctl(_epfd, EPOLL_CTL_DEL, sock, nullptr);
\n return n == 0;
\n }
\n bool CtrlEpoll(int sock, uint32_t events) \/\/ \u6253\u5f00sock\u7684\u4e8b\u4ef6
\n {
\n events |= EPOLLET;
\n struct epoll_event ev;
\n ev.events = events;
\n ev.data.fd = sock;
\n int n = epoll_ctl(_epfd, EPOLL_CTL_MOD, sock, &ev);
\n return n == 0;
\n }
\n bool AddSockToEpoll(int sock, uint32_t events)
\n { \/\/ \u6dfb\u52a0sock\u5230epoll\u4e2d(\u4efb\u52a1\u901a\u77e5)->\u8981\u77e5\u9053sock\u548c\u4e8b\u4ef6(\u4efb\u4f55\u591a\u8def\u8f6c\u63a5\u7684\u670d\u52a1\u5668，\u4e00\u822c\u53ea\u4f1a\u6253\u5f00\u8bfb\u53d6\u4e8b\u4ef6，\u5199\u5165\u4e8b\u4ef6\u6309\u9700\u6253\u5f00)
\n struct epoll_event ev;
\n ev.events = events;
\n ev.data.fd = sock;
\n int n = epoll_ctl(_epfd, EPOLL_CTL_ADD, sock, &ev);
\n return n == 0;
\n }
\n int WaitEpoll(struct epoll_event revs[], int num)
\n {
\n return epoll_wait(_epfd, revs, num, _timeout);
\n }
\n ~Epoll()
\n {}<\/p>\nprivate:
\n int _epfd;
\n int _timeout;
\n};<\/p>\nExcepter\u51fd\u6570：<\/p>\n
void Excepter(Connection *conn)
\n {
\n if(!IsConnectionExists(conn->_sock)) \/\/ _sock\u4e0d\u5b58\u5728\u5c31\u8fd4\u56de
\n return;
\n bool res = _poll.DelFromEpoll(conn->_sock); \/\/ 1. \u4eceepoll\u4e2d\u79fb\u9664
\n assert(res);<\/p>\n_connections.erase(conn->_sock); \/\/ 2. \u4eceunorder_map\u4e2d\u79fb\u9664<\/p>\n
close(conn->_sock); \/\/ 3. \u5173\u95edsock<\/p>\n
delete conn; \/\/ 4. \u91ca\u653e conn;
\n logMessage(DEBUG, "Excepter \u56de\u6536\u5b8c\u6bd5\u6240\u6709\u7684\u5f02\u5e38\u60c5\u51b5");
\n }<\/p>\n\u7f16\u8bd1\u8fd0\u884c：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141009-69889941e6d93.png\")
<\/p>\n\u6b64\u65f6\u4ee3\u7801\u5c31\u7ed3\u675f\u4e86，\u53ef\u4ee5\u81ea\u5df1\u62d3\u5c55\u4e00\u4e0b\u3002\u4e0b\u9762\u653e\u4e00\u4e0b\u5b8c\u6574\u7684TcpServer.hpp：<\/p>\n
TcpServer.hpp<\/h5>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <functional>
\n#include <string>
\n#include <cassert>
\n#include <unordered_map>
\n#include <vector>
\n#include "Sock.hpp"
\n#include "Log.hpp"
\n#include "Epoll.hpp"
\n#include "Protocol.hpp"<\/p>\nclass TcpServer;
\nclass Connection;<\/p>\nusing func_t = std::function<void(Connection *)>;
\nusing callback_t = std::function<void (Connection*, std::string &request)>; \/\/ \u4e0a\u5c42\u4e1a\u52a1\u5904\u7406\u7684\u65b9\u6cd5<\/p>\n\/\/ \u4e3a\u4e86\u80fd\u591f\u6b63\u5e38\u5de5\u4f5c，\u5e38\u89c4\u7684sock\u5fc5\u987b\u8981\u6709\u72ec\u7acb\u7684\u63a5\u6536\u7f13\u51b2\u533a\u548c\u53d1\u9001\u7f13\u51b2\u533a(\u5199\u5165)
\nclass Connection \/\/ \u4e00\u4e2a\u94fe\u63a5\u7c7b
\n{
\npublic:
\n Connection(int sock = -1)
\n : _sock(sock), _tsvr(nullptr)
\n {
\n }
\n void SetCallBack(func_t recv_cb, func_t send_cb, func_t except_cb)
\n { \/\/ \u8bbe\u7f6e\u4e09\u4e2a\u56de\u8c03\u65b9\u6cd5
\n _recv_cb = recv_cb;
\n _send_cb = send_cb;
\n _except_cb = except_cb;
\n }
\n ~Connection()
\n {
\n }<\/p>\npublic:
\n int _sock; \/\/ \u8d1f\u8d23\u8fdb\u884cIO\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n func_t _recv_cb; \/\/ \u4e09\u4e2a\u56de\u8c03\u65b9\u6cd5，\u662f\u5bf9_sock\u8fdb\u884c\u7279\u5b9a\u8bfb\u5199\u7684\u5bf9\u5e94\u65b9\u6cd5
\n func_t _send_cb;
\n func_t _except_cb;<\/p>\nstd::string _inbuffer; \/\/ \u63a5\u6536\u7f13\u51b2\u533a&&\u53d1\u9001\u7f13\u51b2\u533a
\n std::string _outbuffer; \/\/ \u8fd9\u4e24string\u6682\u65f6\u6ca1\u6709\u529e\u6cd5\u5904\u7406\u4e8c\u8fdb\u5236\u6d41，\u6587\u672c\u662f\u53ef\u4ee5\u7684<\/p>\nTcpServer *_tsvr; \/\/ \u8bbe\u7f6e\u5bf9TcpServer\u7684\u56de\u6307\u6307\u9488，\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u5fc3\u662f\u6309\u9700\u6253\u5f00
\n};<\/p>\nclass TcpServer
\n{
\n const static int gport = 8080;
\n const static int gnum = 128;<\/p>\npublic:
\n TcpServer(int port = gport)
\n : _port(port), _revs_num(gnum)
\n {
\n \/\/ 1. \u521b\u5efalistensock
\n _listensock = Sock::Socket();
\n Sock::Bind(_listensock, _port);
\n Sock::Listen(_listensock);<\/p>\n\/\/ 2. \u521b\u5efa\u591a\u8def\u8f6c\u63a5\u5bf9\u8c61
\n _poll.CreateEpoll();<\/p>\n\/\/ 3. \u6dfb\u52a0listensock\u5230\u670d\u52a1\u5668\u4e2d -> \u4e09\u6b65(\u7c7b\u7684\u6784\u9020\u51fd\u6570\u4e5f\u80fd\u8c03\u7528\u7c7b\u7684\u6210\u5458\u65b9\u6cd5，\u8d70\u5230\u51fd\u6570\u4f53\u4e2d\u5bf9\u8c61\u5df2\u7ecf\u5b58\u5728\u4e86)
\n \/\/ \u540e\u4e09\u4e2a\u53c2\u6570\u662f\u51fd\u6570\u5bf9\u8c61，\u8981bind\u7ed1\u5b9a\u8fd4\u56de\u4e00\u4e2a\u51fd\u6570\u5bf9\u8c61->\u7c7b\u5185\u51fd\u6570\u6709this\u6307\u9488，_1\u662f\u9884\u7559\u7684\u53c2\u6570
\n AddConnection(_listensock, std::bind(&TcpServer::Accepter, this, std::placeholders::_1), nullptr, nullptr);<\/p>\n\/\/ 4. \u6784\u5efa\u4e00\u4e2a\u83b7\u53d6\u5c31\u7eea\u4e8b\u4ef6\u7684\u7f13\u51b2\u533a
\n _revs = new struct epoll_event[_revs_num];
\n }
\n void AddConnection(int sock, func_t recv_cb, func_t send_cb, func_t except_cb) \/\/ \u628a\u4efb\u610fsock\u8fdb\u884c\u6dfb\u52a0\u5230TcpServer
\n {
\n Sock::SetNonBlock(sock); \/\/ ET\u6a21\u5f0f\u8981\u628asock\u8bbe\u7f6e\u6210\u975e\u963b\u585e -> \u5728Sock.hpp\u4e2d\u5199\u6210\u51fd\u6570<\/p>\n\/\/ \u9664\u4e86_listensock，\u540e\u9762\u8fd8\u4f1a\u5b58\u5728\u5927\u91cf\u7684socket，\u6bcf\u4e00\u4e2asock\u90fd\u5fc5\u987b\u88ab\u5c01\u88c5\u6210\u4e3a\u4e00\u4e2aConnection
\n \/\/ \u5f53\u670d\u52a1\u5668\u4e2d\u5b58\u5728\u5927\u91cf\u7684Connection\u65f6，TcpServer\u9700\u8981\u5c06\u6240\u6709Connection\u8fdb\u884c\u7ba1\u7406：\u4e0a\u9762\u63cf\u8ff0\u4e86，\u7ec4\u7ec7 -> unordered_map
\n \/\/ 3.1 \u6784\u5efaconn\u5bf9\u8c61，\u5c01\u88c5sock
\n Connection *conn = new Connection(sock);
\n conn->SetCallBack(recv_cb, send_cb, except_cb);
\n conn->_tsvr = this;<\/p>\n\/\/ 3.2 \u6dfb\u52a0sock\u5230epoll\u4e2d(\u4efb\u52a1\u901a\u77e5)->\u8981\u77e5\u9053sock\u548c\u4e8b\u4ef6(\u4efb\u4f55\u591a\u8def\u8f6c\u63a5\u7684\u670d\u52a1\u5668，\u4e00\u822c\u53ea\u4f1a\u6253\u5f00\u8bfb\u53d6\u4e8b\u4ef6，\u5199\u5165\u4e8b\u4ef6\u6309\u9700\u6253\u5f00)
\n _poll.AddSockToEpoll(sock, EPOLLIN | EPOLLET);<\/p>\n\/\/ 3.3 \u5c06\u5bf9\u5e94\u7684Connection*\u5bf9\u8c61\u6307\u9488\u6dfb\u52a0\u5230Connections\u6620\u5c04\u8868\u4e2d(\u4e1a\u52a1\u5904\u7406)
\n _connections.insert(std::make_pair(sock, conn));
\n }<\/p>\nvoid Accepter(Connection *conn)
\n {
\n \/\/ logMessage(DEBUG, "Accepter been called");
\n \/\/ \u4e00\u5b9a\u662flistensock\u5df2\u7ecf\u5c31\u7eea\u4e86，\u6b64\u6b21\u8bfb\u53d6\u4e0d\u4f1a\u963b\u585e，
\n \/\/ \u600e\u4e48\u4fdd\u8bc1，\u5e95\u5c42\u53ea\u6709\u4e00\u4e2a\u8fde\u63a5\u5c31\u7eea\u5462 -> \u5faa\u73af，\u76f4\u5230\u83b7\u53d6\u5931\u8d25
\n while (true)
\n {
\n std::string clientip;
\n uint16_t clientport;
\n int accept_errno = 0;
\n \/\/ sock\u4e00\u5b9a\u662f\u5e38\u89c4\u7684IO sock
\n int sock = Sock::Accept(conn->_sock, &clientip, &clientport, &accept_errno);
\n if (sock < 0) \/\/ \u83b7\u53d6\u5931\u8d25
\n {
\n if (accept_errno == EAGAIN || accept_errno == EWOULDBLOCK)
\n break;
\n else if (accept_errno == EINTR) \/\/ \u6982\u7387\u975e\u5e38\u4f4e
\n continue;
\n else \/\/ accept\u5931\u8d25
\n {
\n logMessage(WARNING, "accept error, %d : %s", accept_errno, strerror(accept_errno));
\n break;
\n }
\n }
\n else \/\/ (sock>=0)\u83b7\u53d6\u94fe\u63a5\u6210\u529f->\u5c06sock\u6258\u7ba1\u7ed9TcpServer
\n {
\n AddConnection(sock, std::bind(&TcpServer::Recver, this, std::placeholders::_1),
\n std::bind(&TcpServer::Sender, this, std::placeholders::_1),
\n std::bind(&TcpServer::Excepter, this, std::placeholders::_1));
\n logMessage(DEBUG, "accept client %s:%d success, add to epoll&&TcpServer success, sock: %d",
\n clientip.c_str(), clientport, sock);
\n }
\n }
\n }<\/p>\nvoid Recver(Connection *conn) \/\/ \u8bfb\u53d6\u4e00\u4e2a\u6b63\u5e38\u7684sock
\n {
\n const int num = 1024;
\n bool err = false;
\n \/\/ logMessage(DEBUG, "Recver event exists, Recver() been called");
\n while (true)
\n {
\n char buffer[num];
\n ssize_t n = recv(conn->_sock, buffer, sizeof(buffer) – 1, 0);
\n if (n < 0)
\n {
\n if (errno == EAGAIN || errno == EWOULDBLOCK) \/\/ \u8bfb\u53d6\u5b8c\u6bd5\u4e86，\u6b63\u5e38\u7684
\n break;
\n else if (errno == EINTR) \/\/ \u8bfb\u53d6\u88ab\u4e2d\u65ad\u4e86，\u91cd\u65b0\u5f00\u59cb\u8bfb
\n continue;
\n else \/\/ \u771f\u6b63\u8bfb\u53d6\u5931\u8d25 -> \u4ea4\u7ed9\u5f02\u5e38\u56de\u8c03
\n {
\n logMessage(ERROR, "recv error, %d : %s", errno, strerror(errno));
\n conn->_except_cb(conn);
\n err = true;
\n break;
\n }
\n }
\n else if (n == 0)
\n {
\n logMessage(DEBUG, "client[%d] quit, server close [%d]", conn->_sock, conn->_sock);
\n conn->_except_cb(conn);
\n err = true;
\n break;
\n }
\n else \/\/ \u8bfb\u53d6\u6210\u529f
\n {
\n buffer[n] = 0;
\n conn->_inbuffer += buffer; \/\/ \u8bfb\u53d6\u5230\u7684\u6570\u636e\u5168\u90e8\u62fc\u63a5\u5230\u63a5\u6536\u7f13\u51b2\u533a
\n }
\n }
\n logMessage(DEBUG, "conn->_inbuffer[sock: %d]: %s", conn->_sock, conn->_inbuffer.c_str());
\n if (!err) \/\/ \u5982\u679c\u9519\u8bef\u7801\u8fd8\u662ffalse\u5c31\u662f\u6b63\u5e38break\u7684
\n {
\n std::vector<std::string> messages;
\n SpliteMessage(conn->_inbuffer, &messages);
\n \/\/ \u4fdd\u8bc1\u8d70\u5230\u8fd9\u91cc，\u5c31\u662f\u4e00\u4e2a\u5b8c\u6574\u62a5\u6587
\n for (auto &msg : messages)
\n { \/\/ \u53ef\u4ee5\u5728\u8fd9\u91cc\u5c06message\u5c01\u88c5\u6210\u4e3atask,\u7136\u540epush\u5230\u4efb\u52a1\u961f\u5217,\u4efb\u52a1\u5904\u7406\u4ea4\u7ed9\u540e\u7aef\u7ebf\u7a0b\u6c60,\u8fd9\u91cc\u4e0d\u5904\u7406
\n _cb(conn, msg);
\n }
\n }
\n }<\/p>\nvoid Sender(Connection *conn)
\n {
\n while(true)
\n {
\n ssize_t n = send(conn->_sock, conn->_outbuffer.c_str(), conn->_outbuffer.size(), 0);
\n if(n > 0) \/\/ \u53d1\u9001\u6210\u529f -> \u79fb\u9664
\n {
\n conn->_outbuffer.erase(0, n);
\n if(conn->_outbuffer.empty()) \/\/ \u53d1\u5b8c\u4e86 -> break
\n break;
\n }
\n else
\n {
\n if(errno == EAGAIN || errno == EWOULDBLOCK) \/\/ \u7f13\u51b2\u533a\u6ee1\u4e86 -> break\u4e0b\u6b21\u518d\u53d1
\n break;
\n else if(errno == EINTR) \/\/ \u53d1\u9001\u88ab\u4e2d\u65ad -> \u91cd\u65b0\u53d1\u9001
\n continue;
\n else \/\/ \u771f\u6b63\u8bfb\u53d6\u5931\u8d25 -> \u4ea4\u7ed9\u5f02\u5e38\u56de\u8c03
\n {
\n logMessage(ERROR, "send error, %d : %s", errno, strerror(errno));
\n conn->_except_cb(conn);
\n break;
\n }
\n }
\n }
\n \/\/ \u4e0d\u786e\u5b9a\u6709\u6ca1\u6709\u53d1\u5b8c，\u4f46\u662f\u53ef\u4ee5\u4fdd\u8bc1，\u5982\u679c\u6ca1\u6709\u51fa\u9519，\u4e00\u5b9a\u662f\u53d1\u5b8c\u4e86，\u6216\u8005\u53d1\u9001\u6761\u4ef6\u4e0d\u6ee1\u8db3，\u4e0b\u6b21\u518d\u53d1
\n if(conn->_outbuffer.empty()) \/\/ \u53d1\u5b8c\u4e86->\u4e0d\u7528\u5173\u5fc3\u5199
\n EnableReadWrite(conn, true, false);
\n else \/\/ \u53d1\u9001\u6761\u4ef6\u4e0d\u6ee1\u8db3，\u4e0b\u6b21\u518d\u53d1
\n EnableReadWrite(conn, true, true);
\n }
\n void EnableReadWrite(Connection *conn, bool readable, bool writeable) \/\/ \u63a7\u5236\u8bfb\u5199\u5f00\u5173
\n { \/\/ \u4e0b\u9762\u7684\u4e09\u76ee：\u5982readable\u4e3a\u771f\u5c31\u5173\u5fc3\u8bfb\u4e8b\u4ef6,\u5426\u5219\u4e3a0,writeable\u5c31\u5173\u5fc3\u5199\u4e8b\u4ef6
\n uint32_t events = ((readable ? EPOLLIN : 0) | (writeable ? EPOLLOUT : 0));
\n bool res = _poll.CtrlEpoll(conn->_sock, events);
\n assert(res);
\n }<\/p>\nvoid Excepter(Connection *conn)
\n {
\n if(!IsConnectionExists(conn->_sock)) \/\/ _sock\u4e0d\u5b58\u5728\u5c31\u8fd4\u56de
\n return;
\n bool res = _poll.DelFromEpoll(conn->_sock); \/\/ 1. \u4eceepoll\u4e2d\u79fb\u9664
\n assert(res);<\/p>\n_connections.erase(conn->_sock); \/\/ 2. \u4eceunorder_map\u4e2d\u79fb\u9664<\/p>\n
close(conn->_sock); \/\/ 3. \u5173\u95edsock<\/p>\n
delete conn; \/\/ 4. \u91ca\u653e conn;
\n logMessage(DEBUG, "Excepter \u56de\u6536\u5b8c\u6bd5\u6240\u6709\u7684\u5f02\u5e38\u60c5\u51b5");
\n }<\/p>\nvoid Dispather(callback_t cb) \/\/ \u6839\u636e\u5c31\u7eea\u7684\u4e8b\u4ef6，\u8fdb\u884c\u7279\u5b9a\u4e8b\u4ef6\u7684\u6d3e\u53d1
\n {
\n _cb = cb;
\n while (true)
\n {
\n LoopOnce();
\n }
\n }
\n void LoopOnce()
\n {
\n int n = _poll.WaitEpoll(_revs, _revs_num);
\n for (int i = 0; i < n; i++) \/\/ \u83b7\u53d6\u4e8b\u4ef6
\n {
\n int sock = _revs[i].data.fd;
\n uint32_t revents = _revs[i].events;
\n if (revents & EPOLLIN) \/\/ \u8bfb\u5c31\u7eea
\n {
\n \/\/ if(Connection\u662f\u5b58\u5728\u5e76\u4e14_connections[sock]->_recv_cb\u88ab\u8bbe\u7f6e\u8fc7)
\n if (IsConnectionExists(sock) && _connections[sock]->_recv_cb != nullptr)
\n _connections[sock]->_recv_cb(_connections[sock]); \/\/ \u8c03\u7528\u8bfb\u4e8b\u4ef6\u7684\u56de\u8c03
\n }
\n if (revents & EPOLLOUT) \/\/ \u5199\u5c31\u7eea
\n {
\n \/\/ if(Connection\u662f\u5b58\u5728\u5e76\u4e14_connections[sock]->_send_cb\u88ab\u8bbe\u7f6e\u8fc7)
\n if (IsConnectionExists(sock) && _connections[sock]->_send_cb != nullptr)
\n _connections[sock]->_send_cb(_connections[sock]); \/\/ \u8c03\u7528\u5199\u4e8b\u4ef6\u7684\u56de\u8c03
\n }
\n }
\n }
\n bool IsConnectionExists(int sock) \/\/ \u5224\u5b9aConnection\u662f\u5426\u5b58\u5728
\n {
\n auto iter = _connections.find(sock);
\n if (iter == _connections.end())
\n return false;
\n else
\n return true;
\n }
\n ~TcpServer()
\n {
\n if (_listensock >= 0)
\n close(_listensock);
\n if (_revs)
\n delete[] _revs;
\n }<\/p>\nprivate:
\n int _listensock;
\n int _port;
\n Epoll _poll;
\n std::unordered_map<int, Connection *> _connections; \/\/ \u7ba1\u7406：sock\u6620\u5c04\u5230Connection
\n struct epoll_event *_revs; \/\/ \u5c31\u7eea\u4e8b\u4ef6\u7f13\u51b2\u533a,\u5c31\u7eea\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u6295\u9012\u5230\u8fd9\u91cc
\n int _revs_num; \/\/ \u5c31\u7eea\u4e8b\u4ef6\u7f13\u51b2\u533a\u5927\u5c0f<\/p>\ncallback_t _cb; \/\/ \u5904\u7406\u4e0a\u5c42\u7684\u4e1a\u52a1\u7684\u56de\u8c03\u51fd\u6570
\n};<\/p>\n
\n\u672c\u7bc7\u5b8c\u3002<\/h3>\n","protected":false},"excerpt":{"rendered":"
1. reactor\u7684\u670d\u52a1\u56681.0\u00a0reactor\u670d\u52a1\u5668\u4ecb\u7ecdReactor\u662f\u4e00\u79cd\u4e8b\u4ef6\u9a71\u52a8\u7684\u9ad8\u6027\u80fd\u7f51\u7edc\u6a21\u578b，\u6838\u5fc3\u662f\u901a\u8fc7\u5355\u7ebf\u7a0b\/\u5c11\u91cf\u7ebf\u7a0b\u7ba1\u7406\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u3002\u5176\u6838\u5fc3\u7ec4\u4ef6\u5305\u62ec：I\/O\u591a\u8def\u590d\u7528\u5668（\u5982epoll）：\u76d1\u542c\u591a\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26（fd）\u7684\u4e8b\u4ef6（\u8bfb\u3001\u5199\u3001\u5f02\u5e38）\u3002\u4e8b\u4ef6\u5206\u53d1\u5668：\u5c06\u5c31\u7eea\u4e8b\u4ef6\u5206\u53d1\u7ed9\u5bf9\u5e94\u7684\u5904\u7406\u5668\u3002\u4e8b\u4ef6\u5904\u7406\u5668：\u6267\u884c\u5177\u4f53\u7684I\/O\u64cd\u4f5c\u548c<\/p>\n","protected":false},"author":2,"featured_media":73995,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,58,43,44],"topic":[],"class_list":["post-74003","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-c","tag-linux","tag-43","tag-44"],"yoast_head":"\n
\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/74003.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"1. reactor\u7684\u670d\u52a1\u56681.0\u00a0reactor\u670d\u52a1\u5668\u4ecb\u7ecdReactor\u662f\u4e00\u79cd\u4e8b\u4ef6\u9a71\u52a8\u7684\u9ad8\u6027\u80fd\u7f51\u7edc\u6a21\u578b，\u6838\u5fc3\u662f\u901a\u8fc7\u5355\u7ebf\u7a0b\/\u5c11\u91cf\u7ebf\u7a0b\u7ba1\u7406\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u3002\u5176\u6838\u5fc3\u7ec4\u4ef6\u5305\u62ec：I\/O\u591a\u8def\u590d\u7528\u5668（\u5982epoll）：\u76d1\u542c\u591a\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26（fd）\u7684\u4e8b\u4ef6（\u8bfb\u3001\u5199\u3001\u5f02\u5e38）\u3002\u4e8b\u4ef6\u5206\u53d1\u5668：\u5c06\u5c31\u7eea\u4e8b\u4ef6\u5206\u53d1\u7ed9\u5bf9\u5e94\u7684\u5904\u7406\u5668\u3002\u4e8b\u4ef6\u5904\u7406\u5668：\u6267\u884c\u5177\u4f53\u7684I\/O\u64cd\u4f5c\u548c\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/74003.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-02-08T14:10:11+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141007-6988993f6b1a6.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"17 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/74003.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/74003.html\",\"name\":\"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-02-08T14:10:11+00:00\",\"dateModified\":\"2026-02-08T14:10:11+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/74003.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/74003.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/74003.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/74003.html","og_locale":"zh_CN","og_type":"article","og_title":"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"1. reactor\u7684\u670d\u52a1\u56681.0\u00a0reactor\u670d\u52a1\u5668\u4ecb\u7ecdReactor\u662f\u4e00\u79cd\u4e8b\u4ef6\u9a71\u52a8\u7684\u9ad8\u6027\u80fd\u7f51\u7edc\u6a21\u578b，\u6838\u5fc3\u662f\u901a\u8fc7\u5355\u7ebf\u7a0b\/\u5c11\u91cf\u7ebf\u7a0b\u7ba1\u7406\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u3002\u5176\u6838\u5fc3\u7ec4\u4ef6\u5305\u62ec：I\/O\u591a\u8def\u590d\u7528\u5668（\u5982epoll）：\u76d1\u542c\u591a\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26（fd）\u7684\u4e8b\u4ef6（\u8bfb\u3001\u5199\u3001\u5f02\u5e38）\u3002\u4e8b\u4ef6\u5206\u53d1\u5668：\u5c06\u5c31\u7eea\u4e8b\u4ef6\u5206\u53d1\u7ed9\u5bf9\u5e94\u7684\u5904\u7406\u5668\u3002\u4e8b\u4ef6\u5904\u7406\u5668：\u6267\u884c\u5177\u4f53\u7684I\/O\u64cd\u4f5c\u548c","og_url":"https:\/\/www.wsisp.com\/helps\/74003.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-02-08T14:10:11+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208141007-6988993f6b1a6.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"17 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/74003.html","url":"https:\/\/www.wsisp.com\/helps\/74003.html","name":"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-02-08T14:10:11+00:00","dateModified":"2026-02-08T14:10:11+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/74003.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/74003.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/74003.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u7f51\u7edc\u548cLinux\u7f51\u7edc-15(IO\u591a\u8def\u8f6c\u63a5)reactor\u7f16\u7a0b-\u670d\u52a1\u5668"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/74003","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=74003"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/74003\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/73995"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=74003"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=74003"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=74003"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=74003"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
- \n
- \n
- \n
- \n
- \n
- \n
- \n
- \n
- \n
- \n
- \n