![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204627-68055d23219d5.png\")
<\/p>\n\u76ee\u5f55<\/p>\n
\n
1. \u7f51\u7edc\u804a\u5929\u5ba4\u7684\u610f\u4e49<\/p>\n
2. \u7f51\u7edc\u804a\u5929\u5ba4\u4e86\u89e3<\/p>\n
2.1. \u7f51\u7edc\u804a\u5929\u5ba4\u6a21\u5757\u5206\u6790<\/p>\n
2.2. \u76ee\u6807<\/p>\n
3. \u57fa\u672c\u6846\u67b6<\/p>\n
3.1. \u6587\u4ef6\u57fa\u672c\u6846\u67b6<\/p>\n
3.2. \u8bbe\u8ba1\u56de\u8c03\u51fd\u6570\u89e3\u8026<\/p>\n
4. Route.hpp \u6a21\u5757(\u6d88\u606f\u8f6c\u53d1)<\/p>\n
4.1. \u5934\u6587\u4ef6\u5305\u542b<\/p>\n
4.2. \u57fa\u672c\u7c7b\u6846\u67b6<\/p>\n
4.3. Route::Forward() \u8f6c\u53d1<\/p>\n
4.3.1. \u51fd\u6570\u5934\u8bbe\u8ba1<\/p>\n
4.3.2. \u7ef4\u62a4\u7528\u6237\u5217\u8868<\/p>\n
4.3.3. \u5ba2\u6237\u9000\u51fa\u804a\u5929<\/p>\n
4.3.4. \u6d88\u606f\u8f6c\u53d1 -> \u7ebf\u7a0b\u6c60<\/p>\n
4.3.4.1. \u5f15\u5165\u7ebf\u7a0b\u6c60\u4ee3\u7801<\/p>\n
4.3.4.2. \u8f6c\u53d1\u4efb\u52a1<\/p>\n
4.4. \u8f6c\u53d1\u6a21\u5757\u4e0e\u670d\u52a1\u5668\u6a21\u5757\u5173\u8054<\/p>\n
4.5. \u6d4b\u8bd5: \u591a\u4e2a\u5ba2\u6237\u7aef\u4e0e\u4e00\u4e2a\u670d\u52a1\u7aef<\/p>\n
5. \u5ba2\u6237\u7aef\u8bfb\u5199\u5e76\u884c<\/p>\n
5.1. \u5ba2\u6237\u7aef\u521d\u59cb\u5316<\/p>\n
5.2. \u53d1\u6d88\u606f\u5ba2\u6237\u7aef\u4e0e\u6536\u6d88\u606f\u5ba2\u6237\u7aef\u89e3\u8026\u5408<\/p>\n
5.2.1. \u6536\u6d88\u606f<\/p>\n
5.2.2. \u53d1\u6d88\u606f<\/p>\n
6. \u53c2\u8003\u4ee3\u7801<\/p>\n
6.1. \u6838\u5fc3\u4ee3\u7801<\/p>\n
6.2. \u5176\u4ed6\u4ee3\u7801<\/p>\n
\u4e3a\u4ec0\u4e48\u8981\u5199\u4e00\u4e2a\u7f51\u7edc\u804a\u5929\u5ba4\u5462? \u524d\u9762\u90fd\u5199\u8fc7\u5b57\u5178\u90a3\u4e2a\u4f8b\u5b50\u4e86.<\/p>\n
\u610f\u4e49\u5728\u4e8e: \u7f51\u7edc\u804a\u5929\u5ba4\u7684\u610f\u4e49\u5728\u4e8e\u591a\u8fdb\u7a0b, \u5f15\u5165\u4f7f\u7528\u7ebf\u7a0b\u6c60.<\/p>\n
\n
<\/p>\n
\u8981\u6c42\u4e0e\u5b57\u5178\u670d\u52a1\u4e00\u6837, \u8981\u6c42\u5404\u4e2a\u6a21\u5757\u89e3\u8026\u5408.<\/p>\n
\u4e1a\u52a1\u903b\u8f91 \u4e0e IO \u903b\u8f91\u89e3\u8026.<\/p>\n
\u540c\u6837\u6211\u4eec\u628a\u4e4b\u524d\u5199\u7684 echo_server \u76f4\u63a5 CV \u5230\u6211\u4eec\u7684 chat_server \u5373\u53ef.<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204627-68055d236d0e7.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204627-68055d2399a2b.png\")
<\/p>\n
\u89e3\u91ca\u4e00\u4e0b\u5404\u4e2a\u53c2\u6570\u7684\u542b\u4e49:<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204627-68055d23c0fd1.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204627-68055d23e8be1.png\")
<\/p>\n
\n
\u89e3\u8026\u5408: \u628a\u670d\u52a1\u53d1\u6d88\u606f\u7ed9\u5230\u8f6c\u53d1\u6a21\u5757, \u6240\u4ee5\u4e0b\u9762\u8fd9\u90e8\u5206\u662f\u4e0d\u8981\u4e86.<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204628-68055d242760f.png\")
<\/p>\n
\u53d8\u6210:<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204628-68055d2465a4f.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204628-68055d2494ce7.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204628-68055d24bc2d3.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204628-68055d24e4e30.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204629-68055d251ab6e.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204629-68055d2546321.png\")
<\/p>\n
\n
\u540c\u65f6, \u8fd8\u9700\u8981\u6ce8\u610f\u5728 InetAddr \u5f53\u4e2d\u53bb\u91cd\u8f7d\u6bd4\u8f83\u8fd0\u7b97\u7b26.<\/p>\n
\u5982\u679c\u53ea\u4fdd\u8bc1 ip \u7684\u552f\u4e00\u6027, \u6240\u4ee5\u4e00\u4e2a\u4e3b\u673a\u4e0b\u7684\u4e00\u4e2a ip \u53ea\u80fd\u542f\u52a8\u4e00\u4e2a\u5ba2\u6237\u7aef, \u6240\u4ee5\u4e0d\u592a\u597d(\u6b63\u5e38\u6765\u8bb2\u662f ip \u552f\u4e00\u7684), \u6211\u4eec\u8fd9\u91cc\u4fdd\u8bc1\u7aef\u53e3\u552f\u4e00\u5373\u53ef.<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204629-68055d25798a1.png\")
<\/p>\n
\u6211\u4eec\u7ea6\u5b9a: \u5047\u8bbe message == "QUIT", \u6211\u4eec\u79fb\u9664 online_user \u4e2d\u7684\u5ba2\u6237. \u5e76\u4e14\u628a\u8fd9\u4e2a\u6d88\u606f\u540c\u6837\u505a\u8f6c\u53d1\u5904\u7406(\u544a\u77e5\u6240\u6709\u4eba\u6709\u4e2a\u4eba\u8d70\u4e86~).<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204629-68055d25adb86.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204629-68055d25e4e60.png\")
<\/p>\n
\u6ce8\u610f: \u627e\u5230\u4e86\u4e00\u5b9a\u8981\u7acb\u523b break, \u8fd9\u4e2a\u5730\u65b9\u5b58\u5728\u8fed\u4ee3\u5668\u5931\u6548\u95ee\u9898.<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204630-68055d261c2d4.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204630-68055d2655293.png\")
<\/p>\n
\u5b57\u8282\u5e8f\u5217\u95ee\u9898\u53ef\u4ee5\u7528 sockaddr \u76f4\u63a5\u89e3\u51b3:<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204630-68055d2684e1c.png\")
<\/p>\n
\n
\u4e0b\u9762\u5b9e\u9645\u4e0a\u8fd8\u6709\u4fe9\u6d3b:<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204630-68055d26af830.png\")
<\/p>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250420204630-68055d26daeaa.png\")
<\/p>\n
\n
![\"\"](\"2025-04-21d33v1ins0va.png\")
<\/p>\n
\u5565\u610f\u601d\u5462? \u4f60\u8fd9\u6837\u76f4\u63a5\u8c03\u7528, \u662f\u4e3b\u7ebf\u7a0b\u505a\u7684, \u6548\u7387\u4e0d\u9ad8, \u56e0\u6b64\u6211\u4eec\u8003\u8651\u628a\u8fd9\u4e2a ForwardHelper \u4efb\u52a1\u5916\u5305\u51fa\u53bb, \u8ba9\u7ebf\u7a0b\u6c60\u7684\u7ebf\u7a0b\u6765\u8fdb\u884c\u5904\u7406, \u800c\u6211\u4eec\u7684\u4e3b\u7ebf\u7a0b\u5219\u6709\u7a7a\u95f2\u53bb\u5904\u7406\u81ea\u5df1\u7684\u4e8b\u60c5.<\/p>\n
\n
\u5305\u88c5\u4efb\u52a1:<\/p>\n
\n
![\"\"](\"2025-04-21l412wikapov.png\")
<\/p>\n
\u6784\u5efa\u4efb\u52a1:<\/p>\n
\n
![\"\"](\"2025-04-21fo0f2hjzp3w.png\")
<\/p>\n
\u83b7\u53d6\u7ebf\u7a0b\u6c60\u5bf9\u8c61\u5e76\u5165\u7ebf\u7a0b\u6c60\u4efb\u52a1\u961f\u5217:<\/p>\n
\n
![\"\"](\"2025-04-210umf4d20qem.png\")
<\/p>\n
\u56e0\u4e3a\u7ebf\u7a0b\u6c60\u4e2d\u7684 func_t \u7c7b\u578b\u5df2\u7ecf\u5360\u7528\u4e86, \u56e0\u6b64\u6211\u4eec\u7ed9 UdpServer.hpp \u4e2d\u7684\u5305\u88c5\u5668\u6539\u4e00\u4e0b\u540d\u5b57.<\/p>\n
\n
![\"\"](\"2025-04-21fnoozzmzrsb.png\")
<\/p>\n
\u670d\u52a1\u7aef\u5bf9\u8c61:<\/p>\n
\n
![\"\"](\"2025-04-21ohiurv51vwb.png\")
<\/p>\n
\u7ed1\u5b9a\u8f6c\u53d1\u6a21\u5757, \u5e76\u4e14\u5173\u8054\u5230\u670d\u52a1\u5668:<\/p>\n
\n
![\"\"](\"2025-04-21jclwphsptff.png\")
<\/p>\n
\u5e26\u4e0a\u7ebf\u7a0b\u5e93\u8fdb\u884c\u7f16\u8bd1:<\/p>\n
\n
![\"\"](\"2025-04-212r5txh11xbk.png\")
<\/p>\n
\n
![\"\"](\"2025-04-21dq32li4wlyd.png\")
<\/p>\n
\u7528 ps -aL\u53ef\u4ee5\u67e5\u8be2\u5f53\u524d\u7684\u4e00\u4e2a\u7ebf\u7a0b\u542f\u52a8\u60c5\u51b5.<\/p>\n
\n
\u4e0b\u9762\u662f\u4e00\u4e9b\u65b9\u4fbf\u9a8c\u8bc1\u7684\u8c03\u8bd5\u6d88\u606f:<\/p>\n
\u76f4\u63a5\u770b\u6e90\u7801\u5427, \u6539\u7684\u6bd4\u8f83\u591a~<\/p>\n
\n
\u4f46\u662f\u53d1\u73b0\u4e86\u4e00\u4e2a\u5927\u95ee\u9898: \u5c31\u662f\u591a\u4e2a\u5ba2\u6237\u7aef\u5728\u8ddf\u670d\u52a1\u5668\u53bb\u4ea4\u4e92\u7684\u65f6\u5019, \u53ea\u8981\u4f60\u5ba2\u6237\u7aef\u4e0d\u8bf4\u8bdd, \u4f60\u5c31\u6536\u4e0d\u5230\u6d88\u606f, \u867d\u7136\u8bf4\u670d\u52a1\u5668\u628a\u6d88\u606f\u8f6c\u53d1\u4e86, \u8fd9\u5c31\u76f8\u5f53\u9006\u5929!<\/p>\n
\u56e0\u4e3a\u5ba2\u6237\u7aef\u963b\u585e\u5728\u53d1\u6d88\u606f\u5f53\u4e2d. \u4f60\u60f3\u63a5\u53d7\u6d88\u606f\u5c31\u5fc5\u987b\u53d1\u6d88\u606f, \u56e0\u4e3a\u662f\u963b\u585e\u72b6\u6001\u561b, \u8fd9\u5c31\u5f88\u5751\u7239. \u6240\u4ee5\u8bf4, \u6211\u4eec\u53ef\u4ee5\u7ed9\u6bcf\u4e2a\u5ba2\u6237\u7aef\u641e\u4e24\u4e2a\u7ebf\u7a0b, \u4e00\u4e2a\u8bfb\u4e00\u4e2a\u53d1\u6d88\u606f, \u4e24\u4e2a\u5e76\u884c\u8dd1\u8fd9\u6837\u7684\u8bdd\u53ef\u80fd\u4f1a\u6bd4\u8f83\u597d.<\/p>\n
\n
\n
![\"\"](\"2025-04-2124vpeda0jle.png\")
<\/p>\n
\u5ba2\u6237\u7aef\u52a0\u5165\u7ebf\u7a0b\u6a21\u5757:<\/p>\n
\n
![\"\"](\"2025-04-21erny0sw4gk3.png\")
<\/p>\n
\u521b\u5efa\u8bfb\u5199\u7ebf\u7a0b\u5e76\u4e14\u542f\u52a8:<\/p>\n
\n
![\"\"](\"2025-04-21qnityzq5pfv.png\")
<\/p>\n
\u4e3b\u7ebf\u7a0b\u8d1f\u8d23\u7b49\u5f85\u4e24\u4e2a\u7ebf\u7a0b\u5373\u53ef:<\/p>\n
\n
![\"\"](\"2025-04-21fgqcgvirbjp.png\")
<\/p>\n
\u6211\u4eec\u6536\u6d88\u606f\u7684\u7ebf\u7a0b\u9700\u8981\u7528\u5230\u5957\u63a5\u5b57, \u56e0\u6b64\u7ed9\u4ed6\u4f20\u8fc7\u53bb\u5373\u53ef, \u56e0\u4e3a\u6211\u4eec\u7684 thread \u81ea\u5df1\u5c01\u88c5\u7684\u7ebf\u7a0b\u5e93\u53ea\u8981\u6c42\u4e00\u4e2a\u53c2\u6570, \u6240\u4ee5\u6211\u4eec bind \u7ed9\u4ed6\u8fc7\u53bb\u5373\u53ef.<\/p>\n
\n
![\"\"](\"2025-04-213nnww1o25ir.png\")
<\/p>\n
\u5230\u4e86\u53d1\u6d88\u606f\u5462? \u53d1\u6d88\u606f\u7684\u7ebf\u7a0b\u9700\u8981\u5957\u63a5\u5b57, \u8fd8\u9700\u8981\u77e5\u9053\u670d\u52a1\u5668\u7684 ip + port. \u8fd9\u4e2a\u5730\u65b9\u8001\u5e08\u53c8\u628a\u547d\u4ee4\u884c\u53c2\u6570\u653e\u5230 main \u91cc\u4e86.<\/p>\n
\n
![\"\"](\"2025-04-21pvd2avjh5uu.png\")
<\/p>\n
\n
![\"\"](\"2025-04-21xzeglj1tfcd.png\")
<\/p>\n
\u4e0a\u9762 code \u7528\u7684\u662f cerr, \u662f\u65b9\u4fbf\u7528\u6765\u91cd\u5b9a\u5411\u6253\u5370\u5230\u4e24\u4e2a\u4e0d\u540c\u7ec8\u7aef\u770b\u6548\u679c\u7684.<\/p>\n
\n
![\"\"](\"2025-04-21bgrj3qrtgri.png\")
<\/p>\n
\n
\u5b9a\u4f4d\u4e00\u4e0b\u4e0d\u540c\u7684\u7ec8\u7aef\u53f7:<\/p>\n
\n
![\"\"](\"2025-04-21ekj0swt3zxe.png\")
<\/p>\n
\u5c06\u8fd9\u4e2a\u7a0b\u5e8f\u7684\u6807\u51c6\u9519\u8bef\u5168\u90e8\u91cd\u5b9a\u5411\u5230 0 \u53f7\u7ec8\u7aef.<\/p>\n
\n
![\"\"](\"2025-04-213byxm3iowcn.png\")
<\/p>\n
ip + port -> \u6807\u8bc6\u5ba2\u6237\u7aef\u7684\u552f\u4e00\u6027.<\/p>\n
#include "UdpServer.hpp"
\n#include "Route.hpp"<\/p>\n
#include <memory><\/p>\n
\/\/ .\/udp_server local-port
\n\/\/ .\/udp_server 8888
\nint main(int argc, char *argv[])
\n{
\n if(argc != 2)
\n {
\n std::cerr << "Usage: " << argv[0] << " local-port" << std::endl;
\n exit(0);
\n }
\n uint16_t port = std::stoi(argv[1]);<\/p>\n
EnableScreen();<\/p>\n
Route messageRoute; \/\/ \u5b9e\u4f8b\u5316\u8f6c\u53d1\u6a21\u5757<\/p>\n
service_t message_route = std::bind(&Route::Forward,\\\\
\n &messageRoute, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3);
\n \/\/ \u628a\u8f6c\u53d1\u6a21\u5757\u4e2d\u7684\u8f6c\u53d1\u51fd\u6570\u7ed9\u5230\u670d\u52a1\u5668\u7528\u6765\u7ed1\u5b9a\u5230\u4e00\u8d77. <\/p>\n
std::unique_ptr<UdpServer> usvr = std::make_unique<UdpServer>(message_route, port); \/\/C++14\u7684\u6807\u51c6
\n usvr->InitServer();
\n usvr->Start();
\n return 0;
\n}
\n#pragma once<\/p>\n
#include <iostream>
\n#include <unistd.h>
\n#include <string>
\n#include <cstring>
\n#include <functional>
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h><\/p>\n
#include "nocopy.hpp"
\n#include "Log.hpp"
\n#include "InetAddr.hpp"
\n\/*
\n* \u670d\u52a1\u5668\u7528\u6765\u8bfb\u53d6\u6570\u636e
\n* \u8bfb\u53d6\u7684\u6570\u636e\u6709\u4e24\u4e2a\u4e1c\u897f
\n* – \u7528\u6237\u53d1\u9001\u7684\u6570\u636e\/\u4fe1\u606f -> \u4ea4\u7ed9 [\u8def\u7531\u8f6c\u53d1\u6a21\u5757] \u8fdb\u884c\u5904\u7406.
\n* – \u7528\u6237\u672c\u8eab\u7684\u4fe1\u606f -> ip + port \u6784\u6210\u4e00\u4e2a \u5728\u7ebf\u7528\u6237\u5217\u8868.
\n* [\u8def\u7531\u8f6c\u53d1\u6a21\u5757] \u6839\u636e \u5728\u7ebf\u7528\u6237\u5217\u8868 \u6765\u8f6c\u53d1\u7ed9 \u6240\u6709\u4eba \u6d88\u606f.
\n* \u7ebf\u7a0b\u6c60\u5e2e\u52a9\u8def\u7531\u8f6c\u53d1\u6a21\u5757\u8fdb\u884c\u8f6c\u53d1. <\/p>\n
\u76ee\u6807: \u670d\u52a1\u5668, \u8f6c\u53d1\u6a21\u5757 \u4ee5\u53ca \u7ebf\u7a0b\u6c60 \u5168\u90e8\u89e3\u8026\u5408!
\n*\/
\nusing namespace log_ns;<\/p>\n
static const int gsockfd = -1;
\nstatic const uint16_t glocalport = 8888;<\/p>\n
enum
\n{
\n SOCKET_ERROR = 1,
\n BIND_ERROR
\n};<\/p>\n
using service_t = std::function<void(int, const std::string &message, InetAddr &who)>;
\n\/\/ \u8f6c\u53d1\u6a21\u5757\u7684\u51fd\u6570\u6307\u9488. -> \u5e2e\u52a9\u6211\u4eec\u670d\u52a1\u5668\u6765\u8f6c\u53d1\u6d88\u606f\u7684.
\n\/\/ \u53c2\u65701: \u4ece\u54ea\u4e2a\u5957\u63a5\u5b57\u53d1\u6d88\u606f?
\n\/\/ \u53c2\u65702: message -> \u8f6c\u53d1\u7684\u6d88\u606f\u5185\u5bb9
\n\/\/ \u53c2\u65703: \u8c01\u53d1\u7684\u8fd9\u4e2a\u6d88\u606f -> \u56e0\u4e3a\u9700\u8981\u7528\u5230\u7528\u6237\u7684ip + port\u6765\u6807\u8bc6\u7528\u6237\u7684\u552f\u4e00\u6027. <\/p>\n
\/\/ UdpServer user("192.1.1.1", 8899);
\n\/\/ \u4e00\u822c\u670d\u52a1\u5668\u4e3b\u8981\u662f\u7528\u6765\u8fdb\u884c\u7f51\u7edc\u6570\u636e\u8bfb\u53d6\u548c\u5199\u5165\u7684\u3002IO\u7684
\n\/\/ \u670d\u52a1\u5668IO\u903b\u8f91 \u548c \u4e1a\u52a1\u903b\u8f91 \u89e3\u8026
\nclass UdpServer : public nocopy
\n{
\npublic:
\n UdpServer(service_t func, uint16_t localport = glocalport)
\n : _func(func),
\n _sockfd(gsockfd),
\n _localport(localport),
\n _isrunning(false)
\n {
\n }
\n void InitServer()
\n {
\n \/\/ 1. \u521b\u5efasocket\u6587\u4ef6
\n _sockfd = ::socket(AF_INET, SOCK_DGRAM, 0);
\n if (_sockfd < 0)
\n {
\n LOG(FATAL, "socket error\\\\n");
\n exit(SOCKET_ERROR);
\n }
\n LOG(DEBUG, "socket create success, _sockfd: %d\\\\n", _sockfd); \/\/ 3<\/p>\n
\/\/ 2. bind
\n struct sockaddr_in local;
\n memset(&local, 0, sizeof(local));
\n local.sin_family = AF_INET;
\n local.sin_port = htons(_localport);
\n \/\/ local.sin_addr.s_addr = inet_addr(_localip.c_str()); \/\/ 1. \u9700\u89814\u5b57\u8282IP 2. \u9700\u8981\u7f51\u7edc\u5e8f\u5217\u7684IP — \u6682\u65f6
\n local.sin_addr.s_addr = INADDR_ANY; \/\/ \u670d\u52a1\u5668\u7aef，\u8fdb\u884c\u4efb\u610fIP\u5730\u5740\u7ed1\u5b9a<\/p>\n
int n = ::bind(_sockfd, (struct sockaddr *)&local, sizeof(local));
\n if (n < 0)
\n {
\n LOG(FATAL, "bind error\\\\n");
\n exit(BIND_ERROR);
\n }
\n LOG(DEBUG, "socket bind success\\\\n");
\n }
\n void Start()
\n {
\n _isrunning = true;
\n char message[1024];
\n while (_isrunning)
\n {
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n ssize_t n = recvfrom(_sockfd, message, sizeof(message) – 1, 0, (struct sockaddr *)&peer, &len);
\n if (n > 0)
\n {
\n InetAddr addr(peer);
\n message[n] = 0; \/\/ \u6536\u5230\u6d88\u606f\u7684\u7f13\u51b2\u533a.
\n LOG(DEBUG, "[%s]# %s\\\\n", addr.AddrStr().c_str(), message); \/\/ \u63d0\u793a\u4e00\u4e0b\u662f\u5426\u63a5\u53d7\u6d88\u606f\u6210\u529f. <\/p>\n
_func(_sockfd, message, addr); \/\/ \u628a\u8f6c\u53d1\u4efb\u52a1\u7ed9\u5230\u8f6c\u53d1\u6a21\u5757\u8fdb\u884c\u5904\u7406.
\n LOG(DEBUG, "return udpserver\\\\n"); \/\/ \u63d0\u793a\u56de\u8c03\u5b8c\u6210!
\n }
\n else
\n {
\n std::cout << "recvfrom , error" << std::endl;
\n }
\n }
\n _isrunning = false;
\n }
\n ~UdpServer()
\n {
\n if (_sockfd > gsockfd)
\n ::close(_sockfd);
\n }<\/p>\n
private:
\n int _sockfd; \/\/ \u8bfb\u5199\u90fd\u7528\u540c\u4e00\u4e2asockfd， \u53cd\u5e94\u8bf4\u660e：UDP\u662f \u5168\u53cc\u5de5 \u901a\u4fe1\u7684！
\n uint16_t _localport;
\n \/\/ std::string _localip; \/\/ TODO:\u540e\u9762\u4e13\u95e8\u8981\u5904\u7406\u4e00\u4e0b\u8fd9\u4e2aIP
\n bool _isrunning;<\/p>\n
service_t _func; \/\/ \u8be5\u51fd\u6570\u7528\u6765\u670d\u52a1\u5668\u56de\u8c03\u8f6c\u53d1\u6a21\u5757, \u662f\u4e00\u4e2a\u56de\u8c03\u51fd\u6570\u6307\u9488.
\n};
\n#include <iostream>
\n#include <string>
\n#include <cstring>
\n#include <unistd.h>
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include "Thread.hpp"<\/p>\n
\/*
\n– \u5ba2\u6237\u7aef\u8981\u4e00\u8fb9\u8bfb\u4e00\u8fb9\u5199 -> \u5ba2\u6237\u7aef\u8981\u591a\u7ebf\u7a0b\u5316!
\n– \u7ebf\u7a0b1: \u8bfb\u6570\u636e \u4ece\u670d\u52a1\u7aef\u90a3\u8fb9\u968f\u65f6\u63a5\u53d7\u6d88\u606f, \u5e76\u7acb\u523b\u663e\u793a\u5230\u7ec8\u7aef\u4e0a.
\n– \u7ebf\u7a0b2: \u53d1\u6d88\u606f, \u4ece\u952e\u76d8\u4e0a\u83b7\u53d6\u7528\u6237\u7684\u6d88\u606f, \u663e\u793a\u5230\u7ec8\u7aef\u4e0a, \u5e76\u7acb\u523b\u53d1\u9001\u7ed9\u670d\u52a1\u5668.
\n*\/
\n\/\/ .\/udpclient 127.0.0.1 8888 2>\/dev\/pts\/0 -> \u628a.\/udpclient\u8fdb\u7a0b\u7684\u6807\u51c6\u9519\u8bef\u4fe1\u606f\u90fd\u91cd\u5b9a\u5411\u52300\u53f7\u865a\u62df\u7ec8\u7aef\u4e0b, \u65b9\u4fbf\u89c2\u5bdf\u73b0\u8c61.
\nusing namespace ThreadMoudle;<\/p>\n
int InitClient()
\n{
\n int sockfd = ::socket(AF_INET, SOCK_DGRAM, 0);
\n if (sockfd < 0)
\n {
\n std::cerr << "create socket error" << std::endl;
\n exit(1);
\n }
\n return sockfd;
\n}<\/p>\n
\/\/ \u8bfb\u7ebf\u7a0b: \u9700\u8981\u77e5\u9053\u4ece\u54ea\u4e2asocket\u8bfb,
\nvoid RecvMessage(int sockfd, const std::string &name)
\n{
\n \/\/ \u63a5\u53d7\u6d88\u606f\u662f\u4e0d\u65ad\u53bb\u5faa\u73af\u63a5\u53d7\u7684.
\n while (true)
\n {
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n char buffer[1024];
\n int n = recvfrom(sockfd, buffer, sizeof(buffer) – 1, 0, (struct sockaddr *)&peer, &len);
\n if (n > 0)
\n {
\n buffer[n] = 0;
\n std::cerr << buffer << std::endl; \/\/ \u8bfb\u53d6\u6210\u529f, \u54b1\u4eec\u6253\u5370\u51fa\u6765.
\n }
\n else
\n {
\n std::cerr << "recvfrom error" << std::endl; \/\/ \u8bfb\u53d6\u5931\u8d25, \u54b1\u4eec\u63d0\u793a\u4e00\u4e0b.
\n break;
\n }
\n }
\n}<\/p>\n
void SendMessage(int sockfd, std::string serverip, uint16_t serverport, const std::string &name)
\n{
\n \/\/ \u586b\u5199\u76ee\u6807\u7ed3\u6784\u4f53
\n struct sockaddr_in server;
\n memset(&server, 0, sizeof(server));
\n server.sin_family = AF_INET;
\n server.sin_port = htons(serverport);
\n server.sin_addr.s_addr = inet_addr(serverip.c_str());<\/p>\n
\/\/ \u51c6\u5907\u8981\u53d1\u9001\u7684\u5185\u5bb9\u7684\u524d\u7f00.
\n std::string cli_profix = name + "# "; \/\/ sender-thread# \u4f60\u597d
\n while (true)
\n {
\n std::string line; \/\/ \u7f13\u51b2\u533a
\n std::cout << cli_profix; \/\/ \u6253\u5370\u53d1\u9001\u524d\u7f00
\n std::getline(std::cin, line); \/\/ \u83b7\u53d6\u7528\u6237\u8f93\u5165\u7684\u6d88\u606f
\n int n = sendto(sockfd, line.c_str(), line.size(), 0, (struct sockaddr *)&server, sizeof(server)); \/\/ \u628a\u6d88\u606f\u53d1\u7ed9server.
\n if (n <= 0)
\n break;
\n }
\n}<\/p>\n
int main(int argc, char *argv[])
\n{
\n \/\/ \u68c0\u67e5\u53c2\u6570
\n if (argc != 3)
\n {
\n std::cerr << "Usage: " << argv[0] << " server-ip server-port" << std::endl;
\n exit(0);
\n }<\/p>\n
std::string serverip = argv[1];
\n uint16_t serverport = std::stoi(argv[2]);
\n int sockfd = InitClient();<\/p>\n
\/\/ \u6536\u6d88\u606f\u7684\u7ebf\u7a0b -> \u5e76\u628a\u6536\u6d88\u606f\u7684\u51fd\u6570\u7ed9\u5230\u8be5\u7ebf\u7a0b
\n Thread recver("recver-thread", std::bind(&RecvMessage, sockfd, std::placeholders::_1));
\n \/\/ string \u7528\u6765\u8ba9Thread\u6807\u8bc6\u7ebf\u7a0b\u540d, func(string), \u662f\u4e3a\u4e86\u65b9\u4fbf\u5728func\u91cc\u6253\u5370\u7ebf\u7a0b\u540d.
\n \/\/ \u53d1\u6d88\u606f\u7684\u7ebf\u7a0b -> \u5e76\u628a\u53d1\u6d88\u606f\u7684\u51fd\u6570\u7ed9\u5230\u8be5\u7ebf\u7a0b
\n Thread sender("sender-thread", std::bind(&SendMessage, sockfd, serverip, serverport, std::placeholders::_1));<\/p>\n
\/\/ \u4e24\u4e2a\u7ebf\u7a0b\u542f\u52a8\u8d77\u6765
\n recver.Start();
\n sender.Start();<\/p>\n
\/\/ \u4e3b\u7ebf\u7a0b\u7b49\u5f85\u4e24\u4e2a\u7ebf\u7a0b
\n recver.Join();
\n sender.Join();<\/p>\n
::close(sockfd); \/\/ \u5173\u95ed\u6587\u4ef6\u63cf\u8ff0\u7b26
\n return 0;
\n}
\n#pragma once
\n#include <iostream>
\n#include <string>
\n#include <vector>
\n#include <functional>
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <pthread.h>
\n#include "InetAddr.hpp"
\n#include "ThreadPool.hpp"
\n#include "LockGuard.hpp"<\/p>\n
\/\/ class user
\n\/\/ {};<\/p>\n
using task_t = std::function<void()>;<\/p>\n
class Route
\n{
\npublic:
\n Route()
\n {
\n pthread_mutex_init(&_mutex, nullptr);
\n }
\n \/\/ \u68c0\u67e5\u7528\u6237\u662f\u5426\u5728\u5728\u7ebf\u7528\u6237\u5217\u8868\u5f53\u4e2d + \u5bf9\u5e94\u7684\u884c\u4e3a.
\n \/\/ \u4e0d\u5728 -> \u6dfb\u52a0\u7528\u6237.
\n \/\/ \u5728 -> \u4ec0\u4e48\u90fd\u4e0d\u505a.
\n void CheckOnlineUser(InetAddr &who)
\n {
\n LockGuard lockguard(&_mutex);
\n for (auto &user : _online_user)
\n {
\n if (user == who) \/\/ \u5982\u679c\u5b58\u5728, \u5c31\u4ec0\u4e48\u90fd\u4e0d\u505a. -> \u91cd\u8f7dInetAddr\u7684\u6bd4\u8f83bool operator==().
\n {
\n LOG(DEBUG, "%s is exists\\\\n", who.AddrStr().c_str()); \/\/ \u5b58\u5728\u7684\u7528\u6237\u6d88\u606f\u63d0\u793a.
\n return; \/\/ \u76f4\u63a5\u9000\u51fa
\n }
\n }
\n LOG(DEBUG, "%s is not exists, add it\\\\n", who.AddrStr().c_str()); \/\/ \u4e0d\u5b58\u5728\u7684\u7528\u6237\u4e5f\u63d0\u793a\u4e00\u4e0b.
\n _online_user.push_back(who); \/\/ \u4e0d\u5728, \u6211\u4eec\u5c31\u6dfb\u52a0\u8fdb\u53bb.
\n }
\n \/\/ for test<\/p>\n
\/\/ \u5728\u7528\u6237\u5217\u8868\u5f53\u4e2d\u79fb\u9664\u7528\u6237.
\n void Offline(InetAddr &who)
\n {
\n LockGuard lockguard(&_mutex); \/\/ \u52a0\u9501.
\n auto iter = _online_user.begin();
\n for (; iter != _online_user.end(); iter++)
\n {
\n if (*iter == who)
\n {
\n LOG(DEBUG, "%s is offline\\\\n", who.AddrStr().c_str()); \/\/ \u65e5\u5fd7: \u63d0\u793a\u67d0\u7528\u6237\u79bb\u5f00.
\n _online_user.erase(iter);
\n break; \/\/ \u8fed\u4ee3\u5668\u5931\u6548, \u76f4\u63a5break;
\n }
\n }
\n }<\/p>\n
void ForwardHelper(int sockfd, const std::string message, InetAddr who)
\n {
\n \/\/ \u4ece\u54ea\u8f6c\u53d1, \u54ea\u4e2a\u5957\u63a5\u5b57? -> sockfd
\n \/\/ \u8f6c\u53d1\u5565\u6d88\u606f? -> message
\n \/\/ \u8c01\u53d1\u7684? -> who
\n LockGuard lockguard(&_mutex); \/\/ \u52a0\u9501.
\n std::string send_message = "[" + who.AddrStr() + "]# " + message; \/\/ \u51c6\u5907\u8981\u8f6c\u53d1\u7684\u6d88\u606f
\n for (auto &user : _online_user)
\n {
\n struct sockaddr_in peer = user.Addr(); \/\/ Addr(): \u8fd4\u56de\u7684\u662f\u7f51\u7edc\u5e8f\u5217\u7684\u5957\u63a5\u5b57\u4fe1\u606f.
\n LOG(DEBUG, "Forward message to %s, message is %s\\\\n", user.AddrStr().c_str(), send_message.c_str()); \/\/ debug: \u5373\u5c06\u8f6c\u53d1\u7684\u6d88\u606f\u4e5f\u63d0\u793a\u4e00\u4e0b.
\n ::sendto(sockfd, send_message.c_str(), send_message.size(), 0, (struct sockaddr *)&peer, sizeof(peer));
\n }
\n }<\/p>\n
\/\/ \u6d88\u606f\u8f6c\u53d1
\n void Forward(int sockfd, const std::string &message, InetAddr &who)
\n {
\n \/\/ 1. \u8be5\u7528\u6237\u662f\u5426\u5728 \u5728\u7ebf\u7528\u6237\u5217\u8868\u4e2d\u5462？\u5982\u679c\u5728，\u4ec0\u4e48\u90fd\u4e0d\u505a，\u5982\u679c\u4e0d\u5728，\u81ea\u52a8\u6dfb\u52a0\u5230_online_user
\n CheckOnlineUser(who);<\/p>\n
\/\/ 1.1 \u7528\u6237\u53ef\u9009\u62e9\u9000\u51fa: message == "QUIT" "Q"
\n if (message == "QUIT" || message == "Q")
\n {
\n Offline(who);
\n }<\/p>\n
\/\/ 2. who \u4e00\u5b9a\u5728_online_user\u5217\u8868\u91cc\u9762
\n \/\/ ForwardHelper(sockfd, message); \/\/ \u8fd9\u6837\u662f\u8def\u7531\u6a21\u5757\/\u670d\u52a1\u5668\u8fdb\u884c\u6d88\u606f\u8f6c\u53d1, \u6211\u4eec\u4e0b\u9762\u8fd9\u79cd\u5199\u6cd5\u5c31\u7b97\u628a\u8fd9\u4e2a\u8f6c\u53d1\u4efb\u52a1\u7ed9\u5230\u7ebf\u7a0b.
\n task_t t = std::bind(&Route::ForwardHelper, this, sockfd, message, who); \/\/ \u5305\u88c5\u4e00\u4e0b\u8f6c\u53d1\u51fd\u6570. \u56e0\u4e3a\u7ebf\u7a0b\u6c60\u4e2d\u7684\u7ebf\u7a0b\u53ea\u63a5\u53d7void()\u7c7b\u578b\u7684\u884c\u4e3a.
\n ThreadPool<task_t>::GetInstance()->Equeue(t); \/\/ \u542f\u52a8\u7ebf\u7a0b\u6c60, \u83b7\u53d6\u4e00\u4e2a\u7ebf\u7a0b\u6c60\u5355\u4f8b\u5bf9\u8c61 -> \u6d3e\u53d1\u4efb\u52a1\u7ed9\u4ed6\u7684\u5b50\u7ebf\u7a0b.
\n }
\n ~Route()
\n {
\n pthread_mutex_destroy(&_mutex);
\n }<\/p>\n
private:
\n std::vector<InetAddr> _online_user; \/\/ \u7ef4\u62a4\u5728\u7ebf\u7528\u6237\u5217\u8868.
\n pthread_mutex_t _mutex; \/\/ \u7528\u6765\u4fdd\u62a4\u516c\u5171\u8d44\u6e90.
\n};
\n#pragma once<\/p>\n
#include <iostream>
\n#include <string>
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <arpa\/inet.h>
\n#include <netinet\/in.h><\/p>\n
class InetAddr
\n{
\nprivate:
\n void ToHost(const struct sockaddr_in &addr)
\n {
\n _port = ntohs(addr.sin_port);
\n \/\/ _ip = inet_ntoa(addr.sin_addr);
\n char ip_buf[32];
\n \/\/ inet_p to n
\n \/\/ p: process
\n \/\/ n: net
\n \/\/ inet_pton(int af, const char *src, void *dst);
\n \/\/ inet_pton(AF_INET, ip.c_str(), &addr.sin_addr.s_addr);
\n ::inet_ntop(AF_INET, &addr.sin_addr, ip_buf, sizeof(ip_buf));
\n _ip = ip_buf;
\n }<\/p>\n
public:
\n InetAddr(const struct sockaddr_in &addr):_addr(addr)
\n {
\n ToHost(addr);
\n }<\/p>\n
\/\/ ip + port \u552f\u4e00\u6027:
\n \/\/ \u4e00\u822c\u6765\u8bf4ip\u552f\u4e00\u5c31\u7b97\u662f\u552f\u4e00\u7684.
\n \/\/ \u8fd9\u91cc\u4e3a\u4e86\u65b9\u4fbf\u6d4b\u8bd5, \u628aport\u4e5f\u641e\u6210\u533a\u5206\u552f\u4e00\u6027\u7684.
\n bool operator == (const InetAddr &addr)
\n {
\n return (this->_ip == addr._ip && this->_port == addr._port);
\n }
\n std::string Ip()
\n {
\n return _ip;
\n }
\n uint16_t Port()
\n {
\n return _port;
\n }
\n struct sockaddr_in Addr()
\n {
\n return _addr;
\n }
\n \/\/ \u7528\u6765\u65b9\u4fbf\u8c03\u8bd5, \u8fd4\u56de\u7684\u662f\u5b57\u7b26\u4e32, \u65b9\u4fbf\u6253\u5370.
\n std::string AddrStr()
\n {
\n return _ip + ":" + std::to_string(_port);
\n }
\n ~InetAddr()
\n {
\n }<\/p>\n
private:
\n std::string _ip;
\n uint16_t _port;
\n struct sockaddr_in _addr;
\n}; <\/p>\n
#pragma once
\n#include <iostream>
\n#include <string>
\n#include <functional>
\n#include <pthread.h><\/p>\n
namespace ThreadMoudle
\n{
\n \/\/ \u7ebf\u7a0b\u8981\u6267\u884c\u7684\u65b9\u6cd5，\u540e\u9762\u6211\u4eec\u968f\u65f6\u8c03\u6574
\n \/\/ typedef void (*func_t)(ThreadData *td); \/\/ \u51fd\u6570\u6307\u9488\u7c7b\u578b<\/p>\n
\/\/ typedef std::function<void()> func_t;
\n using func_t = std::function<void(const std::string&)>;<\/p>\n
class Thread
\n {
\n public:
\n void Excute()
\n {
\n _isrunning = true;
\n _func(_name);
\n _isrunning = false;
\n }
\n public:
\n Thread(const std::string &name, func_t func):_name(name), _func(func)
\n {
\n }
\n static void *ThreadRoutine(void *args) \/\/ \u65b0\u7ebf\u7a0b\u90fd\u4f1a\u6267\u884c\u8be5\u65b9\u6cd5！
\n {
\n Thread *self = static_cast<Thread*>(args); \/\/ \u83b7\u5f97\u4e86\u5f53\u524d\u5bf9\u8c61
\n self->Excute();
\n return nullptr;
\n }
\n bool Start()
\n {
\n int n = ::pthread_create(&_tid, nullptr, ThreadRoutine, this);
\n if(n != 0) return false;
\n return true;
\n }
\n std::string Status()
\n {
\n if(_isrunning) return "running";
\n else return "sleep";
\n }
\n void Stop()
\n {
\n if(_isrunning)
\n {
\n ::pthread_cancel(_tid);
\n _isrunning = false;
\n }
\n }
\n void Join()
\n {
\n ::pthread_join(_tid, nullptr);
\n }
\n std::string Name()
\n {
\n return _name;
\n }
\n ~Thread()
\n {
\n }<\/p>\n
private:
\n std::string _name;
\n pthread_t _tid;
\n bool _isrunning;
\n func_t _func; \/\/ \u7ebf\u7a0b\u8981\u6267\u884c\u7684\u56de\u8c03\u51fd\u6570
\n };
\n} \/\/ namespace ThreadModle<\/p>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <unistd.h>
\n#include <string>
\n#include <vector>
\n#include <queue>
\n#include <functional>
\n#include "Thread.hpp"
\n#include "Log.hpp"
\n#include "LockGuard.hpp"<\/p>\n
using namespace ThreadMoudle;
\nusing namespace log_ns;<\/p>\n
static const int gdefaultnum = 5;<\/p>\n
void test()
\n{
\n while (true)
\n {
\n std::cout << "hello world" << std::endl;
\n sleep(1);
\n }
\n}<\/p>\n
template <typename T>
\nclass ThreadPool
\n{
\nprivate:
\n void LockQueue()
\n {
\n pthread_mutex_lock(&_mutex);
\n }
\n void UnlockQueue()
\n {
\n pthread_mutex_unlock(&_mutex);
\n }
\n void Wakeup()
\n {
\n pthread_cond_signal(&_cond);
\n }
\n void WakeupAll()
\n {
\n pthread_cond_broadcast(&_cond);
\n }
\n void Sleep()
\n {
\n pthread_cond_wait(&_cond, &_mutex);
\n }
\n bool IsEmpty()
\n {
\n return _task_queue.empty();
\n }
\n void HandlerTask(const std::string &name) \/\/ this
\n {
\n while (true)
\n {
\n \/\/ \u53d6\u4efb\u52a1
\n LockQueue();
\n while (IsEmpty() && _isrunning)
\n {
\n _sleep_thread_num++;
\n LOG(INFO, "%s thread sleep begin!\\\\n", name.c_str());
\n Sleep();
\n LOG(INFO, "%s thread wakeup!\\\\n", name.c_str());
\n _sleep_thread_num–;
\n }
\n \/\/ \u5224\u5b9a\u4e00\u79cd\u60c5\u51b5
\n if (IsEmpty() && !_isrunning)
\n {
\n UnlockQueue();
\n LOG(INFO, "%s thread quit\\\\n", name.c_str());
\n break;
\n }<\/p>\n
\/\/ \u6709\u4efb\u52a1
\n T t = _task_queue.front();
\n _task_queue.pop();
\n UnlockQueue();<\/p>\n
\/\/ \u5904\u7406\u4efb\u52a1
\n t(); \/\/ \u5904\u7406\u4efb\u52a1，\u6b64\u5904\u4e0d\u7528\/\u4e0d\u80fd\u5728\u4e34\u754c\u533a\u4e2d\u5904\u7406
\n \/\/ std::cout << name << ": " << t.result() << std::endl;
\n \/\/ LOG(DEBUG, "hander task done, task is : %s\\\\n", t.result().c_str());
\n }
\n }
\n void Init()
\n {
\n func_t func = std::bind(&ThreadPool::HandlerTask, this, std::placeholders::_1);
\n for (int i = 0; i < _thread_num; i++)
\n {
\n std::string threadname = "thread-" + std::to_string(i + 1);
\n _threads.emplace_back(threadname, func);
\n LOG(DEBUG, "construct thread %s done, init success\\\\n", threadname.c_str());
\n }
\n }
\n void Start()
\n {
\n _isrunning = true;
\n for (auto &thread : _threads)
\n {
\n LOG(DEBUG, "start thread %s done.\\\\n", thread.Name().c_str());
\n thread.Start();
\n }
\n }
\n ThreadPool(int thread_num = gdefaultnum)
\n : _thread_num(thread_num), _isrunning(false), _sleep_thread_num(0)
\n {
\n pthread_mutex_init(&_mutex, nullptr);
\n pthread_cond_init(&_cond, nullptr);
\n }
\n ThreadPool(const ThreadPool<T> &) = delete;
\n void operator=(const ThreadPool<T> &) = delete;<\/p>\n
public:
\n void Stop()
\n {
\n LockQueue();
\n _isrunning = false;
\n WakeupAll();
\n UnlockQueue();
\n LOG(INFO, "Thread Pool Stop Success!\\\\n");
\n }<\/p>\n
\/\/ \u5982\u679c\u662f\u591a\u7ebf\u7a0b\u83b7\u53d6\u5355\u4f8b\u5462？
\n static ThreadPool<T> *GetInstance()
\n {
\n if (_tp == nullptr)
\n {
\n LockGuard lockguard(&_sig_mutex);
\n if (_tp == nullptr)
\n {
\n LOG(INFO, "create threadpool\\\\n");
\n \/\/ thread-1 thread-2 thread-3….
\n _tp = new ThreadPool<T>();
\n _tp->Init();
\n _tp->Start();
\n }
\n else
\n {
\n LOG(INFO, "get threadpool\\\\n");
\n }
\n }
\n return _tp;
\n }<\/p>\n
void Equeue(const T &in)
\n {
\n LockQueue();
\n if (_isrunning)
\n {
\n _task_queue.push(in);
\n if (_sleep_thread_num > 0)
\n Wakeup();
\n }
\n UnlockQueue();
\n }
\n ~ThreadPool()
\n {
\n pthread_mutex_destroy(&_mutex);
\n pthread_cond_destroy(&_cond);
\n }<\/p>\n
private:
\n int _thread_num;
\n std::vector<Thread> _threads;
\n std::queue<T> _task_queue;
\n bool _isrunning;<\/p>\n
int _sleep_thread_num;<\/p>\n
pthread_mutex_t _mutex;
\n pthread_cond_t _cond;<\/p>\n
\/\/ \u5355\u4f8b\u6a21\u5f0f
\n \/\/ volatile static ThreadPool<T> *_tp;
\n static ThreadPool<T> *_tp;
\n static pthread_mutex_t _sig_mutex;
\n};<\/p>\n
template <typename T>
\nThreadPool<T> *ThreadPool<T>::_tp = nullptr;
\ntemplate <typename T>
\npthread_mutex_t ThreadPool<T>::_sig_mutex = PTHREAD_MUTEX_INITIALIZER;<\/p>\n
#pragma once<\/p>\n
#include <pthread.h><\/p>\n
class LockGuard
\n{
\npublic:
\n LockGuard(pthread_mutex_t *mutex):_mutex(mutex)
\n {
\n pthread_mutex_lock(_mutex);
\n }
\n ~LockGuard()
\n {
\n pthread_mutex_unlock(_mutex);
\n }
\nprivate:
\n pthread_mutex_t *_mutex;
\n};
\n#pragma once<\/p>\n
#include <iostream>
\n#include <sys\/types.h>
\n#include <unistd.h>
\n#include <ctime>
\n#include <cstdarg>
\n#include <fstream>
\n#include <cstring>
\n#include <pthread.h>
\n#include "LockGuard.hpp"<\/p>\n
namespace log_ns
\n{<\/p>\n
enum
\n {
\n DEBUG = 1,
\n INFO,
\n WARNING,
\n ERROR,
\n FATAL
\n };<\/p>\n
std::string LevelToString(int level)
\n {
\n switch (level)
\n {
\n case DEBUG:
\n return "DEBUG";
\n case INFO:
\n return "INFO";
\n case WARNING:
\n return "WARNING";
\n case ERROR:
\n return "ERROR";
\n case FATAL:
\n return "FATAL";
\n default:
\n return "UNKNOWN";
\n }
\n }<\/p>\n
std::string GetCurrTime()
\n {
\n time_t now = time(nullptr);
\n struct tm *curr_time = localtime(&now);
\n char buffer[128];
\n snprintf(buffer, sizeof(buffer), "%d-%02d-%02d %02d:%02d:%02d",
\n curr_time->tm_year + 1900,
\n curr_time->tm_mon + 1,
\n curr_time->tm_mday,
\n curr_time->tm_hour,
\n curr_time->tm_min,
\n curr_time->tm_sec);
\n return buffer;
\n }<\/p>\n
class logmessage
\n {
\n public:
\n std::string _level;
\n pid_t _id;
\n std::string _filename;
\n int _filenumber;
\n std::string _curr_time;
\n std::string _message_info;
\n };<\/p>\n
#define SCREEN_TYPE 1
\n#define FILE_TYPE 2<\/p>\n
const std::string glogfile = ".\/log.txt";
\n pthread_mutex_t glock = PTHREAD_MUTEX_INITIALIZER;<\/p>\n
\/\/ log.logMessage("", 12, INFO, "this is a %d message ,%f, %s hellwrodl", x, , , );
\n class Log
\n {
\n public:
\n Log(const std::string &logfile = glogfile) : _logfile(logfile), _type(SCREEN_TYPE)
\n {
\n }
\n void Enable(int type)
\n {
\n _type = type;
\n }
\n void FlushLogToScreen(const logmessage &lg)
\n {
\n printf("[%s][%d][%s][%d][%s] %s",
\n lg._level.c_str(),
\n lg._id,
\n lg._filename.c_str(),
\n lg._filenumber,
\n lg._curr_time.c_str(),
\n lg._message_info.c_str());
\n }
\n void FlushLogToFile(const logmessage &lg)
\n {
\n std::ofstream out(_logfile, std::ios::app);
\n if (!out.is_open())
\n return;
\n char logtxt[2048];
\n snprintf(logtxt, sizeof(logtxt), "[%s][%d][%s][%d][%s] %s",
\n lg._level.c_str(),
\n lg._id,
\n lg._filename.c_str(),
\n lg._filenumber,
\n lg._curr_time.c_str(),
\n lg._message_info.c_str());
\n out.write(logtxt, strlen(logtxt));
\n out.close();
\n }
\n void FlushLog(const logmessage &lg)
\n {
\n \/\/ \u52a0\u8fc7\u6ee4\u903b\u8f91 — TODO<\/p>\n
LockGuard lockguard(&glock);
\n switch (_type)
\n {
\n case SCREEN_TYPE:
\n FlushLogToScreen(lg);
\n break;
\n case FILE_TYPE:
\n FlushLogToFile(lg);
\n break;
\n }
\n }
\n void logMessage(std::string filename, int filenumber, int level, const char *format, …)
\n {
\n logmessage lg;<\/p>\n
lg._level = LevelToString(level);
\n lg._id = getpid();
\n lg._filename = filename;
\n lg._filenumber = filenumber;
\n lg._curr_time = GetCurrTime();<\/p>\n
va_list ap;
\n va_start(ap, format);
\n char log_info[1024];
\n vsnprintf(log_info, sizeof(log_info), format, ap);
\n va_end(ap);
\n lg._message_info = log_info;<\/p>\n
\/\/ \u6253\u5370\u51fa\u6765\u65e5\u5fd7
\n FlushLog(lg);
\n }
\n ~Log()
\n {
\n }<\/p>\n
private:
\n int _type;
\n std::string _logfile;
\n };<\/p>\n
Log lg;<\/p>\n
#define LOG(Level, Format, …) \\\\
\n do \\\\
\n { \\\\
\n lg.logMessage(__FILE__, __LINE__, Level, Format, ##__VA_ARGS__); \\\\
\n } while (0)
\n#define EnableScreen() \\\\
\n do \\\\
\n { \\\\
\n lg.Enable(SCREEN_TYPE); \\\\
\n } while (0)
\n#define EnableFILE() \\\\
\n do \\\\
\n { \\\\
\n lg.Enable(FILE_TYPE); \\\\
\n } while (0)
\n};
\n.PHONY:all
\nall:udpserver udpclient<\/p>\n
udpserver:UdpServerMain.cc
\ng++ -o $@ $^ -std=c++14 -lpthread \/\/ \u7ebf\u7a0b\u5e93
\nudpclient:UdpClientMain.cc
\ng++ -o $@ $^ -std=c++14 -lpthread \/\/ \u7ebf\u7a0b\u5e93<\/p>\n
.PHONY:clean
\nclean:
\nrm -rf udpserver udpclient
\n#pragma once<\/p>\n
class nocopy
\n{
\npublic:
\n nocopy(){}
\n ~nocopy(){}
\n nocopy(const nocopy&) = delete;
\n const nocopy& operator=(const nocopy&) = delete;
\n};<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb826\u6b21\uff0c\u70b9\u8d5e20\u6b21\uff0c\u6536\u85cf13\u6b21\u3002[net 6] udp_chat_server\u57fa\u4e8eudp\u7684\u7b80\u5355\u804a\u5929\u5ba4(\u591a\u7ebf\u7a0b\u7684\u670d\u52a1\u5668\u4e0e\u4e1a\u52a1\u76f8\u5206\u79bb)<\/p>\n","protected":false},"author":2,"featured_media":30836,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[58,230,43],"topic":[],"class_list":["post-30856","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-linux","tag-php","tag-43"],"yoast_head":"\n