![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205847-6a6523871c266.jpg\")
<\/p>\n<\/p>\n
🔥\u4e2a\u4eba\u4e3b\u9875：<\/span>Cx330🌸<\/p>\n \u2744\ufe0f\u4e2a\u4eba\u4e13\u680f：<\/span>\u300aC\u8bed\u8a00\u300b\u300aLeetCode\u5237\u9898\u96c6\u300b\u300a\u6570\u636e\u7ed3\u6784-\u521d\u9636\u300b\u300aC++\u77e5\u8bc6\u5206\u4eab\u300b<\/p>\n \u300a\u4f18\u9009\u7b97\u6cd5\u6307\u5357-\u5fc5\u5237\u7ecf\u5178100\u9898\u300b\u300aLinux\u64cd\u4f5c\u7cfb\u7edf\u300b:\u4ece\u5165\u95e8\u5230\u5165\u9b54<\/p>\n \u300aGit\u6df1\u5ea6\u89e3\u6790\u300b:\u7248\u672c\u7ba1\u7406\u5b9e\u6218\u5168\u89e3\u00a0\u300aQt \u6781\u5883\u67b6\u6784\u300b<\/p>\n 🌟\u5fc3\u5411\u5f80\u4e4b\u884c\u5fc5\u80fd<\/span><\/p>\n 🎥Cx330🌸\u7684\u7b80\u4ecb：<\/span><\/p>\n \u76ee\u5f55<\/p>\n \u524d\u8a00<\/p>\n \u4e00.\u00a0TCP\u00a0\u670d\u52a1\u5668\u6838\u5fc3\u6a21\u578b\u6f14\u8fdb<\/p>\n \u4e8c. \u81ea\u7814\u57fa\u7840\u7ec4\u4ef6\u6df1\u5ea6\u89e3\u6790<\/p>\n 2.1 \u4e92\u65a5\u9501\u4e0e RAII \u9501\u5b88\u536b（Mutex.hpp）<\/p>\n 2.2 \u6761\u4ef6\u53d8\u91cf\u5c01\u88c5（Cond.hpp）<\/p>\n 2.3 \u7ebf\u7a0b\u5c01\u88c5（Thread.hpp）<\/p>\n 2.4 \u7b56\u7565\u6a21\u5f0f\u65e5\u5fd7\u7cfb\u7edf（Logger.hpp）<\/p>\n 2.5 \u7f51\u7edc\u5730\u5740\u5c01\u88c5（InetAddr.hpp）<\/p>\n \u4e09. V3\u00a0\u591a\u8fdb\u7a0b\u7248\u672c：\u8fdc\u7a0b\u547d\u4ee4\u6267\u884c\u670d\u52a1\u5668\u5b9e\u6218<\/p>\n 3.1 \u9700\u6c42\u80cc\u666f\u4e0e\u6574\u4f53\u8bbe\u8ba1<\/p>\n 3.2 \u4e1a\u52a1\u5c42：\u547d\u4ee4\u6267\u884c\u6a21\u5757\u6df1\u5ea6\u89e3\u6790（ExcuteCommand.hpp）<\/p>\n 3.3 \u7f51\u7edc\u5c42：\u591a\u7ebf\u7a0b TCP \u670d\u52a1\u5668\u6df1\u5ea6\u89e3\u6790<\/p>\n 3.3.1 \u6838\u5fc3\u7c7b\u578b\u4e0e\u6210\u5458\u5b9a\u4e49<\/p>\n 3.3.2 \u670d\u52a1\u7aef\u5b8c\u6574\u4ee3\u7801\u89e3\u6790（TcpServer.hpp）<\/p>\n 3.3.3 \u5ba2\u6237\u7aef\u5b8c\u6574\u4ee3\u7801\u89e3\u6790<\/p>\n 3.3.4 \u670d\u52a1\u7aef\u4e3b\u51fd\u6570\u4ee3\u7801（TcpServer.cc）<\/p>\n \u56db. V4 \u7ebf\u7a0b\u6c60\u7248\u672c：\u9ad8\u5e76\u53d1 Echo \u670d\u52a1\u5668\u5b9e\u73b0<\/p>\n 4.1 \u7ebf\u7a0b\u6c60\u6838\u5fc3\u8bbe\u8ba1\u601d\u60f3<\/p>\n 4.2 \u7ebf\u7a0b\u6c60\u6a21\u677f\u7c7b\u6df1\u5ea6\u89e3\u6790（ThreadPool.hpp）<\/p>\n 4.3 \u57fa\u4e8e\u7ebf\u7a0b\u6c60\u7684 TCP Echo \u670d\u52a1\u5668\u5b9e\u73b0<\/p>\n 4.3.1 \u670d\u52a1\u5668\u6838\u5fc3\u5b9e\u73b0（TcpEchoServer.hpp）<\/p>\n 4.4 \u7ebf\u7a0b\u6c60\u7248\u672c\u7684\u6838\u5fc3\u4f18\u52bf<\/p>\n \u4e94.\u00a0\u6838\u5fc3\u9762\u8bd5\u8003\u70b9\u4e0e\u5b9e\u6218\u8e29\u5751\u6307\u5357（QA\u95ee\u7b54\u7248）<\/p>\n 5.1 \u9ad8\u9891\u9762\u8bd5\u8003\u70b9<\/p>\n 5.2 \u5b9e\u6218\u8e29\u5751\u4e0e\u907f\u5751\u65b9\u6848<\/p>\n \u7ed3\u8bed<\/p>\n \u5728\u7f51\u7edc\u7f16\u7a0b\u7684\u6c5f\u6e56\u91cc，\u5982\u4f55\u8ba9\u670d\u52a1\u5668\u4f18\u96c5\u3001\u9ad8\u6548\u5730\u5904\u7406\u6210\u5343\u4e0a\u4e07\u7684\u5ba2\u6237\u7aef\u8fde\u63a5，\u662f\u6bcf\u4e00\u4f4d C++ \u7a0b\u5e8f\u5458\u7684\u5fc5\u4fee\u8bfe\u3002\u4ece\u6700\u521d\u7684\u201c\u5355\u5175\u4f5c\u6218\u201d（\u5355\u7ebf\u7a0b\u963b\u585e）\u5230\u540e\u6765\u7684\u201c\u4eba\u6d77\u6218\u672f\u201d（\u591a\u7ebf\u7a0b\u673a\u5236），\u518d\u5230\u73b0\u4ee3\u9ad8\u6027\u80fd\u6846\u67b6\u4e2d\u5fc5\u5907\u7684\u201c\u7cbe\u5175\u5f3a\u5c06\u201d（\u7ebf\u7a0b\u6c60\u67b6\u6784），\u6bcf\u4e00\u6b65\u6f14\u8fdb\u90fd\u4f34\u968f\u7740\u5bf9\u7cfb\u7edf\u8d44\u6e90（CPU\u3001\u5185\u5b58\u3001I\/O）\u66f4\u6df1\u5c42\u6b21\u7684\u601d\u8003\u3002<\/p>\n \u4eca\u5929，\u6211\u4eec\u5c31\u6765\u5f7b\u5e95\u6253\u901a TCP \u670d\u52a1\u5668\u591a\u7ebf\u7a0b\/\u7ebf\u7a0b\u6c60\u7684\u6838\u5fc3\u77e5\u8bc6\u70b9，\u6df1\u5165\u5185\u6838，\u5e76\u624b\u5199\u4e00\u5957\u5de5\u4e1a\u7ea7\u3001\u53ef\u76f4\u63a5\u590d\u7528\u7684\u73b0\u4ee3 C++ \u7ebf\u7a0b\u6c60 TCP \u670d\u52a1\u5668！<\/p>\n \u4e3a\u4e86\u5e2e\u52a9\u5927\u5bb6\u6784\u5efa\u6e05\u6670\u7684\u5e95\u5c42\u8ba4\u77e5，\u6211\u4eec\u5c06\u5355\u8fdb\u7a0b\u3001\u591a\u8fdb\u7a0b\u3001\u591a\u7ebf\u7a0b\u3001\u7ebf\u7a0b\u6c60\u56db\u79cd\u7ecf\u5178\u6a21\u578b\u5728\u6838\u5fc3\u6307\u6807\u4e0a\u8fdb\u884c\u6a2a\u5411\u5bf9\u6bd4：<\/p>\n \u8bc4\u4f30\u6307\u6807<\/p>\n \u5355\u8fdb\u7a0b（\u4e32\u884c\/\u8fed\u4ee3）<\/p>\n \u591a\u8fdb\u7a0b（Fork Per Conn）<\/p>\n \u591a\u7ebf\u7a0b（One Thread Per Conn）<\/p>\n \u7ebf\u7a0b\u6c60（Thread Pool）<\/p>\n<\/tr>\n \u5e76\u53d1\u80fd\u529b<\/p>\n<\/td>\n \u6781\u5dee（\u540c\u4e00\u65f6\u95f4\u53ea\u80fd\u5904\u7406\u4e00\u4e2a）<\/p>\n<\/td>\n \u8f83\u597d（\u53d7\u9650\u4e8e\u7cfb\u7edf\u6700\u5927\u8fdb\u7a0b\u6570）<\/p>\n<\/td>\n \u8f83\u597d（\u53d7\u9650\u4e8e\u6700\u5927\u7cfb\u7edf\u7ebf\u7a0b\u6570）<\/p>\n<\/td>\n \u4f18\u79c0（\u9ad8\u6548\u590d\u7528\u7ebf\u7a0b，\u652f\u6301\u6d77\u91cf\u4efb\u52a1\u6392\u961f）<\/p>\n<\/td>\n<\/tr>\n \u521b\u5efa\/\u9500\u6bc1\u5f00\u9500<\/p>\n<\/td>\n \u65e0（\u65e0\u9700\u9891\u7e41\u521b\u5efa\/\u9500\u6bc1）<\/p>\n<\/td>\n \u6781\u5927（\u9700\u5206\u914d\u72ec\u7acb\u865a\u62df\u5730\u5740\u7a7a\u95f4）<\/p>\n<\/td>\n \u8f83\u5927（\u867d\u6bd4\u8fdb\u7a0b\u8f7b\u91cf，\u4f46\u9891\u7e41\u8c03\u7528\u4ee3\u4ef7\u4ecd\u9ad8）<\/p>\n<\/td>\n \u6781\u5c0f（\u521d\u59cb\u5316\u65f6\u4e00\u6b21\u6027\u521b\u5efa，\u8fd0\u884c\u671f\u96f6\u5f00\u9500）<\/p>\n<\/td>\n<\/tr>\n \u4e0a\u4e0b\u6587\u5207\u6362\u5f00\u9500<\/p>\n<\/td>\n \u65e0<\/p>\n<\/td>\n \u6781\u5927（\u6d89\u53ca\u9875\u8868\u5207\u6362\u3001TLB \u5237\u65b0\u7b49）<\/p>\n<\/td>\n \u8f83\u5927（\u6d89\u53ca CPU \u5bc4\u5b58\u5668\u3001\u5185\u6838\u6808\u5207\u6362）<\/p>\n<\/td>\n \u6781\u5c0f\u4e14\u53ef\u63a7（\u7ebf\u7a0b\u6570\u91cf\u56fa\u5b9a，\u907f\u514d\u9891\u7e41\u6362\u5165\u6362\u51fa）<\/p>\n<\/td>\n<\/tr>\n \u901a\u4fe1\u673a\u5236 (IPC\/Sync)<\/p>\n<\/td>\n \u65e0\u9700\u901a\u4fe1<\/p>\n<\/td>\n \u590d\u6742（\u9700\u4f7f\u7528\u7ba1\u9053\u3001\u5171\u4eab\u5185\u5b58\u3001\u4fe1\u53f7\u91cf\u7b49）<\/p>\n<\/td>\n \u7b80\u5355\u4f46\u654f\u611f（\u901a\u8fc7\u5171\u4eab\u5185\u5b58，\u9700\u4e92\u65a5\u9501\/\u6761\u4ef6\u53d8\u91cf\u9632\u7ade\u4e89）<\/p>\n<\/td>\n \u9002\u4e2d（\u5185\u7f6e\u7ebf\u7a0b\u5b89\u5168\u4efb\u52a1\u961f\u5217\u8fdb\u884c\u5e73\u6ed1\u540c\u6b65）<\/p>\n<\/td>\n<\/tr>\n \u5b89\u5168\u7a33\u5b9a\u6027<\/p>\n<\/td>\n \u8f83\u5dee（\u5355\u8fde\u63a5\u5d29\u6e83\u5bfc\u81f4\u670d\u52a1\u762b\u75ea）<\/p>\n<\/td>\n \u6781\u9ad8（\u8fdb\u7a0b\u95f4\u5185\u5b58\u9694\u79bb，\u5355\u4e2a\u5b50\u8fdb\u7a0b\u5d29\u6e83\u4e92\u4e0d\u5f71\u54cd）<\/p>\n<\/td>\n \u8f83\u5dee（\u4e00\u4e2a\u7ebf\u7a0b\u56e0\u6bb5\u9519\u8bef\u5d29\u6e83，\u6574\u4e2a\u8fdb\u7a0b\u4f1a\u968f\u4e4b\u5d29\u584c）<\/p>\n<\/td>\n \u8f83\u597d（\u7ebf\u7a0b\u6570\u56fa\u5b9a，\u53ef\u901a\u8fc7\u6355\u83b7\u5f02\u5e38\u548c\u9650\u5236\u89c4\u6a21\u6765\u63a7\u9669）<\/p>\n<\/td>\n<\/tr>\n \u5b9e\u73b0\u590d\u6742\u5ea6<\/p>\n<\/td>\n \u6781\u7b80<\/p>\n<\/td>\n \u4e2d\u7b49（\u9700\u8981\u59a5\u5584\u5904\u7406\u50f5\u5c38\u8fdb\u7a0b waitpid）<\/p>\n<\/td>\n \u8f83\u6613<\/p>\n<\/td>\n \u8f83\u9ad8（\u9700\u8981\u7cbe\u7ec6\u5904\u7406\u7ebf\u7a0b\u540c\u6b65\u3001\u9501\u7ade\u4e89\u53ca\u4f18\u96c5\u9000\u573a）<\/p>\n<\/td>\n<\/tr>\n \u5178\u578b\u5e94\u7528\u573a\u666f<\/p>\n<\/td>\n \u5c40\u57df\u7f51\u7b80\u5355\u6d4b\u8bd5\u3001\u5355\u5ba2\u6237\u7aef\u8c03\u8bd5<\/p>\n<\/td>\n \u7ecf\u5178\u7684 Unix \u670d\u52a1（\u5982\u65e9\u671f Apache）\u3001\u5bf9\u5b89\u5168\u9694\u79bb\u8981\u6c42\u6781\u9ad8\u7684\u573a\u666f<\/p>\n<\/td>\n \u65e9\u671f\u4e2d\u4f4e\u5e76\u53d1\u670d\u52a1\u5668\u3001\u7b80\u5355\u591a\u4efb\u52a1\u540e\u53f0<\/p>\n<\/td>\n \u73b0\u4ee3\u9ad8\u6027\u80fd\u670d\u52a1\u5668\u9ed8\u8ba4\u6838\u5fc3\u67b6\u6784（\u5982 Nginx\u3001Memcached）<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u6838\u5fc3\u5173\u952e\u7ed3\u8bba：\u7ebf\u7a0b\u6c60\u7248\u672c\u4ec5\u9002\u5408\u77ed\u670d\u52a1 \/ \u77ed\u8fde\u63a5\u573a\u666f\u3002\u5982\u679c\u7528\u7ebf\u7a0b\u6c60\u5904\u7406\u957f\u8fde\u63a5，\u4e00\u4e2a\u8fde\u63a5\u4f1a\u957f\u671f\u5360\u7528\u4e00\u4e2a\u5de5\u4f5c\u7ebf\u7a0b，\u5f53\u7ebf\u7a0b\u6c60\u7ebf\u7a0b\u8017\u5c3d\u540e，\u65b0\u7684\u5ba2\u6237\u7aef\u5c06\u5b8c\u5168\u65e0\u6cd5\u5efa\u7acb\u8fde\u63a5，\u8fd9\u662f\u65b0\u624b\u6700\u5bb9\u6613\u8e29\u7684\u5751\u3002<\/p>\n \u672c\u6587\u6240\u6709\u670d\u52a1\u5668\u5b9e\u73b0，\u5747\u57fa\u4e8e\u81ea\u7814\u7684 Linux\u00a0\u7cfb\u7edf\u7f16\u7a0b\u7ec4\u4ef6\u5c01\u88c5，\u8fd9\u4e9b\u7ec4\u4ef6\u4e0d\u4ec5\u5c4f\u853d\u4e86\u539f\u751f C \u63a5\u53e3\u7684\u7e41\u7410\u7ec6\u8282，\u66f4\u662f\u89e3\u51b3\u4e86\u5e76\u53d1\u5b89\u5168\u3001\u8d44\u6e90\u6cc4\u6f0f\u7b49\u7ecf\u5178\u95ee\u9898\u3002<\/p>\n \u4e92\u65a5\u9501\u662f\u5e76\u53d1\u7f16\u7a0b\u7684\u57fa\u77f3，\u7528\u4e8e\u4fdd\u62a4\u4e34\u754c\u8d44\u6e90\u7684\u539f\u5b50\u8bbf\u95ee；\u800c RAII \u98ce\u683c\u7684\u9501\u5b88\u536b，\u662f C++ \u4e2d\u907f\u514d\u9501\u6cc4\u6f0f\u3001\u6b7b\u9501\u7684\u6700\u4f73\u5b9e\u8df5\u3002<\/p>\n #ifndef MUTEX_HPP #include <iostream> \/\/ \u4e92\u65a5\u9501\u5c01\u88c5\u7c7b：\u63d0\u4f9b\u52a0\u9501\/\u89e3\u9501\u53ca\u83b7\u53d6\u539f\u59cb\u9501\u7684\u63a5\u53e3 \/\/ RAII \u98ce\u683c\u7684\u9501\u5b88\u536b\u7c7b：\u6784\u9020\u65f6\u52a0\u9501，\u6790\u6784\u65f6\u89e3\u9501，\u81ea\u52a8\u7ba1\u7406\u9501\u7684\u751f\u547d\u5468\u671f #endif<\/p>\n \u6e90\u7801\u6838\u5fc3\u89e3\u8bfb：<\/p>\n \u6761\u4ef6\u53d8\u91cf\u7528\u4e8e\u7ebf\u7a0b\u95f4\u7684\u901a\u77e5\u673a\u5236，\u914d\u5408\u4e92\u65a5\u9501\u5b9e\u73b0\u751f\u4ea7\u8005 – \u6d88\u8d39\u8005\u6a21\u578b，\u662f\u7ebf\u7a0b\u6c60\u7684\u6838\u5fc3\u540c\u6b65\u7ec4\u4ef6\u3002<\/p>\n #ifndef COND_HPP #include <iostream> \/** \/** \/\/ \u5524\u9192\u4e00\u4e2a\u5728\u6b64\u6761\u4ef6\u53d8\u91cf\u4e0b\u7b49\u5f85\u7684\u7ebf\u7a0b \/\/ \u5524\u9192\u6240\u6709\u5728\u6b64\u6761\u4ef6\u53d8\u91cf\u4e0b\u7b49\u5f85\u7684\u7ebf\u7a0b \/\/ \u6790\u6784\u51fd\u6570：\u9500\u6bc1\u6761\u4ef6\u53d8\u91cf\u8d44\u6e90 private: #endif<\/p>\n \u6e90\u7801\u6838\u5fc3\u89e3\u8bfb：<\/p>\n \u5bf9\u539f\u751f POSIX \u7ebf\u7a0b\u5e93\u8fdb\u884c C++ \u5c01\u88c5，\u89e3\u51b3\u4e86\u7c7b\u00a0\u6210\u5458\u51fd\u6570\u4f5c\u4e3a\u7ebf\u7a0b\u5165\u53e3\u7684\u53c2\u6570\u5339\u914d\u95ee\u9898，\u540c\u65f6\u63d0\u4f9b\u4e86\u7ebf\u7a0b\u547d\u540d\u3001LWP \u83b7\u53d6\u3001\u72b6\u6001\u7ba1\u7406\u7b49\u5b9e\u7528\u80fd\u529b\u3002<\/p>\n #ifndef __THREAD_HPP #include <iostream> \/\/ \u5b9a\u4e49\u7ebf\u7a0b\u6267\u884c\u7684\u4efb\u52a1\u7c7b\u578b，\u4f7f\u7528\u5305\u88c5\u5668\u589e\u5f3a\u7075\u6d3b\u6027 \/\/ \u7ebf\u7a0b\u72b6\u6001\u679a\u4e3e：\u7528\u4e8e\u6784\u5efa\u7b80\u5355\u7684\u72b6\u6001\u673a，\u786e\u4fdd\u62a4\u6cd5\u64cd\u4f5c \/\/ \u8fd9\u4e2a\u662f\u6709\u70b9bug\u7684：\u5168\u5c40\u9759\u6001\u53d8\u91cf\u5728\u591a\u7ebf\u7a0b\u5e76\u53d1\u521b\u5efa\u5bf9\u8c61\u65f6\u5b58\u5728\u201c\u7ade\u6001\u6761\u4ef6\u201d class Thread \/** \/\/ \u4e3a\u7ebf\u7a0b\u8bbe\u7f6e\u540d\u5b57，\u65b9\u4fbf\u5728\u8c03\u8bd5\u5668（\u5982 gdb）\u4e2d\u8bc6\u522b \/\/ \u6267\u884c\u7528\u6237\u771f\u6b63\u4f20\u5165\u7684\u4efb\u52a1 public: \/\/ \u542f\u52a8\u7ebf\u7a0b：\u6b63\u5f0f\u8c03\u7528\u5e95\u5c42\u63a5\u53e3 \/\/ \u4f20\u5165 this \u4f5c\u4e3a routine \u7684\u53c2\u6570，\u5b9e\u73b0 C \u5230 C++ \u7684\u8de8\u8d8a \/\/ \u505c\u6b62\u7ebf\u7a0b：\u901a\u8fc7\u53d1\u9001\u53d6\u6d88\u8bf7\u6c42 \/\/ \u8d44\u6e90\u56de\u6536：\u963b\u585e\u7b49\u5f85\u7ebf\u7a0b\u7ed3\u675f \/\/ \u7ebf\u7a0b\u5206\u79bb：\u5c06\u7ebf\u7a0b\u8bbe\u7f6e\u4e3a\u7531\u7cfb\u7edf\u81ea\u52a8\u56de\u6536 \/\/ \u83b7\u53d6\u7ebf\u7a0b\u540d\u79f0\u63a5\u53e3 ~Thread() private: #endif<\/p>\n \u6e90\u7801\u6838\u5fc3\u89e3\u8bfb：<\/p>\n \u57fa\u4e8e\u7b56\u7565\u6a21\u5f0f\u5b9e\u73b0\u7684\u591a\u7ebf\u7a0b\u00a0\u5b89\u5168\u65e5\u5fd7\u7cfb\u7edf，\u652f\u6301\u63a7\u5236\u53f0 \/ \u6587\u4ef6\u53cc\u8f93\u51fa\u7b56\u7565，\u901a\u8fc7 RAII \u673a\u5236\u5b9e\u73b0\u65e5\u5fd7\u6d88\u606f\u7684\u81ea\u52a8\u5237\u65b0，\u662f\u670d\u52a1\u5668\u8c03\u8bd5\u4e0e\u95ee\u9898\u5b9a\u4f4d\u7684\u6838\u5fc3\u5de5\u5177\u3002<\/p>\n #ifndef __LOGGER_HPP #include <iostream> namespace LogModule char data_time_str[128]; enum LogLevel \/\/ 2.\u65e5\u5fd7\u7b49\u7ea7 \/\/ 3.\u65e5\u5fd7\u5237\u65b0 \/\/ \u5b50\u7c7b：\u7ee7\u627f\u7eaf\u865a\u63a5\u53e3\u7c7b static const std::string glogdir = ".\/log\/"; \/\/ \u65b9\u6cd51： \/\/ \u65b9\u6cd52： \/\/ \u65b9\u6cd53： out.close(); \/\/ \u771f\u6b63\u8981\u7684\u65e5\u5fd7\u7c7b \/\/ \u5185\u90e8\u7c7b：\u4e00\u6761\u65e5\u5fd7 template<typename T> ~LogMessage() \/\/ RAII\u98ce\u683c\u7684\u65e5\u5fd7\u5237\u65b0 \/\/ LogMessage \u5bf9\u8c61\u6253\u5370\u65e5\u5fd7\u7684\u65f6\u5019，\u6545\u610f\u8fd4\u56de\u4e00\u4e2a\u4e34\u65f6\u7684 LogMessage\u5bf9\u8c61 Logger logger; \/\/ \u52a8\u6001\u8c03\u6574\u65e5\u5fd7\u7b56\u7565 #endif <\/p>\n \u6838\u5fc3\u8bbe\u8ba1\u4eae\u70b9：<\/p>\n \u5bf9sockaddr_in<\/span><\/span>\u7ed3\u6784\u4f53\u4e0e\u5b57\u8282\u5e8f\u8f6c\u6362\u8fdb\u884c\u5c01\u88c5，\u5c4f\u853d\u4e86\u7f51\u7edc\u5b57\u8282\u5e8f\u4e0e\u4e3b\u673a\u5b57\u8282\u5e8f\u7684\u8f6c\u6362\u7ec6\u8282，\u5927\u5e45\u7b80\u5316 TCP \u670d\u52a1\u5668\u4e2dbind<\/span><\/span>\u3001connect<\/span><\/span>\u3001accept<\/span><\/span>\u7684\u5730\u5740\u64cd\u4f5c\u3002<\/p>\n #pragma once<\/p>\n \/\/ \u7f51\u7edc\u548c\u672c\u5730socket\u8f6c\u6362\u7684\u7c7b<\/p>\n #include <iostream> #define CONV(addr) ((struct sockaddr*)(addr))<\/p>\n class InetAddr InetAddr(uint16_t port, std::string ip = "0.0.0.0") } \u6838\u5fc3\u80fd\u529b：<\/p>\n \u6211\u4eec\u8981\u5b9e\u73b0\u4e00\u4e2a\u7c7b SSH \u7684\u8fdc\u7a0b\u547d\u4ee4\u6267\u884c\u670d\u52a1\u5668，\u6838\u5fc3\u80fd\u529b\u5982\u4e0b：<\/p>\n \u6574\u4f53\u67b6\u6784\u8bbe\u8ba1：\u91c7\u7528\u5206\u5c42\u8bbe\u8ba1\u601d\u60f3，\u5c06\u7f51\u7edc\u901a\u4fe1\u4e0e\u4e1a\u52a1\u5904\u7406\u5b8c\u5168\u89e3\u8026<\/p>\n \u547d\u4ee4\u6267\u884c\u6a21\u5757\u662f\u4e1a\u52a1\u7684\u6838\u5fc3，\u8d1f\u8d23\u547d\u4ee4\u7684\u5b89\u5168\u6821\u9a8c\u4e0e\u6267\u884c，\u6838\u5fc3\u89e3\u51b3\u4e24\u4e2a\u95ee\u9898：\u5982\u4f55\u5728 C++ \u4e2d\u6267\u884c Linux \u547d\u4ee4\u5e76\u83b7\u53d6\u8f93\u51fa\u3001\u5982\u4f55\u907f\u514d\u6076\u610f\u547d\u4ee4\u6267\u884c\u7684\u5b89\u5168\u98ce\u9669\u3002<\/p>\n #ifndef __EXCUTECOMMAND__HPP #include <cstddef> using namespace std; \/\/ \u547d\u4ee4\u6267\u884c\u5668\u7c7b：\u4e13\u95e8\u8d1f\u8d23\u89e3\u6790\u5e76\u6267\u884c\u6765\u81ea\u7f51\u7edc\u7684\u7cfb\u7edf\u547d\u4ee4，\u5e76\u5c06\u8f93\u51fa\u7ed3\u679c\u4f5c\u4e3a\u5b57\u7b26\u4e32\u8fd4\u56de return false; \/\/ \u5982\u679c\u904d\u5386\u5b8c\u767d\u540d\u5355\u90fd\u6ca1\u627e\u5230，\u9ed8\u8ba4\u89c6\u4f5c\u4e0d\u5b89\u5168\u547d\u4ee4，\u76f4\u63a5\u62d2\u7edd public: \/\/ \u6267\u884c\u5916\u90e8\u547d\u4ee4\u7684\u4e3b\u51fd\u6570 \/\/ 2. \u6838\u5fc3\u7cfb\u7edf\u8c03\u7528：popen std::string result; \/\/ 3. \u5faa\u73af\u8bfb\u53d6\u6267\u884c\u7ed3\u679c \/\/ 4. \u6536\u5c3e\u5de5\u4f5c：\u6781\u5176\u91cd\u8981 return result; \/\/ \u5c06\u5b8c\u6574\u7684\u6267\u884c\u7ed3\u679c\u8fd4\u56de\u7ed9\u8c03\u7528\u8005（\u7f51\u7edc\u5c42） ~ExcuteCommand() private: \u6e90\u7801\u6838\u5fc3\u89e3\u8bfb：<\/p>\n \u7ed3\u679c\u8bfb\u53d6\u903b\u8f91：\u901a\u8fc7fgets<\/span><\/span>\u5faa\u73af\u8bfb\u53d6\u7ba1\u9053\u4e2d\u7684\u8f93\u51fa，\u62fc\u63a5\u6210\u5b8c\u6574\u7684\u7ed3\u679c\u5b57\u7b26\u4e32\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aef，\u7f13\u51b2\u533a\u9010\u884c\u6e05\u7a7a，\u907f\u514d\u6570\u636e\u6b8b\u7559\u3002<\/p>\n \u591a\u7ebf\u7a0b TCP \u670d\u52a1\u5668\u8d1f\u8d23\u7f51\u7edc\u901a\u4fe1，\u901a\u8fc7\u56de\u8c03\u51fd\u6570\u6ce8\u5165\u4e1a\u52a1\u5904\u7406\u903b\u8f91，\u5b8c\u5168\u4e0d\u5173\u5fc3\u5177\u4f53\u4e1a\u52a1，\u5177\u5907\u6781\u9ad8\u7684\u590d\u7528\u6027\u3002<\/p>\n \/\/ \u4e1a\u52a1\u56de\u8c03\u51fd\u6570\u7c7b\u578b：\u8f93\u5165\u547d\u4ee4\u5b57\u7b26\u4e32，\u8fd4\u56de\u6267\u884c\u7ed3\u679c class TcpServer \u6838\u5fc3\u8bbe\u8ba1\u89e3\u8bfb：<\/p>\n #ifndef __TCP__SERVER__HPP #include <csignal> #include <sys\/socket.h> \/\/ \u5b9a\u4e49\u56de\u8c03\u51fd\u6570\u7c7b\u578b：\u63a5\u6536\u4e00\u4e2a string（\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u8bf7\u6c42），\u8fd4\u56de\u4e00\u4e2a string（\u5904\u7406\u540e\u7684\u7ed3\u679c）\u3002 static const uint16_t gdefaultport = 8080; class TcpServer \/\/ 1. \u8bfb\u53d6 \/\/ \u52a0\u5de5\u5904\u7406\u6570\u636e \/\/ 2. \u5199\u56de\u6570\u636e \/\/ \u6781\u5176\u91cd\u8981：\u8df3\u51fa\u5faa\u73af\u8bf4\u660e\u670d\u52a1\u7ed3\u675f，\u5fc5\u987b\u5173\u95ed IO \u5957\u63a5\u5b57，\u5426\u5219\u4f1a\u9020\u6210\u7cfb\u7edf\u6587\u4ef6\u63cf\u8ff0\u7b26\u6cc4\u6f0f \/\/ 2.bind int n = bind(_listensockfd, (struct sockaddr*)&local, len); \/\/ 3. \u8bbe\u7f6e\u6210\u76d1\u542c \/\/ version1 — \u591a\u8fdb\u7a0b\u7248\u672c #include "InetAddr.hpp" \/\/ \u6253\u5370\u4f7f\u7528\u8bf4\u660e\u624b\u518c\u3002 \/\/ \u5ba2\u6237\u7aef\u542f\u52a8\u793a\u4f8b: .\/TcpClient 127.0.0.1 8080 \/\/ \u89e3\u6790\u547d\u4ee4\u884c\u53c2\u6570\u63d0\u53d6\u76ee\u6807\u670d\u52a1\u5668\u4fe1\u606f \/\/ 1. \u521b\u5efasocket\u5957\u63a5\u5b57 \/\/ 2. \u5efa\u7acb\u8fde\u63a5 \/\/ \u6838\u5fc3\u8003\u70b9：\u5ba2\u6237\u7aef\u4e0d\u9700\u8981\u624b\u52a8 bind \u7ed1\u5b9a\u672c\u673a\u7aef\u53e3！ \/\/ 3. sockfd\u901a\u4fe1\u8fc7\u7a0b \/\/ \u5199 \/\/ \u8bfb \/\/ \u9000\u51fa\u5faa\u73af\u540e，\u5173\u95ed\u5c5e\u4e8e\u5ba2\u6237\u7aef\u7684\u5957\u63a5\u5b57 #include "TcpServer.hpp" \/\/ \u6253\u5370\u7a0b\u5e8f\u7684\u4f7f\u7528\u8bf4\u660e\u624b\u518c \/\/ \u6807\u51c6\u542f\u52a8\u65b9\u5f0f: .\/tcp_echo_server 8080 \/\/ \u521d\u59cb\u5316\u65e5\u5fd7\u7cfb\u7edf，\u5c06\u540e\u7eed\u4ea7\u751f\u7684\u65e5\u5fd7\u4fe1\u606f\u8f93\u51fa\u5230\u63a7\u5236\u53f0 \/\/ \u89e3\u6790\u547d\u4ee4\u884c\u53c2\u6570，\u5c06\u5b57\u7b26\u4e32\u683c\u5f0f\u7684\u7aef\u53e3\u53f7 (argv[1]) \u8f6c\u6362\u4e3a 16\u4f4d\u65e0\u7b26\u53f7\u6574\u6570 \/\/ ============================================================================== \/\/ 1. \u521b\u5efa\u4e00\u4e2a\u547d\u4ee4\u884c\u5904\u7406\u7684\u6a21\u5757 (\u4ee3\u8868\u3010\u4e1a\u52a1\u5c42 \/ \u5e94\u7528\u5c42\u3011) \/\/ 2. \u521b\u5efa\u4e00\u4e2a\u7f51\u7edc\u670d\u52a1\u6a21\u5757 (\u4ee3\u8868\u3010\u7f51\u7edc\u901a\u4fe1\u5c42\u3011) \/\/ 3. \u5c06\u4e1a\u52a1\u6a21\u5757\u201c\u6ce8\u5165\u201d\u5230\u7f51\u7edc\u6a21\u5757\u4e2d (\u89e3\u8026\u7684\u7075\u9b42\u6240\u5728) \/\/ 4. \u542f\u52a8\u7f51\u7edc\u670d\u52a1\u5668，\u8fdb\u5165 accept \u963b\u585e\u5faa\u73af，\u6b63\u5f0f\u5f00\u59cb\u63d0\u4f9b\u670d\u52a1 return 0; \/\/ \u7a0b\u5e8f\u6b63\u5e38\u9000\u51fa（\u5b9e\u9645\u4e0a\u56e0\u4e3a Start \u662f\u6b7b\u5faa\u73af，\u4e00\u822c\u4e0d\u4f1a\u6267\u884c\u5230\u8fd9\u91cc） \u591a\u7ebf\u7a0b\u7248\u672c\u867d\u7136\u89e3\u51b3\u4e86\u5e76\u53d1\u95ee\u9898，\u4f46\u5728\u77ed\u8fde\u63a5\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b，\u9891\u7e41\u521b\u5efa\u9500\u6bc1\u7ebf\u7a0b\u4f1a\u5e26\u6765\u5927\u91cf\u7684\u7cfb\u7edf\u5f00\u9500，\u540c\u65f6\u65e0\u9650\u5236\u521b\u5efa\u7ebf\u7a0b\u4f1a\u5bfc\u81f4\u7cfb\u7edf\u8c03\u5ea6\u538b\u529b\u5267\u589e\u3002\u800c\u7ebf\u7a0b\u6c60\u6a21\u578b\u6b63\u662f\u89e3\u51b3\u8fd9\u4e2a\u95ee\u9898\u7684\u6700\u4f18\u65b9\u6848\u3002<\/p>\n \u7ebf\u7a0b\u6c60\u672c\u8d28\u4e0a\u662f\u751f\u4ea7\u8005 – \u6d88\u8d39\u8005\u6a21\u578b\u7684\u7ecf\u5178\u5e94\u7528，\u6838\u5fc3\u8bbe\u8ba1\u5982\u4e0b：<\/p>\n \u6211\u4eec\u5b9e\u73b0\u7684\u7ebf\u7a0b\u6c60\u662f\u6a21\u677f\u7c7b，\u652f\u6301\u4efb\u610f\u7c7b\u578b\u7684\u4efb\u52a1，\u5177\u5907\u6781\u9ad8\u7684\u901a\u7528\u6027，\u540c\u65f6\u96c6\u6210\u4e86\u4e4b\u524d\u5c01\u88c5\u7684\u4e92\u65a5\u9501\u3001\u6761\u4ef6\u53d8\u91cf\u3001\u7ebf\u7a0b\u7c7b，\u662f\u5de5\u4e1a\u7ea7\u7684\u5b9e\u73b0\u65b9\u6848\u3002<\/p>\n #ifndef THREADPOOL_HPP \/\/ \u53ef\u4ee5\u770b\u5230\u6211\u4eec\u76f4\u63a5\u4f7f\u7528\u4e86\u5f88\u591a\u4e4b\u524d\u81ea\u5df1\u9020\u7684\u8f6e\u5b50 const static int gDefaultCnt = 5;<\/p>\n \/** \/\/ \u5185\u90e8\u903b\u8f91：\u539f\u5b50\u5316\u63d0\u53d6\u4efb\u52a1（\u8c03\u7528\u524d\u9700\u6301\u6709\u9501） \/** \/\/ 1. \u4efb\u52a1\u961f\u5217\u4e3a\u7a7a && \u7ebf\u7a0b\u5904\u4e8e\u8fd0\u884c\u72b6\u6001(\u4e0d\u9000\u51fa) — \u5141\u8bb8\u4f11\u7720 \/\/ 2. \u4efb\u52a1\u961f\u5217\u4e3a\u7a7a && \u7ebf\u7a0b\u4e0d\u5904\u4e8e\u8fd0\u884c\u72b6\u6001(\u8981\u9000\u51fa) — \u5141\u8bb8\u9000\u51fa \/\/ 3. \u4efb\u52a1\u961f\u5217\u4e0d\u4e3a\u7a7a，\u65e0\u8bba\u8fd0\u884c\u72b6\u6001\u5982\u4f55，\u90fd\u8981\u63d0\u53d6\u4efb\u52a1\u5904\u7406 \/\/ \u5355\u4f8b\u6a21\u5f0f\u9632\u5fa1：\u79c1\u6709\u5316\u6784\u9020\u51fd\u6570，\u675c\u7edd\u5916\u90e8\u968f\u610f\u521b\u5efa\u5bf9\u8c61 \/\/ \u5c06\u62f7\u8d1d\u548c\u8d4b\u503c\u8bed\u53e5\u53bb\u6389 public: \/\/ \u7b2c\u4e8c\u5c42\u5224\u65ad：\u4e3a\u4e86\u4fdd\u8bc1\u552f\u4e00\u6027\u3002\u5728\u83b7\u5f97\u9501\u540e\u518d\u6b21\u68c0\u67e5， } \/\/ \u542f\u52a8\u7ebf\u7a0b\u670d\u52a1 \/\/ \u751f\u4ea7\u8005\u4e0b\u53d1\u4efb\u52a1 \/\/ \u5524\u9192\u4e00\u4e2a\u6765\u7ebf\u7a0b\u6765\u6267\u884c\u4efb\u52a1 \/\/ \u4f18\u96c5\u505c\u6b62\u7ebf\u7a0b\u6c60 \/\/ \u5524\u9192\u6240\u6709\u7684\u53bb\u6267\u884c, \u4fdd\u8bc1\u6240\u6709\u7ebf\u7a0b\u90fd\u80fd\u610f\u8bc6\u5230\u72b6\u6001\u6539\u53d8\u5e76\u6b63\u786e break \/\/ \u963b\u585e\u5f0f\u8d44\u6e90\u56de\u6536 ~ThreadPool() private: std::queue<T> _queue; \/\/ \u5171\u4eab\u4efb\u52a1\u961f\u5217 \/\/ \u5355\u4f8b\u6a21\u5f0f\u9759\u6001\u6210\u5458 \/\/ \u9759\u6001\u6210\u5458\u53d8\u91cf\u5728\u7c7b\u5916\u521d\u59cb\u5316： template <typename T> #endif<\/p>\n Echo \u670d\u52a1\u5668\u662f\u7f51\u7edc\u7f16\u7a0b\u7684\u7ecf\u5178\u6848\u4f8b，\u5ba2\u6237\u7aef\u53d1\u9001\u4ec0\u4e48\u5185\u5bb9，\u670d\u52a1\u7aef\u5c31\u539f\u6837\u8fd4\u56de，\u975e\u5e38\u9002\u5408\u9a8c\u8bc1\u7ebf\u7a0b\u6c60\u7684\u9ad8\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002\u6ce8\u610f：\u8fd9\u91cc\u6211\u4eec\u91c7\u7528\u77ed\u8fde\u63a5\u8bbe\u8ba1，\u9002\u914d\u7ebf\u7a0b\u6c60\u7684\u9002\u7528\u573a\u666f\u3002<\/p>\n #ifndef __TCP__ECHOSERVER__HPP #include <csignal> #include <sys\/socket.h> static const uint16_t gdefaultport = 8080; \/\/ \u5b9a\u4e49\u4e00\u4e2a\u4efb\u52a1 class TcpEchoServer \/\/ \u957f\u8fde\u63a5\u670d\u52a1 \/\/ \u77ed\u8fde\u63a5\u670d\u52a1：\u5904\u7406\u5b8c\u4e00\u6b21\u8bfb\u5199\u8bf7\u6c42\u540e，\u7acb\u523b\u7ed3\u675f\u51fd\u6570，\u91ca\u653e\u5f53\u524d\u7ebf\u7a0b\u5f52\u8fd8\u7ed9\u7ebf\u7a0b\u6c60\u3002 \/\/ 1. \u8bfb\u53d6 \/\/ \u52a0\u5de5\u5904\u7406\u6570\u636e \/\/ 2. \u5199\u56de\u6570\u636e \/\/ \u6781\u5176\u91cd\u8981：\u4f5c\u4e3a\u77ed\u670d\u52a1，\u5904\u7406\u5b8c\u4e00\u6b21\u4e1a\u52a1\u540e\u5fc5\u987b\u4e3b\u52a8\u5173\u95ed\u5957\u63a5\u5b57 (\u56db\u6b21\u6325\u624b) \/\/ 2.bind int n = bind(_listensockfd, (struct sockaddr*)&local, len); \/\/ 3. \u8bbe\u7f6e\u6210\u76d1\u542c \/\/ \u4e3b\u7ebf\u7a0b (Main Thread) \u7684\u804c\u8d23\u53d1\u751f\u4e86\u8f6c\u53d8： \/\/ \u5904\u7406\u8fde\u63a5, \u8fdb\u884cIO\u901a\u4fe1 \u6838\u5fc3\u89e3\u8bfb：<\/p>\n TCP \u670d\u52a1\u5668\u4e2d，listen \u51fd\u6570\u7684\u7b2c\u4e8c\u4e2a\u53c2\u6570 backlog \u7684\u542b\u4e49\u662f\u4ec0\u4e48？<\/p>\n \u7ebf\u7a0b\u6c60\u957f\u8fde\u63a5\u5360\u7528\u5751<\/p>\n \u9ad8\u5e76\u53d1 TCP \u670d\u52a1\u5668\u5f00\u53d1，\u662f\u8fde\u63a5\u5e95\u5c42\u64cd\u4f5c\u7cfb\u7edf\u5185\u6838\u548c\u4e0a\u5c42\u5206\u5e03\u5f0f\u4e1a\u52a1\u67b6\u6784\u7684\u4e00\u9053\u6865\u6881\u3002\u4ece\u5355\u7ebf\u7a0b\u7684\u7b80\u964b，\u5230\u591a\u7ebf\u7a0b\u7684\u65e0\u5e8f，\u518d\u5230\u7ebf\u7a0b\u6c60\u6a21\u578b\u7684\u6210\u719f，\u6211\u4eec\u5728\u89e3\u51b3\u95ee\u9898\u7684\u540c\u65f6，\u4e5f\u66f4\u6df1\u523b\u5730\u7406\u89e3\u4e86\u7cfb\u7edf\u5bf9\u8d44\u6e90\u7684\u7ba1\u63a7\u3002<\/p>\n \u5982\u679c\u4f60\u60f3\u5199\u51fa\u66f4\u9ad8\u7ea7\u7684\u3001\u767e\u4e07\u5e76\u53d1\u7ea7\u522b\u7684\u670d\u52a1\u5668，\u4e0d\u59a8\u5728\u6b64\u57fa\u7840\u4e0a，\u7ee7\u7eed\u6df1\u5165\u63a2\u7d22 epoll<\/span><\/span> + \u975e\u963b\u585e I\/O（Reactor \u6a21\u5f0f）\u4ee5\u53ca\u8fb9\u7f18\u89e6\u53d1（Edge Triggered）\u7684\u5965\u79d8\u3002<\/p>\n","protected":false},"excerpt":{"rendered":" 🔥\u4e2a\u4eba\u4e3b\u9875：Cx330🌸
\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205847-6a652387801ba.gif\")
<\/p>\n
\n
\n\u524d\u8a00<\/h3>\n
\n\u4e00.\u00a0TCP\u00a0\u670d\u52a1\u5668\u6838\u5fc3\u6a21\u578b\u6f14\u8fdb<\/h3>\n
\n\n
\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n
\n\u4e8c. \u81ea\u7814\u57fa\u7840\u7ec4\u4ef6\u6df1\u5ea6\u89e3\u6790<\/h3>\n
2.1 \u4e92\u65a5\u9501\u4e0e RAII \u9501\u5b88\u536b（Mutex.hpp）<\/h4>\n
\n#define MUTEX_HPP<\/p>\n
\n#include <pthread.h><\/p>\n
\nclass Mutex
\n{
\npublic:
\n \/\/ \u6784\u9020\u51fd\u6570：\u521d\u59cb\u5316\u4e92\u65a5\u9501
\n Mutex()
\n {
\n pthread_mutex_init(&_lock, nullptr);
\n }
\n \/\/ \u6790\u6784\u51fd\u6570：\u9500\u6bc1\u4e92\u65a5\u9501
\n ~Mutex()
\n {
\n pthread_mutex_destroy(&_lock);
\n }
\n \/\/ \u52a0\u9501\u64cd\u4f5c
\n void Lock()
\n {
\n pthread_mutex_lock(&_lock);
\n }
\n \/\/ \u89e3\u9501\u64cd\u4f5c
\n void UnLock()
\n {
\n pthread_mutex_unlock(&_lock);
\n }
\n \/\/ \u83b7\u53d6\u539f\u59cb\u4e92\u65a5\u9501\u6307\u9488，\u7528\u4e8e\u9700\u8981\u539f\u751f pthread_mutex_t \u7684\u63a5\u53e3
\n pthread_mutex_t* Origin()
\n {
\n return &_lock;
\n }
\nprivate:
\n pthread_mutex_t _lock; \/\/ POSIX \u4e92\u65a5\u9501
\n};<\/p>\n
\nclass LockGuard
\n{
\npublic:
\n \/\/ \u6784\u9020\u51fd\u6570：\u63a5\u6536\u4e00\u4e2a Mutex \u6307\u9488，\u5e76\u7acb\u5373\u52a0\u9501
\n LockGuard(Mutex* lockptr) : _lockptr(lockptr)
\n {
\n _lockptr->Lock();
\n }
\n \/\/ \u6790\u6784\u51fd\u6570：\u81ea\u52a8\u89e3\u9501
\n ~LockGuard()
\n {
\n _lockptr->UnLock();
\n }
\nprivate:
\n Mutex* _lockptr; \/\/ \u6307\u5411\u88ab\u7ba1\u7406\u7684\u4e92\u65a5\u9501
\n};<\/p>\n\n
2.2 \u6761\u4ef6\u53d8\u91cf\u5c01\u88c5（Cond.hpp）<\/h4>\n
\n#define COND_HPP<\/p>\n
\n#include <pthread.h>
\n#include "Mutex.hpp"<\/p>\n
\n * @brief \u6761\u4ef6\u53d8\u91cf\u5c01\u88c5\u7c7b
\n * \u6838\u5fc3\u903b\u8f91：\u63d0\u4f9b\u7ebf\u7a0b\u95f4\u7684\u901a\u77e5\u673a\u5236\u3002
\n * \u5b83\u5141\u8bb8\u7ebf\u7a0b\u5728\u67d0\u4e9b\u6761\u4ef6\u4e0d\u6ee1\u8db3\u65f6\u6302\u8d77，\u5e76\u5728\u5176\u4ed6\u7ebf\u7a0b\u6539\u53d8\u6761\u4ef6\u5e76\u53d1\u9001\u4fe1\u53f7\u65f6\u88ab\u5524\u9192\u3002
\n *\/
\nclass Cond
\n{
\npublic:
\n \/\/ \u6784\u9020\u51fd\u6570：\u521d\u59cb\u5316\u6761\u4ef6\u53d8\u91cf
\n Cond()
\n {
\n \/\/ nullptr \u8868\u793a\u4f7f\u7528\u64cd\u4f5c\u7cfb\u7edf\u9ed8\u8ba4\u7684\u6761\u4ef6\u53d8\u91cf\u5c5e\u6027
\n pthread_cond_init(&cond, nullptr);
\n }<\/p>\n
\n * @brief \u7b49\u5f85\u6761\u4ef6\u6ee1\u8db3
\n * @param mutex \u5fc5\u987b\u662f\u5f53\u524d\u7ebf\u7a0b\u5df2\u7ecf\u6301\u6709\u7684\u4e92\u65a5\u9501
\n * * \u5e95\u5c42\u903b\u8f91\u201c\u4e09\u6b65\u8df3\u201d：
\n * 1. \u81ea\u52a8\u91ca\u653e\u4f20\u5165\u7684 mutex \u9501（\u8fd9\u6837\u5176\u4ed6\u7ebf\u7a0b\u624d\u80fd\u4fee\u6539\u4e34\u754c\u8d44\u6e90）\u3002
\n * 2. \u5c06\u5f53\u524d\u7ebf\u7a0b\u6302\u8d77\u5e76\u52a0\u5165\u5230\u8be5\u6761\u4ef6\u53d8\u91cf\u7684\u7b49\u5f85\u961f\u5217\u4e2d\u3002
\n * 3. \u5f53\u88ab\u5524\u9192\u8fd4\u56de\u65f6，\u4f1a\u81ea\u52a8\u5c1d\u8bd5\u91cd\u65b0\u7ade\u4e89\u5e76\u6301\u6709\u8be5 mutex \u9501\u3002
\n *\/
\n void Wait(Mutex &mutex)
\n {
\n \/\/ \u8c03\u7528\u5c01\u88c5\u597d\u7684 Mutex \u7c7b\u7684 Origin() \u63a5\u53e3，\u914d\u5408\u5e95\u5c42 C \u63a5\u53e3\u4f7f\u7528
\n pthread_cond_wait(&cond, mutex.Origin());
\n }<\/p>\n
\n void NotifyOne()
\n {
\n \/\/ \u5524\u9192\u961f\u5217\u4e2d\u7684\u7b2c\u4e00\u4e2a\u7ebf\u7a0b（\u5982\u679c\u5b58\u5728）
\n pthread_cond_signal(&cond);
\n }<\/p>\n
\n void NotifyAll()
\n {
\n \/\/ \u5e7f\u64ad\u901a\u77e5，\u5e38\u7528\u4e8e\u591a\u4e2a\u6d88\u8d39\u8005\u6216\u590d\u6742\u7684\u8d44\u6e90\u53d8\u52a8\u573a\u666f
\n pthread_cond_broadcast(&cond);
\n }<\/p>\n
\n ~Cond()
\n {
\n \/**
\n * \u6ce8\u610f\u4e8b\u9879：
\n * \u9500\u6bc1\u4e00\u4e2a\u4ecd\u6709\u7ebf\u7a0b\u5728\u7b49\u5f85\u7684\u6761\u4ef6\u53d8\u91cf\u662f\u5371\u9669\u884c\u4e3a\u3002
\n * \u5728\u7ebf\u7a0b\u6c60\u9500\u6bc1\u524d，\u901a\u5e38\u9700\u8981\u5148\u8c03\u7528 NotifyAll \u5e76\u56de\u6536\u6240\u6709\u7ebf\u7a0b\u3002
\n *\/
\n pthread_cond_destroy(&cond);
\n }<\/p>\n
\n pthread_cond_t cond; \/\/ POSIX \u7ebf\u7a0b\u5e93\u63d0\u4f9b\u7684\u5e95\u5c42\u6761\u4ef6\u53d8\u91cf\u7ed3\u6784
\n};<\/p>\n\n
\n
\n
2.3 \u7ebf\u7a0b\u5c01\u88c5（Thread.hpp）<\/h4>\n
\n#define __THREAD_HPP<\/p>\n
\n#include <string>
\n#include <functional>
\n#include <pthread.h>
\n#include <unistd.h>
\n#include <sys\/types.h>
\n#include <sys\/syscall.h><\/p>\n
\nusing func_t = std::function<void()>;<\/p>\n
\nenum class TSTAYUS
\n{
\n THREAD_NEW, \/\/ \u65b0\u5efa\u72b6\u6001
\n THREAD_RUNNING, \/\/ \u8fd0\u884c\u72b6\u6001
\n THREAD_STOPPED, \/\/ \u505c\u6b62\/\u9000\u51fa\u72b6\u6001
\n};<\/p>\n
\n\/\/ \u591a\u4e2a\u7ebf\u7a0b\u53ef\u80fd\u540c\u65f6\u6267\u884c gunm++，\u5bfc\u81f4\u7ebf\u7a0b\u7f16\u53f7\u91cd\u590d，\u751f\u4ea7\u73af\u5883\u4e0b\u5efa\u8bae\u4f7f\u7528 std::atomic<int>
\nstatic int gunm = 1;<\/p>\n
\n{
\nprivate:
\n \/\/ \u83b7\u53d6\u6240\u5c5e\u8fdb\u7a0b\u7684 PID
\n void get_pid()
\n {
\n _pid = getpid();
\n }
\n \/\/ \u83b7\u53d6\u5185\u6838\u7ea7\u7ebf\u7a0b ID (LWP ID)，\u8fd9\u624d\u662f Linux \u7cfb\u7edf\u76d1\u63a7（\u5982 top -H）\u770b\u5230\u7684\u771f\u6b63 ID
\n void get_lwid()
\n {
\n \/\/ \u539f\u751f pthread \u5e93\u6ca1\u6709\u76f4\u63a5\u83b7\u53d6 LWP \u7684\u63a5\u53e3，\u5fc5\u987b\u901a\u8fc7\u7cfb\u7edf\u8c03\u7528
\n _lwid = syscall(SYS_gettid);
\n }<\/p>\n
\n * @brief \u9759\u6001\u6210\u5458\u51fd\u6570\u4f5c\u4e3a\u7ebf\u7a0b\u5165\u53e3\u70b9
\n * \u5173\u952e\u903b\u8f91：pthread_create \u8981\u6c42\u56de\u8c03\u51fd\u6570\u5fc5\u987b\u662f void* (*)(void*)
\n * \u7c7b\u7684\u666e\u901a\u6210\u5458\u51fd\u6570\u9690\u542b this \u6307\u9488，\u53c2\u6570\u4e0d\u5339\u914d，\u6545\u5fc5\u987b\u8bbe\u4e3a static\u3002
\n * \u901a\u8fc7\u4f20\u5165 args (this \u6307\u9488) \u91cd\u65b0\u627e\u56de\u5bf9\u8c61\u4e0a\u4e0b\u6587\u3002
\n *\/
\n static void* routine(void* args)
\n {
\n Thread* ts = static_cast<Thread*>(args);
\n ts->get_pid();
\n ts->get_lwid();<\/p>\n
\n pthread_setname_np(pthread_self(), ts->Name().c_str());<\/p>\n
\n ts->_func();
\n return nullptr;
\n }<\/p>\n
\n \/\/ \u6784\u9020\u51fd\u6570：\u5b8c\u6210\u4efb\u52a1\u7ed1\u5b9a\u4e0e\u547d\u540d，\u6b64\u65f6\u7ebf\u7a0b\u5c1a\u672a\u5728\u5185\u6838\u4e2d\u521b\u5efa
\n Thread(func_t f) : _func(f), _joinable(true), _status(TSTAYUS::THREAD_NEW)
\n {
\n _name = "Worker-" + std::to_string(gunm++);
\n }<\/p>\n
\n void start()
\n {
\n if(_status == TSTAYUS::THREAD_RUNNING)
\n {
\n std::cerr << "thread is already running" << std::endl;
\n return;
\n }<\/p>\n
\n int n = pthread_create(&_tid, nullptr, routine, this);
\n if(n != 0)
\n {
\n std::cerr << "pthread_create failed" << std::endl;
\n }
\n _status = TSTAYUS::THREAD_RUNNING;
\n }<\/p>\n
\n void stop()
\n {
\n if(_status == TSTAYUS::THREAD_RUNNING)
\n {
\n \/\/ pthread_cancel \u662f\u6bd4\u8f83\u66b4\u529b\u7684\u9000\u51fa\u65b9\u5f0f，\u4f9d\u8d56\u7ebf\u7a0b\u5185\u90e8\u662f\u5426\u5b58\u5728\u53d6\u6d88\u70b9
\n int n = pthread_cancel(_tid);
\n if(n != 0)
\n {
\n std::cerr << "pthread_cancel failed" << std::endl;
\n }
\n _status = TSTAYUS::THREAD_STOPPED;
\n }
\n else
\n {
\n std::cerr << "thread status is : THREAD_STOPPED or THREAD_NEW" << std::endl;
\n return;
\n }
\n }<\/p>\n
\n void join()
\n {
\n if(_joinable)
\n {
\n \/\/ \u53ea\u6709\u5904\u4e8e joinable \u72b6\u6001\u7684\u7ebf\u7a0b\u624d\u9700\u8981\u88ab join，\u5426\u5219\u4f1a\u4ea7\u751f\u8d44\u6e90\u6cc4\u9732
\n int n = pthread_join(_tid, nullptr);
\n if(n != 0)
\n {
\n std::cerr << "pthread_join failed" << std::endl;
\n }
\n printf("lwp: %d, name: %s, join success\\\\n", _lwid, _name.c_str());
\n }
\n else {
\n printf("lwp: %d, name: %s, join failed, because thread is detached\\\\n", _lwid, _name.c_str());
\n }
\n }<\/p>\n
\n void detach()
\n {
\n if(_joinable && _status == TSTAYUS::THREAD_RUNNING)
\n {
\n _joinable = false;
\n \/\/ \u5206\u79bb\u540e，\u8be5\u7ebf\u7a0b\u9000\u51fa\u65f6\u4f1a\u81ea\u52a8\u91ca\u653e\u6240\u6709\u8d44\u6e90，\u65e0\u9700 join
\n int n = pthread_detach(_tid);
\n if(n != 0)
\n {
\n std::cerr << "pthread_detach failed" << std::endl;
\n }
\n }
\n }<\/p>\n
\n std::string Name()
\n {
\n return _name;
\n }<\/p>\n
\n {
\n \/\/ \u6790\u6784\u51fd\u6570\u4e2d\u672a\u505a\u5f3a\u5236 join，\u8fd9\u662f\u4e3a\u4e86\u7ed9\u4f7f\u7528\u8005\u7559\u51fa\u63a7\u5236\u6743
\n \/\/ \u4f46\u8981\u6ce8\u610f，\u5982\u679c\u5bf9\u8c61\u9500\u6bc1\u65f6\u7ebf\u7a0b\u8fd8\u5728\u8dd1\u4e14\u672a detach，\u53ef\u80fd\u4f1a\u5bfc\u81f4\u7a0b\u5e8f\u5d29\u6e83
\n }<\/p>\n
\n pthread_t _tid; \/\/ \u7ebf\u7a0b\u5e93\u5c42\u9762\u7684 ID (\u7528\u6237\u5c42 ID)
\n pid_t _pid; \/\/ \u6240\u5c5e\u8fdb\u7a0b ID
\n pid_t _lwid; \/\/ \u8f7b\u91cf\u7ea7\u8fdb\u7a0b ID (\u5185\u6838\u5c42\u771f\u6b63\u7684\u7ebf\u7a0b ID)
\n std::string _name; \/\/ \u7ebf\u7a0b\u53ef\u8bfb\u6027\u540d\u79f0
\n func_t _func; \/\/ \u7ebf\u7a0b\u6267\u884c\u7684\u4efb\u52a1\u5305\u88c5\u5668
\n bool _joinable; \/\/ \u662f\u5426\u5141\u8bb8\u88ab\u7b49\u5f85\u6807\u8bb0
\n TSTAYUS _status; \/\/ \u5f53\u524d\u7ebf\u7a0b\u72b6\u6001\u673a
\n};<\/p>\n\n
2.4 \u7b56\u7565\u6a21\u5f0f\u65e5\u5fd7\u7cfb\u7edf（Logger.hpp）<\/h4>\n
\n#define __LOGGER_HPP<\/p>\n
\n#include <cstdio>
\n#include <string>
\n#include <ctime>
\n#include <filesystem> \/\/ C++17
\n#include "Mutex.hpp"
\n#include <fstream>
\n#include <sstream>
\n#include <memory>
\n#include <unistd.h><\/p>\n
\n{
\n \/\/ 1.\u83b7\u53d6\u65f6\u95f4
\n std::string GetTimeStamp()
\n {
\n time_t timestamp = time(nullptr);
\n struct tm data_time;
\n localtime_r(×tamp, &data_time);<\/p>\n
\n snprintf(data_time_str, sizeof(data_time_str), "%4d-%02d-%02d %02d:%02d:%02d",
\n data_time.tm_year + 1900, \/\/ \u4ece1900\u5f00\u59cb\u8bb0\u7684
\n data_time.tm_mon + 1, \/\/ \u9ed8\u8ba4\u6708\u4efd\u4ece0\u5f00\u59cb\u8bb0\u7684
\n data_time.tm_mday,
\n data_time.tm_hour,
\n data_time.tm_min,
\n data_time.tm_sec);
\n return data_time_str;
\n }<\/p>\n
\n {
\n DEBUG,
\n INFO,
\n WARNING,
\n ERROR,
\n FATAL
\n };<\/p>\n
\n std::string LogLevel2String(LogLevel level)
\n {
\n switch (level)
\n {
\n case LogLevel::DEBUG:
\n return "DEBUG";
\n case LogLevel::INFO:
\n return "INFO";
\n case LogLevel::WARNING:
\n return "WARNING";
\n case LogLevel::ERROR:
\n return "ERROR";
\n case LogLevel::FATAL:
\n return "FATAL";
\n default:
\n return "UNKNOWN";
\n }
\n }<\/p>\n
\n \/\/ \u57fa\u7c7b：\u7b56\u7565\u57fa\u7c7b,\u8bbe\u7f6e\u5237\u65b0\u7b56\u7565\u7684
\n class LogStrategy
\n {
\n public:
\n virtual ~LogStrategy() = default;
\n virtual void SyncLog(const std::string &logmessage) = 0;
\n };<\/p>\n
\n \/\/ \u7b56\u75651
\n class ConsoleLogStrategy : public LogStrategy
\n {
\n public:
\n ConsoleLogStrategy(){}
\n ~ConsoleLogStrategy(){}
\n virtual void SyncLog(const std::string &logmessage) override
\n {
\n LockGuard lockguard(&_mutex);
\n std::cout<<logmessage<<std::endl;
\n }
\n private:
\n Mutex _mutex;
\n };<\/p>\n
\n static const std::string glogfilename = "log.log";
\n \/\/ \u5b50\u7c7b：\u7ee7\u627f\u7eaf\u865a\u63a5\u53e3\u7c7b
\n \/\/ \u7b56\u75652
\n class FileLogStrategy : public LogStrategy
\n {
\n public:
\n FileLogStrategy(const std::string &dir = glogdir,const std::string &filename = glogfilename)
\n :_logdir(dir),_logfilename(filename)
\n {
\n \/\/ log\/log.txt
\n LockGuard lockguard(&_mutex);
\n if(std::filesystem::exists(_logdir))
\n {
\n return;
\n }
\n else
\n {
\n try
\n {
\n std::filesystem::create_directories(_logdir);
\n }
\n catch (const std::filesystem::filesystem_error &e)
\n {
\n std::cerr<< e.what() <<std::endl;
\n }
\n }
\n }
\n ~FileLogStrategy()
\n {}
\n void SyncLog(const std::string &logmessage) override
\n {
\n std::string target = _logdir + _logfilename;
\n std::ofstream out(target,std::ios::app); \/\/ \u8ffd\u52a0\u5199\u5165\u6587\u4ef6
\n if(!out.is_open())
\n {
\n return;
\n }<\/p>\n
\n \/\/ out.write(logmessage.c_str(), logmessage.size());
\n \/\/ out.write("\\\\n", 1); \/\/ \u5199\u5165\u6362\u884c\u7b26<\/p>\n
\n \/\/ std::string line = logmessage + '\\\\n';
\n \/\/ out.write(line.c_str(), line.size());<\/p>\n
\n out << logmessage << '\\\\n';<\/p>\n
\n }
\n private:
\n std::string _logdir;
\n std::string _logfilename; \/\/ .\/log\/XXX.log
\n Mutex _mutex;
\n };<\/p>\n
\n class Logger
\n {
\n public:
\n Logger()
\n {
\n UseConsoleLogStrategy();
\n }
\n ~Logger(){}
\n \/\/ \u663e\u793a\u5668\u7684\u5237\u65b0\u7b56\u7565
\n void UseConsoleLogStrategy()
\n {
\n _strategy = std::make_unique<ConsoleLogStrategy>();
\n }
\n \/\/ \u6587\u4ef6\u7684\u5237\u65b0\u7b56\u7565
\n void UseFileLogStrategy()
\n {
\n _strategy = std::make_unique<FileLogStrategy>();
\n }<\/p>\n
\n \/\/ \u76ee\u6807\u662f\u628a\u4e00\u4e2a\u7c7b\u5bf9\u8c61，\u53d8\u6210\u4e00\u4e2astring
\n class LogMessage
\n {
\n public:
\n LogMessage(LogLevel level,std::string &filename,int line,Logger &self)
\n :_level(level),
\n _curr_time(GetTimeStamp()),
\n _pid(getpid()),
\n _filename(filename),
\n _line(line),
\n _logger(self)
\n {
\n std::stringstream ss;
\n ss << "[" << _curr_time << "] "
\n << "[" << LogLevel2String(_level) << "] "
\n << "[" << _pid << "] "
\n << "[" << _filename << "] "
\n << "[" << _line << "] "
\n << "- ";
\n _loginfo = ss.str();
\n }<\/p>\n
\n LogMessage &operator << (const T &info)
\n {
\n std::stringstream ss;
\n ss << info;
\n _loginfo += ss.str();
\n return *this;
\n }<\/p>\n
\n {
\n if(_logger._strategy)
\n {
\n _logger._strategy->SyncLog(_loginfo);
\n }
\n }
\n private:
\n LogLevel _level; \/\/ \u65e5\u5fd7\u7b49\u7ea7
\n std::string _curr_time; \/\/ \u5f53\u524d\u65f6\u95f4
\n pid_t _pid; \/\/ \u8fdb\u7a0bpid
\n std::string _filename; \/\/ \u6587\u4ef6\u540d
\n int _line; \/\/ \u884c\u53f7
\n std::string _loginfo; \/\/ \u4e00\u6761\u5b8c\u6574\u7684\u65e5\u5fd7
\n Logger &_logger; \/\/ \u5916\u90e8\u7c7b\u7684\u5f15\u7528
\n };<\/p>\n
\n \/\/ \u4e3a\u4ec0\u4e48\u8981\u8fd4\u56de\u4e34\u65f6\u5185\u90e8\u7c7b\u5bf9\u8c61？
\n LogMessage operator()(LogLevel level,std::string filename, int line)
\n {
\n return LogMessage(level,filename,line,*this);
\n }
\n private:
\n std::unique_ptr<LogStrategy> _strategy; \/\/ \u5237\u65b0\u65e5\u5fd7\u7684\u7b56\u7565
\n };<\/p>\n
\n \/\/ \u4f7f\u7528\u5b8f，\u5305\u88c5\u6211\u4eec\u7684\u65e5\u5fd7\u6253\u5370\u8fc7\u7a0b，\u5b8f\u6709\u4e00\u4e2a\u7279\u70b9，#define A B，B\u66ff\u6362\u6210A
\n #define LOG(level) logger(level,__FILE__,__LINE__)<\/p>\n
\n #define ENABLE_CONSOLE_LOG_STRATEGY() logger.UseConsoleLogStrategy()
\n #define ENABLE_FILE_LOG_STRATEGY() logger.UseFileLogStrategy()
\n}<\/p>\n\n
2.5 \u7f51\u7edc\u5730\u5740\u5c01\u88c5（InetAddr.hpp）<\/h4>\n
\n#include <string>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h><\/p>\n
\n{
\npublic:
\n \/\/ n -> h — \u7f51\u7edc\u8f6c\u4e3b\u673a
\n InetAddr(struct sockaddr_in &addr):_net_addr(addr)
\n {
\n _port = ntohs(_net_addr.sin_port);
\n _ip = inet_ntoa(_net_addr.sin_addr);
\n }<\/p>\n
\n :_port(port),_ip(ip)
\n {
\n _net_addr.sin_family = AF_INET;
\n _net_addr.sin_port = htons(_port); \/\/ \u5c06\u4e3b\u673a\u5b57\u8282\u5e8f\u7684\u7aef\u53e3\u53f7\u8f6c\u6362\u4e3a\u7f51\u7edc\u5b57\u8282\u5e8f
\n _net_addr.sin_addr.s_addr = inet_addr(_ip.c_str()); \/\/ \u7b49\u4ef7 INADDR_ANY
\n }
\n uint16_t Port() { return _port; }
\n std::string IP() { return _ip; }
\n struct sockaddr *Addr()
\n {
\n return CONV(&_net_addr);
\n }
\n bool operator==(const InetAddr &addr)
\n {
\n return (_ip == addr._ip) && (_port == addr._port);
\n }
\n socklen_t AddrLen()
\n {
\n return sizeof(_net_addr);
\n }
\n std::string StringAddress()
\n {
\n return "[" + _ip + ":" + std::to_string(_port) + "]";
\n }
\n ~InetAddr()
\n {<\/p>\n
\nprivate:
\n \/\/ \u672c\u5730\u5730\u5740
\n uint16_t _port;
\n std::string _ip;
\n \/\/ \u7f51\u7edc\u5730\u5740
\n struct sockaddr_in _net_addr;
\n}; <\/p>\n\n
\n\u4e09. V3\u00a0\u591a\u8fdb\u7a0b\u7248\u672c：\u8fdc\u7a0b\u547d\u4ee4\u6267\u884c\u670d\u52a1\u5668\u5b9e\u6218<\/h3>\n
3.1 \u9700\u6c42\u80cc\u666f\u4e0e\u6574\u4f53\u8bbe\u8ba1<\/h4>\n
\n
\n
3.2 \u4e1a\u52a1\u5c42：\u547d\u4ee4\u6267\u884c\u6a21\u5757\u6df1\u5ea6\u89e3\u6790（ExcuteCommand.hpp）<\/h4>\n
\n#define __EXCUTECOMMAND__HPP<\/p>\n
\n#include <cstdio> \/\/ popen, pclose, fgets \u7b49\u6807\u51c6 C \u5e93\u51fd\u6570\u4f9d\u8d56\u4e8e\u6b64
\n#include <iostream>
\n#include <vector>
\n#include "Logger.hpp"<\/p>\n
\nusing namespace LogModule;<\/p>\n
\n\/\/ \u8fd9\u662f\u4e00\u4e2a\u5178\u578b\u7684\u5c06\u201c\u4e1a\u52a1\u903b\u8f91\u201d\u4e0e\u201c\u7f51\u7edc\u901a\u4fe1\u201d\u89e3\u8026\u7684\u8bbe\u8ba1
\nclass ExcuteCommand
\n{
\nprivate:
\n \/\/ \u5b89\u5168\u6821\u9a8c\u6838\u5fc3：\u57fa\u4e8e\u201c\u767d\u540d\u5355\u201d\u673a\u5236\u8fdb\u884c\u62e6\u622a
\n \/\/ \u4e3a\u4ec0\u4e48\u4e0d\u7528\u9ed1\u540d\u5355？\u56e0\u4e3a\u9ed1\u540d\u5355\u9632\u4e0d\u4f4f\u547d\u4ee4\u6ce8\u5165（\u5982 "ls && rm -rf \/"）
\n bool IsSafe(const std::string &cmdstr)
\n {
\n for(auto& str : _white_list)
\n {
\n \/\/ \u6ce8\u610f：\u8fd9\u91cc\u4f7f\u7528\u7684\u662f\u7cbe\u786e\u5339\u914d (==)，\u610f\u5473\u7740\u5ba2\u6237\u7aef\u53d1\u6765\u7684\u547d\u4ee4\u5fc5\u987b\u8fde\u7a7a\u683c\u90fd\u5206\u6beb\u4e0d\u5dee
\n \/\/ \u8fd9\u79cd\u8bbe\u8ba1\u6781\u5176\u4e25\u683c，\u4f46\u4e5f\u6700\u5b89\u5168，\u675c\u7edd\u4e86\u4efb\u4f55\u5f62\u5f0f\u7684\u53c2\u6570\u6ce8\u5165\u653b\u51fb
\n if(cmdstr == str) return true;
\n }<\/p>\n
\n }<\/p>\n
\n ExcuteCommand()
\n {
\n \/\/ \u6784\u9020\u65f6\u521d\u59cb\u5316\u767d\u540d\u5355\u3002\u53ea\u6709\u8fd9 5 \u4e2a\u7eaf\u8bfb\u53d6\u3001\u65e0\u7834\u574f\u6027\u7684\u547d\u4ee4\u662f\u88ab\u5141\u8bb8\u6267\u884c\u7684
\n _white_list.push_back("pwd");
\n _white_list.push_back("who");
\n _white_list.push_back("whoami");
\n _white_list.push_back("ls -a -l");
\n _white_list.push_back("env");
\n }<\/p>\n
\n std::string Excute(const std::string cmdstr)
\n {
\n \/\/ 1. \u6267\u884c\u524d\u7f6e\u5b89\u5168\u62e6\u622a
\n if(!IsSafe(cmdstr)) return "UnSafe";<\/p>\n
\n \/\/ popen \u5728\u5e95\u5c42\u4f1a\u81ea\u52a8\u4e3a\u4f60\u5b8c\u6210\u56db\u5927\u6b65\u9aa4：
\n \/\/ (1) \u521b\u5efa\u65e0\u540d\u7ba1\u9053 (pipe)
\n \/\/ (2) fork() \u521b\u5efa\u5b50\u8fdb\u7a0b
\n \/\/ (3) \u5728\u5b50\u8fdb\u7a0b\u4e2d\u8c03\u7528 exec \u51fd\u6570\u7c07\u6267\u884c shell \u547d\u4ee4 (sh -c cmdstr)
\n \/\/ (4) "r" \u8868\u793a\u7236\u8fdb\u7a0b\u8981\u8bfb\u53d6\u5b50\u8fdb\u7a0b\u7684\u6807\u51c6\u8f93\u51fa\u6d41
\n FILE* fp = popen(cmdstr.c_str(), "r");
\n if(fp == nullptr)
\n {
\n LOG(LogLevel::ERROR) << "exec error: " << cmdstr;
\n return "error"; \/\/ \u521b\u5efa\u8fdb\u7a0b\u6216\u7ba1\u9053\u5931\u8d25
\n }<\/p>\n
\n char buffer[512]; \/\/ \u7528\u4e8e\u6682\u5b58\u4ece\u7ba1\u9053\u4e2d\u8bfb\u53d6\u7684\u6570\u636e\u5757<\/p>\n
\n \/\/ fgets \u4f1a\u4ece fp (\u7ba1\u9053\u8bfb\u7aef) \u4e2d\u8bfb\u53d6\u6570\u636e，\u76f4\u5230\u8bfb\u5230 EOF \u6216\u53d1\u751f\u9519\u8bef
\n \/\/ \u7531\u4e8e\u547d\u4ee4\u8f93\u51fa\u53ef\u80fd\u5f88\u957f（\u6bd4\u5982 env），\u8fd9\u91cc\u5fc5\u987b\u7528 while \u5faa\u73af\u5206\u6279\u8bfb\u53d6
\n while(fgets(buffer, sizeof(buffer), fp) != nullptr)
\n {
\n result += buffer; \/\/ \u5c06\u5f53\u524d\u8bfb\u5230\u7684\u6570\u636e\u5757\u8ffd\u52a0\u5230\u6700\u7ec8\u7ed3\u679c\u5b57\u7b26\u4e32\u4e2d
\n buffer[0] = 0; \/\/ \u6e05\u7a7a\u4e00\u4e0b (\u539f\u6ce8\u91ca\u4fdd\u7559\u3002\u5e95\u5c42\u903b\u8f91：\u5c06\u9996\u5b57\u7b26\u7f6e\u4e3a \\\\0，\u4f5c\u4e3a\u4e00\u79cd\u9632\u5b88\u578b\u7f16\u7a0b\u4e60\u60ef)
\n }<\/p>\n
\n \/\/ pclose \u4e0d\u4ec5\u4ec5\u662f\u5173\u95ed\u6587\u4ef6\u6307\u9488，\u5b83\u5728\u5e95\u5c42\u8fd8\u4f1a\u8c03\u7528 waitpid() \u53bb\u56de\u6536\u521a\u521a popen \u521b\u5efa\u7684\u5b50\u8fdb\u7a0b
\n \/\/ \u5982\u679c\u4e0d\u8c03 pclose，\u4f1a\u5bfc\u81f4\u4ea7\u751f\u5927\u91cf\u7684\u50f5\u5c38\u8fdb\u7a0b，\u6700\u7ec8\u8017\u5c3d\u7cfb\u7edf PID \u8d44\u6e90
\n pclose(fp);<\/p>\n
\n }<\/p>\n
\n {}<\/p>\n
\n std::vector<std::string> _white_list; \/\/ \u767d\u540d\u5355\u5217\u8868，\u5b58\u50a8 100% \u4fe1\u4efb\u7684\u547d\u4ee4
\n};
\n#endif<\/p>\n\n
\n
\n
3.3 \u7f51\u7edc\u5c42：\u591a\u7ebf\u7a0b TCP \u670d\u52a1\u5668\u6df1\u5ea6\u89e3\u6790<\/h4>\n
3.3.1 \u6838\u5fc3\u7c7b\u578b\u4e0e\u6210\u5458\u5b9a\u4e49<\/h5>\n
\nusing callback_t = std::function<std::string(std::string)>;
\nstatic const uint16_t gdefaultport = 8080;
\nstatic const int gbacklog = 32;<\/p>\n
\n{
\nprivate:
\n \/\/ \u6838\u5fc3\u4e1a\u52a1\u5904\u7406\u51fd\u6570：\u6bcf\u4e2a\u8fde\u63a5\u7684IO\u5faa\u73af
\n void Service(int sockfd, InetAddr client);
\npublic:
\n TcpServer (uint16_t port = gdefaultport): _port(port), _listensockfd(-1) {}
\n \/\/ \u670d\u52a1\u5668\u521d\u59cb\u5316：\u6ce8\u5165\u4e1a\u52a1\u56de\u8c03\u3001socket\u521b\u5efa\u3001bind\u3001listen
\n void Init(callback_t cb);
\n \/\/ \u670d\u52a1\u5668\u542f\u52a8：\u4e8b\u4ef6\u5faa\u73af，accept\u65b0\u8fde\u63a5
\n void Start();
\n ~TcpServer(){}
\nprivate:
\n uint16_t _port; \/\/ \u670d\u52a1\u5668\u76d1\u542c\u7aef\u53e3
\n int _listensockfd; \/\/ \u76d1\u542c\u5957\u63a5\u5b57
\n callback_t _cb; \/\/ \u4e1a\u52a1\u5904\u7406\u56de\u8c03\u51fd\u6570
\n};<\/p>\n\n
3.3.2 \u670d\u52a1\u7aef\u5b8c\u6574\u4ee3\u7801\u89e3\u6790（TcpServer.hpp）<\/h5>\n
\n#define __TCP__SERVER__HPP<\/p>\n
\n#include <cstdint>
\n#include <functional>
\n#include <pthread.h>
\n#include <string>
\n#include <string.h>
\n#include <unistd.h>
\n#include <sys\/wait.h><\/p>\n
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include "InetAddr.hpp"
\n#include "Logger.hpp"
\nusing namespace LogModule;<\/p>\n
\n\/\/ \u8fd9\u662f\u7f51\u7edc\u5c42（TcpServer）\u548c\u4e1a\u52a1\u5c42（\u5982 ExecuteCommand）\u5f7b\u5e95\u89e3\u8026\u7684\u7075\u9b42\u6240\u5728\u3002
\nusing callback_t = std::function<std::string(std::string)>;<\/p>\n
\nstatic const int gbacklog = 32;<\/p>\n
\n{
\nprivate:
\n \/\/ sockfd: \u65e2\u53ef\u4ee5\u652f\u6301\u8bfb，\u53c8\u53ef\u4ee5\u652f\u6301\u5199, TCP socket\u4e5f\u662f\u5168\u53cc\u5de5\u7684.
\n \/\/ \u4e13\u95e8\u8d1f\u8d23\u4e0e\u67d0\u4e00\u4e2a\u7279\u5b9a\u5ba2\u6237\u7aef\u8fdb\u884c IO \u901a\u4fe1\u7684\u201c\u670d\u52a1\u5458\u201d\u51fd\u6570
\n void Service(int sockfd, InetAddr client)
\n {
\n \/\/ \u957f\u8fde\u63a5\u670d\u52a1
\n while (true)
\n {
\n char inbuffer[1024];<\/p>\n
\n \/\/ \u6ce8\u610f：sizeof(inbuffer) – 1 \u662f\u4e3a\u4e86\u9884\u7559\u4e00\u4e2a\u5b57\u8282，\u7ed9\u540e\u9762\u7684 \\\\0 \u5360\u4f4d，\u9632\u6b62\u5b57\u7b26\u4e32\u8d8a\u754c
\n int n = read(sockfd, inbuffer, sizeof(inbuffer) – 1);
\n if(n > 0)
\n {
\n inbuffer[n] = 0; \/\/ \u624b\u52a8\u5c06\u5176\u8f6c\u6362\u4e3a\u5b89\u5168\u7684 C \u98ce\u683c\u5b57\u7b26\u4e32
\n LOG(LogLevel::INFO) << client.StringAddress() << " say# " << inbuffer;
\n }
\n else if(n == 0)
\n {
\n \/\/ read \u8fd4\u56de 0 \u662f\u4e00\u4e2a\u975e\u5e38\u5173\u952e\u7684\u4fe1\u53f7：\u4ee3\u8868\u5ba2\u6237\u7aef\u4e3b\u52a8\u5173\u95ed\u4e86\u8fde\u63a5 (EOF)
\n LOG(LogLevel::INFO) << client.StringAddress() << " close sockfd: " << sockfd << ", me too!";
\n break;
\n }
\n else
\n {
\n \/\/ \u53d1\u751f\u7f51\u7edc\u9519\u8bef\u6216\u88ab\u4fe1\u53f7\u4e2d\u65ad
\n LOG(LogLevel::ERROR) << "read socket error";
\n break;
\n }<\/p>\n
\n \/\/ \u67b6\u6784\u4eae\u70b9：\u5c06\u8bfb\u5230\u7684\u6570\u636e\u76f4\u63a5\u6254\u7ed9\u7ed1\u5b9a\u7684\u56de\u8c03\u51fd\u6570，\u7f51\u7edc\u5c42\u6839\u672c\u4e0d\u5173\u5fc3\u91cc\u9762\u662f\u5728\u7b97\u52a0\u6cd5\u8fd8\u662f\u5728\u6267\u884c\u7cfb\u7edf\u547d\u4ee4
\n std::string result = _cb(inbuffer);<\/p>\n
\n int m = write(sockfd, result.c_str(), result.size());
\n if(m < 0)
\n {
\n LOG(LogLevel::ERROR) << "write socket error";
\n break;
\n }
\n }<\/p>\n
\n close(sockfd);
\n }
\npublic:
\n TcpServer (uint16_t port = gdefaultport): _port(port), _listensockfd(-1)
\n {}
\n void Init(callback_t cb)
\n {
\n \/\/ \u5c06\u5916\u90e8\u4f20\u8fdb\u6765\u7684\u4e1a\u52a1\u903b\u8f91\u6ce8\u518c\u5230\u670d\u52a1\u5668\u5185\u90e8
\n _cb = cb;
\n \/\/ 1. \u521b\u5efa\u5957\u63a5\u5b57
\n \/\/ AF_INET\u4ee3\u8868\u4f7f\u7528IPv4\u534f\u8bae，SOCK_STREAM\u4ee3\u8868\u4f7f\u7528\u9762\u5411\u8fde\u63a5\u7684TCP\u5b57\u8282\u6d41
\n _listensockfd = socket(AF_INET, SOCK_STREAM, 0); \/\/ \u8bbe\u7f6e\u62100\u5c31\u53ef\u4ee5\u4e86
\n if(_listensockfd < 0)
\n {
\n LOG(LogLevel::FATAL) << "create socket error: " << _listensockfd;
\n exit(2);
\n }
\n LOG(LogLevel::INFO) << "create socket success: " << _listensockfd;<\/p>\n
\n \/\/ \u6211\u4eec\u8fd9\u91cc\u662f\u53ef\u4ee5\u76f4\u63a5\u4f7f\u7528\u6211\u4eec\u7684InetAddr\u7684,\u4f46\u662f\u6211\u4eec\u540e\u9762\u518d\u7528
\n struct sockaddr_in local;
\n socklen_t len = sizeof(local);
\n memset(&local, 0, len); \/\/ \u7ed3\u6784\u4f53\u6e05\u96f6，\u517b\u6210\u826f\u597d\u4e60\u60ef\u9632\u6b62\u810f\u6570\u636e
\n local.sin_family = AF_INET;
\n \/\/ htons\/htonl: \u5fc5\u987b\u5c06\u4e3b\u673a\u7684\u5b57\u8282\u5e8f\u8f6c\u6362\u4e3a\u7f51\u7edc\u7edf\u4e00\u89c4\u5b9a\u7684\u5927\u7aef\u5b57\u8282\u5e8f
\n local.sin_port = htons(_port);
\n local.sin_addr.s_addr = htonl(INADDR_ANY); \/\/ INADDR_ANY\u8868\u793a\u76d1\u542c\u672c\u673a\u6240\u6709\u7f51\u5361\u63a5\u53e3\u7684\u8bf7\u6c42<\/p>\n
\n if(n < 0)
\n {
\n LOG(LogLevel::FATAL) << "bind error: " << _listensockfd;
\n exit(3);
\n }
\n LOG(LogLevel::INFO) << "bind success: " << _listensockfd;<\/p>\n
\n \/\/ listen \u4f7f\u5f97\u670d\u52a1\u5668\u771f\u6b63\u5f00\u59cb\u5728\u7cfb\u7edf\u5185\u6838\u5c42\u9762\u201c\u88ab\u52a8\u5f85\u547d\u201d，gbacklog \u662f\u5185\u6838\u7ef4\u62a4\u7684\u5168\u8fde\u63a5\u961f\u5217\u957f\u5ea6
\n n = listen(_listensockfd, gbacklog);
\n if(n < 0)
\n {
\n LOG(LogLevel::FATAL) << "listen error: " << _listensockfd;
\n exit(3);
\n }
\n LOG(LogLevel::INFO) << "listen success: " << _listensockfd;
\n }
\n void Start()
\n {
\n \/\/ \u591a\u8fdb\u7a0b\u7248\u672c\u7b49\u5f85\u7684\u6700\u4f73\u5b9e\u8df5
\n \/\/ \u5ffd\u7565 SIGCHLD \u4fe1\u53f7，\u544a\u8bc9\u5185\u6838：\u201c\u6211\u5bf9\u5b50\u8fdb\u7a0b\u7684\u6b7b\u6d3b\u4e0d\u611f\u5174\u8da3\u201d\u3002
\n \/\/ \u8fd9\u6837\u5b50\u8fdb\u7a0b\u7ed3\u675f\u540e，\u5185\u6838\u4f1a\u81ea\u52a8\u6e05\u7406\u5176\u8d44\u6e90，\u5b8c\u7f8e\u907f\u514d\u4e86\u50f5\u5c38\u8fdb\u7a0b\u7684\u4ea7\u751f，\u4e3b\u8fdb\u7a0b\u4e5f\u4e0d\u7528\u963b\u585e\u53bb wait\u3002
\n signal(SIGCHLD, SIG_IGN);
\n while(true)
\n {
\n struct sockaddr_in clientaddr;
\n socklen_t len = sizeof(clientaddr);
\n \/\/ accept \u8d1f\u8d23\u4ece\u5e95\u5c42\u961f\u5217\u4e2d\u62ff\u53d6\u4e00\u4e2a\u5df2\u7ecf\u5efa\u7acb\u597d\u7684\u8fde\u63a5\u3002_listensockfd \u662f\u62c9\u5ba2\u7684，\u8fd4\u56de\u7684 sockfd \u662f\u5e72\u6d3b\u7684\u3002
\n int sockfd = accept(_listensockfd, (struct sockaddr *)&clientaddr, &len);
\n if (sockfd < 0)
\n {
\n LOG(LogLevel::WARNING) << "accept error";
\n continue; \/\/ accept \u5931\u8d25\u5f80\u5f80\u662f\u5c40\u90e8\u7f51\u7edc\u6ce2\u52a8\u6216\u4fe1\u53f7\u6253\u65ad，\u4e0d\u5f71\u54cd\u5168\u5c40，\u7ee7\u7eed\u63a5\u5f85\u4e0b\u4e00\u4e2a\u5373\u53ef
\n }
\n \/\/ \u7f51\u7edc\u8f6c\u4e3b\u673a
\n InetAddr clientaddress(clientaddr);
\n LOG(LogLevel::INFO) << "get a new link: " << clientaddress.StringAddress() << " sockfd: " << sockfd;<\/p>\n
\n \/\/ fork() \u4f1a\u521b\u5efa\u4e00\u4e2a\u5b50\u8fdb\u7a0b，\u5b50\u8fdb\u7a0b\u4f1a\u62f7\u8d1d\u7236\u8fdb\u7a0b\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u8868
\n pid_t pid = fork();
\n if(pid < 0)
\n {
\n LOG(LogLevel::ERROR) << "fork error";
\n close(sockfd);
\n }
\n else if(pid == 0)
\n {
\n \/\/ \u5b50\u8fdb\u7a0b,\u62f7\u8d1d\u7236\u8fdb\u7a0b\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u8868，\u4ece\u800c\u548c\u7236\u8fdb\u7a0b\u770b\u5230\u540c\u4e00\u6279\u6587\u4ef6
\n \/\/ \u5173\u95ed\u81ea\u5df1\u4e0d\u9700\u8981\u7684\u6587\u4ef6fd
\n \/\/ \u5b50\u8fdb\u7a0b\u4e13\u804c\u8d1f\u8d23\u4e3a\u8fd9\u4e2a\u5ba2\u6237\u7aef\u670d\u52a1，\u4e0d\u8d1f\u8d23\u62c9\u5ba2，\u6240\u4ee5\u5173\u95ed\u76d1\u542c\u5957\u63a5\u5b57
\n close(_listensockfd);
\n \/\/ **************************************
\n \/\/ \u5b50\u8fdb\u7a0b
\n \/\/ if(fork() > 0)
\n \/\/ exit(0);
\n \/\/ \/\/ \u5b59\u5b50\u8fdb\u7a0b — \u4f60\u53bb\u6267\u884c
\n \/\/ Service(sockfd, clientaddress);
\n \/\/ **************************************
\n Service(sockfd, clientaddress);
\n exit(0); \/\/ \u670d\u52a1\u5b8c\u6bd5\u540e，\u5b50\u8fdb\u7a0b\u5fc5\u987b\u9000\u51fa，\u7edd\u4e0d\u80fd\u8ba9\u5b83\u56de\u5230\u5916\u5c42\u7684 while \u5faa\u73af\u53bb accept
\n }
\n else{}
\n \/\/ \u7236\u8fdb\u7a0b\u4e0d\u9700\u8981\u8fd9\u4e2a
\n \/\/ \u56e0\u4e3a\u7236\u8fdb\u7a0b\u5df2\u7ecf\u628a\u8fd9\u4e2a sockfd \u4ea4\u7ed9\u5b50\u8fdb\u7a0b\u5904\u7406\u4e86\u3002\u5982\u679c\u4e0d\u5173，\u6bcf\u6765\u4e00\u4e2a\u5ba2\u4eba\u7236\u8fdb\u7a0b\u5c31\u591a\u5360\u4e00\u4e2a fd，\u5f88\u5feb\u5c31\u4f1a fd \u8017\u5c3d\u5bfc\u81f4\u670d\u52a1\u5668\u5d29\u6e83\u3002
\n close(sockfd);
\n \/\/ \/\/ \u7236\u8fdb\u7a0b
\n \/\/ pid_t rid = waitpid(pid, nullptr, 0);
\n }
\n }
\n ~TcpServer(){}
\nprivate:
\n uint16_t _port;
\n int _listensockfd;
\n callback_t _cb; \/\/ \u5b58\u653e\u5916\u90e8\u6ce8\u5165\u7684\u4e1a\u52a1\u903b\u8f91\u56de\u8c03\u51fd\u6570
\n};
\n#endif<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205847-6a652387d885f.png\")
<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205848-6a65238845667.png\")
<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205848-6a652388aface.png\")
<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205849-6a65238928b81.png\")
<\/p>\n3.3.3 \u5ba2\u6237\u7aef\u5b8c\u6574\u4ee3\u7801\u89e3\u6790<\/h5>\n
\n#include <arpa\/inet.h>
\n#include <cstdint>
\n#include <iostream>
\n#include <netinet\/in.h>
\n#include <string>
\n#include <sys\/socket.h>
\n#include <sys\/types.h>
\n#include <unistd.h><\/p>\n
\n\/\/ （\u6ce8：\u539f\u4ee3\u7801\u8fd9\u91cc\u7684\u63d0\u793a\u5b57\u4e32\u4e3a " ServerPort"，\u4f46\u4e0b\u9762\u903b\u8f91\u5b9e\u9645\u9700\u8981 IP \u548c Port，\u8fd9\u662f\u4e2a\u5c0f\u7455\u75b5，\u4f46\u4e0d\u5f71\u54cd\u6574\u4f53\u903b\u8f91）
\nvoid Usage(std::string procname)
\n{
\n std::cout << "Usage: " << procname << " ServerPort" << std::endl;
\n}<\/p>\n
\nint main(int argc, char *argv[])
\n{
\n \/\/ \u5ba2\u6237\u7aef\u542f\u52a8\u5fc5\u987b\u77e5\u9053\u76ee\u6807\u670d\u52a1\u5668\u662f\u8c01，\u6240\u4ee5\u53c2\u6570\u4e2a\u6570\u5fc5\u987b\u4e3a 3 (\u7a0b\u5e8f\u540d\u3001\u76ee\u6807IP\u3001\u76ee\u6807\u7aef\u53e3)
\n if(argc != 3)
\n {
\n Usage(argv[0]);
\n exit(1);
\n }<\/p>\n
\n std::string serverIp = argv[1];
\n uint16_t serverPort = std::stoi(argv[2]);<\/p>\n
\n \/\/ \u5ba2\u6237\u7aef\u4e5f\u9700\u8981\u4e00\u4e2a\u901a\u4fe1\u7aef\u70b9\u3002AF_INET(IPv4), SOCK_STREAM(TCP\u534f\u8bae)
\n int sockfd = socket(AF_INET, SOCK_STREAM, 0);
\n if(sockfd < 0)
\n {
\n std::cerr << "socket error" << std::endl;
\n exit(2);
\n }<\/p>\n
\n \/\/ \u5c01\u88c5\u670d\u52a1\u5668\u7684 IP \u548c\u7aef\u53e3\u5730\u5740\u4fe1\u606f
\n InetAddr serveraddress(serverPort, serverIp);<\/p>\n
\n \/\/ \u5f53\u6211\u4eec\u8c03\u7528 connect \u5411\u670d\u52a1\u5668\u53d1\u8d77\u8fde\u63a5（TCP \u4e09\u6b21\u63e1\u624b）\u65f6，\u64cd\u4f5c\u7cfb\u7edf\u4f1a\u5728\u5e95\u5c42\u81ea\u52a8\u4e3a\u8be5\u5ba2\u6237\u7aef\u5206\u914d\u4e00\u4e2a\u7a7a\u95f2\u7684\u968f\u673a\u7aef\u53e3\u3002
\n \/\/ \u8fd9\u5b8c\u7f8e\u907f\u514d\u4e86\u5982\u679c\u5ba2\u6237\u7aef\u628a\u7aef\u53e3\u5199\u6b7b，\u5bfc\u81f4\u7aef\u53e3\u88ab\u5360\u7528\u65e0\u6cd5\u542f\u52a8\u7684\u95ee\u9898\u3002
\n int n = connect(sockfd, serveraddress.Addr(), serveraddress.AddrLen());
\n if(n < 0)
\n {
\n std::cerr << "connect error" << std::endl;
\n exit(3); \/\/ \u8fde\u63a5\u5931\u8d25\u901a\u5e38\u662f\u56e0\u4e3a\u7f51\u7edc\u4e0d\u901a\u6216\u76ee\u6807\u670d\u52a1\u5668\u8fdb\u7a0b\u672a\u542f\u52a8
\n }<\/p>\n
\n \/\/ \u8fdb\u5165\u957f\u8fde\u63a5\u7684\u8bf7\u6c42-\u54cd\u5e94\u5faa\u73af (\u4e00\u95ee\u4e00\u7b54\u6a21\u5f0f)
\n while(true)
\n {
\n std::string line;
\n std::cout << "Please Enter# ";
\n \/\/ \u4f7f\u7528 std::getline \u800c\u4e0d\u662f cin >>，\u662f\u56e0\u4e3a\u7528\u6237\u8f93\u5165\u7684\u547d\u4ee4\u4e2d\u901a\u5e38\u5305\u542b\u7a7a\u683c（\u5982 "ls -a -l"）
\n \/\/ cin >> \u9047\u5230\u7a7a\u683c\u5c31\u4f1a\u505c\u6b62\u8bfb\u53d6，\u800c getline \u4f1a\u8bfb\u53d6\u5b8c\u6574\u7684\u4e00\u884c
\n std::getline(std::cin, line);<\/p>\n
\n \/\/ TCP \u662f\u5168\u53cc\u5de5\u7684，\u5ba2\u6237\u7aef\u7528 sockfd \u5411\u670d\u52a1\u5668\u53d1\u6570\u636e\u3002
\n ssize_t n = write(sockfd, line.c_str(), line.size());
\n (void)n; \/\/ \u5f3a\u5236\u7c7b\u578b\u8f6c\u6362，\u7528\u6765\u6d88\u9664\u7f16\u8bd1\u5668\u5173\u4e8e "\u53d8\u91cf n \u58f0\u660e\u4e86\u4f46\u672a\u4f7f\u7528" \u7684\u8b66\u544a<\/p>\n
\n char buffer[4096]; \/\/ \u5f00\u5927\u4e00\u70b9
\n \/\/ \u4e4b\u524d\u6d4b\u8bd5\u8fc7，\u5982\u679c\u63a5\u6536\u670d\u52a1\u5668 `ls -al` \u8fd4\u56de\u7684\u6570\u636e，\u7f13\u51b2\u533a\u592a\u5c0f\u4f1a\u5bfc\u81f4\u6570\u636e\u622a\u65ad\u3002
\n \/\/ \u6240\u4ee5\u8fd9\u91cc\u5f00\u4e86 4096 \u5b57\u8282\u3002\u4f46\u8981\u6ce8\u610f，\u5728\u7eaf\u9762\u5411\u5b57\u8282\u6d41\u7684 TCP \u4e2d，\u4e00\u6b21 read \u4f9d\u7136\u4e0d\u4e00\u5b9a\u80fd\u8bfb\u5b8c\u8d85\u5927\u6570\u636e\u3002
\n ssize_t m = read(sockfd, buffer, sizeof(buffer) – 1);
\n if(m > 0)
\n {
\n buffer[m] = 0; \/\/ \u624b\u52a8\u5728\u672b\u5c3e\u6dfb\u52a0 '\\\\0'，\u5c06\u539f\u59cb\u5b57\u8282\u6d41\u8f6c\u5316\u4e3a C \u98ce\u683c\u5b57\u7b26\u4e32\u4ee5\u4fbf\u5b89\u5168\u6253\u5370
\n std::cout << "-> " << buffer << std::endl;
\n }
\n else if(m == 0)
\n {
\n \/\/ \u670d\u52a1\u5668\u7aef\u5173\u95ed\u4e86\u8fde\u63a5（\u6bd4\u5982\u670d\u52a1\u7aef\u88ab kill \u6389\u4e86，\u6216\u8005\u662f\u4e00\u4e2a\u77ed\u670d\u52a1\u5904\u7406\u5b8c\u4e3b\u52a8 close \u4e86）
\n \/\/ \u5ba2\u6237\u7aef\u611f\u77e5\u5230 EOF，\u968f\u4e4b\u9000\u51fa
\n std::cerr << "server quit!" << std::endl;
\n break;
\n }
\n else
\n {
\n std::cerr << "read error" << std::endl;
\n break;
\n }
\n }<\/p>\n
\n \/\/ \u6b64\u65f6\u64cd\u4f5c\u7cfb\u7edf\u5e95\u5c42\u4f1a\u5411\u670d\u52a1\u5668\u53d1\u9001 TCP \u56db\u6b21\u6325\u624b\u7684 FIN \u62a5\u6587，\u6b63\u5f0f\u65ad\u5f00\u8fde\u63a5
\n close(sockfd);
\n return 0;
\n}<\/p>\n3.3.4 \u670d\u52a1\u7aef\u4e3b\u51fd\u6570\u4ee3\u7801（TcpServer.cc）<\/h5>\n
\n#include "ExcuteCommand.hpp"
\n#include "Logger.hpp"
\n#include <cstdint>
\n#include <memory> \/\/ \u63d0\u4f9b std::unique_ptr \u7b49\u667a\u80fd\u6307\u9488\u7684\u652f\u6301<\/p>\n
\n\/\/ \u5f53\u7528\u6237\u5728\u547d\u4ee4\u884c\u542f\u52a8\u7a0b\u5e8f\u7684\u53c2\u6570\u6570\u91cf\u4e0d\u7b26\u5408\u9884\u671f\u65f6，\u8c03\u7528\u6b64\u51fd\u6570\u8fdb\u884c\u63d0\u793a
\nvoid Usage(std::string procname)
\n{
\n \/\/ procname \u901a\u5e38\u63a5\u6536\u7684\u662f argv[0]，\u5373\u5f53\u524d\u53ef\u6267\u884c\u7a0b\u5e8f\u7684\u8def\u5f84\u6216\u540d\u79f0
\n std::cout << "Usage: " << procname << " ServerPort" << std::endl;
\n}<\/p>\n
\nint main(int argc, char *argv[])
\n{
\n \/\/ \u53c2\u6570\u6821\u9a8c：\u786e\u4fdd\u7528\u6237\u8f93\u5165\u4e86\u7a0b\u5e8f\u540d\u548c\u76d1\u542c\u7aef\u53e3\u53f7\u8fd9\u4e24\u4e2a\u53c2\u6570
\n if(argc != 2)
\n {
\n Usage(argv[0]);
\n exit(1);
\n }<\/p>\n
\n ENABLE_CONSOLE_LOG_STRATEGY();<\/p>\n
\n uint16_t ServerPort = std::stoi(argv[1]);<\/p>\n
\n \/\/ \u67b6\u6784\u6838\u5fc3：\u6a21\u5757\u5316\u4e0e\u4f9d\u8d56\u6ce8\u5165
\n \/\/ ==============================================================================<\/p>\n
\n \/\/ \u4e13\u804c\u8d1f\u8d23\u5224\u65ad\u547d\u4ee4\u662f\u5426\u5b89\u5168（\u767d\u540d\u5355），\u4ee5\u53ca\u4f7f\u7528 popen \u5728\u5e95\u5c42\u6267\u884c\u547d\u4ee4\u3002
\n \/\/ \u5b83\u6839\u672c\u4e0d\u77e5\u9053\u7f51\u7edc\u7684\u5b58\u5728，\u662f\u4e00\u4e2a\u7eaf\u7cb9\u7684\u4e1a\u52a1\u7ec4\u4ef6\u3002
\n std::unique_ptr<ExcuteCommand> excute = std::make_unique<ExcuteCommand>();<\/p>\n
\n \/\/ \u4e13\u804c\u8d1f\u8d23 socket \u521b\u5efa\u3001bind\u3001listen \u4ee5\u53ca\u591a\u8fdb\u7a0b\u7684\u5e76\u53d1\u8c03\u5ea6 (accept \/ fork)\u3002
\n \/\/ \u5b83\u53ea\u77e5\u9053\u6536\u53d1\u5b57\u7b26\u4e32，\u6839\u672c\u4e0d\u77e5\u9053\u8fd9\u4e9b\u5b57\u7b26\u4e32\u4ee3\u8868\u7684\u662f\u7cfb\u7edf\u547d\u4ee4\u3002
\n std::unique_ptr<TcpServer> tsvr = std::make_unique<TcpServer>(ServerPort);<\/p>\n
\n \/\/ tsvr->Init \u9700\u8981\u4e00\u4e2a function<string(string)> \u7c7b\u578b\u7684\u56de\u8c03\u51fd\u6570\u3002
\n \/\/ \u8fd9\u91cc\u4f7f\u7528\u4e86 C++11 \u7684 Lambda \u8868\u8fbe\u5f0f：
\n \/\/ – [&excute]：\u901a\u8fc7\u5f15\u7528\u6355\u83b7\u5916\u90e8\u4f5c\u7528\u57df\u7684 excute \u667a\u80fd\u6307\u9488\u5bf9\u8c61\u3002
\n \/\/ – (std::string cmdstring) -> std::string：\u5b9a\u4e49\u4e86\u8f93\u5165\u548c\u8f93\u51fa\u53c2\u6570，\u5b8c\u7f8e\u5951\u5408 callback_t\u3002
\n \/\/ \u8fd0\u884c\u65f6\u8868\u73b0：\u5f53 TcpServer \u6536\u5230\u6570\u636e\u65f6，\u4f1a\u6267\u884c\u5927\u62ec\u53f7\u91cc\u7684\u5185\u5bb9，\u5373\u628a\u6570\u636e\u4ea4\u7ed9 excute \u53bb\u6267\u884c，\u5e76\u628a\u7ed3\u679c\u62ff\u56de\u6765\u3002
\n tsvr->Init([&excute](std::string cmdstring)->std::string{
\n return excute->Excute(cmdstring);
\n });<\/p>\n
\n tsvr->Start();<\/p>\n
\n}<\/p>\n
\n\u56db. V4 \u7ebf\u7a0b\u6c60\u7248\u672c：\u9ad8\u5e76\u53d1 Echo \u670d\u52a1\u5668\u5b9e\u73b0<\/h3>\n
4.1 \u7ebf\u7a0b\u6c60\u6838\u5fc3\u8bbe\u8ba1\u601d\u60f3<\/h4>\n
\n
4.2 \u7ebf\u7a0b\u6c60\u6a21\u677f\u7c7b\u6df1\u5ea6\u89e3\u6790（ThreadPool.hpp）<\/h4>\n
\n#define THREADPOOL_HPP<\/p>\n
\n#include <iostream>
\n#include <memory>
\n#include <pthread.h>
\n#include <vector>
\n#include <queue>
\n#include "Thread.hpp"
\n#include "Logger.hpp"
\n#include "Mutex.hpp"
\n#include "Cond.hpp"
\nusing namespace LogModule;<\/p>\n
\n * @brief \u7ebf\u7a0b\u6c60\u5355\u4f8b\u6a21\u677f\u7c7b
\n * \u91c7\u7528\u4e86\u201c\u61d2\u6c49\u6a21\u5f0f\u201d\u5b9e\u73b0，\u5373\u5728\u7b2c\u4e00\u6b21\u8c03\u7528 GetInstance \u65f6\u624d\u8fdb\u884c\u5b9e\u4f8b\u5316\u3002
\n *\/
\ntemplate<typename T>
\nclass ThreadPool
\n{
\nprivate:
\n \/\/ \u5185\u90e8\u903b\u8f91：\u5224\u5b9a\u961f\u5217\u72b6\u6001
\n bool IsEmptyQueue()
\n {
\n return _queue.empty();
\n }<\/p>\n
\n T PopHelper()
\n {
\n T t = _queue.front();
\n _queue.pop();
\n return t;
\n }<\/p>\n
\n * @brief \u6d88\u8d39\u8005\u6838\u5fc3\u6267\u884c\u6d41
\n * \u8fd0\u884c\u4e8e\u5b50\u7ebf\u7a0b\u6808\u4e2d，\u901a\u8fc7\u6761\u4ef6\u53d8\u91cf\u5b9e\u73b0\u9ad8\u6548\u7684\u4efb\u52a1\u7b49\u5f85\u4e0e\u5524\u9192\u3002
\n *\/
\n void ThreadRoutine()
\n {
\n char name[64];
\n pthread_getname_np(pthread_self(), name, sizeof(name));
\n while(true)
\n {
\n T task; \/\/ \u4efb\u52a1\u5bf9\u8c61
\n \/\/ \u4e34\u754c\u533a\u4f5c\u7528\u57df：\u786e\u4fdd\u9501\u7684\u6301\u6709\u65f6\u95f4\u6700\u77ed\u5316
\n {
\n LockGuard lockGuard(&_mutex); \/\/ \u52a0\u9501\u4fdd\u62a4<\/p>\n
\n \/**
\n * \u6df1\u5ea6\u89e3\u6790：
\n * \u6b64\u5904\u7684 while \u5faa\u73af\u4e0d\u4ec5\u89e3\u51b3\u4e86\u201c\u865a\u5047\u5524\u9192\u201d，\u8fd8\u914d\u5408\u5355\u4f8b\u6a21\u5f0f
\n * \u786e\u4fdd\u4e86\u591a\u4e2a\u5b50\u7ebf\u7a0b\u5728\u7ade\u4e89\u552f\u4e00\u4efb\u52a1\u961f\u5217\u65f6\u7684\u903b\u8f91\u4e25\u5bc6\u6027\u3002
\n *\/
\n while(IsEmptyQueue() && _isrunning) \/\/ \u9632\u6b62\u4f2a\u5524\u9192
\n {
\n LOG(LogLevel::DEBUG) << "\u6ca1\u6709\u4efb\u52a1,\u7ebf\u7a0b\u4f11\u7720: " << "|" << name << "|";
\n _sleeper_cnt++;
\n _cond.Wait(_mutex); \/\/ \u6838\u5fc3：\u91ca\u653e\u9501 -> \u6302\u8d77 -> \u88ab\u5524\u9192 -> \u91cd\u83b7\u9501
\n _sleeper_cnt–;
\n LOG(LogLevel::DEBUG) << "\u6709\u4efb\u52a1,\u7ebf\u7a0b\u5524\u9192: " << "|" << name << "|";
\n }<\/p>\n
\n if(IsEmptyQueue() && !_isrunning)
\n {
\n LOG(LogLevel::INFO) << "Thread: " << name << "quit";
\n break;
\n }<\/p>\n
\n task = PopHelper();
\n }
\n \/\/ \u4efb\u52a1\u6267\u884c\u653e\u5728\u9501\u5916，\u8fd9\u662f\u5b9e\u73b0\u771f\u6b63\u5e76\u53d1\u3001\u907f\u514d\u7ebf\u7a0b\u6c60\u9000\u5316\u4e3a\u5355\u7ebf\u7a0b\u7684\u5173\u952e
\n task();
\n }
\n }<\/p>\n
\nprivate:
\n ThreadPool(int num = gDefaultCnt): _num(num), _isrunning(false), _sleeper_cnt(0)
\n {
\n for(int i = 0; i < num; i++)
\n {
\n \/\/ \u5229\u7528lambda\u8868\u8fbe\u5f0f\u6355\u6349this\u6307\u9488,\u4e0d\u7136\u4f1a\u51fa\u73b0\u53c2\u6570\u4e0d\u5339\u914d\u7684\u95ee\u9898
\n \/\/ \u8ddfThread.hpp\u4e2d\u6709\u5173\u7cfb
\n _threads.emplace_back([this](){
\n this->ThreadRoutine();
\n });
\n }
\n }<\/p>\n
\n \/**
\n * \u8865\u5145\u5efa\u8bae：
\n * \u867d\u7136\u8fd9\u91cc\u7528\u4e86 = default，\u4f46\u5728\u6807\u51c6\u7684\u5355\u4f8b\u6a21\u5f0f\u4e2d，
\n * \u62f7\u8d1d\u6784\u9020\u548c\u8d4b\u503c\u8fd0\u7b97\u7b26\u901a\u5e38\u5e94\u8be5\u8bbe\u4e3a = delete，\u4ee5\u9632\u6b62\u5b9e\u4f8b\u88ab\u201c\u514b\u9686\u201d\u3002
\n *\/
\n ThreadPool(const ThreadPool<T>& ) = delete;
\n ThreadPool<T>& operator =(const ThreadPool<T>&) = delete;<\/p>\n
\n \/\/ \u5b9a\u4e49\u6210\u9759\u6001\u7684：\u5168\u5c40\u552f\u4e00\u8bbf\u95ee\u70b9
\n \/**
\n * @brief \u83b7\u53d6\u5355\u4f8b\u5bf9\u8c61\u7684\u9759\u6001\u63a5\u53e3
\n * \u91c7\u7528\u4e86\u201c\u53cc\u68c0\u67e5\u9501 (Double-Checked Locking)\u201d\u673a\u5236\u3002
\n *\/
\n static ThreadPool<T>* GetInstance()
\n {
\n \/\/ \u7b2c\u4e00\u5c42\u5224\u65ad：\u4e3a\u4e86\u63d0\u9ad8\u6027\u80fd\u3002\u5982\u679c\u5b9e\u4f8b\u5df2\u5b58\u5728，\u76f4\u63a5\u8fd4\u56de，\u907f\u514d\u4e0d\u5fc5\u8981\u7684\u52a0\u9501\u5f00\u9500\u3002
\n if(_instance == nullptr)
\n {
\n \/\/ \u52a0\u9501：\u4fdd\u8bc1\u521b\u5efa\u5b9e\u4f8b\u8fc7\u7a0b\u7684\u539f\u5b50\u6027，\u9632\u6b62\u591a\u4e2a\u7ebf\u7a0b\u540c\u65f6\u6267\u884c new \u64cd\u4f5c
\n LockGuard lockGuard(&_signalton_lock);<\/p>\n
\n \/\/ \u786e\u8ba4\u5728\u6b64\u671f\u95f4\u6ca1\u6709\u5176\u4ed6\u7ebf\u7a0b\u63d0\u524d\u521b\u5efa\u4e86\u5b9e\u4f8b\u3002
\n if(_instance == nullptr)
\n {
\n LOG(LogLevel::DEBUG) << "\u9996\u6b21\u521b\u5efa,\u521b\u5efa\u6210\u529f" ;
\n _instance = new ThreadPool<T>(); \/\/ \u53ea\u4f1a\u521b\u5efa\u4e00\u6b21
\n _instance->Start(); \/\/ \u521b\u5efa\u51fa\u6765\u8fd0\u884c\u4e00\u6b21<\/p>\n
\n }
\n return _instance;
\n }<\/p>\n
\n void Start()
\n {
\n LockGuard lockGuard(&_mutex);
\n if(_isrunning)
\n return;
\n _isrunning = true;
\n for(auto& thread: _threads)
\n thread.start();
\n }<\/p>\n
\n void Enqueue(const T& task)
\n {
\n LockGuard lockGuard(&_mutex);
\n if(!_isrunning) \/\/ \u5982\u679c\u5f53\u524d\u5904\u4e8e\u505c\u6b62\u72b6\u6001,\u7981\u6b62\u7ee7\u7eed\u52a0\u4efb\u52a1
\n return;
\n _queue.push(task);<\/p>\n
\n \/\/ \u4f18\u5316\u7b56\u7565：\u53ea\u6709\u5b58\u5728\u6b63\u5728\u7761\u89c9\u7684\u5de5\u4eba\u624d\u53d1\u901a\u77e5
\n if(_sleeper_cnt > 0)
\n _cond.NotifyOne();
\n }<\/p>\n
\n void Stop()
\n {
\n LockGuard lockGuard(&_mutex);
\n if(_isrunning)
\n {
\n LOG(LogLevel::DEBUG) << "\u5173\u95ed\u7ebf\u7a0b\u6c60";
\n _isrunning = false; \/\/ \u6539\u53d8\u72b6\u6001，\u4f5c\u4e3a ThreadRoutine \u9000\u51fa\u7684\u89e6\u53d1\u4fe1\u53f7<\/p>\n
\n if(_sleeper_cnt > 0)
\n _cond.NotifyAll();
\n }
\n }<\/p>\n
\n void Wait()
\n {
\n \/\/ join \u64cd\u4f5c\u672c\u8eab\u963b\u585e，\u4e14\u4e0d\u6d89\u53ca\u4e34\u754c\u8d44\u6e90\u4fee\u6539，\u6545\u65e0\u9700\u52a0\u9501
\n for(auto& thread: _threads)
\n thread.join();
\n }<\/p>\n
\n {}<\/p>\n
\n \/\/ \u7ebf\u7a0b\u6c60\u7ba1\u7406\u7ec4\u4ef6
\n std::vector<Thread> _threads; \/\/ \u7ba1\u7406\u7ebf\u7a0b\u5bf9\u8c61\u7684\u5bb9\u5668
\n int _num; \/\/ \u7ebf\u7a0b\u6c60\u89c4\u6a21
\n bool _isrunning; \/\/ \u5168\u5c40\u751f\u547d\u5468\u671f\u5f00\u5173
\n int _sleeper_cnt; \/\/ \u8bb0\u5f55\u5f53\u524d\u7a7a\u95f2\u5de5\u4eba\u7684\u6570\u91cf<\/p>\n
\n Mutex _mutex; \/\/ \u4fdd\u62a4\u4efb\u52a1\u961f\u5217\u7684\u4e92\u65a5\u9501
\n Cond _cond; \/\/ \u534f\u8c03\u751f\u4ea7\/\u6d88\u8d39\u8282\u594f\u7684\u6761\u4ef6\u53d8\u91cf<\/p>\n
\n static ThreadPool<T> *_instance; \/\/ \u5168\u5c40\u552f\u4e00\u5b9e\u4f8b\u6307\u9488
\n static Mutex _signalton_lock; \/\/ \u4fdd\u62a4\u5355\u4f8b\u5b9e\u4f8b\u5316\u7684\u9759\u6001\u9501
\n};<\/p>\n
\n\/\/ \u9759\u6001\u6307\u9488\u5728 main \u8fd0\u884c\u524d\u521d\u59cb\u5316\u4e3a null，\u4fdd\u8bc1 GetInstance \u7684\u903b\u8f91\u8d77\u70b9\u6b63\u786e\u3002
\ntemplate<typename T>
\nThreadPool<T>* ThreadPool<T>::_instance = nullptr;<\/p>\n
\nMutex ThreadPool<T>::_signalton_lock;<\/p>\n4.3 \u57fa\u4e8e\u7ebf\u7a0b\u6c60\u7684 TCP Echo \u670d\u52a1\u5668\u5b9e\u73b0<\/h4>\n
4.3.1 \u670d\u52a1\u5668\u6838\u5fc3\u5b9e\u73b0（TcpEchoServer.hpp）<\/h5>\n
\n#define __TCP__ECHOSERVER__HPP<\/p>\n
\n#include <cstdint>
\n#include <pthread.h>
\n#include <string>
\n#include <string.h>
\n#include <unistd.h>
\n#include <sys\/wait.h>
\n#include <functional><\/p>\n
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include "InetAddr.hpp"
\n#include "Logger.hpp"
\n#include "ThreadPool.hpp"
\nusing namespace LogModule;<\/p>\n
\nstatic const int gbacklog = 32;<\/p>\n
\n\/\/ \u67b6\u6784\u89e3\u6790：\u5229\u7528 C++11 \u7684 std::function \u5c06\u4e1a\u52a1\u903b\u8f91\u7edf\u4e00\u5c01\u88c5\u6210\u65e0\u53c2\u65e0\u8fd4\u56de\u503c\u7684\u53ef\u8c03\u7528\u5bf9\u8c61\u3002
\n\/\/ \u8fd9\u6837\u7ebf\u7a0b\u6c60\u5185\u90e8\u7684\u7ebf\u7a0b\u53ea\u9700\u65e0\u8111\u6267\u884c task_t()，\u5b9e\u73b0\u4e86\u201c\u4efb\u52a1\u6d3e\u53d1\u201d\u4e0e\u201c\u4efb\u52a1\u6267\u884c\u201d\u7684\u5b8c\u5168\u89e3\u8026\u3002
\nusing task_t = std::function<void()>;<\/p>\n
\n{
\nprivate:
\n \/\/ sockfd: \u65e2\u53ef\u4ee5\u652f\u6301\u8bfb，\u53c8\u53ef\u4ee5\u652f\u6301\u5199, TCP socket\u4e5f\u662f\u5168\u53cc\u5de5\u7684.
\n \/\/ \u8fd9\u662f\u7531\u7ebf\u7a0b\u6c60\u4e2d\u67d0\u4e2a\u5177\u4f53\u7684\u5de5\u4f5c\u7ebf\u7a0b（Worker Thread）\u6765\u6267\u884c\u7684\u51fd\u6570
\n void Service(int sockfd, InetAddr client)
\n {
\n char name[128];
\n \/\/ \u83b7\u53d6\u5f53\u524d\u6267\u884c\u6b64\u4efb\u52a1\u7684\u7ebf\u7a0b\u540d\u79f0（\u5982 "Worker-1", "Worker-2" \u7b49）
\n \/\/ \u4f5c\u7528：\u5728\u65e5\u5fd7\u4e2d\u6253\u5370\u51fa\u7ebf\u7a0b\u540d，\u65b9\u4fbf\u8ffd\u8e2a\u591a\u7ebf\u7a0b\u5e76\u53d1\u72b6\u6001\u4e0b，\u662f\u54ea\u4e2a\u5e95\u5c42\u7ebf\u7a0b\u670d\u52a1\u4e86\u54ea\u4e2a\u5ba2\u6237\u7aef\u3002
\n pthread_getname_np(pthread_self(), name, sizeof(name));<\/p>\n
\n \/\/ \u6211\u4eec\u7684\u7ebf\u7a0b\u6c60\u7248\u672c\u4e0d\u9002\u5408\u957f\u8fde\u63a5\u670d\u52a1，\u8fd9\u91cc\u6539\u6210\u77ed\u8fde\u63a5
\n \/\/ \u6838\u5fc3\u75db\u70b9：\u5982\u679c\u7ee7\u7eed\u4fdd\u7559\u6b7b\u5faa\u73af\u7684\u957f\u8fde\u63a5，\u5f53\u5e76\u53d1\u8fde\u63a5\u6570\u8d85\u8fc7\u7ebf\u7a0b\u6c60\u5bb9\u91cf（\u5982 5 \u4e2a）\u65f6，
\n \/\/ \u6240\u6709\u7ebf\u7a0b\u90fd\u4f1a\u5361\u5728\u5faa\u73af\u91cc\u51fa\u4e0d\u6765，\u5bfc\u81f4\u7b2c 6 \u4e2a\u53ca\u4ee5\u540e\u7684\u5ba2\u6237\u7aef\u6c38\u8fdc\u5f97\u4e0d\u5230\u54cd\u5e94（\u5373\u88ab\u201c\u997f\u6b7b\u201d）\u3002<\/p>\n
\n \/\/ while (true)
\n \/\/ {
\n char inbuffer[1024];<\/p>\n
\n \/\/ TCP \u9762\u5411\u5b57\u8282\u6d41，\u6b64\u65f6\u53ea\u8bfb\u53d6\u4e00\u6b21\u8bf7\u6c42\u5305
\n int n = read(sockfd, inbuffer, sizeof(inbuffer) – 1);
\n if (n > 0) {
\n inbuffer[n] = 0; \/\/ \u624b\u52a8\u8f6c\u6362\u4e3a C \u98ce\u683c\u5b57\u7b26\u4e32，\u9632\u6b62\u6253\u5370\u8d8a\u754c\u4e71\u7801
\n LOG(LogLevel::INFO) << name << " : " << client.StringAddress() << " say# " << inbuffer;
\n } else if (n == 0) {
\n LOG(LogLevel::INFO) << client.StringAddress()
\n << " close sockfd: " << sockfd << ", me too!";
\n } else {
\n LOG(LogLevel::ERROR) << "read socket error";
\n }<\/p>\n
\n std::string echo_string = "server echo# ";
\n echo_string += inbuffer;<\/p>\n
\n int m = write(sockfd, echo_string.c_str(), echo_string.size());
\n if (m < 0) {
\n LOG(LogLevel::ERROR) << "write socket error";
\n }
\n \/\/ }<\/p>\n
\n \/\/ \u4e00\u65b9\u9762\u91ca\u653e\u4e86 Linux \u7cfb\u7edf\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u8d44\u6e90，\u53e6\u4e00\u65b9\u9762\u4e5f\u544a\u77e5\u5ba2\u6237\u7aef\u672c\u6b21\u670d\u52a1\u5df2\u7ed3\u675f\u3002
\n close(sockfd);
\n }
\npublic:
\n TcpEchoServer(uint16_t port = gdefaultport): _port(port), _listensockfd(-1)
\n {}
\n void Init()
\n {
\n \/\/ 1. \u521b\u5efa\u5957\u63a5\u5b57
\n \/\/ AF_INET: IPv4 \u7f51\u7edc\u534f\u8bae; SOCK_STREAM: TCP \u5b57\u8282\u6d41\u4f20\u8f93\u534f\u8bae
\n _listensockfd = socket(AF_INET, SOCK_STREAM, 0); \/\/ \u8bbe\u7f6e\u62100\u5c31\u53ef\u4ee5\u4e86
\n if(_listensockfd < 0)
\n {
\n LOG(LogLevel::FATAL) << "create socket error: " << _listensockfd;
\n exit(2);
\n }
\n LOG(LogLevel::INFO) << "create socket success: " << _listensockfd;<\/p>\n
\n \/\/ \u6211\u4eec\u8fd9\u91cc\u662f\u53ef\u4ee5\u76f4\u63a5\u4f7f\u7528\u6211\u4eec\u7684InetAddr\u7684,\u4f46\u662f\u6211\u4eec\u540e\u9762\u518d\u7528
\n \/\/ \u7ed1\u5b9a\u672c\u673a\u7684 IP \u5730\u5740\u548c\u6307\u5b9a\u7684\u7aef\u53e3\u53f7，\u4e3a\u670d\u52a1\u5668\u786e\u5b9a\u552f\u4e00\u7684\u7f51\u7edc\u8eab\u4efd
\n struct sockaddr_in local;
\n socklen_t len = sizeof(local);
\n memset(&local, 0, len);
\n local.sin_family = AF_INET;
\n local.sin_port = htons(_port); \/\/ \u4e3b\u673a\u5b57\u8282\u5e8f -> \u7f51\u7edc\u5b57\u8282\u5e8f (\u5904\u7406\u7aef\u53e3)
\n local.sin_addr.s_addr = htonl(INADDR_ANY); \/\/ INADDR_ANY: \u76d1\u542c\u672c\u673a\u6240\u6709\u7f51\u5361\u63a5\u6536\u5230\u7684\u6570\u636e<\/p>\n
\n if(n < 0)
\n {
\n LOG(LogLevel::FATAL) << "bind error: " << _listensockfd;
\n exit(3); \/\/ \u5e38\u89c1\u9519\u8bef\u539f\u56e0：\u8be5\u7aef\u53e3\u5df2\u88ab\u5176\u4ed6\u8fdb\u7a0b\u5360\u7528
\n }
\n LOG(LogLevel::INFO) << "bind success: " << _listensockfd;<\/p>\n
\n \/\/ \u5c06\u5957\u63a5\u5b57\u4ece\u4e3b\u52a8\u72b6\u6001\u8f6c\u4e3a\u88ab\u52a8\u72b6\u6001，\u5141\u8bb8\u5e95\u5c42\u64cd\u4f5c\u7cfb\u7edf\u63a5\u6536\u4f20\u5165\u7684\u8fde\u63a5\u8bf7\u6c42\u5e76\u653e\u5165\u5168\u8fde\u63a5\u961f\u5217
\n n = listen(_listensockfd, gbacklog);
\n if(n < 0)
\n {
\n LOG(LogLevel::FATAL) << "listen error: " << _listensockfd;
\n exit(3);
\n }
\n LOG(LogLevel::INFO) << "listen success: " << _listensockfd;
\n }
\n void Start()
\n {
\n \/\/ \u591a\u8fdb\u7a0b\u7248\u672c\u7b49\u5f85\u7684\u6700\u4f73\u5b9e\u8df5
\n \/\/ signal(SIGCHLD, SIG_IGN); \/\/ \u5728\u5f53\u524d\u57fa\u4e8e\u7ebf\u7a0b\u6c60\u7684\u67b6\u6784\u4e2d，\u6211\u4eec\u4e0d\u521b\u5efa\u5b50\u8fdb\u7a0b，\u6240\u4ee5\u4e0d\u9700\u8981\u5904\u7406\u6b64\u4fe1\u53f7<\/p>\n
\n \/\/ \u5b83\u53d8\u6210\u4e86\u7eaf\u7cb9\u7684\u201c\u4efb\u52a1\u751f\u4ea7\u8005\u201d，\u53ea\u8d1f\u8d23\u63a5\u5f85\u65b0\u5ba2\u4eba，\u5177\u4f53\u7684\u670d\u52a1\u7ec6\u8282\u7edf\u7edf\u4ea4\u7ed9\u7ebf\u7a0b\u6c60\u5904\u7406\u3002
\n while(true)
\n {
\n struct sockaddr_in clientaddr;
\n socklen_t len = sizeof(clientaddr);
\n \/\/ accept \u5c5e\u4e8e\u963b\u585e\u5f0f\u8c03\u7528，\u4ece\u5e95\u5c42\u7684\u5168\u8fde\u63a5\u961f\u5217\u4e2d\u53d6\u51fa\u4e00\u4e2a\u5efa\u7acb\u597d\u4e09\u6b21\u63e1\u624b\u7684\u8fde\u63a5
\n int sockfd = accept(_listensockfd, (struct sockaddr *)&clientaddr, &len);
\n if (sockfd < 0)
\n {
\n LOG(LogLevel::WARNING) << "accept error";
\n continue;
\n }
\n \/\/ \u7f51\u7edc\u8f6c\u4e3b\u673a，\u65b9\u4fbf\u540e\u7eed\u6253\u5370\u53cb\u597d\u7684\u5ba2\u6237\u7aef IP \u548c Port
\n InetAddr clientaddress(clientaddr);
\n LOG(LogLevel::INFO) << "get a new link: " << clientaddress.StringAddress() << " sockfd: " << sockfd;<\/p>\n
\n \/\/ \u7ebf\u7a0b\u6c60\u7248\u672c：\u5c06\u4efb\u52a1\u5c01\u88c5\u4e3a Lambda \u8868\u8fbe\u5f0f\u5e76\u63a8\u5165\u7ebf\u7a0b\u6c60\u7684\u4efb\u52a1\u961f\u5217\u4e2d
\n \/\/ \u6613\u9519\u70b9\u5206\u6790：\u8fd9\u91cc\u3010\u5fc5\u987b\u3011\u4f7f\u7528\u503c\u6355\u83b7 [sockfd, clientaddress, this]！
\n \/\/ \u5982\u679c\u4f7f\u7528\u5f15\u7528\u6355\u83b7 [&]，\u5f53\u4e3b\u7ebf\u7a0b\u7acb\u523b\u8fdb\u5165\u4e0b\u4e00\u6b21 while \u5faa\u73af\u5e76\u91cd\u65b0 accept \u65f6，
\n \/\/ \u5c40\u90e8\u7684 sockfd \u548c clientaddr \u4f1a\u88ab\u8986\u76d6\u6216\u9500\u6bc1，\u5bfc\u81f4\u7ebf\u7a0b\u6c60\u91cc\u5ef6\u540e\u6267\u884c\u7684\u4efb\u52a1\u62ff\u5230\u91ce\u6570\u636e\u3002
\n ThreadPool<task_t>::GetInstance()->Enqueue([sockfd, clientaddress, this](){
\n \/\/ \u901a\u8fc7 this \u6307\u9488\u8c03\u7528\u5f53\u524d\u7c7b\u7684\u79c1\u6709\u6210\u5458\u51fd\u6570 Service
\n Service(sockfd, clientaddress);
\n });
\n }
\n }
\n ~TcpEchoServer(){}
\nprivate:
\n uint16_t _port;
\n int _listensockfd;
\n};
\n#endif<\/p>\n\n
4.4 \u7ebf\u7a0b\u6c60\u7248\u672c\u7684\u6838\u5fc3\u4f18\u52bf<\/h4>\n
\n
\n\u4e94.\u00a0\u6838\u5fc3\u9762\u8bd5\u8003\u70b9\u4e0e\u5b9e\u6218\u8e29\u5751\u6307\u5357（QA\u95ee\u7b54\u7248）<\/h3>\n
5.1 \u9ad8\u9891\u9762\u8bd5\u8003\u70b9<\/h4>\n
\n
\n
\n
\n
\n
\n
\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/07\/20260725205849-6a65238976229.png\")
<\/p>\n5.2 \u5b9e\u6218\u8e29\u5751\u4e0e\u907f\u5751\u65b9\u6848<\/h4>\n
\n
\n
\n
\n
\n
\n\u7ed3\u8bed<\/h3>\n
\n\u2744\ufe0f\u4e2a\u4eba\u4e13\u680f：\u300aC\u8bed\u8a00\u300b\u300aLeetCode\u5237\u9898\u96c6\u300b\u300a\u6570\u636e\u7ed3\u6784-\u521d\u9636\u300b\u300aC\u77e5\u8bc6\u5206\u4eab\u300b
\n\u300a\u4f18\u9009\u7b97\u6cd5\u6307\u5357-\u5fc5\u5237\u7ecf\u5178100\u9898\u300b\u300aLinux\u64cd\u4f5c\u7cfb\u7edf\u300b:\u4ece\u5165\u95e8\u5230\u5165\u9b54
\n\u300aGit\u6df1\u5ea6\u89e3\u6790\u300b:\u7248\u672c\u7ba1\u7406\u5b9e\u6218\u5168\u89e3\u00a0\u300aQt \u6781\u5883\u67b6\u6784\u300b
\n🌟\u5fc3\u5411\u5f80\u4e4b\u884c\u5fc5\u80fd 🎥Cx330🌸\u7684\u7b80\u4ecb： \u76ee\u5f55
\n\u524d\u8a00
\n\u4e00.\u00a0TCP\u00a0\u670d\u52a1\u5668\u6838\u5fc3\u6a21\u578b\u6f14\u8fdb
\n\u4e8c. \u81ea\u7814\u57fa\u7840\u7ec4<\/p>\n","protected":false},"author":2,"featured_media":83815,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[205,43,188,78,44],"topic":[],"class_list":["post-83822","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-tcp-ip","tag-43","tag-188","tag-78","tag-44"],"yoast_head":"\n