![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105649-68038171109bb.png\")
<\/p>\nReactor \u662f\u4e00\u79cd\u5e94\u7528\u5728\u670d\u52a1\u5668\u7aef\u7684\u5f00\u53d1\u6a21\u5f0f（\u4e5f\u6709\u8bf4\u6cd5\u79f0 Reactor \u662f\u4e00\u79cd IO \u6a21\u5f0f），\u76ee\u7684\u662f\u63d0\u9ad8\u670d\u52a1\u7aef\u7a0b\u5e8f\u7684\u5e76\u53d1\u80fd\u529b<\/p>\n
\u5b83\u8981\u89e3\u51b3\u4ec0\u4e48\u95ee\u9898\u5462？<\/p>\n
\u4f20\u7edf\u7684 thread per connection \u7528\u6cd5\u4e2d，\u7ebf\u7a0b\u5728\u771f\u6b63\u5904\u7406\u8bf7\u6c42\u4e4b\u524d\u9996\u5148\u9700\u8981\u4ece socket \u4e2d\u8bfb\u53d6\u7f51\u7edc\u8bf7\u6c42，\u800c\u5728\u8bfb\u53d6\u5b8c\u6210\u4e4b\u524d，\u7ebf\u7a0b\u672c\u8eab\u88ab\u963b\u585e，\u4e0d\u80fd\u505a\u4efb\u4f55\u4e8b，\u8fd9\u5c31\u5bfc\u81f4\u7ebf\u7a0b\u8d44\u6e90\u88ab\u5360\u7528，\u800c\u7ebf\u7a0b\u8d44\u6e90\u672c\u8eab\u662f\u5f88\u73cd\u8d35\u7684，\u5c24\u5176\u662f\u5728\u5904\u7406\u9ad8\u5e76\u53d1\u8bf7\u6c42\u65f6\u3002\u00a0<\/p>\n
\u00a0 \u800c Reactor \u6a21\u5f0f\u6307\u51fa，\u5728\u7b49\u5f85 IO \u65f6，\u7ebf\u7a0b\u53ef\u4ee5\u5148\u9000\u51fa，\u8fd9\u6837\u5c31\u4e0d\u4f1a\u56e0\u4e3a\u6709\u7ebf\u7a0b\u5728\u7b49\u5f85 IO \u800c\u5360\u7528\u8d44\u6e90\u3002\u4f46\u662f\u8fd9\u6837\u539f\u5148\u7684\u6267\u884c\u6d41\u7a0b\u5c31\u6ca1\u6cd5\u8fd8\u539f\u4e86，\u56e0\u6b64，\u6211\u4eec\u53ef\u4ee5\u5229\u7528\u4e8b\u4ef6\u9a71\u52a8\u7684\u65b9\u5f0f，\u8981\u6c42\u7ebf\u7a0b\u5728\u9000\u51fa\u4e4b\u524d\u5411 event loop \u6ce8\u518c\u56de\u8c03\u51fd\u6570，\u8fd9\u6837 IO \u5b8c\u6210\u65f6 event loop \u5c31\u53ef\u4ee5\u8c03\u7528\u56de\u8c03\u51fd\u6570\u5b8c\u6210\u5269\u4f59\u7684\u64cd\u4f5c\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u6240\u4ee5\u8bf4，Reactor \u6a21\u5f0f\u901a\u8fc7\u51cf\u5c11\u670d\u52a1\u5668\u7684\u8d44\u6e90\u6d88\u8017，\u63d0\u9ad8\u4e86\u5e76\u53d1\u7684\u80fd\u529b\u3002\u5f53\u7136，\u4ece\u5b9e\u73b0\u89d2\u5ea6\u4e0a，\u4e8b\u4ef6\u9a71\u52a8\u7f16\u7a0b\u4f1a\u66f4\u96be\u5199，\u96be debug \u4e00\u4e9b\u3002<\/p>\n
\u6211\u4eec\u7528\u201c\u9910\u5385\u201d\u7c7b\u6bd4\u7684\u8bdd，\u5c31\u50cf\u4e0b\u56fe：<\/p>\n
\u5bf9\u4e8e\u6bcf\u4e2a\u65b0\u6765\u7684\u987e\u5ba2，\u524d\u53f0\u90fd\u9700\u8981\u627e\u5230\u4e00\u4e2a\u670d\u52a1\u5458\u548c\u53a8\u5e08\u6765\u670d\u52a1\u8fd9\u4e2a\u987e\u5ba2\u3002<\/p>\n
\u00a0\u00a0\u00a0\u8fd9\u5c31\u662f\u4f20\u7edf\u7684\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u3002\u6bcf\u4e2a\u987e\u5ba2\u90fd\u6709\u81ea\u5df1\u7684\u670d\u52a1\u56e2\u961f（\u7ebf\u7a0b），\u5728\u4eba\u5c11\u7684\u60c5\u51b5\u4e0b\u662f\u53ef\u4ee5\u826f\u597d\u7684\u8fd0\u4f5c\u7684\u3002\u73b0\u5728\u9910\u5385\u7684\u53e3\u7891\u597d，\u987e\u5ba2\u4eba\u6570\u4e0d\u65ad\u589e\u52a0，\u8fd9\u65f6\u670d\u52a1\u5458\u5c31\u6709\u70b9\u5904\u7406\u4e0d\u8fc7\u6765\u4e86\u3002<\/p>\n
\u8fd9\u65f6\u8001\u677f\u53d1\u73b0，\u6bcf\u4e2a\u670d\u52a1\u5458\u5728\u670d\u52a1\u5b8c\u5ba2\u4eba\u540e，\u90fd\u8981\u53bb\u4f11\u606f\u4e00\u4e0b，\u56e0\u6b64\u8001\u677f\u5c31\u8bf4，\u201c\u4f60\u4eec\u90fd\u522b\u4f11\u606f\u4e86，\u5728\u65c1\u8fb9\u5f85\u547d\u201d\u3002\u8fd9\u6837\u53ef\u80fd 10 \u4e2a\u670d\u52a1\u5458\u4e5f\u6765\u5f97\u53ca\u670d\u52a1 20 \u4e2a\u987e\u5ba2\u4e86\u3002\u8fd9\u4e5f\u662f\u201c\u7ebf\u7a0b\u6c60\u201d\u7684\u65b9\u5f0f，\u901a\u8fc7\u91cd\u7528\u7ebf\u7a0b\u6765\u51cf\u5c11\u7ebf\u7a0b\u7684\u521b\u5efa\u548c\u9500\u6bc1\u65f6\u95f4，\u4ece\u800c\u63d0\u9ad8\u6027\u80fd\u3002<\/p>\n
\u00a0\u00a0\u4f46\u662f\u5ba2\u4eba\u53c8\u8fdb\u4e00\u6b65\u589e\u52a0\u4e86，\u4ec5\u4ec5\u9760\u5265\u524a\u670d\u52a1\u5458\u7684\u4f11\u606f\u65f6\u95f4\u4e5f\u6ca1\u6709\u529e\u6cd5\u670d\u52a1\u8fd9\u4e48\u591a\u5ba2\u4eba\u3002\u8001\u677f\u4ed4\u7ec6\u89c2\u5bdf，\u53d1\u73b0\u5176\u5b9e\u670d\u52a1\u5458\u5e76\u4e0d\u662f\u4e00\u76f4\u5728\u5e72\u6d3b\u7684，\u5927\u90e8\u5206\u65f6\u95f4\u4ed6\u4eec\u53ea\u662f\u7ad9\u5728\u9910\u684c\u65c1\u8fb9\u7b49\u5ba2\u4eba\u70b9\u83dc\u3002<\/p>\n
\u00a0\u00a0\u4e8e\u662f\u8001\u677f\u5c31\u5bf9\u670d\u52a1\u5458\u8bf4，\u5ba2\u4eba\u70b9\u83dc\u7684\u65f6\u5019\u4f60\u4eec\u5c31\u522b\u50bb\u7ad9\u7740\u4e86，\u5148\u53bb\u670d\u52a1\u5176\u5b83\u5ba2\u4eba，\u6709\u5ba2\u4eba\u70b9\u597d\u7684\u65f6\u5019\u558a\u4f60\u4eec\u518d\u8fc7\u53bb\u3002\u5bf9\u5e94\u4e8e\u4e0b\u56fe：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105649-68038171497c2.png\")
<\/p>\n
\u6700\u540e，\u8001\u677f\u53d1\u73b0\u6839\u672c\u4e0d\u9700\u8981\u90a3\u4e48\u591a\u7684\u670d\u52a1\u5458，\u4e8e\u662f\u88c1\u4e86\u4e00\u6ce2\u5458，\u6700\u7ec8\u751a\u81f3\u53ef\u4ee5\u53ea\u6709\u4e00\u4e2a\u670d\u52a1\u5458\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u8fd9\u5c31\u662f Reactor \u6a21\u5f0f\u7684\u6838\u5fc3\u601d\u60f3：\u51cf\u5c11\u7b49\u5f85\u3002\u5f53\u9047\u5230\u9700\u8981\u7b49\u5f85 IO \u65f6，\u5148\u91ca\u653e\u8d44\u6e90，\u800c\u5728 IO \u5b8c\u6210\u65f6，\u518d\u901a\u8fc7\u4e8b\u4ef6\u9a71\u52a8 (event driven) \u7684\u65b9\u5f0f，\u7ee7\u7eed\u63a5\u4e0b\u6765\u7684\u5904\u7406\u3002\u4ece\u6574\u4f53\u4e0a\u51cf\u5c11\u4e86\u8d44\u6e90\u7684\u6d88\u8017\u3002<\/p>\n
\u5982\u679c\u8981\u8ba9\u670d\u52a1\u5668\u670d\u52a1\u591a\u4e2a\u5ba2\u6237\u7aef，\u90a3\u4e48\u6700\u76f4\u63a5\u7684\u65b9\u5f0f\u5c31\u662f\u4e3a\u6bcf\u4e00\u6761\u8fde\u63a5\u521b\u5efa\u7ebf\u7a0b\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u5176\u5b9e\u521b\u5efa\u8fdb\u7a0b\u4e5f\u662f\u53ef\u4ee5\u7684，\u539f\u7406\u662f\u4e00\u6837\u7684，\u8fdb\u7a0b\u548c\u7ebf\u7a0b\u7684\u533a\u522b\u5728\u4e8e\u7ebf\u7a0b\u6bd4\u8f83\u8f7b\u91cf\u7ea7\u4e9b，\u7ebf\u7a0b\u7684\u521b\u5efa\u548c\u7ebf\u7a0b\u95f4\u5207\u6362\u7684\u6210\u672c\u8981\u5c0f\u4e9b，\u4e3a\u4e86\u63cf\u8ff0\u7b80\u8ff0，\u540e\u9762\u90fd\u4ee5\u7ebf\u7a0b\u4e3a\u4f8b\u3002<\/p>\n
\u00a0\u5904\u7406\u5b8c\u4e1a\u52a1\u903b\u8f91\u540e，\u968f\u7740\u8fde\u63a5\u5173\u95ed\u540e\u7ebf\u7a0b\u4e5f\u540c\u6837\u8981\u9500\u6bc1\u4e86，\u4f46\u662f\u8fd9\u6837\u4e0d\u505c\u5730\u521b\u5efa\u548c\u9500\u6bc1\u7ebf\u7a0b，\u4e0d\u4ec5\u4f1a\u5e26\u6765\u6027\u80fd\u5f00\u9500，\u4e5f\u4f1a\u9020\u6210\u6d6a\u8d39\u8d44\u6e90，\u800c\u4e14\u5982\u679c\u8981\u8fde\u63a5\u51e0\u4e07\u6761\u8fde\u63a5，\u521b\u5efa\u51e0\u4e07\u4e2a\u7ebf\u7a0b\u53bb\u5e94\u5bf9\u4e5f\u662f\u4e0d\u73b0\u5b9e\u7684\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u8981\u8fd9\u4e48\u89e3\u51b3\u8fd9\u4e2a\u95ee\u9898\u5462？\u6211\u4eec\u53ef\u4ee5\u4f7f\u7528\u300c\u8d44\u6e90\u590d\u7528\u300d\u7684\u65b9\u5f0f\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u4e5f\u5c31\u662f\u4e0d\u7528\u518d\u4e3a\u6bcf\u4e2a\u8fde\u63a5\u521b\u5efa\u7ebf\u7a0b，\u800c\u662f\u521b\u5efa\u4e00\u4e2a\u300c\u7ebf\u7a0b\u6c60\u300d，\u5c06\u8fde\u63a5\u5206\u914d\u7ed9\u7ebf\u7a0b，\u7136\u540e\u4e00\u4e2a\u7ebf\u7a0b\u53ef\u4ee5\u5904\u7406\u591a\u4e2a\u8fde\u63a5\u7684\u4e1a\u52a1\u3002<\/p>\n
\u00a0\u00a0\u4e0d\u8fc7，\u8fd9\u6837\u53c8\u5f15\u6765\u4e00\u4e2a\u65b0\u7684\u95ee\u9898，\u7ebf\u7a0b\u600e\u6837\u624d\u80fd\u9ad8\u6548\u5730\u5904\u7406\u591a\u4e2a\u8fde\u63a5\u7684\u4e1a\u52a1？<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u5f53\u4e00\u4e2a\u8fde\u63a5\u5bf9\u5e94\u4e00\u4e2a\u7ebf\u7a0b\u65f6，\u7ebf\u7a0b\u4e00\u822c\u91c7\u7528\u300cread -> \u4e1a\u52a1\u5904\u7406 -> send\u300d\u7684\u5904\u7406\u6d41\u7a0b，\u5982\u679c\u5f53\u524d\u8fde\u63a5\u6ca1\u6709\u6570\u636e\u53ef\u8bfb，\u90a3\u4e48\u7ebf\u7a0b\u4f1a\u963b\u585e\u5728 read \u64cd\u4f5c\u4e0a（ socket \u9ed8\u8ba4\u60c5\u51b5\u662f\u963b\u585e I\/O），\u4e0d\u8fc7\u8fd9\u79cd\u963b\u585e\u65b9\u5f0f\u5e76\u4e0d\u5f71\u54cd\u5176\u4ed6\u7ebf\u7a0b\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u4f46\u662f\u5f15\u5165\u4e86\u7ebf\u7a0b\u6c60，\u90a3\u4e48\u4e00\u4e2a\u7ebf\u7a0b\u8981\u5904\u7406\u591a\u4e2a\u8fde\u63a5\u7684\u4e1a\u52a1，\u7ebf\u7a0b\u5728\u5904\u7406\u67d0\u4e2a\u8fde\u63a5\u7684 read \u64cd\u4f5c\u65f6，\u5982\u679c\u9047\u5230\u6ca1\u6709\u6570\u636e\u53ef\u8bfb，\u5c31\u4f1a\u53d1\u751f\u963b\u585e，\u90a3\u4e48\u7ebf\u7a0b\u5c31\u6ca1\u529e\u6cd5\u7ee7\u7eed\u5904\u7406\u5176\u4ed6\u8fde\u63a5\u7684\u4e1a\u52a1\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u8981\u89e3\u51b3\u8fd9\u4e00\u4e2a\u95ee\u9898，\u6700\u7b80\u5355\u7684\u65b9\u5f0f\u5c31\u662f\u5c06 socket \u6539\u6210\u975e\u963b\u585e，\u7136\u540e\u7ebf\u7a0b\u4e0d\u65ad\u5730\u8f6e\u8be2\u8c03\u7528 read \u64cd\u4f5c\u6765\u5224\u65ad\u662f\u5426\u6709\u6570\u636e，\u8fd9\u79cd\u65b9\u5f0f\u867d\u7136\u8be5\u80fd\u591f\u89e3\u51b3\u963b\u585e\u7684\u95ee\u9898，\u4f46\u662f\u89e3\u51b3\u7684\u65b9\u5f0f\u6bd4\u8f83\u7c97\u66b4，\u56e0\u4e3a\u8f6e\u8be2\u662f\u8981\u6d88\u8017 CPU \u7684，\u800c\u4e14\u968f\u7740\u4e00\u4e2a \u7ebf\u7a0b\u5904\u7406\u7684\u8fde\u63a5\u8d8a\u591a，\u8f6e\u8be2\u7684\u6548\u7387\u5c31\u4f1a\u8d8a\u4f4e\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u4e0a\u9762\u7684\u95ee\u9898\u5728\u4e8e，\u7ebf\u7a0b\u5e76\u4e0d\u77e5\u9053\u5f53\u524d\u8fde\u63a5\u662f\u5426\u6709\u6570\u636e\u53ef\u8bfb，\u4ece\u800c\u9700\u8981\u6bcf\u6b21\u901a\u8fc7 read \u53bb\u8bd5\u63a2\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u90a3\u6709\u6ca1\u6709\u529e\u6cd5\u5728\u53ea\u6709\u5f53\u8fde\u63a5\u4e0a\u6709\u6570\u636e\u7684\u65f6\u5019，\u7ebf\u7a0b\u624d\u53bb\u53d1\u8d77\u8bfb\u8bf7\u6c42\u5462？\u7b54\u6848\u662f\u6709\u7684，\u5b9e\u73b0\u8fd9\u4e00\u6280\u672f\u7684\u5c31\u662f\u00a0I\/O \u591a\u8def\u590d\u7528\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0I\/O \u591a\u8def\u590d\u7528\u6280\u672f\u4f1a\u7528\u4e00\u4e2a\u7cfb\u7edf\u8c03\u7528\u51fd\u6570\u6765\u76d1\u542c\u6211\u4eec\u6240\u6709\u5173\u5fc3\u7684\u8fde\u63a5，\u4e5f\u5c31\u8bf4\u53ef\u4ee5\u5728\u4e00\u4e2a\u76d1\u63a7\u7ebf\u7a0b\u91cc\u9762\u76d1\u63a7\u5f88\u591a\u7684\u8fde\u63a5\u3002<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105649-6803817199477.png\")
<\/p>\n<\/p>\n
\u00a0\u6211\u4eec\u719f\u6089\u7684 select\/poll\/epoll \u5c31\u662f\u5185\u6838\u63d0\u4f9b\u7ed9\u7528\u6237\u6001\u7684\u591a\u8def\u590d\u7528\u7cfb\u7edf\u8c03\u7528，\u7ebf\u7a0b\u53ef\u4ee5\u901a\u8fc7\u4e00\u4e2a\u7cfb\u7edf\u8c03\u7528\u51fd\u6570\u4ece\u5185\u6838\u4e2d\u83b7\u53d6\u591a\u4e2a\u4e8b\u4ef6\u3002\u00a0<\/p>\n
select\/poll\/epoll \u662f\u5982\u4f55\u83b7\u53d6\u7f51\u7edc\u4e8b\u4ef6\u7684\u5462？<\/p>\n
\u5728\u83b7\u53d6\u4e8b\u4ef6\u65f6，\u5148\u628a\u6211\u4eec\u8981\u5173\u5fc3\u7684\u8fde\u63a5\u4f20\u7ed9\u5185\u6838，\u518d\u7531\u5185\u6838\u68c0\u6d4b：<\/p>\n
\u5982\u679c\u6ca1\u6709\u4e8b\u4ef6\u53d1\u751f，\u7ebf\u7a0b\u53ea\u9700\u963b\u585e\u5728\u8fd9\u4e2a\u7cfb\u7edf\u8c03\u7528，\u800c\u65e0\u9700\u50cf\u524d\u9762\u7684\u7ebf\u7a0b\u6c60\u65b9\u6848\u90a3\u6837\u8f6e\u8bad\u8c03\u7528 read \u64cd\u4f5c\u6765\u5224\u65ad\u662f\u5426\u6709\u6570\u636e\u3002 \u5982\u679c\u6709\u4e8b\u4ef6\u53d1\u751f，\u5185\u6838\u4f1a\u8fd4\u56de\u4ea7\u751f\u4e86\u4e8b\u4ef6\u7684\u8fde\u63a5，\u7ebf\u7a0b\u5c31\u4f1a\u4ece\u963b\u585e\u72b6\u6001\u8fd4\u56de，\u7136\u540e\u5728\u7528\u6237\u6001\u4e2d\u518d\u5904\u7406\u8fd9\u4e9b\u8fde\u63a5\u5bf9\u5e94\u7684\u4e1a\u52a1\u5373\u53ef\u3002 \u00a0<\/p>\n<\/p>\n
\u662f\u7684，\u57fa\u672c\u662f\u57fa\u4e8e I\/O \u591a\u8def\u590d\u7528，\u7528\u8fc7 I\/O \u591a\u8def\u590d\u7528\u63a5\u53e3\u5199\u7f51\u7edc\u7a0b\u5e8f\u7684\u540c\u5b66，\u80af\u5b9a\u77e5\u9053\u662f\u9762\u5411\u8fc7\u7a0b\u7684\u65b9\u5f0f\u5199\u4ee3\u7801\u7684，\u8fd9\u6837\u7684\u5f00\u53d1\u7684\u6548\u7387\u4e0d\u9ad8\u3002<\/p>\n
\u00a0\u00a0\u00a0\u4e8e\u662f，\u5927\u4f6c\u4eec\u57fa\u4e8e\u9762\u5411\u5bf9\u8c61\u7684\u601d\u60f3，\u5bf9 I\/O \u591a\u8def\u590d\u7528\u4f5c\u4e86\u4e00\u5c42\u5c01\u88c5，\u8ba9\u4f7f\u7528\u8005\u4e0d\u7528\u8003\u8651\u5e95\u5c42\u7f51\u7edc API \u7684\u7ec6\u8282，\u53ea\u9700\u8981\u5173\u6ce8\u5e94\u7528\u4ee3\u7801\u7684\u7f16\u5199\u3002\u5927\u4f6c\u4eec\u8fd8\u4e3a\u8fd9\u79cd\u6a21\u5f0f\u53d6\u4e86\u4e2a\u8ba9\u4eba\u7b2c\u4e00\u65f6\u95f4\u96be\u4ee5\u7406\u89e3\u7684\u540d\u5b57：Reactor \u6a21\u5f0f\u3002<\/p>\n<\/p>\n
\u00a0\u00a0\u00a0Reactor \u7ffb\u8bd1\u8fc7\u6765\u7684\u610f\u601d\u662f\u300c\u53cd\u5e94\u5806\u300d，\u53ef\u80fd\u5927\u5bb6\u4f1a\u8054\u60f3\u5230\u7269\u7406\u5b66\u91cc\u7684\u6838\u53cd\u5e94\u5806，\u5b9e\u9645\u4e0a\u5e76\u4e0d\u662f\u7684\u8fd9\u4e2a\u610f\u601d\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u8fd9\u91cc\u7684\u53cd\u5e94\u6307\u7684\u662f\u300c\u5bf9\u4e8b\u4ef6\u53cd\u5e94\u300d，\u4e5f\u5c31\u662f\u6765\u4e86\u4e00\u4e2a\u4e8b\u4ef6，Reactor \u5c31\u6709\u76f8\u5bf9\u5e94\u7684\u53cd\u5e94\/\u54cd\u5e94\u3002<\/p>\n<\/p>\n
\u00a0 \u00a0\u4e8b\u5b9e\u4e0a，Reactor \u6a21\u5f0f\u4e5f\u53eb Dispatcher \u6a21\u5f0f，\u6211\u89c9\u5f97\u8fd9\u4e2a\u540d\u5b57\u66f4\u8d34\u5408\u8be5\u6a21\u5f0f\u7684\u542b\u4e49，\u5373 I\/O \u591a\u8def\u590d\u7528\u76d1\u542c\u4e8b\u4ef6，\u6536\u5230\u4e8b\u4ef6\u540e，\u6839\u636e\u4e8b\u4ef6\u7c7b\u578b\u5206\u914d（Dispatch）\u7ed9\u67d0\u4e2a\u8fdb\u7a0b \/ \u7ebf\u7a0b\u3002<\/p>\n
Reactor \u6a21\u5f0f\u4e3b\u8981\u7531 Reactor \u548c\u5904\u7406\u8d44\u6e90\u6c60\u8fd9\u4e24\u4e2a\u6838\u5fc3\u90e8\u5206\u7ec4\u6210，\u5b83\u4fe9\u8d1f\u8d23\u7684\u4e8b\u60c5\u5982\u4e0b：<\/p>\n
Reactor \u6a21\u5f0f\u662f\u7075\u6d3b\u591a\u53d8\u7684，\u53ef\u4ee5\u5e94\u5bf9\u4e0d\u540c\u7684\u4e1a\u52a1\u573a\u666f，\u7075\u6d3b\u5728\u4e8e：<\/p>\n
\u5c06\u4e0a\u9762\u7684\u4e24\u4e2a\u56e0\u7d20\u6392\u5217\u7ec4\u8bbe\u4e00\u4e0b，\u7406\u8bba\u4e0a\u5c31\u53ef\u4ee5\u6709 4 \u79cd\u65b9\u6848\u9009\u62e9：<\/p>\n<\/p>\n
\u65b9\u6848\u5177\u4f53\u4f7f\u7528\u8fdb\u7a0b\u8fd8\u662f\u7ebf\u7a0b，\u8981\u770b\u4f7f\u7528\u7684\u7f16\u7a0b\u8bed\u8a00\u4ee5\u53ca\u5e73\u53f0\u6709\u5173：<\/p>\n<\/p>\n
\u5176\u4e2d，\u300c\u591a Reactor \u5355\u8fdb\u7a0b \/ \u7ebf\u7a0b\u300d\u5b9e\u73b0\u65b9\u6848\u76f8\u6bd4\u300c\u5355 Reactor \u5355\u8fdb\u7a0b \/ \u7ebf\u7a0b\u300d\u65b9\u6848，\u4e0d\u4ec5\u590d\u6742\u800c\u4e14\u4e5f\u6ca1\u6709\u6027\u80fd\u4f18\u52bf，\u56e0\u6b64\u5b9e\u9645\u4e2d\u5e76\u6ca1\u6709\u5e94\u7528\u3002<\/p>\n
\u5269\u4e0b\u7684 3 \u4e2a\u65b9\u6848\u90fd\u662f\u6bd4\u8f83\u7ecf\u5178\u7684，\u4e14\u90fd\u6709\u5e94\u7528\u5728\u5b9e\u9645\u7684\u9879\u76ee\u4e2d：<\/p>\n<\/li>\n
\u63a5\u4e0b\u6765，\u5206\u522b\u4ecb\u7ecd\u8fd9\u4e09\u4e2a\u7ecf\u5178\u7684 Reactor \u65b9\u6848\u3002<\/p>\n
\u4e00\u822c\u6765\u8bf4，C \u8bed\u8a00\u5b9e\u73b0\u7684\u662f\u300c\u5355 Reactor \u5355\u8fdb\u7a0b\u300d\u7684\u65b9\u6848，\u56e0\u4e3a C \u8bed\u7f16\u5199\u5b8c\u7684\u7a0b\u5e8f，\u8fd0\u884c\u540e\u5c31\u662f\u4e00\u4e2a\u72ec\u7acb\u7684\u8fdb\u7a0b，\u4e0d\u9700\u8981\u5728\u8fdb\u7a0b\u4e2d\u518d\u521b\u5efa\u7ebf\u7a0b\u3002<\/p>\n
\u6211\u4eec\u6765\u770b\u770b\u300c\u5355 Reactor \u5355\u8fdb\u7a0b\u300d\u7684\u65b9\u6848\u793a\u610f\u56fe：![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105649-68038171d5558.png\")
<\/p>\n<\/li>\n<\/ul>\n
\u53ef\u4ee5\u770b\u5230\u8fdb\u7a0b\u91cc\u6709\u00a0Reactor\u3001Acceptor\u3001Handler\u00a0\u8fd9\u4e09\u4e2a\u5bf9\u8c61：<\/p>\n
\u5bf9\u8c61\u91cc\u7684 select\u3001accept\u3001read\u3001send \u662f\u7cfb\u7edf\u8c03\u7528\u51fd\u6570，dispatch \u548c \u300c\u4e1a\u52a1\u5904\u7406\u300d\u662f\u9700\u8981\u5b8c\u6210\u7684\u64cd\u4f5c，\u5176\u4e2d dispatch \u662f\u5206\u53d1\u4e8b\u4ef6\u64cd\u4f5c\u3002<\/p>\n
\u63a5\u4e0b\u6765，\u4ecb\u7ecd\u4e0b\u300c\u5355 Reactor \u5355\u8fdb\u7a0b\u300d\u8fd9\u4e2a\u65b9\u6848：<\/p>\n<\/li>\n
\u4f46\u662f，\u8fd9\u79cd\u65b9\u6848\u5b58\u5728 2 \u4e2a\u7f3a\u70b9：<\/p>\n<\/li>\n
Redis\u00a0\u662f\u7531 C \u8bed\u8a00\u5b9e\u73b0\u7684，\u5b83\u91c7\u7528\u7684\u6b63\u662f\u300c\u5355 Reactor \u5355\u8fdb\u7a0b\u300d\u7684\u65b9\u6848，\u56e0\u4e3a Redis \u4e1a\u52a1\u5904\u7406\u4e3b\u8981\u662f\u5728\u5185\u5b58\u4e2d\u5b8c\u6210，\u64cd\u4f5c\u7684\u901f\u5ea6\u662f\u5f88\u5feb\u7684，\u6027\u80fd\u74f6\u9888\u4e0d\u5728 CPU \u4e0a，\u6240\u4ee5 Redis \u5bf9\u4e8e\u547d\u4ee4\u7684\u5904\u7406\u662f\u5355\u8fdb\u7a0b\u7684\u65b9\u6848\u3002<\/p>\n
\u5982\u679c\u8981\u514b\u670d\u300c\u5355 Reactor \u5355\u7ebf\u7a0b \/ \u8fdb\u7a0b\u300d\u65b9\u6848\u7684\u7f3a\u70b9，\u90a3\u4e48\u5c31\u9700\u8981\u5f15\u5165\u591a\u7ebf\u7a0b \/ \u591a\u8fdb\u7a0b，\u8fd9\u6837\u5c31\u4ea7\u751f\u4e86\u5355 Reactor \u591a\u7ebf\u7a0b\/ \u591a\u8fdb\u7a0b\u7684\u65b9\u6848\u3002<\/p>\n
\u95fb\u5176\u540d\u4e0d\u5982\u770b\u5176\u56fe，\u5148\u6765\u770b\u770b\u300c\u5355 Reactor \u591a\u7ebf\u7a0b\u300d\u65b9\u6848\u7684\u793a\u610f\u56fe\u5982\u4e0b![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105650-6803817222aeb.png\")
<\/p>\n
\u8be6\u7ec6\u8bf4\u4e00\u4e0b\u8fd9\u4e2a\u65b9\u6848：<\/p>\n
\u4e0a\u9762\u7684\u4e09\u4e2a\u6b65\u9aa4\u548c\u5355 Reactor \u5355\u7ebf\u7a0b\u65b9\u6848\u662f\u4e00\u6837\u7684，\u63a5\u4e0b\u6765\u7684\u6b65\u9aa4\u5c31\u5f00\u59cb\u4e0d\u4e00\u6837\u4e86：<\/p>\n<\/li>\n
\u5b50\u7ebf\u7a0b\u91cc\u7684 Processor \u5bf9\u8c61\u5c31\u8fdb\u884c\u4e1a\u52a1\u5904\u7406，\u5904\u7406\u5b8c\u540e，\u5c06\u7ed3\u679c\u53d1\u7ed9\u4e3b\u7ebf\u7a0b\u4e2d\u7684 Handler \u5bf9\u8c61，\u63a5\u7740\u7531 Handler \u901a\u8fc7 send \u65b9\u6cd5\u5c06\u54cd\u5e94\u7ed3\u679c\u53d1\u9001\u7ed9 client；<\/p>\n<\/li>\n
\u5355 Reator \u591a\u7ebf\u7a0b\u7684\u65b9\u6848\u4f18\u52bf\u5728\u4e8e\u80fd\u591f\u5145\u5206\u5229\u7528\u591a\u6838 CPU \u7684\u80fd，\u90a3\u65e2\u7136\u5f15\u5165\u591a\u7ebf\u7a0b，\u90a3\u4e48\u81ea\u7136\u5c31\u5e26\u6765\u4e86\u591a\u7ebf\u7a0b\u7ade\u4e89\u8d44\u6e90\u7684\u95ee\u9898\u3002<\/p>\n
\u00a0 \u00a0\u4f8b\u5982，\u5b50\u7ebf\u7a0b\u5b8c\u6210\u4e1a\u52a1\u5904\u7406\u540e，\u8981\u628a\u7ed3\u679c\u4f20\u9012\u7ed9\u4e3b\u7ebf\u7a0b\u7684 Reactor \u8fdb\u884c\u53d1\u9001，\u8fd9\u91cc\u6d89\u53ca\u5171\u4eab\u6570\u636e\u7684\u7ade\u4e89\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u8981\u907f\u514d\u591a\u7ebf\u7a0b\u7531\u4e8e\u7ade\u4e89\u5171\u4eab\u8d44\u6e90\u800c\u5bfc\u81f4\u6570\u636e\u9519\u4e71\u7684\u95ee\u9898，\u5c31\u9700\u8981\u5728\u64cd\u4f5c\u5171\u4eab\u8d44\u6e90\u524d\u52a0\u4e0a\u4e92\u65a5\u9501，\u4ee5\u4fdd\u8bc1\u4efb\u610f\u65f6\u95f4\u91cc\u53ea\u6709\u4e00\u4e2a\u7ebf\u7a0b\u5728\u64cd\u4f5c\u5171\u4eab\u8d44\u6e90，\u5f85\u8be5\u7ebf\u7a0b\u64cd\u4f5c\u5b8c\u91ca\u653e\u4e92\u65a5\u9501\u540e，\u5176\u4ed6\u7ebf\u7a0b\u624d\u6709\u673a\u4f1a\u64cd\u4f5c\u5171\u4eab\u6570\u636e\u3002<\/p>\n<\/li>\n<\/ul>\n
\u804a\u5b8c\u5355 Reactor \u591a\u7ebf\u7a0b\u7684\u65b9\u6848，\u63a5\u7740\u6765\u770b\u770b\u5355 Reactor \u591a\u8fdb\u7a0b\u7684\u65b9\u6848\u00a0 \u00a0<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u53e6\u5916，\u300c\u5355 Reactor\u300d\u7684\u6a21\u5f0f\u8fd8\u6709\u4e2a\u95ee\u9898，\u56e0\u4e3a\u4e00\u4e2a Reactor \u5bf9\u8c61\u627f\u62c5\u6240\u6709\u4e8b\u4ef6\u7684\u76d1\u542c\u548c\u54cd\u5e94，\u800c\u4e14\u53ea\u5728\u4e3b\u7ebf\u7a0b\u4e2d\u8fd0\u884c，\u5728\u9762\u5bf9\u77ac\u95f4\u9ad8\u5e76\u53d1\u7684\u573a\u666f\u65f6，\u5bb9\u6613\u6210\u4e3a\u6027\u80fd\u7684\u74f6\u9888\u7684\u5730\u65b9\u3002<\/p>\n<\/p>\n
\u8981\u89e3\u51b3\u300c\u5355 Reactor\u300d\u7684\u95ee\u9898，\u5c31\u662f\u5c06\u300c\u5355 Reactor\u300d\u5b9e\u73b0\u6210\u300c\u591a Reactor\u300d，\u8fd9\u6837\u5c31\u4ea7\u751f\u4e86\u7b2c \u591a Reactor \u591a\u8fdb\u7a0b \/ \u7ebf\u7a0b\u7684\u65b9\u6848\u3002<\/p>\n
\u8001\u89c4\u77e9，\u95fb\u5176\u540d\u4e0d\u5982\u770b\u5176\u56fe\u3002\u591a Reactor \u591a\u8fdb\u7a0b \/ \u7ebf\u7a0b\u65b9\u6848\u7684\u793a\u610f\u56fe\u5982\u4e0b（\u4ee5\u7ebf\u7a0b\u4e3a\u4f8b）：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105650-68038172740f0.png\")
<\/p>\n<\/p>\n<\/p>\n
\u65b9\u6848\u8be6\u7ec6\u8bf4\u660e\u5982\u4e0b：<\/p>\n
\u591a Reactor \u591a\u7ebf\u7a0b\u7684\u65b9\u6848\u867d\u7136\u770b\u8d77\u6765\u590d\u6742\u7684，\u4f46\u662f\u5b9e\u9645\u5b9e\u73b0\u65f6\u6bd4\u5355 Reactor \u591a\u7ebf\u7a0b\u7684\u65b9\u6848\u8981\u7b80\u5355\u7684\u591a，\u539f\u56e0\u5982\u4e0b：<\/p>\n<\/li>\n
\u5927\u540d\u9f0e\u9f0e\u7684\u4e24\u4e2a\u5f00\u6e90\u8f6f\u4ef6 Netty \u548c Memcache \u90fd\u91c7\u7528\u4e86\u300c\u591a Reactor \u591a\u7ebf\u7a0b\u300d\u7684\u65b9\u6848\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u91c7\u7528\u4e86\u300c\u591a Reactor \u591a\u8fdb\u7a0b\u300d\u65b9\u6848\u7684\u5f00\u6e90\u8f6f\u4ef6\u662f\u00a0Nginx，\u4e0d\u8fc7\u65b9\u6848\u4e0e\u6807\u51c6\u7684\u591a Reactor \u591a\u8fdb\u7a0b\u6709\u4e9b\u5dee\u5f02\u3002<\/p>\n
\u00a0 \u5177\u4f53\u5dee\u5f02\u8868\u73b0\u5728\u4e3b\u8fdb\u7a0b\u4e2d\u4ec5\u4ec5\u7528\u6765\u521d\u59cb\u5316 socket，\u5e76\u6ca1\u6709\u521b\u5efa mainReactor \u6765 accept \u8fde\u63a5，\u800c\u662f\u7531\u5b50\u8fdb\u7a0b\u7684 Reactor \u6765 accept \u8fde\u63a5，\u901a\u8fc7\u9501\u6765\u63a7\u5236\u4e00\u6b21\u53ea\u6709\u4e00\u4e2a\u5b50\u8fdb\u7a0b\u8fdb\u884c accept（\u9632\u6b62\u51fa\u73b0\u60ca\u7fa4\u73b0\u8c61），\u5b50\u8fdb\u7a0b accept \u65b0\u8fde\u63a5\u540e\u5c31\u653e\u5230\u81ea\u5df1\u7684 Reactor \u8fdb\u884c\u5904\u7406，\u4e0d\u4f1a\u518d\u5206\u914d\u7ed9\u5176\u4ed6\u5b50\u8fdb\u7a0b\u3002<\/p>\n<\/li>\n<\/ul>\n
\u63a5\u4e0b\u6765\u6211\u4eec\u5c31\u8981\u6765\u5b9e\u73b0\u4e00\u4e2a\u5355 Reactor \u5355\u8fdb\u7a0b\u7248\u672c\u7684TCP\u670d\u52a1\u5668<\/p>\n<\/p>\n
\u9996\u5148\u6211\u4eec\u9700\u8981\u4e0b\u9762\u8fd9\u4e9b\u6587\u4ef6<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105650-68038172edc33.png\")
<\/p>\n<\/p>\n
\u8fd9\u4e2aSocket.hpp，nocopy.hpp，Epoller.hpp\u90fd\u662f\u6211\u4eec\u5c01\u88c5\u597d\u4e86\u7684，\u6211\u4eec\u76f4\u63a5\u4f7f\u7528\u5c31\u884c\u4e86，\u63a5\u4e0b\u6765\u6211\u4eec\u53ea\u9700\u8981\u7f16\u5199tcpserver.hpp\u548cmain.cc<\/p>\n
\u00a0 \u00a0 \u627f\u63a5\u4e0a\u4e00\u8282\u4e2d\u7684 epoll \u670d\u52a1\u5668：\u73b0\u5728\u7684\u95ee\u9898\u662f，\u6765\u81ea\u7528\u6237\u7684\u6570\u636e\u53ef\u80fd\u4f1a\u88ab TCP \u534f\u8bae\u62c6\u5206\u6210\u591a\u4e2a\u62a5\u6587，\u90a3\u4e48\u670d\u52a1\u5668\u600e\u4e48\u624d\u80fd\u77e5\u9053\u4ec0\u4e48\u65f6\u5019\u6700\u540e\u4e00\u4e2a\u5c0f\u62a5\u6587\u88ab\u63a5\u6536\u4e86\u5462？\u8981\u4fdd\u8bc1\u5b8c\u6574\u5730\u8bfb\u53d6\u5ba2\u6237\u7aef\u53d1\u9001\u7684\u6570\u636e，\u670d\u52a1\u5668\u9700\u8981\u5c06\u8fd9\u6b21\u8bfb\u53d6\u5230\u7684\u6570\u636e\u4fdd\u5b58\u8d77\u6765，\u5bf9\u5b83\u4eec\u8fdb\u884c\u4e00\u5b9a\u7684\u5904\u7406（\u62a5\u6587\u53ef\u80fd\u4f1a\u6709\u62a5\u5934，\u4ee5\u89e3\u51b3\u7c98\u5305\u95ee\u9898），\u6700\u540e\u5c06\u5b83\u4eec\u62fc\u63a5\u8d77\u6765，\u518d\u5411\u4e0a\u5c42\u5e94\u7528\u7a0b\u5e8f\u4ea4\u4ed8\u3002<\/p>\n
\u00a0\u00a0\u95ee\u9898\u662f\u00a0Recver \u4e2d\u7684\u7f13\u51b2\u533a buffer \u662f\u4e00\u4e2a\u5c40\u90e8\u53d8\u91cf，\u6bcf\u6b21\u5faa\u73af\u90fd\u4f1a\u91cd\u7f6e\u3002\u800c\u670d\u52a1\u7aef\u53ef\u80fd\u4f1a\u6709\u6210\u767e\u4e0a\u5343\u4e2a\u6765\u81ea\u5ba2\u6237\u7aef\u5efa\u7acb\u8fde\u63a5\u540e\u6253\u5f00\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26，\u8fd9\u65e0\u6cd5\u4fdd\u8bc1\u4e3a\u6bcf\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26\u90fd\u4fdd\u5b58\u672c\u8f6e\u5faa\u73af\u8bfb\u53d6\u7684\u6570\u636e\u3002<\/p>\n
\u00a0 \u00a0 \u89e3\u51b3\u529e\u6cd5\u662f\u4e3a\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26\u5efa\u7acb\u72ec\u7acb\u7684\u63a5\u6536\u548c\u53d1\u9001\u7f13\u51b2\u533a，\u56e0\u4e3a\u5957\u63a5\u5b57\u662f\u57fa\u4e8e\u8fde\u63a5\u7684，\u6240\u4ee5\u7528\u4e00\u4e2a\u540d\u4e3a Connection \u7684\u7c7b\u6765\u4fdd\u5b58\u6240\u6709\u548c\u8fde\u63a5\u76f8\u5173\u7684\u5c5e\u6027，\u4f8b\u5982\u6587\u4ef6\u63cf\u8ff0\u7b26，\u6536\u53d1\u7f13\u51b2\u533a，\u4ee5\u53ca\u5bf9\u6587\u4ef6\u63cf\u8ff0\u7b26\u7684\u64cd\u4f5c（\u5305\u62ec\u8bfb\u3001\u5199\u548c\u5f02\u5e38\u64cd\u4f5c），\u6240\u4ee5\u8981\u8bbe\u7f6e\u4e09\u4e2a\u56de\u8c03\u51fd\u6570\u4ee5\u4f9b\u540e\u7eed\u5728\u4e0d\u540c\u7684\u5206\u652f\u8c03\u7528，\u6700\u540e\u8fd8\u8981\u8bbe\u7f6e\u4e00\u4e2a\u56de\u6307\u6307\u9488，\u5b83\u5c06\u4f1a\u4fdd\u5b58\u670d\u52a1\u5668\u5bf9\u8c61\u7684\u5730\u5740，\u5230\u540e\u9762\u4f1a\u4ecb\u7ecd\u5b83\u7684\u7528\u5904\u3002<\/p>\n
\u200b
\n#pragma once
\n#include<iostream>
\n#include<string>
\n#include<functional>
\n#include<memory><\/p>\n
class Connection;
\nusing func_t =std::function<void(std::shared_ptr<Connection>)>;<\/p>\n
class Connection
\n{<\/p>\n
private:
\nint _sock;
\nstd::string _inbuffer;\/\/\u8fd9\u91cc\u6765\u5f53\u8f93\u5165\u7f13\u51b2\u533a，\u4f46\u662f\u8fd9\u91cc\u662f\u6709\u7f3a\u70b9\u7684，\u5b83\u4e0d\u80fd\u5904\u7406\u4e8c\u8fdb\u5236\u6d41
\nstd::string _outbuffer;<\/p>\n
func_t _recv_cb;\/\/\u8bfb\u56de\u8c03\u51fd\u6570
\nfunc_t _send_cb;\/\/\u5199\u56de\u8c03\u51fd\u6570
\nfunc_t _except_cd;\/\/<\/p>\n
\/\/\u6dfb\u52a0\u4e00\u4e2a\u56de\u6307\u6307\u9488
\nstd::shared_ptr<TcpServer> _tcp_server_ptr;
\n};
\nclass TcpServer
\n{<\/p>\n
};<\/p>\n
\u200b <\/p>\n<\/p>\n
\u00a0Connection\u7ed3\u6784\u4e2d\u9664\u4e86\u5305\u542b\u6587\u4ef6\u63cf\u8ff0\u7b26\u548c\u5176\u5bf9\u5e94\u7684\u8bfb\u56de\u8c03\u3001\u5199\u56de\u8c03\u548c\u5f02\u5e38\u56de\u8c03\u5916，\u8fd8\u5305\u542b\u4e00\u4e2a\u8f93\u5165\u7f13\u51b2\u533a_inbuffer\u3001\u4e00\u4e2a\u8f93\u51fa\u7f13\u51b2\u533a_outbuffer\u4ee5\u53ca\u4e00\u4e2a\u56de\u6307\u6307\u9488_tcp_setver_ptr<\/p>\n<\/p>\n
\u00a0 \u00a0\u5f53\u67d0\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26\u7684\u8bfb\u4e8b\u4ef6\u5c31\u7eea\u65f6，\u8c03\u7528recv\u51fd\u6570\u8bfb\u53d6\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u6570\u636e，\u4f46\u5e76\u4e0d\u80fd\u4fdd\u8bc1\u8bfb\u5230\u4e86\u4e00\u4e2a\u5b8c\u6574\u62a5\u6587，\u56e0\u6b64\u9700\u8981\u5c06\u8bfb\u53d6\u5230\u7684\u6570\u636e\u6682\u65f6\u5b58\u653e\u5230\u8be5\u6587\u4ef6\u63cf\u8ff0\u7b26\u5bf9\u5e94\u7684_inBuffer\u4e2d，\u5f53_inBuffer\u4e2d\u53ef\u4ee5\u5206\u79bb\u51fa\u4e00\u4e2a\u5b8c\u6574\u7684\u62a5\u6587\u540e\u518d\u5c06\u5176\u5206\u79bb\u51fa\u6765\u8fdb\u884c\u6570\u636e\u5904\u7406，_inBuffer\u672c\u8d28\u5c31\u662f\u7528\u6765\u89e3\u51b3\u7c98\u5305\u95ee\u9898\u7684\u00a0<\/p>\n
\u5f53\u5904\u7406\u5b8c\u4e00\u4e2a\u62a5\u6587\u8bf7\u6c42\u540e，\u9700\u5c06\u54cd\u5e94\u6570\u636e\u53d1\u9001\u7ed9\u5ba2\u6237\u7aef，\u4f46\u5e76\u4e0d\u80fd\u4fdd\u8bc1\u5e95\u5c42TCP\u7684\u53d1\u9001\u7f13\u51b2\u533a\u4e2d\u6709\u8db3\u591f\u7684\u7a7a\u95f4\u5199\u5165，\u56e0\u6b64\u9700\u5c06\u8981\u53d1\u9001\u7684\u6570\u636e\u6682\u65f6\u5b58\u653e\u5230\u8be5\u6587\u4ef6\u63cf\u8ff0\u7b26\u5bf9\u5e94\u7684_outBuffer\u4e2d，\u5f53\u5e95\u5c42TCP\u7684\u53d1\u9001\u7f13\u51b2\u533a\u4e2d\u6709\u7a7a\u95f4，\u5373\u5199\u4e8b\u4ef6\u5c31\u7eea\u65f6，\u518d\u4f9d\u6b21\u53d1\u9001_outBuffer\u4e2d\u7684\u6570\u636e<\/p>\n
\u00a0 \u00a0 Connection\u7ed3\u6784\u4e2d\u8bbe\u7f6e\u56de\u6307\u6307\u9488_svrPtr，\u4fbf\u4e8e\u5feb\u901f\u627e\u5230TcpServer\u5bf9\u8c61，\u56e0\u4e3a\u540e\u7eed\u9700\u8981\u6839\u636eConnection\u7ed3\u6784\u627e\u5230\u8fd9\u4e2aTcpServer\u5bf9\u8c61\u3002\u5982\u4e0a\u5c42\u4e1a\u52a1\u5904\u7406\u51fd\u6570NetCal\u51fd\u6570\u5411_outBuffer\u8f93\u51fa\u7f13\u51b2\u533a\u9012\u4ea4\u6570\u636e\u540e，\u9700\u901a\u8fc7Connection\u4e2d\u7684\u56de\u6307\u6307\u9488，"\u63d0\u9192"TcpServer\u8fdb\u884c\u5904\u7406<\/p>\n
Connection\u7ed3\u6784\u4e2d\u9700\u63d0\u4f9b\u4e00\u4e2a\u7ba1\u7406\u56de\u8c03\u7684\u6210\u5458\u51fd\u6570，\u4fbf\u4e8e\u5916\u90e8\u5bf9\u56de\u8c03\u8fdb\u884c\u8bbe\u7f6e<\/p>\n
\u6309\u7167\u4e4b\u524d\u7684\u7ecf\u9a8c，\u6211\u4eec\u5f88\u5feb\u5c31\u80fd\u5199\u51fa\u4e0b\u9762\u8fd9\u4e2a<\/p>\n
#include <memory> \/\/ \u5305\u542bshared_ptr\u548cunique_ptr\u7b49\u667a\u80fd\u6307\u9488\u7684\u5934\u6587\u4ef6
\n#include <unordered_map> \/\/ \u5305\u542bunordered_map\u7684\u5934\u6587\u4ef6 <\/p>\n
class TcpServer
\n{
\npublic:
\n \/\/ \u6784\u9020\u51fd\u6570，\u521d\u59cb\u5316TCP\u670d\u52a1\u5668
\n \/\/ \u63a5\u6536\u4e00\u4e2a\u7aef\u53e3\u53f7\u4f5c\u4e3a\u53c2\u6570，\u7528\u4e8e\u521b\u5efa\u76d1\u542c\u5957\u63a5\u5b57，\u5e76\u521d\u59cb\u5316\u4e8b\u4ef6\u8f6e\u8be2\u5668
\n TcpServer(uint16_t port)
\n : _port(port), \/\/ \u5b58\u50a8\u7aef\u53e3\u53f7
\n _listensock_ptr(new Sock()), \/\/ \u521b\u5efa\u4e00\u4e2aSock\u5bf9\u8c61\u7528\u4e8e\u76d1\u542c，\u5e76\u4f7f\u7528shared_ptr\u7ba1\u7406
\n _epoller_ptr(new Epoller()) \/\/ \u521b\u5efa\u4e00\u4e2aEpoller\u5bf9\u8c61\u7528\u4e8e\u4e8b\u4ef6\u8f6e\u8be2，\u5e76\u4f7f\u7528shared_ptr\u7ba1\u7406
\n {
\n _listensock_ptr->Socket(); \/\/ \u8c03\u7528Sock\u7684Socket\u65b9\u6cd5\u521b\u5efa\u5957\u63a5\u5b57
\n _listensock_ptr->Bind(_port); \/\/ \u7ed1\u5b9a\u7aef\u53e3\u53f7
\n _listensock_ptr->Listen(); \/\/ \u5f00\u59cb\u76d1\u542c <\/p>\n
\/\/ \u6ce8\u610f：\u8fd9\u91cc\u53ef\u80fd\u8fd8\u9700\u8981\u5c06\u76d1\u542c\u5957\u63a5\u5b57\u6dfb\u52a0\u5230\u4e8b\u4ef6\u8f6e\u8be2\u5668\u4e2d，\u4f46\u4ee3\u7801\u4e2d\u6ca1\u6709\u663e\u793a
\n } <\/p>\n
\/\/ \u521d\u59cb\u5316\u65b9\u6cd5，\u53ef\u4ee5\u5728\u8fd9\u91cc\u6dfb\u52a0\u989d\u5916\u7684\u521d\u59cb\u5316\u903b\u8f91
\n \/\/ \u4f46\u4ece\u63d0\u4f9b\u7684\u4ee3\u7801\u6765\u770b，\u8fd9\u4e2a\u65b9\u6cd5\u76ee\u524d\u662f\u7a7a\u7684
\n void Init()
\n {
\n \/\/ \u53ef\u4ee5\u5728\u8fd9\u91cc\u6dfb\u52a0\u521d\u59cb\u5316\u4ee3\u7801
\n } <\/p>\n
\/\/ \u542f\u52a8\u65b9\u6cd5，\u7528\u4e8e\u542f\u52a8\u670d\u52a1\u5668\u7684\u4e8b\u4ef6\u5faa\u73af
\n \/\/ \u4f46\u4ece\u63d0\u4f9b\u7684\u4ee3\u7801\u6765\u770b，\u8fd9\u4e2a\u65b9\u6cd5\u76ee\u524d\u662f\u7a7a\u7684
\n \/\/ \u901a\u5e38，\u8fd9\u91cc\u4f1a\u5305\u542b\u542f\u52a8\u4e8b\u4ef6\u8f6e\u8be2\u5668\u7684\u903b\u8f91
\n void Start()
\n {
\n \/\/ \u542f\u52a8\u4e8b\u4ef6\u8f6e\u8be2\u5668，\u5f00\u59cb\u5904\u7406\u7f51\u7edc\u4e8b\u4ef6
\n \/\/ \u6ce8\u610f：\u5b9e\u9645\u4ee3\u7801\u4e2d\u9700\u8981\u5b9e\u73b0\u8fd9\u90e8\u5206\u903b\u8f91
\n } <\/p>\n
\/\/ \u6790\u6784\u51fd\u6570，\u7528\u4e8e\u6e05\u7406\u8d44\u6e90
\n \/\/ \u6ce8\u610f：\u7531\u4e8e\u4f7f\u7528\u4e86shared_ptr，\u8fd9\u91cc\u7684\u8d44\u6e90\u6e05\u7406\u5c06\u662f\u81ea\u52a8\u7684
\n \/\/ \u4f46\u5982\u679c\u8fd8\u6709\u5176\u4ed6\u9700\u8981\u624b\u52a8\u6e05\u7406\u7684\u8d44\u6e90（\u5982\u6587\u4ef6\u63cf\u8ff0\u7b26\u7b49），\u5219\u5e94\u8be5\u5728\u8fd9\u91cc\u5904\u7406
\n ~TcpServer()
\n {
\n \/\/ \u6790\u6784\u51fd\u6570\u4f1a\u81ea\u52a8\u8c03\u7528shared_ptr\u7684\u6790\u6784，\u4ece\u800c\u9500\u6bc1Sock\u548cEpoller\u5bf9\u8c61
\n \/\/ \u5982\u679c\u9700\u8981，\u53ef\u4ee5\u5728\u8fd9\u91cc\u6dfb\u52a0\u989d\u5916\u7684\u6e05\u7406\u4ee3\u7801
\n } <\/p>\n
private:
\n uint16_t _port; \/\/ \u5b58\u50a8\u670d\u52a1\u5668\u76d1\u542c\u7684\u7aef\u53e3\u53f7
\n std::shared_ptr<Epoller> _epoller_ptr; \/\/ \u4e8b\u4ef6\u8f6e\u8be2\u5668\u7684\u667a\u80fd\u6307\u9488
\n std::unordered_map<int, std::shared_ptr<Connection>> _connections; \/\/ \u5b58\u50a8\u8fde\u63a5\u7684\u54c8\u5e0c\u8868，\u952e\u4e3a\u5957\u63a5\u5b57\u63cf\u8ff0\u7b26，\u503c\u4e3aConnection\u5bf9\u8c61\u7684\u667a\u80fd\u6307\u9488
\n std::shared_ptr<Sock> _listensock_ptr; \/\/ \u76d1\u542c\u5957\u63a5\u5b57\u7684\u667a\u80fd\u6307\u9488
\n}; <\/p>\n<\/p>\n
\u8fd9\u91cc\u56de\u7b54\u4e00\u4e2a\u95ee\u9898<\/p>\n<\/p>\n
\u00a0\u5f53\u7136\u662f\u9700\u8981\u7684，\u6240\u4ee5\u5728\u670d\u52a1\u5668\u7c7b\u91cc\u9762，\u5b9a\u4e49\u4e86\u4e00\u4e2a\u54c8\u5e0c\u8868_connections，\u7528sock\u6765\u4f5c\u4e3a\u54c8\u5e0c\u8868\u7684\u952e\u503c，sock\u5bf9\u5e94\u7684\u7ed3\u6784\u4f53connection\u548csock\u4e00\u8d77\u4f5c\u4e3a\u952e\u503c\u5bf9，\u4e5f\u5c31\u662f\u54c8\u5e0c\u6876\u4e2d\u5b58\u50a8\u7684\u503c(\u5b58\u50a8\u952e\u503c\u5bf9<sock, connection>)，\u4eca\u5929\u662f\u4e0d\u4f1a\u51fa\u73b0\u54c8\u5e0c\u51b2\u7a81\u7684，\u6240\u4ee5\u6bcf\u4e2a\u952e\u503c\u4e0b\u9762\u7684\u54c8\u5e0c\u6876\u53ea\u4f1a\u6302\u4e00\u4e2a\u952e\u503c\u5bf9，\u5373\u4e00\u4e2a<sock, connection>.<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u521d\u59cb\u5316\u670d\u52a1\u5668\u65f6，\u7b2c\u4e00\u4e2a\u9700\u8981\u88ab\u6dfb\u52a0\u5230\u54c8\u5e0c\u8868\u4e2d\u7684sock，\u4e00\u5b9a\u662flistensock，\u6240\u4ee5\u5728init\u65b9\u6cd5\u4e2d，\u5148\u628alistensock\u6dfb\u52a0\u5230\u54c8\u5e0c\u8868\u91cc\u9762，\u6dfb\u52a0\u7684\u540c\u65f6\u8fd8\u8981\u4f20\u8be5listensock\u6240\u5bf9\u5e94\u7684\u5173\u5fc3\u4e8b\u4ef6\u7684\u65b9\u6cd5，\u5bf9\u4e8elistensock\u6765\u8bf4，\u53ea\u9700\u8981\u5173\u6ce8\u8bfb\u65b9\u6cd5\u5373\u53ef，\u5176\u4ed6\u4e24\u4e2a\u65b9\u6cd5\u8bbe\u4e3anullptr\u5373\u53ef\u3002<\/p>\n<\/p>\n
\u63a5\u4e0b\u6765\u662f\u4f7f\u7528ET\u6a21\u5f0f\u7684，\u6240\u4ee5\u6211\u4eec\u8981\u5b9e\u65bd\u4e0b\u9762\u8fd9\u4e09\u70b9<\/p>\n
\u76f8\u6bd4\u4e8eLT\u6a21\u5f0f，\u5173\u4e8eET（\u8fb9\u7f18\u89e6\u53d1）\u6a21\u5f0f\u7684\u4f7f\u7528，\u786e\u5b9e\u9700\u8981\u5173\u6ce8\u8fd9\u51e0\u4e2a\u5173\u952e\u70b9：<\/p>\n<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a01.\u8bbe\u7f6eEPOLLET\u6807\u5fd7：\u5728\u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26（\u5982socket）\u6dfb\u52a0\u5230epoll\u5b9e\u4f8b\u65f6，\u4f60\u9700\u8981\u901a\u8fc7epoll_event\u7ed3\u6784\u4f53\u4e2d\u7684events\u5b57\u6bb5\u8bbe\u7f6eEPOLLET\u6807\u5fd7，\u4ee5\u542f\u7528\u8fb9\u7f18\u89e6\u53d1\u6a21\u5f0f\u3002\u8fd9\u544a\u8bc9epoll，\u4f60\u5e0c\u671b\u5728\u8be5\u6587\u4ef6\u63cf\u8ff0\u7b26\u7684\u72b6\u6001\u4ece\u975e\u5c31\u7eea\u53d8\u4e3a\u5c31\u7eea\u65f6\u53ea\u63a5\u6536\u4e00\u6b21\u4e8b\u4ef6\u901a\u77e5\u3002 \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a02.\u5c06socket\u6587\u4ef6\u63cf\u8ff0\u7b26\u8bbe\u7f6e\u4e3a\u975e\u963b\u585e：\u7531\u4e8eET\u6a21\u5f0f\u8981\u6c42\u4f60\u80fd\u591f\u5728\u4e00\u4e2a\u4e8b\u4ef6\u901a\u77e5\u4e2d\u5c3d\u53ef\u80fd\u591a\u5730\u5904\u7406\u6570\u636e，\u76f4\u5230\u6ca1\u6709\u66f4\u591a\u6570\u636e\u53ef\u8bfb，\u56e0\u6b64\u5c06socket\u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f\u662f\u975e\u5e38\u91cd\u8981\u7684\u3002\u8fd9\u5141\u8bb8\u4f60\u7684read\u8c03\u7528\u5728\u6ca1\u6709\u6570\u636e\u53ef\u8bfb\u65f6\u7acb\u5373\u8fd4\u56deEAGAIN\u6216EWOULDBLOCK，\u800c\u4e0d\u662f\u963b\u585e\u7b49\u5f85\u3002 \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a03.\u5faa\u73af\u8c03\u7528read\u76f4\u5230\u8fd4\u56deEAGAIN\u6216EWOULDBLOCK：\u5728\u63a5\u6536\u5230\u4e00\u4e2aET\u6a21\u5f0f\u7684\u4e8b\u4ef6\u901a\u77e5\u540e，\u4f60\u9700\u8981\u5728\u4e00\u4e2a\u5faa\u73af\u4e2d\u8c03\u7528read\u51fd\u6570，\u4e0d\u65ad\u5c1d\u8bd5\u4ecesocket\u4e2d\u8bfb\u53d6\u6570\u636e，\u76f4\u5230read\u8fd4\u56deEAGAIN\u6216EWOULDBLOCK\u3002\u8fd9\u8868\u793a\u5f53\u524d\u6ca1\u6709\u66f4\u591a\u6570\u636e\u53ef\u8bfb，\u4f60\u53ef\u4ee5\u5b89\u5168\u5730\u7ee7\u7eed\u7b49\u5f85\u4e0b\u4e00\u4e2a\u4e8b\u4ef6\u901a\u77e5\u3002<\/p>\n
\u4e3a\u4e86\u65b9\u4fbf\u4f7f\u7528，\u6211\u4eec\u5c06\u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e\u7684\u4ee3\u7801\u5c01\u88c5\u5230set_non_blocking\u51fd\u6570\u91cc\u9762\u53bb\u4e86<\/p>\n
TcpServer\u7c7b<\/p>\n
class TcpServer : public nocopy
\n{
\n static const int num = 64;<\/p>\n
public:
\n TcpServer(uint16_t port) : _port(port),
\n _listensock_ptr(new Sock()),
\n _epoller_ptr(new Epoller()),
\n _quit(true)
\n {
\n _listensock_ptr->Socket();
\n set_non_blocking(_listensock_ptr->Fd()); \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n _listensock_ptr->Bind(_port);
\n _listensock_ptr->Listen();
\n }
\n ~TcpServer()
\n {
\n }
\n \/\/ \u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n int set_non_blocking(int fd)
\n {
\n int flags = fcntl(fd, F_GETFL, 0);
\n if (flags == -1)
\n {
\n perror("fcntl: get flags");
\n return -1;
\n }
\n if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1)
\n {
\n perror("fcntl: set non-blocking");
\n return -1;
\n }
\n return 0;
\n }<\/p>\n
void Init()
\n {
\n }
\n void Start()
\n {
\n _quit = false;
\n \/\/ \u5c06listen\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u4e2d->\u5c06listensock\u548c\u4ed6\u5173\u5fc3\u7684\u4e8b\u4ef6，\u6dfb\u52a0\u5230\u5185\u6838\u7684epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811\u91cc\u9762
\n \/\/ 1.\u5c06listensock\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_ADD, _listensock_ptr->Fd(), (EPOLLIN | EPOLLET)); \/\/ \u6ce8\u610f\u8fd9\u91cc\u7684EPOLLET\u8bbe\u7f6e\u4e86ET\u6a21\u5f0f
\n \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e,\u8fd9\u4e2a\u5728\u521d\u59cb\u5316\u5df2\u7ecf\u5b8c\u6210\u4e86
\n struct epoll_event revs[num]; \/\/ \u4e13\u95e8\u7528\u6765\u5904\u7406\u4e8b\u4ef6\u7684
\n while (!_quit)
\n {
\n int n=_epoller_ptr->EpollerWait(revs,num);
\n for(int i=0;i<num;i++)
\n {<\/p>\n
}
\n }
\n _quit = true;
\n }<\/p>\n
private:
\n uint16_t _port;
\n std::shared_ptr<Epoller> _epoller_ptr;
\n std::unordered_map<int, std::shared_ptr<Connection>> _connections;
\n std::shared_ptr<Sock> _listensock_ptr;
\n bool _quit;
\n}; <\/p>\n
\u5199\u5230\u8fd9\u91cc，\u6211\u4eec\u53d1\u73b0\u6211\u4eec\u8fd9\u4e2a\u4ee3\u7801\u548c\u4e4b\u524d\u7684\u4e0d\u662f\u5dee\u4e0d\u591a\u5417？\u4f46\u4e8b\u5b9e\u4e0a，\u73b0\u5728\u624d\u5230\u5173\u952e\u7684\u5730\u65b9！！\u00a0<\/p>\n<\/p>\n
\u6211\u4eec\u5728\u4e0a\u9762\u63d0\u53ca：<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5f53\u67d0\u4e2a\u6587\u4ef6\u63cf\u8ff0\u7b26\u7684\u8bfb\u4e8b\u4ef6\u5c31\u7eea\u65f6，\u8c03\u7528recv\u51fd\u6570\u8bfb\u53d6\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u6570\u636e，\u4f46\u5e76\u4e0d\u80fd\u4fdd\u8bc1\u8bfb\u5230\u4e86\u4e00\u4e2a\u5b8c\u6574\u62a5\u6587，\u56e0\u6b64\u9700\u8981\u5c06\u8bfb\u53d6\u5230\u7684\u6570\u636e\u6682\u65f6\u5b58\u653e\u5230\u8be5\u6587\u4ef6\u63cf\u8ff0\u7b26\u5bf9\u5e94\u7684_inBuffer\u4e2d，\u5f53_inBuffer\u4e2d\u53ef\u4ee5\u5206\u79bb\u51fa\u4e00\u4e2a\u5b8c\u6574\u7684\u62a5\u6587\u540e\u518d\u5c06\u5176\u5206\u79bb\u51fa\u6765\u8fdb\u884c\u6570\u636e\u5904\u7406，_inBuffer\u672c\u8d28\u5c31\u662f\u7528\u6765\u89e3\u51b3\u7c98\u5305\u95ee\u9898\u7684<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5f53\u5904\u7406\u5b8c\u4e00\u4e2a\u62a5\u6587\u8bf7\u6c42\u540e，\u9700\u5c06\u54cd\u5e94\u6570\u636e\u53d1\u9001\u7ed9\u5ba2\u6237\u7aef，\u4f46\u5e76\u4e0d\u80fd\u4fdd\u8bc1\u5e95\u5c42TCP\u7684\u53d1\u9001\u7f13\u51b2\u533a\u4e2d\u6709\u8db3\u591f\u7684\u7a7a\u95f4\u5199\u5165，\u56e0\u6b64\u9700\u5c06\u8981\u53d1\u9001\u7684\u6570\u636e\u6682\u65f6\u5b58\u653e\u5230\u8be5\u6587\u4ef6\u63cf\u8ff0\u7b26\u5bf9\u5e94\u7684_outBuffer\u4e2d，\u5f53\u5e95\u5c42TCP\u7684\u53d1\u9001\u7f13\u51b2\u533a\u4e2d\u6709\u7a7a\u95f4，\u5373\u5199\u4e8b\u4ef6\u5c31\u7eea\u65f6，\u518d\u4f9d\u6b21\u53d1\u9001_outBuffer\u4e2d\u7684\u6570\u636e<\/p>\n<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u5199\u5230\u8fd9\u91cc，\u6211\u4eec\u9700\u8981\u7406\u89e3，\u6211\u4eec\u4e0d\u4ec5\u4ec5\u9700\u8981\u5c06listen\u5957\u63a5\u5b57\u52a0\u5165\u5230\u6211\u4eec\u7684epoll\u7684\u7ea2\u9ed1\u6811\u91cc\u9762，\u6211\u8fd8\u9700\u8981\u5c06listen\u5957\u63a5\u5b57\u5efa\u7acb\u4e00\u4e2aConnection\u5bf9\u8c61，\u5c06listen\u5957\u63a5\u5b57\u52a0\u5165\u5230Connection\u4e2d，\u540c\u65f6\u8fd8\u8981\u5373\u8981\u5c06<listen\u5957\u63a5\u5b57，Connection>\u653e\u5230\u6211\u4eec\u7684unordered_map\u5bf9\u8c61_connections\u91cc\u9762\u53bb\u3002\u53ea\u8981\u6211\u4eec\u628aConnection\u5bf9\u8c61\u7ba1\u7406\u597d\u4e86，\u6211\u4eec\u7684\u8fde\u63a5\u5c31\u7ba1\u7406\u597d\u4e86\u3002<\/p>\n
\u6240\u4ee5，\u6211\u4eec\u73b0\u5728\u9700\u8981\u91cd\u65b0\u7f16\u5199\u4e00\u4e0b\u6211\u4eec\u7684\u8fde\u63a5\u7c7b\u2014\u2014Connection\u7c7b<\/p>\n
Connection\u7c7b<\/p>\n
class Connection
\n{
\npublic:
\n Connection(int sock, std::shared_ptr<TcpServer> tcp_server_ptr) : _sock(sock), _tcp_server_ptr(tcp_server_ptr)
\n {
\n }
\n ~Connection()
\n {
\n }
\n void setcallback(func_t recv_cb, func_t send_cb, func_t except_cb)
\n {
\n _recv_cb = recv_cb;
\n _send_cb = send_cb;
\n _except_cd = except_cb;
\n }<\/p>\n
private:
\n int _sock;
\n std::string _inbuffer; \/\/ \u8fd9\u91cc\u6765\u5f53\u8f93\u5165\u7f13\u51b2\u533a，\u4f46\u662f\u8fd9\u91cc\u662f\u6709\u7f3a\u70b9\u7684，\u5b83\u4e0d\u80fd\u5904\u7406\u4e8c\u8fdb\u5236\u6d41
\n std::string _outbuffer;<\/p>\n
func_t _recv_cb; \/\/ \u8bfb\u56de\u8c03\u51fd\u6570
\n func_t _send_cb; \/\/ \u5199\u56de\u8c03\u51fd\u6570
\n func_t _except_cd; \/\/<\/p>\n
\/\/ \u6dfb\u52a0\u4e00\u4e2a\u56de\u6307\u6307\u9488
\n std::shared_ptr<TcpServer> _tcp_server_ptr;
\n }; <\/p>\n
\u73b0\u5728\u6211\u4eec\u5c31\u9700\u8981\u6765\u5b9e\u73b0\u6211\u4eec\u4e0a\u9762\u7684\u5185\u5bb9\u4e86<\/p>\n
void AddConnection(int sock, uint32_t event, func_t recv_cb, func_t send_cb, func_t except_cb,
\n std::string clientip="0.0.0.0",uint16_t clientport=0)
\n {<\/p>\n
\/\/ 1.\u7ed9listen\u5957\u63a5\u5b57\u521b\u5efa\u4e00\u4e2aConnection\u5bf9\u8c61
\n std::shared_ptr<Connection> new_connection = std::make_shared<Connection>(sock, std::shared_ptr<TcpServer>(this)); \/\/ \u521b\u5efaConnection\u5bf9\u8c61
\n new_connection->setcallback(recv_cb, send_cb, except_cb);<\/p>\n
\/\/ 2.\u6dfb\u52a0\u5230_connections\u91cc\u9762\u53bb
\n _connections.insert(std::make_pair(sock, new_connection));<\/p>\n
\/\/ \u5c06listen\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u4e2d->\u5c06listensock\u548c\u4ed6\u5173\u5fc3\u7684\u4e8b\u4ef6，\u6dfb\u52a0\u5230\u5185\u6838\u7684epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811\u91cc\u9762
\n \/\/ 3.\u5c06listensock\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_ADD, sock, event); \/\/ \u6ce8\u610f\u8fd9\u91cc\u7684EPOLLET\u8bbe\u7f6e\u4e86ET\u6a21\u5f0f<\/p>\n
std::cout << "add a new connection success,sockfd:" << sock << std::endl;
\n } <\/p>\n
\u6b63\u5982\u4e0a\u9762\u6240\u8bf4，\u8fd9\u4e2a\u51fd\u6570\u5b8c\u6210\u4e86\u4e09\u4ef6\u4e8b\u60c5\u3002<\/p>\n
\u63a5\u4e0b\u6765\u6211\u4eec\u5c31\u53ef\u4ee5\u4fee\u6539\u6211\u4eec\u7684Init\u51fd\u6570<\/p>\n
init\u51fd\u6570<\/p>\n
void Init()
\n {
\n _listensock_ptr->Socket();
\n set_non_blocking(_listensock_ptr->Fd()); \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n _listensock_ptr->Bind(_port);
\n _listensock_ptr->Listen();
\n AddConnection(_listensock_ptr->Fd(),(EPOLLIN|EPOLLET),nullptr,nullptr,nullptr);\/\/\u6682\u65f6\u8bbe\u7f6e\u6210nullptr
\n } <\/p>\n
\u6211\u4eec\u5728\u8fd9\u91cc\u5c06Start\u51fd\u6570\u66f4\u540d\u4e3aLoop\u51fd\u6570，\u5e76\u4e14\u521b\u5efa\u4e00\u4e2a\u65b0\u51fd\u6570Dispatcher<\/p>\n
bool IsConnectionSafe(int fd)
\n {
\n auto iter = _connections.find(fd);
\n if (iter == _connections.end())
\n {
\n return false;
\n }
\n else
\n {
\n return true;
\n }
\n }
\n void Dispatcher() \/\/ \u4e8b\u4ef6\u6d3e\u53d1\u5668
\n {
\n int n = _epoller_ptr->EpollerWait(revs, num); \/\/ \u83b7\u53d6\u5df2\u7ecf\u5c31\u7eea\u7684\u4e8b\u4ef6
\n for (int i = 0; i < num; i++)
\n {
\n uint32_t events = revs[i].events;
\n int sock = revs[i].data.fd;
\n \/\/ \u5982\u679c\u51fa\u73b0\u5f02\u5e38，\u7edf\u4e00\u8f6c\u53d1\u4e3a\u8bfb\u5199\u95ee\u9898，\u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLERR) \/\/ \u51fa\u73b0\u9519\u8bef\u4e86
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n if (events & EPOLLHUP)
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n \/\/ \u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLIN&&IsConnectionSafe(sock)) \/\/ \u8bfb\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if(_connections[sock]->_recv_cb)
\n _connections[sock]->_recv_cb(_connections[sock]);<\/p>\n
}
\n if (events & EPOLLOUT&&IsConnectionSafe(sock)) \/\/ \u5199\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if(_connections[sock]->_send_cb)
\n _connections[sock]->_send_cb(_connections[sock]);
\n }
\n }
\n }
\n void Loop()
\n {
\n _quit = false;<\/p>\n
while (!_quit)
\n {
\n Dispatcher();
\n }
\n _quit = true;
\n } <\/p>\n<\/p>\n
\u00a0 \u00a0\u4e8b\u4ef6\u6d3e\u53d1\u5668\u662f\u771f\u6b63\u670d\u52a1\u5668\u8981\u5f00\u59cb\u8fd0\u884c\u4e86，\u670d\u52a1\u5668\u4f1a\u5c06\u5c31\u7eea\u7684\u6bcf\u4e2a\u8fde\u63a5\u90fd\u8fdb\u884c\u5904\u7406，\u9996\u5148\u5982\u679c\u8fde\u63a5\u4e0d\u5728\u54c8\u5e0c\u8868\u4e2d，\u90a3\u5c31\u8bf4\u660e\u8fd9\u4e2a\u8fde\u63a5\u4e2d\u7684sock\u8fd8\u6ca1\u6709\u88ab\u6dfb\u52a0\u5230epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811，\u4e0d\u80fd\u76f4\u63a5\u8fdb\u884c\u5904\u7406，\u9700\u8981\u5148\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811\u4e2d，\u7136\u540e\u8ba9epoll_wait\u6765\u62ff\u53d6\u5c31\u7eea\u7684\u8fde\u63a5\u518d\u544a\u77e5\u7a0b\u5e8f\u5458，\u8fd9\u4e2a\u65f6\u5019\u518d\u8fdb\u884c\u5904\u7406，\u8fd9\u6837\u624d\u4e0d\u4f1a\u7b49\u5f85，\u800c\u662f\u76f4\u63a5\u8fdb\u884c\u6570\u636e\u62f7\u8d1d\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 Loop\u4e2d\u5904\u7406\u5c31\u7eea\u7684\u4e8b\u4ef6\u7684\u65b9\u6cd5\u975e\u5e38\u975e\u5e38\u7684\u7b80\u5355，\u5982\u679c\u8be5\u5c31\u7eea\u7684fd\u5173\u5fc3\u7684\u662f\u8bfb\u4e8b\u4ef6，\u90a3\u5c31\u76f4\u63a5\u8c03\u7528\u8be5sock\u6240\u5728\u8fde\u63a5\u7ed3\u6784\u4f53\u5185\u90e8\u7684\u8bfb\u65b9\u6cd5\u5373\u53ef，\u5982\u679c\u662f\u5199\u4e8b\u4ef6\u90a3\u5c31\u8c03\u7528\u5199\u65b9\u6cd5\u5373\u53ef\u3002\u6709\u4eba\u8bf4\u90a3\u5982\u679cfd\u5173\u5fc3\u5f02\u5e38\u4e8b\u4ef6\u5462？\u5176\u5b9e\u5f02\u5e38\u4e8b\u4ef6\u5927\u90e8\u5206\u4e5f\u90fd\u662f\u8bfb\u4e8b\u4ef6，\u4e0d\u8fc7\u4e5f\u6709\u5199\u4e8b\u4ef6，\u6240\u4ee5\u5904\u7406\u5f02\u5e38\u7684\u903b\u8f91\u6211\u4eec\u76f4\u63a5\u653e\u5230\u8bfb\u65b9\u6cd5\u548c\u5199\u65b9\u6cd5\u91cc\u9762\u5373\u53ef，\u5f53\u6709\u5f02\u5e38\u4e8b\u4ef6\u5230\u6765\u65f6，\u76f4\u63a5\u53bb\u5bf9\u5e94\u7684\u8bfb\u65b9\u6cd5\u6216\u5199\u65b9\u6cd5\u91cc\u9762\u6267\u884c\u5bf9\u5e94\u7684\u903b\u8f91\u5373\u53ef\u3002<\/p>\n
\u4ee5\u4e0b\u662f\u4e00\u4e9b\u53ef\u80fd\u89e6\u53d1 EPOLLERR \u4e8b\u4ef6\u7684\u60c5\u51b5\u7684\u793a\u4f8b:<\/p>\n
2.\u63a5\u6536\u9519\u8bef:\u5728\u975e\u963b\u585e\u5957\u63a5\u5b57\u4e0a\u8fdb\u884c\u8bfb\u53d6\u64cd\u4f5c\u65f6，\u5982\u679c\u53d1\u751f\u9519\u8bef，\u4f8b\u5982\u5bf9\u65b9\u5173\u95ed\u4e86\u8fde\u63a5\u6216\u8005\u63a5\u6536\u7f13\u51b2\u533a\u6ea2\u51fa，\u5957\u63a5\u5b57\u7684 epol \u4e8b\u4ef6\u96c6\u4e2d\u5c06\u5305\u542b EPOLLERR \u4e8b\u4ef6\u3002 3.\u53d1\u9001\u9519\u8bef:\u5728\u975e\u963b\u585e\u5957\u63a5\u5b57\u4e0a\u8fdb\u884c\u5199\u5165\u64cd\u4f5c\u65f6，\u5982\u679c\u53d1\u751f\u9519\u8bef，\u4f8b\u5982\u5bf9\u65b9\u5173\u95ed\u4e86\u8fde\u63a5\u6216\u8005\u53d1\u9001\u7f13\u51b2\u533a\u6ea2\u51fa，\u5957\u63a5\u5b57\u7684 epol \u4e8b\u4ef6\u96c6\u4e2d\u5c06\u5305\u542b EPOLLERR \u4e8b\u4ef6\u3002<\/p>\n<\/li>\n
\u9700\u8981\u6ce8\u610f\u7684\u662f，EPOLLERR \u4e8b\u4ef6\u901a\u5e38\u4e0e EPOLLIN \u6216 EPOLLOUT \u4e8b\u4ef6\u4e00\u8d77\u4f7f\u7528\u3002\u5f53\u53d1\u751f EPOLLERR \u4e8b\u4ef6\u65f6，\u901a\u5e38\u4e5f\u4f1a\u540c\u65f6\u53d1\u751f EPOLLIN \u6216EPOLLOUT \u4e8b\u4ef6..<\/p>\n<\/p>\n
\u00a0 \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u5047\u8bbe\u67d0\u4e2a\u5f02\u5e38\u4e8b\u4ef6\u53d1\u751f\u4e86，\u90a3\u4e48\u8fd9\u4e2a\u5f02\u5e38\u4e8b\u4ef6\u4f1a\u81ea\u52a8\u88ab\u5185\u6838\u8bbe\u7f6e\u5230epoll_wait\u8fd4\u56de\u7684\u4e8b\u4ef6\u96c6\u4e2d，\u8fd9\u4e2a\u5f02\u5e38\u4e8b\u4ef6\u4e00\u5b9a\u4f1a\u548c\u4e00\u4e2asock\u5173\u8054，\u6bd4\u5982\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\u7528sock\u901a\u4fe1\u7740，\u7a81\u7136\u5ba2\u6237\u7aef\u5173\u95ed\u8fde\u63a5，\u90a3\u4e48\u670d\u52a1\u5668\u7684sock\u4e0a\u539f\u672c\u5173\u5fc3\u7740\u8bfb\u4e8b\u4ef6，\u6b64\u65f6\u5185\u6838\u4f1a\u81ea\u52a8\u5c06\u5f02\u5e38\u4e8b\u4ef6\u8bbe\u7f6e\u5230\u8be5sock\u5173\u5fc3\u7684\u4e8b\u4ef6\u96c6\u5408\u91cc，\u5728\u5904\u7406sock\u5173\u5fc3\u7684\u8bfb\u4e8b\u4ef6\u65f6，\u8bfb\u65b9\u6cd5\u4f1a\u634e\u5e26\u5904\u7406\u6389\u8fd9\u4e2a\u5f02\u5e38\u4e8b\u4ef6，\u5904\u7406\u65b9\u5f0f\u4e3a\u670d\u52a1\u5668\u5173\u95ed\u901a\u4fe1\u7684sock，\u56e0\u4e3a\u5ba2\u6237\u7aef\u5df2\u7ecf\u628a\u8fde\u63a5\u65ad\u5f00\u4e86，\u670d\u52a1\u5668\u6ca1\u5fc5\u8981\u7ef4\u62a4\u548c\u8fd9\u4e2a\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u4e86，\u670d\u52a1\u5668\u4e5f\u65ad\u5f00\u5c31\u597d，\u8fd9\u6837\u7684\u903b\u8f91\u5728\u8bfb\u65b9\u6cd5\u91cc\u9762\u5c31\u53ef\u4ee5\u5b9e\u73b0\u3002<\/p>\n<\/p>\n
\u6211\u4eec\u770b\u4e0a\u9762\u7684\u4e8b\u4ef6\u6d3e\u53d1\u5668，\u6700\u540e\u90fd\u662f\u6d3e\u53d1\u7ed9_send_cb\u548c_recv_cb\u51fd\u6570，\u8fd9\u4e24\u4e2a\u51fd\u6570\u6211\u4eec\u8fd8\u6ca1\u6709\u8bbe\u7f6e\u5462！\u6240\u4ee5\u6211\u4eec\u9700\u8981\u6765\u8bbe\u7f6e\u4e00\u4e0b<\/p>\n
void Init()
\n {
\n _listensock_ptr->Socket();
\n set_non_blocking(_listensock_ptr->Fd()); \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n _listensock_ptr->Bind(_port);
\n _listensock_ptr->Listen();
\n AddConnection(_listensock_ptr->Fd(), (EPOLLIN | EPOLLET),
\n std::bind(&TcpServer::Accepter, this, std::placeholders::_1), nullptr, nullptr); \/\/ \u6682\u65f6\u8bbe\u7f6e\u6210nullptr
\n }
\n void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len=sizeof(peer);
\n int sock=accept(conection->Getsock(),(sockaddr*)&peer,&len);
\n if(sock>0)
\n {
\n set_non_blocking(sock);\/\/\u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection (sock,EPOLLIN,nullptr,nullptr,nullptr);
\n }
\n else{
\n if(errno==EWOULDBLOCK) break;
\n else if(errno==EINTR) break;
\n else break;<\/p>\n
}<\/p>\n
}
\n } <\/p>\n
\u00a0 \u4f46\u5982\u679c\u4f60\u8981\u662f\u5728\u7c7b\u5185\u4f20\u53c2，\u90a3\u5c31\u6709\u95ee\u9898\u4e86，\u4f1a\u51fa\u73b0\u7c7b\u578b\u4e0d\u5339\u914d\u7684\u95ee\u9898，\u8fd9\u4e2a\u95ee\u9898\u771f\u7684\u5f88\u6076\u5fc3，\u800c\u4e14\u8fd9\u4e2a\u95ee\u9898\u4e00\u62a5\u9519\u5c31\u5288\u91cc\u556a\u5566\u7684\u62a5\u4e00\u5927\u5806\u9519，\u56e0\u4e3afunction\u662f\u6a21\u677f，C++\u62a5\u9519\u6700\u6076\u5fc3\u7684\u5c31\u662f\u6a21\u677f\u62a5\u9519，\u4e00\u62a5\u9519\u4eba\u90fd\u8981\u70b8\u4e86\u3002\u8bdd\u8bf4\u56de\u6765，\u4e3a\u4ec0\u4e48\u662f\u7c7b\u578b\u4e0d\u5339\u914d\u5462？\u56e0\u4e3a\u5728\u7c7b\u5185\u8c03\u7528\u7c7b\u5185\u65b9\u6cd5\u65f6，\u5176\u5b9e\u662f\u901a\u8fc7this\u6307\u9488\u6765\u8c03\u7528\u7684，\u5982\u679c\u4f60\u76f4\u63a5\u5c06Accepter\u65b9\u6cd5\u4f20\u7ed9AddConnection，\u4e24\u8005\u7c7b\u578b\u662f\u4e0d\u5339\u914d\u7684，\u56e0\u4e3aAccepter\u7684\u7b2c\u4e00\u4e2a\u53c2\u6570\u662fthis\u6307\u9488，\u6b63\u786e\u7684\u505a\u6cd5\u662f\u5229\u7528\u5305\u88c5\u5668\u7684\u9002\u914d\u5668bind\u6765\u8fdb\u884c\u4f20\u53c2，bind\u5c06Accepter\u8fdb\u884c\u7ed1\u5b9a，\u524d\u4e24\u4e2a\u53c2\u6570\u4e3a\u7ed1\u5b9a\u7684\u5bf9\u8c61\u7c7b\u578b \u548c \u7ed9\u7ed1\u5b9a\u7684\u5bf9\u8c61\u6240\u4f20\u7684\u53c2\u6570，\u56e0\u4e3aAccepter\u7b2c\u4e00\u4e2a\u53c2\u6570\u662fthis\u6307\u9488，\u6240\u4ee5\u7b2c\u4e00\u4e2a\u53c2\u6570\u5c31\u53ef\u4ee5\u56fa\u5b9a\u4f20this，\u540e\u9762\u7684\u4e00\u4e2a\u53c2\u6570\u4e0d\u5e94\u8be5\u662f\u73b0\u5728\u4f20，\u800c\u5e94\u8be5\u662f\u8c03\u7528Accepter\u65b9\u6cd5\u7684\u65f6\u5019\u518d\u4f20，\u53ea\u6709\u8fd9\u6837\u624d\u80fd\u5728\u7c7b\u5185\u5c06\u7c7b\u6210\u5458\u51fd\u6570\u6307\u9488\u4f20\u7ed9\u5305\u88c5\u5668\u7c7b\u578b\u3002<\/p>\n<\/li>\n
\u00a0\u4e0d\u8fc7\u5427\u8fd8\u6709\u4e00\u79cd\u4e0d\u5e38\u7528\u7684\u65b9\u6cd5，\u5c31\u662f\u5229\u7528lambda\u8868\u8fbe\u5f0f\u6765\u8fdb\u884c\u4f20\u53c2，lambda\u53ef\u4ee5\u6355\u6349\u4e0a\u4e0b\u6587\u7684this\u6307\u9488，\u7136\u540e\u518d\u628alambda\u7c7b\u578b\u4f20\u7ed9\u5305\u88c5\u5668\u7c7b\u578b，\u8fd9\u79cd\u65b9\u5f0f\u4e0d\u5e38\u7528，\u7528\u8d77\u6765\u4e5f\u602a\u522b\u626d\u7684，function\u548cbind\u662f\u9002\u914d\u6a21\u5f0f，\u4e24\u8005\u642d\u914d\u5728\u4e00\u8d77\u7528\u8fd8\u662f\u66f4\u987a\u773c\u4e00\u4e9b，lambda\u8fd9\u79cd\u65b9\u5f0f\u4e86\u89e3\u4e00\u4e0b\u5c31\u597d\u3002<\/p>\n<\/li>\n
\u4e3a\u4e86\u6f14\u793a\u6548\u679c，\u6211\u4eec\u5199\u4e86\u4e00\u4e2a\u6253\u5370\u51fd\u6570\u6765\u5c55\u793a！<\/p>\n
void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len=sizeof(peer);
\n int sock=accept(conection->Getsock(),(sockaddr*)&peer,&len);
\n if(sock>0)
\n {
\n \/\/\u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport=ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET,&(peer.sin_addr),buffer,sizeof(buffer));
\n std::cout<<"get a new client from:"<<buffer<<conection->Getsock()<<std::endl;<\/p>\n
set_non_blocking(sock);\/\/\u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection (sock,EPOLLIN,nullptr,nullptr,nullptr);
\n }
\n else{
\n if(errno==EWOULDBLOCK) break;
\n else if(errno==EINTR) break;
\n else break;<\/p>\n
}<\/p>\n
}
\n }
\n void PrintConnection()
\n {
\n std::cout<<"_connections fd list: "<<std::endl;
\n for(auto&connection:_connections)
\n {
\n std::cout<<connection.second->Getsock()<<" ";
\n }
\n std::cout<<std::endl;
\n } <\/p>\n<\/p>\n
tcpserver.hpp\u00a0<\/p>\n
#pragma once
\n#include <iostream>
\n#include <string>
\n#include <functional>
\n#include <memory>
\n#include <unordered_map><\/p>\n
#include "Socket.hpp"
\n#include "Epoller.hpp"
\n#include "nocopy.hpp"<\/p>\n
class Connection;
\nusing func_t = std::function<void(std::shared_ptr<Connection>)>;
\nclass TcpServer;<\/p>\n
class Connection
\n{
\npublic:
\n Connection(int sock, std::shared_ptr<TcpServer> tcp_server_ptr) : _sock(sock), _tcp_server_ptr(tcp_server_ptr)
\n {
\n }
\n ~Connection()
\n {
\n }
\n void setcallback(func_t recv_cb, func_t send_cb, func_t except_cb)
\n {
\n _recv_cb = recv_cb;
\n _send_cb = send_cb;
\n _except_cb = except_cb;
\n }
\n int Getsock()
\n {
\n return _sock;
\n }<\/p>\n
private:
\n int _sock;
\n std::string _inbuffer; \/\/ \u8fd9\u91cc\u6765\u5f53\u8f93\u5165\u7f13\u51b2\u533a，\u4f46\u662f\u8fd9\u91cc\u662f\u6709\u7f3a\u70b9\u7684，\u5b83\u4e0d\u80fd\u5904\u7406\u4e8c\u8fdb\u5236\u6d41
\n std::string _outbuffer;<\/p>\n
public:
\n func_t _recv_cb; \/\/ \u8bfb\u56de\u8c03\u51fd\u6570
\n func_t _send_cb; \/\/ \u5199\u56de\u8c03\u51fd\u6570
\n func_t _except_cb; \/\/<\/p>\n
\/\/ \u6dfb\u52a0\u4e00\u4e2a\u56de\u6307\u6307\u9488
\n std::shared_ptr<TcpServer> _tcp_server_ptr;
\n};
\nclass TcpServer : public nocopy
\n{
\n static const int num = 64;<\/p>\n
public:
\n TcpServer(uint16_t port) : _port(port),
\n _listensock_ptr(new Sock()),
\n _epoller_ptr(new Epoller()),
\n _quit(true)
\n {
\n }
\n ~TcpServer()
\n {
\n }
\n \/\/ \u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n int set_non_blocking(int fd)
\n {
\n int flags = fcntl(fd, F_GETFL, 0);
\n if (flags == -1)
\n {
\n perror("fcntl: get flags");
\n return -1;
\n }
\n if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1)
\n {
\n perror("fcntl: set non-blocking");
\n return -1;
\n }
\n return 0;
\n }<\/p>\n
void Init()
\n {
\n _listensock_ptr->Socket();
\n set_non_blocking(_listensock_ptr->Fd()); \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n _listensock_ptr->Bind(_port);
\n _listensock_ptr->Listen();
\n AddConnection(_listensock_ptr->Fd(), (EPOLLIN | EPOLLET),
\n std::bind(&TcpServer::Accepter, this, std::placeholders::_1), nullptr, nullptr); \/\/ \u6682\u65f6\u8bbe\u7f6e\u6210nullptr
\n }
\n void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len=sizeof(peer);
\n int sock=accept(conection->Getsock(),(sockaddr*)&peer,&len);
\n if(sock>0)
\n {
\n \/\/\u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport=ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET,&(peer.sin_addr),buffer,sizeof(buffer));
\n std::cout<<"get a new client from:"<<buffer<<conection->Getsock()<<std::endl;<\/p>\n
set_non_blocking(sock);\/\/\u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection (sock,EPOLLIN,nullptr,nullptr,nullptr);
\n }
\n else{
\n if(errno==EWOULDBLOCK) break;
\n else if(errno==EINTR) break;
\n else break;<\/p>\n
}<\/p>\n
}
\n }
\n void PrintConnection()
\n {
\n std::cout<<"_connections fd list: "<<std::endl;
\n for(auto&connection:_connections)
\n {
\n std::cout<<connection.second->Getsock()<<" ";
\n }
\n std::cout<<std::endl;
\n }
\n void AddConnection(int sock, uint32_t event, func_t recv_cb, func_t send_cb, func_t except_cb)
\n {
\n \/\/ 1.\u7ed9listen\u5957\u63a5\u5b57\u521b\u5efa\u4e00\u4e2aConnection\u5bf9\u8c61
\n std::shared_ptr<Connection> new_connection = std::make_shared<Connection>(sock, std::shared_ptr<TcpServer>(this)); \/\/ \u521b\u5efaConnection\u5bf9\u8c61
\n new_connection->setcallback(recv_cb, send_cb, except_cb);<\/p>\n
\/\/ 2.\u6dfb\u52a0\u5230_connections\u91cc\u9762\u53bb
\n _connections.insert(std::make_pair(sock, new_connection));<\/p>\n
\/\/ \u5c06listen\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u4e2d->\u5c06listensock\u548c\u4ed6\u5173\u5fc3\u7684\u4e8b\u4ef6，\u6dfb\u52a0\u5230\u5185\u6838\u7684epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811\u91cc\u9762
\n \/\/ 3.\u5c06listensock\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_ADD, sock, event); \/\/ \u6ce8\u610f\u8fd9\u91cc\u7684EPOLLET\u8bbe\u7f6e\u4e86ET\u6a21\u5f0f<\/p>\n
std::cout<<"add a new connection success,sockfd:"<<sock<<std::endl;
\n }
\n bool IsConnectionSafe(int fd)
\n {
\n auto iter = _connections.find(fd);
\n if (iter == _connections.end())
\n {
\n return false;
\n }
\n else
\n {
\n return true;
\n }
\n }
\n void Dispatcher() \/\/ \u4e8b\u4ef6\u6d3e\u53d1\u5668
\n {
\n int n = _epoller_ptr->EpollerWait(revs, num); \/\/ \u83b7\u53d6\u5df2\u7ecf\u5c31\u7eea\u7684\u4e8b\u4ef6
\n for (int i = 0; i < num; i++)
\n {
\n uint32_t events = revs[i].events;
\n int sock = revs[i].data.fd;
\n \/\/ \u5982\u679c\u51fa\u73b0\u5f02\u5e38，\u7edf\u4e00\u8f6c\u53d1\u4e3a\u8bfb\u5199\u95ee\u9898，\u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLERR) \/\/ \u51fa\u73b0\u9519\u8bef\u4e86
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n if (events & EPOLLHUP)
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n \/\/ \u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLIN && IsConnectionSafe(sock)) \/\/ \u8bfb\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if (_connections[sock]->_recv_cb)
\n _connections[sock]->_recv_cb(_connections[sock]);
\n }
\n if (events & EPOLLOUT && IsConnectionSafe(sock)) \/\/ \u5199\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if (_connections[sock]->_send_cb)
\n _connections[sock]->_send_cb(_connections[sock]);
\n }
\n }
\n }
\n void Loop()
\n {
\n _quit = false;<\/p>\n
while (!_quit)
\n {
\n Dispatcher();
\n PrintConnection();
\n }
\n _quit = true;
\n }<\/p>\n
private:
\n uint16_t _port;
\n std::shared_ptr<Epoller> _epoller_ptr;
\n std::unordered_map<int, std::shared_ptr<Connection>> _connections;
\n std::shared_ptr<Sock> _listensock_ptr;
\n bool _quit;
\n struct epoll_event revs[num]; \/\/ \u4e13\u95e8\u7528\u6765\u5904\u7406\u4e8b\u4ef6\u7684
\n}; <\/p>\n
\u6211\u4eec\u770b\u770b\u6548\u679c<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105651-680381731dbd4.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105651-680381734317b.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105651-68038173656fc.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105651-680381738b927.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105651-68038173ad788.png\")
<\/p>\n<\/p>\n
\u8fd8\u53ef\u4ee5\u554a！！！\u5230\u8fd9\u91cc\u6211\u4eec\u5c31\u7b97\u662f\u6253\u901a\u4e86\u6211\u4eec\u8fde\u63a5\u7684\u8fc7\u7a0b，\u6211\u4eec\u63a5\u7740\u770b<\/p>\n
\u6211\u4eec\u770b\u770b\u8fd9\u4e2aAccepter\u51fd\u6570<\/p>\n
void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len=sizeof(peer);
\n int sock=accept(conection->Getsock(),(sockaddr*)&peer,&len);
\n if(sock>0)
\n {
\n \/\/\u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport=ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET,&(peer.sin_addr),buffer,sizeof(buffer));
\n std::cout<<"get a new client from:"<<buffer<<conection->Getsock()<<std::endl;<\/p>\n
set_non_blocking(sock);\/\/\u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection (sock,EPOLLIN,nullptr,nullptr,nullptr);
\n }
\n else{
\n if(errno==EWOULDBLOCK) break;
\n else if(errno==EINTR) break;
\n else break;<\/p>\n
}<\/p>\n
}
\n } <\/p>\n<\/p>\n
\u6ce8\u610f\u91cc\u9762\u7684AddConnection\u51fd\u6570，\u8fd9\u4e2a\u51fd\u6570\u662f\u7528\u6587\u4ef6\u63cf\u8ff0\u7b26\u6765\u521b\u5efaConnection\u5bf9\u8c61\u7684\u3002\u4f46\u662f\u6587\u4ef6\u63cf\u8ff0\u7b26\u6709\u4e24\u79cd\u554a！\u4e00\u4e2a\u662flisten\u5957\u63a5\u5b57，\u4e00\u4e2a\u662f\u666e\u901a\u5957\u63a5\u5b57\u3002Listen\u5957\u63a5\u5b57\u53ea\u5173\u5fc3\u8bfb\u4e8b\u4ef6，\u800c\u5176\u4ed6\u6587\u4ef6\u63cf\u8ff0\u7b26\u5219\u662f\u5173\u5fc3\u8bfb，\u5199，\u5f02\u5e38\u4e8b\u4ef6\u7684！！\u4f46\u662f\u6211\u4eec\u5728\u8fd9\u91cc\u5374\u7edf\u4e00\u4f7f\u7528\u4e86AddConnection (sock,EPOLLIN,nullptr,nullptr,nullptr);\u4e00\u68cd\u5b50\u6253\u6b7b，\u53ea\u5173\u5fc3\u8bfb\u4e8b\u4ef6\u3002\u8fd9\u6837\u5b50\u662f\u975e\u5e38\u4e0d\u5408\u7406\u7684\u3002<\/p>\n
\u6240\u4ee5\u5bf9\u5e94AddConnection (sock,EPOLLIN,nullptr,nullptr,nullptr);\u8fd9\u91cc，\u6211\u4eec\u9700\u8981\u4fee\u6539<\/p>\n
\/\/\u8fde\u63a5\u7ba1\u7406\u5668
\n void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len=sizeof(peer);
\n int sock=accept(conection->Getsock(),(sockaddr*)&peer,&len);
\n if(sock>0)
\n {
\n \/\/\u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport=ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET,&(peer.sin_addr),buffer,sizeof(buffer));
\n std::cout<<"get a new client from:"<<buffer<<conection->Getsock()<<std::endl;<\/p>\n
set_non_blocking(sock);\/\/\u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection (sock,EPOLLIN,
\n std::bind(&TcpServer::Recver, this, std::placeholders::_1),
\n std::bind(&TcpServer::Sender, this, std::placeholders::_1),
\n std::bind(&TcpServer::Excepter, this, std::placeholders::_1);
\n }
\n else{
\n if(errno==EWOULDBLOCK) break;
\n else if(errno==EINTR) break;
\n else break;<\/p>\n
}<\/p>\n
}
\n }
\n \/\/\u4e8b\u4ef6\u7ba1\u7406\u5668
\n void Recver(std::shared_ptr<Connection> conection)
\n {
\n std::cout<<"haha ,got you"<<conection->Getsock()<<std::endl;
\n }
\n void Sender(std::shared_ptr<Connection> conection)
\n {}
\n void Excepter(std::shared_ptr<Connection> conection)
\n {} <\/p>\n
\u6211\u4eec\u53ef\u4ee5\u6d4b\u8bd5\u4e00\u4e0b，\u5230\u5e95\u6709\u6ca1\u6709\u7528<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105651-68038173d9a26.png\")
<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-6803817407907.png\")
<\/p>\n<\/p>\n
\u6211\u4eec\u53d1\u73b0\u5b83\u5728\u4e00\u76f4\u6253\u5370！\u8bf4\u660e\u6211\u4eec\u6210\u529f\u4e86！！<\/p>\n
\u597d\u4e86，\u6211\u4eec\u73b0\u5728\u5c31\u5e94\u8be5\u6765\u5904\u7406\u8bfb\u5199\u5f02\u5e38\u4e8b\u4ef6<\/p>\n
\u00a0 \u00a0 Recver\u8fd9\u91cc\u8fd8\u662f\u548c\u4e4b\u524d\u4e00\u6837\u7684\u95ee\u9898，\u4e5f\u662f\u524d\u9762\u5728\u5199\u4e09\u4e2a\u591a\u8def\u8f6c\u63a5\u63a5\u53e3\u670d\u52a1\u5668\u65f6，\u4e00\u76f4\u6ca1\u6709\u5904\u7406\u7684\u95ee\u9898，\u4f60\u600e\u4e48\u4fdd\u8bc1\u4f60\u4e00\u6b21\u5c31\u628a\u6240\u6709\u6570\u636e\u5168\u90e8\u90fd\u8bfb\u4e0a\u6765\u4e86\u5462？<\/p>\n
\u5982\u679c\u4e0d\u80fd\u4fdd\u8bc1，\u90a3\u5c31\u548cAccepter\u4e00\u6837，\u5fc5\u987b\u6253\u6b7b\u5faa\u73af\u6765\u8fdb\u884c\u8bfb\u53d6，\u5f53recv\u8fd4\u56de\u503c\u5927\u4e8e0，\u90a3\u6211\u4eec\u5c31\u628a\u8bfb\u53d6\u5230\u7684\u6570\u636e\u5148\u653e\u5165\u7f13\u51b2\u533a，\u7f13\u51b2\u533a\u5728\u54ea\u91cc\u5462？<\/p>\n
\u00a0\u00a0\u5176\u5b9e\u5c31\u5728connection\u53c2\u6570\u6240\u6307\u5411\u7684\u7ed3\u6784\u4f53\u91cc\u9762，\u7ed3\u6784\u4f53\u91cc\u4f1a\u6709sock\u6240\u5bf9\u5e94\u7684\u6536\u53d1\u7f13\u51b2\u533a\u3002\u7136\u540e\u5c31\u8c03\u7528\u5916\u90e8\u4f20\u5165\u7684\u56de\u8c03\u51fd\u6570_service，\u5bf9\u670d\u52a1\u5668\u6536\u5230\u7684\u6570\u636e\u8fdb\u884c\u5e94\u7528\u5c42\u7684\u4e1a\u52a1\u903b\u8f91\u5904\u7406\u3002<\/p>\n
\u4e1a\u52a1\u903b\u8f91\u5904\u7406\u65b9\u6cd5\u5e94\u8be5\u5728\u672c\u6b21\u5faa\u73af\u8bfb\u53d6\u5230\u6240\u6709\u7684\u6570\u636e\u4e4b\u540e\u518d\u8fdb\u884c\u5904\u7406\u3002<\/p>\n<\/li>\n
class Connection
\n{
\n……
\n void Append(std::string info)\/\/\u8bfb\u53d6\u6210\u529f\u4e86，\u5c31\u628a\u8bfb\u53d6\u7684\u5185\u5bb9\u5b58\u5230\u8fd9\u91cc\u6765！
\n {
\n _inbuffer+=info;
\n }<\/p>\n
private:
\n int _sock;
\n std::string _inbuffer; \/\/ \u8fd9\u91cc\u6765\u5f53\u8f93\u5165\u7f13\u51b2\u533a，\u4f46\u662f\u8fd9\u91cc\u662f\u6709\u7f3a\u70b9\u7684，\u5b83\u4e0d\u80fd\u5904\u7406\u4e8c\u8fdb\u5236\u6d41
\n std::string _outbuffer;<\/p>\n
}; <\/p>\n
\u6211\u4eec\u63a5\u7740\u5199，<\/p>\n
\u4e3a\u4e86\u65b9\u4fbf，\u6211\u4eec\u8fd9\u91cc\u7ed9Connection\u7c7b\u52a0\u5165\u4e24\u4e2a\u65b0\u6210\u5458，\u4e0b\u9762\u662f\u4fee\u6539\u7684\u90e8\u5206<\/p>\n
class Connection
\n{
\npublic:<\/p>\n
uint16_t _clientport;
\n std::string _clientip;
\n};
\nclass TcpServer : public nocopy
\n{
\n \/\/ \u8fde\u63a5\u7ba1\u7406\u5668
\n void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n int sock = accept(conection->Getsock(), (sockaddr *)&peer, &len);
\n if (sock > 0)
\n {
\n \/\/ \u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport = ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET, &(peer.sin_addr), buffer, sizeof(buffer));
\n std::cout << "get a new client from:" << buffer << conection->Getsock() << std::endl;<\/p>\n
set_non_blocking(sock); \/\/ \u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection(sock, EPOLLIN,
\n std::bind(&TcpServer::Recver, this, std::placeholders::_1),
\n std::bind(&TcpServer::Sender, this, std::placeholders::_1),
\n std::bind(&TcpServer::Excepter, this, std::placeholders::_1),
\n buffer,clientport);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n break;
\n }
\n }
\n }
\n \/\/ \u4e8b\u4ef6\u7ba1\u7406\u5668
\n void Recver(std::shared_ptr<Connection> conection)
\n {
\n int sock = conection->Getsock();
\n while (1)
\n {
\n char buffer[128];
\n memset(buffer, 0, sizeof(buffer));
\n ssize_t n = recv(sock, buffer, sizeof(buffer) – 1, 0); \/\/ \u975e\u963b\u585e\u8bfb\u53d6
\n if (n > 0) \/\/ \u6210\u529f\u4e86！！
\n {
\n conection->Append(buffer); \/\/ \u628a\u8bfb\u53d6\u7684\u6570\u636e\u653e\u5230Connection\u5bf9\u8c61\u7684\u8f93\u5165\u7f13\u51b2\u533a\u91cc\u9762
\n }
\n else if (n == 0)
\n {<\/p>\n
}
\n else
\n {<\/p>\n
}
\n }
\n }<\/p>\n
void AddConnection(int sock, uint32_t event, func_t recv_cb, func_t send_cb, func_t except_cb,
\n std::string clientip="0.0.0.0",uint16_t clientport=0)
\n {<\/p>\n
\/\/ 1.\u7ed9listen\u5957\u63a5\u5b57\u521b\u5efa\u4e00\u4e2aConnection\u5bf9\u8c61
\n std::shared_ptr<Connection> new_connection = std::make_shared<Connection>(sock, std::shared_ptr<TcpServer>(this)); \/\/ \u521b\u5efaConnection\u5bf9\u8c61
\n new_connection->setcallback(recv_cb, send_cb, except_cb);
\n new_connection->_clientip=clientip;
\n new_connection->_clientport=clientport;<\/p>\n
\/\/ 2.\u6dfb\u52a0\u5230_connections\u91cc\u9762\u53bb
\n _connections.insert(std::make_pair(sock, new_connection));<\/p>\n
\/\/ \u5c06listen\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u4e2d->\u5c06listensock\u548c\u4ed6\u5173\u5fc3\u7684\u4e8b\u4ef6，\u6dfb\u52a0\u5230\u5185\u6838\u7684epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811\u91cc\u9762
\n \/\/ 3.\u5c06listensock\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_ADD, sock, event); \/\/ \u6ce8\u610f\u8fd9\u91cc\u7684EPOLLET\u8bbe\u7f6e\u4e86ET\u6a21\u5f0f<\/p>\n
std::cout << "add a new connection success,sockfd:" << sock << std::endl;
\n }<\/p>\n
}; <\/p>\n
\u5177\u4f53\u4fee\u6539\u770b\u4ee3\u7801\u5373\u53ef<\/p>\n<\/p>\n
\u00a0\u6211\u4eec\u63a5\u7740\u5b8c\u5584\u6211\u4eec\u7684\u8bfb\u4e8b\u4ef6\u7684\u5904\u7406<\/p>\n
\/\/ \u4e8b\u4ef6\u7ba1\u7406\u5668
\n void Recver(std::shared_ptr<Connection> conection)
\n {
\n int sock = conection->Getsock();
\n while (1)
\n {
\n char buffer[128];
\n memset(buffer, 0, sizeof(buffer));
\n ssize_t n = recv(sock, buffer, sizeof(buffer) – 1, 0); \/\/ \u975e\u963b\u585e\u8bfb\u53d6
\n if (n > 0) \/\/ \u6210\u529f\u4e86！！
\n {
\n conection->Append(buffer); \/\/ \u628a\u8bfb\u53d6\u7684\u6570\u636e\u653e\u5230Connection\u5bf9\u8c61\u7684\u8f93\u5165\u7f13\u51b2\u533a\u91cc\u9762
\n }
\n else if (n == 0) \/\/ \u5ba2\u6237\u7aef
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "quit" << std::endl;
\n Excepter(conection);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "recv err" << std::endl;
\n Excepter(conection);
\n }
\n }
\n }
\n }
\n void Sender(std::shared_ptr<Connection> conection)
\n {
\n }
\n void Excepter(std::shared_ptr<Connection> conection)
\n {
\n } <\/p>\n
\u597d，\u6211\u4eec\u628a\u6e90\u4ee3\u7801\u62ff\u51fa\u6765\u6d4b\u8bd5\u4e00\u4e0b<\/p>\n
tcpserver.hpp<\/p>\n<\/p>\n
#pragma once
\n#include <iostream>
\n#include <string>
\n#include <functional>
\n#include <memory>
\n#include <unordered_map><\/p>\n
#include "Socket.hpp"
\n#include "Epoller.hpp"
\n#include "nocopy.hpp"<\/p>\n
class Connection;
\nusing func_t = std::function<void(std::shared_ptr<Connection>)>;
\nclass TcpServer;<\/p>\n
class Connection
\n{
\npublic:
\n Connection(int sock, std::shared_ptr<TcpServer> tcp_server_ptr) : _sock(sock), _tcp_server_ptr(tcp_server_ptr)
\n {
\n }
\n ~Connection()
\n {
\n }
\n void setcallback(func_t recv_cb, func_t send_cb, func_t except_cb)
\n {
\n _recv_cb = recv_cb;
\n _send_cb = send_cb;
\n _except_cb = except_cb;
\n }
\n int Getsock()
\n {
\n return _sock;
\n }
\n void Append(std::string info)
\n {
\n _inbuffer += info;
\n }<\/p>\n
public:
\n int _sock;
\n std::string _inbuffer; \/\/ \u8fd9\u91cc\u6765\u5f53\u8f93\u5165\u7f13\u51b2\u533a，\u4f46\u662f\u8fd9\u91cc\u662f\u6709\u7f3a\u70b9\u7684，\u5b83\u4e0d\u80fd\u5904\u7406\u4e8c\u8fdb\u5236\u6d41
\n std::string _outbuffer;<\/p>\n
public:
\n func_t _recv_cb; \/\/ \u8bfb\u56de\u8c03\u51fd\u6570
\n func_t _send_cb; \/\/ \u5199\u56de\u8c03\u51fd\u6570
\n func_t _except_cb; \/\/
\n std::shared_ptr<TcpServer> _tcp_server_ptr; \/\/ \u6dfb\u52a0\u4e00\u4e2a\u56de\u6307\u6307\u9488
\n uint16_t _clientport;
\n std::string _clientip;
\n};
\nclass TcpServer : public nocopy
\n{
\n static const int num = 64;<\/p>\n
public:
\n TcpServer(uint16_t port) : _port(port),
\n _listensock_ptr(new Sock()),
\n _epoller_ptr(new Epoller()),
\n _quit(true)
\n {
\n }
\n ~TcpServer()
\n {
\n }
\n \/\/ \u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n int set_non_blocking(int fd)
\n {
\n int flags = fcntl(fd, F_GETFL, 0);
\n if (flags == -1)
\n {
\n perror("fcntl: get flags");
\n return -1;
\n }
\n if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1)
\n {
\n perror("fcntl: set non-blocking");
\n return -1;
\n }
\n return 0;
\n }<\/p>\n
void Init()
\n {
\n _listensock_ptr->Socket();
\n set_non_blocking(_listensock_ptr->Fd()); \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n _listensock_ptr->Bind(_port);
\n _listensock_ptr->Listen();
\n AddConnection(_listensock_ptr->Fd(), (EPOLLIN | EPOLLET),
\n std::bind(&TcpServer::Accepter, this, std::placeholders::_1), nullptr, nullptr); \/\/ \u6682\u65f6\u8bbe\u7f6e\u6210nullptr
\n }
\n \/\/ \u8fde\u63a5\u7ba1\u7406\u5668
\n void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n int sock = accept(conection->Getsock(), (sockaddr *)&peer, &len);
\n if (sock > 0)
\n {
\n \/\/ \u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport = ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET, &(peer.sin_addr), buffer, sizeof(buffer));
\n std::cout << "get a new client from:" << buffer << conection->Getsock() << std::endl;<\/p>\n
set_non_blocking(sock); \/\/ \u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection(sock, EPOLLIN,
\n std::bind(&TcpServer::Recver, this, std::placeholders::_1),
\n std::bind(&TcpServer::Sender, this, std::placeholders::_1),
\n std::bind(&TcpServer::Excepter, this, std::placeholders::_1),
\n buffer, clientport);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n break;
\n }
\n }
\n }
\n \/\/ \u4e8b\u4ef6\u7ba1\u7406\u5668
\n void Recver(std::shared_ptr<Connection> conection)
\n {
\n int sock = conection->Getsock();
\n while (1)
\n {
\n char buffer[128];
\n memset(buffer, 0, sizeof(buffer));
\n ssize_t n = recv(sock, buffer, sizeof(buffer) – 1, 0); \/\/ \u975e\u963b\u585e\u8bfb\u53d6
\n if (n > 0) \/\/ \u6210\u529f\u4e86！！
\n {
\n conection->Append(buffer); \/\/ \u628a\u8bfb\u53d6\u7684\u6570\u636e\u653e\u5230Connection\u5bf9\u8c61\u7684\u8f93\u5165\u7f13\u51b2\u533a\u91cc\u9762
\n }
\n else if (n == 0) \/\/ \u5ba2\u6237\u7aef
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "quit" << std::endl;
\n Excepter(conection);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "recv err" << std::endl;
\n Excepter(conection);
\n }
\n }
\n }
\n }
\n void Sender(std::shared_ptr<Connection> conection)
\n {
\n }
\n void Excepter(std::shared_ptr<Connection> conection)
\n {
\n std::cout<<"Execpted ! fd:"<<conection->Getsock()<<std::endl;
\n }
\n void PrintConnection()
\n {
\n std::cout << "_connections fd list: " ;
\n for (auto &connection : _connections)
\n {
\n std::cout << connection.second->Getsock() << " ";
\n std::cout<<connection.second->_inbuffer;
\n }
\n std::cout << std::endl;
\n }
\n void AddConnection(int sock, uint32_t event, func_t recv_cb, func_t send_cb, func_t except_cb,
\n std::string clientip = "0.0.0.0", uint16_t clientport = 0)
\n {<\/p>\n
\/\/ 1.\u7ed9listen\u5957\u63a5\u5b57\u521b\u5efa\u4e00\u4e2aConnection\u5bf9\u8c61
\n std::shared_ptr<Connection> new_connection = std::make_shared<Connection>(sock, std::shared_ptr<TcpServer>(this)); \/\/ \u521b\u5efaConnection\u5bf9\u8c61
\n new_connection->setcallback(recv_cb, send_cb, except_cb);
\n new_connection->_clientip = clientip;
\n new_connection->_clientport = clientport;<\/p>\n
\/\/ 2.\u6dfb\u52a0\u5230_connections\u91cc\u9762\u53bb
\n _connections.insert(std::make_pair(sock, new_connection));<\/p>\n
\/\/ \u5c06listen\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u4e2d->\u5c06listensock\u548c\u4ed6\u5173\u5fc3\u7684\u4e8b\u4ef6，\u6dfb\u52a0\u5230\u5185\u6838\u7684epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811\u91cc\u9762
\n \/\/ 3.\u5c06listensock\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_ADD, sock, event); \/\/ \u6ce8\u610f\u8fd9\u91cc\u7684EPOLLET\u8bbe\u7f6e\u4e86ET\u6a21\u5f0f<\/p>\n
std::cout << "add a new connection success,sockfd:" << sock << std::endl;
\n }
\n bool IsConnectionSafe(int fd)
\n {
\n auto iter = _connections.find(fd);
\n if (iter == _connections.end())
\n {
\n return false;
\n }
\n else
\n {
\n return true;
\n }
\n }
\n void Dispatcher() \/\/ \u4e8b\u4ef6\u6d3e\u53d1\u5668
\n {
\n int n = _epoller_ptr->EpollerWait(revs, num); \/\/ \u83b7\u53d6\u5df2\u7ecf\u5c31\u7eea\u7684\u4e8b\u4ef6
\n for (int i = 0; i < num; i++)
\n {
\n uint32_t events = revs[i].events;
\n int sock = revs[i].data.fd;
\n \/\/ \u5982\u679c\u51fa\u73b0\u5f02\u5e38，\u7edf\u4e00\u8f6c\u53d1\u4e3a\u8bfb\u5199\u95ee\u9898，\u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLERR) \/\/ \u51fa\u73b0\u9519\u8bef\u4e86
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n if (events & EPOLLHUP)
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n \/\/ \u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLIN && IsConnectionSafe(sock)) \/\/ \u8bfb\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if (_connections[sock]->_recv_cb)
\n _connections[sock]->_recv_cb(_connections[sock]);
\n }
\n if (events & EPOLLOUT && IsConnectionSafe(sock)) \/\/ \u5199\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if (_connections[sock]->_send_cb)
\n _connections[sock]->_send_cb(_connections[sock]);
\n }
\n }
\n }
\n void Loop()
\n {
\n _quit = false;<\/p>\n
while (!_quit)
\n {
\n Dispatcher();
\n PrintConnection();
\n }
\n _quit = true;
\n }<\/p>\n
private:
\n uint16_t _port;
\n std::shared_ptr<Epoller> _epoller_ptr;
\n std::unordered_map<int, std::shared_ptr<Connection>> _connections;
\n std::shared_ptr<Sock> _listensock_ptr;
\n bool _quit;
\n struct epoll_event revs[num]; \/\/ \u4e13\u95e8\u7528\u6765\u5904\u7406\u4e8b\u4ef6\u7684
\n}; <\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-680381742e234.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-680381744e2ce.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-680381747043b.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-680381749bcff.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-68038174bdd78.png\")
<\/p>\n<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419105652-68038174e868e.png\")
<\/p>\n
![\"\"](\"2025-04-19otkjmjufyje.png\")
<\/p>\n
\u597d\u50cf\u6ca1\u6709\u4ec0\u4e48\u95ee\u9898\u554a！！！\u00a0\u6211\u4eec\u786e\u5b9e\u505a\u5230\u4e86\u8bfb\u53d6\u6570\u636e！\u4f46\u662f\u6211\u4eec\u8fd8\u662f\u6ca1\u6709\u5904\u7406\u8fd9\u4e9b\u6570\u636e！！<\/p>\n
\u6240\u4ee5\u6211\u4eec\u53c8\u8981\u5f04\u4e00\u4e2a\u56de\u8c03\u51fd\u6570\u6765\u5904\u7406\u8fd9\u4e9b\u6570\u636e<\/p>\n
class TcpServer : public nocopy
\n{
\n public:
\n TcpServer(uint16_t port,func_t OnMessage) : _port(port),
\n _listensock_ptr(new Sock()),
\n _epoller_ptr(new Epoller()),
\n _quit(true),
\n _OnMessage(OnMessage)
\n {
\n }
\n…
\n \/\/ \u4e8b\u4ef6\u7ba1\u7406\u5668
\n void Recver(std::shared_ptr<Connection> conection)
\n {
\n int sock = conection->Getsock();
\n while (1)
\n {
\n char buffer[128];
\n memset(buffer, 0, sizeof(buffer));
\n ssize_t n = recv(sock, buffer, sizeof(buffer) – 1, 0); \/\/ \u975e\u963b\u585e\u8bfb\u53d6
\n if (n > 0) \/\/ \u6210\u529f\u4e86！！
\n {
\n conection->Append(buffer); \/\/ \u628a\u8bfb\u53d6\u7684\u6570\u636e\u653e\u5230Connection\u5bf9\u8c61\u7684\u8f93\u5165\u7f13\u51b2\u533a\u91cc\u9762
\n }
\n else if (n == 0) \/\/ \u5ba2\u6237\u7aef
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "quit" << std::endl;
\n Excepter(conection);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "recv err" << std::endl;
\n Excepter(conection);
\n }
\n }
\n _OnMessage(conection);\/\/\u5c06\u8bfb\u53d6\u7684\u6570\u636e\u4ea4\u7ed9\u4e0a\u5c42\u5904\u7406
\n }
\n }<\/p>\n
private:
\n ….<\/p>\n
\/\/\u4e0a\u5c42\u5904\u7406\u6570\u636e
\n func_t _OnMessage;\/\/\u5c06\u6570\u636e\u4ea4\u7ed9\u4e0a\u5c42
\n}; <\/p>\n
\u6211\u4eec\u8981\u6c42\u4e0a\u5c42\u6765\u5b8c\u6210\u68c0\u6d4b，\u6765\u5904\u7406\u7c98\u5305\u7684\u95ee\u9898！\u8fd9\u4e2a_OnMessage\u4e0d\u5c31\u662f\u56de\u8c03\u51fd\u6570\u5417！！！<\/p>\n
\u6211\u4eec\u7b80\u5355\u7684\u5199\u4e00\u4e2a<\/p>\n
mian.cc<\/p>\n
#include"tcpserver.hpp"
\n#include<memory><\/p>\n
void DefaultOmMessage(std::shared_ptr<Connection> connection_ptr)
\n{
\n std::cout<<"\u4e0a\u5c42\u5f97\u5230\u4e86\u6570\u636e："<<connection_ptr->_inbuffer<<std::endl;<\/p>\n
}<\/p>\n
int main()
\n{
\n std::unique_ptr<TcpServer> svr(new TcpServer(8877,DefaultOmMessage));
\n svr->Init();
\n svr->Loop();
\n} <\/p>\n
\u6211\u4eec\u6765\u6d4b\u8bd5\u4e00\u4e0b\u884c\u4e0d\u884c<\/p>\n
![\"\"](\"2025-04-19r0qoepp2ss2.png\")
<\/p>\n
![\"\"](\"2025-04-19bigfeyi1irp.png\")
<\/p>\n
![\"\"](\"2025-04-19keadz5u35jh.png\")
<\/p>\n
\u53ef\u4ee5\u54e6！！！ \u6211\u4eec\u5df2\u7ecf\u62ff\u5230\u6570\u636e\u4e86，\u90a3\u6211\u4eec\u5e94\u8be5\u600e\u4e48\u5904\u7406\u6570\u636e\u5462？\u6211\u4eec\u5e94\u8be5\u5728\u8fd9\u91cc\u5b8c\u6210\u5e8f\u5217\u548c\u53cd\u5e8f\u5217\u5316！！！\u7531\u4e8e\u6211\u4e4b\u524d\u5199\u8fc7\u5e8f\u5217\u548c\u53cd\u5e8f\u5217\u5316，\u4ee5\u53ca\u7f16\u7801\u89e3\u7801\u7684\u4ee3\u7801，\u6240\u4ee5\u6211\u76f4\u63a5\u62ff\u8fc7\u590d\u5236\u7c98\u8d34\u597d\u4e86\u3002<\/p>\n
Serialization.hpp<\/p>\n
#pragma
\n#define CRLF "\\\\t" \/\/ \u5206\u9694\u7b26
\n#define CRLF_LEN strlen(CRLF) \/\/ \u5206\u9694\u7b26\u957f\u5ea6
\n#define SPACE " " \/\/ \u7a7a\u683c
\n#define SPACE_LEN strlen(SPACE) \/\/ \u7a7a\u683c\u957f\u5ea6
\n#define OPS "+-*\/%" \/\/ \u8fd0\u7b97\u7b26<\/p>\n
#include <iostream>
\n#include <string>
\n#include <cstring>
\n#include<assert.h><\/p>\n
\/\/\u53c2\u6570len\u4e3ain\u7684\u957f\u5ea6，\u662f\u4e00\u4e2a\u8f93\u51fa\u578b\u53c2\u6570\u3002\u5982\u679c\u4e3a0\u4ee3\u8868err
\nstd::string decode(std::string& in,size_t*len)
\n{
\n assert(len);\/\/\u5982\u679c\u957f\u5ea6\u4e3a0\u662f\u9519\u8bef\u7684<\/p>\n
\/\/ 1.\u786e\u8ba4in\u7684\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u5b8c\u6574（\u5206\u9694\u7b26）
\n *len=0;<\/p>\n
size_t pos = in.find(CRLF);\/\/\u67e5\u627e\\\\t\u7b2c\u4e00\u6b21\u51fa\u73b0\u65f6\u7684\u4e0b\u6807
\n \/\/\u67e5\u627e\u4e0d\u5230，err
\n if(pos == std::string::npos){
\n return "";\/\/\u8fd4\u56de\u7a7a\u4e32
\n }<\/p>\n
\/\/ 2.\u6709\u5206\u9694\u7b26，\u5224\u65ad\u957f\u5ea6\u662f\u5426\u8fbe\u6807
\n \/\/ \u6b64\u65f6pos\u4e0b\u6807\u6b63\u597d\u5c31\u662f\u6807\u8bc6\u5927\u5c0f\u7684\u5b57\u7b26\u957f\u5ea6
\n std::string inLenStr = in.substr(0,pos);\/\/\u4ece\u4e0b\u68070\u5f00\u59cb\u4e00\u76f4\u622a\u53d6\u5230\u7b2c\u4e00\u4e2a\\\\t\u4e4b\u524d<\/p>\n
\/\/\u5230\u8fd9\u91cc\u6211\u4eec\u8981\u660e\u767d，\u6211\u4eec\u8fd9\u4e0a\u9762\u622a\u53d6\u7684\u662f\u6700\u5f00\u5934\u7684\u957f\u5ea6，\u4e5f\u5c31\u662f\u8bf4，\u6211\u4eec\u622a\u53d6\u5230\u7684\u4e00\u5b9a\u662f\u4e2a\u6570\u5b57，\u8fd9\u4e2a\u662f\u6211\u4eec\u5e8f\u5217\u5316\u5b57\u7b26\u7684\u957f\u5ea6<\/p>\n
size_t inLen = atoi(inLenStr.c_str());\/\/\u628a\u622a\u53d6\u7684\u8fd9\u4e2a\u5b57\u7b26\u4e32\u8f6cint，inLen\u5c31\u662f\u5e8f\u5217\u5316\u5b57\u7b26\u7684\u957f\u5ea6<\/p>\n
\/\/\u4f20\u5165\u7684\u5b57\u7b26\u4e32\u7684\u957f\u5ea6 – \u7b2c\u4e00\u4e2a\\\\t\u524d\u9762\u7684\u5b57\u7b26\u6570 – 2\u4e2a\\\\t
\n size_t left = in.size() – inLenStr.size()- 2*CRLF_LEN;\/\/\u539f\u672c\u9884\u8ba1\u7684\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u957f\u5ea6
\n if(left<inLen){\/\/\u771f\u5b9e\u7684\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u957f\u5ea6\u548c\u9884\u8ba1\u7684\u5b57\u7b26\u4e32\u957f\u5ea6\u8fdb\u884c\u6bd4\u8f83
\n return ""; \/\/\u5269\u4e0b\u7684\u957f\u5ea6（\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u7684\u957f\u5ea6）\u6ca1\u6709\u8fbe\u5230\u6807\u660e\u7684\u957f\u5ea6
\n }<\/p>\n
\/\/ 3.\u8d70\u5230\u6b64\u5904，\u5b57\u7b26\u4e32\u5b8c\u6574，\u5f00\u59cb\u63d0\u53d6\u5e8f\u5217\u5316\u5b57\u7b26\u4e32
\n std::string ret = in.substr(pos+CRLF_LEN,inLen);\/\/\u4ecepos+CRLF_LEN\u4e0b\u6807\u5f00\u59cb\u8bfb\u53d6inLen\u4e2a\u957f\u5ea6\u7684\u5b57\u7b26\u4e32\u2014\u2014\u5373\u5e8f\u5217\u5316\u5b57\u7b26\u4e32<\/p>\n
*len = inLen;<\/p>\n
\/\/ 4.\u56e0\u4e3ain\u4e2d\u53ef\u80fd\u8fd8\u6709\u5176\u4ed6\u7684\u62a5\u6587（\u4e0b\u4e00\u6761）
\n \/\/ \u6240\u4ee5\u9700\u8981\u628a\u5f53\u524d\u7684\u62a5\u6587\u4ecein\u4e2d\u5220\u9664，\u65b9\u4fbf\u4e0b\u6b21decode，\u907f\u514d\u4e8c\u6b21\u8bfb\u53d6
\n size_t rmLen = inLenStr.size() + ret.size() + 2*CRLF_LEN;\/\/\u957f\u5ea6+2\u4e2a\\\\t+\u5e8f\u5217\u5b57\u7b26\u4e32\u7684\u957f\u5ea6
\n in.erase(0,rmLen);\/\/\u79fb\u9664\u4ece\u7d22\u5f150\u5f00\u59cb\u957f\u5ea6\u4e3armLen\u7684\u5b57\u7b26\u4e32<\/p>\n
\/\/ 5.\u8fd4\u56de
\n return ret;
\n}<\/p>\n
\/\/\u7f16\u7801\u4e0d\u9700\u8981\u4fee\u6539\u6e90\u5b57\u7b26\u4e32，\u6240\u4ee5const\u3002\u53c2\u6570len\u4e3ain\u7684\u957f\u5ea6
\nstd::string encode(const std::string& in,size_t len)
\n{
\n std::string ret = std::to_string(len);\/\/\u5c06\u957f\u5ea6\u8f6c\u4e3a\u5b57\u7b26\u4e32\u6dfb\u52a0\u5728\u6700\u524d\u9762，\u4f5c\u4e3a\u6807\u8bc6
\n ret+=CRLF;
\n ret+=in;
\n ret+=CRLF;
\n return ret;
\n}<\/p>\n
class Request\/\/\u5ba2\u6237\u7aef\u4f7f\u7528\u7684
\n{
\npublic:
\n \/\/ \u5c06\u7528\u6237\u7684\u8f93\u5165\u8f6c\u6210\u5185\u90e8\u6210\u5458
\n \/\/ \u7528\u6237\u53ef\u80fd\u8f93\u5165x+y，x+ y，x +y,x + y\u7b49\u7b49\u683c\u5f0f
\n \/\/ \u63d0\u524d\u4fee\u6539\u7528\u6237\u8f93\u5165（\u4e3b\u8981\u8fd8\u662f\u53bb\u6389\u7a7a\u683c），\u63d0\u53d6\u51fa\u6210\u5458
\n Request()
\n {<\/p>\n
}<\/p>\n
\/\/ \u5220\u9664\u8f93\u5165\u4e2d\u7684\u7a7a\u683c
\n void rmSpace(std::string &in)
\n {
\n std::string tmp;
\n for (auto e : in)
\n {
\n if (e != ' ')
\n {
\n tmp += e;
\n }
\n }
\n in = tmp;
\n }<\/p>\n
\/\/ \u5e8f\u5217\u5316 （\u5165\u53c2\u5e94\u8be5\u662f\u7a7a\u7684，\u4f1a\u8fd4\u56de\u4e00\u4e2a\u5e8f\u5217\u5316\u5b57\u7b26\u4e32）
\n void serialize(std::string &out)\/\/\u8fd9\u4e2a\u662f\u5ba2\u6237\u7aef\u5728\u53d1\u9001\u6d88\u606f\u7ed9\u670d\u52a1\u7aef\u65f6\u4f7f\u7528\u7684，\u5728\u8fd9\u4e4b\u540e\u8981\u5148\u7f16\u7801，\u624d\u80fd\u53d1\u9001\u51fa\u53bb
\n {
\n \/\/ x + y
\n out.clear(); \/\/ \u5e8f\u5217\u5316\u7684\u5165\u53c2\u662f\u7a7a\u7684
\n out += std::to_string(_x);
\n out += SPACE;
\n out += _ops; \/\/ \u64cd\u4f5c\u7b26\u4e0d\u80fd\u7528tostring，\u4f1a\u88ab\u8f6c\u6210ascii
\n out += SPACE;
\n out += std::to_string(_y);
\n \/\/ \u4e0d\u7528\u6dfb\u52a0\u5206\u9694\u7b26（\u8fd9\u662fencode\u8981\u5e72\u7684\u4e8b\u60c5）
\n }
\n \/\/\u5e8f\u5217\u5316\u4e4b\u540e\u5e94\u8be5\u8981\u7f16\u7801，\u53bb\u52a0\u4e2a\u957f\u5ea6<\/p>\n
\/\/ \u53cd\u5e8f\u5217\u5316（\u89e3\u5f00
\n bool deserialize(const std::string &in)\/\/\u8fd9\u4e2a\u662f\u670d\u52a1\u7aef\u63a5\u6536\u5230\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u6d88\u606f\u540e\u4f7f\u7528\u7684，\u5728\u8fd9\u4e4b\u524d\u8981\u5148\u89e3\u7801
\n {
\n \/\/ x + y \u9700\u8981\u53d6\u51fax，y\u548c\u64cd\u4f5c\u7b26
\n size_t space1 = in.find(SPACE); \/\/ \u7b2c\u4e00\u4e2a\u7a7a\u683c
\n if (space1 == std::string::npos) \/\/ \u6ca1\u627e\u5230
\n {
\n return false;
\n }<\/p>\n
size_t space2 = in.rfind(SPACE); \/\/ \u7b2c\u4e8c\u4e2a\u7a7a\u683c
\n if (space2 == std::string::npos) \/\/ \u6ca1\u627e\u5230
\n {
\n return false;
\n }<\/p>\n
\/\/ \u4e24\u4e2a\u7a7a\u683c\u90fd\u5b58\u5728，\u5f00\u59cb\u53d6\u6570\u636e
\n std::string dataX = in.substr(0, space1);
\n std::string dataY = in.substr(space2 + SPACE_LEN); \/\/ \u9ed8\u8ba4\u53d6\u5230\u7ed3\u5c3e<\/p>\n
std::string op = in.substr(space1 + SPACE_LEN, space2 – (space1 + SPACE_LEN));
\n if (op.size() != 1)
\n {
\n return false; \/\/ \u64cd\u4f5c\u7b26\u957f\u5ea6\u6709\u95ee\u9898
\n }<\/p>\n
\/\/ \u6ca1\u95ee\u9898\u4e86，\u8f6c\u5185\u90e8\u6210\u5458
\n _x = atoi(dataX.c_str());
\n _y = atoi(dataY.c_str());
\n _ops = op[0];
\n return true;
\n }<\/p>\n
public:
\n int _x;
\n int _y;
\n char _ops;
\n};<\/p>\n
class Response \/\/ \u670d\u52a1\u7aef\u5fc5\u987b\u56de\u5e94
\n{
\n public:
\n Response(int code = 0, int result = 0)
\n : _exitCode(code), _result(result)
\n {
\n }<\/p>\n
\/\/ \u5e8f\u5217\u5316
\n void serialize(std::string &out)\/\/\u8fd9\u4e2a\u662f\u670d\u52a1\u7aef\u53d1\u9001\u6d88\u606f\u7ed9\u5ba2\u6237\u7aef\u4f7f\u7528\u7684，\u4f7f\u7528\u4e4b\u540e\u8981\u7f16\u7801
\n {
\n \/\/ code ret
\n out.clear();
\n out += std::to_string(_exitCode);
\n out += SPACE;
\n out += std::to_string(_result);
\n out += CRLF;
\n }<\/p>\n
\/\/ \u53cd\u5e8f\u5217\u5316
\n bool deserialize(const std::string &in)\/\/\u8fd9\u4e2a\u662f\u5ba2\u6237\u7aef\u63a5\u6536\u670d\u52a1\u7aef\u6d88\u606f\u540e\u4f7f\u7528\u7684，\u4f7f\u7528\u4e4b\u524d\u8981\u5148\u89e3\u7801
\n {
\n \/\/ \u53ea\u6709\u4e00\u4e2a\u7a7a\u683c
\n size_t space = in.find(SPACE); \/\/ \u5bfb\u627e\u7b2c\u4e00\u4e2a\u7a7a\u683c\u7684\u4e0b\u6807
\n if (space == std::string::npos) \/\/ \u6ca1\u627e\u5230
\n {
\n return false;
\n }<\/p>\n
std::string dataCode = in.substr(0, space);
\n std::string dataRes = in.substr(space + SPACE_LEN);<\/p>\n
_exitCode = atoi(dataCode.c_str());
\n _result = atoi(dataRes.c_str());
\n return true;
\n }<\/p>\n
public:
\n int _exitCode; \/\/ \u8ba1\u7b97\u670d\u52a1\u7684\u9000\u51fa\u7801
\n int _result; \/\/ \u7ed3\u679c
\n};
\nResponse Caculater(const Request& req)
\n{
\n Response resp;\/\/\u6784\u9020\u51fd\u6570\u4e2d\u5df2\u7ecf\u6307\u5b9a\u4e86exitcode\u4e3a0
\n switch (req._ops)
\n {
\n case '+':
\n resp._result = req._x + req._y;
\n break;
\n case '-':
\n resp._result = req._x – req._y;
\n break;
\n case '*':
\n resp._result = req._x * req._y;
\n break;
\n case '%':
\n {
\n if(req._y == 0)
\n {
\n resp._exitCode = -1;\/\/\u53d6\u6a21\u9519\u8bef
\n break;
\n }
\n resp._result = req._x % req._y;\/\/\u53d6\u6a21\u662f\u53ef\u4ee5\u64cd\u4f5c\u8d1f\u6570\u7684
\n break;
\n }
\n case '\/':
\n {
\n if(req._y == 0)
\n {
\n resp._exitCode = -2;\/\/\u96640\u9519\u8bef
\n break;
\n }
\n resp._result = req._x \/ req._y;\/\/\u53d6\u6a21\u662f\u53ef\u4ee5\u64cd\u4f5c\u8d1f\u6570\u7684
\n break;
\n }
\n default:
\n resp._exitCode = -3;\/\/\u64cd\u4f5c\u7b26\u975e\u6cd5
\n break;
\n }<\/p>\n
return resp;
\n} <\/p>\n
\u00a0\u63a5\u4e0b\u6765\u6211\u4eec\u5c31\u53ef\u4ee5\u5bf9\u8bfb\u53d6\u7684\u6570\u636e\u8fdb\u884c\u5904\u7406\u4e86！！！\u600e\u4e48\u5904\u7406\u5462？\u6211\u4eec\u8fd8\u662f\u8ddf\u81ea\u5b9a\u4e49\u534f\u8bae\u90a3\u7bc7\u4e00\u6837，\u641e\u4e00\u4e2a\u8ba1\u7b97\u5668\u597d\u4e86！<\/p>\n
Caculater\u51fd\u6570<\/p>\n
Response Caculater(const Request& req)
\n{
\n Response resp;\/\/\u6784\u9020\u51fd\u6570\u4e2d\u5df2\u7ecf\u6307\u5b9a\u4e86exitcode\u4e3a0
\n switch (req._ops)
\n {
\n case '+':
\n resp._result = req._x + req._y;
\n break;
\n case '-':
\n resp._result = req._x – req._y;
\n break;
\n case '*':
\n resp._result = req._x * req._y;
\n break;
\n case '%':
\n {
\n if(req._y == 0)
\n {
\n resp._exitCode = -1;\/\/\u53d6\u6a21\u9519\u8bef
\n break;
\n }
\n resp._result = req._x % req._y;\/\/\u53d6\u6a21\u662f\u53ef\u4ee5\u64cd\u4f5c\u8d1f\u6570\u7684
\n break;
\n }
\n case '\/':
\n {
\n if(req._y == 0)
\n {
\n resp._exitCode = -2;\/\/\u96640\u9519\u8bef
\n break;
\n }
\n resp._result = req._x \/ req._y;\/\/\u53d6\u6a21\u662f\u53ef\u4ee5\u64cd\u4f5c\u8d1f\u6570\u7684
\n break;
\n }
\n default:
\n resp._exitCode = -3;\/\/\u64cd\u4f5c\u7b26\u975e\u6cd5
\n break;
\n }<\/p>\n
return resp;
\n} <\/p>\n
\u6211\u4eec\u628a\u8fd9\u4e2a\u653e\u5230\u4e86\u6211\u4eec\u7684\u00a0Serialization.hpp<\/p>\n
\u63a5\u4e0b\u6765\u5c31\u63a5\u7740\u4fee\u6539\u6211\u4eec\u7684main.cc\u597d\u4e86！<\/p>\n
main.cc<\/p>\n
#include "tcpserver.hpp"
\n#include <memory>
\n#include "Serialization.hpp"<\/p>\n
void DefaultOmMessage(std::shared_ptr<Connection> connection_ptr)
\n{
\n std::cout << "\u4e0a\u5c42\u5f97\u5230\u4e86\u6570\u636e：" << connection_ptr->_inbuffer << std::endl;
\n std::string inbuf = connection_ptr->_inbuffer;
\n size_t packageLen = inbuf.size();
\n \/\/\u7531\u4e8e\u6211\u4eec\u662f\u4f7f\u7528telnet\u6765\u6d4b\u8bd5\u7684\u6240\u4ee5，\u6211\u4eec\u5c31\u4e0d\u89e3\u7801\u4e86
\n \/*
\n \/\/ 3.1.\u89e3\u7801\u548c\u53cd\u5e8f\u5217\u5316\u5ba2\u6237\u7aef\u4f20\u6765\u7684\u6d88\u606f
\n std::string package = decode(inbuf, &packageLen); \/\/ \u89e3\u7801
\n if (packageLen == 0)
\n {
\n printf("decode err: %s[%d] status: %d", connection_ptr->_clientip, connection_ptr->_clientport, packageLen);
\n \/\/ \u62a5\u6587\u4e0d\u5b8c\u6574\u6216\u6709\u8bef
\n }
\n *\/<\/p>\n
Request req;
\n bool deStatus = req.deserialize(inbuf); \/\/ \u4f7f\u7528Request\u7684\u53cd\u5e8f\u5217\u5316，packsge\u5185\u90e8\u5404\u4e2a\u6210\u5458\u5df2\u7ecf\u6709\u4e86\u6570\u503c
\n if (deStatus) \/\/ \u83b7\u53d6\u6d88\u606f\u53cd\u5e8f\u5217\u5316\u6210\u529f
\n {
\n \/\/ 3.2.\u83b7\u53d6\u7ed3\u6784\u5316\u7684\u76f8\u5e94
\n Response resp = Caculater(req); \/\/ \u5c06\u8ba1\u7b97\u4efb\u52a1\u7684\u7ed3\u679c\u5b58\u653e\u5230Response\u91cc\u9762\u53bb<\/p>\n
\/\/ 3.3.\u5e8f\u5217\u5316\u548c\u7f16\u7801\u54cd\u5e94
\n std::string echoStr;
\n resp.serialize(echoStr); \/\/ \u5e8f\u5217\u5316<\/p>\n
\/\/\u7531\u4e8e\u6211\u4eec\u4f7f\u7528\u7684\u662ftelnet\u6765\u6d4b\u8bd5\u7684，\u6240\u4ee5\u6211\u4eec\u4e0d\u7f16\u7801\u4e86
\n \/\/ echoStr = encode(echoStr, echoStr.size()); \/\/ \u7f16\u7801<\/p>\n
\/\/ 3.4.\u5199\u5165，\u53d1\u9001\u8fd4\u56de\u503c\u7ed9\u8f93\u51fa\u7f13\u51b2\u533a
\n connection_ptr->_outbuffer=echoStr;
\n std::cout<<connection_ptr->_outbuffer<<std::endl;
\n }
\n else \/\/ \u5ba2\u6237\u7aef\u6d88\u606f\u53cd\u5e8f\u5217\u5316\u5931\u8d25
\n {
\n printf("deserialize err: %s[%d] status: %d", connection_ptr->_clientip, connection_ptr->_clientport, deStatus);
\n return;
\n }<\/p>\n
}<\/p>\n
int main()
\n{
\n std::unique_ptr<TcpServer> svr(new TcpServer(8877, DefaultOmMessage));
\n svr->Init();
\n svr->Loop();
\n} <\/p>\n
\u6211\u4eec\u6d4b\u8bd5\u4e00\u4e0b\u00a0<\/p>\n
![\"\"](\"2025-04-19xaujrfp1a1i.png\")
<\/p>\n
![\"\"](\"2025-04-19fqf2agu2dgk.png\")
<\/p>\n
![\"\"](\"2025-04-19ytqs0vdwhgl.png\")
<\/p>\n
\u53ef\u4ee5\u554a！！！\u00a0\u63a5\u4e0b\u6765\u5c31\u662f\u4e13\u95e8\u5904\u7406\u5199\u4e8b\u4ef6<\/p>\n
\u00a0 \u4e4b\u524d\u5199\u670d\u52a1\u5668\u65f6，\u6211\u4eec\u4ece\u6765\u6ca1\u5904\u7406\u8fc7\u5199\u4e8b\u4ef6，\u5199\u4e8b\u4ef6\u548c\u8bfb\u4e8b\u4ef6\u4e0d\u592a\u4e00\u6837，\u5173\u5fc3\u8bfb\u4e8b\u4ef6\u662f\u8981\u5e38\u8bbe\u7f6e\u7684，\u4f46\u5199\u4e8b\u4ef6\u4e00\u822c\u90fd\u662f\u5c31\u7eea\u7684，\u56e0\u4e3a\u5185\u6838\u53d1\u9001\u7f13\u51b2\u533a\u5927\u6982\u7387\u90fd\u662f\u6709\u7a7a\u95f4\u7684，\u5982\u679c\u6bcf\u6b21\u90fd\u8981\u8ba9epoll\u5e2e\u6211\u4eec\u5173\u5fc3\u8bfb\u4e8b\u4ef6，\u8fd9\u5176\u5b9e\u662f\u4e00\u79cd\u8d44\u6e90\u7684\u6d6a\u8d39，\u56e0\u4e3a\u5927\u90e8\u5206\u60c5\u51b5\u4e0b，\u4f60send\u6570\u636e，\u90fd\u662f\u4f1a\u76f4\u63a5\u5c06\u5e94\u7528\u5c42\u6570\u636e\u62f7\u8d1d\u5230\u5185\u6838\u7f13\u51b2\u533a\u7684，\u4e0d\u4f1a\u51fa\u73b0\u7b49\u5f85\u7684\u60c5\u51b5，\u800crecv\u5c31\u4e0d\u592a\u4e00\u6837，recv\u5728\u8bfb\u53d6\u7684\u65f6\u5019，\u6709\u53ef\u80fd\u6570\u636e\u8fd8\u5728\u7f51\u7edc\u91cc\u9762，\u6240\u4ee5recv\u8981\u7b49\u5f85\u7684\u6982\u7387\u662f\u6bd4\u8f83\u9ad8\u7684，\u6240\u4ee5\u5bf9\u4e8e\u8bfb\u4e8b\u4ef6\u6765\u8bf4，\u5e38\u5e38\u90fd\u8981\u5c06\u5176\u8bbe\u7f6e\u5230sock\u6240\u5173\u5fc3\u7684\u4e8b\u4ef6\u96c6\u5408\u4e2d\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u4f46\u5199\u4e8b\u4ef6\u5e76\u4e0d\u662f\u8fd9\u6837\u7684，\u5199\u4e8b\u4ef6\u5e94\u8be5\u662f\u5076\u5c14\u8bbe\u7f6e\u5230\u5173\u5fc3\u96c6\u5408\u4e2d，\u6bd4\u5982\u4f60\u8fd9\u6b21\u6ca1\u628a\u6570\u636e\u4e00\u6b21\u6027\u53d1\u5b8c，\u4f46\u4f60\u53c8\u6ca1\u8bbe\u7f6e\u8be5sock\u5173\u5fc3\u5199\u4e8b\u4ef6，\u5f53\u4e0b\u6b21\u5199\u4e8b\u4ef6\u5c31\u7eea\u4e86，\u4e5f\u5c31\u662f\u5185\u6838\u53d1\u9001\u7f13\u51b2\u533a\u6709\u7a7a\u95f4\u4e86，epoll_wait\u4e5f\u4e0d\u4f1a\u901a\u77e5\u4f60，\u90a3\u4f60\u8fd8\u600e\u4e48\u53d1\u9001\u5269\u4f59\u6570\u636e\u554a，\u6240\u4ee5\u8fd9\u4e2a\u65f6\u5019\u4f60\u5c31\u5e94\u8be5\u8bbe\u7f6e\u5199\u4e8b\u4ef6\u5173\u5fc3\u4e86，\u8ba9epoll_wait\u5e2e\u4f60\u76d1\u89c6sock\u4e0a\u7684\u5199\u4e8b\u4ef6，\u4ee5\u4fbf\u4e8e\u4e0b\u6b21epoll_wait\u901a\u77e5\u4f60\u65f6，\u4f60\u8fd8\u80fd\u591f\u7ee7\u7eed\u53d1\u9001\u4e0a\u6b21\u6ca1\u53d1\u5b8c\u7684\u6570\u636e\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u8fd9\u4e2a\u65f6\u5019\u53ef\u80fd\u6709\u4eba\u4f1a\u95ee，ET\u6a21\u5f0f\u4e0d\u662f\u53ea\u4f1a\u901a\u77e5\u4e00\u6b21\u5417？\u5982\u679c\u6211\u8fd9\u6b21\u8bbe\u7f6e\u4e86\u5199\u5173\u5fc3，\u4f46\u4e0b\u6b21\u53d1\u9001\u6570\u636e\u7684\u65f6\u5019，\u8fd8\u662f\u6ca1\u53d1\u9001\u5b8c\u6bd5（\u56e0\u4e3a\u5185\u6838\u53d1\u9001\u7f13\u51b2\u533a\u53ef\u80fd\u6ca1\u6709\u5269\u4f59\u7a7a\u95f4\u4e86），\u90a3\u540e\u9762ET\u6a21\u5f0f\u662f\u4e0d\u662f\u5c31\u4e0d\u4f1a\u901a\u77e5\u6211\u4e86\u5440，\u90a3\u6211\u8fd8\u600e\u4e48\u7ee7\u7eed\u53d1\u9001\u5269\u4f59\u7684\u6570\u636e\u5462？ET\u6a21\u5f0f\u5728\u5e95\u5c42\u5c31\u7eea\u7684\u4e8b\u4ef6\u72b6\u6001\u53d1\u751f\u53d8\u5316\u65f6，\u8fd8\u4f1a\u518d\u901a\u77e5\u4e0a\u5c42\u4e00\u6b21\u7684，\u5bf9\u4e8e\u8bfb\u4e8b\u4ef6\u6765\u8bf4，\u5f53\u6570\u636e\u4ece\u65e0\u5230\u6709，\u4ece\u6709\u5230\u591a\u72b6\u6001\u53d1\u751f\u53d8\u5316\u65f6，ET\u5c31\u8fd8\u4f1a\u901a\u77e5\u4e0a\u5c42\u4e00\u6b21，\u5bf9\u4e8e\u5199\u4e8b\u4ef6\u6765\u8bf4，\u5f53\u5185\u6838\u53d1\u9001\u7f13\u51b2\u533a\u5269\u4f59\u7a7a\u95f4\u4ece\u65e0\u5230\u6709，\u4ece\u6709\u5230\u591a\u72b6\u6001\u53d1\u751f\u53d8\u5316\u65f6，ET\u4e5f\u8fd8\u4f1a\u901a\u77e5\u4e0a\u5c42\u4e00\u6b21，\u6240\u4ee5\u4e0d\u7528\u62c5\u5fc3\u6570\u636e\u53d1\u9001\u4e0d\u5b8c\u7684\u95ee\u9898\u4ea7\u751f，\u56e0\u4e3aET\u662f\u4f1a\u901a\u77e5\u6211\u4eec\u7684\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728\u5faa\u73af\u5916，\u6211\u4eec\u53ea\u9700\u8981\u901a\u8fc7\u5224\u65adoutbuffer\u662f\u5426\u4e3a\u7a7a\u7684\u60c5\u51b5，\u6765\u51b3\u5b9a\u662f\u5426\u8981\u8bbe\u7f6e\u5199\u4e8b\u4ef6\u5173\u5fc3，\u5f53\u6570\u636e\u53d1\u9001\u5b8c\u4e86\u90a3\u6211\u4eec\u5c31\u53d6\u6d88\u5bf9\u4e8e\u5199\u4e8b\u4ef6\u7684\u5173\u5fc3，\u4e0d\u5360\u7528epoll\u7684\u8d44\u6e90，\u5982\u679c\u6570\u636e\u6ca1\u53d1\u9001\u5b8c，\u90a3\u5c31\u8bbe\u7f6e\u5bf9\u4e8e\u5199\u4e8b\u4ef6\u7684\u5173\u5fc3，\u56e0\u4e3a\u6211\u4eec\u8981\u4fdd\u8bc1\u4e0b\u6b21\u5199\u4e8b\u4ef6\u5c31\u7eea\u65f6，epoll_wait\u80fd\u591f\u901a\u77e5\u6211\u4eec\u5bf9\u5199\u4e8b\u4ef6\u8fdb\u884c\u5904\u7406\u3002<\/p>\n
main.cc<\/p>\n
#include "tcpserver.hpp"
\n#include <memory>
\n#include "Serialization.hpp"<\/p>\n
void DefaultOmMessage(std::shared_ptr<Connection> connection_ptr)
\n{
\n std::cout << "\u4e0a\u5c42\u5f97\u5230\u4e86\u6570\u636e：" << connection_ptr->_inbuffer << std::endl;
\n std::string inbuf = connection_ptr->_inbuffer;
\n size_t packageLen = inbuf.size();
\n \/\/\u7531\u4e8e\u6211\u4eec\u662f\u4f7f\u7528telnet\u6765\u6d4b\u8bd5\u7684\u6240\u4ee5，\u6211\u4eec\u5c31\u4e0d\u89e3\u7801\u4e86
\n \/*
\n \/\/ 3.1.\u89e3\u7801\u548c\u53cd\u5e8f\u5217\u5316\u5ba2\u6237\u7aef\u4f20\u6765\u7684\u6d88\u606f
\n std::string package = decode(inbuf, &packageLen); \/\/ \u89e3\u7801
\n if (packageLen == 0)
\n {
\n printf("decode err: %s[%d] status: %d", connection_ptr->_clientip, connection_ptr->_clientport, packageLen);
\n \/\/ \u62a5\u6587\u4e0d\u5b8c\u6574\u6216\u6709\u8bef
\n }
\n *\/<\/p>\n
Request req;
\n bool deStatus = req.deserialize(inbuf); \/\/ \u4f7f\u7528Request\u7684\u53cd\u5e8f\u5217\u5316，packsge\u5185\u90e8\u5404\u4e2a\u6210\u5458\u5df2\u7ecf\u6709\u4e86\u6570\u503c
\n if (deStatus) \/\/ \u83b7\u53d6\u6d88\u606f\u53cd\u5e8f\u5217\u5316\u6210\u529f
\n {
\n \/\/ 3.2.\u83b7\u53d6\u7ed3\u6784\u5316\u7684\u76f8\u5e94
\n Response resp = Caculater(req); \/\/ \u5c06\u8ba1\u7b97\u4efb\u52a1\u7684\u7ed3\u679c\u5b58\u653e\u5230Response\u91cc\u9762\u53bb<\/p>\n
\/\/ 3.3.\u5e8f\u5217\u5316\u548c\u7f16\u7801\u54cd\u5e94
\n std::string echoStr;
\n resp.serialize(echoStr); \/\/ \u5e8f\u5217\u5316<\/p>\n
\/\/\u7531\u4e8e\u6211\u4eec\u4f7f\u7528\u7684\u662ftelnet\u6765\u6d4b\u8bd5\u7684，\u6240\u4ee5\u6211\u4eec\u4e0d\u7f16\u7801\u4e86
\n \/\/ echoStr = encode(echoStr, echoStr.size()); \/\/ \u7f16\u7801<\/p>\n
\/\/ 3.4.\u5199\u5165，\u53d1\u9001\u8fd4\u56de\u503c\u7ed9\u8f93\u51fa\u7f13\u51b2\u533a
\n connection_ptr->_outbuffer=echoStr;
\n std::cout<<connection_ptr->_outbuffer<<std::endl;<\/p>\n
\/\/\u53d1\u9001
\n connection_ptr->_tcp_server_ptr->Sender(connection_ptr);\/\/\u8c03\u7528\u91cc\u9762\u7684\u65b9\u6cd5\u6765\u53d1\u9001
\n }
\n else \/\/ \u5ba2\u6237\u7aef\u6d88\u606f\u53cd\u5e8f\u5217\u5316\u5931\u8d25
\n {
\n printf("deserialize err: %s[%d] status: %d", connection_ptr->_clientip, connection_ptr->_clientport, deStatus);
\n return;
\n }<\/p>\n
} <\/p>\n
\u6211\u4eec\u6ce8\u610f\u6700\u540e\u4e00\u53e5，\u6211\u4eec\u76f4\u63a5\u628a\u53d1\u751f\u8ba4\u4e3a\u4ea4\u7ed9\u4e86Tcpserver\u7c7b\u91cc\u7684Sender\u51fd\u6570，\u4e0d\u8fc7\u8fd9\u4e2a\u51fd\u6570\u8fd8\u6ca1\u6709\u5199，\u6211\u4eec\u6765\u5199\u4e00\u4e0b！<\/p>\n
Tcpserver\u7c7b\u91cc\u7684Sender\u51fd\u6570<\/p>\n
void Sender(std::shared_ptr<Connection> connection) \/\/ \u4f7f\u7528shared_ptr\u7ba1\u7406Connection\u5bf9\u8c61\u7684\u751f\u547d\u5468\u671f
\n{
\n \/\/ \u65e0\u9650\u5faa\u73af，\u76f4\u5230\u8f93\u51fa\u7f13\u51b2\u533a\u4e3a\u7a7a\u6216\u53d1\u751f\u9700\u8981\u9000\u51fa\u7684\u9519\u8bef
\n while (true)
\n {
\n \/\/ \u5f15\u7528\u5f53\u524d\u8fde\u63a5\u7684\u8f93\u51fa\u7f13\u51b2\u533a
\n auto &outbuffer = connection->_outbuffer; <\/p>\n
\/\/ \u5c1d\u8bd5\u53d1\u9001\u6570\u636e，send\u51fd\u6570\u8fd4\u56de\u53d1\u9001\u7684\u5b57\u8282\u6570，\u6216\u8005-1\u8868\u793a\u9519\u8bef
\n ssize_t n = send(connection->Getsock(), outbuffer.data(), outbuffer.size(), 0); <\/p>\n
\/\/ \u5982\u679cn\u5927\u4e8e0，\u8868\u793a\u90e8\u5206\u6216\u5168\u90e8\u6570\u636e\u53d1\u9001\u6210\u529f
\n if (n > 0)
\n {
\n \/\/ \u4ece\u8f93\u51fa\u7f13\u51b2\u533a\u4e2d\u79fb\u9664\u5df2\u53d1\u9001\u7684\u6570\u636e
\n outbuffer.erase(0, n); <\/p>\n
\/\/ \u5982\u679c\u8f93\u51fa\u7f13\u51b2\u533a\u4e3a\u7a7a，\u5219\u9000\u51fa\u5faa\u73af
\n if (outbuffer.empty())
\n break;
\n }
\n \/\/ \u5982\u679cn\u7b49\u4e8e0，\u8868\u793a\u8fde\u63a5\u5df2\u5173\u95ed（\u5bf9\u7aef\u6267\u884c\u4e86\u5173\u95ed\u64cd\u4f5c），\u9000\u51fa\u51fd\u6570
\n else if (n == 0)
\n {
\n return;
\n }
\n \/\/ \u5904\u7406\u53d1\u9001\u5931\u8d25\u7684\u60c5\u51b5
\n else
\n {
\n \/\/ \u6839\u636eerrno\u7684\u503c\u5224\u65ad\u9519\u8bef\u7c7b\u578b
\n if (errno == EWOULDBLOCK)
\n {
\n \/\/ EWOULDBLOCK\u8868\u793a\u975e\u963b\u585e\u6a21\u5f0f\u4e0b\u8d44\u6e90\u6682\u65f6\u4e0d\u53ef\u7528，\u53ef\u7a0d\u540e\u91cd\u8bd5，\u4f46\u8fd9\u91cc\u9009\u62e9\u76f4\u63a5\u9000\u51fa\u5faa\u73af
\n break;
\n }
\n else if (errno == EINTR)
\n {
\n \/\/ EINTR\u8868\u793a\u64cd\u4f5c\u88ab\u4fe1\u53f7\u4e2d\u65ad，\u53ef\u4ee5\u5b89\u5168\u5730\u91cd\u65b0\u5c1d\u8bd5
\n continue;
\n }
\n else
\n {
\n \/\/ \u6253\u5370\u9519\u8bef\u4fe1\u606f，\u5305\u542b\u5957\u63a5\u5b57\u63cf\u8ff0\u7b26\u548c\u5ba2\u6237\u7aefIP\u5730\u5740\u53ca\u7aef\u53e3
\n std::cout << "sockfd:" << connection->Getsock() << ",client:" << connection->_clientip << ":" << connection->_clientport << "send error" << std::endl; <\/p>\n
\/\/ \u8c03\u7528\u5f02\u5e38\u5904\u7406\u56de\u8c03\u51fd\u6570
\n Excepter(conection); <\/p>\n
\/\/ \u9000\u51fa\u5faa\u73af
\n break;
\n }
\n }
\n }
\n} <\/p>\n
\u4f46\u662f\u8fd9\u8fd8\u4e0d\u591f\u554a，\u4e07\u4e00\u6211\u6ca1\u5199\u5b8c\u6570\u636e\u5462？\u6211\u4eec\u8fd8\u9700\u8981\u8fdb\u884c\u5199\u5904\u7406，\u8fd9\u91cc\u6211\u4eec\u5c31\u501f\u52a9epoll\u673a\u5236\u6765\u5e2e\u6211\u4eec\u3002<\/p>\n
\/\/ Sender\u51fd\u6570\u8d1f\u8d23\u901a\u8fc7\u7ed9\u5b9a\u7684Connection\u5bf9\u8c61\u53d1\u9001\u6570\u636e\u3002
\n\/\/ \u5b83\u4f7f\u7528epoll\u673a\u5236\u6765\u7ba1\u7406\u5957\u63a5\u5b57\u7684\u8bfb\u5199\u4e8b\u4ef6，\u6839\u636e\u53d1\u9001\u60c5\u51b5\u8c03\u6574\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u6ce8\u3002
\nvoid Sender(std::shared_ptr<Connection> connection)
\n{
\n \/\/ \u5f15\u7528Connection\u5bf9\u8c61\u7684\u8f93\u51fa\u7f13\u51b2\u533a
\n auto &outbuffer = connection->_outbuffer; <\/p>\n
\/\/ \u5faa\u73af\u53d1\u9001\u6570\u636e，\u76f4\u5230\u8f93\u51fa\u7f13\u51b2\u533a\u4e3a\u7a7a\u6216\u53d1\u751f\u9519\u8bef
\n while (true)
\n {
\n \/\/ \u5c1d\u8bd5\u53d1\u9001\u6570\u636e
\n ssize_t n = send(connection->Getsock(), outbuffer.data(), outbuffer.size(), 0); \/\/ \u6ce8\u610f：\u4f7f\u7528.data()\u83b7\u53d6\u7f13\u51b2\u533a\u9996\u5730\u5740 <\/p>\n
\/\/ \u5982\u679c\u53d1\u9001\u6210\u529f（n > 0）
\n if (n > 0)
\n {
\n \/\/ \u4ece\u8f93\u51fa\u7f13\u51b2\u533a\u4e2d\u79fb\u9664\u5df2\u53d1\u9001\u7684\u6570\u636e
\n outbuffer.erase(0, n); <\/p>\n
\/\/ \u5982\u679c\u8f93\u51fa\u7f13\u51b2\u533a\u4e3a\u7a7a，\u5219\u9000\u51fa\u5faa\u73af
\n if (outbuffer.empty())
\n break;
\n }
\n \/\/ \u5982\u679cn == 0，\u8868\u793a\u8fde\u63a5\u5df2\u6b63\u5e38\u5173\u95ed（\u5bf9\u7aef\u8c03\u7528\u4e86close），\u9000\u51fa\u51fd\u6570
\n else if (n == 0)
\n {
\n return;
\n }
\n \/\/ \u5904\u7406\u53d1\u9001\u5931\u8d25\u7684\u60c5\u51b5
\n else
\n {
\n \/\/ \u68c0\u67e5errno\u4ee5\u786e\u5b9a\u9519\u8bef\u7c7b\u578b
\n if (errno == EWOULDBLOCK)
\n {
\n \/\/ EWOULDBLOCK\u8868\u793a\u8d44\u6e90\u6682\u65f6\u4e0d\u53ef\u7528，\u901a\u5e38\u53d1\u751f\u5728\u975e\u963b\u585e\u6a21\u5f0f\u4e0b，\u9000\u51fa\u5faa\u73af
\n break;
\n }
\n else if (errno == EINTR)
\n {
\n \/\/ EINTR\u8868\u793a\u64cd\u4f5c\u88ab\u4fe1\u53f7\u4e2d\u65ad，\u7ee7\u7eed\u5faa\u73af\u5c1d\u8bd5\u53d1\u9001
\n continue;
\n }
\n else
\n {
\n \/\/ \u6253\u5370\u9519\u8bef\u4fe1\u606f，\u5e76\u8c03\u7528Connection\u5bf9\u8c61\u7684\u5f02\u5e38\u5904\u7406\u56de\u8c03\u51fd\u6570
\n std::cout << "sockfd:" << connection->Getsock() << ",client:" << connection->_clientip << ":" << connection->_clientport << "send error" << std::endl;
\n Excepter(conection);
\n break;
\n }
\n }
\n } <\/p>\n
\/\/ \u6839\u636e\u8f93\u51fa\u7f13\u51b2\u533a\u662f\u5426\u4e3a\u7a7a，\u8c03\u6574\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u6ce8
\n if (!outbuffer.empty())
\n {
\n \/\/ \u5982\u679c\u8f93\u51fa\u7f13\u51b2\u533a\u4e0d\u4e3a\u7a7a，\u5f00\u542f\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u6ce8
\n EnableEvent(connection->Getsock(), true, true); \/\/ \u540c\u65f6\u5173\u5fc3\u8bfb\u548c\u5199\u4e8b\u4ef6
\n }
\n else
\n {
\n \/\/ \u5982\u679c\u8f93\u51fa\u7f13\u51b2\u533a\u4e3a\u7a7a，\u5173\u95ed\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u6ce8，\u4f46\u4fdd\u6301\u5bf9\u8bfb\u4e8b\u4ef6\u7684\u5173\u6ce8
\n EnableEvent(connection->Getsock(), true, false); \/\/ \u53ea\u5173\u5fc3\u8bfb\u4e8b\u4ef6
\n }
\n} <\/p>\n
\/\/ EnableEvent\u51fd\u6570\u7528\u4e8e\u6839\u636e\u7ed9\u5b9a\u7684\u53c2\u6570，\u66f4\u65b0epoll\u4e8b\u4ef6\u76d1\u542c\u5668\u5bf9\u5957\u63a5\u5b57\u7684\u4e8b\u4ef6\u5173\u6ce8\u3002
\nvoid EnableEvent(int sock, bool readable, bool sendable)
\n{
\n \/\/ \u521d\u59cb\u5316events\u53d8\u91cf，\u7528\u4e8e\u5b58\u50a8\u8981\u8bbe\u7f6e\u7684\u4e8b\u4ef6\u6807\u5fd7
\n uint32_t events = 0; <\/p>\n
\/\/ \u5982\u679c\u9700\u8981\u5173\u6ce8\u8bfb\u4e8b\u4ef6，\u5219\u8bbe\u7f6eEPOLLIN\u6807\u5fd7
\n events |= (readable ? EPOLLIN : 0); <\/p>\n
\/\/ \u5982\u679c\u9700\u8981\u5173\u6ce8\u5199\u4e8b\u4ef6，\u5219\u8bbe\u7f6eEPOLLOUT\u6807\u5fd7
\n events |= (sendable ? EPOLLOUT : 0); <\/p>\n
\/\/ \u603b\u662f\u8bbe\u7f6eEPOLLET\u6807\u5fd7，\u8868\u793a\u4f7f\u7528\u8fb9\u7f18\u89e6\u53d1\u6a21\u5f0f（Edge Triggered）
\n events |= EPOLLET; <\/p>\n
\/\/ \u8c03\u7528epoll\u66f4\u65b0\u51fd\u6570，\u4fee\u6539\u5bf9\u6307\u5b9a\u5957\u63a5\u5b57\u7684\u4e8b\u4ef6\u5173\u6ce8
\n \/\/ \u6ce8\u610f：_epoller_ptr\u5e94\u8be5\u662f\u4e00\u4e2a\u6307\u5411epoll\u4e8b\u4ef6\u76d1\u542c\u5668\u5bf9\u8c61\u7684\u6307\u9488，EPOLL_CTL_MOD\u8868\u793a\u4fee\u6539\u73b0\u6709\u4e8b\u4ef6
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_MOD, sock, events);
\n} <\/p>\n
\u6211\u4eec\u6d4b\u8bd5\u4e00\u4e0b，\u8fd9\u80fd\u4e0d\u80fd\u5b8c\u6210\u5199\u7684\u4efb\u52a1\u554a！![\"\"](\"2025-04-190nj0xbqc30t.png\")
<\/p>\n
\u00a0 <\/p>\n<\/p>\n<\/p>\n
![\"\"](\"2025-04-19z3cfn0rmnww.png\")
<\/p>\n<\/p>\n
\u5f88\u597d，\u663e\u7136\u662f\u6210\u529f\u4e86！！！<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u4e0b\u9762\u662f\u5f02\u5e38\u4e8b\u4ef6\u7684\u5904\u7406\u65b9\u6cd5，\u6211\u4eec\u7edf\u4e00\u5bf9\u6240\u6709\u5f02\u5e38\u4e8b\u4ef6，\u90fd\u5148\u5c06\u5176\u4eceepoll\u6a21\u578b\u4e2d\u79fb\u9664，\u7136\u540e\u5173\u95ed\u6587\u4ef6\u63cf\u8ff0\u7b26，\u6700\u540e\u5c06conn\u4ece\u54c8\u5e0c\u8868_connecions\u4e2d\u79fb\u9664\u3002<\/p>\n
void Excepter(std::shared_ptr<Connection> conection)
\n {
\n std::cout << "Execpted ! fd:" << conection->Getsock() << std::endl;
\n \/\/1.\u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26\u4eceepoll\u6a21\u578b\u91cc\u9762\u79fb\u9664\u6765
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_DEL,conection->Getsock(),0);
\n \/\/2.\u5173\u95ed\u5f02\u5e38\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n close(conection->Getsock());
\n \/\/3.\u4eceunordered_map\u4e2d\u5220\u9664
\n _connections.erase(conection->Getsock());<\/p>\n
} <\/p>\n
\u6211\u4eec\u6765\u6d4b\u8bd5\u4e00\u4e0b：<\/p>\n
\u6211\u4eec\u8fde\u63a5\u6211\u4eec\u7684\u670d\u52a1\u5668，\u7136\u540e\u9000\u51fa，\u670d\u52a1\u5668\u5c31\u4f1a\u6253\u5370\u4e0b\u9762\u8fd9\u4e9b\u5185\u5bb9<\/p>\n<\/p>\n
![\"\"](\"2025-04-1931o1vnsmb52.png\")
<\/p>\n<\/p>\n
\u5f88\u663e\u7136\u5931\u8d25\u4e86！<\/p>\n
\u00a0\u4e3a\u4ec0\u4e48\u5462？\u5c31\u662fconnection\u6307\u9488\u7684\u751f\u547d\u5468\u671f\u6709\u95ee\u9898<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0\u503c\u5f97\u6ce8\u610f\u7684\u662f，connnection\u6307\u9488\u6307\u5411\u7684\u8fde\u63a5\u7ed3\u6784\u4f53\u7a7a\u95f4，\u5fc5\u987b\u7531\u6211\u4eec\u81ea\u5df1\u91ca\u653e，\u6709\u4eba\u8bf4，\u4e3a\u4ec0\u4e48\u554a？\u4f60\u54c8\u5e0c\u8868\u4e0d\u662f\u90fd\u5df2\u7ecferase\u4e86\u4e48？\u4e3a\u4ec0\u4e48\u8fd8\u8981\u7a0b\u5e8f\u5458\u81ea\u5df1\u518ddelete\u8fde\u63a5\u7ed3\u6784\u4f53\u7a7a\u95f4\u5462？ <\/p>\n<\/p>\n
\u8fd9\u91cc\u8981\u7ed9\u5927\u5bb6\u8bf4\u660e\u4e00\u70b9\u7684\u662f，\u6240\u6709\u7684\u5bb9\u5668\u5728erase\u7684\u65f6\u5019，\u90fd\u53ea\u91ca\u653e\u5bb9\u5668\u81ea\u5df1\u6240new\u51fa\u6765\u7684\u7a7a\u95f4，\u50cf\u54c8\u5e0c\u8868\u8fd9\u6837\u7684\u5bb9\u5668，\u5b83\u4f1anew\u4e00\u4e2a\u5b58\u50a8\u952e\u503c\u5bf9\u7684\u8282\u70b9\u7a7a\u95f4，\u8282\u70b9\u91cc\u9762\u5b58\u50a8\u7740conn\u6307\u9488\u548csockfd，\u5f53\u8c03\u7528\u54c8\u5e0c\u8868\u7684erase\u65f6，\u54c8\u5e0c\u8868\u53ea\u4f1a\u91ca\u653e\u5b83\u81ea\u5df1new\u51fa\u6765\u7684\u8282\u70b9\u7a7a\u95f4，\u81f3\u4e8e\u8fd9\u4e2a\u8282\u70b9\u7a7a\u95f4\u91cc\u9762\u5b58\u50a8\u4e86\u4e00\u4e2aConnection\u7c7b\u578b\u7684\u6307\u9488，\u5e76\u4e14\u8fd9\u4e2a\u6307\u9488\u53d8\u91cf\u6307\u5411\u4e00\u4e2a\u7ed3\u6784\u4f53\u7a7a\u95f4，\u8fd9\u4e9b\u4e8b\u60c5\u54c8\u5e0c\u8868\u624d\u4e0d\u4f1a\u7ba1\u4f60\u5462，\u5bb9\u5668\u53ea\u4f1a\u91ca\u653e\u4ed6\u81ea\u5df1\u5f00\u8f9f\u7684\u7a7a\u95f4，\u54c8\u5e0c\u8868\u662fvector\u6302\u5355\u94fe\u8868\u7684\u65b9\u5f0f\u6765\u5b9e\u73b0\u7684\u3002 \u6240\u4ee5\u6211\u4eec\u8981\u81ea\u5df1\u624b\u52a8\u91ca\u653econn\u6307\u5411\u7684\u7a7a\u95f4，\u5982\u679c\u4f60\u4e0d\u60f3\u81ea\u5df1\u624b\u52a8\u91ca\u653econn\u6307\u5411\u7684\u5806\u7a7a\u95f4\u8d44\u6e90，\u5219\u53ef\u4ee5\u5b58\u50a8\u667a\u80fd\u6307\u9488\u5bf9\u8c61，\u8fd9\u6837\u5728\u54c8\u5e0c\u8868erase\u65f6，\u5c31\u4f1a\u91ca\u653e\u667a\u80fd\u6307\u9488\u5bf9\u8c61\u7684\u7a7a\u95f4，\u4ece\u800c\u81ea\u52a8\u8c03\u7528Connection\u7c7b\u7684\u6790\u6784\u51fd\u6570\u3002<\/p>\n
\u00a0\u00a0\u8fd9\u6837\u641e\u8d77\u6765\u5176\u5b9e\u8fd8\u662f\u5f88\u9ebb\u70e6\u7684，\u6240\u4ee5\u6211\u4eec\u5c31\u81ea\u5df1\u624b\u52a8\u91ca\u653e\u5c31\u597d\u4e86，\u5982\u679c\u4e0d\u624b\u52a8\u91ca\u653e\u90a3\u5c31\u4f1a\u9020\u6210\u5185\u5b58\u6cc4\u9732\u3002<\/p>\n
\u7531\u4e8e\u5b9e\u73b0\u8d77\u6765\u6bd4\u8f83\u9ebb\u70e6，\u9700\u8981\u4fee\u6539\u4ee3\u7801\u7684\u5f88\u591a\u5730\u65b9，\u6211\u5c31\u4e0d\u6539\u4e86，\u4f46\u662f\u6700\u6838\u5fc3\u7684\u90e8\u5206\u5c31\u50cf\u4e0b\u9762\u8fd9\u6837\u5b50![\"\"](\"2025-04-19aqgtbqntsub.png\")
<\/p>\n<\/p>\n
\u00a0\u81f3\u6b64，\u6211\u4eec\u7684\u7b80\u6613\u7248\u672c\u7684\u5355Reactor\u5355\u8fdb\u7a0b\u7248\u672c\u7684TCP\u670d\u52a1\u5668\u5c31\u7b97\u5b8c\u6210\u4e86！<\/p>\n
tcpserver.hpp<\/p>\n
#pragma once
\n#include <iostream>
\n#include <string>
\n#include <functional>
\n#include <memory>
\n#include <unordered_map><\/p>\n
#include "Socket.hpp"
\n#include "Epoller.hpp"
\n#include "nocopy.hpp"
\n#include <sys\/socket.h>
\n#include <sys\/types.h><\/p>\n
class Connection;
\nusing func_t = std::function<void(std::shared_ptr<Connection>)>;
\nclass TcpServer;<\/p>\n
class Connection
\n{
\npublic:
\n Connection(int sock, std::shared_ptr<TcpServer> tcp_server_ptr) : _sock(sock), _tcp_server_ptr(tcp_server_ptr)
\n {
\n }
\n ~Connection()
\n {
\n }
\n void setcallback(func_t recv_cb, func_t send_cb, func_t except_cb)
\n {
\n _recv_cb = recv_cb;
\n _send_cb = send_cb;
\n _except_cb = except_cb;
\n }
\n int Getsock()
\n {
\n return _sock;
\n }
\n void Append(std::string info)
\n {
\n _inbuffer += info;
\n }<\/p>\n
public:
\n int _sock;
\n std::string _inbuffer; \/\/ \u8fd9\u91cc\u6765\u5f53\u8f93\u5165\u7f13\u51b2\u533a，\u4f46\u662f\u8fd9\u91cc\u662f\u6709\u7f3a\u70b9\u7684，\u5b83\u4e0d\u80fd\u5904\u7406\u4e8c\u8fdb\u5236\u6d41
\n std::string _outbuffer;<\/p>\n
public:
\n func_t _recv_cb; \/\/ \u8bfb\u56de\u8c03\u51fd\u6570
\n func_t _send_cb; \/\/ \u5199\u56de\u8c03\u51fd\u6570
\n func_t _except_cb; \/\/
\n std::shared_ptr<TcpServer> _tcp_server_ptr; \/\/ \u6dfb\u52a0\u4e00\u4e2a\u56de\u6307\u6307\u9488
\n uint16_t _clientport;
\n std::string _clientip;
\n};
\nclass TcpServer : public nocopy
\n{
\n static const int num = 64;<\/p>\n
public:
\n TcpServer(uint16_t port, func_t OnMessage) : _port(port),
\n _listensock_ptr(new Sock()),
\n _epoller_ptr(new Epoller()),
\n _quit(true),
\n _OnMessage(OnMessage)
\n {
\n }
\n ~TcpServer()
\n {
\n }
\n \/\/ \u8bbe\u7f6e\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n int set_non_blocking(int fd)
\n {
\n int flags = fcntl(fd, F_GETFL, 0);
\n if (flags == -1)
\n {
\n perror("fcntl: get flags");
\n return -1;
\n }
\n if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1)
\n {
\n perror("fcntl: set non-blocking");
\n return -1;
\n }
\n return 0;
\n }<\/p>\n
void Init()
\n {
\n _listensock_ptr->Socket();
\n set_non_blocking(_listensock_ptr->Fd()); \/\/ \u8bbe\u7f6elisten\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e3a\u975e\u963b\u585e
\n _listensock_ptr->Bind(_port);
\n _listensock_ptr->Listen();
\n AddConnection(_listensock_ptr->Fd(), (EPOLLIN | EPOLLET),
\n std::bind(&TcpServer::Accepter, this, std::placeholders::_1), nullptr, nullptr); \/\/ \u6682\u65f6\u8bbe\u7f6e\u6210nullptr
\n }
\n \/\/ \u8fde\u63a5\u7ba1\u7406\u5668
\n void Accepter(std::shared_ptr<Connection> conection)
\n {
\n while (1)
\n {
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n int sock = accept(conection->Getsock(), (sockaddr *)&peer, &len);
\n if (sock > 0)
\n {
\n \/\/ \u83b7\u53d6\u5ba2\u6237\u7aef\u4fe1\u606f
\n uint16_t clientport = ntohs(peer.sin_port);
\n char buffer[128];
\n inet_ntop(AF_INET, &(peer.sin_addr), buffer, sizeof(buffer));
\n std::cout << "get a new client from:" << buffer << conection->Getsock() << std::endl;<\/p>\n
set_non_blocking(sock); \/\/ \u8bbe\u7f6e\u975e\u963b\u585e
\n AddConnection(sock, EPOLLIN,
\n std::bind(&TcpServer::Recver, this, std::placeholders::_1),
\n std::bind(&TcpServer::Sender, this, std::placeholders::_1),
\n std::bind(&TcpServer::Excepter, this, std::placeholders::_1),
\n buffer, clientport);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n break;
\n }
\n }
\n }
\n \/\/ \u4e8b\u4ef6\u7ba1\u7406\u5668
\n void Recver(std::shared_ptr<Connection> conection)
\n {
\n int sock = conection->Getsock();
\n while (1)
\n {
\n char buffer[128];
\n memset(buffer, 0, sizeof(buffer));
\n ssize_t n = recv(sock, buffer, sizeof(buffer) – 1, 0); \/\/ \u975e\u963b\u585e\u8bfb\u53d6
\n if (n > 0) \/\/ \u6210\u529f\u4e86！！
\n {
\n conection->Append(buffer); \/\/ \u628a\u8bfb\u53d6\u7684\u6570\u636e\u653e\u5230Connection\u5bf9\u8c61\u7684\u8f93\u5165\u7f13\u51b2\u533a\u91cc\u9762
\n }
\n else if (n == 0) \/\/ \u5ba2\u6237\u7aef
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "quit" << std::endl;
\n Excepter(conection);
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n break;
\n else
\n {
\n std::cout << "sockfd:" << sock << ",client:" << conection->_clientip << ":" << conection->_clientport << "recv err" << std::endl;
\n Excepter(conection);
\n }
\n }
\n _OnMessage(conection); \/\/ \u5c06\u8bfb\u53d6\u7684\u6570\u636e\u4ea4\u7ed9\u4e0a\u5c42\u5904\u7406
\n }
\n }
\n void Sender(std::shared_ptr<Connection> conection)
\n {
\n std::string outbuffer = conection->_outbuffer;
\n while (1)
\n {<\/p>\n
ssize_t n = send(conection->Getsock(), outbuffer.data(), outbuffer.size(), 0);
\n if (n > 0) \/\/ \u53d1\u6210\u529f\u4e86
\n {
\n outbuffer.erase(0, n);
\n if (outbuffer.empty())
\n break;
\n }
\n else if (n == 0)
\n {
\n return;
\n }
\n else
\n {
\n if (errno == EWOULDBLOCK)
\n break;
\n else if (errno == EINTR)
\n continue;
\n else
\n {
\n std::cout << "sockfd:" << conection->Getsock() << ",client:" << conection->_clientip << ":" << conection->_clientport << "send error" << std::endl;
\n Excepter(conection);
\n break;
\n }
\n }
\n }
\n if (!outbuffer.empty())
\n {
\n \/\/ \u5f00\u542f\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u5fc3
\n EnableEvent(conection->Getsock(), true, true); \/\/ \u5173\u5fc3\u8bfb\u5199
\n }
\n else
\n {
\n \/\/ \u5173\u95ed\u5bf9\u5199\u4e8b\u4ef6\u7684\u5173\u5fc3
\n EnableEvent(conection->Getsock(), true, false); \/\/ \u5173\u5fc3\u8bfb,\u4e0d\u5173\u5fc3\u5199
\n }
\n }
\n void EnableEvent(int sock, bool readable, bool sendable)
\n {
\n uint32_t events = 0;
\n events |= (readable ? EPOLLIN : 0) | (sendable ? EPOLLOUT : 0) | EPOLLET;
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_MOD, sock, events);
\n }
\n void Excepter(std::shared_ptr<Connection> conection)
\n {
\n if (!conection)
\n {
\n \/\/ Connection \u5bf9\u8c61\u53ef\u80fd\u5df2\u88ab\u9500\u6bc1，\u65e0\u9700\u8fdb\u4e00\u6b65\u64cd\u4f5c
\n std::cout << "Connection already destroyed, no further action taken." << std::endl;
\n return;
\n }<\/p>\n
std::cout << "Execpted ! fd:" << conection->Getsock() << std::endl;
\n \/\/ 1.\u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26\u4eceepoll\u6a21\u578b\u91cc\u9762\u79fb\u9664\u6765
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_DEL, conection->Getsock(), 0);
\n \/\/ 2.\u5173\u95ed\u5f02\u5e38\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26
\n close(conection->Getsock());
\n \/\/ 3.\u4eceunordered_map\u4e2d\u5220\u9664
\n _connections.erase(conection->Getsock());
\n }
\n void PrintConnection()
\n {
\n std::cout << "_connections fd list: ";
\n for (auto &connection : _connections)
\n {
\n std::cout << connection.second->Getsock() << " ";
\n std::cout << connection.second->_inbuffer;
\n }
\n std::cout << std::endl;
\n }
\n void AddConnection(int sock, uint32_t event, func_t recv_cb, func_t send_cb, func_t except_cb,
\n std::string clientip = "0.0.0.0", uint16_t clientport = 0)
\n {<\/p>\n
\/\/ 1.\u7ed9listen\u5957\u63a5\u5b57\u521b\u5efa\u4e00\u4e2aConnection\u5bf9\u8c61
\n std::shared_ptr<Connection> new_connection = std::make_shared<Connection>(sock, std::shared_ptr<TcpServer>(this)); \/\/ \u521b\u5efaConnection\u5bf9\u8c61
\n new_connection->setcallback(recv_cb, send_cb, except_cb);
\n new_connection->_clientip = clientip;
\n new_connection->_clientport = clientport;<\/p>\n
\/\/ 2.\u6dfb\u52a0\u5230_connections\u91cc\u9762\u53bb
\n _connections.insert(std::make_pair(sock, new_connection));<\/p>\n
\/\/ \u5c06listen\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u4e2d->\u5c06listensock\u548c\u4ed6\u5173\u5fc3\u7684\u4e8b\u4ef6，\u6dfb\u52a0\u5230\u5185\u6838\u7684epoll\u6a21\u578b\u4e2d\u7684\u7ea2\u9ed1\u6811\u91cc\u9762
\n \/\/ 3.\u5c06listensock\u6dfb\u52a0\u5230\u7ea2\u9ed1\u6811
\n _epoller_ptr->EpollUpDate(EPOLL_CTL_ADD, sock, event); \/\/ \u6ce8\u610f\u8fd9\u91cc\u7684EPOLLET\u8bbe\u7f6e\u4e86ET\u6a21\u5f0f<\/p>\n
std::cout << "add a new connection success,sockfd:" << sock << std::endl;
\n }
\n bool IsConnectionSafe(int fd)
\n {
\n auto iter = _connections.find(fd);
\n if (iter == _connections.end())
\n {
\n return false;
\n }
\n else
\n {
\n return true;
\n }
\n }
\n void Dispatcher() \/\/ \u4e8b\u4ef6\u6d3e\u53d1\u5668
\n {
\n int n = _epoller_ptr->EpollerWait(revs, num); \/\/ \u83b7\u53d6\u5df2\u7ecf\u5c31\u7eea\u7684\u4e8b\u4ef6
\n for (int i = 0; i < num; i++)
\n {
\n uint32_t events = revs[i].events;
\n int sock = revs[i].data.fd;
\n \/\/ \u5982\u679c\u51fa\u73b0\u5f02\u5e38，\u7edf\u4e00\u8f6c\u53d1\u4e3a\u8bfb\u5199\u95ee\u9898，\u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLERR) \/\/ \u51fa\u73b0\u9519\u8bef\u4e86
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n if (events & EPOLLHUP)
\n {
\n events |= (EPOLLIN | EPOLLOUT);
\n }
\n \/\/ \u53ea\u9700\u8981\u5904\u7406\u8bfb\u5199\u5c31\u884c
\n if (events & EPOLLIN && IsConnectionSafe(sock)) \/\/ \u8bfb\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if (_connections[sock]->_recv_cb)
\n _connections[sock]->_recv_cb(_connections[sock]);
\n }
\n if (events & EPOLLOUT && IsConnectionSafe(sock)) \/\/ \u5199\u4e8b\u4ef6\u5c31\u7eea
\n {
\n if (_connections[sock]->_send_cb)
\n _connections[sock]->_send_cb(_connections[sock]);
\n }
\n }
\n }
\n void Loop()
\n {
\n _quit = false;<\/p>\n
while (!_quit)
\n {
\n Dispatcher();
\n PrintConnection();
\n }
\n _quit = true;
\n }<\/p>\n
private:
\n uint16_t _port;
\n std::shared_ptr<Epoller> _epoller_ptr;
\n std::unordered_map<int, std::shared_ptr<Connection>> _connections;
\n std::shared_ptr<Sock> _listensock_ptr;
\n bool _quit;
\n struct epoll_event revs[num]; \/\/ \u4e13\u95e8\u7528\u6765\u5904\u7406\u4e8b\u4ef6\u7684<\/p>\n
\/\/ \u4e0a\u5c42\u5904\u7406\u6570\u636e
\n func_t _OnMessage; \/\/ \u5c06\u6570\u636e\u4ea4\u7ed9\u4e0a\u5c42
\n}; <\/p>\n
Epoller.hpp<\/p>\n
v#pragma once<\/p>\n
#include <iostream>
\n#include <sys\/epoll.h>
\n#include <unistd.h>
\n#include <cerrno>
\n#include "nocopy.hpp"<\/p>\n
class Epoller : public nocopy
\n{
\n static const int size = 128;<\/p>\n
public:
\n Epoller()
\n {
\n _epfd = epoll_create(size);
\n if (_epfd == -1)
\n {
\n perror("epoll_creat error");
\n }
\n else
\n {
\n printf("epoll_creat successful:%d\\\\n", _epfd);
\n }
\n }
\n ~Epoller()
\n {
\n if (_epfd > 0)
\n {
\n close(_epfd);
\n }
\n }<\/p>\n
int EpollerWait(struct epoll_event revents[],int num)
\n {
\n int n=epoll_wait(_epfd,revents,num,3000);
\n return n;
\n }<\/p>\n
int EpollUpDate(int oper,int sock,uint16_t event)
\n {
\n int n;
\n if(oper==EPOLL_CTL_DEL)\/\/\u5c06\u8be5\u4e8b\u4ef6\u4eceepoll\u7ea2\u9ed1\u6811\u91cc\u9762\u5220\u9664
\n {
\n n=epoll_ctl(_epfd,oper,sock,nullptr);
\n if(n!=0)
\n {
\n printf("delete epoll_ctl error");
\n }
\n }
\n else{\/\/\u6dfb\u52a0\u548c\u4fee\u6539,\u5373EPOLL_CTL_MOD\u548cEPOLL_CTL_ADD
\n struct epoll_event ev;
\n ev.events=event;
\n ev.data.fd=sock;\/\/\u65b9\u4fbf\u6211\u4eec\u77e5\u9053\u662f\u54ea\u4e2afd\u5c31\u7eea\u4e86<\/p>\n
n=epoll_ctl(_epfd,oper,sock,&ev);
\n if(n!=0)
\n {
\n perror("add epoll_ctl error");
\n }
\n }
\n return n;
\n }<\/p>\n
private:
\n int _epfd;
\n}; <\/p>\n
nocopy.hpp<\/p>\n
#pragma once <\/p>\n
class nocopy
\n{
\npublic:
\n \/\/ \u5141\u8bb8\u4f7f\u7528\u9ed8\u8ba4\u6784\u9020\u51fd\u6570（\u7531\u7f16\u8bd1\u5668\u81ea\u52a8\u751f\u6210）
\n nocopy() = default; <\/p>\n
\/\/ \u7981\u7528\u62f7\u8d1d\u6784\u9020\u51fd\u6570，\u9632\u6b62\u901a\u8fc7\u62f7\u8d1d\u6765\u521b\u5efa\u7c7b\u7684\u5b9e\u4f8b
\n nocopy(const nocopy&) = delete; <\/p>\n
\/\/ \u7981\u7528\u8d4b\u503c\u8fd0\u7b97\u7b26，\u9632\u6b62\u7c7b\u7684\u5b9e\u4f8b\u4e4b\u95f4\u901a\u8fc7\u8d4b\u503c\u64cd\u4f5c\u8fdb\u884c\u5185\u5bb9\u590d\u5236
\n nocopy& operator=(const nocopy&) = delete;
\n}; <\/p>\n
Serialization.hpp<\/p>\n
#pragma
\n#define CRLF "\\\\t" \/\/ \u5206\u9694\u7b26
\n#define CRLF_LEN strlen(CRLF) \/\/ \u5206\u9694\u7b26\u957f\u5ea6
\n#define SPACE " " \/\/ \u7a7a\u683c
\n#define SPACE_LEN strlen(SPACE) \/\/ \u7a7a\u683c\u957f\u5ea6
\n#define OPS "+-*\/%" \/\/ \u8fd0\u7b97\u7b26<\/p>\n
#include <iostream>
\n#include <string>
\n#include <cstring>
\n#include<assert.h><\/p>\n
\/\/\u53c2\u6570len\u4e3ain\u7684\u957f\u5ea6，\u662f\u4e00\u4e2a\u8f93\u51fa\u578b\u53c2\u6570\u3002\u5982\u679c\u4e3a0\u4ee3\u8868err
\nstd::string decode(std::string& in,size_t*len)
\n{
\n assert(len);\/\/\u5982\u679c\u957f\u5ea6\u4e3a0\u662f\u9519\u8bef\u7684<\/p>\n
\/\/ 1.\u786e\u8ba4in\u7684\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u5b8c\u6574（\u5206\u9694\u7b26）
\n *len=0;<\/p>\n
size_t pos = in.find(CRLF);\/\/\u67e5\u627e\\\\t\u7b2c\u4e00\u6b21\u51fa\u73b0\u65f6\u7684\u4e0b\u6807
\n \/\/\u67e5\u627e\u4e0d\u5230，err
\n if(pos == std::string::npos){
\n return "";\/\/\u8fd4\u56de\u7a7a\u4e32
\n }<\/p>\n
\/\/ 2.\u6709\u5206\u9694\u7b26，\u5224\u65ad\u957f\u5ea6\u662f\u5426\u8fbe\u6807
\n \/\/ \u6b64\u65f6pos\u4e0b\u6807\u6b63\u597d\u5c31\u662f\u6807\u8bc6\u5927\u5c0f\u7684\u5b57\u7b26\u957f\u5ea6
\n std::string inLenStr = in.substr(0,pos);\/\/\u4ece\u4e0b\u68070\u5f00\u59cb\u4e00\u76f4\u622a\u53d6\u5230\u7b2c\u4e00\u4e2a\\\\t\u4e4b\u524d<\/p>\n
\/\/\u5230\u8fd9\u91cc\u6211\u4eec\u8981\u660e\u767d，\u6211\u4eec\u8fd9\u4e0a\u9762\u622a\u53d6\u7684\u662f\u6700\u5f00\u5934\u7684\u957f\u5ea6，\u4e5f\u5c31\u662f\u8bf4，\u6211\u4eec\u622a\u53d6\u5230\u7684\u4e00\u5b9a\u662f\u4e2a\u6570\u5b57，\u8fd9\u4e2a\u662f\u6211\u4eec\u5e8f\u5217\u5316\u5b57\u7b26\u7684\u957f\u5ea6<\/p>\n
size_t inLen = atoi(inLenStr.c_str());\/\/\u628a\u622a\u53d6\u7684\u8fd9\u4e2a\u5b57\u7b26\u4e32\u8f6cint，inLen\u5c31\u662f\u5e8f\u5217\u5316\u5b57\u7b26\u7684\u957f\u5ea6<\/p>\n
\/\/\u4f20\u5165\u7684\u5b57\u7b26\u4e32\u7684\u957f\u5ea6 – \u7b2c\u4e00\u4e2a\\\\t\u524d\u9762\u7684\u5b57\u7b26\u6570 – 2\u4e2a\\\\t
\n size_t left = in.size() – inLenStr.size()- 2*CRLF_LEN;\/\/\u539f\u672c\u9884\u8ba1\u7684\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u957f\u5ea6
\n if(left<inLen){\/\/\u771f\u5b9e\u7684\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u957f\u5ea6\u548c\u9884\u8ba1\u7684\u5b57\u7b26\u4e32\u957f\u5ea6\u8fdb\u884c\u6bd4\u8f83
\n return ""; \/\/\u5269\u4e0b\u7684\u957f\u5ea6（\u5e8f\u5217\u5316\u5b57\u7b26\u4e32\u7684\u957f\u5ea6）\u6ca1\u6709\u8fbe\u5230\u6807\u660e\u7684\u957f\u5ea6
\n }<\/p>\n
\/\/ 3.\u8d70\u5230\u6b64\u5904，\u5b57\u7b26\u4e32\u5b8c\u6574，\u5f00\u59cb\u63d0\u53d6\u5e8f\u5217\u5316\u5b57\u7b26\u4e32
\n std::string ret = in.substr(pos+CRLF_LEN,inLen);\/\/\u4ecepos+CRLF_LEN\u4e0b\u6807\u5f00\u59cb\u8bfb\u53d6inLen\u4e2a\u957f\u5ea6\u7684\u5b57\u7b26\u4e32\u2014\u2014\u5373\u5e8f\u5217\u5316\u5b57\u7b26\u4e32<\/p>\n
*len = inLen;<\/p>\n
\/\/ 4.\u56e0\u4e3ain\u4e2d\u53ef\u80fd\u8fd8\u6709\u5176\u4ed6\u7684\u62a5\u6587（\u4e0b\u4e00\u6761）
\n \/\/ \u6240\u4ee5\u9700\u8981\u628a\u5f53\u524d\u7684\u62a5\u6587\u4ecein\u4e2d\u5220\u9664，\u65b9\u4fbf\u4e0b\u6b21decode，\u907f\u514d\u4e8c\u6b21\u8bfb\u53d6
\n size_t rmLen = inLenStr.size() + ret.size() + 2*CRLF_LEN;\/\/\u957f\u5ea6+2\u4e2a\\\\t+\u5e8f\u5217\u5b57\u7b26\u4e32\u7684\u957f\u5ea6
\n in.erase(0,rmLen);\/\/\u79fb\u9664\u4ece\u7d22\u5f150\u5f00\u59cb\u957f\u5ea6\u4e3armLen\u7684\u5b57\u7b26\u4e32<\/p>\n
\/\/ 5.\u8fd4\u56de
\n return ret;
\n}<\/p>\n
\/\/\u7f16\u7801\u4e0d\u9700\u8981\u4fee\u6539\u6e90\u5b57\u7b26\u4e32，\u6240\u4ee5const\u3002\u53c2\u6570len\u4e3ain\u7684\u957f\u5ea6
\nstd::string encode(const std::string& in,size_t len)
\n{
\n std::string ret = std::to_string(len);\/\/\u5c06\u957f\u5ea6\u8f6c\u4e3a\u5b57\u7b26\u4e32\u6dfb\u52a0\u5728\u6700\u524d\u9762，\u4f5c\u4e3a\u6807\u8bc6
\n ret+=CRLF;
\n ret+=in;
\n ret+=CRLF;
\n return ret;
\n}<\/p>\n
class Request\/\/\u5ba2\u6237\u7aef\u4f7f\u7528\u7684
\n{
\npublic:
\n \/\/ \u5c06\u7528\u6237\u7684\u8f93\u5165\u8f6c\u6210\u5185\u90e8\u6210\u5458
\n \/\/ \u7528\u6237\u53ef\u80fd\u8f93\u5165x+y，x+ y，x +y,x + y\u7b49\u7b49\u683c\u5f0f
\n \/\/ \u63d0\u524d\u4fee\u6539\u7528\u6237\u8f93\u5165（\u4e3b\u8981\u8fd8\u662f\u53bb\u6389\u7a7a\u683c），\u63d0\u53d6\u51fa\u6210\u5458
\n Request()
\n {<\/p>\n
}<\/p>\n
\/\/ \u5220\u9664\u8f93\u5165\u4e2d\u7684\u7a7a\u683c
\n void rmSpace(std::string &in)
\n {
\n std::string tmp;
\n for (auto e : in)
\n {
\n if (e != ' ')
\n {
\n tmp += e;
\n }
\n }
\n in = tmp;
\n }<\/p>\n
\/\/ \u5e8f\u5217\u5316 （\u5165\u53c2\u5e94\u8be5\u662f\u7a7a\u7684，\u4f1a\u8fd4\u56de\u4e00\u4e2a\u5e8f\u5217\u5316\u5b57\u7b26\u4e32）
\n void serialize(std::string &out)\/\/\u8fd9\u4e2a\u662f\u5ba2\u6237\u7aef\u5728\u53d1\u9001\u6d88\u606f\u7ed9\u670d\u52a1\u7aef\u65f6\u4f7f\u7528\u7684，\u5728\u8fd9\u4e4b\u540e\u8981\u5148\u7f16\u7801，\u624d\u80fd\u53d1\u9001\u51fa\u53bb
\n {
\n \/\/ x + y
\n out.clear(); \/\/ \u5e8f\u5217\u5316\u7684\u5165\u53c2\u662f\u7a7a\u7684
\n out += std::to_string(_x);
\n out += SPACE;
\n out += _ops; \/\/ \u64cd\u4f5c\u7b26\u4e0d\u80fd\u7528tostring，\u4f1a\u88ab\u8f6c\u6210ascii
\n out += SPACE;
\n out += std::to_string(_y);
\n \/\/ \u4e0d\u7528\u6dfb\u52a0\u5206\u9694\u7b26（\u8fd9\u662fencode\u8981\u5e72\u7684\u4e8b\u60c5）
\n }
\n \/\/\u5e8f\u5217\u5316\u4e4b\u540e\u5e94\u8be5\u8981\u7f16\u7801，\u53bb\u52a0\u4e2a\u957f\u5ea6<\/p>\n
\/\/ \u53cd\u5e8f\u5217\u5316（\u89e3\u5f00
\n bool deserialize(const std::string &in)\/\/\u8fd9\u4e2a\u662f\u670d\u52a1\u7aef\u63a5\u6536\u5230\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u6d88\u606f\u540e\u4f7f\u7528\u7684，\u5728\u8fd9\u4e4b\u524d\u8981\u5148\u89e3\u7801
\n {
\n \/\/ x + y \u9700\u8981\u53d6\u51fax，y\u548c\u64cd\u4f5c\u7b26
\n size_t space1 = in.find(SPACE); \/\/ \u7b2c\u4e00\u4e2a\u7a7a\u683c
\n if (space1 == std::string::npos) \/\/ \u6ca1\u627e\u5230
\n {
\n return false;
\n }<\/p>\n
size_t space2 = in.rfind(SPACE); \/\/ \u7b2c\u4e8c\u4e2a\u7a7a\u683c
\n if (space2 == std::string::npos) \/\/ \u6ca1\u627e\u5230
\n {
\n return false;
\n }<\/p>\n
\/\/ \u4e24\u4e2a\u7a7a\u683c\u90fd\u5b58\u5728，\u5f00\u59cb\u53d6\u6570\u636e
\n std::string dataX = in.substr(0, space1);
\n std::string dataY = in.substr(space2 + SPACE_LEN); \/\/ \u9ed8\u8ba4\u53d6\u5230\u7ed3\u5c3e<\/p>\n
std::string op = in.substr(space1 + SPACE_LEN, space2 – (space1 + SPACE_LEN));
\n if (op.size() != 1)
\n {
\n return false; \/\/ \u64cd\u4f5c\u7b26\u957f\u5ea6\u6709\u95ee\u9898
\n }<\/p>\n
\/\/ \u6ca1\u95ee\u9898\u4e86，\u8f6c\u5185\u90e8\u6210\u5458
\n _x = atoi(dataX.c_str());
\n _y = atoi(dataY.c_str());
\n _ops = op[0];
\n return true;
\n }<\/p>\n
public:
\n int _x;
\n int _y;
\n char _ops;
\n};<\/p>\n
class Response \/\/ \u670d\u52a1\u7aef\u5fc5\u987b\u56de\u5e94
\n{
\n public:
\n Response(int code = 0, int result = 0)
\n : _exitCode(code), _result(result)
\n {
\n }<\/p>\n
\/\/ \u5e8f\u5217\u5316
\n void serialize(std::string &out)\/\/\u8fd9\u4e2a\u662f\u670d\u52a1\u7aef\u53d1\u9001\u6d88\u606f\u7ed9\u5ba2\u6237\u7aef\u4f7f\u7528\u7684，\u4f7f\u7528\u4e4b\u540e\u8981\u7f16\u7801
\n {
\n \/\/ code ret
\n out.clear();
\n out += std::to_string(_exitCode);
\n out += SPACE;
\n out += std::to_string(_result);
\n out += CRLF;
\n }<\/p>\n
\/\/ \u53cd\u5e8f\u5217\u5316
\n bool deserialize(const std::string &in)\/\/\u8fd9\u4e2a\u662f\u5ba2\u6237\u7aef\u63a5\u6536\u670d\u52a1\u7aef\u6d88\u606f\u540e\u4f7f\u7528\u7684，\u4f7f\u7528\u4e4b\u524d\u8981\u5148\u89e3\u7801
\n {
\n \/\/ \u53ea\u6709\u4e00\u4e2a\u7a7a\u683c
\n size_t space = in.find(SPACE); \/\/ \u5bfb\u627e\u7b2c\u4e00\u4e2a\u7a7a\u683c\u7684\u4e0b\u6807
\n if (space == std::string::npos) \/\/ \u6ca1\u627e\u5230
\n {
\n return false;
\n }<\/p>\n
std::string dataCode = in.substr(0, space);
\n std::string dataRes = in.substr(space + SPACE_LEN);<\/p>\n
_exitCode = atoi(dataCode.c_str());
\n _result = atoi(dataRes.c_str());
\n return true;
\n }<\/p>\n
public:
\n int _exitCode; \/\/ \u8ba1\u7b97\u670d\u52a1\u7684\u9000\u51fa\u7801
\n int _result; \/\/ \u7ed3\u679c
\n};
\nResponse Caculater(const Request& req)
\n{
\n Response resp;\/\/\u6784\u9020\u51fd\u6570\u4e2d\u5df2\u7ecf\u6307\u5b9a\u4e86exitcode\u4e3a0
\n switch (req._ops)
\n {
\n case '+':
\n resp._result = req._x + req._y;
\n break;
\n case '-':
\n resp._result = req._x – req._y;
\n break;
\n case '*':
\n resp._result = req._x * req._y;
\n break;
\n case '%':
\n {
\n if(req._y == 0)
\n {
\n resp._exitCode = -1;\/\/\u53d6\u6a21\u9519\u8bef
\n break;
\n }
\n resp._result = req._x % req._y;\/\/\u53d6\u6a21\u662f\u53ef\u4ee5\u64cd\u4f5c\u8d1f\u6570\u7684
\n break;
\n }
\n case '\/':
\n {
\n if(req._y == 0)
\n {
\n resp._exitCode = -2;\/\/\u96640\u9519\u8bef
\n break;
\n }
\n resp._result = req._x \/ req._y;\/\/\u53d6\u6a21\u662f\u53ef\u4ee5\u64cd\u4f5c\u8d1f\u6570\u7684
\n break;
\n }
\n default:
\n resp._exitCode = -3;\/\/\u64cd\u4f5c\u7b26\u975e\u6cd5
\n break;
\n }<\/p>\n
return resp;
\n} <\/p>\n
\u00a0main.cc<\/p>\n
\u00a0<\/p>\n
#include "tcpserver.hpp"
\n#include <memory>
\n#include "Serialization.hpp"<\/p>\n
void DefaultOmMessage(std::shared_ptr<Connection> connection_ptr)
\n{
\n std::cout << "\u4e0a\u5c42\u5f97\u5230\u4e86\u6570\u636e：" << connection_ptr->_inbuffer << std::endl;
\n std::string inbuf = connection_ptr->_inbuffer;
\n size_t packageLen = inbuf.size();
\n \/\/\u7531\u4e8e\u6211\u4eec\u662f\u4f7f\u7528telnet\u6765\u6d4b\u8bd5\u7684\u6240\u4ee5，\u6211\u4eec\u5c31\u4e0d\u89e3\u7801\u4e86
\n \/*
\n \/\/ 3.1.\u89e3\u7801\u548c\u53cd\u5e8f\u5217\u5316\u5ba2\u6237\u7aef\u4f20\u6765\u7684\u6d88\u606f
\n std::string package = decode(inbuf, &packageLen); \/\/ \u89e3\u7801
\n if (packageLen == 0)
\n {
\n printf("decode err: %s[%d] status: %d", connection_ptr->_clientip, connection_ptr->_clientport, packageLen);
\n \/\/ \u62a5\u6587\u4e0d\u5b8c\u6574\u6216\u6709\u8bef
\n }
\n *\/<\/p>\n
Request req;
\n bool deStatus = req.deserialize(inbuf); \/\/ \u4f7f\u7528Request\u7684\u53cd\u5e8f\u5217\u5316，packsge\u5185\u90e8\u5404\u4e2a\u6210\u5458\u5df2\u7ecf\u6709\u4e86\u6570\u503c
\n if (deStatus) \/\/ \u83b7\u53d6\u6d88\u606f\u53cd\u5e8f\u5217\u5316\u6210\u529f
\n {
\n \/\/ 3.2.\u83b7\u53d6\u7ed3\u6784\u5316\u7684\u76f8\u5e94
\n Response resp = Caculater(req); \/\/ \u5c06\u8ba1\u7b97\u4efb\u52a1\u7684\u7ed3\u679c\u5b58\u653e\u5230Response\u91cc\u9762\u53bb<\/p>\n
\/\/ 3.3.\u5e8f\u5217\u5316\u548c\u7f16\u7801\u54cd\u5e94
\n std::string echoStr;
\n resp.serialize(echoStr); \/\/ \u5e8f\u5217\u5316<\/p>\n
\/\/\u7531\u4e8e\u6211\u4eec\u4f7f\u7528\u7684\u662ftelnet\u6765\u6d4b\u8bd5\u7684，\u6240\u4ee5\u6211\u4eec\u4e0d\u7f16\u7801\u4e86
\n \/\/ echoStr = encode(echoStr, echoStr.size()); \/\/ \u7f16\u7801<\/p>\n
\/\/ 3.4.\u5199\u5165，\u53d1\u9001\u8fd4\u56de\u503c\u7ed9\u8f93\u51fa\u7f13\u51b2\u533a
\n connection_ptr->_outbuffer=echoStr;
\n std::cout<<connection_ptr->_outbuffer<<std::endl;<\/p>\n
connection_ptr->_tcp_server_ptr->Sender(connection_ptr);\/\/\u8c03\u7528\u91cc\u9762\u7684\u65b9\u6cd5\u6765\u53d1\u9001
\n }
\n else \/\/ \u5ba2\u6237\u7aef\u6d88\u606f\u53cd\u5e8f\u5217\u5316\u5931\u8d25
\n {
\n printf("deserialize err: %s[%d] status: %d", connection_ptr->_clientip, connection_ptr->_clientport, deStatus);
\n return;
\n }<\/p>\n
}<\/p>\n
int main()
\n{
\n std::unique_ptr<TcpServer> svr(new TcpServer(8877, DefaultOmMessage));
\n svr->Init();
\n svr->Loop();
\n} <\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 Reactor\u4e3b\u8981\u56f4\u7ed5\u4e8b\u4ef6\u6d3e\u53d1\u548c\u81ea\u52a8\u53cd\u5e94\u5c55\u5f00\u7684，\u5c31\u6bd4\u5982\u8fde\u63a5\u8bf7\u6c42\u5230\u6765，epoll_wait\u63d0\u9192\u7a0b\u5e8f\u5458\u5c31\u7eea\u7684\u4e8b\u4ef6\u5230\u6765，\u5e94\u8be5\u5c3d\u5feb\u5904\u7406，\u5219\u4e0e\u5c31\u7eea\u4e8b\u4ef6\u76f8\u5173\u8054\u7684sock\u4f1a\u5bf9\u5e94\u7740\u4e00\u4e2aconnection\u7ed3\u6784\u4f53，\u8fd9\u4e2a\u7ed3\u6784\u4f53\u6211\u89c9\u5f97\u5c31\u662f\u53cd\u5e94\u5806\u6a21\u5f0f\u7684\u7cbe\u534e\u6240\u5728，\u65e0\u8bba\u662f\u4ec0\u4e48\u6837\u5c31\u7eea\u7684\u4e8b\u4ef6，\u6bcf\u4e2asock\u90fd\u4f1a\u6709\u5bf9\u5e94\u7684\u56de\u8c03\u65b9\u6cd5，\u6240\u4ee5\u5904\u7406\u5c31\u7eea\u7684\u4e8b\u4ef6\u5f88\u5bb9\u6613，\u76f4\u63a5\u56de\u8c03connection\u5185\u7684\u5bf9\u5e94\u65b9\u6cd5\u5373\u53ef，\u662f\u8bfb\u4e8b\u4ef6\u5c31\u8c03\u7528\u8bfb\u65b9\u6cd5，\u662f\u5199\u4e8b\u4ef6\u5c31\u8c03\u7528\u5199\u65b9\u6cd5，\u662f\u5f02\u5e38\u4e8b\u4ef6，\u5219\u5728\u8bfb\u65b9\u6cd5\u6216\u5199\u65b9\u6cd5\u4e2d\u5904\u7406IO\u7684\u540c\u65f6，\u987a\u4fbf\u5904\u7406\u6389\u5f02\u5e38\u4e8b\u4ef6\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u6240\u4ee5\u6211\u611f\u89c9Reactor\u5c31\u50cf\u4e00\u4e2a\u5316\u5b66\u53cd\u5e94\u5806，\u4f60\u5411\u8fd9\u4e2a\u53cd\u5e94\u5806\u91cc\u9762\u6254\u4e00\u4e9b\u8fde\u63a5\u8bf7\u6c42，\u6216\u8005\u7f51\u7edc\u6570\u636e，\u5219\u8fd9\u4e2a\u53cd\u5e94\u5806\u4f1a\u81ea\u52a8\u5339\u914d\u76f8\u5bf9\u5e94\u7684\u5904\u7406\u673a\u5236\u6765\u5904\u7406\u5230\u6765\u7684\u4e8b\u4ef6，\u5f88\u65b9\u4fbf，\u540c\u65f6\u7531\u4e8eET\u6a21\u5f0f\u548cEPOLL，\u8fd9\u5c31\u8ba9Reactor\u5728\u5904\u7406\u9ad8\u5e76\u53d1\u8fde\u63a5\u65f6，\u5c55\u73b0\u51fa\u4e86\u4e0d\u4fd7\u7684\u5b9e\u529b\u3002<\/p>\n<\/p>\n<\/p>\n<\/p><\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1k\u6b21\uff0c\u70b9\u8d5e8\u6b21\uff0c\u6536\u85cf13\u6b21\u3002Reactor\u4e3b\u8981\u56f4\u7ed5\u4e8b\u4ef6\u6d3e\u53d1\u548c\u81ea\u52a8\u53cd\u5e94\u5c55\u5f00\u7684\uff0c\u5c31\u6bd4\u5982\u8fde\u63a5\u8bf7\u6c42\u5230\u6765\uff0cepoll_wait\u63d0\u9192\u7a0b\u5e8f\u5458\u5c31\u7eea\u7684\u4e8b\u4ef6\u5230\u6765\uff0c\u5e94\u8be5\u5c3d\u5feb\u5904\u7406\uff0c\u5219\u4e0e\u5c31\u7eea\u4e8b\u4ef6\u76f8\u5173\u8054\u7684sock\u4f1a\u5bf9\u5e94\u7740\u4e00\u4e2aconnection\u7ed3\u6784\u4f53\uff0c\u8fd9\u4e2a\u7ed3\u6784\u4f53\u6211\u89c9\u5f97\u5c31\u662f\u53cd\u5e94\u5806\u6a21\u5f0f\u7684\u7cbe\u534e\u6240\u5728\uff0c\u65e0\u8bba\u662f\u4ec0\u4e48\u6837\u5c31\u7eea\u7684\u4e8b\u4ef6\uff0c\u6bcf\u4e2asock\u90fd\u4f1a\u6709\u5bf9\u5e94\u7684\u56de\u8c03\u65b9\u6cd5\uff0c\u6240\u4ee5\u5904\u7406\u5c31\u7eea\u7684\u4e8b\u4ef6\u5f88\u5bb9\u6613\uff0c\u76f4\u63a5\u56de\u8c03connection\u5185\u7684\u5bf9\u5e94\u65b9\u6cd5\u5373\u53ef\uff0c\u662f\u8bfb\u4e8b\u4ef6\u5c31\u8c03\u7528\u8bfb\u65b9\u6cd5\uff0c\u662f\u5199\u4e8b\u4ef6\u5c31\u8c03\u7528\u5199\u65b9\u6cd5\uff0c\u662f\u5f02\u5e38\u4e8b\u4ef6\uff0c\u5219\u5728\u8bfb\u65b9\u6cd5\u6216\u5199\u65b9\u6cd5\u4e2d\u5904\u7406IO\u7684\u540c\u65f6\uff0c\u987a\u4fbf\u5904\u7406\u6389\u5f02\u5e38\u4e8b\u4ef6\u3002_react io<\/p>\n","protected":false},"author":2,"featured_media":27254,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[43,44],"topic":[],"class_list":["post-27274","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-43","tag-44"],"yoast_head":"\n