\n| TcpServer<\/td>\n | \u96c6\u6210\u4e4b\u524d\u7684\u6240\u6709\u7c7b，\u771f\u6b63\u7684\u670d\u52a1\u5668\u7c7b<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u00a0 \u00a0 \u00a0 \u00a0 \u53c8\u5206\u4e3a\u4e94\u4e2a\u5927\u6a21\u5757：\u57fa\u7840\u5de5\u5177\u6a21\u5757\u3001\u7f51\u7edc\u57fa\u7840\u6a21\u5757\u3001\u4e8b\u4ef6\u9a71\u52a8\u6838\u5fc3\u3001\u9ad8\u7ea7\u7279\u6027\u6a21\u5757\u3001\u4e1a\u52a1\u6838\u5fc3\u6a21\u5757\u3002<\/p>\n \u56db：\u6a21\u5757\u8be6\u7ec6\u4ecb\u7ecd\u6bcf\u4e2a\u6a21\u5757\u4ee5\u53ca\u6bcf\u4e2a\u6a21\u5757\u4e4b\u95f4\u7684\u5173\u8054\u548c\u4f9d\u8d56\u5173\u7cfb<\/h2>\n4.1\u57fa\u7840\u5de5\u5177\u6a21\u5757<\/h3>\n4.1.1 \u65e5\u5fd7\u5b8f\u2014\u2014LOG<\/h4>\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u65e5\u5fd7\u5b8f\u7684\u8bbe\u8ba1\u521d\u8877\u2014\u2014\u5728\u6d4b\u8bd5\u9879\u76ee\u65f6\u4e3a\u4e86\u65b9\u4fbf\u6211\u4eec\u51c6\u786e\u5feb\u901f\u5730\u627e\u5230\u9519\u8bef\u4fe1\u606f，\u6211\u4eec\u4e00\u822c\u4f1a\u4f7f\u7528\u65e5\u5fd7\u5e2e\u6211\u4eec\u5feb\u901f\u5b9a\u4f4d，\u5728\u65e5\u5fd7\u4e2d\u4e0d\u662f\u5355\u7eaf\u7684\u9519\u8bef\u4fe1\u606f，\u6211\u4eec\u8fd8\u4f1a\u989d\u5916\u7684\u6dfb\u52a0\u9519\u8bef\u6587\u4ef6\u540d，\u884c\u53f7，\u9519\u8bef\u65f6\u95f4\u7b49\u7b49，\u6765\u5e2e\u52a9\u6211\u4eec\u627e\u51fa\u9519\u8bef\u3002\u5177\u4f53\u5982\u4e0b：<\/p>\n #define INF 0
\n#define DBG 1
\n#define ERR 2
\n#define LOG_LEVEL DBG<\/p>\n \/\/\u4f7f\u7528strrchr\u53bb\u627e\u5230\u5206\u5272\u7b26\u4e4b\u540e\u7684\u5b57\u7b26\u4e32
\n#define SHORT_FILE (strrchr(__FILE__, '\/') ? strrchr(__FILE__, '\/') + 1 : __FILE__)
\n#define LOG(level,fromat,…) do{\\\\
\n if(level<LOG_LEVEL)break;\\\\
\n time_t t = time(nullptr);\\\\
\n struct tm * ltm = localtime(&t);\\\\
\n char time_buf[32]={0};\\\\
\n strftime(time_buf,31,"%H:%M:%S",ltm);\\\\
\n fprintf(stdout , "[thread id:%p time:%s %s:%d]" fromat "\\\\n" ,(void*)pthread_self(),time_buf , SHORT_FILE , __LINE__ , ##__VA_ARGS__);\\\\
\n}while(0)<\/p>\n #define INF_LOG(fromat , …) LOG(INF , fromat , ##__VA_ARGS__)
\n#define DBG_LOG(fromat , …) LOG(DBG , fromat , ##__VA_ARGS__)
\n#define ERR_LOG(fromat , …) LOG(ERR , fromat , ##__VA_ARGS__) <\/p>\n \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u5176\u4e2d\u65e5\u5fd7\u5b8f\u7684\u6d89\u53ca\u5230\u4e86\u53ef\u53d8\u957f\u53c2\u6570，\u4ee5\u53caGNU\u6269\u5c55\u53d8\u957f\u53c2\u6570\u7684\u4f7f\u7528##__VA_ARGS__，\u5f53\u53d8\u957f\u5e38\u6570\u4e3a\u7a7a\u65f6，\u81ea\u52a8\u5220\u9664\u53c2\u6570\u4e2d\u524d\u9762\u7684\u9017\u53f7\u3002\u5176\u6b21\u662f\u6211\u4f7f\u7528\u4e86\u4e00\u4e2a\u5b8f\u51fd\u6570SHORT_FILE\u53bb\u622a\u53d6\u8def\u5f84\u4e2d\u6240\u5bf9\u5e94\u8fd9\u4e2a\u6587\u4ef6\u7684\u6587\u4ef6\u540d，\u5176\u4e2dstrrchr\u2014\u2014\u4ece\u8def\u5f84\u672b\u5c3e\u5f00\u59cb\u627e\u8def\u5f84\u5206\u9694\u7b26，\u4e09\u76ee\u8868\u8fbe\u5f0f\u7684\u76ee\u7684\u662f，\u5982\u679c__FILE__\u5c31\u662f\u6587\u4ef6\u540d\u90a3\u4e48\u5c31\u76f4\u63a5\u8fd4\u56de\u8fd9\u4e2a\u8def\u5f84，\u5982\u679c\u8def\u5f84\u540d\u4e2d\u6709\/\u90a3\u4e48\u5c31\u627e\u5230\u6700\u540e\u4e00\u4e2a\/\u5206\u9694\u7b26\u7684\u4f4d\u7f6e+1\u5c31\u662f\u6587\u4ef6\u540d\u3002\u5177\u4f53\u53ef\u4ee5\u770b\u4ee3\u7801，\u601d\u60f3\u662f\u6bd4\u8f83\u7b80\u5355\u7684\u3002<\/p>\n 4.1.2 Any\u7c7b\u2014\u2014\u7c7b\u578b\u64e6\u9664<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u76ee\u7684\u662f\u4e3a\u4e86\u8ba9\u6211\u7684muduo\u670d\u52a1\u5668\u53ef\u4ee5\u652f\u6301\u9002\u914d\u4e0d\u540c\u7684\u534f\u8bae(HTTP\/HTTPS\/FTP)\u7684\u670d\u52a1\u5668，\u8bbe\u8ba1\u4e86\u8fd9\u4e2a\u7c7b\u3002\u4e3b\u8981\u7528\u5230\u4e86\u591a\u6001，\u6a21\u7248\u7c7b\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n \/\/\u7c7b\u578b\u64e6\u9664\u5bb9\u5668\u2014\u2014\u5b58\u50a8\u4efb\u610f\u7c7b\u578b\u7684\u4e0a\u4e0b\u6587
\n\/\/\u7528\u540c\u4e00\u4e2a Any \u5bf9\u8c61\u5c31\u80fd\u5b58\u50a8\u4efb\u610f\u7c7b\u578b\u7684\u6570\u636e，\u800c\u4e0d\u662f\u4e3a int\u3001string\u3001\u81ea\u5b9a\u4e49\u7c7b\u5206\u522b\u521b\u5efa Any<int>\u3001Any<string> \u8fd9\u7c7b\u7ed1\u5b9a\u4e86\u5177\u4f53\u7c7b\u578b\u7684\u5bf9\u8c61\u2014\u2014\u7528\u5728\u5047\u8bbe\u6211\u8981\u7528\u5176\u4ed6\u5e94\u7528\u5c42\u534f\u8bae\u8fd9\u4e2a\u9879\u76ee\u540e\u9762\u5199\u4e86\u4e00\u4e2ahttp\u670d\u52a1\u5668\u6240\u6709\u53ef\u4ee5\u76f4\u63a5\u7528，\u6211\u6362\u4e2ahttps\u4e5f\u53ef\u4ee5\u7528\u2014\u2014\u8fd9\u5c31\u662fAny\u7c7b\u7684\u610f\u4e49\u6240\u5728
\nclass Any{
\n private:
\n class holder{
\n public:
\n virtual ~holder(){}
\n virtual const std::type_info& type()=0;
\n virtual holder* clone()=0;
\n };
\n template<class T>
\n class placeholder: public holder{
\n public:
\n placeholder(const T& val):_val(val){}
\n virtual const std::type_info& type(){return typeid(T);}
\n virtual holder* clone(){return new placeholder<T>(_val);}
\n T _val;
\n };
\n holder* _content;
\n public:
\n Any():_content(nullptr){}<\/p>\n template<class T>
\n Any(const T& val){
\n _content=new placeholder<T> (val);
\n }
\n Any(const Any& val){
\n _content=val._content?val._content->clone():nullptr;
\n }
\n ~Any(){delete _content;}<\/p>\n \/\/\u8fd9\u91ccother\u80fd\u533a\u8bbf\u95ee_content\u79c1\u6709\u6210\u5458\u53d8\u91cf\u662f\u56e0\u4e3a\u662f\u5728swap\u6210\u5458\u51fd\u6570\u4e2d\u3002\u53ea\u6709\u4e0d\u5728Any\u7c7b\u4e2d\u624d\u4e0d\u80fd\u53bb\u8bbf\u95ee\u79c1\u6709\u6210\u5458\u53d8\u91cf\u3002
\n Any& swap(Any&other){
\n \/\/swap\u51fd\u6570\u8981\u6c42\u4ea4\u6362\u4e24\u4e2a\u53ef\u4fee\u6539\u7684\u5de6\u503c
\n std::swap(other._content,_content);
\n return *this;
\n }
\n \/\/\u8fd4\u56de\u5b50\u7c7b\u5bf9\u8c61\u4fdd\u5b58\u7684\u6570\u636e\u7684\u6307\u9488
\n template<class T>
\n T* get(){
\n assert(_content != nullptr && "Any object is empty");
\n assert(_content->type() == typeid(T) && "Type mismatch");
\n \/\/\u8fd9\u91cc\u6362\u6210static_cast\u66f4\u597d，static_cast\u662f\u7f16\u8bd1\u65f6\u68c0\u67e5，\u8fd0\u884c\u96f6\u5f00\u9500，\u800c\u4e14\u6211\u5df2\u7ecf\u7528assert\u65ad\u8a00\u4e86\u4e0d\u4f1a\u51fa\u73b0\u7c7b\u578b\u4e0d\u5339\u914d
\n \/\/ return &((dynamic_cast<placeholder<T>*>(_content))->_val);
\n return &((static_cast<placeholder<T>*>(_content))->_val);
\n }<\/p>\n \/\/\u91cd\u8f7d\u8d4b\u503c\u51fd\u6570
\n template<class T>
\n Any& operator=(const T& val){
\n \/\/\u8fd9\u4e00\u6b65\u5f88\u5de7\u5999，\u7701\u53bb\u4e86\u81ea\u5df1\u5199new\u7684\u8fc7\u7a0b\u76f8\u5f53\u4e8e\u4e00\u79cd\u70ab\u6280\u4e86，\u6784\u9020Any\u4e34\u65f6\u5bf9\u8c61，\u7136\u540e\u8c03\u7528swap\u51fd\u6570\u5c06\u4e34\u65f6\u5bf9\u8c61\u4e2d\u7684\u6307\u9488\u548cthis\u4e2d\u7684\u6307\u9488\u4ea4\u6362，\u4ea4\u6362\u5b8c\u540e\u4e34\u65f6\u5bf9\u8c61\u81ea\u5df1\u9500\u6bc1\u2014\u2014\u6b64\u65f6\u5c31\u76f8\u5f53\u4e8e\u539f\u672c\u7684\u5185\u5b58\u88ab\u91ca\u653e\u4e86\u2014\u2014\u76f8\u5f53\u4e8e\u539f\u672c\u96be\u9053\u7a7a\u95f4\u88ab\u91ca\u653e\u4e86
\n Any(val).swap(*this);
\n return *this;
\n }<\/p>\n \/\/\u8fd4\u56de\u503c\u4e3a&\u662f\u56e0\u4e3a\u91cd\u590d\u8d4b\u503c\u65f6\u907f\u514d\u4e0d\u5fc5\u8981\u7684\u62f7\u8d1d
\n Any& operator=(const Any& other){
\n Any(other).swap(*this);
\n return *this;
\n }
\n}; <\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u76ee\u7684\u662f\u8ba9\u4e00\u4e2aAny\u5bf9\u8c61\u5c31\u53ef\u4ee5\u4fdd\u5b58\u4efb\u610f\u7c7b\u578b\u7684\u6570\u636e\u3002\u5728Any\u7c7b\u4e2d\u4fdd\u5b58\u4e00\u4e2a\u7236\u7c7b\u6307\u9488，\u5229\u7528\u7236\u7c7b\u6307\u9488\u53ef\u4ee5\u6307\u5411\u5b50\u7c7b\u6307\u9488\u7684\u591a\u6001\u7279\u6027，\u5b50\u7c7b\u8bbe\u7f6e\u6210\u4e00\u4e2a\u6a21\u7248\u7c7b，\u6765\u4fdd\u5b58\u6307\u5b9a\u7684\u6570\u636e\u7c7b\u3002\u8fd9\u6837\u5c31\u5b9e\u4e60\u4e86Any\u7c7b\u6307\u5411\u4efb\u610f\u7c7b\u578b\u7684\u6570\u636e\u64cd\u4f5c\u4e86，\u5728\u4fdd\u5b58\u6570\u636e\u65f6，Any\u4f1a\u6839\u636e\u6784\u9020\u51fd\u6570\u63a8\u5bfc\u5b58\u7684\u6570\u636e\u7c7b\u578b，\u5728\u8bfb\u53d6\u6570\u636e\u65f6\u4f1a\u4f7f\u7528get\u51fd\u6570\u4f20\u5165\u7c7b\u578b\u53c2\u6570\u5b89\u5168\u7684\u8bfb\u53d6\u8bfb\u53d6\u6570\u636e\u3002\u76f8\u6bd4\u4e8e\u76f4\u63a5\u4f7f\u7528void* \u8fd9\u6837\u66f4\u52a0\u7b26\u5408\u73b0\u4ee3C++\u7684\u8bbe\u8ba1\u601d\u8def：\u5b89\u5168，\u62bd\u8c61，\u6613\u7528\u3002<\/p>\n \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Any\u7c7b\u7684\u8bbe\u8ba1：\u7236\u7c7b\u7684\u8bbe\u8ba1：\u53ea\u9700\u8981\u8bbe\u8ba1\u865a\u865a\u6784\u51fd\u6570，\u865a\u7c7b\u578b\u8fd4\u56de\u51fd\u6570\u548c\u865a\u5b50\u7c7b\u514b\u9686\u51fd\u6570(\u4e3a\u4e86\u4f7f\u7528\u62f7\u8d1d\u6784\u9020\u51fd\u6570)\u3002\u5b50\u7c7b\u7684\u8bbe\u8ba1：\u53ea\u9700\u8981\u5b50\u7c7b\u53bb\u91cd\u5199\u865a\u51fd\u6570\u5c31\u884c\u4e86\u3002\u5728\u5916\u90e8\u7c7b\u4e5f\u5c31\u662fAny\u7c7b\u4e2d\u521d\u6b65\u7684\u6784\u9020\u51fd\u6570\u62f7\u8d1d\u6784\u9020\u51fd\u6570\u4ee5\u53ca\u865a\u6784\u51fd\u6570\u662f\u5fc5\u8981\u7684\u3002\u7136\u540e\u5c31\u662f\u83b7\u53d6Any\u7c7b\u4e2d\u7684\u6570\u636e\u7684\u51fd\u6570get，\u4ee5\u53ca\u5404\u79cd\u5bf9\u4e8eAny\u4e2d\u7684\u6570\u636e\u4ea4\u6362\u51fd\u6570，\u6bd4\u5982swap，operator=(\u8d4b\u503c\u8fd0\u7b97\u7b26\u91cd\u8f7d)，\u5176\u4e2d\u4f7f\u7528\u7684\u662f\u6df1\u62f7\u8d1d\u3002<\/p>\n 4.1.3 Buffer\u7c7b\u2014\u2014\u8bfb\u5199\u7f13\u51b2\u533a<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u4e3a\u4e86\u65b9\u4fbf\u6211\u4eec\u5904\u7406\u6570\u636e，\u4e0d\u4f7f\u7528\u539f\u751f\u7684I\/O\u7f13\u51b2\u533a，\u539f\u751fI\/O\u7f13\u51b2\u533a\u9996\u5148\u6211\u4eec\u4e0d\u80fd\u76f4\u63a5\u64cd\u4f5c，\u5176\u6b21\u539f\u751f\u7f13\u51b2\u533a\u5927\u5c0f\u6709\u9650，\u800c\u4e14\u53ef\u4ee5\u907f\u514dTCP\u7684\u7c98\u5305\/\u62c6\u5305\u95ee\u9898\u3002\u6240\u4ee5\u4e3a\u4e86\u89e3\u51b3\u8fd9\u4e9b\u96be\u70b9\u6211\u4eec\u4f7f\u7528Buffer\u6765\u505a\u4e00\u5c42\u5e94\u7528\u5c42\u7684\u7f13\u51b2\u533a，\u628aI\/O\u7f13\u51b2\u533a\u62ff\u4e0a\u6765\u505a\u5c01\u88c5\u3002\u4ee3\u7801\u5982\u4e0b:<\/p>\n \/\/\u670d\u52a1\u5668\u4e1a\u52a1\u7f13\u51b2\u533a\u2014\u2014\u5c06IO\u7f13\u51b2\u533a\u62ff\u5230\u4e1a\u52a1\u7f13\u51b2\u533a\u505a\u5904\u7406
\n#define BUFFER_DEFAULT_SIZE 1024
\nclass Buffer{
\n private:
\n std::vector<char> _buffer;
\n uint64_t _reader_idx;
\n uint64_t _writer_idx;
\n public:
\n Buffer():_buffer(BUFFER_DEFAULT_SIZE),_reader_idx(0),_writer_idx(0){}
\n char *Begin(){return &*_buffer.begin();}
\n \/\/\u83b7\u53d6\u5f53\u524d\u5199\u5165\/\u8bfb\u51fa\u7684\u8d77\u59cb\u5730\u5740,_buffer\u7684\u7a7a\u95f4\u7684\u8d77\u59cb\u5730\u5740，\u52a0\u4e0a\u504f\u79fb\u91cf
\n char* WritePosition(){return Begin()+_writer_idx;}
\n char* ReadPosition(){return Begin()+_reader_idx;}
\n \/\/\u83b7\u53d6\u7f13\u51b2\u533a\u5199\u4f4d\u7f6e\u4e4b\u540e\/\u8bfb\u4f4d\u7f6e\u4e4b\u524d\u7684\u7a7a\u95f2\u7a7a\u95f4\u5927\u5c0f
\n \/\/ \u5982\u679c\u53d1\u751f\u4e86\u6269\u5bb9 ，\u8fd9\u91cc\u7684\u5bb9\u91cf\u8ba1\u7b97\u5c31\u662f\u9519\u8bef\u7684
\n \/\/ uint64_t TailIdleSize(){return BUFFER_DEFAULT_SIZE-_writer_idx;}
\n uint64_t TailIdleSize(){return _buffer.size() – _writer_idx;}
\n uint64_t HeadIdleSize(){return _reader_idx;}
\n \/\/\u83b7\u53d6\u7f13\u51b2\u533a\u53ef\u8bfb\u6570\u636e\u5927\u5c0f
\n uint64_t ReadAbleSize(){
\n \/\/ \/\/\u8fd9\u4e00\u6b65\u662f\u8003\u8651\u73af\u5f62\u7ed3\u6784\u662f\u5fc5\u987b\u7684，\u4f46\u662f\u6211\u8fd9\u91cc\u4e0d\u662f\u73af\u5f62\u7ed3\u6784，\u8fd9\u6bb5\u4ee3\u7801\u53ef\u6709\u53ef\u65e0\u3002
\n \/\/ assert(_reader_idx<=_writer_idx);
\n return _writer_idx-_reader_idx;
\n }<\/p>\n \/\/\u5c06\u8bfb\/\u5199\u504f\u79fb\u91cf\u540e\u79fb
\n void MoveReadOffset(uint64_t len){
\n if(len == 0)return;
\n assert(len<=ReadAbleSize());
\n _reader_idx+=len;
\n }
\n void MoveWriteOffset(uint64_t len){
\n assert(len<=TailIdleSize());
\n _writer_idx+=len;
\n }
\n \/\/\u786e\u4fdd\u53ef\u5199\u7a7a\u95f4\u8db3\u591f，\u9996\u5148\u8981\u58f0\u660e\u7684\u662f\u8fd9\u91cc\u7684\u6570\u636e\u7f13\u51b2\u533a\u4e0d\u662f\u73af\u5f62\u7ed3\u6784\u3002
\n void EnsureWriteSpace(uint64_t len){
\n if(TailIdleSize() >= len){return;\/*\u6b64\u65f6\u53ef\u5199\u7a7a\u95f4\u8db3\u591f*\/}<\/p>\n if(len<=TailIdleSize()+HeadIdleSize()){
\n \/\/\u5c06\u6570\u636e\u524d\u79fb，\u7528\u5230copy\u51fd\u6570
\n uint64_t temp=ReadAbleSize();
\n auto dest=ReadPosition();
\n std::copy(dest,dest+temp,Begin());<\/p>\n _reader_idx=0;\/\/\u5c06\u8bfb\u504f\u79fb\u7f6e\u4e3a0，\u4ece\u5934\u5f00\u59cb
\n _writer_idx=temp;\/\/\u5c06\u5199\u504f\u79fb\u91cf\u7f6e\u4e3a\u6570\u636e\u957f\u5ea6
\n }
\n else{
\n \/\/\u6269\u5bb9
\n _buffer.resize(_writer_idx+len);
\n }
\n }
\n \/\/\u5199\u5165\u6570\u636e\u2014\u2014\u8d77\u59cb\u5c31\u662f\u62f7\u8d1d
\n void Write(const void* data,uint64_t len){
\n \/\/1.\u5224\u65ad\u7a7a\u95f4\u30022.\u62f7\u8d1d\u6570\u636e
\n if(len == 0)return;
\n EnsureWriteSpace(len);
\n \/\/void* \u662f\u6ca1\u6709\u6b65\u957f\u7684
\n const char*d=(const char*)data;
\n std::copy(d,d+len,WritePosition());
\n \/\/\u540c\u6837\u8fd9\u91cc\u4e5f\u5206\u5f00\u5199，\u5b9e\u73b0\u4e24\u4e2aAPI-\u5199\u5165\u4e0d\u79fb\u52a8，\u5199\u5165\u79fb\u52a8
\n \/\/ MoveWriteOffset(len);
\n }
\n void WriteAndPush(const void* data,uint64_t len){
\n Write(data,len);
\n MoveWriteOffset(len);
\n }<\/p>\n void WriteString(std::string &data){Write(data.c_str(),data.size());}
\n void WriteStringAndPush(std::string &data){
\n WriteString(data);
\n MoveWriteOffset(data.size());
\n }<\/p>\n void WriteBuffer(Buffer& data){Write(data.ReadPosition(),data.ReadAbleSize());}
\n void WriteBufferAndPush(Buffer& data){
\n WriteBuffer(data);
\n MoveWriteOffset(data.ReadAbleSize());
\n }<\/p>\n \/\/\u8bfb\u6570\u636e-\u4e0d\u79fb\u52a8\u6307\u9488
\n void Read(void *buf,uint64_t len){
\n \/\/\u786e\u4fdd\u53ef\u8bfb
\n assert(len<=ReadAbleSize());
\n std::copy(ReadPosition(),ReadPosition()+len,(char*)buf);<\/p>\n \/\/\u4e24\u4e2a\u51fd\u6570\u5206\u5f00\u5199
\n \/\/ MoveReadOffset(len);
\n }
\n \/\/\u8bfb\u6570\u636e-\u79fb\u52a8\u6307\u9488
\n void ReadAndPop(void *buf,uint64_t len){
\n Read(buf,len);
\n MoveReadOffset(len);
\n }
\n std::string ReadAsStirng(uint64_t len){
\n assert(len<=ReadAbleSize());
\n \/\/string::c_str()\u2014\u2014\u8fd9\u8fd4\u56de\u7684\u662f\u4e00\u4e2aconst char*\u7684\u7c7b\u578b
\n std::string s;
\n s.resize(len);
\n Read(&s[0],s.size());
\n return s;
\n }
\n std::string ReadAsStirngAndPop(uint64_t len){
\n assert(len<=ReadAbleSize());
\n std::string s = ReadAsStirng(len);
\n MoveReadOffset(len);
\n return s;
\n }
\n \/\/\u5728tcp\u4e2d\u8fd8\u6709\u4e00\u4e2a\u529f\u80fd\u5c31\u662f\u4e00\u6b21\u8bfb\u53d6\u4e00\u884c\u6570\u636e\u2014\u2014\u8bf4\u767d\u4e86\u8fd9\u5c31\u662f\u5bf9tcp\u7f13\u51b2\u533a\u7684\u4e00\u6b21\u91cd\u65b0\u5c01\u88c5，\u6ee1\u8db3\u6211\u4eec\u7684\u9700\u6c42
\n char* FindCRLF(){
\n char * res = static_cast<char*>(memchr(ReadPosition(),'\\\\n',ReadAbleSize()));
\n return res;
\n }<\/p>\n std::string GetLine(){
\n char* pos = FindCRLF();
\n if(pos == nullptr){
\n return "";
\n }
\n return ReadAsStirng(pos-ReadPosition()+1);
\n }
\n std::string GetLineAndPop(){
\n std::string str = GetLine();
\n MoveReadOffset(str.size());
\n return str;
\n }
\n \/\/\u6e05\u7a7a\u7f13\u51b2\u533a
\n void Clear(){
\n _reader_idx=0;
\n _writer_idx=0;
\n }
\n};<\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u5728\u7f13\u51b2\u533a\u5927\u5c0f\u8fd9\u91cc\u6211\u9ed8\u8ba4\u8bbe\u7f6e\u6210\u4e861024，\u8fd9\u91cc\u6ce8\u610f\u6570\u5b57\u4e00\u5b9a\u8981\u5f04\u6210\u5b8f\u5b9a\u4e49，\u4e0d\u7136\u5c31\u4f1a\u51fa\u73b0\u4e00\u5806\u7684\u9b54\u5e7b\u6570\u5b57，\u589e\u5927\u4e86\u540e\u671f\u7ef4\u62a4\u4fee\u6539\u7684\u96be\u5ea6\u3002\u5728\u7f13\u51b2\u533a\u5bb9\u5668\u4e2d\u4f7f\u7528vector\u56e0\u4e3a\u5176\u7ebf\u6027\u7684\u6570\u636e\u8bbf\u95ee\u7279\u6027\u53ef\u4ee5\u52a0\u5927\u8bfb\u53d6\u6548\u7387，\u4e5f\u65b9\u4fbf\u6211\u4eec\u6269\u5bb9，\u4f7f\u7528\u4e24\u4e2a\u6307\u9488(\u6574\u5f62\u4e0b\u6807)\u53bb\u4fdd\u5b58\u5199\u6570\u636e\u4e0b\u6807\u548c\u8bfb\u6570\u636e\u4e0b\u6807\u3002\u8fd9\u6837\u5c31\u591f\u4e86\u3002\u63a5\u7740\u5c31\u662f\u5bf9\u5916\u5f00\u653e\u7684\u5904\u7406\u7f13\u51b2\u533a\u7684\u51fd\u6570，\u6bd4\u5982：\u83b7\u53d6\u5269\u4f59\u7f13\u51b2\u533a\u7a7a\u95f4\u3001\u83b7\u53d6\u8bfb\u4f4d\u7f6e\u3001\u83b7\u53d6\u5199\u4f4d\u7f6e\u3001\u5199\u6570\u636e\u3001\u8bfb\u6570\u636e\u3001\u6269\u5bb9\u51fd\u6570\u3001\u6e05\u7a7a\u7f13\u51b2\u533a\u3001\u4ee5\u53ca\u4e3a\u4e86http\u670d\u52a1\u5668\u5904\u7406\u53c2\u6570\u989d\u5916\u8bbe\u7f6e\u4e86\u8bfb\u53d6\u4e00\u884c\u6570\u636e\u7684\u63a5\u53e3\u7b49\u3002<\/p>\n 4.2 \u7f51\u7edc\u57fa\u7840\u6a21\u5757<\/h3>\n4.2.1 Socket\u7c7b\u2014\u2014\u539f\u751fAPI\u5c01\u88c5<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u8fd9\u4e2a\u7c7b\u5c31\u662f\u5bf9Socket\u7684\u539f\u751f\u5c01\u88c5，\u5728Socket\u7684\u57fa\u7840\u4e0a\u628a\u53d1\u9001\u548c\u63a5\u6536\u6570\u636e\u4ee5\u53ca\u521b\u5efa\u5ba2\u6237\u7aef\u8fde\u63a5\u548c\u670d\u52a1\u5668\u8fde\u63a5\u76f4\u63a5\u96c6\u6210\u5728\u4e86\u8fd9\u4e2a\u7c7b\u4e2d\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n class Socket{
\n private:
\n \/\/\u521b\u5efa\u76d1\u542c\u5957\u63a5\u5b57
\n int _sockfd;
\n public:
\n Socket():_sockfd(-1){}
\n Socket(int fd):_sockfd(fd){}
\n ~Socket(){Close();}
\n int Fd() { return _sockfd; }
\n \/\/\u521b\u5efa\u5957\u63a5\u5b57
\n bool Create(){
\n \/\/int socket(int domain,int type,int protocol);
\n _sockfd=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
\n if(_sockfd<0){
\n ERR_LOG("Create \u76d1\u542c\u5957\u63a5\u5b57\u5931\u8d25！！！");
\n return false;
\n }
\n return true;
\n }
\n \/\/\u7ed1\u5b9a\u5730\u5740\u4fe1\u606f
\n bool Bind(const std::string& ip ,uint16_t port){
\n \/\/\u521b\u5efatcp
\n struct sockaddr_in addr;
\n addr.sin_family=AF_INET;
\n addr.sin_port=htons(port);
\n addr.sin_addr.s_addr=inet_addr(ip.c_str());
\n socklen_t len=sizeof(struct sockaddr_in);
\n \/\/ int ret = bind(_sockfd,reinterpret_cast<struct sockaddr*>(&addr),len);
\n int ret = bind(_sockfd, (struct sockaddr*)&addr, len);
\n if(ret<0){
\n ERR_LOG("Bind \u5931\u8d25！！！！");
\n return false;
\n }
\n return true;
\n }
\n \/\/\u5f00\u59cb\u76d1\u542c
\n bool Listen(int backlog = MAX_LISTEN){
\n \/\/int listen(int backlog)
\n int ret = listen(_sockfd,backlog);
\n if(ret<0){
\n ERR_LOG("Listen \u5931\u8d25！！！！");
\n return false;
\n }
\n return true;
\n }
\n \/\/\u5411\u670d\u52a1\u5668\u53d1\u8d77\u8fde\u63a5
\n bool Connect(const std::string&ip ,uint16_t port){
\n struct sockaddr_in addr;
\n addr.sin_family=AF_INET;
\n addr.sin_port=htons(port);
\n addr.sin_addr.s_addr=inet_addr(ip.c_str());
\n socklen_t len=sizeof(struct sockaddr_in);
\n \/\/ int ret = connect(_sockfd,reinterpret_cast<struct sockaddr*>(&addr),len);
\n int ret = connect(_sockfd,(struct sockaddr*)&addr,len);<\/p>\n if(ret<0){
\n ERR_LOG("Connect \u5931\u8d25！！！！");
\n return false;
\n }
\n return true;
\n }
\n int Accept(){
\n \/\/int accept(int sockfd,struct sockaddr* addr, socklen_t* len);
\n int newfd = accept(_sockfd,nullptr,nullptr);
\n if(newfd<0){
\n ERR_LOG("Accept \u5931\u8d25！！！%s",strerror(errno));
\n return -1;
\n }
\n return newfd;
\n }
\n ssize_t Recv(void*buf,size_t len,int flag=0){
\n ssize_t ret = recv(_sockfd,buf,len,flag);
\n if(ret<=0){
\n if(errno == EAGAIN || errno == EINTR){
\n ERR_LOG("\u4fe1\u53f7\u4e2d\u65ad\/\u6ca1\u6570\u636e");
\n return 0;
\n \/\/EAGAIN\u2014\u2014\u975e\u963b\u585e\u6ca1\u6570\u636e\u4e86
\n \/\/EINTR\u2014\u2014\u963b\u585e，\u88ab\u4fe1\u53f7\u4e2d\u65ad\u4e86
\n }
\n return -1;
\n }
\n return ret;
\n }
\n ssize_t NonBlockRecv(void*buf,size_t len){return Recv(buf,len,MSG_DONTWAIT);}<\/p>\n ssize_t Send(const void*buf,size_t len,int flag=0){
\n ssize_t ret = send(_sockfd,buf,len,flag);
\n if(ret<0){
\n if(errno == EAGAIN || errno == EINTR){
\n ERR_LOG("\u4fe1\u53f7\u4e2d\u65ad\/\u6ca1\u6570\u636e");
\n return 0;
\n \/\/EAGAIN\u2014\u2014\u975e\u963b\u585e\u6ca1\u6570\u636e\u4e86
\n \/\/EINTR\u2014\u2014\u963b\u585e，\u88ab\u4fe1\u53f7\u4e2d\u65ad\u4e86
\n }
\n ERR_LOG("Send \u5931\u8d25！！！！");
\n return -1;
\n }
\n return ret;
\n }
\n \/\/MSG_DONTWAIT
\n ssize_t NonBlockSend(const void*buf,size_t len){ if (len == 0) return 0;return Send(buf,len,MSG_DONTWAIT);}
\n \/\/\u5173\u95ed\u5957\u63a5\u5b57
\n void Close(){
\n if(_sockfd!=-1){
\n close(_sockfd);
\n _sockfd=-1;
\n }
\n }
\n \/\/\u521b\u5efa\u4e00\u4e2a\u670d\u52a1\u5668\u8fde\u63a5
\n bool CreateServer(uint16_t port,const std::string&ip="0.0.0.0",bool blog_flag=false){
\n \/\/1.\u521b\u5efa\u76d1\u542c\u5957\u63a5\u5b57 2.\u8bbe\u7f6e\u975e\u963b\u585e 3.\u7ed1\u5b9a\u5957\u63a5\u5b57 4.\u5f00\u59cb\u76d1\u542c 5.\u542f\u52a8\u5730\u5740\u91cd\u7528
\n if(!Create())return false;
\n if(blog_flag)NonBlock();
\n if(!Bind(ip,port))return false;
\n if(!Listen())return false;
\n ReuseAddress();
\n return true;
\n }
\n \/\/\u521b\u5efa\u4e00\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5
\n bool CreateClient(uint16_t port,const std::string&ip){
\n \/\/1.\u521b\u5efa\u8fde\u63a5\u5957\u63a5\u5b57 2.\u8fde\u63a5\u670d\u52a1\u5668
\n if(!Create())return false;
\n if(!Connect(ip,port))return false;
\n return true;
\n }
\n \/\/\u8bbe\u7f6e\u5957\u63a5\u5b57\u9009\u9879—\u5f00\u542f\u5730\u5740\u7aef\u53e3\u7684\u91cd\u7528
\n void ReuseAddress(){
\n \/\/int setsockopt(int fd,int leve , int optname , void * val,int vallen)
\n int val = 1;
\n setsockopt(_sockfd,SOL_SOCKET , SO_REUSEADDR , (void*)&val ,sizeof(int));
\n val = 1;
\n setsockopt(_sockfd,SOL_SOCKET , SO_REUSEPORT , (void*)&val ,sizeof(int));
\n }
\n \/\/\u8bbe\u7f6e\u5957\u63a5\u5b57\u963b\u585e\u5c5e\u6027—\u8bbe\u7f6e\u4e3a\u975e\u963b\u585e
\n void NonBlock(){
\n \/\/int fcntl(int fd , int cmd ,…..\/*arg*\/);
\n int flag = fcntl(_sockfd,F_GETFL,0);
\n fcntl(_sockfd,F_SETFL,flag | O_NONBLOCK);
\n }
\n}; <\/p>\n 4.2.2 Channel\u7c7b\u2014\u2014\u4e8b\u4ef6\u5c01\u88c5<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 Channel\u7c7b\u5b9e\u9645\u4e0a\u5c31\u662f\u5bf9epoll\u64cd\u4f5c\u7684\u5c01\u88c5\u7c7b，\u529f\u80fd\u6709：\u542f\u52a8\u8bfb\/\u5199\u4e8b\u4ef6\u76d1\u63a7\u3001\u5173\u95ed\u8bfb\/\u5199\u4e8b\u4ef6\u76d1\u63a7\u3001\u662f\u5426\u76d1\u63a7\u4e86\u8bfb\/\u5199\u4e8b\u4ef6\u3001\u4ee5\u53ca\u5bf9\u5c31\u7eea\u4e8b\u4ef6\u7684\u5904\u7406\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n \/\/epoll\u6a21\u5f0fLT\u6a21\u5f0f-\u6c34\u5e73\u89e6\u53d1
\n\/\/\u8bbe\u7f6e\u7ba1\u7406\u4e8b\u4ef6\u76d1\u63a7，\u5199\u4e8b\u4ef6\u8fd8\u662f\u8bfb\u4e8b\u4ef6，\u4e00\u4e2a\u8fde\u63a5\u5bf9\u5e94\u4e00\u4e2aChannel\u7c7b
\n#include <sys\/epoll.h> \/\/ \u5305\u542bEPOLLIN\u7b49epoll\u4e8b\u4ef6\u6807\u5fd7\u7684\u5b9a\u4e49
\nclass Channel{
\n private:
\n int _fd;
\n EventLoop* _loop;
\n uint32_t _events; \/\/ \u5f53\u524d\u9700\u8981\u76d1\u63a7\u7684\u4e8b\u4ef6
\n uint32_t _revents;\/\/ \u5f53\u524d\u76d1\u63a7\u4e8b\u4ef6\u7684\u5c31\u7eea\u4e8b\u4ef6
\n using EventCallback = std::function<void()>;
\n EventCallback _read_callback; \/\/\u53ef\u8bfb\u4e8b\u4ef6\u88ab\u5904\u7f5a\u7684\u56de\u8c03\u51fd\u6570
\n EventCallback _write_callback;\/\/\u53ef\u5199\u4e8b\u4ef6\u88ab\u5904\u7f5a\u7684\u56de\u8c03\u51fd\u6570
\n EventCallback _error_callback;\/\/\u9519\u8bef\u4e8b\u4ef6\u88ab\u5904\u7f5a\u7684\u56de\u8c03\u51fd\u6570
\n EventCallback _close_callback;\/\/\u8fde\u63a5\u65ad\u5f00\u4e8b\u4ef6\u88ab\u5904\u7f5a\u7684\u56de\u8c03\u51fd\u6570
\n EventCallback _event_callback;\/\/\u4efb\u610f\u4e8b\u4ef6\u88ab\u5904\u7f5a\u7684\u56de\u8c03\u51fd\u6570
\n public:
\n Channel(EventLoop* loop,int fd):_fd(fd),_loop(loop),_events( 0),_revents(0) {}
\n int Fd(){return _fd;}
\n uint32_t Events(){return _events;}\/\/\u83b7\u53d6\u76d1\u63a7\u4e8b\u4ef6
\n void SetRevents(uint32_t events){_revents=events;}\/\/\u8bbe\u7f6e\u5b9e\u9645\u5c31\u7eea\u7684\u4e8b\u4ef6
\n void SetReadCallback(const EventCallback& cb){_read_callback=cb;}
\n void SetWriteCallback(const EventCallback& cb){_write_callback=cb;}
\n void SetErrorCallback(const EventCallback& cb){_error_callback=cb;}
\n void SetCloseCallback(const EventCallback& cb){_close_callback=cb;}
\n void SetEventCallback(const EventCallback& cb){_event_callback=cb;}
\n \/\/\u5f53\u524d\u662f\u5426\u76d1\u63a7\u4e86\u53ef\u8bfb
\n bool ReadAble(){return _events & EPOLLIN;\/*\u5c31\u662f\u770b\u6211\u5f53\u524d\u76d1\u63a7\u7684\u4e8b\u4ef6\u4e2d\u662f\u5426\u76d1\u63a7\u4e86\u53ef\u8bfb\u4e8b\u4ef6\u5c31\u662f\u53bb\u6309\u4f4d\u4e0e\u4e00\u4e0b*\/}
\n \/\/\u5f53\u524d\u662f\u5426\u76d1\u63a7\u4e86\u53ef\u5199,\u8fd9\u91cc\u5904\u7406\u5728LT\u6a21\u5f0f\u4e0b\u9632\u6b62\u591a\u6b21\u7684\u8bbe\u7f6e\u53ef\u8bfb\u53ef\u5199\u5bfc\u81f4\u7684LoopBusy
\n bool WriteAble(){return _events & EPOLLOUT;}
\n \/\/\u542f\u52a8\u8bfb\u4e8b\u4ef6\u76d1\u63a7 \u8fd9\u53ea\u662f\u8bbe\u7f6e\u4e86_event\u8fd8\u5e76\u6ca1\u6709\u8bbe\u7f6e\u5230epoll\u4e2d\u53bb
\n void EnableRead(){_events |= EPOLLIN; Update();}
\n \/\/\u542f\u52a8\u5199\u4e8b\u4ef6\u76d1\u63a7
\n void EnableWrite(){_events |= EPOLLOUT; Update();}
\n \/\/\u5173\u95ed\u8bfb\u4e8b\u4ef6\u76d1\u63a7
\n void DisableRead(){_events &= ~EPOLLIN; Update();}
\n \/\/\u5173\u95ed\u5199\u4e8b\u4ef6\u76d1\u63a7
\n void DisableWrite(){_events &= ~EPOLLOUT; Update();}
\n \/\/\u5173\u95ed\u6240\u6709\u4e8b\u4ef6\u76d1\u63a7
\n void DisableAll(){_events=0;}
\n \/\/\u79fb\u9664\u76d1\u63a7\u2014\u2014\u540e\u9762\u8c03\u7528EventLoop\u8c03\u7528
\n void Remove();
\n void Update();
\n \/\/\u4e8b\u4ef6\u5904\u7406，\u4e00\u65e6\u8fde\u63a5\u89e6\u53d1\u4e86\u4e8b\u4ef6，\u5c31\u8c03\u7528\u8fd9\u4e2a\u51fd\u6570，\u7136\u540e\u770b_revnet\u89e6\u53d1\u4e86\u54ea\u4e00\u4e2a\u4e8b\u4ef6，\u7136\u540e\u5185\u90e8\u8c03\u7528\u4e0d\u540c\u7684\u56de\u8c03
\n \/\/\u81ea\u5df1\u89e6\u53d1\u4e86\u4ec0\u4e48\u4e8b\u4ef6\u81ea\u5df1\u5904\u7406，EventLoop\u4e0d\u5173\u5fc3，\u6211\u53ea\u7ba1\u8c03\u7528HanleEvent\u2014\u2014\u672c\u8d28\u5c31\u662f\u8fdb\u884c\u4e86\u4e00\u5c42\u5c01\u88c5\u561b，\u770b\u662f\u5c01\u88c5\u5230\u54ea\u4e00\u5c42\u4e86\u3002
\n void HandleEvent(){
\n \/\/\u89e6\u53d1\u8fde\u63a5\u65ad\u5f00\u4e5f\u5c31\u662f\u534a\u5173\u95ed\u8fde\u63a5EPOLLRDHUP(\u5bf9\u65b9\u5173\u95ed\u8fde\u63a5)，\u90a3\u4e48\u6211\u4eec\u5c31\u8981\u628a\u7f13\u51b2\u533a\u7684\u6570\u636e\u8bfb\u5b8c
\n if((_revents & EPOLLIN) || (_revents & EPOLLRDHUP) || (_revents & EPOLLPRI)){
\n \/\/ if(_read_callback)_read_callback();
\n \/\/ if(_event_callback)_event_callback();
\n if(_read_callback)_read_callback();
\n }
\n \/\/\u6709\u53ef\u80fd\u4f1a\u91ca\u653e\u8fde\u63a5\u7684\u4e8b\u4ef6，\u4e00\u6b21\u5904\u7406\u4e00\u4e2a
\n if(_revents & EPOLLOUT)
\n {
\n \/\/\u653e\u5230\u4e8b\u4ef6\u5904\u7406\u5b8c\u6bd5\u540e\u8c03\u7528，\u5237\u65b0\u6d3b\u8dc3\u5ea6
\n \/\/ if(_write_callback)_write_callback();
\n \/\/ if(_event_callback)_event_callback();
\n if(_write_callback)_write_callback();
\n }
\n else if(_revents & EPOLLERR)
\n {
\n \/\/\u653e\u5230\u524d\u9762，\u56e0\u4e3a\u51fa\u9519\u76f4\u63a5\u5173\u95ed\u4e86
\n if(_error_callback)_error_callback();
\n }
\n else if(_revents & EPOLLHUP)
\n {
\n if(_close_callback)_close_callback();
\n }
\n if(_event_callback)_event_callback();
\n }
\n}; <\/p>\n 4.3 \u4e8b\u4ef6\u9a71\u52a8\u6a21\u5757<\/h3>\n4.3.1 Poller\u7c7b\u2014\u2014\u5bf9epoll\u7684\u5c01\u88c5<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 Poller\u7c7b\u65f6\u771f\u6b63\u5730\u5bf9epoll\u7684\u5c01\u88c5\u5185\u90e8\u6709epoll\u7684\u521b\u5efa，\u548c\u5bf9\u76d1\u63a7\u4e8b\u4ef6\u7684\u771f\u6b63\u4fee\u6539\u3002\u5728\u6210\u5458\u53d8\u91cf\u4e2d，\u6709\u4e00\u4e2a_epfd（epoll\u7684fd\u64cd\u4f5c\u7b26）\u4ee5\u53ca\u4e00\u4e2aepoll_event\u6570\u7ec4\u5bf9\u6240\u6709\u8fde\u63a5\u7684\u7ba1\u7406，\u8fd8\u6709\u4e00\u4e2a\u8fde\u63a5\u4e00\u4e2afd\u7684\u54c8\u5e0c\u5b58\u50a8\u8868，\u65b9\u4fbf\u67e5\u8be2\u548c\u5bf9\u5355\u4e2a\u8fde\u63a5\u64cd\u4f5c\u3002<\/p>\n #define MAX_EPOLLEVENTS 1024
\n#include <sys\/epoll.h>
\n#include<unordered_map><\/p>\n \/\/epoll\u7ba1\u7406\u7c7b\u2014\u2014\u5bf9\u6240\u6709\u94fe\u63a5\u5bf9\u5e94\u7684\u6240\u6709Channel\u7c7b\u7ba1\u7406\u2014\u2014\u8fdb\u884c\u66f4\u65b0\u4fee\u6539，\u5f00\u542f\u4e8b\u4ef6\u76d1\u63a7\u548c\u53d6\u6d88\u76d1\u63a7\u2014\u2014\u5bf9\u6240\u6709\u670d\u52a1\u5668\u4e0a\u7684\u8fde\u63a5\u505a\u7ba1\u7406
\nclass Poller{
\n private:
\n int _epfd;
\n struct epoll_event _evs[MAX_EPOLLEVENTS];
\n std::unordered_map<int,Channel*> _channels;
\n private:
\n \/\/\u5bf9epoll\u7684\u76f4\u63a5\u64cd\u4f5c
\n void Update(Channel *channel,int op){
\n \/\/int epoll+ctl(int epfd , int op , int fd , struct eopll_event* ev);
\n int fd = channel->Fd();
\n struct epoll_event ev;
\n ev.data.fd=fd;
\n \/\/\u8981\u64cd\u4f5c\u7684\u4e8b\u4ef6
\n ev.events=channel->Events();
\n int ret = epoll_ctl(_epfd,op,fd,&ev);
\n if(ret<0){
\n ERR_LOG("epoll_ctl \u5931\u8d25！！！");
\n }
\n return ;
\n }
\n \/\/\u5224\u65ad\u4e00\u4e2aChannel\/\u4e00\u4e2a\u8fde\u63a5\u662f\u5426\u5df2\u7ecf\u6dfb\u52a0\u4e86\u4e8b\u4ef6\u76d1\u63a7
\n bool HashCHannel(Channel* channel){
\n auto it = _channels.find(channel->Fd());
\n if(it==_channels.end())return false;
\n return true;
\n }<\/p>\n public:
\n Poller(){
\n _epfd = epoll_create(MAX_EPOLLEVENTS);
\n if(_epfd<0){
\n ERR_LOG("epoll_create \u5931\u8d25！！！");
\n abort();
\n }
\n }
\n \/\/\u6dfb\u52a0\u6216\u4fee\u6539\u76d1\u63a7\u4e8b\u4ef6
\n void UpdateEvent(Channel *channel){
\n auto it = _channels.find(channel->Fd());
\n if(it==_channels.end()){
\n _channels.insert({channel->Fd(),channel});
\n return Update(channel,EPOLL_CTL_ADD);
\n }
\n Update(channel,EPOLL_CTL_MOD);
\n }
\n \/\/\u79fb\u9664\u76d1\u63a7
\n void RemoveEvent(Channel *channel){
\n auto it = _channels.find(channel->Fd());
\n if(it!=_channels.end()) _channels.erase(it);
\n Update(channel,EPOLL_CTL_DEL);
\n }
\n \/\/\u5f00\u59cb\u76d1\u63a7，\u8fd4\u56de\u6d3b\u8dc3\u8fde\u63a5
\n void Poll(std::vector<Channel*>* active){
\n \/\/int epoll_wait(int epfd , struct epoll_event* evs , int maxevents , int timeout)
\n int nfds = epoll_wait(_epfd,_evs,MAX_EPOLLEVENTS,-1);\/\/-1\u4ee3\u8868\u963b\u585e\u7b49\u5f85，timeout>=0\u4ee3\u8868\u963b\u585e\u7b49\u5f85x\u79d2，\u8d85\u65f6\u8fd4\u56de
\n if(nfds<0){
\n if(errno == EINTR){
\n \/\/\u53ef\u80fd\u662f\u7531\u4e8e\u4e2d\u65ad\u6253\u65ad\u4e86epoll_wait\u51fd\u6570
\n return;\/\/\u6b64\u65f6\u7a0b\u5e8f\u4e0d\u9000\u51fa
\n }
\n ERR_LOG("epoll_wait \u5931\u8d25:%s\\\\n",strerror(errno));
\n abort();\/\/\u9000\u51fa\u7a0b\u5e8f\u2014\u2014\u5f02\u5e38\u9000\u51fa\u6709\u8c03\u8bd5\u4fe1\u606f，exit\u6b63\u5e38\u9000\u51fa\u6e05\u7406\u7a0b\u5e8f
\n }
\n for(int i=0;i<nfds;++i){
\n auto it = _channels.find(_evs[i].data.fd);
\n assert(it!=_channels.end());
\n it->second->SetRevents(_evs[i].events);
\n active->push_back(it->second);
\n }
\n }
\n}; <\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u5176\u4e2d\u6700\u5173\u952e\u7684\u662fPoll\u51fd\u6570，\u5f00\u59cb\u76d1\u63a7，\u8fd4\u56de\u6d3b\u8dc3\u8fde\u63a5\u3002epoll_wait\u8fd4\u56de\u5c31\u7eea\u94fe\u8868\u4e2d\u7684\u4e8b\u4ef6\u6570\u91cf，\u6240\u4ee5\u5728\u540e\u7eed\u7684for\u5faa\u73af\u4e2d\u628a\u5c31\u7eea\u4e8b\u4ef6\u4e00\u4e00\u8bbe\u7f6e\u5230\u6bcf\u4e2a\u8fde\u63a5\u7684Channel\u4e2d\u3002<\/p>\n 4.3.2 EventLoop\u7c7b\u2014\u2014Reactor\u6838\u5fc3<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u5728EventLoop\u7c7b\u4e2d\u6700\u4e3b\u8981\u7684\u5c31\u662fStart\u51fd\u6570\u2014\u2014\u5904\u7406\u5c31\u7eea\u76d1\u63a7\u4e8b\u4ef6，\u6267\u884c\u4efb\u52a1\u961f\u5217\u4e2d\u7684\u4efb\u52a1\u7684\u6b7b\u5faa\u73af，\u5982\u679c\u6ca1\u6709\u5c31\u7eea\u76d1\u63a7\u4e8b\u4ef6\u5c31\u4f1a\u5361\u5728Poll\u4e2d，\u4f46\u662f\u5728\u5176\u4ed6\u7ebf\u7a0b\u538b\u5165\u4efb\u52a1\u961f\u5217\u65f6\u3001\u76d1\u63a7\u4e8b\u4ef6\u5c31\u7eea\u65f6\u6216\u8005\u5728\u670d\u52a1\u5668\u7684listen_fd\u7ba1\u7406\u7c7b\u4e2d\u65b0\u8fde\u63a5\u5230\u6765\u65f6，\u5c31\u4e0d\u5728\u963b\u585e\u672c\u8d28\u5c31\u662f\u6709\u76d1\u63a7\u4e8b\u4ef6\u5c31\u7eea\u4e86epoll_wait\u51fd\u6570\u8fd4\u56de\u4e86\u5c31\u4e0d\u5728\u963b\u585e\u4e86\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n using Functor = std::function<void()>;<\/p>\n #include<thread>
\n#include<mutex>
\n#include<memory>
\n#include<sys\/eventfd.h>
\n\/\/\u4efb\u52a1\u6267\u884c\u7684Loop\u2014\u2014\u4e8b\u4ef6\u5faa\u73af\u6838\u5fc3\u662fReactor\u7684\u6838\u5fc3
\nclass EventLoop{
\n private:
\n std::thread::id _thread_id;\/\/\u7ebf\u7a0bID<\/p>\n int _event_fd;\/\/eventfd\u5524\u9192IO\u4e8b\u4ef6\u76d1\u63a7\u6709\u53ef\u80fd\u5bfc\u81f4\u7684\u963b\u585e,\u6765\u4e00\u4e2a\u4efb\u52a1\u8981\u538b\u5165\u961f\u5217\u90a3\u4e48\u5c31\u8981\u5524\u9192\u5728epoll_wait\u7684\u963b\u585e\u5c31\u8981\u7528\u5230\u8fd9\u4e2a\u95f9\u949ffd
\n std::unique_ptr<Channel> _event_channel;
\n \/\/\u5bf9\u6240\u6709\u7684\u8fde\u63a5\u7684\u4e8b\u4ef6\u505a\u7ba1\u7406，\u56e0\u4e3a\u7ebf\u7a0b\u6c60\u91c7\u7528RR\u8f6e\u8be2\u7684\u65b9\u5f0f，\u4e00\u4e2a\u7ebf\u7a0b\u4f1a\u7ba1\u7406\u591a\u4e2a\u8fde\u63a5
\n Poller _poller;\/\/\u8fdb\u884c\u6240\u6709\u63cf\u8ff0\u7b26\u7684\u4e8b\u4ef6\u76d1\u63a7<\/p>\n std::vector<Functor> _tasks;\/\/\u4efb\u52a1\u6c60
\n std::mutex _mutex;\/\/\u5b9e\u73b0\u4efb\u52a1\u6c60\u64cd\u4f5c\u7684\u7ebf\u7a0b\u5b89\u5168
\n TimerWheel _timer_wheel;\/\/\u5b9a\u65f6\u5668\u6a21\u5757
\n public:
\n void RunAllTask(){
\n std::vector<Functor> functor;
\n {
\n std::unique_lock<std::mutex> _lock(_mutex);
\n _tasks.swap(functor);
\n }
\n for(auto&f : functor)f();
\n return ;
\n }
\n static int CreateEventFd(){
\n int efd = eventfd(0,EFD_CLOEXEC | EFD_NONBLOCK);
\n if(efd<0){
\n ERR_LOG("eventfd failed!!!");
\n abort();\/\/\u8ba9\u7a0b\u5e8f\u5f02\u5e38\u9000\u51fa
\n }
\n return efd;
\n }
\n void ReadEventFd(){
\n uint64_t res = 0;
\n int ret =read(_event_fd,&res,sizeof(res));
\n if(ret <0){
\n \/\/EAGAIN\u662f\u8d44\u6e90\u5360\u65f6\u4e0d\u53ef\u7528(\u6bd4\u5982\u8bfb\u5b8c\u4e86\u6570\u636e\/\u6ca1\u6570\u636e\u53ef\u8bfb)，EINTR\u662f\u7cfb\u7edf\u8c03\u7528\u56e0\u4fe1\u53f7\u4e2d\u65ad\u800c\u63d0\u524d\u7ec8\u6b62
\n if(errno == EINTR || errno == EAGAIN){
\n return;
\n }
\n \/\/\u8fd9\u91cc\u5c31\u662f\u4e25\u91cd\u9519\u8bef
\n ERR_LOG("read eventd \u5931\u8d25！！");
\n abort();
\n }
\n return;
\n }
\n void WeakUpEventFd(){
\n uint64_t val =1;
\n int ret = write(_event_fd,&val,sizeof(val));
\n if(ret <0){
\n if(errno == EINTR){
\n return;
\n }
\n \/\/\u8fd9\u91cc\u5c31\u662f\u4e25\u91cd\u9519\u8bef
\n ERR_LOG("write eventd \u5931\u8d25！！");
\n abort();
\n }
\n return;
\n }
\n public:
\n EventLoop():_thread_id(std::this_thread::get_id()),
\n _event_fd(CreateEventFd()),
\n _event_channel(new Channel(this,_event_fd)),
\n _timer_wheel(this){
\n \/\/\u7ed9eventfd\u6dfb\u52a0\u53ef\u8bfb\u4e8b\u4ef6\u56de\u8c03\u51fd\u6570，\u8bfb\u53d6eventfd\u4e8b\u4ef6\u901a\u77e5\u6b21\u6570
\n _event_channel->SetReadCallback(std::bind(&EventLoop::ReadEventFd,this));
\n \/\/\u542f\u52a8eventfd\u7684\u8bfb\u4e8b\u4ef6\u76d1\u63a7
\n _event_channel->EnableRead();
\n }
\n void Start(){
\n \/\/\u8fd9\u4e2a\u5faa\u73af\u53ef\u4ee5\u52a0\u5230start\u91cc\u9762\u4e5f\u53ef\u4ee5\u5728\u5916\u90e8\u8c03\u7528start\u65f6\u5957\u4e0a\u4e00\u5c42\u5faa\u73af
\n \/\/Reactor\u7684\u4f53\u73b0\u6240\u5728，Reactor\u5c31\u662f\u4e00\u79cd\u624b\u6bb5\u548c\u65b9\u6cd5\u2014\u2014\u76d1\u542c\u4e8b\u4ef6，\u7136\u540e\u5728\u76d1\u542c\u4e8b\u4ef6\u4e2d\u6267\u884c\u5bf9\u5e94\u53ef\u6267\u884c\u4e8b\u4ef6\u3002
\n while(true){
\n \/\/\u5206\u4e09\u6b65：1.\u4e8b\u4ef6\u76d1\u63a7 2.\u5c31\u7eea\u4e8b\u4ef6\u5904\u7406 3.\u6267\u884c\u4efb\u52a1
\n \/\/1.\u4e8b\u4ef6\u76d1\u63a7
\n std::vector<Channel*> actives;
\n _poller.Poll(&actives);
\n \/\/\u8fd9\u91cc\u987a\u5e8f\u4e0d\u80fd\u53d8\u901a\u5e38IO\u662f\u5b9e\u65f6\u7684，\u5bf9\u5ef6\u8fdf\u654f\u611f，\u5e94\u8be5\u7acb\u5373\u5904\u7406\u3002
\n \/\/\u5c31\u7eea\u4e8b\u4ef6\u7684\u5904\u7406
\n for(auto &channel:actives)channel->HandleEvent();
\n \/\/\u6267\u884c\u4efb\u52a1\u2014\u2014\u628aclose(fd)\u5173\u95ed\u5ba2\u6237\u7aef\u8fde\u63a5\u653e\u5230\u4efb\u52a1\u6c60\u4e2d(\u907f\u514d\u6211\u8fd8\u5728\u5904\u7406\u6211\u5c31\u76f4\u63a5\u5173\u4e86)\u3001\u5b9a\u65f6\u5668\u4efb\u52a1
\n RunAllTask();
\n }
\n }<\/p>\n \/\/\u7528\u4e8e\u5224\u65ad\u5f53\u524d\u7ebf\u7a0b\u662f\u5426\u662fEventLoop\u5bf9\u5e94\u7684\u7ebf\u7a0b
\n bool IsInLoop(){
\n return (_thread_id == std::this_thread::get_id());
\n }<\/p>\n \/\/\u786e\u4fdd\u51fd\u6570\u6267\u884c\u65f6loop\u4e2d\u6267\u884c\u7684
\n void AssertInLoop(){
\n assert(_thread_id == std::this_thread::get_id());
\n }
\n \/\/\u5224\u65ad\u5c06\u8981\u6267\u884c\u7684\u4efb\u52a1\u662f\u5426\u5904\u4e8e\u5f53\u524d\u7ebf\u7a0b\u4e2d，\u5982\u679c\u662f\u5c31\u76f4\u63a5\u6267\u884c，\u5982\u679c\u4e0d\u662f\u5c31\u63d2\u5165\u4efb\u52a1\u961f\u5217\u4e2d\u3002
\n \/\/\u8fd9\u4e3b\u8981\u662f\u4e3a\u4e86\u62d3\u5c55\u4e1a\u52a1\u573a\u666f，\u6bd4\u5982\u8fde\u63a5\u7ba1\u7406\u7ebf\u7a0b，\u534f\u8bae\u89e3\u6790\u7ebf\u7a0b，\u4e1a\u52a1\u903b\u8f91\u7ebf\u7a0b，\u6570\u636e\u5e93\u7ebf\u7a0b，\u54cd\u5e94\u7ec4\u88c5\u7ebf\u7a0b\u3002\u591a\u4e2a\u7ebf\u7a0b\u7684\u65f6\u5019\u6211\u4e00\u4e2a\u8fde\u63a5\u4e00\u4e2a\u5728\u4e3b\u7ebf\u7a0b\u4e2d\u6267\u884c\u4efb\u52a1，\u8fde\u63a5\u7ba1\u7406\u7ebf\u7a0b\u662f\u4e3b\u7ebf\u7a0b
\n void RunInLoop(const Functor & cb){
\n if(IsInLoop()){
\n return cb();
\n }
\n return QueueInLoop(cb);
\n }<\/p>\n \/\/\u5c06\u64cd\u4f5c\u538b\u5165\u4efb\u52a1\u6c60
\n void QueueInLoop(const Functor &cb){
\n {
\n std::unique_lock<std::mutex> _lock(_mutex);
\n _tasks.push_back(cb);
\n }
\n \/\/\u5524\u9192\u54ea\u4e9b\u56e0\u4e3a_poller.Poll()\u65f6\u7684\u963b\u585e\u7ebf\u7a0b，\u4e0d\u7136\u4efb\u52a1\u961f\u5217\u534a\u5929\u4e0d\u4f1a\u88ab\u6267\u884c
\n WeakUpEventFd();
\n }<\/p>\n \/\/\u6dfb\u52a0\/\u4fee\u6539\u63cf\u8ff0\u7b26\u7684\u4e8b\u4ef6\u76d1\u63a7
\n void UpdateEvent(Channel* channel){
\n return _poller.UpdateEvent(channel);
\n }<\/p>\n \/\/\u79fb\u9664\u63cf\u8ff0\u7b26\u7684\u76d1\u63a7
\n void RemoveEvent(Channel* channel){
\n return _poller.RemoveEvent(channel);
\n }<\/p>\n void TimerAdd(uint64_t id,uint32_t delay,const TaskFunc& cb){
\n return _timer_wheel.TimerAdd(id,delay,cb);
\n }
\n void TimerRefresh(uint64_t id){return _timer_wheel.TimerRefresh(id);}
\n void TimerCancel(uint64_t id){return _timer_wheel.TimerCancel(id);}
\n \/\/\u5982\u679c\u6211\u8981\u628a\u5b9a\u65f6\u5668\u505c\u4e86，\u7136\u540e\u518d\u542f\u7528\u90a3\u4e48\u5c31\u9700\u8981\u8fd9\u4e2a\u63a5\u53e3
\n bool HashTimer(uint64_t id){return _timer_wheel.HashTimer(id);}
\n}; <\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u5728\u6210\u5458\u53d8\u91cf\u4e2d\u6709，\u7ebf\u7a0bID\u3001event_fd(\u95f9\u949ffd)\u3001\u95f9\u949f\u7684Channel\u3001\u5bf9\u6240\u6709\u8fde\u63a5\u7684\u7ba1\u7406Poll\u7c7b\u3001\u4efb\u52a1\u6c60\u3001\u5b9a\u65f6\u5668\u3001\u9501\u3002\u5176\u4e2d\u7ebf\u7a0bID\u548cevent_fd\u662f\u4e3a\u4e86\u5728\u5355\u4e2a\u8fde\u63a5\u7684\u591a\u7ebf\u7a0b\u573a\u666f\u4e0b\u6240\u8bbe\u7f6e\u7684，\u7ebf\u7a0bID\u662f\u4e3a\u4e86\u7ebf\u7a0b\u5b89\u5168，\u4fdd\u8bc1\u5728\u591a\u7ebf\u7a0b\u573a\u666f\u4e2d\u6211\u538b\u5165\u5230\u4e00\u4e2a\u4efb\u52a1\u961f\u5217\u4e2d，\u4f9d\u6b21\u6267\u884c\u3002\u6700\u597d\u4f7f\u7528\u9501\u786e\u4fdd\u6570\u636e\u7684\u4e00\u81f4\u6027\u3002\u5728\u5355\u8fde\u63a5\u591a\u7ebf\u7a0b\u573a\u666f\u4e2d，\u6211\u53ef\u80fd\u6709\u5de5\u4f5c\u7ebf\u7a0b，\u6570\u636e\u5e93\u7ebf\u7a0b，\u4e1a\u52a1\u7ebf\u7a0b，\u94fe\u63a5\u7ba1\u7406\u7ebf\u7a0b，\u4e0d\u540c\u7ebf\u7a0b\u8981\u628a\u4efb\u52a1\u538b\u5165，\u540c\u65f6\u56e0\u4e3a\u6211\u7684EventLoop\u542f\u52a8\u540e\u4e00\u76f4\u5728Poll\u963b\u585e\u7b49\u5f85\u5c31\u7eea\u4e8b\u4ef6，\u6240\u4ee5\u8fd9\u91cc\u4e3a\u4e86\u9632\u6b62\u6211\u4e00\u76f4\u538b\u5165\u4efb\u52a1，\u4efb\u52a1\u786e\u4e0d\u80fd\u6267\u884c，\u6211\u5c31\u8bbe\u7f6eeventfd\u8fd9\u4e2a\u53d8\u91cf，\u5c31\u76f8\u5f53\u4e8e\u95f9\u949f，\u6211\u628a\u95f9\u949f\u6302\u5230epoll\u7684\u7ea2\u9ed1\u6811\u4e2d，\u538b\u5165\u4efb\u52a1\u540e\u6211\u5c31\u8c03\u7528WeakUpEventFd\u51fd\u6570\u5c31\u4f1a\u5199\u5165\u6570\u636e\u5230eventfd\u4e2d\u6fc0\u6d3bepoll_wait，\u5c31\u7eea\u4e8b\u4ef6\u89e6\u53d1\u5c31\u4e0d\u4f1a\u963b\u585e\u4e86，\u5c31\u4f9d\u6b21\u6267\u884c\u4efb\u52a1\u6c60\u4e2d\u7684\u4efb\u52a1<\/p>\n 4.4 \u9ad8\u7ea7\u7279\u6027\u6a21\u5757<\/h3>\n4.4.1\u00a0TimerTask\u7c7b\u2014\u2014\u4efb\u52a1\u8d85\u65f6\u7c7b<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u5b9a\u65f6\u4efb\u52a1\u6211\u8fd9\u91cc\u7684\u601d\u8def\u5c31\u662f\u5728\u6790\u6784\u51fd\u6570\u4e2d\u8c03\u81ea\u5df1\u7684_task_cb\u4efb\u52a1\u56de\u8c03，\u7136\u540e\u518d\u65f6\u95f4\u8f6e\u5b9a\u65f6\u5668\u91cc\u8d85\u65f6\u4e86\u5c31\u76f4\u63a5\u628a\u65f6\u95f4\u8f6e\u4e2d\u7684\u5b9a\u65f6\u4efb\u52a1clear()\u81ea\u52a8\u8c03\u7528\u81ea\u5df1\u7684\u6790\u6784\u51fd\u6570\u81ea\u52a8\u6267\u884c\u8d85\u65f6\u4efb\u52a1\u4e86\u3002\u5176\u4f59\u7684\u5c31\u662f\u6210\u5458\u53d8\u91cf\u7684\u8bbe\u7f6e\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u7528\u4e00\u4e2a64\u4f4d\u7684\u6574\u5f62\u505a\u5b9a\u65f6\u5668\u7684ID，2^64\u4e2a\u5b9a\u65f6\u5668\u9762\u5bf9，\u9ad8\u5e76\u53d1\u7684\u670d\u52a1\u5668\u4e5f\u9519\u9519\u6709\u4f59\u4e86，\u8d85\u65f6\u65f6\u95f4\u7528\u4e00\u4e2a32\u4f4d\u7684\u6574\u5f62\u5176\u5b9e16\u4f4d\u6574\u578b\u751a\u81f3uint_8\u90fd\u884c\u5177\u4f53\u770b\u5e94\u7528\u573a\u666f，\u7528_canceled\u6807\u8bb0\u8fd9\u4e2a\u4efb\u52a1\u662f\u5426\u88ab\u53d6\u6d88\u5b9a\u65f6\u4e86，\u907f\u514d\u91cd\u590d\u6267\u884c，\u7136\u540e\u5c31\u662f\u5b9a\u65f6\u4efb\u52a1\u51fd\u6570\u4ee5\u53ca_release\u51fd\u6570\u2014\u2014\u8fd9\u4e2a\u51fd\u6570\u662f\u4e3a\u4e86\u6211\u5728\u6267\u884c\u5b9a\u65f6\u4efb\u52a1\u7684\u65f6\u5019\u987a\u4fbf\u628a\u5b9a\u65f6\u4efb\u52a1\u5728\u65f6\u95f4\u8f6e\u7ba1\u7406\u7c7b\u4e2d\u7684\u4fdd\u5b58\u8bb0\u5f55\u4e5f\u5220\u4e86\u76ee\u7684\u5c31\u662f\u65b9\u4fbf\u4e5f\u7b26\u5408\u9ad8\u5185\u805a\u4f4e\u5076\u5c14\u539f\u5219\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n using TaskFunc = std::function<void()>;
\nusing ReleaseFunc = std::function<void()>;<\/p>\n \/\/\u5355\u4e2a\u8d85\u65f6\u4efb\u52a1\u7c7b\u2014\u2014\u4e3b\u8981\u662f\u8d85\u65f6\u4e86\u5c31\u5728\u4ed6\u7684\u6790\u6784\u51fd\u6570\u4e2d\u6267\u884c\u5b9a\u65f6\u4efb\u52a1
\nclass TimerTask{
\n private:
\n uint64_t _id; \/\/\u5b9a\u65f6\u5668\u4efb\u52a1\u5bf9\u8c61ID
\n uint32_t _timeout;\/\/\u5b9a\u65f6\u4efb\u52a1\u7684\u8d85\u65f6\u65f6\u95f4
\n bool _canceled;\/\/ false-\u8868\u793a\u6ca1\u6709\u88ab\u53d6\u6d88， true-\u8868\u793a\u88ab\u53d6\u6d88
\n TaskFunc _task_cb;\/\/\u5b9a\u65f6\u5668\u5bf9\u8c61\u8981\u6267\u884c\u7684\u5b9a\u65f6\u4efb\u52a1
\n ReleaseFunc _release;\/\/\u7528\u4e8e\u5220\u9664TimerWheel\u4e2d\u4fdd\u5b58\u7684\u5b9a\u65f6\u5668\u5bf9\u8c61\u4fe1\u606f
\n public:
\n TimerTask(uint64_t id, uint32_t delay, const TaskFunc &cb):
\n _id(id), _timeout(delay), _task_cb(cb), _canceled(false) {}
\n ~TimerTask()
\n {
\n if (_canceled == false) _task_cb();
\n _release();
\n }
\n void Cancel() { _canceled = true; }
\n void SetRelease(const ReleaseFunc &cb) { _release = cb; }
\n uint32_t DelayTime() { return _timeout; }
\n}; <\/p>\n 4.4.2\u00a0TimerWheel\u7c7b\u2014\u2014\u65f6\u95f4\u8f6e\u5b9a\u65f6\u5668<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u4e0a\u9762\u8bf4\u4e86\u8d85\u65f6\u4efb\u52a1\u7c7b，\u8fd9\u91cc\u7684TImerWheel\u7c7b\u5c31\u662f\u6a21\u62df\u6307\u9488\u8df3\u52a8\u6765\u6267\u884c\u4efb\u52a1，\u5df2\u7ecf\u5bf9\u4efb\u52a1\u7684\u589e\u5220\u67e5\u6539\u7684\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n \/\/\u65f6\u95f4\u8f6e\u2014\u2014\u6a21\u62df\u65f6\/\u79d2\/\u5206\u949f\u7684\u8df3\u52a8\u2014\u2014\u8fd9\u91cc\u662f\u6a21\u62df\u79d2\u949f\u7684\u8df3\u52a8\u3002
\nclass TimerWheel{
\n private:
\n using WeakPtr = std::weak_ptr<TimerTask>;
\n using PtrTask = std::shared_ptr<TimerTask>;
\n int _tick;\/\/\u79d2\u9488\u7684\u4f4d\u7f6e
\n int _capacity;\/\/\u8868\u76d8\u7684\u523b\u5ea6
\n \/\/\u540c\u7406\u8fd9\u662fshared_ptr\u8868\u53ea\u5b58\u5728\u4e00\u4efd，clear\u4e86，\u5c31\u76f4\u63a5\u6790\u6784，\u56e0\u4e3a\u53ef\u80fd\u6709\u591a\u4e2a\u4efb\u52a1\u5728\u540c\u4e00\u4e2a\u65f6\u523b\u6240\u4ee5\u7528vector<vector<PtrTask>>\u7684\u5f62\u5f0f
\n std::vector<std::vector<PtrTask>> _wheel;
\n \/\/\u8fd9\u91cc\u5f88\u5173\u952e，\u6211\u627e\u4efb\u52a1\u7684\u8868\u53ea\u80fd\u5b58weak_ptr\u4e0d\u7136\u6211\u65e0\u6cd5\u505a\u5230\u6790\u6784\u51fd\u6570\u6267\u884c\u4efb\u52a1，\u56e0\u4e3a\u4efb\u52a1\u8868\u5b58shared_ptr\u7684\u8bdd\u90a3\u4e48\u5c31\u6c38\u8fdc\u6709\u4e00\u4e2a\u5b9e\u4f8b\u5728\u3002
\n std::unordered_map<uint64_t,WeakPtr> _timers;<\/p>\n \/\/\u4e0b\u9762\u662f\u4e3a\u4e86\u628a\u5b9a\u65f6\u5668\u878d\u5408\u5230EventLoop\u4e2d\u6240\u9700\u8981\u6dfb\u52a0\u7684\u6210\u5458
\n EventLoop* _loop;
\n int _timerfd;\/\/\u5b9a\u65f6\u5668\u63cf\u8ff0\u7b26–\u53ef\u8bfb\u4e8b\u4ef6\u56de\u8c03\u5c31\u662f\u8bfb\u53d6\u8ba1\u6570\u5668，\u6267\u884c\u5b9a\u65f6\u4efb\u52a1
\n std::unique_ptr<Channel> _timer_channel;
\n private:
\n void RemoveTimer(uint64_t id){
\n auto it = _timers.find(id);
\n if(it==_timers.end())return;
\n _timers.erase(it);
\n }
\n static int CreateTimerfd(){
\n int timerfd = timerfd_create(CLOCK_MONOTONIC,0);
\n if(timerfd < 0){
\n ERR_LOG("TIMERFD CREATE FAILED!!!");
\n abort();
\n }
\n \/\/int timerfd_settime(int fd,int flags,struct itimerspc* new,struct itimerspc* old);
\n struct itimerspec itime;
\n itime.it_value.tv_sec=1;
\n itime.it_value.tv_nsec=0;\/\/\u7b2c\u4e00\u6b21\u8d85\u65f6\u95f4\u4e3a1s\u540e
\n itime.it_interval.tv_sec =1;
\n itime.it_interval.tv_nsec=0;\/\/\u7b2c\u4e00\u6b21\u8d85\u65f6\u540e，\u6bcf\u6b21\u8d85\u65f6\u7684\u95f4\u9694\u65f6\u95f4
\n timerfd_settime(timerfd,0,&itime,nullptr);
\n return timerfd;
\n }
\n int ReadTimefd(){
\n uint64_t times;
\n int ret = read(_timerfd,×,8);
\n if(ret<0){
\n ERR_LOG("READ TIMEFD FAILED!!!");
\n abort();
\n }
\n return times;
\n }<\/p>\n void RunTimerTask() {
\n _tick = (_tick + 1) % _capacity;
\n _wheel[_tick].clear();\/\/\u6e05\u7a7a\u6307\u5b9a\u4f4d\u7f6e\u7684\u6570\u7ec4，\u5c31\u4f1a\u628a\u6570\u7ec4\u4e2d\u4fdd\u5b58\u7684\u6240\u6709\u7ba1\u7406\u5b9a\u65f6\u5668\u5bf9\u8c61\u7684shared_ptr\u91ca\u653e\u6389
\n }
\n void OnTime(){
\n int times = ReadTimefd();
\n for (int i = 0; i < times; i++) {
\n RunTimerTask();
\n }
\n }
\n \/\/\u6dfb\u52a0\u5b9a\u65f6\u4efb\u52a1
\n void TimerAddInLoop(uint64_t id , uint32_t delay,const TaskFunc&cb){
\n \/\/\u53ef\u80fd\u51fa\u73b0\u540c\u65f6\u63d2\u5165\u540c\u4e00\u4e2a\u4efb\u52a1\u7684\u60c5\u51b5
\n \/\/\u65b0\u589e：\u68c0\u67e5ID\u662f\u5426\u5df2\u5b58\u5728，\u5b58\u5728\u5219\u5148\u53d6\u6d88\u65e7\u4efb\u52a1
\n auto it = _timers.find(id);
\n if(it != _timers.end()){
\n PtrTask old_task = it->second.lock();
\n if(old_task) old_task->Cancel(); \/\/ \u6807\u8bb0\u65e7\u4efb\u52a1\u53d6\u6d88，\u907f\u514d\u6267\u884c
\n }
\n PtrTask pt(new TimerTask(id,delay,cb));
\n pt->SetRelease(std::bind(&TimerWheel::RemoveTimer,this,id));
\n int pos = (_tick+delay)%_capacity;
\n _wheel[pos].push_back(pt);
\n _timers[id]=WeakPtr(pt);
\n }
\n \/\/\u5237\u65b0\/\u5ef6\u8fdf\u5b9a\u65f6\u4efb\u52a1
\n void TimerRefreshInLoop(uint64_t id){
\n \/\/\u901a\u8fc7\u4fdd\u5b58\u7684\u5b9a\u65f6\u5668\u5bf9\u8c61\u7684weak_ptr\u6784\u9020\u5904\u4e00\u4e2ashared_ptr\u51fa\u6765，\u6dfb\u52a0\u5230\u8f6e\u5b50\u4e2d
\n auto it = _timers.find(id);
\n if(it == _timers.end())return;
\n PtrTask pt = it->second.lock();\/\/lock\u83b7\u53d6weak_ptr\u7684\u5bf9\u8c61，\u5e76\u8d4b\u503c\u7ed9\u65b0\u7684shared_ptr\u53bb\u7ba1\u7406\u6b64\u65f6\u5f15\u7528\u8ba1\u6570+1
\n int delay = pt->DelayTime();
\n int pos = (_tick+delay)%_capacity;
\n _wheel[pos].push_back(pt);
\n }
\n void TimerCancelInLoop(uint64_t id){
\n auto it = _timers.find(id);
\n if(it == _timers.end()){
\n return;\/\/\u6ca1\u627e\u5230\u5b9a\u65f6\u4efb\u52a1，\u6ca1\u6cd5\u5237\u65b0，\u6ca1\u6cd5\u5ef6\u8fdf
\n }
\n PtrTask pt = it->second.lock();
\n if(pt)pt->Cancel();
\n }
\n public:
\n TimerWheel(EventLoop* loop):_capacity(60),_tick(0),_wheel(_capacity),_loop(loop),
\n _timerfd(CreateTimerfd()),_timer_channel(new Channel(_loop,_timerfd))
\n {
\n _timer_channel->SetReadCallback(std::bind(&TimerWheel::OnTime,this));
\n _timer_channel->EnableRead();\/\/\u542f\u52a8\u8bfb\u4e8b\u4ef6\u76d1\u63a7
\n }
\n void TimerAdd(uint64_t id , uint32_t delay,const TaskFunc&cb);
\n void TimerRefresh(uint64_t id);
\n void TimerCancel(uint64_t id);
\n \/\/\u8fd9\u4e2a\u63a5\u53e3\u5b58\u5728\u7ebf\u7a0b\u5b89\u5168\u95ee\u9898，\u4e0d\u80fd\u5728\u5176\u4ed6\u7ebf\u7a0b\u8c03\u7528\u53ea\u80fd\u5728\u5bf9\u5e94EventLoop\u4e2d\u8c03\u7528\u3002
\n bool HashTimer(uint64_t id){
\n auto it = _timers.find(id);
\n if(it == _timers.end())return false;
\n return true;
\n }<\/p>\n };<\/p>\n 4.4.3 LoopThread\/LoopThreadPoll\u7c7b\u2014\u2014\u591a\u7ebf\u7a0b\u7c7b<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u5728LoopThread\u7c7b\u4e2d\u6211\u4e0d\u80fd\u76f4\u63a5\u521b\u5efaEventLoop\u5b9e\u4f8b\u5bf9\u8c61\u4e0d\u7136\u7ebf\u7a0bID\u5c31\u662f\u4e3b\u7ebf\u7a0b\u7684ID\/\u5f53\u524d\u7ebf\u7a0bID，\u6240\u4ee5\u5728LoopThread\u4e2d\u662fEventLoop\u7684\u6307\u9488\u5bf9\u8c61，\u63a5\u7740\u6709\u4e00\u4e2a\u51fd\u6570ThreadEntry\u8fd9\u4e2a\u51fd\u6570\u662f\u4f20\u7ed9thread\u7684\u6267\u884c\u51fd\u6570，\u7136\u540e\u518dthread\u7ebf\u7a0b\u4e2d\u521b\u5efaloop，\u8fd9\u6837\u5728\u54ea\u4e2a\u7ebf\u7a0b\u4e2d\u521b\u5efa\u7684EventLoop\u4e2d\u7684\u7ebf\u7a0bid\u5c31\u662f\u54ea\u4e2a\u7ebf\u7a0b\u7684\u3002\u6211\u521b\u5efa\u4e86EventLoop\u5b9e\u4f8b\u540c\u65f6\u662f\u8981\u63d0\u4f9b\u7ed9\u5916\u90e8\u4f7f\u7528\u7684，\u6240\u4ee5\u6211\u8fd8\u9700\u8981\u4e00\u4e2aGetLoop\u51fd\u6570，\u4f46\u662f\u6211\u4e0d\u80fd\u6ca1\u6709\u521b\u5efa\u7ebf\u7a0b\u6211\u5c31\u76f4\u63a5\u7ed9\u522b\u4eba\u83b7\u53d6\u5427，\u8fd9\u6837\u662f\u9519\u8bef\u7684，\u6240\u4ee5\u8fd9\u91cc\u6211\u8fd8\u9700\u8981\u52a0\u4e0a\u6761\u4ef6\u53d8\u91cf\u53bb\u63a7\u5236\u987a\u5e8f，\u53ea\u6709\u521b\u5efa\u4e86\u7ebf\u7a0b\u540e\u624d\u80fd\u53bb\u8c03\u7528GetLoop\u51fd\u6570\u53bb\u83b7\u53d6EventLoop\u5b9e\u4f8b\u3002\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u5728LoopThreadPoll\u7c7b\u4e2d\u91c7\u7528RR\u8f6e\u8be2\u7684\u65b9\u5f0f\u53bb\u4e00\u6b21\u8bbf\u95ee\u7ebf\u7a0b\u6c60\u4e2d\u7684\u5176\u4f59\u7ebf\u7a0b\u3002\u7528vector<LoopThread*> _threads\u4fdd\u5b58\u6240\u6709\u7684LoopThread\u5bf9\u8c61(\u7ebf\u7a0b\u6c60)，\u7528vector<EventLoop*> _loops\u4fdd\u5b58\u7ebf\u7a0b\u6c60\u4e2d\u7684EventLoop\u5bf9\u8c61，\u8fd9\u91cc\u4e0b\u6807\u662f\u5bf9\u5e94\u5173\u7cfb，\u7ebf\u7a0b\u7684\u4e0b\u6807\u548cEventLoop\u7684\u4e0b\u6807\u662f\u4e00\u6837\u7684\u3002_threads\u548c_loops\u7684\u5927\u5c0f\u5c31\u662f\u7ebf\u7a0b\u6c60\u5927\u5c0f\u7528_thread_count\u6765\u8bbe\u7f6e，\u7528_next_idx\u8868\u793a\u5e94\u8be5\u5de5\u4f5c\u5230\u54ea\u4e00\u4e2a\u7ebf\u7a0b\u4e86\u56e0\u4e3a\u662fRR\u8f6e\u8be2\u7684\u65b9\u5f0f\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u4ee3\u7801\u5982\u4e0b：<\/p>\n \/\/\u5148\u6709\u7ebf\u7a0b\u518d\u6709EventLoop\u5bf9\u8c61，\u7136\u540eEventLoop\u5bf9\u8c61\u5728\u7ebf\u7a0b\u4e2d\u5b9e\u4f8b\u5316(\u4e0d\u7136\u8bbe\u7f6eid\u5c31\u662f\u4e3b\u7ebf\u7a0b\u7684\u7ebf\u7a0bid)，\u8fd9\u6837\u624d\u80fd\u4fdd\u8bc1id\u662f\u552f\u4e00\u7684，
\n#include <condition_variable> \/\/ \u6761\u4ef6\u53d8\u91cf\u7684\u6838\u5fc3\u5934\u6587\u4ef6
\n#include <mutex> \/\/ \u5404\u79cd\u9501（\u4e92\u65a5\u9501\u3001\u9012\u5f52\u9501\u7b49）\u7684\u6838\u5fc3\u5934\u6587\u4ef6
\nclass LoopThread{
\n private:
\n \/\/\u540c\u6b65\u64cd\u4f5c
\n std::mutex _mutex;\/\/\u4e92\u65a5\u9501
\n std::condition_variable _cond;\/\/\u6761\u4ef6\u53d8\u91cf<\/p>\n \/\/\u521b\u5efa\u4e00\u4e2a\u7ebf\u7a0b\u4e00\u4e2aEventLoop\u7684\u5b9e\u4f8b\u5316
\n EventLoop *_loop; \/\/EventLoop\u7684\u6307\u9488\u53d8\u91cf，\u8fd9\u4e2a\u5bf9\u8c61\u9700\u8981\u5728\u7ebf\u7a0b\u5185\u53d6\u5b9e\u4f8b\u5316，\u6240\u4ee5\u8981\u521d\u59cb\u5316\u4e3a\u6307\u9488(\u5f15\u7528\u521d\u59cb\u5316\u5fc5\u987b\u8d4b\u503c，\u6240\u4ee5\u8fd9\u91cc\u8fd8\u662f\u7528\u6307\u9488)，\u4f20\u9012\u6211\u7684loop\u5bf9\u8c61\u7ed9\u4e3b\u7ebf\u7a0b
\n std::thread _thread;\/\/EventLoop\u5bf9\u5e94\u7684\u7ebf\u7a0b
\n private:
\n \/\/\u5b9e\u4f8b\u5316EventLoop\u5bf9\u8c61，\u5524\u9192_cond\u4e0a\u53ef\u80fduse\u7684\u7ebf\u7a0b，\u5e76\u4e14\u5f00\u59cb\u8fd0\u884cEventLoop\u6a21\u5757\u7684\u529f\u80fd\u2014\u2014\u5b9e\u9645\u4e0a\u5c31\u662f\u53bb\u8fd0\u884cstart\u51fd\u6570
\n void ThreadEntry(){
\n \/\/\u4f46\u662f\u6ce8\u610f\u8fd9\u662f\u5c40\u90e8\u53d8\u91cf\u51fd\u6570\u9000\u51fa\u5c31\u9500\u6bc1\u4e86，\u6240\u4ee5\u4e0b\u9762\u7684start\u662f\u5faa\u73af\u6267\u884c\u7684
\n EventLoop loop;\/\/\u8fd9\u91cc\u4e3a\u4ec0\u4e48\u4e0d\u76f4\u63a5\u4f7f\u7528_loop\u5462？\u2014\u2014\u9996\u5148\u662f\u5c40\u90e8\u7684，\u6240\u4ee5\u8df3\u51fa\u4f5c\u7528\u57df\u81ea\u52a8\u9500\u6bc1\u4e86，\u5176\u6b21\u8fd9\u662f\u4e00\u4e2aEventLoop\u5b9e\u4f8b，\u76f4\u63a5\u8d4b\u503c\u4e86\u3002\u5982\u679cLoopThread\u4e2d_loop\u662f\u5b9e\u4f8b\u5bf9\u8c61\u7684\u8bdd，\u90a3\u4e48\u7ebf\u7a0bid\u5c31\u662f\u4e3b\u7ebf\u7a0b\u4e5f\u5c31\u662f\u521b\u5efa\u5b9e\u4f8b\u7684\u7ebf\u7a0bid\u4e86，\u6211\u628a\u8fd9\u4e2a\u5f53\u4f5cthread()\u51fd\u6570\u7684\u51fd\u6570\u4f20\u5165thread\u7136\u540e\u5728\u65b0\u7684\u7ebf\u7a0b\u4e2d\u521b\u5efa，\u8fd9\u6837id\u5c31\u662f\u65b0\u7ebf\u7a0b\u7684id\u4e86
\n {
\n std::unique_lock<std::mutex> lock(_mutex);\/\/\u52a0\u9501
\n _loop=&loop;
\n _cond.notify_all();\/\/\u5524\u9192\u6240\u6709\u7b49\u5f85\u7684\u6761\u4ef6\u53d8\u91cf
\n }
\n loop.Start();
\n }
\n public:
\n \/\/\u5728\u6784\u9020\u51fd\u6570\u4e2d\u521b\u5efa\u7ebf\u7a0b，\u8bbe\u5b9a\u7ebf\u7a0b\u7684\u5165\u53e3\u51fd\u6570\u2014\u2014\u8c03\u7528\u6784\u9020\u51fd\u6570\u5c31\u81ea\u52a8\u521b\u5efa\u7ebf\u7a0b
\n LoopThread():_loop(nullptr),_thread(std::thread(std::bind(&LoopThread::ThreadEntry,this))){}
\n \/\/\u5f53\u5916\u754c\u6709\u4e00\u4e2a\u65b0\u94fe\u63a5\u6765\u4e86，\u6211\u5f97\u83b7\u53d6\u8fd9\u4e2aEventLoop\u624d\u80fd\u53bb\u6dfb\u52a0\u4efb\u52a1，\u624d\u80fd\u5c06EventLoop\u548c\u8fde\u63a5\u5173\u8054
\n \/\/\u4f46\u662f\u6211\u4eec\u8981\u6ce8\u610f，\u5047\u8bbe\u6b64\u65f6\u6211\u4eec\u8fd8\u6ca1\u6709\u8bbe\u7f6eEventLoop，\u5c31\u574f\u4e8b\u4e86\u6240\u4ee5\u6b64\u65f6\u8981\u7528\u6761\u4ef6\u53d8\u91cf\u6765\u63a7\u5236\u987a\u5e8f，GetLoop\u4e2d\u5c31\u963b\u585e\u7b49\u5f85\u5b9e\u4f8b\u5316\u5b8c\u4e86\u624d\u53ef\u4ee5\u83b7\u53d6EventLoop\u5b9e\u4f8b\u5316\u5bf9\u8c61
\n EventLoop *GetLoop(){
\n EventLoop *loop = nullptr;
\n {
\n std::unique_lock<std::mutex> lock(_mutex);\/\/\u52a0\u9501-\u5728\u6784\u9020\u51fd\u6570\u4e2d\u7b49\u5f85
\n \/\/\u4f7f\u7528&\u2014\u2014\u907f\u514d\u62f7\u8d1d，\u5f15\u7528\u7684\u65b9\u5f0f\u83b7\u53d6\u5916\u90e8\u6240\u6709\u7684\u53d8\u91cf，\u53ef\u4fee\u6539\u3002=\u4e0d\u53ef\u4fee\u6539，\u8fd8\u4f1a\u9020\u6210\u62f7\u8d1d
\n _cond.wait(lock,[&](){return _loop !=nullptr;});\/\/loop\u4e3anullptr\u5c31\u963b\u585e，\u7b49\u5f85\u88ab\u5524\u9192，\u628a\u5224\u65ad\u6761\u4ef6\u5199\u5230wait\u51fd\u6570\u4e2d
\n loop=_loop;
\n }
\n return loop;
\n }<\/p>\n };<\/p>\n \/\/\u7ebf\u7a0b\u6c60
\nclass LoopThreadPoll{
\n private:
\n int _thread_count;\/\/\u4ece\u5c5e\u7ebf\u7a0b\u7684\u6570\u91cf
\n int _next_idx;\/\/\u5f53\u524d\u54ea\u4e00\u4e2a\u7ebf\u7a0b\u5728\u8fd0\u884c\/\u5de5\u4f5c\u5230\u54ea\u4e00\u4e2a\u7ebf\u7a0b\u4e86
\n EventLoop* _baseloop;\/\/\u4e3bEventLoop，\u8fd0\u884c\u5728\u4e3b\u7ebf\u7a0b，\u4ece\u5c5e\u7ebf\u7a0b\u6570\u91cf\u4e3a0，\u5219\u6240\u6709\u64cd\u4f5c\u90fd\u5728baseloop\u4e2d\u8fdb\u884c
\n std::vector<LoopThread*> _threads;\/\/\u4fdd\u5b58\u6240\u6709\u7684LoopThread\u5bf9\u8c61
\n std::vector<EventLoop*> _loops;\/\/\u4ece\u5c5e\u7ebf\u7a0b\u6570\u91cf\u5927\u4e8e0\u5219\u4ece_loops\u4e2d\u8fdb\u884c\u7ebf\u7a0bEventLoop\u5206\u914d\u2014\u2014\u8bbe\u7f6e\u8fd9\u4e2avector\u662f\u6709\u5fc5\u8981\u7684，\u56e0\u4e3a\u6211\u4e0d\u80fd\u76f4\u63a5\u4f7f\u7528_threads->_loop\u5bf9\u8c61，\u56e0\u4e3a\u6b64\u65f6_loop\u53ef\u80fd\u662f\u975e\u7ebf\u7a0b\u5b89\u5168\u7684，\u53ef\u80fd\u6ca1\u6709\u521b\u5efa，\u7528GetLoop\u51fd\u6570\u80af\u5b9a\u662f\u5b58\u5728\u624d\u80fd\u83b7\u53d6\u7684\u3002\u6240\u4ee5\u4e3a\u4e86\u65b9\u4fbf\u7528\u6570\u7ec4\u5b58EventLoop\u5bf9\u8c61
\n public:
\n LoopThreadPoll(EventLoop *baseloop):_thread_count(0),_next_idx(0),_baseloop(baseloop){}
\n \/\/\u8bbe\u7f6e\u7ebf\u7a0b\u6570\u91cf
\n void SetThreadCount(const int count){_thread_count=count;}
\n \/\/\u521b\u5efa\u6240\u6709\u7684\u4ece\u5c5e\u7ebf\u7a0b
\n void Create(){
\n if(_thread_count>0){
\n _threads.resize(_thread_count);
\n _loops.resize(_thread_count);
\n for(int i=0;i<_thread_count;++i){
\n _threads[i]=new LoopThread();
\n _loops[i]=_threads[i]->GetLoop();
\n }
\n }
\n }
\n \/\/\u56e0\u4e3a\u91c7\u53d6RR\u8f6e\u8be2\u7684\u65b9\u5f0f\u6240\u4ee5\u547d\u540d\u662f\u8fd4\u56de\u4e0b\u4e00\u4e2a\u7ebf\u7a0b
\n EventLoop* NextLoop(){
\n if(_thread_count==0)return _baseloop;
\n _next_idx=(_next_idx+1)%_thread_count;
\n return _loops[_next_idx];
\n }
\n}; <\/p>\n 4.5 \u4e1a\u52a1\u6838\u5fc3\u6a21\u5757<\/h3>\n4.5.1 Acceptor\u7c7b\u2014\u2014\u76d1\u542c\u5957\u63a5\u5b57\u7ba1\u7406\u7c7b<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u662f\u4e3bReactor\u7684\u5177\u4f53\u5b9e\u73b0\u7c7b，\u4e3bReactor\u7684\u4f5c\u7528\u5c31\u662f\u7ba1\u7406\u76d1\u542cfd，\u6765\u4e00\u4e2a\u8fde\u63a5\u5c31\u8c03\u7528\u56de\u8c03\u51fd\u6570\u53bb\u5efa\u7acb\u4e00\u4e2a\u8fde\u63a5\u7c7b，\u5e95\u5c42\u8fd8\u662f\u8c03\u7528\u4e86\u6211\u4eec\u4e4b\u524d\u5c01\u88c5\u7684Channel\u7c7b\u3001Socket\u7c7b\u3001EventLoop\u7c7b\u3002\u8fd9\u91cc\u7684EventLoop\u6211\u4eec\u76f4\u63a5\u4f7f\u7528\u4e3b\u7ebf\u7a0b\u7684EventLoop\u5c31\u884c\u4e86，\u4e5f\u5c31\u662fTcpServer\u7c7b\u7684EventLoop\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n class Acceptor{
\n private:
\n Socket _socket;\/\/\u7528\u4e8e\u521b\u5efa\u5957\u63a5\u5b57
\n EventLoop *_loop;\/\/\u7528\u4e8e\u5bf9\u76d1\u542c\u5957\u63a5\u5b57\u8fdb\u884c\u4e8b\u4ef6\u76d1\u63a7
\n Channel _channel;\/\/\u7528\u4e8e\u5bf9\u76d1\u542c\u5957\u63a5\u5b57\u8fdb\u884c\u4e8b\u4ef6\u76d1\u63a7<\/p>\n using AcceptCallback = std::function<void(int)>;
\n AcceptCallback _accept_callback;
\n private:
\n \/\/\u76d1\u542c\u5957\u63a5\u5b57\u7684\u8bfb\u4e8b\u4ef6\u56de\u8c03\u5904\u7406\u51fd\u6570–\u83b7\u53d6\u65b0\u8fde\u63a5，\u8c03\u7528_accept_callback\u51fd\u6570\u8fdb\u884c\u65b0\u94fe\u63a5\u5904\u7406
\n void HandleRead(){
\n int newfd = _socket.Accept();
\n if(newfd<0)return;
\n if(_accept_callback)_accept_callback(newfd);
\n }
\n int CreateServer(uint16_t port){
\n bool ret = _socket.CreateServer(port);
\n assert(ret == true);
\n return _socket.Fd();
\n }
\n public:<\/p>\n \/\/\u8fd9\u91cc\u542f\u52a8\u4e8b\u4ef6\u76d1\u63a7\u6bd4\u8bbe\u7f6e\u56de\u8c03\u65e9，\u8fd9\u5c31\u4f1a\u5bfc\u81f4，\u7acb\u5373\u6709\u76d1\u63a7\u4e86，
\n \/\/\u4f46\u662f\u56de\u8c03\u8fd8\u6ca1\u88ab\u8bbe\u7f6e，\u4ec0\u4e48\u6ca1\u505a\u5c31\u5173\u4e86，fd\u4e5f\u6ca1\u88ab\u91ca\u653e，\u6240\u4ee5\u4e0d\u80fd\u628a\u542f\u52a8\u8bfb\u4e8b\u4ef6\u76d1\u63a7\u653e\u5230\u6784\u9020\u51fd\u6570\u4e2d
\n \/\/
\n Acceptor(EventLoop* loop,uint16_t port):
\n _socket(CreateServer(port)),
\n _loop(loop),
\n _channel(loop,_socket.Fd()){
\n _channel.SetReadCallback(std::bind(&Acceptor::HandleRead,this));
\n }
\n void SetAcceptCallback(const AcceptCallback& cb){_accept_callback = cb;}
\n \/\/\u6240\u4ee5\u8981\u8bbe\u7f6e\u4e00\u4e2alisten\u63a5\u53e3\u3002\u4f7f\u7528\u8005\u624b\u52a8\u5f00\u59cb\u76d1\u542c\u3002
\n void Listen(){_channel.EnableRead();}
\n}; <\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u5177\u4f53\u6d41\u7a0b\u5c31\u662f，\u5728TcpServer\u4e2d\u8bbe\u7f6e_accept_callback\u2014\u2014\u5b9e\u9645\u4e0a\u5c31\u662f\u521b\u5efa\u8fde\u63a5\u7c7b\u7684\u51fd\u6570，\u261e\u540e\u5728Acceptor\u7684\u6784\u9020\u51fd\u6570\u4e2d\u8bbe\u7f6e\u76d1\u542c\u5957\u63a5\u5b57，\u628a\u76d1\u542c\u5957\u63a5\u5b57\u7684fd\u8bbe\u7f6e\u5230Channel\u4e2d\u4ee5\u53ca\u628acallback\u8bbe\u7f6e\u7ed9Channel，\u7136\u540e\u5728TcpServer\u4e2d\u542f\u52a8\u5bf9\u8bfb\u4e8b\u4ef6\u76d1\u63a7\u3002\u8fd9\u6837\u53ea\u8981\u6709\u5ba2\u6237\u7aef\u8fde\u63a5\u6765\u4e86，\u8bfb\u4e8b\u4ef6\u5c31\u4f1a\u5c31\u7eea，\u76f8\u5e94\u7684\u5c31\u4f1a\u5728EventLoop\u4e2d\u7684Start\u51fd\u6570\u4e2dPoll\u5c31\u68c0\u6d4b\u5230\u5c31\u7eea\u4e8b\u4ef6\u5c31\u4f1a\u5728Channel\u4e2d\u6267\u884c\u5c31\u7eea\u4e8b\u4ef6\u7684\u56de\u8c03\u51fd\u6570，\u7136\u540e\u6211\u8bbe\u7f6e\u7684\u56de\u8c03\u51fd\u6570\u662f\u7ed9\u5ba2\u6237\u7aef\u521b\u5efa\u65b0\u94fe\u63a5\u4e5f\u5c31\u662f\u521b\u5efa\u4e00\u4e2aConnection\u7c7b，\u6240\u4ee5\u5ba2\u6237\u7aef\u4e5f\u521b\u5efa\u6210\u529f\u4e86\u3002<\/p>\n 4.5.2\u00a0Connection\u7c7b\u2014\u2014\u8fde\u63a5\u7ba1\u7406\u7c7b\/\u5ba2\u6237\u7aef\u8fde\u63a5\u7c7b<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 \u8fd9\u5c31\u662f\u771f\u6b63\u7684\u5ba2\u6237\u7aef\u8fde\u63a5\u7c7b，\u5305\u542b\u81ea\u5b9a\u4e49\u7f13\u51b2\u533aBuffer\u3001\u8fde\u63a5\u5957\u63a5\u5b57\u3001\u8fde\u63a5\u4e8b\u4ef6\u7684\u7ba1\u7406Channel\u7c7b\u3001\u7c7b\u578b\u64e6\u9664\u7c7b(\u4fdd\u5b58\u8bf7\u6c42\u63a5\u6536\u5904\u7406\u7684\u4e0a\u4e0b\u6587)\u3001\u8fde\u63a5id(\u65b9\u4fbf\u6211\u4eecTcpServer\u7c7b\u7ba1\u7406)\u3001\u662f\u5426\u542f\u52a8\u6d3b\u8dc3\u9500\u6bc1\u6807\u5fd7\u3001EventLoop\u7c7b\u3001\u8fde\u63a5\u72b6\u6001\u7684\u679a\u4e3e\u3002\u5c24\u5176\u662f\u8fde\u63a5\u72b6\u6001\u7684\u679a\u4e3e，\u65b9\u4fbf\u6211\u4eec\u66f4\u52a0\u7075\u6d3b\u7684\u5904\u7406\u5404\u79cd\u51fd\u6570\u3002\u5176\u516c\u6709\u6210\u5458\u51fd\u6570\u5c31\u662f\u5c06\u79c1\u6709\u51fd\u6570\u5c01\u88c5\u5230\u4efb\u52a1\u961f\u5217\u91cc\u7136\u540e\u8c03\u7528\u3002\u5404\u79cd\u79c1\u6709\u51fd\u6570\u4e3b\u8981\u5c31\u662f：SendInLoop\u53d1\u9001\u6570\u636e\u3001ShutdownInLoop\u5173\u95ed\u8fde\u63a5\u3001\u5173\u95ed\u548c\u5f00\u542f\u8fde\u63a5\u7684\u975e\u6d3b\u8dc3\u9500\u6bc1\u3001\u7136\u540e\u5c31\u662f\u66f4\u65b0\u534f\u8bae(\u8fd9\u4e2a\u53ef\u80fd\u7528\u4e0d\u5230)\u3001\u5df2\u7ecf\u5404\u79cd\u8bbe\u7f6e\u7ed9Channel\u56de\u8c03\u51fd\u6570\u7684\u8bbe\u7f6e\u8bfb\u3001\u5199\u3001\u9519\u8bef\u3001\u4efb\u610f\u4e8b\u4ef6\u3001\u5173\u95ed\u3002\u6700\u540e\u5728\u5bf9\u5916\u7684\u516c\u5171\u63a5\u53e3\u5c31\u662f\u4e00\u4e9b\u5b89\u5168\u7684\u8bbf\u95ee\u79c1\u6709\u53d8\u91cf\u7684\u51fd\u6570，\u4ee5\u53caConnection\u7c7b\u4e2d\u56de\u8c03\u51fd\u6570\u7684\u8bbe\u7f6e\u3002<\/p>\n \/\/\u8bbe\u7f6e\u8fde\u63a5\u72b6\u6001
\ntypedef enum {DISCONNECTED , CONNECTED , CONNECTING , DISCONNECTING}ConnStatu;
\n\/\/ DISCONNECTED — \u8fde\u63a5\u5173\u95ed\u8f6c\u6001
\n\/\/ ONNECTED — \u8fde\u63a5\u5efa\u7acb\u6210\u529f-\u5f85\u5904\u7406\u8f6c\u6001
\n\/\/ CONNECTING — \u8fde\u63a5\u5efa\u7acb\u5b8c\u6210，\u5404\u79cd\u8bbe\u7f6e\u5df2\u5b8c\u6210，\u53ef\u4ee5\u901a\u4fe1
\n\/\/ DISCONNECTING — \u5f85\u5173\u95ed\u72b6\u6001<\/p>\n using PtrConnection = std::shared_ptr<Connection>;<\/p>\n \/\/\u4e00\u4e2a\u8fde\u63a5\u4e00\u4e2aConnection
\n\/\/\u53ea\u6709\u7ee7\u627f\u4e86enable_shared_from_this<Connection>\u624d\u80fd\u4f7f\u7528shared_from_this，\u8fd4\u56de\u4e00\u4e2a\u81ea\u5df1\u7684shared_ptr，enable_shared_from_this<Connection>\u5e95\u5c42\u662f\u5c01\u88c5\u4e86\u4e00\u4e2aweak_ptr，\u6240\u4ee5shared_ptr\u8ba1\u6570\u4e0d\u4f1a+\u20141
\nclass Connection: public std::enable_shared_from_this<Connection>{
\n private:
\n uint64_t _conn_id;\/\/\u8fde\u63a5\u7684\u552f\u4e00ID，\u4fbf\u4e8e\u8fde\u63a5\u7684\u7ba1\u7406\u548c\u67e5\u627e,\u56e0\u4e3a_conn_id\u552f\u4e00\u6240\u4ee5\u6211\u4eec\u9ed8\u8ba4_time_id\u5c31\u662f_conn_id
\n int _sockfd;\/\/\u8fde\u63a5\u5173\u8054\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n bool _enable_inactive_release; \/\/\u8fde\u63a5\u662f\u5426\u542f\u52a8\u975e\u6d3b\u8dc3\u9500\u6bc1\u7684\u5224\u65ad\u6807\u5fd7，\u9ed8\u8ba4\u4e3afalse
\n \/\/\u8fd9\u91cc\u7684EventLoop\u8bbe\u7f6e\u7684\u662f\u6307\u9488\u539f\u56e0\u662f\u8fd9\u91cc\u7684loop\u662f\u7ebf\u7a0b\u6c60\u4e2d\u4f20\u8fc7\u6765\u7684loop\u3002\u5982\u679c\u76f4\u63a5\u8bbe\u7f6e\u4e3a\u5bf9\u8c61\u7684\u8bdd\u5c31\u4e0d\u662f\u7ebf\u7a0b\u6c60\u6a21\u5f0f\u4e86\u5931\u53bb\u4e86\u7ebf\u7a0b\u6c60\u7684\u4f18\u52bf\u4f1a\u9891\u7e41\u7684\u521b\u5efa\u548c\u9500\u6bc1\u7ebf\u7a0b\u2014\u2014\u8fd9\u8981\u4ece\u7528\u6237\u6001\u5207\u6362\u6210\u5185\u6838\u6001\u8017\u65f6
\n \/\/\u7ebf\u7a0b\u6c60\u662f\u4e00\u76f4\u5b58\u5728\u5185\u5b58\u4e2d，\u4e5f\u907f\u514d\u4e86\u7f13\u5b58\u6c61\u67d3
\n EventLoop *_loop;\/\/\u5173\u8054\u4e00\u4e2aEventLoop\u540c\u6837\u4e00\u4e2a\u8fde\u63a5\u7684\u51fd\u6570\u8c03\u7528\u5e94\u8be5\u662f\u7ebf\u7a0b\u5b89\u5168\u7684，\u6240\u4ee5\u540c\u6837\u8981\u5173\u8054\u4e00\u4e2aloop，\u56e0\u4e3a\u4e00\u4e2aloop\u5173\u8054\u4e00\u4e2a\u7ebf\u7a0b
\n ConnStatu _statu;\/\/\u8fde\u63a5\u7684\u72b6\u6001<\/p>\n Socket _socket;\/\/\u521b\u5efasocket\u5957\u63a5\u5b57，\u8fdb\u884c\u57fa\u7840\u7684\u7f51\u7edc\u901a\u4fe1\u8bbe\u7f6e
\n Channel _channel;\/\/\u8fde\u63a5\u7684\u4e8b\u4ef6\u7ba1\u7406
\n Buffer _in_buffer;\/\/\u8f93\u5165\u7f13\u51b2\u533a
\n Buffer _out_buffer;\/\/\u8f93\u51fa\u7f13\u51b2\u533a
\n Any _context;\/\/\u8bf7\u6c42\u7684\u63a5\u6536\u5904\u7406\u4e0a\u4e0b\u6587<\/p>\n \/\/\u4e0b\u9762\u56db\u4e2a\u56de\u8c03\u51fd\u6570，\u662f\u8ba9\u7ec4\u4ef6\u4f7f\u7528\u8005(\u670d\u52a1\u5668\u6a21\u5757)\u6765\u8bbe\u7f6e\u7684–\u5176\u5b9e\u670d\u52a1\u5668\u6a21\u5757\u7684\u5904\u7406\u56de\u8c03\u4e5f\u662f\u7ec4\u4ef6\u4f7f\u7528\u8005\u8bbe\u7f6e\u7684
\n using ConnectedCallback = std::function<void(const PtrConnection &)>;
\n using MessageCallback = std::function<void(const PtrConnection &,Buffer *)>;
\n using CloseCallback = std::function<void(const PtrConnection &)>;
\n using AnyEventCallback = std::function<void(const PtrConnection &)>;
\n ConnectedCallback _connected_callback;
\n MessageCallback _message_callback;
\n CloseCallback _closed_callback;
\n AnyEventCallback _event_callback;
\n \/\/\u989d\u5916\u8bbe\u7f6e\u7684\u4e0b\u9762\u8fd9\u4e2a\u662f\u2014\u2014\u7ec4\u4ef6\u5185\u8bbe\u7f6e\u7684\u8fde\u63a5\u5173\u95ed\u56de\u8c03\u2014\u2014\u7ec4\u4ef6\u5185\u8bbe\u7f6e\u7684，\u56e0\u4e3a\u670d\u52a1\u5668\u7ec4\u4ef6\u5185\u4f1a\u628a\u6240\u6709\u7684\u8fde\u63a5\u7ba1\u7406\u8d77\u6765，\u4e00\u65e6\u67d0\u4e2a\u8fde\u63a5\u8981\u5173\u95ed
\n \/\/\u90a3\u4e48\u5c31\u5e94\u8be5\u4ece\u7ba1\u7406\u7684\u5730\u65b9\u79fb\u9664\u6389\u81ea\u5df1\u7684\u4fe1\u606f
\n CloseCallback _server_closed_callback;<\/p>\n \/\/\u540c\u65f6\u8fd9\u4e9b\u56de\u8c03，\u4e00\u4e2a\u8fde\u63a5\u6240\u6709\u7684\u56de\u8c03\u90fd\u8981\u653e\u5230\u4efb\u52a1\u961f\u5217\u4e2d\u53bb，\u786e\u4fdd\u7ebf\u7a0b\u5b89\u5168
\n private:
\n \/\/\u6240\u4ee5\u9700\u8981\u8bbe\u7f6e\u4e00\u5806\u7684InLoop\u63a5\u53e3，\u628a\u56de\u8c03\u653e\u5165\u540c\u4e00\u4e2aloop\u4e2d\u7684\u540c\u4e00\u4e2a\u4efb\u52a1\u961f\u5217\u4e2d<\/p>\n \/\/\u8fde\u63a5\u83b7\u53d6\u4e4b\u540e，\u6240\u5728\u7684\u72b6\u6001\u4e0b\u8981\u8fdb\u884c\u5404\u79cd\u8bbe\u7f6e(\u7ed9Channel\u8bbe\u7f6e\u4e8b\u4ef6\u56de\u8c03，\u542f\u52a8\u8bfb\u76d1\u63a7)
\n void EstablIsShedInLoop(){
\n \/\/1.\u4fee\u6539\u8fde\u63a5\u72b6\u6001 2.\u542f\u52a8\u8bfb\u4e8b\u4ef6\u76d1\u63a7 3.\u8c03\u7528\u56de\u8c03\u51fd\u6570
\n assert(_statu == CONNECTING);\/\/\u5f53\u524d\u8fde\u63a5\u4e00\u5b9a\u662f\u7684\u534a\u8fde\u63a5\u72b6\u6001，\u8fd9\u6837\u6211\u624d\u53bb\u8bbe\u7f6e\u4e8b\u4ef6\u56de\u8c03
\n _statu = CONNECTED;\/\/\u5f53\u524d\u51fd\u6570\u6267\u884c\u5b8c\u6bd5，\u5219\u8fde\u63a5\u8fdb\u5165\u5df2\u5b8c\u6210\u8fde\u63a5\u72b6\u6001
\n _channel.EnableRead();\/\/\u4e00\u65e6\u542f\u52a8\u8bfb\u4e8b\u4ef6\u76d1\u63a7\u5c31\u6709\u53ef\u80fd\u4f1a\u7acb\u5373\u89e6\u53d1\u8bfb\u4e8b\u4ef6，\u5982\u679c\u8fd9\u65f6\u5019\u542f\u52a8\u4e86\u975e\u6d3b\u8dc3\u8fde\u63a5\u9500\u6bc1
\n if(_connected_callback)_connected_callback(shared_from_this());\/\/\u6709\u8fde\u63a5\u56de\u8c03\u51fd\u6570\u5c31\u89e6\u53d1\u5bf9\u5e94\u7684\u51fd\u6570
\n }<\/p>\n \/\/\u5b9e\u9645\u7684\u91ca\u653e\u63a5\u53e3
\n void ReleaseInLoop(){
\n \/\/1.\u4fee\u6539\u8fde\u63a5\u72b6\u6001，\u5c06\u5176\u7f6e\u4e3aDISCONNECTED
\n _statu=DISCONNECTED;
\n \/\/2.\u79fb\u9664\u8fde\u63a5\u7684\u4e8b\u4ef6\u76d1\u63a7
\n _channel.Remove();
\n \/\/3.\u5173\u95ed\u63cf\u8ff0\u7b26
\n _socket.Close();
\n \/\/4.\u5982\u679c\u5f53\u524d\u5b9a\u65f6\u5668\u961f\u5217\u4e2d\u8fd8\u6709\u5b9a\u65f6\u9500\u6bc1\u4efb\u52a1，\u5219\u53d6\u6d88\u4efb\u52a1
\n if(_loop->HashTimer(_conn_id)) CancelInactiveReleaseInLoop();
\n \/\/5.\u8c03\u7528\u5173\u95ed\u56de\u8c03\u51fd\u6570，\u907f\u514d\u5148\u79fb\u9664\u670d\u52a1\u5668\u7ba1\u7406\u7684\u8fde\u63a5\u4fe1\u606f\u5bfc\u81f4Connection\u88ab\u91ca\u653e，\u518d\u53bb\u5904\u7406\u4f1a\u51fa\u9519，\u56e0\u6b64\u5148\u8c03\u7528\u7528\u6237\u7684\u5173\u95ed\u670d\u52a1\u5668\u56de\u8c03\u51fd\u6570
\n if(_closed_callback)_closed_callback(shared_from_this());
\n \/\/6.\u8c03\u7528\u7ec4\u4ef6\u5185\u4e5f\u5c31\u662fConnection\u7684\u5173\u95ed\u56de\u8c03\u51fd\u6570
\n if(_server_closed_callback)_server_closed_callback(shared_from_this());
\n }<\/p>\n \/\/ void SendInLoop(const char* data,size_t len){
\n \/\/ if(_statu == DISCONNECTED)return ;
\n \/\/ _out_buffer.WriteAndPush(data,len);
\n \/\/ if(_channel.WriteAble()==false){
\n \/\/ _channel.EnableWrite();
\n \/\/ }
\n \/\/ }
\n \/\/\u8fd9\u4e2a\u63a5\u53e3\u5e76\u4e0d\u662f\u5b9e\u9645\u7684\u53d1\u9001\u63a5\u53e3，\u800c\u53ea\u662f\u628a\u6570\u636e\u653e\u5230\u4e86\u53d1\u9001\u7f13\u51b2\u533a，\u56e0\u4e3a\u5df2\u7ecf\u542f\u52a8\u4e86\u53ef\u5199\u4e8b\u4ef6\u76d1\u63a7
\n void SendInLoop(Buffer &buf) {
\n if (_statu == DISCONNECTED) return ;
\n _out_buffer.WriteBufferAndPush(buf);
\n \/\/\u6211\u5199\u5230\u53d1\u9001\u7f13\u51b2\u533a\u4e86，\u5982\u679c\u6ca1\u6709\u76d1\u63a7\u5199\u7f13\u51b2\u533a\u5c31\u542f\u52a8\u76d1\u63a7
\n if (_channel.WriteAble() == false) {
\n _channel.EnableWrite();
\n }
\n }
\n void ShutdownInLoop(){
\n _statu = DISCONNECTING;\/\/\u8bbe\u7f6e\u8fde\u63a5\u4e3a\u534a\u5173\u95ed\u72b6\u6001
\n if(_in_buffer.ReadAbleSize()>0){
\n if(_message_callback)_message_callback(shared_from_this(),&_in_buffer);
\n }
\n \/\/\u8981\u4e48\u5c31\u662f\u5199\u5165\u6570\u636e\u7684\u65f6\u5019\u51fa\u9519\u5173\u95ed，\u8981\u4e48\u5c31\u662f\u4e48\u6709\u5f85\u53d1\u9001\u6570\u636e，\u76f4\u63a5\u5173\u95ed
\n \/\/\u867d\u7136SendLoop\u51fd\u6570\u4e2d\u505a\u4e86\u5199\u4e8b\u4ef6\u76d1\u63a7\u7684\u5224\u65ad，\u4f46\u662f\u8fd9\u6837\u66f4\u52a0\u4f18\u96c5，\u9632\u6b62\u4ee3\u7801\u7455\u75b5\u3002\u66f4\u52a0\u5b89\u5168
\n if(_out_buffer.ReadAbleSize()>0){
\n if(_channel.WriteAble() == false){
\n _channel.EnableWrite();
\n }
\n }
\n if(_out_buffer.ReadAbleSize() == 0){
\n Release();
\n }
\n }
\n \/\/\u542f\u52a8\u975e\u6d3b\u8dc3\u8fde\u63a5\u8d85\u65f6\u91ca\u653e\u89c4\u5219
\n void EnableInactiveReleaseInLoop(int sec){
\n \/\/1.\u5c06\u5224\u65ad\u6807\u5fd7 _enable_inactive_release \u7f6e\u4e3atrue
\n _enable_inactive_release = true;
\n \/\/2.\u5982\u679c\u5f53\u524d\u5b9a\u65f6\u9500\u6bc1\u4efb\u52a1\u5df2\u7ecf\u5b58\u5728，\u90a3\u5c31\u5237\u65b0\u4e00\u4e0b\u5ef6\u8fdf\u5373\u53ef
\n if(_loop->HashTimer(_conn_id))return _loop->TimerRefresh(_conn_id);
\n \/\/3.\u5982\u679c\u4e0d\u5b58\u5728\u5b9a\u65f6\u9500\u6bc1\u4efb\u52a1，\u5219\u65b0\u589e
\n _loop->TimerAdd(_conn_id,sec,std::bind(&Connection::Release,this));
\n }
\n \/\/\u53d6\u6d88\u975e\u6d3b\u8dc3\u8fde\u63a5\u8d85\u65f6\u91ca\u653e\u89c4\u5219
\n void CancelInactiveReleaseInLoop(){
\n _enable_inactive_release = false;
\n \/\/\u5b58\u5728\u5219\u53d6\u6d88
\n if(_loop->HashTimer(_conn_id))return _loop->TimerCancel(_conn_id);
\n }
\n \/\/\u66f4\u65b0\u534f\u8bae
\n void UpgradeInLoop(const Any & context ,
\n const ConnectedCallback& conn,
\n MessageCallback& msg,
\n CloseCallback& closed,
\n AnyEventCallback& event){
\n _context=context;
\n _connected_callback=conn;
\n _message_callback=msg;
\n _closed_callback=closed;
\n _event_callback=event;
\n }<\/p>\n \/\/\u9664\u6b64\u4e4b\u5916\u8fd8\u6709\u4e94\u4e2achannel\u7684\u4e8b\u4ef6\u56de\u8c03\u51fd\u6570
\n \/\/\u89e6\u53d1\u53ef\u8bfb\u4e8b\u4ef6\u540e\u8c03\u7528\u7684\u51fd\u6570，\u63a5\u53d7socket\u6570\u636e\u653e\u5230\u63a5\u53d7\u7f13\u51b2\u533a\u4e2d，\u7136\u540e\u8c03\u7528_message_callback\u5904\u7406
\n void HandleRead(){
\n \/\/1.\u63a5\u53d7socket\u6570\u636e，\u653e\u5230\u7f13\u51b2\u533a
\n char buf[65536];
\n ssize_t ret = _socket.NonBlockRecv(buf,65535);
\n if(ret < 0){
\n \/\/\u51fa\u9519\u4e86，\u4e0d\u80fd\u76f4\u63a5\u5173\u95ed\u8fde\u63a5，\u8981\u770b\u6570\u636e\u8fd8\u6709\u6ca1\u6709\u8981\u5904\u7406\u7684\u6216\u5f85\u5904\u7406\u7684\u3002
\n return ShutdownInLoop();\/\/\u7136\u540e\u5728\u51fd\u6570\u4e2d，\u5224\u65ad\u662f\u5426\u662f\u5f85\u5173\u95ed\u8fde\u63a5\u7684\u72b6\u6001\u3002\u8fd8\u6709\u5c31\u662f\u53ea\u6709\u8fde\u63a5\u5904\u7406\u5b8c\u540e\u624d\u53bb\u5b9a\u4e00\u4e2a\u52a0\u65f6\u6216\u8005\u5237\u65b0，\u4e0d\u7136\u6211\u8fde\u63a5\u4e1a\u52a1\u53ef\u80fd\u6ca1\u5904\u7406\u5b8c\u5c31\u8d85\u65f6\u5173\u95ed\u4e4b\u7c7b\u7684\u4e86
\n }
\n \/\/ else if(ret == 0){
\n \/\/ \/\/\u8fd9\u91cc\u7684\u7b49\u4e8e0\u8868\u793a\u7684\u662f\u6ca1\u6709\u8bfb\u53d6\u5230\u6570\u636e，\u800c\u5e76\u4e0d\u662f\u8fde\u63a5\u65ad\u5f00\u4e86，\u8fde\u63a5\u65ad\u5f00\u8fd4\u56de\u7684\u662f-1
\n \/\/ \/\/\u4f46\u662f\u53ef\u4ee5\u4e0d\u5199\u56e0\u4e3a\u5728Write\u51fd\u6570\u4e2d\u6211\u4eec\u8fd8\u8bbe\u7f6e\u4e86ret==0 \u5c31return\u7684\u60c5\u51b5\u3002
\n \/\/ return;
\n \/\/ }
\n \/\/\u5c06\u6570\u636e\u653e\u5165\u8f93\u5165\u7f13\u51b2\u533a
\n _in_buffer.WriteAndPush(buf,ret);
\n \/\/2.\u8c03\u7528message_callback\u8fdb\u884c\u4e1a\u52a1\u5904\u7406
\n if(_in_buffer.ReadAbleSize()>0){
\n \/\/shared_from_this–\u4ece\u5f53\u524d\u5bf9\u8c61\u81ea\u8eab\u83b7\u53d6\u81ea\u8eab\u7684shared_ptr\u7ba1\u7406\u5bf9\u8c61
\n \/\/\u8fd9\u5c31\u662fret ==0 \u7684\u60c5\u51b5，\u4e0d\u8fc7\u6211\u5199\u4e86else if\u8fd9\u91cc\u6c38\u8fdc\u6210\u7acb ，\u6709\u6570\u636e\u5c31\u8fdb\u884c\u4e1a\u52a1\u5904\u7406
\n return _message_callback(shared_from_this(),&_in_buffer);
\n }
\n }
\n \/\/\u63cf\u8ff0\u7b26\u53ef\u5199\u4e8b\u4ef6\u89e6\u53d1\u540e\u8c03\u7528\u7684\u51fd\u6570，\u5c06\u53d1\u9001\u7f13\u51b2\u533a\u4e2d\u7684\u6570\u636e\u8fdb\u884c\u53d1\u9001\u3002
\n void HandleWrite(){
\n ssize_t ret = _socket.NonBlockSend(_out_buffer.ReadPosition(),_out_buffer.ReadAbleSize());
\n if(ret<0){
\n \/\/\u51fa\u9519\u4e86\u8981\u5173\u95ed
\n \/\/\u4f46\u662f\u60f3\u8981\u628a\u7f13\u51b2\u533a\u4e2d\u7684\u6570\u636e\u5148\u5904\u7406\u4e86
\n if(_in_buffer.ReadAbleSize()>0){
\n _message_callback(shared_from_this(),&_in_buffer);
\n }
\n \/\/\u6ca1\u6709\u5c31\u91ca\u653e
\n return Release();\/\/\u8fd9\u65f6\u5019\u5c31\u662f\u5b9e\u9645\u7684\u5173\u95ed\u91ca\u653e\u64cd\u4f5c\u4e86\u3002\u56e0\u4e3a\u53d1\u9001\u5b8c\u4e86\u6211\u5c31\u4e0d\u9700\u8981\u7ee7\u7eed\u5904\u7406\u4e86\u3002
\n }
\n _out_buffer.MoveReadOffset(ret);\/\/\u8fd8\u8981\u5c06\u6211\u4eec\u7684\u8bfb\u504f\u79fb\u5411\u540e\u504f\u79fb
\n if(_out_buffer.ReadAbleSize() == 0){
\n _channel.DisableWrite();\/\/\u5173\u95ed\u5199\u4e8b\u4ef6\u76d1\u63a7，\u7f13\u51b2\u533a\u5df2\u7ecf\u6ca1\u6709\u6570\u636e\u4e86，\u5c31\u4e0d\u8981\u76d1\u63a7\u5199\u4e86(\u4e0d\u65ad\u7684\u89e6\u53d1\u5199\u4e8b\u4ef6，\u53c8\u6ca1\u6709\u4e8b\u4ef6\u53ef\u5199LoopBusy)，LT\u6a21\u5f0f\u4e0b\u5982\u679c\u6709\u6570\u636e\u5c31\u4f1a\u4e00\u76f4\u63d0\u793a-ET
\n \/\/\u56de\u987eepoll\u7684\u76d1\u63a7，\u63a5\u6536\u7f13\u51b2\u533a\u53ea\u8981\u6709\u6570\u636e\u53ef\u8bfb\u5c31\u89e6\u53d1\u8bfb\u4e8b\u4ef6，\u53d1\u9001\u7f13\u51b2\u533a\u53ea\u8981\u6709\u7a7a\u95f2\u7a7a\u95f4\u5c31\u89e6\u53d1\u5199\u4e8b\u4ef6\u3002
\n \/\/\u5982\u679c\u5f53\u524d\u662f\u8fde\u63a5\u5f85\u5173\u95ed\u72b6\u6001，\u5219\u6709\u6570\u636e，\u53d1\u9001\u5b8c\u8fde\u63a5\u6570\u636e\u91ca\u653e\u8fde\u63a5，\u6ca1\u6709\u6570\u636e\u5219\u76f4\u63a5\u91ca\u653e
\n if(_statu == DISCONNECTING){
\n return Release();
\n }
\n }
\n return;
\n }
\n \/\/\u63cf\u8ff0\u7b26\u89e6\u53d1\u6302\u65ad\u4e8b\u4ef6
\n void HandleClose(){
\n \/\/\u4e00\u65e6\u8fde\u63a5\u6302\u65ad\u4e86，\u5957\u63a5\u5b57\u5c31\u4ec0\u4e48\u90fd\u5e72\u4e0d\u4e86，\u56e0\u6b64\u6709\u6570\u636e\u5f85\u5904\u7406\u5c31\u5904\u7406\u4e00\u4e0b，\u5b8c\u6bd5\u5173\u95ed\u8fde\u63a5
\n if(_in_buffer.ReadAbleSize()>0){
\n _message_callback(shared_from_this(),&_in_buffer);
\n }
\n return Release();
\n }
\n \/\/\u63cf\u8ff0\u7b26\u89e6\u53d1\u51fa\u9519\u4e8b\u4ef6
\n void HandleError(){
\n return HandleClose();
\n }
\n \/\/\u63cf\u8ff0\u7b26\u89e6\u53d1\u4efb\u610f\u4e8b\u4ef6\u30021.\u5237\u65b0\u8fde\u63a5\u7684\u6d3b\u8dc3\u5ea6-\u5ef6\u8fdf\u5b9a\u65f6\u9500\u6bc1\u4efb\u52a1\u30022.\u8c03\u7528\u7ec4\u4ef6\u4f7f\u7528\u8005\u7684\u4efb\u610f\u4e8b\u4ef6\u56de\u8c03
\n void HandleEvent(){
\n \/\/\u542f\u52a8\u4e86\u975e\u6d3b\u8dc3\u9500\u6bc1
\n if(_enable_inactive_release == true){
\n _loop->TimerRefresh(_conn_id);
\n }
\n if(_event_callback)_event_callback(shared_from_this());
\n }
\n public:
\n Connection(EventLoop* loop,uint64_t conn_id ,int sockfd):_conn_id(conn_id),
\n _sockfd(sockfd),_enable_inactive_release(false),_loop(loop),
\n _statu(CONNECTING),_socket(_sockfd),_channel(loop,sockfd)
\n {
\n _channel.SetCloseCallback(std::bind(&Connection::HandleClose,this));
\n _channel.SetEventCallback(std::bind(&Connection::HandleEvent,this));
\n _channel.SetReadCallback(std::bind(&Connection::HandleRead,this));
\n _channel.SetErrorCallback(std::bind(&Connection::HandleError,this));
\n _channel.SetWriteCallback(std::bind(&Connection::HandleWrite,this));
\n }
\n ~Connection(){DBG_LOG("\u91ca\u653e\u8fde\u63a5\u7c7b:%p",this);}
\n \/\/\u53d1\u9001\u6570\u636e\u5230\u7f13\u51b2\u533a，\u542f\u52a8\u4e8b\u4ef6\u76d1\u63a7，\u56e0\u4e3a\u8fd9\u53ea\u662f\u7528\u6237\u8c03\u7528\u63a5\u53e3，\u6211\u4eec\u8fd8\u8981\u5904\u7406\u7f13\u51b2\u533a\u6570\u636e(\u534f\u8bae，\u7c98\u5305，\u662f\u5426\u5b8c\u6574\u7b49)，\u771f\u6b63\u53d1\u9001\u662fepoll\u76d1\u63a7\u5199\u4e8b\u4ef6\u540e\u8c03\u7528socket.send()\u53d1\u9001
\n void Send(const char* data,size_t len){
\n \/\/ _loop->RunInLoop(std::bind(&Connection::SendInLoop,this,data,len));
\n \/\/\u5916\u754c\u4f20\u5165\u7684data，\u53ef\u80fd\u662f\u4e2a\u4e34\u65f6\u7684\u7a7a\u95f4，\u6211\u4eec\u73b0\u5728\u53ea\u662f\u628a\u53d1\u9001\u64cd\u4f5c\u538b\u5165\u4e86\u4efb\u52a1\u6c60，\u6709\u53ef\u80fd\u5e76\u6ca1\u6709\u88ab\u7acb\u5373\u6267\u884c
\n \/\/\u56e0\u6b64\u6709\u53ef\u80fd\u6267\u884c\u7684\u65f6\u5019，data\u6307\u5411\u7684\u7a7a\u95f4\u6709\u53ef\u80fd\u5df2\u7ecf\u88ab\u91ca\u653e\u4e86\u3002
\n Buffer buf;
\n buf.WriteAndPush(data, len);
\n _loop->RunInLoop(std::bind(&Connection::SendInLoop, this, std::move(buf)));
\n }
\n \/\/\u63d0\u4f9b\u7ed9\u7ec4\u4ef6\u4f7f\u7528\u8005\u7684\u5173\u95ed\u63a5\u53e3–\u5e76\u4e0d\u5b9e\u9645\u5173\u95ed，\u9700\u8981\u5224\u65ad\u6709\u6ca1\u6709\u6570\u636e\u5f85\u5904\u7406
\n void Shutdown(){
\n _loop->RunInLoop(std::bind(&Connection::ShutdownInLoop,this));
\n }
\n void Release(){
\n _loop->QueueInLoop(std::bind(&Connection::ReleaseInLoop,this));
\n }
\n \/\/\u542f\u52a8\u975e\u6d3b\u8dc3\u9500\u6bc1，\u5e76\u5b9a\u4e49\u591a\u957f\u65f6\u95f4\u65e0\u901a\u4fe1\u5c31\u662f\u975e\u6d3b\u8dc3，\u6dfb\u52a0\u5b9a\u65f6\u4efb\u52a1
\n void EnableInactiveRelease(int sec){
\n _loop->RunInLoop(std::bind(&Connection::EnableInactiveReleaseInLoop,this,sec));
\n }
\n \/\/\u53d6\u6d88\u975e\u6d3b\u8dc3\u9500\u6bc1
\n void CancelInactiveRelease(){
\n _loop->RunInLoop(std::bind(&Connection::CancelInactiveReleaseInLoop,this));
\n }<\/p>\n \/\/\u94fe\u63a5\u5efa\u7acb\u5c31\u7eea\u540e，\u8fdb\u884cChannel\u56de\u8c03\u8bbe\u7f6e，\u5e76\u8c03\u7528connect_cb
\n void Established(){
\n _loop->RunInLoop(std::bind(&Connection::EstablIsShedInLoop,this));
\n }
\n \/\/\u5207\u6362\u534f\u8bae–\u91cd\u7f6e\u4e0a\u4e0b\u6587\u4ee5\u53ca\u9636\u6bb5\u6027\u5904\u7406\u51fd\u6570 — \u8fd9\u662f\u975e\u7ebf\u7a0b\u5b89\u5168\u7684，\u5fc5\u987b\u5728\u7ebf\u7a0b\u5f53\u4e2d\u7acb\u5373\u6267\u884c，\u9632\u6b62\u6211\u8981\u5728A\u540e\u5207\u6362\u534f\u8bae，\u4f46\u662f\u591a\u7ebf\u7a0b\u53ef\u80fdA\u8fd8\u6ca1\u7ed3\u675f\u534f\u8bae\u5148\u6267\u884c\u4e86\u534f\u8bae\u4e86\u8fd9\u79cd\u60c5\u51b5\u3002
\n void Upgrade(const Any & context,
\n const ConnectedCallback& conn,
\n MessageCallback& msg,
\n CloseCallback& closed,
\n AnyEventCallback& event){
\n _loop->AssertInLoop();
\n _loop->RunInLoop(std::bind(&Connection::UpgradeInLoop,this,context,conn,msg,closed,event));
\n }<\/p>\n \/\/\u5bf9\u4e8eConnection\u7684\u5176\u4f59\u63a5\u53e3
\n \/\/\u6210\u5458\u521d\u59cb\u5316\u63a5\u53e3，\u83b7\u53d6\u6210\u5458\u63a5\u53e3
\n int Fd(){return _sockfd;}
\n int Id(){return _conn_id;}
\n \/\/ ConnStatu Statu();\/\/\u8fd4\u56de\u4e00\u4e2a\u8fde\u63a5\u7684\u8f6c\u6001
\n \/\/ \/\/\u4f46\u662f\u6211\u4eec\u771f\u6b63\u5173\u5fc3\u7684\u662f\u662f\u5426\u5904\u4e8e\u8fde\u63a5CONNECTED\u7684\u72b6\u6001
\n bool Connected(){return (_statu == CONNECTED);}
\n \/\/\u83b7\u53d6\u4e0a\u4e0b\u6587\u4fe1\u606f，\u8fd4\u56de\u7684\u662f\u6307\u9488
\n Any* GetContext(){return &_context;}
\n \/\/\u8bbe\u7f6e\u6210\u5458\u521d\u59cb\u5316
\n void SetContext(const Any& context){_context = context;}
\n \/\/\u8bbe\u7f6e\u4e0a\u4e0b\u6587\u4fe1\u606f，\u8fde\u63a5\u5efa\u7acb\u5b8c\u6210\u9636\u6bb5(???\u6216\u8005\u5047\u8bbe\u534f\u8bae\u5207\u6362\u4e86，\u540c\u6837\u4e5f\u8981\u628a\u4e4b\u524d\u7684\u4e0a\u4e0b\u6587\u4fe1\u606f\u4fee\u6539\u6210\u65b0\u7684\u534f\u8bae\u4e0a\u4e0b\u6587\u4fe1\u606f)
\n void SetConnectedCallback(const ConnectedCallback& cb){_connected_callback=cb;}
\n void SetMessageCallback(const MessageCallback& cb){_message_callback=cb;}
\n void SetClosedCallback(const CloseCallback& cb){_closed_callback=cb;}
\n void SetSrvClosedCallback(const CloseCallback& cb){_server_closed_callback=cb;}
\n void SetAnyEventCallback(const AnyEventCallback& cb){_event_callback=cb;}
\n}; <\/p>\n \u00a0 \u00a0 \u00a0 \u00a0 \u6838\u5fc3\u8fd8\u662f\u5e95\u5c42\u7684Channel\u7c7bepoll\u5bf9\u5c31\u7eea\u4e8b\u4ef6\u7684\u7ba1\u7406，\u7279\u70b9\u662f\u8fd9\u91cc\u8fd8\u5904\u7406\u4e86\u591a\u7ebf\u7a0b\u4e5f\u5c31\u662f\u5355\u8fde\u63a5\u591a\u7ebf\u7a0b\u7684\u573a\u666f\u4e0b\u7684\u4efb\u52a1\u6c60\u5904\u7406\u3002<\/p>\n 4.5.3\u00a0TcpServer\u7c7b\u2014\u2014\u670d\u52a1\u5668\u5165\u53e3\u7c7b<\/h4>\n\u00a0 \u00a0 \u00a0 \u00a0 TcpServer\u7c7b\u5c31\u662f\u5bf9\u4e0a\u9762\u7684Acceptor\u7c7b\u548cConnection\u4ee5\u53ca\u7ebf\u7a0b\u6c60\u7684\u6838\u5fc3\u5c01\u88c5，\u7528_conns\u7ba1\u7406\u6240\u6709\u7684\u8fde\u63a5\u3002TcpServer\u7c7b\u5c31\u6bd4\u8f83\u7b80\u5355\u4e86\u5404\u79cd\u51fd\u6570\u5c31\u662f\u5bf9\u8fde\u63a5\u7684\u5904\u7406\u51fd\u6570，\u4ee5\u53ca\u6dfb\u52a0\u5b9a\u65f6\u4efb\u52a1\u3002\u6700\u6838\u5fc3\u7684\u5c31\u662fNewConnection\u51fd\u6570\u8bbe\u7f6e\u7ed9Acceptor\u7136\u540eAcceptor\u624d\u53ef\u4ee5\u5728\u65b0\u8fde\u63a5\u6765\u7684\u65f6\u5019\u521b\u5efaConnection\u7c7b\u7ed9\u65b0\u5ba2\u6237\u7aef\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n class TcpServer{
\n private:
\n uint64_t _next_id; \/\/\u81ea\u52a8\u589e\u957f\u7684\u8fde\u63a5ID
\n int _port; \/\/\u670d\u52a1\u5668\u6240\u6302\u8f7d\u7684\u7aef\u53e3
\n int _timeout; \/\/\u975e\u6d3b\u8dc3\u94fe\u63a5\u7684\u7edf\u8ba1\u65f6\u95f4
\n \/\/\u5728_acceptor\u4e4b\u524d\u6211\u4eec\u8981\u628a_baseloop\u5b9e\u4f8b\u5316\u51fa\u6765
\n EventLoop _baseloop; \/\/\u4e3b\u7ebf\u7a0b\u7684EventLoop\u5bf9\u8c61，\u8d1f\u8d23\u76d1\u542c\u4e8b\u4ef6\u7684\u5904\u7406
\n Acceptor _acceptor; \/\/\u76d1\u542c\u5957\u63a5\u5b57\u7684\u7ba1\u7406\u5bf9\u8c61
\n LoopThreadPoll _pool; \/\/\u4ece\u5c5eEventLoop\u7684\u7ebf\u7a0b\u6c60
\n bool _enable_inactive_release;\/\/\u662f\u5426\u542f\u52a8\u4e86\u975e\u6d3b\u8dc3\u94fe\u63a5\u9500\u6bc1\u7684\u5224\u65ad\u6807\u5fd7
\n std::unordered_map<uint64_t,PtrConnection> _conns;\/\/\u4fdd\u5b58\u7ba1\u7406\u6240\u6709\u8fde\u63a5\u5bf9\u5e94\u7684shared_ptr\u5bf9\u8c61
\n private:
\n \/\/\u56de\u8c03\u51fd\u6570\u2014\u2014Connection\u7684\u56de\u8c03\u51fd\u6570
\n using ConnectedCallback = std::function<void(const PtrConnection &)>;
\n using MessageCallback = std::function<void(const PtrConnection &,Buffer *)>;
\n using CloseCallback = std::function<void(const PtrConnection &)>;
\n using AnyEventCallback = std::function<void(const PtrConnection &)>;
\n ConnectedCallback _connected_callback;
\n MessageCallback _message_callback;
\n CloseCallback _closed_callback;
\n AnyEventCallback _event_callback;
\n private:
\n void RemoveConnectionInLoop(const PtrConnection &conn){
\n int id=conn->Id();
\n auto it=_conns.find(id);
\n if(it!=_conns.end())
\n _conns.erase(id);
\n }
\n \/\/\u4ece\u7ba1\u7406\u7684_conns\u4e2d\u79fb\u9664\u5bf9\u5e94\u8fde\u63a5\u4fe1\u606f，\u8fd9\u4e2a\u8fde\u63a5\u624d\u4f1a\u771f\u6b63\u7684\u91ca\u653e\u3002\u8fd9\u5b9e\u9645\u4e0a\u5c31\u662f\u670d\u52a1\u5668\u4e2d\u7684close\u4e5f\u5c31\u662fSrvClosedCallback
\n void RemoveConnection(const PtrConnection &conn){
\n _baseloop.RunInLoop(std::bind(&TcpServer::RemoveConnectionInLoop,this,conn));
\n }
\n \/\/\u4e3a\u65b0\u94fe\u63a5\u6784\u9020\u4e00\u4e2aConnection\u8fdb\u884c\u7ba1\u7406
\n void NewConnection(int fd){
\n _next_id++;
\n PtrConnection conn(new Connection(_pool.NextLoop(), _next_id,fd));
\n \/\/\u8fd9\u91cc\u7684\u8bbe\u7f6e\u987a\u5e8f\u4e0d\u80fd\u4e71，\u56e0\u4e3a\u5728Established\u51fd\u6570\u4e2d\u4f1a\u5148\u8c03\u7528Message_cb\u51fd\u6570\u6240\u4ee5Message
\n conn->SetMessageCallback(_message_callback);
\n conn->SetClosedCallback(_closed_callback);
\n conn->SetConnectedCallback(_connected_callback);
\n conn->SetAnyEventCallback(_event_callback);
\n conn->SetSrvClosedCallback(std::bind(&TcpServer::RemoveConnection,this,std::placeholders::_1));
\n if(_enable_inactive_release)conn->EnableInactiveRelease(_timeout);
\n conn->Established();
\n _conns.insert(std::make_pair(_next_id,conn));\/\/\u7ba1\u7406\u8d77\u6765\u4e0d\u7136\u76f4\u63a5\u91ca\u653e\u4e86\u5c31\u7528\u4e0d\u4e86\u4e86
\n }<\/p>\n \/\/\u6dfb\u52a0\u5b9a\u65f6\u4efb\u52a1
\n void RunAfterInLoop(const Functor& task,int delay){
\n _next_id++;
\n _baseloop.TimerAdd(_next_id,delay,task);
\n }
\n public:
\n TcpServer(int port):_next_id(0),_port(port),_timeout(5),\/\/\u9ed8\u8ba45s
\n _acceptor(&_baseloop,_port),
\n _pool(&_baseloop),
\n _enable_inactive_release(false){
\n \/\/ _acceptor.Listen();\/\/Listen\u4e0d\u80fd\u6302\u5230\u8fd9\u91cc\u56e0\u4e3a\u670d\u52a1\u5668\u7684\u5176\u4ed6\u8bbe\u7f6e\u8fd8\u6ca1\u8bbe\u7f6e\u597d
\n \/\/ _pool.Create();\/\/\u521b\u5efa\u7ebf\u7a0b\u6c60\u7684\u4ece\u5c5e\u7ebf\u7a0b,\u4f46\u662f\u4e0d\u80fd\u653e\u5230\u6784\u5efa\u51fd\u6570\u4e2d，\u56e0\u4e3a\u6b64\u65f6\u8fd8\u6ca1\u6709\u8bbe\u7f6eSetThreadCount\u6240\u4ee5\u7ebf\u7a0b\u6570\u91cf\u9ed8\u8ba4\u662f0
\n _acceptor.SetAcceptCallback(std::bind(&TcpServer::NewConnection,this,std::placeholders::_1));
\n _acceptor.Listen();\/\/\u5c06\u76d1\u542c\u5957\u63a5\u5b57\u6302\u5230baseloop\u4e0a\u5f00\u59cb\u76d1\u63a7\u4e8b\u4ef6
\n }
\n void SetThreadCount(int count){_pool.SetThreadCount(count);}
\n void Start(){_pool.Create();_baseloop.Start();}
\n void EnableInactiveRelease(int timeout){_timeout=timeout;_enable_inactive_release=true;}
\n \/\/\u7528\u4e8e\u6dfb\u52a0\u4e00\u4e2a\u5b9a\u65f6\u4efb\u52a1
\n void RunAfter(const Functor& task,int delay){
\n _baseloop.RunInLoop(std::bind(&TcpServer::RunAfterInLoop,this,task,delay));
\n }
\n \/\/\u8bbe\u7f6e\u56de\u8c03\u51fd\u6570
\n void SetConnectedCallback(const ConnectedCallback& cb){_connected_callback=cb;}
\n void SetMessageCallback(const MessageCallback& cb){_message_callback=cb;}
\n void SetClosedCallback(const CloseCallback& cb){_closed_callback=cb;}
\n void SetAnyEventCallback(const AnyEventCallback& cb){_event_callback=cb;}
\n};<\/p>\n \u4e94：\u9879\u76ee\u603b\u7ed3<\/h2>\n\u00a0 \u00a0 \u00a0 \u00a0 \u4e00\u4e2a\u5b8c\u6574\u7684\u4effmuduo\u5e93\u7684\u9ad8\u6027\u80fd\u670d\u52a1\u5668\u9879\u76ee\u4ee3\u7801\u5c31\u662f\u8fd9\u6837，\u6574\u4f53\u770b\u4e0b\u6765\u6838\u5fc3\u6280\u672f\u548c\u6574\u4f53\u7684\u6846\u67b6\u4e4b\u95f4\u7684\u8054\u7cfb\u8fd8\u662f\u6bd4\u8f83\u901a\u900f\u7684，\u6700\u4e3b\u8981\u7684\u6838\u5fc3\u5c31\u662fChannel\u7c7b\u548cEventLoop\u7c7b，Channel\u662fepoll\u7684\u6838\u5fc3\u8d1f\u8d23\u5bf9\u4e8b\u4ef6\u7684\u76d1\u63a7\u5df2\u7ecf\u8fd4\u56de\u5c31\u7eea\u4e8b\u4ef6，EventLoop\u662fReactor\u7684\u6838\u5fc3\u8d1f\u8d23\u83b7\u53d6\u5c31\u7eea\u4e8b\u4ef6\u548c\u5bf9\u5c31\u7eea\u4e8b\u4ef6\u7684\u5904\u7406\u5df2\u7ecf\u5bf9\u4efb\u52a1\u6c60\u4e2d\u7684\u4efb\u52a1\u5904\u7406\u3002<\/p>\n \u6838\u5fc3\u6280\u672f\u4eae\u70b9<\/h5>\n\n- \u7ebf\u7a0b\u6a21\u578b\u4f18\u5316：LoopThreadPoll \u5b9e\u73b0\u8fde\u63a5\u7684 RR \u8f6e\u8be2\u5206\u914d，\u5145\u5206\u5229\u7528\u591a\u6838 CPU，\u89e3\u51b3\u5355\u7ebf\u7a0b Reactor \u7684\u6027\u80fd\u74f6\u9888；<\/li>\n
- \u5b9a\u65f6\u5668\u9ad8\u6548\u5b9e\u73b0：\u57fa\u4e8e timerfd \u7684\u5355\u5c42\u65f6\u95f4\u8f6e\u5b9a\u65f6\u5668，O (1) \u65f6\u95f4\u590d\u6742\u5ea6\u5904\u7406\u77ed\u5b9a\u65f6\u4efb\u52a1，\u9002\u914d\u8fde\u63a5\u8d85\u65f6\u573a\u666f；<\/li>\n
- \u534f\u8bae\u7075\u6d3b\u9002\u914d：Any \u7c7b\u5b9e\u73b0\u7c7b\u578b\u64e6\u9664，\u652f\u6301 HTTP \/ \u81ea\u5b9a\u4e49\u534f\u8bae\u7684\u4e0a\u4e0b\u6587\u5b58\u50a8，\u65e0\u9700\u4fee\u6539\u6846\u67b6\u5373\u53ef\u6269\u5c55\u65b0\u534f\u8bae；<\/li>\n
- IO \u4e8b\u4ef6\u5b89\u5168\u5904\u7406：ET \u6a21\u5f0f + \u975e\u963b\u585e fd \u7684\u7ec4\u5408，\u907f\u514d\u6570\u636e\u6b8b\u7559\u548c\u7ebf\u7a0b\u5361\u6b7b，\u4fdd\u8bc1\u9ad8\u5e76\u53d1\u4e0b\u7684\u7a33\u5b9a\u6027\u3002<\/li>\n<\/ul>\n","protected":false},"excerpt":{"rendered":"
\u524d\u8a00： \u672c\u6587\u5b9e\u73b0\u7684\u662f\u4e00\u4e2a\u4effmuduo\u5e93\u6838\u5fc3\u8bbe\u8ba1\u7684\u9ad8\u6027\u80fdTCP\u670d\u52a1\u5668，\u57fa\u4e8e\u591aReactor\u6a21\u5f0fepoll\u591a\u7ebf\u7a0b\u65f6\u95f4\u8f6e\u5b9a\u65f6\u5668，\u8986\u76d6Linux\/C\u7f51\u7edc\u7f16\u7a0b\u6838\u5fc3\u77e5\u8bc6\u70b9\u3002 \u4f5c\u4e3a\u5b66\u4e60\u5b8cC\/Linux\u540e\u7684\u5b9e\u6218\u9879\u76ee，\u68b3\u7406\u5e95\u5c42\u7f51\u7edc\u6846\u67b6\u7684\u8bbe\u8ba1\u601d\u8def，\u4e5f\u4e3a\u5b9e\u4e60\u6c42\u804c\u592f\u5b9e\u5e95\u5c42\u7f16\u7a0b\u80fd\u529b\u3002 \u8bfb\u5b8c\u672c\u6587\u5e0c\u671b\u80fd\u5e2e\u4f60\u7406\u89e3\u591aReactor\u6a21\u5f0f\u7684\u843d\u5730\u5b9e\u73b0\u3001muduo\u6838\u5fc3\u6a21\u5757\u7684\u8bbe\u8ba1\u903b\u8f91，\u4ee5\u53caLinux\u7f51\u7edc\u7f16\u7a0b\u7684\u5173\u952e\u5751\u70b9\u3002\u9879\u76ee\u6e90\u7801gitee<\/p>\n","protected":false},"author":2,"featured_media":66700,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,3884,58,205,43],"topic":[],"class_list":["post-66701","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-c","tag-epoll","tag-linux","tag-tcp-ip","tag-43"],"yoast_head":"\n \u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09 - \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\/66701.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u524d\u8a00： \u672c\u6587\u5b9e\u73b0\u7684\u662f\u4e00\u4e2a\u4effmuduo\u5e93\u6838\u5fc3\u8bbe\u8ba1\u7684\u9ad8\u6027\u80fdTCP\u670d\u52a1\u5668，\u57fa\u4e8e\u591aReactor\u6a21\u5f0fepoll\u591a\u7ebf\u7a0b\u65f6\u95f4\u8f6e\u5b9a\u65f6\u5668，\u8986\u76d6Linux\/C\u7f51\u7edc\u7f16\u7a0b\u6838\u5fc3\u77e5\u8bc6\u70b9\u3002 \u4f5c\u4e3a\u5b66\u4e60\u5b8cC\/Linux\u540e\u7684\u5b9e\u6218\u9879\u76ee，\u68b3\u7406\u5e95\u5c42\u7f51\u7edc\u6846\u67b6\u7684\u8bbe\u8ba1\u601d\u8def，\u4e5f\u4e3a\u5b9e\u4e60\u6c42\u804c\u592f\u5b9e\u5e95\u5c42\u7f16\u7a0b\u80fd\u529b\u3002 \u8bfb\u5b8c\u672c\u6587\u5e0c\u671b\u80fd\u5e2e\u4f60\u7406\u89e3\u591aReactor\u6a21\u5f0f\u7684\u843d\u5730\u5b9e\u73b0\u3001muduo\u6838\u5fc3\u6a21\u5757\u7684\u8bbe\u8ba1\u903b\u8f91，\u4ee5\u53caLinux\u7f51\u7edc\u7f16\u7a0b\u7684\u5173\u952e\u5751\u70b9\u3002\u9879\u76ee\u6e90\u7801gitee\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/66701.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-01-27T03:25:12+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260127032509-697830154d07b.jpg\" \/>\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=\"26 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/66701.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/66701.html\",\"name\":\"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-01-27T03:25:12+00:00\",\"dateModified\":\"2026-01-27T03:25:12+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/66701.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/66701.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/66701.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09\"}]},{\"@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":"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09 - \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\/66701.html","og_locale":"zh_CN","og_type":"article","og_title":"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u524d\u8a00： \u672c\u6587\u5b9e\u73b0\u7684\u662f\u4e00\u4e2a\u4effmuduo\u5e93\u6838\u5fc3\u8bbe\u8ba1\u7684\u9ad8\u6027\u80fdTCP\u670d\u52a1\u5668，\u57fa\u4e8e\u591aReactor\u6a21\u5f0fepoll\u591a\u7ebf\u7a0b\u65f6\u95f4\u8f6e\u5b9a\u65f6\u5668，\u8986\u76d6Linux\/C\u7f51\u7edc\u7f16\u7a0b\u6838\u5fc3\u77e5\u8bc6\u70b9\u3002 \u4f5c\u4e3a\u5b66\u4e60\u5b8cC\/Linux\u540e\u7684\u5b9e\u6218\u9879\u76ee，\u68b3\u7406\u5e95\u5c42\u7f51\u7edc\u6846\u67b6\u7684\u8bbe\u8ba1\u601d\u8def，\u4e5f\u4e3a\u5b9e\u4e60\u6c42\u804c\u592f\u5b9e\u5e95\u5c42\u7f16\u7a0b\u80fd\u529b\u3002 \u8bfb\u5b8c\u672c\u6587\u5e0c\u671b\u80fd\u5e2e\u4f60\u7406\u89e3\u591aReactor\u6a21\u5f0f\u7684\u843d\u5730\u5b9e\u73b0\u3001muduo\u6838\u5fc3\u6a21\u5757\u7684\u8bbe\u8ba1\u903b\u8f91，\u4ee5\u53caLinux\u7f51\u7edc\u7f16\u7a0b\u7684\u5173\u952e\u5751\u70b9\u3002\u9879\u76ee\u6e90\u7801gitee","og_url":"https:\/\/www.wsisp.com\/helps\/66701.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-01-27T03:25:12+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260127032509-697830154d07b.jpg"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"26 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/66701.html","url":"https:\/\/www.wsisp.com\/helps\/66701.html","name":"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-01-27T03:25:12+00:00","dateModified":"2026-01-27T03:25:12+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/66701.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/66701.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/66701.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u3010C++\/Linux\u5b9e\u6218\u9879\u76ee\u3011\u4effmuduo\u5e93\u5b9e\u73b0\u9ad8\u6027\u80fdReactor\u6a21\u5f0fTCP\u670d\u52a1\u5668\uff08\u6df1\u5ea6\u89e3\u6790\uff09"}]},{"@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\/66701","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=66701"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/66701\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/66700"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=66701"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=66701"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=66701"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=66701"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} |
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260127032509-697830154d07b.jpg\")
<\/p>\n