![\"@bit::Shadow](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261102234126-6ae91fa6232c8.png\")
<\/p>\n<\/p>\n<\/p>\n<\/p>\n
\u8fd9\u4efd\u4ee3\u7801\u662f\u4e00\u4e2a\u58f0\u660e\u4e0e\u5b9e\u73b0\u540c\u5904 .hpp \u7684 header-only Reactor \u670d\u52a1\u7aef\u9aa8\u67b6：\u4ece Buffer（\u53cc\u4e0b\u6807\u7f13\u51b2\u533a）\u8d77\u6b65，\u7ecf Socket（fd \u7684 RAII \u5305\u88c5）\u3001Channel（\u4e8b\u4ef6\u4e0e\u4e94\u7c7b\u56de\u8c03）\u3001Poller（epoll \u5c01\u88c5）\u3001TimerTask\/TimeWheel（timerfd \u9a71\u52a8\u7684\u79d2\u7ea7\u65f6\u95f4\u8f6e）\u3001EventLoop（Poller + \u4efb\u52a1\u961f\u5217 + eventfd \u5524\u9192）\u3001LoopThread\/LoopThreadPool（\u591a\u7ebf\u7a0b\u4ece\u5c5e loop）\u3001Any（\u8fde\u63a5\u4e0a\u4e0b\u6587）\u3001Connection（\u8fde\u63a5\u72b6\u6001\u673a\u4e0e\u6536\u53d1\u7f13\u51b2）\u3001Acceptor\/TcpServer（\u76d1\u542c\u4e0e\u8fde\u63a5\u7ba1\u7406）\u9010\u5c42\u96c6\u6210\u3002EchoServer \u53ea\u662f\u6700\u8584\u7684\u4e00\u5c42\u88c5\u914d：\u4e09\u4e2a std::bind \u6302\u4e0a\u8fde\u63a5\u3001\u6d88\u606f\u3001\u65ad\u5f00\u56de\u8c03；main \u4ec5 make_unique<EchoServer>(8080) \u52a0 Start()\u3002\u5b83\u7684\u4ef7\u503c\u5728\u4e8e\u628a"\u4e8b\u4ef6\u5c42\u2014\u8c03\u5ea6\u5c42\u2014\u8fde\u63a5\u5c42"\u7684\u8fb9\u754c\u5207\u5f97\u8db3\u591f\u5e72\u51c0，\u4e1a\u52a1\u4fa7\u53ea\u9700\u7406\u89e3 MessageCallBack(const PtrConnection&, Buffer*) \u7684\u8bed\u4e49\u5373\u53ef\u66ff\u6362\u534f\u8bae\u3002<\/p>\n
\u4ee3\u7801\u4ed3\u5e93：https:\/\/gitee.com\/btshadow\/moduo_project\/tree\/master\/key_nodes\/EchoServer<\/p>\n
\u6309\u672c\u6587\u7684\u5199\u4f5c\u7ea6\u5b9a，\u672c\u6587\u4ef6\u5185\u4ee5 \/* *\/ \u5305\u88f9\u7684\u5b57\u6bb5\u6ce8\u91ca\u6bb5（\u56de\u987e\u3001\u65b0\u77e5\u8bc6\u3001\u6ce8\u610f\u3001\u53cd\u601d\u7b49）\u4e0d\u5728\u6b64\u8282\u5c55\u5f00，\u672c\u6587\u5168\u90e8\u5185\u5bb9\u53ea\u4f9d\u636e\u4ee3\u7801\u672c\u4f53\u4e0e \/\/ \u884c\u5185\u6ce8\u91ca\u6210\u6587；\u4ee3\u7801\u91cc\u4ec5\u6709\u7f16\u53f7\u6807\u8bb0\u3001\u5b57\u6bb5\u6ce8\u91ca\u6bb5\u53c8\u672a\u7ed9\u51fa\u89e3\u91ca\u7684 bugN，\u540c\u6837\u4e0d\u4f5c\u53d9\u8ff0\u3002<\/p>\n
\u5355\u6587\u4ef6\u5373\u4f9d\u8d56\u987a\u5e8f：echo.hpp \u5f15\u5165 server.hpp，\u5176\u540e\u4f9d\u6b21\u662f Buffer\u3001Socket\u3001Channel\u3001Poller\u3001TimerTask\/TimeWheel\u3001EventLoop\u3001LoopThread(Pool)\u3001Any\u3001Connection\u3001Acceptor\u3001TcpServer\u3002\u6574\u4efd\u5934\u6587\u4ef6\u6ca1\u6709\u4e00\u4e2a .cpp，\u56e0\u6b64\u6ca1\u6709\u94fe\u63a5\u671f\u7b26\u53f7\u53ef\u4f9b\u4f9d\u8d56\u3002<\/p>\n
\u4e3a\u7834\u5faa\u73af\u5305\u542b，Channel \u53ea\u4fdd\u7559 EventLoop*（Poller* \u6210\u5458\u88ab\u6ce8\u91ca\u6389\u4e86），Update()\/Remove() \u58f0\u660e\u5728\u7c7b\u5185\u3001\u5b9a\u4e49\u843d\u5728 EventLoop \u4e4b\u540e：<\/p>\n
\/\/ EventLoop.hpp（\u6587\u4ef6\u672b\u5c3e）<\/span> TimeWheel::AddTask\/RefreshTask\/CancelTask \u540c\u6837\u5728\u6587\u4ef6\u672b\u5c3e\u5b9a\u4e49，\u56e0\u4e3a\u5b83\u4eec\u7684\u51fd\u6570\u4f53\u8981\u7528 _evtloop->PushTaskqueue\u3002\u7531\u6b64\u4ea7\u751f\u4e00\u6761\u9700\u8981\u8bb0\u4f4f\u7684\u8fb9\u754c：\u8fd9\u4e9b\u7c7b\u5916\u5b9a\u4e49\u90fd\u4e0d\u662f inline，#pragma once \u53ea\u80fd\u963b\u6b62\u540c\u4e00\u7f16\u8bd1\u5355\u5143\u91cd\u590d\u5305\u542b，\u4e0d\u80fd\u963b\u6b62\u591a\u4e2a\u7f16\u8bd1\u5355\u5143\u5404\u4ea7\u751f\u4e00\u4efd\u5b9a\u4e49，\u6240\u4ee5\u8fd9\u4efd\u5934\u6587\u4ef6\u76ee\u524d\u53ea\u5728\u5355\u7f16\u8bd1\u5355\u5143\u63a5\u5165（main.cpp）\u4e0b\u6210\u7acb\u3002<\/p>\n \u4e09\u4e2a\u6210\u5458：std::vector<char> _buf\u3001_redidx\u3001_wrtidx\u3002\u6784\u9020\u65f6 reserve(BUF_CAPACITY=65536) \u540e resize(0)，\u5bb9\u91cf\u4e00\u6b21\u5230\u4f4d\u3001size \u4ea4\u7ed9\u5199\u5165\u6d41\u7a0b\u7ef4\u62a4\u3002<\/p>\n Begin() \u53d6\u9996\u5143\u7d20\u5730\u5740，End() \u662f Begin() + _buf.capacity() \u800c\u975e Begin() + _buf.size()\u3002\u8fd9\u4e00\u70b9\u51b3\u5b9a\u4e86\u6574\u5957\u63a5\u53e3\u7684\u5750\u6807\u7cfb：ReadOffset()\u3001WriteOffset() \u90fd\u7528 Begin() + idx \u8ba1\u7b97，\u8bfb\u5199\u4f4d\u7f6e\u7531\u4e0b\u6807\u72ec\u7acb\u63cf\u8ff0，vector \u7684 size \u53ea\u7528\u6765\u914d\u5408 insert \u4e0e resize\u3002\u884c\u5185\u6ce8\u91ca\u7ed9\u51fa\u7684\u7406\u7531\u5f88\u76f4\u63a5：\u89e3\u51b3 _redidx \u504f\u79fb\u540e size \u96be\u4ee5\u51b3\u5b9a\u7684\u95ee\u9898\u3001\u7f13\u548c capacity \u4e0e size \u7684\u8026\u5408\u3002\u56db\u4e2a\u91cf\u56e0\u6b64\u5404\u53f8\u5176\u804c：ReadableGet()=_wrtidx-_redidx\u3001HeadableGet()=_redidx（\u5185\u542b\u4e0e ReadOffset()-Begin() \u7684\u4e00\u81f4\u6027\u65ad\u8a00）\u3001TailableGet()=capacity-_wrtidx\u3001CapacityGet()=capacity\u3002<\/p>\n ReadLen(len) \u9010\u5b57\u8282\u62fc\u51fa std::string，\u8bfb\u5b8c\u53ea\u63a8\u8fdb _redidx \u800c\u4e0d erase\u2014\u2014\u56e0\u4e3a"\u4e0d\u5b58\u5728\u6d1e"，\u4e0b\u6807\u8db3\u4ee5\u63cf\u8ff0\u8bfb\u53d6\u8fdb\u5ea6，\u642c\u79fb\u6570\u636e\u53cd\u800c\u8981\u989d\u5916\u5904\u7406\u5de6\u4fa7\u7a7a\u4f4d\u3002\u526f\u4f5c\u7528\u662f：\u53ea\u8981\u4e0d\u89e6\u53d1 EnsureEnoughCapacity \u7684\u91cd\u6392，_buf.size() \u5c31\u4e0e _wrtidx \u4fdd\u6301\u540c\u6b65，Write \u91cc _buf.insert(_buf.begin()+_wrtidx, …) \u7684\u63d2\u5165\u70b9\u624d\u59cb\u7ec8\u5408\u6cd5\u3002<\/p>\n Write(data,len) \u7684\u987a\u5e8f\u662f EnsureEnoughCapacity(len) \u2192 insert \u2192 _wrtidx += len \u2192 assert(_wrtidx >= _redidx)\u3002\u5176\u4e2d assert(_buf.capacity() – _wrtidx > len) \u7528\u7684\u662f\u4e25\u683c\u5927\u4e8e，\u800c EnsureEnoughCapacity \u7684\u524d\u7f6e\u5224\u65ad\u662f >=：\u6070\u597d\u5199\u6ee1\u5269\u4f59\u5bb9\u91cf（len == capacity-_wrtidx）\u65f6\u80fd\u8fc7\u524d\u8005\u3001\u8fc7\u4e0d\u4e86\u540e\u8005，\u8fd9\u662f\u672c\u6587\u4ef6\u91cc\u5c11\u6570"\u8fb9\u754c\u6bd4\u8bed\u4e49\u66f4\u4e25"\u7684\u5730\u65b9\u3002<\/p>\n EnsureEnoughCapacity(uint32_t size) \u5206\u4e09\u652f：\u53f3\u4fa7\u591f\u7528\u76f4\u63a5\u8fd4\u56de；\u4e0d\u591f\u5219\u7528 memmove(const_cast<char*>(Begin()), ReadOffset(), ReadableGet()) \u5de6\u79fb\u538b\u5b9e（\u91cd\u53e0\u62f7\u8d1d，\u4e0d\u80fd\u6362 std::copy）；\u4ecd\u4e0d\u591f\u5219 reserve(capacity + size)\u3002\u6ce8\u610f\u6269\u5bb9\u5224\u65ad\u53d1\u751f\u5728 memmove \u4e4b\u540e\u3001_wrtidx \u6298\u7b97\u4e4b\u524d，\u7528\u7684\u662f\u538b\u5b9e\u524d\u7684\u5199\u4f4d\u7f6e，\u5224\u65ad\u504f\u4fdd\u5b88，\u4ee3\u4ef7\u662f\u591a reserve \u4e00\u4efd\u3002\u51fd\u6570\u672b\u5c3e\u7684\u4e09\u6b65\u5fc5\u987b\u4fdd\u6301\u8fd9\u4e2a\u987a\u5e8f：<\/p>\n _wrtidx -=<\/span> ReadOffset<\/span>(<\/span>)<\/span> –<\/span> Begin<\/span>(<\/span>)<\/span>;<\/span> ReadOffset() \u4f9d\u8d56 _redidx，\u82e5\u5148\u628a _redidx \u5f52\u96f6，\u7b2c\u4e8c\u884c\u6052\u51cf 0，_wrtidx \u4e0d\u88ab\u6298\u7b97，\u7d27\u63a5\u7740\u7684 resize(_wrtidx – _redidx) \u4f1a\u628a size \u6491\u5927，\u7559\u4e0b\u4e00\u6bb5\u4ece\u672a\u5199\u5165\u7684\u533a\u95f4\u3002\u53e6\u5916\u5f62\u53c2\u662f uint32_t \u800c\u8c03\u7528\u70b9\u4f20 uint64_t，\u7c7b\u578b\u4e0d\u4e00\u81f4\u503c\u5f97\u8bb0\u4f4f\u3002<\/p>\n ReadOnly\/WriteOnly \u8d70"\u5148\u8c03\u7528\u518d\u53cd\u5411\u8865\u507f"：ReadOnly \u8c03 Read(len) \u540e _redidx -= len，WriteOnly \u8c03 Write \u540e _wrtidx -= len，\u4ece\u800c\u5728\u4e0d\u79fb\u52a8\u6307\u9488\u7684\u524d\u63d0\u4e0b\u63a2\u6d4b\u6570\u636e\u3002FindCRLF() \u7528 memchr \u627e '\\\\n'，\u672a\u627e\u5230\u65f6\u8fd4\u56de ""\u2014\u2014\u4e8e\u662f GetLine() \u91cc\u7684 pos == nullptr \u5224\u65ad\u4e0d\u53ef\u8fbe，\u4e14\u6b64\u65f6 pos – ReadOffset() \u662f\u4e00\u4e2a\u65e0\u610f\u4e49\u7684\u5de8\u5927\u504f\u79fb，\u4f1a\u76f4\u63a5\u5f53 len \u4f20\u7ed9 Read\u3002\u8fd9\u4e24\u5904\u9700\u8981\u590d\u770b\u3002<\/p>\n Socket \u628a fd \u6536\u8fdb RAII\u3002Create\/Bind\/Listen\/Accept\/Connect\/Recv\/Send \u90fd\u662f\u8584\u5c01\u88c5，\u503c\u5f97\u8bb0\u7684\u6709\u4e09\u70b9\u3002\u4e00\u662f Bind \u91cc inet_pton \u53ea\u5224 < 0，\u800c\u5b57\u7b26\u4e32\u975e\u6cd5\u65f6\u5b83\u8fd4\u56de 0，\u975e\u6cd5\u5730\u5740\u4e0d\u4f1a\u88ab\u62e6\u4e0b\u3002\u4e8c\u662f Recv\/Send \u628a EAGAIN\/EWOULDBLOCK\/EINTR \u7edf\u4e00\u6620\u5c04\u6210 0\u3001\u5176\u4f59\u8d1f\u503c\u6620\u5c04\u6210 -1，\u4e8e\u662f\u8c03\u7528\u5c42\u65e2\u62ff\u4e0d\u5230"\u88ab\u4fe1\u53f7\u4e2d\u65ad\u9700\u91cd\u8bd5"\u7684\u4fe1\u606f，\u4e5f\u5206\u4e0d\u6e05"\u6682\u65f6\u65e0\u6570\u636e"\u4e0e"\u5bf9\u7aef\u5173\u95ed"（\u4e24\u8005\u90fd\u662f 0）\u3002\u4e09\u662f fd \u7684\u591a\u6b21 close \u8def\u5f84：Socket::Close() \u6ca1\u6709\u628a _sockfd \u7f6e -1，\u6790\u6784\u8fd8\u4f1a close \u4e00\u6b21；\u800c Connection \u540c\u65f6\u6301\u6709 _socket \u4e0e _channel（Channel \u6309\u540c\u4e00\u4e2a fd \u6784\u9020，Channel::Close() \u4e5f close），ReleaseInLoop \u91cc\u5148 _channel.Close()，\u4e4b\u540e _socket \u6790\u6784\u518d close \u4e00\u6b21\u3002<\/p>\n CreateServer(port, ip="0.0.0.0") \u7684\u987a\u5e8f\u662f Create \u2192 SetReuseAddrPort \u2192 Bind \u2192 Listen，\u4e24\u4e2a setsockopt(SO_REUSEADDR \/ SO_REUSEPORT) \u90fd\u843d\u5728 bind \u4e4b\u524d\u3002<\/p>\n Channel \u6301 _fd\u3001_loop\u3001_events\u3001_revents \u4e0e\u4e94\u4e2a std::function\u3002EnableRead\/EnableWrite\/RemRead\/RemWrite\/RemAll \u4e00\u5f8b"\u5148\u5224\u72b6\u6001\u518d\u6539\u4f4d\u518d Update()"，\u91cd\u590d\u542f\u52a8\u53ea\u6253\u544a\u8b66；SetRevents() \u5728\u5199\u5165 _revents \u540e\u987a\u624b Update()，\u628a"\u8bbe\u7f6e\u89e6\u53d1\u4e8b\u4ef6"\u548c"\u540c\u6b65 epoll"\u7ed1\u5728\u4e00\u8d77\u3002HandleEvent() \u7528\u7684\u662f\u5e76\u5217 if \u800c\u975e else if：EPOLLIN|EPOLLRDHUP|EPOLLPRI \u547d\u4e2d\u65f6\u82e5\u5e26 EPOLLRDHUP \u5c31\u5148\u8c03 _close_cb \u5e76 return，\u5176\u4f59\u5206\u652f（EPOLLOUT\u3001EPOLLERR\u3001EPOLLHUP）\u53ef\u53e0\u52a0\u8fdb\u5165，\u56e0\u6b64\u4e00\u6b21\u5c31\u7eea\u53ef\u80fd\u540c\u65f6\u89e6\u53d1\u8bfb\u3001\u5199\u3001\u9519\u3001\u6302\u65ad\u591a\u4e2a\u56de\u8c03；\u4e94\u4e2a\u56de\u8c03\u91cc\u53ea\u6709 _close_cb \u6ca1\u6709\u7a7a\u5224\u3002<\/p>\n Poller \u662f epoll_create(256) + _fdarr[1024] + unordered_map<int, Channel*>\u3002ChannelSet() \u505a\u4e24\u4ef6\u4e8b：epoll_ctl \u4e4b\u540e\u7acb\u523b _channels[fd] = channel，\u65b0\u589e\u4e0e\u4fee\u6539\u5171\u7528\u540c\u4e00\u6761\u5199\u5165\u3002Poll() \u53d6\u56de\u4e8b\u4ef6\u540e\u6309 _fdarr[i].data.fd \u67e5\u8868，\u67e5\u4e0d\u5230\u65f6\u662f return \u800c\u975e continue，\u4f1a\u628a\u672c\u8f6e\u5269\u4f59\u6d3b\u8dc3 Channel \u4e00\u5e76\u4e22\u6389\u3002RemoveEvent() \u53ea\u505a DEL \u52a0 erase，\u4e0d close，close \u4ea4\u7ed9 Channel::Close()\u2014\u2014\u804c\u8d23\u5212\u5206\u6e05\u6670，\u4f46\u4e5f\u610f\u5473\u7740 fd \u7684\u5173\u95ed\u65f6\u673a\u5b8c\u5168\u7531\u8fde\u63a5\u5c42\u638c\u63e1\u3002<\/p>\n \u6210\u5458\u987a\u5e8f\u503c\u5f97\u5148\u770b\u4e00\u773c：_thread_id\u3001_event_fd\u3001_mutex\u3001_tasks\u3001_poller\u3001_event_channel\u3001_time_wheel\u3002\u6784\u9020\u5217\u8868\u91cc _time_wheel(this) \u5728\u51fd\u6570\u4f53\u4e4b\u524d\u5b8c\u6210，\u800c TimeWheel \u6784\u9020\u671f\u5c31\u4f1a CreateTimerfd() \u5e76 EnableRead()，\u7ecf Channel::Update \u2192 AddMoniter \u6253\u8fdb _poller\u2014\u2014\u6240\u4ee5 _poller \u5fc5\u987b\u5728\u58f0\u660e\u987a\u5e8f\u4e0a\u65e9\u4e8e _time_wheel，\u5426\u5219\u6784\u9020\u671f\u56de\u8c03\u4f1a\u843d\u5230\u672a\u6784\u9020\u7684\u5bf9\u8c61\u4e0a\u3002<\/p>\n Start() \u662f\u4e09\u6bb5：_poller.Poll(&actives) \u2192 \u9010\u4e2a HandleEvent() \u2192 RunTaskQueueTasks()\u3002<\/p>\n \u8de8\u7ebf\u7a0b\u53ea\u8d70\u4e00\u6761\u53e3\u5b50\u3002PushTaskqueue(fc) \u7528 IsMatchEtLoop() \u5224\u7ebf\u7a0b：\u547d\u4e2d\u5c31\u5f53\u573a fc()，\u5426\u5219 Push\u3002Push \u5728\u9501\u91cc push_back，\u51fa\u9501\u540e WeakUpEventfd() \u5199\u4e00\u4e2a 1，\u628a\u53ef\u80fd\u963b\u585e\u5728 epoll_wait \u7684 loop \u62fd\u9192（EFD_NONBLOCK \u4fdd\u8bc1\u5199\u4e0d\u4f1a\u963b\u585e，\u8bfb\u4fa7 ReadEventfd \u628a\u8ba1\u6570\u5668\u8bfb\u7a7a）\u3002RunTaskQueueTasks() \u5728\u9501\u5185 _tasks.swap(tmpFuncs)\u3001\u51fa\u9501\u518d\u9010\u4e2a\u6267\u884c，\u4e34\u754c\u533a\u53ea\u4fdd\u62a4\u5bb9\u5668\u672c\u8eab，\u56de\u8c03\u4e0d\u6301\u9501\u2014\u2014\u8fd9\u4e00\u70b9\u51b3\u5b9a\u4e86\u4efb\u52a1\u91cc\u53ef\u4ee5\u5b89\u5168\u5730\u518d Push\u3002<\/p>\n \u7531\u6b64\u5e26\u6765\u4e00\u4e2a\u5bb9\u6613\u5fd8\u7684\u8bed\u4e49：Established()\u3001Shutdown()\u3001Send(data,len) \u90fd\u53ea\u628a this \u548c\u8c03\u7528\u65b9\u7684\u88f8\u6307\u9488 std::bind \u8d77\u6765\u6392\u961f，\u771f\u6b63\u6267\u884c\u5728 loop \u7ebf\u7a0b\u3002Send(const void*,size_t) \u4e0d\u505a\u62f7\u8d1d，\u6240\u4ee5\u8c03\u7528\u65b9\u4f20\u5165\u7684 data \u5fc5\u987b\u6d3b\u5230 SendInLoop \u6267\u884c\u2014\u2014EchoServer \u4f20\u7684\u662f _inbuf \u7684\u5185\u90e8\u5730\u5740，\u800c Buffer \u8bfb\u540e\u4e0d erase，\u6b63\u597d\u6210\u7acb\u3002<\/p>\n TimerTask \u7684\u6267\u884c\u903b\u8f91\u5199\u5728\u6790\u6784\u91cc：_cancel \u4e3a\u771f\u5219\u53ea\u6253\u5370\u8fd4\u56de；\u4e3a\u5047\u5219\u8dd1 _task_cb，\u518d\u8dd1 _release\u3002\u4e5f\u5c31\u662f\u8bf4\u4efb\u52a1\u4e0d\u662f"\u5230\u70b9\u88ab\u8c03\u7528"，\u800c\u662f"\u5230\u70b9\u88ab\u9500\u6bc1"\u3002\u8fd9\u8981\u6c42\u5916\u90e8\u4fdd\u8bc1\u6700\u540e\u4e00\u4e2a shared_ptr \u5728\u6b63\u786e\u65f6\u523b\u91ca\u653e\u3002<\/p>\n \u6784\u9020\u51fd\u6570\u628a _cancel(true)，TimerAdd \u91cc\u5148 SetCancel(false) \u518d SetRealese(std::bind(&TimeWheel::RemoveTimer, this, id))\u2014\u2014\u987a\u5e8f\u4e0d\u80fd\u53cd，\u56e0\u4e3a SetRealese \u5728 _cancel \u4e3a\u771f\u65f6\u4f1a\u76f4\u63a5 ERR_LOG \u8fd4\u56de，_release \u4f1a\u7559\u7a7a，\u4efb\u52a1\u968f\u69fd\u6e05\u7a7a\u9500\u6bc1\u540e\u5c31\u6ca1\u6709\u4eba\u628a _timers \u91cc\u7684\u6761\u76ee erase \u6389\u3002<\/p>\n TimeWheel \u7528\u4e24\u5f20\u8868\u5206\u5de5：_wheel（vector<vector<PtrTask>>，\u957f\u5ea6 _capacity = Time_Out = 120）\u6301\u6709\u5f3a\u5f15\u7528，\u51b3\u5b9a\u751f\u547d\u5468\u671f；_timers（unordered_map<uint64_t, WeakTask>）\u53ea\u505a id \u7d22\u5f15\u4e0e\u5224\u6d3b\u3002\u521d\u59cb\u5316\u5217\u8868 _wheel(_capacity) \u4f9d\u8d56 _capacity \u5148\u5c31\u4f4d，\u5fc5\u987b\u4e0e\u58f0\u660e\u987a\u5e8f\u4e00\u81f4\u3002<\/p>\n CreateTimerfd() \u7528 CLOCK_MONOTONIC，it_value \u4e0e it_interval \u5404 1 \u79d2，\u4e8e\u662f timerfd \u6bcf\u79d2"\u8bfb\u5c31\u7eea"\u4e00\u6b21；\u8be5 fd \u7531 _timer_channel \u76d1\u63a7，\u8bfb\u56de\u8c03 OnTime() = ReadTimerfd()（\u628a\u8ba1\u6570\u5668\u8bfb\u7a7a）+ TickRun()\u3002<\/p>\n TimerAdd \u6309 pos = (_tick + delay) % _capacity \u63d2\u5165\u69fd\u9996，\u540c\u65f6\u628a WeakTask \u767b\u8bb0\u8fdb _timers\u3002Refresh \u4ece _timers[id].lock() \u53d6\u56de\u5f3a\u5f15\u7528\u518d\u6309 (timeout + _tick) % _capacity \u63d2\u4e00\u4efd\u65b0\u6761\u76ee，\u65e7\u69fd\u91cc\u90a3\u4efd\u4e0d\u5220\u2014\u2014\u540c\u4e00\u4efb\u52a1\u4f1a\u5728\u591a\u4e2a\u69fd\u5404\u6301\u4e00\u4efd\u5f3a\u5f15\u7528，\u91cd\u590d\u5237\u65b0\u8d8a\u591a，\u6761\u76ee\u8d8a\u591a，\u771f\u6b63\u6267\u884c\u88ab\u63a8\u5230\u6700\u540e\u4e00\u4e2a\u69fd\u88ab\u6e05\u7a7a\u7684\u65f6\u5019\u3002<\/p>\n TickRun() \u5148\u626b _wheel[(_tick+1) % _capacity]，\u53ea\u8981\u53d1\u73b0\u4efb\u4e00 _cancel \u4e3a\u771f\u7684\u4efb\u52a1\u5c31\u6253\u5370\u540e return：_tick \u4e0d\u63a8\u8fdb，\u69fd\u4e5f\u4e0d\u6e05\u7a7a，\u7b49\u4e8e\u88ab\u53d6\u6d88\u9879\u5361\u4f4f\u6574\u53ea\u8f6e\u5b50；\u5426\u5219\u63a8\u8fdb _tick \u5e76 _wheel[_tick].clear()，\u9760 clear \u89e6\u53d1\u7684\u6790\u6784\u6765\u6267\u884c\u4efb\u52a1\u3002<\/p>\n \u53e6\u5916 HashAble(uint64_t id) \u5199\u7684\u662f _timers[id].lock() == 0，\u7528\u7684\u662f operator[]：\u67e5\u8be2\u5373\u63d2\u5165，\u5bf9\u4e0d\u5b58\u5728\u7684 id \u4f1a\u7559\u4e0b\u4e00\u4e2a\u7a7a weak_ptr \u6761\u76ee\u3002<\/p>\n LoopThread \u7684 Handle() \u5728\u5b50\u7ebf\u7a0b\u6808\u4e0a\u6784\u9020 EventLoop，\u52a0\u9501\u628a\u5730\u5740\u5199\u56de _loop \u5e76 notify_all()，\u968f\u540e while(1) loop.Start()\u3002GetLoop() \u7528 _cond.wait(lock, [this]{ return _loop != nullptr; }) \u7b49\u8fd9\u4e00\u53e5\u5199\u5b8c\u3002\u6784\u9020\u5217\u8868\u91cc _thread(std::thread(&LoopThread::Handle, this)) \u4f1a\u5728\u5bf9\u8c61\u6784\u9020\u5b8c\u6210\u524d\u5c31\u628a\u7ebf\u7a0b\u62c9\u8d77\u6765，\u5b83\u80fd\u6210\u7acb\u7684\u552f\u4e00\u524d\u63d0\u662f _mutex\/_cond \u5728\u58f0\u660e\u987a\u5e8f\u4e0a\u65e9\u4e8e _thread\u3002~LoopThread() \u53ea detach，\u6ca1\u6709\u505c\u6b62\u8def\u5f84，_loop \u6307\u5411\u7684\u4ecd\u662f\u5b50\u7ebf\u7a0b\u6808\u4e0a\u7684\u5bf9\u8c61\u3002<\/p>\n LoopThreadPool::CreateThreads() \u6309 _thread_count resize \u540e\u9010\u4e2a new LoopThread() \u5e76 GetLoop() \u7f13\u5b58\u6307\u9488；GetNextLoop() \u5148\u81ea\u589e\u518d\u53d6\u6a21，\u6240\u4ee5\u9996\u4e2a\u65b0\u8fde\u63a5\u843d\u5728 _loops[1]（\u884c\u5185\u6ce8\u91ca\u4e5f\u5199\u660e"\u81ea[1]\u5f00\u59cb"）；_thread_count == 0 \u65f6\u6574\u4f53\u56de\u843d\u5230 _base_loop\u3002<\/p>\n Any \u7528 holder\/placeholder<T> \u4e24\u7ea7\u7ed3\u6784\u6536\u53e3\u7c7b\u578b：clone() \u505a\u6df1\u62f7\u8d1d，type() \u8fd4\u56de typeid(T)，get<T>() \u5148 assert \u7c7b\u578b\u4e00\u81f4\u518d dynamic_cast \u53d6 _val；operator=(const T&) \u8d70 Any(val).swap(*this)，\u5373\u6784\u9020\u4e34\u65f6\u5bf9\u8c61\u518d\u4ea4\u6362，swap \u53ea\u6362 _content \u6307\u9488\u3002<\/p>\n Connection \u7ee7\u627f enable_shared_from_this，\u6240\u6709\u56de\u8c03\u90fd\u901a\u8fc7 shared_from_this() \u4f20\u51fa，\u907f\u514d\u88f8 this \u4e0a\u518d\u9020\u4e00\u4e2a shared_ptr \u9020\u6210\u53cc\u91cd\u91ca\u653e\u3002\u6784\u9020\u65f6\u628a Channel \u7684\u4e94\u7c7b\u56de\u8c03\u5168\u90e8\u6307\u5411\u81ea\u8eab\u7684 HandleRead\/HandleWrite\/HandleHup\/HandleErr\/HandleEvent，\u5e76 SetNonBlock()\u3002<\/p>\n \u72b6\u6001\u5b57\u6bb5\u662f ConnStat _stat，\u679a\u4e3e\u6709\u56db\u4e2a\u503c，\u4f46\u4ee3\u7801\u91cc\u53ea\u51fa\u73b0\u4e09\u5904\u8d4b\u503c：\u6784\u9020\u65f6 CONNECTING\u3001ShutdownInLoop \u91cc DISCONNECTING\u3001ReleaseInLoop \u91cc DISCONNECTED\u3002\u6ca1\u6709\u628a _stat \u7f6e\u4e3a CONNECTED \u7684\u4f4d\u7f6e，\u56e0\u6b64 Connected() \u6052\u4e3a false，HandleWrite \u91cc\u90a3\u53e5\u65ad\u8a00\u4e5f\u88ab\u6ce8\u6389\u2014\u2014\u540e\u7eed\u8981\u6062\u590d"\u53ef\u901a\u4fe1"\u8bed\u4e49\u5f97\u8865\u8fd9\u4e00\u6b65\u3002<\/p>\n \u8bfb\u4fa7 HandleRead()：\u6808\u4e0a char temp[BUF_CAPACITY]，RecvNonBlock(temp, BUF_CAPACITY-1)；n < 0 \u76f4\u63a5 ShutdownInLoop()（\u51fa\u9519\u4e0d\u5f53\u573a\u5173\u95ed）；\u5176\u540e if ((ssize_t)_inbuf.TailableGet() < n || _connCB == nullptr) \u6253\u5370\u9519\u8bef\u5e76 return，\u6570\u636e\u88ab\u4e22\u5f03\u4e14\u8fde\u63a5\u4e0d\u5173；\u5224\u65ad\u91cc\u7528\u7684\u662f _connCB，\u4f46\u771f\u6b63\u88ab\u8c03\u7528\u7684\u662f _msgCB，\u4e24\u8005\u4e0d\u662f\u540c\u4e00\u4e2a\u6210\u5458\u3002n == 0 \u65f6\u4ecd\u4f1a\u8d70\u5b8c Write（\u5199 0 \u5b57\u8282）\u5e76\u8c03\u7528 _msgCB\u2014\u2014\u7ed3\u5408 Socket::Recv \u628a EAGAIN \u4e5f\u5f52\u96f6，\u8fd9\u91cc\u65e0\u6cd5\u533a\u5206"\u6ca1\u6570\u636e"\u4e0e"\u5bf9\u7aef\u5173\u4e86"\u3002<\/p>\n \u5199\u4fa7 HandleWrite()：SendNonBlock(_outbuf.ReadOffset(), _outbuf.ReadableGet()) \u4e4b\u540e\u4e0d\u770b n \u7684\u5b9e\u9645\u503c，\u76f4\u63a5 _outbuf.RdixMove(_outbuf.ReadableGet()) \u5168\u91cf\u524d\u79fb，\u5e76\u65e0\u6761\u4ef6 RemWrite()\u3002\u77ed\u5199\u4e0e"\u8fd8\u6709\u6b8b\u7559\u6570\u636e"\u4e24\u79cd\u60c5\u51b5\u90fd\u4f1a\u88ab\u8fd9\u6b21\u5168\u91cf\u524d\u79fb＋\u5173\u5199\u76d1\u63a7\u541e\u6389\u3002<\/p>\n ShutdownInLoop() \u7684\u987a\u5e8f\u662f\u5148\u8865\u5904\u7406\u8f93\u5165\u7f13\u51b2（_inbuf.ReadableGet() > 0 \u5c31\u518d\u6295\u4e00\u6b21 _msgCB），\u518d\u770b\u8f93\u51fa\u7f13\u51b2：\u975e\u7a7a\u5219\u786e\u4fdd\u5199\u76d1\u63a7\u5f00\u7740\u3001\u7b49\u4e0b\u4e00\u8f6e HandleWrite；\u4e3a\u7a7a\u624d Release()\u3002ReleaseInLoop() \u662f Remove()（epoll DEL + \u4ece _channels \u6458\u9664）\u2192 _channel.Close()（close fd）\u2192 \u82e5\u65f6\u95f4\u8f6e\u91cc\u8fd8\u6709\u8be5 id \u5c31\u53d6\u6d88 \u2192 _closeCB \u2192 _svrCloseCB\u3002<\/p>\n Acceptor \u76f4\u63a5\u6301 Socket \u4e0e Channel：_socket(CreateServerFc(port)) \u5931\u8d25\u5373 abort()，_channel(_socket.Fd(), loop) \u4f9d\u8d56 _socket \u5728\u58f0\u660e\u987a\u5e8f\u4e0a\u9760\u524d\u3002\u6784\u9020\u4f53\u5185 EnableRead() \u5df2\u7ecf\u89e6\u53d1\u8fc7\u4e00\u6b21 Update \u2192 AddMoniter，\u968f\u540e\u53c8\u663e\u5f0f _loop->AddMoniter(&_channel)，\u7b2c\u4e8c\u6b21\u8d70\u7684\u662f MOD \u5206\u652f，\u5c5e\u5197\u4f59\u4f46\u65e0\u5bb3\u3002\u8bfb\u56de\u8c03 HandleRead() \u53ea\u505a Accept() \u52a0 _readCB(newclientfd)\u3002<\/p>\n TcpServer::NewConnetion(fd)：\u81ea\u589e _next_id \u4f5c\u8fde\u63a5 id，_loops.GetNextLoop() \u9009\u4ece\u5c5e loop，\u88c5\u597d\u56db\u4e2a\u5916\u90e8\u56de\u8c03\u540e Established()，\u6309 _enable_inactive_release \u51b3\u5b9a\u662f\u5426 EnableInactiveRelease(_timeout)，\u6700\u540e _conns[_next_id] = newConn \u4fdd\u6d3b\u3002<\/p>\n \u9500\u6bc1\u8def\u5f84\u76ee\u524d\u4e0d\u901a：RemoveConnection \u628a conn->Fd() \u4f20\u7ed9 RemoveConnectionInLoop(uint64_t fd)，\u800c _conns \u7684 key \u662f _next_id，\u6309 fd \u67e5\u5fc5\u7136\u67e5\u4e0d\u5230；\u540c\u65f6\u5f53\u524d\u4ee3\u7801\u6ca1\u6709\u4efb\u4f55\u5730\u65b9\u8c03\u7528 RemoveConnection，TcpServer \u4e5f\u6ca1\u6709\u901a\u8fc7 Connection::SetServerCB \u628a _svrCloseCB \u6302\u4e0a\u53bb，\u56e0\u6b64 _conns \u91cc\u4e0d\u4f1a\u6709\u6761\u76ee\u88ab\u79fb\u9664\u3002<\/p>\n EnableInactiveRelease(scds) \u53ea\u7f6e _timeout \u4e0e\u5f00\u5173，assert(scds < Time_Out) \u628a\u4e0a\u9650\u5361\u5728 120 \u79d2；EchoServer \u4f20\u7684\u662f 30，\u884c\u5185\u6ce8\u91ca\u5199\u7684\u662f 10s，\u4e8c\u8005\u4e0d\u4e00\u81f4\u3002\u6784\u9020\u91cc\u8fd8\u6709 signal(SIGPIPE, SIG_IGN)：\u5ba2\u6237\u7aef\u5f02\u5e38\u65ad\u5f00\u540e\u7ee7\u7eed\u53d1\u9001\u4f1a\u8ba9\u8fdb\u7a0b\u76f4\u63a5\u88ab SIGPIPE \u7ec8\u6b62\u3002Start() \u662f while(1) _baseloop->Start();，\u4e3b\u7ebf\u7a0b\u6c38\u8fdc\u505c\u5728 base loop；_baseloop \u7531\u88f8 new EventLoop() \u4ea7\u751f，\u6790\u6784\u91cc\u53ea\u6253\u65e5\u5fd7\u4e0d delete\u3002<\/p>\n \u88c5\u914d\u53ea\u6709\u56db\u884c\u6709\u6548\u4ee3\u7801：EnableInactiveRelease(30)，\u4ee5\u53ca SetConnectCB \u2192 ReadCallback\u3001SetMessageCB \u2192 WriteCallback\u3001SetClosedCB \u2192 HupCallback \u4e09\u4e2a std::bind；\u7ebf\u7a0b\u6570\u9ed8\u8ba4 2\u3002<\/p>\n ReadCallback \u6302\u5728"\u8fde\u63a5\u5efa\u7acb"\u4e0a，\u5374\u76f4\u63a5\u7528 read(conn->Fd(), buf, 1023) \u53bb\u8bfb fd\u3002\u6b64\u65f6 fd \u5df2\u88ab Connection \u6784\u9020\u7f6e\u4e3a\u975e\u963b\u585e，\u5efa\u8fde\u77ac\u95f4\u6ca1\u6709\u6570\u636e，read \u8fd4\u56de -1，\u53ea\u4f1a\u6253\u4e00\u6761 DBG_LOG\u3002\u6570\u636e\u771f\u6b63\u5230\u8fbe\u65f6\u8d70\u7684\u662f MessageCB，\u56e0\u6b64\u8fd9\u4e2a\u56de\u8c03\u5728\u6574\u6761\u94fe\u4e0a\u5b9e\u9645\u53ea\u627f\u62c5"\u89e6\u53d1\u4e00\u6b21\u8bfb\u65e5\u5fd7"\u7684\u4f5c\u7528；n == 0（EOF）\u4e5f\u6ca1\u6709\u5355\u72ec\u5904\u7406\u3002<\/p>\n WriteCallback \u624d\u662f\u56de\u58f0\u672c\u4f53：ReadableGet() == 0 \u76f4\u63a5\u8fd4\u56de；\u5426\u5219 conn->Send(buf->ReadOffset(), buf->ReadableGet()) \u628a _inbuf \u4e2d\u7684\u539f\u59cb\u6307\u9488\u6295\u9012\u5230 loop \u7ebf\u7a0b，SendInLoop \u628a\u5b83 Write \u8fdb _outbuf \u5e76 EnableWrite()；EPOLLOUT \u5c31\u7eea\u540e HandleWrite \u628a _outbuf \u53d1\u56de\u5bf9\u7aef\u3002\u6295\u9012\u4e4b\u540e\u672c\u5730\u7d27\u63a5\u7740 buf->RdixMove(buf->ReadableGet()) \u5168\u91cf\u524d\u79fb\u8bfb\u4f4d\u7f6e（\u6570\u636e\u4ecd\u5728 _buf \u91cc，\u6240\u4ee5\u6307\u9488\u4f9d\u65e7\u6709\u6548），\u6700\u540e conn->Shutdown()，\u5151\u73b0\u884c\u5185\u6ce8\u91ca\u91cc"\u4ec5\u901a\u4fe1\u4e00\u6b21\u5373\u5173\u95ed\u5bf9\u7aef"\u7684\u51b3\u7b56\u3002<\/p>\n \u5b8c\u6574\u56de\u58f0\u94fe\u56e0\u6b64\u662f：HandleRead \u2192 _inbuf \u2192 _msgCB(WriteCallback) \u2192 Send \u2192 _outbuf \u2192 HandleWrite \u2192 \u5bf9\u7aef\u3002TCP \u5c42\u7684\u6536\u53d1\u5b57\u8282\u6570\u7531 Connection \u8d1f\u8d23，EchoServer \u53ea\u5728 MessageCB \u91cc\u628a\u6570\u636e\u4ece\u8f93\u5165\u4fa7\u642c\u5230\u8f93\u51fa\u4fa7\u3002<\/p>\n \u8fd9\u4efd\u5b9e\u73b0\u6309\u4e09\u5c42\u5207\u5206：\u4e8b\u4ef6\u5c42（Socket\/Channel\/Poller）\u53ea\u7ba1 fd \u4e0e\u5c31\u7eea\u4e8b\u4ef6，\u8c03\u5ea6\u5c42（EventLoop\/TimeWheel\/LoopThread(Pool)）\u53ea\u7ba1 loop \u5f52\u5c5e\u3001\u4efb\u52a1\u6392\u961f\u4e0e\u5b9a\u65f6，\u8fde\u63a5\u5c42（Connection\/Acceptor\/TcpServer）\u53ea\u7ba1\u72b6\u6001\u3001\u7f13\u51b2\u533a\u4e0e\u751f\u547d\u5468\u671f\u3002Buffer \u7684\u53cc\u4e0b\u6807\u8bbe\u8ba1\u628a\u8bfb\u5199\u4f4d\u7f6e\u4ece vector \u7684 size \u91cc\u62c6\u51fa\u6765，\u6536\u76ca\u662f End() \u4e0e\u4e24\u4e2a Offset() \u5904\u4e8e\u540c\u4e00\u5750\u6807\u7cfb\u3001\u8bfb\u540e\u65e0\u9700\u642c\u79fb；\u4ee3\u4ef7\u662f\u6240\u6709\u4e0b\u6807\u8bbf\u95ee\u90fd\u7531\u81ea\u5df1\u4fdd\u8bc1\u4e0d\u8d8a\u754c，resize\u3001insert\u3001clear \u4e0e\u4e0b\u6807\u6298\u7b97\u7684\u5148\u540e\u987a\u5e8f\u90fd\u4e0d\u80fd\u968f\u624b\u6539\u3002\u65f6\u95f4\u8f6e\u628a"\u5230\u70b9\u6267\u884c"\u5bc4\u6258\u5728\u6790\u6784\u65f6\u673a\u4e0a，\u56e0\u6b64\u4efb\u52a1\u751f\u547d\u5468\u671f\u5b8c\u5168\u7ed1\u5b9a\u5728\u69fd\u4f4d\u7684 shared_ptr \u4e0a，\u53d6\u6d88\u4e0e\u5237\u65b0\u90fd\u53ea\u662f\u6539\u53d8\u5f3a\u5f15\u7528\u7684\u5206\u5e03\u3002\u53cd\u590d\u9700\u8981\u590d\u770b\u7684\u4e09\u5904\u662f：\u4e0b\u6807\u6362\u7b97\u4e0e size \u7684\u540c\u6b65\u987a\u5e8f\u3001\u77ed\u5199\u4e0e n == 0 \u7684\u5904\u7406\u3001\u4ee5\u53ca _conns \u7684 key \u4e0e\u9500\u6bc1\u8def\u5f84\u662f\u5426\u63a5\u901a\u3002<\/p>\n 1. Buffer::End() \u4e3a\u4ec0\u4e48\u7528 capacity() \u800c\u4e0d\u662f size()？ \u7528 capacity() \u624d\u80fd\u8ba9 End() \u6052\u7b49\u4e8e"\u7269\u7406\u7f13\u51b2\u533a\u672b\u5c3e"，\u4e0e Begin()+_redidx\u3001Begin()+_wrtidx \u540c\u4e00\u5750\u6807\u7cfb；size() \u5728\u8bfb\u53d6\u540e\u4e0d\u4f1a\u7f29\u5c0f（ReadLen \u53ea\u63a8\u8fdb _redidx），\u7528\u5b83\u7b97 End() \u4f1a\u8ba9"\u672b\u5c3e"\u968f\u8bfb\u53d6\u6f02\u79fb\u3002\u89c1 echo.hpp \u4e2d Buffer::End\/Begin\/ReadOffset\/WriteOffset\u3002<\/p>\n 2. EnsureEnoughCapacity \u672b\u5c3e\u90a3\u4e24\u884c\u5199\u53cd\u4f1a\u51fa\u73b0\u4ec0\u4e48\u73b0\u8c61？ _wrtidx -= ReadOffset() – Begin(); \u5fc5\u987b\u5728 _redidx = 0; \u4e4b\u524d\u3002\u5148\u5f52\u96f6\u65f6 ReadOffset() == Begin()，\u51cf\u6570\u4e3a 0，_wrtidx \u4fdd\u6301\u65e7\u503c，\u968f\u540e _buf.resize(_wrtidx – _redidx) \u628a size \u6491\u5230\u65e7\u5199\u4f4d\u7f6e，\u7f13\u51b2\u533a\u91cc\u591a\u51fa\u4e00\u6bb5\u4ece\u672a\u5199\u5165\u7684\u533a\u95f4\u3002\u89c1 Buffer::EnsureEnoughCapacity\u3002<\/p>\n 3. Write \u91cc assert(capacity – _wrtidx > len) \u4e3a\u4ec0\u4e48\u662f\u4e25\u683c\u5927\u4e8e？ \u5b83\u4e0e EnsureEnoughCapacity \u7684 >= \u4e0d\u4e00\u81f4：\u6070\u597d\u5199\u6ee1\u5269\u4f59\u5bb9\u91cf\u65f6\u524d\u8005\u80fd\u901a\u8fc7\u3001\u540e\u8005\u65ad\u8a00\u5931\u8d25，len == 0 \u4e14\u5728\u5bb9\u91cf\u8fb9\u754c\u4e0a\u4e5f\u4f1a\u89e6\u53d1\u3002\u51e1\u662f\u8d34\u7740\u5bb9\u91cf\u4e0a\u9650\u7684\u5199\u5165\u8def\u5f84\u90fd\u8981\u6309\u8fd9\u4e2a\u66f4\u4e25\u7684\u7ea6\u675f\u9884\u4f30\u3002\u89c1 Buffer::Write\u3002<\/p>\n 4. HandleWrite \u4e3a\u4ec0\u4e48\u53ef\u80fd\u4e22\u6389\u6ca1\u53d1\u5b8c\u7684\u6570\u636e？ \u53d1\u9001\u540e\u4e0d\u770b SendNonBlock \u7684\u8fd4\u56de\u503c，\u76f4\u63a5 RdixMove(ReadableGet()) \u628a\u8bfb\u4f4d\u7f6e\u5168\u91cf\u524d\u79fb，\u5e76\u4e14\u65e0\u6761\u4ef6 RemWrite()\u3002\u4e00\u65e6\u53d1\u751f\u77ed\u5199，_outbuf \u91cc\u5269\u4f59\u7684\u6570\u636e\u5176\u4e0b\u6807\u5df2\u88ab\u8df3\u8fc7，\u5199\u76d1\u63a7\u4e5f\u5df2\u5173\u95ed，\u4e0d\u4f1a\u518d\u6709\u4e0b\u4e00\u8f6e EPOLLOUT\u3002\u89c1 Connection::HandleWrite\u3002<\/p>\n 5. _conns \u4e3a\u4ec0\u4e48\u6536\u4e0d\u5230\u8fde\u63a5\u9500\u6bc1\u901a\u77e5？ \u4e24\u4e2a\u539f\u56e0\u53e0\u52a0：RemoveConnection \u4f20\u7684\u662f conn->Fd()，\u800c _conns \u4ee5 _next_id \u4e3a key，RemoveConnectionInLoop \u91cc _conns.find(fd) \u5fc5\u7136\u843d\u7a7a；\u4e14\u6ca1\u6709\u4efb\u4f55\u8c03\u7528\u70b9\u89e6\u53d1 RemoveConnection，TcpServer \u4e5f\u672a\u8c03\u7528 Connection::SetServerCB \u8bbe\u7f6e _svrCloseCB\u3002\u89c1 TcpServer::NewConnetion\/RemoveConnection\/RemoveConnectionInLoop \u4e0e Connection::ReleaseInLoop\u3002<\/p>\n 6. \u65f6\u95f4\u8f6e\u91cc\u51fa\u73b0\u88ab\u53d6\u6d88\u7684\u4efb\u52a1\u4f1a\u600e\u6837？ TickRun() \u626b\u4e0b\u4e00\u69fd\u65f6，\u53ea\u8981\u6709\u4efb\u4e00\u4efb\u52a1\u7684 _cancel \u4e3a\u771f\u5c31\u6253\u5370\u5e76 return，_tick \u4e0d\u63a8\u8fdb\u3001\u69fd\u4e0d\u6e05\u7a7a；\u540c\u65f6 HashAble() \u7528 _timers[id].lock() == 0 \u5224\u65ad，operator[] \u4f1a\u7ed9\u67e5\u8be2\u8fc7\u7684 id \u7559\u4e0b\u7a7a\u6761\u76ee\u3002\u4e24\u8005\u90fd\u4f1a\u6539\u53d8 _timers \u4e0e _wheel \u7684\u5b9e\u9645\u72b6\u6001\u3002\u89c1 TimeWheel::TickRun\/HashAble\u3002<\/p>\n header-only\u3001Reactor\u3001epoll\u3001\u65f6\u95f4\u8f6e\u3001C++ \u670d\u52a1\u7aef<\/p>\n","protected":false},"excerpt":{"rendered":" \u76ee\u5f552. \u6458\u89813. \u6ce8\u91ca4. \u5206\u8282\u6b63\u65874.1 \u67b6\u6784\u603b\u89c8\u4e0e\u5305\u542b\u987a\u5e8f4.2 Buffer：\u4e24\u4e2a\u4e0b\u6807\u4e0e\u4e00\u4e2a vector4.3 Socket \/ Channel \/ Poller：\u4e8b\u4ef6\u5c424.4 EventLoop：\u4efb\u52a1\u961f\u5217\u4e0e\u5524\u91924.5 TimeWheel：\u4ee5\u6790\u6784\u65f6\u673a\u9a71\u52a8\u7684\u4efb\u52a14.6 LoopThread \/ LoopThreadPool \/ Any4.7 Connection：\u72b6\u6001\u673a\u4e0e\u6536\u53d1\u7f13\u51b24.8 Accept<\/p>\n","protected":false},"author":2,"featured_media":121630,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[43,44],"topic":[],"class_list":["post-121631","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-43","tag-44"],"yoast_head":"\n
\nvoid<\/span> Channel<\/span>::<\/span>Update<\/span>(<\/span>)<\/span> {<\/span> _loop-><\/span>AddMoniter<\/span>(<\/span>this<\/span>)<\/span>;<\/span> }<\/span>
\nvoid<\/span> Channel<\/span>::<\/span>Remove<\/span>(<\/span>)<\/span> {<\/span> _loop-><\/span>RemoveMoniter<\/span>(<\/span>this<\/span>)<\/span>;<\/span> }<\/span><\/p>\n4.2 Buffer：\u4e24\u4e2a\u4e0b\u6807\u4e0e\u4e00\u4e2a vector<\/h4>\n
\n _redidx =<\/span> 0<\/span>;<\/span>
\n _buf.<\/span>resize<\/span>(<\/span>_wrtidx –<\/span> _redidx)<\/span>;<\/span><\/p>\n4.3 Socket \/ Channel \/ Poller：\u4e8b\u4ef6\u5c42<\/h4>\n
4.4 EventLoop：\u4efb\u52a1\u961f\u5217\u4e0e\u5524\u9192<\/h4>\n
4.5 TimeWheel：\u4ee5\u6790\u6784\u65f6\u673a\u9a71\u52a8\u7684\u4efb\u52a1<\/h4>\n
4.6 LoopThread \/ LoopThreadPool \/ Any<\/h4>\n
4.7 Connection：\u72b6\u6001\u673a\u4e0e\u6536\u53d1\u7f13\u51b2<\/h4>\n
4.8 Acceptor \/ TcpServer<\/h4>\n
4.9 EchoServer \u4e0e main \u7684\u5b8c\u6574\u4e3b\u94fe<\/h4>\n
5. \u603b\u7ed3<\/h3>\n
6. \u5e38\u89c1\u95ee\u9898<\/h3>\n
7. \u6807\u7b7e<\/h3>\n