![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250422080616-68074df859fdd.gif\")
<\/p>\n📢\u535a\u5ba2\u4e3b\u9875：https:\/\/blog.csdn.net\/2301_779549673 📢\u535a\u5ba2\u4ed3\u5e93：https:\/\/gitee.com\/JohnKingW\/linux_test\/tree\/master\/lesson 📢\u6b22\u8fce\u70b9\u8d5e 👍 \u6536\u85cf \u2b50\u7559\u8a00 📝 \u5982\u6709\u9519\u8bef\u656c\u8bf7\u6307\u6b63！ 📢\u672c\u6587\u7531 JohnKi \u539f\u521b，\u9996\u53d1\u4e8e CSDN🙉 📢\u672a\u6765\u5f88\u957f，\u503c\u5f97\u6211\u4eec\u5168\u529b\u5954\u8d74\u66f4\u7f8e\u597d\u7684\u751f\u6d3b\u2728<\/p>\n
<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250422080616-68074df87d41b.gif\")
<\/p>\n<\/p>\n
\u4e0a\u4e00\u7bc7\u6587\u7ae0\u4e2d，\u6211\u4eec\u5b9e\u73b0\u4e86\u56de\u663e\u5ba2\u6237\u7aef\u8f93\u5165\u7684\u529f\u80fd<\/font>，\u8fd9\u529f\u80fd\u5f80\u5f80\u662f\u4e0d\u591f\u7684，\u4e3a\u4e86\u66f4\u597d\u5730\u6a21\u62df\u73b0\u5b9e\u9700\u6c42，\u6211\u4eec\u73b0\u5728\u591a\u589e\u52a0\u4e00\u4e2a\u529f\u80fd – \u5b57\u5178\u7ffb\u8bd1\u529f\u80fd<\/font><\/p>\n \u522b\u7684\u529f\u80fd\u3001\u6210\u5458\u540d\u4fdd\u6301\u4e0d\u53d8，\u4e3a\u4e86\u65b0\u589e\u5b57\u5178\u7ffb\u8bd1\u529f\u80fd，\u6211\u4eec\u9700\u8981\u5f15\u5165\u51fd\u6570\u5bf9\u8c61\u7c7b\u578b<\/font><\/p>\n \/\/ \u56de\u8c03\u51fd\u6570\u5bf9\u8c61\u58f0\u660e class UdpServer : public nocopy{ func_t _func; \/\/ \u56de\u8c03\u51fd\u6570 UdpServer(uint16_t localport = gdefaultport, func_t func = nullptr) void Start() { \/\/ \u63a5\u6536\u6570\u636e\u62a5 \u5b57\u5178\u7c7b\u6267\u884c\u52a0\u8f7d\u5b57\u5178\u6587\u4ef6 \u548c \u6267\u884c\u7ffb\u8bd1<\/font>\u7684\u529f\u80fd<\/p>\n class Dictionary{ \u6211\u4eec\u4ee5 ": " \u4e00\u4e2a\u5192\u53f7\u52a0\u4e00\u4e2a\u7a7a\u683c\u7684\u5f62\u5f0f，\u8fdb\u884c\u7ffb\u8bd1<\/p>\n \u52a0\u8f7d\u5b57\u5178\u6587\u4ef6\u7684\u672c\u8d28\u662f\u4ee5KV\u7684\u5f62\u5f0f\u5c06\u82f1\u6587\u5355\u8bcd\u548c\u4e2d\u6587\u7ffb\u8bd1\u63d2\u5165\u5230_dict\u54c8\u5e0c\u8868\u4e2d！<\/font><\/p>\n<\/li>\n \u52a0\u8f7d\u6587\u4ef6\u5305\u542b3\u4e2a\u5927\u7684\u6b65\u9aa4：<\/p>\n \/\/ \u52a0\u8f7d\u5b57\u5178\u6587\u4ef6 \/\/ 2. \u6309\u884c\u8bfb\u53d6\u5185\u5bb9 auto pos = line.find(sep); \/\/ \u4f7f\u7528find\u627e\u5230\u5206\u9694\u7b26\u4f4d\u7f6e，\u8fd4\u56de\u8fed\u4ee3\u5668\u4f4d\u7f6e std::string key = line.substr(0, pos); \/\/ \u524d\u95ed\u540e\u5f00 std::string value = line.substr(pos + sep.size()); _dict.insert(std::make_pair(key, value)); \/\/ 3. \u5173\u95ed\u6587\u4ef6 \u521d\u59cb\u5316\u5b57\u5178\u6587\u4ef6，\u5e76\u5c06\u952e\u503c\u5bf9\u52a0\u8f7d\u5230\u672c\u5730\u4fdd\u5b58<\/p>\n \/\/ \u6784\u9020\u51fd\u6570 \u5728\u952e\u503c\u5bf9\u4e2d\u67e5\u627e\u662f\u5426\u6709\u8be5\u5355\u8bcd，\u6709\u5355\u8bcd\u5c31\u8fd4\u56de\u503c，\u6ca1\u6709\u8fd4\u56deNone<\/p>\n \/\/ \u7ffb\u8bd1 \u56e0\u4e3a\u6211\u4eec\u73b0\u5728\u9700\u8981\u5c06\u5b57\u5178\u7c7b\u7684\u67e5\u627e\u65b9\u6cd5 \u4f5c\u4e3a\u56de\u8c03\u51fd\u6570\u4f20\u7ed9\u670d\u52a1\u7aef<\/font> ，\u6240\u4ee5\u9700\u8981\u8fdb\u884c\u4e00\u4e9b\u53d8\u5316<\/p>\n #include "UdpServer.hpp" int main(int argc, char *argv[]) uint16_t port = std::stoi(argv[1]);<\/p>\n ENABLE_CONSOLE_LOG(); \/\/ \u65e5\u671f\u7c7b\u65b9\u6cd5，\u4f7f\u65e5\u5fd7\u5728\u63a7\u5236\u53f0\u8f93\u51fa<\/p>\n std::shared_ptr<Dictionary> dict_ptr = std::make_shared<Dictionary>();<\/p>\n std::unique_ptr<UdpServer> usvr = std::make_unique<UdpServer>(port, [&dict_ptr]( const std::string& word){ usvr->InitServer(); \/\/ \u521d\u59cb\u5316\u670d\u52a1\u7aef UdpServer.hpp<\/p>\n #include <iostream> #include <sys\/types.h> #include "InetAddr.hpp" using namespace LogModule;<\/p>\n const static int gsockfd = -1; \/\/ \u56de\u8c03\u51fd\u6570\u5bf9\u8c61\u58f0\u660e class nocopy{ class UdpServer : public nocopy{ \/\/ 2. bind \/\/ \u5c06\u5957\u63a5\u5b57\u7ed1\u5b9a\u5230\u672c\u5730\u5730\u5740 \/\/ \u63a5\u6536\u6570\u636e\u62a5 func_t _func; \/\/ \u56de\u8c03\u51fd\u6570 UdpServer.cpp<\/p>\n #include "UdpServer.hpp" int main(int argc, char *argv[]) uint16_t port = std::stoi(argv[1]);<\/p>\n ENABLE_CONSOLE_LOG(); \/\/ \u65e5\u671f\u7c7b\u65b9\u6cd5，\u4f7f\u65e5\u5fd7\u5728\u63a7\u5236\u53f0\u8f93\u51fa<\/p>\n std::shared_ptr<Dictionary> dict_ptr = std::make_shared<Dictionary>();<\/p>\n std::unique_ptr<UdpServer> usvr = std::make_unique<UdpServer>(port, [&dict_ptr]( const std::string& word){ usvr->InitServer(); \/\/ \u521d\u59cb\u5316\u670d\u52a1\u7aef UdpClient.hpp<\/p>\n #pragma once<\/p>\n #include "Common.hpp" UdpClient.cpp<\/p>\n #include "UdpClient.hpp"<\/p>\n int main(int argc, char* argv[]){ \/\/ 1. \u521b\u5efa\u5957\u63a5\u5b57 \/\/ 1. \u586b\u5145 server \u4fe1\u606f \/\/ 2. \u53d1\u9001\u6570\u636e \/\/ client \u5fc5\u987b\u81ea\u5df1\u7684ip\u548c\u7aef\u53e3\u3002\u4f46\u662f\u5ba2\u6237\u7aef，\u4e0d\u9700\u8981\u663e\u793a\u8c03\u7528bind struct sockaddr_in temp; Common.hpp<\/p>\n #pragma once<\/p>\n #include <iostream><\/p>\n #define Die(code) \\\\ #define CONV(v) (struct sockaddr *)(v)<\/p>\n enum InetAddr.hpp<\/p>\n #pragma once<\/p>\n #include <iostream> class InetAddr public: private: Dictionary.hpp<\/p>\n #pragma once<\/p>\n #include <iostream> using namespace LogModule;<\/p>\n const static std::string sep = ": "; class Dictionary{ \/\/ 2. \u6309\u884c\u8bfb\u53d6\u5185\u5bb9 auto pos = line.find(sep); \/\/ \u4f7f\u7528find\u627e\u5230\u5206\u9694\u7b26\u4f4d\u7f6e，\u8fd4\u56de\u8fed\u4ee3\u5668\u4f4d\u7f6e std::string key = line.substr(0, pos); \/\/ \u524d\u95ed\u540e\u5f00 std::string value = line.substr(pos + sep.size()); _dict.insert(std::make_pair(key, value)); \/\/ 3. \u5173\u95ed\u6587\u4ef6 Log.hpp<\/p>\n #pragma once<\/p>\n #include <iostream> namespace LogModule \/\/ \u83b7\u53d6\u4e00\u4e0b\u5f53\u524d\u7cfb\u7edf\u7684\u65f6\u95f4 char buffer[1024]; return buffer; \/\/ \u6784\u6210: 1. \u6784\u5efa\u65e5\u5fd7\u5b57\u7b26\u4e32 2. \u5237\u65b0\u843d\u76d8(screen, file) \/\/ 2. \u65e5\u5fd7\u7b49\u7ea7 std::string Level2String(LogLevel level) \/\/ 3. \u5237\u65b0\u7b56\u7565. \/\/ 3.1 \u63a7\u5236\u53f0\u7b56\u7565 private: \/\/ 3.2 \u6587\u4ef6\u7ea7(\u78c1\u76d8)\u7b56\u7565 if (std::filesystem::exists(_logpath)) private: \/\/ \u9501 \/\/ \u65e5\u5fd7\u7c7b: \u6784\u5efa\u65e5\u5fd7\u5b57\u7b26\u4e32, \u6839\u636e\u7b56\u7565，\u8fdb\u884c\u5237\u65b0 ~LogMessage() private: \/\/ \u5c31\u662f\u8981\u62f7\u8d1d,\u6545\u610f\u7684\u62f7\u8d1d private: Logger logger;<\/p>\n #define LOG(Level) logger(Level, __FILE__, __LINE__) Mutex.hpp<\/p>\n #pragma once namespace LockModule private: class LockGuard Makefile<\/p>\n .PHONY: all server_udp:UdpServer.cpp client_udp:UdpClient.cpp .PHONY: clean \u672c\u7bc7\u535a\u6587\u5bf9 \u3010Linux\u7f51\u7edc\u3011\u6784\u5efaUdp\u670d\u52a1\u5668\u4e0e\u5b57\u5178\u7ffb\u8bd1\u7cfb\u7edf \u505a\u4e86\u4e00\u4e2a\u8f83\u4e3a\u8be6\u7ec6\u7684\u4ecb\u7ecd，\u4e0d\u77e5\u9053\u5bf9\u4f60\u6709\u6ca1\u6709\u5e2e\u52a9\u5462<\/p>\n \u89c9\u5f97\u535a\u4e3b\u5199\u5f97\u8fd8\u4e0d\u9519\u7684\u4e09\u8fde\u652f\u6301\u4e0b\u5427！\u4f1a\u7ee7\u7eed\u52aa\u529b\u7684~<\/p>\n","protected":false},"excerpt":{"rendered":" \u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb768\u6b21\uff0c\u70b9\u8d5e39\u6b21\uff0c\u6536\u85cf34\u6b21\u3002\u672c\u7bc7\u535a\u6587\u5bf9\u3010Linux\u7f51\u7edc\u3011\u6784\u5efaUdp\u670d\u52a1\u5668\u4e0e\u5b57\u5178\u7ffb\u8bd1\u7cfb\u7edf\u505a\u4e86\u4e00\u4e2a\u8f83\u4e3a\u8be6\u7ec6\u7684\u4ecb\u7ecd\uff0c\u4e0d\u77e5\u9053\u5bf9\u4f60\u6709\u6ca1\u6709\u5e2e\u52a9\u5462\u89c9\u5f97\u535a\u4e3b\u5199\u5f97\u8fd8\u4e0d\u9519\u7684\u4e09\u8fde\u652f\u6301\u4e0b\u5427\uff01\u4f1a\u7ee7\u7eed\u52aa\u529b\u7684~<\/p>\n","protected":false},"author":2,"featured_media":31936,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[58,205,193,43,78],"topic":[],"class_list":["post-31939","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-linux","tag-tcp-ip","tag-udp","tag-43","tag-78"],"yoast_head":"\n🏳\ufe0f\u200d🌈\u4e00\u3001\u670d\u52a1\u7aef\u66f4\u65b0<\/h2>\n
1.1 \u51fd\u6570\u5bf9\u8c61\u58f0\u660e<\/h3>\n
\nusing func_t = std::function<std::string(std::string)>;<\/p>\n1.2 UdpServer \u7c7b\u6210\u5458\u66f4\u65b0<\/h3>\n
\n public:
\nUdpServer(func_t func,uint16_t localport = glocalport);
\n void InitServer();
\n void Start();
\n ~UdpServer();
\n private:
\n int _sockfd; \/\/ \u6587\u4ef6\u63cf\u8ff0\u7b26
\n uint16_t _localport; \/\/ \u7aef\u53e3\u53f7
\n std::string _localip; \/\/ \u672c\u5730IP\u5730\u5740
\n bool _isrunning; \/\/ \u8fd0\u884c\u72b6\u6001<\/p>\n
\n};<\/p>\n1.3 \u6784\u9020\u51fd\u6570\u66f4\u65b0<\/h3>\n
\n
\n : _sockfd(gsockfd), _localport(localport), _isrunning(false), _func(func) {}<\/p>\n1.4 \u5f00\u59cb – Start() \u66f4\u65b0<\/h3>\n
\n
\n _isrunning = true;
\n while (true) {
\n char inbuffer[1024]; \/\/ \u63a5\u6536\u7f13\u51b2\u533a
\n struct sockaddr_in peer; \/\/ \u63a5\u6536\u5ba2\u6237\u7aef\u5730\u5740
\n socklen_t peerlen = sizeof(peer); \/\/ \u8ba1\u7b97\u63a5\u6536\u7684\u5ba2\u6237\u7aef\u5730\u5740\u957f\u5ea6<\/p>\n
\n \/\/ recvfrom(int sockfd, void* buf, size_t len, int flags, struct
\n \/\/ sockaddr* src_addr, socklen_t* addrlen)
\n \/\/ \u4ece\u5957\u63a5\u5b57\u63a5\u6536\u6570\u636e，\u5e76\u5b58\u5165buf\u6307\u5411\u7684\u7f13\u51b2\u533a\u4e2d，\u8fd4\u56de\u5b9e\u9645\u63a5\u6536\u7684\u5b57\u8282\u6570
\n \/\/ \u53c2\u6570sockfd：\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26
\n \/\/ \u53c2\u6570buf：\u6307\u5411\u63a5\u6536\u7f13\u51b2\u533a\u7684\u6307\u9488，c_str()\u51fd\u6570\u53ef\u4ee5\u5c06\u5b57\u7b26\u4e32\u8f6c\u6362\u4e3achar*，\u4ee5\u4fbf\u5b58\u5165\u7f13\u51b2\u533a
\n \/\/ \u53c2\u6570len：\u63a5\u6536\u7f13\u51b2\u533a\u7684\u957f\u5ea6
\n \/\/ \u53c2\u6570flags：\u63a5\u6536\u6807\u5fd7，\u4e00\u822c\u8bbe\u4e3a0
\n \/\/ \u53c2\u6570src_addr：\u6307\u5411\u5ba2\u6237\u7aef\u5730\u5740\u7684\u6307\u9488，\u82e5\u4e0d\u4e3aNULL，\u51fd\u6570\u8fd4\u56de\u65f6，\u8be5\u6307\u9488\u6307\u5411\u5ba2\u6237\u7aef\u7684\u5730\u5740，\u662f\u7f51\u7edc\u5b57\u8282\u5e8f
\n \/\/ \u53c2\u6570addrlen：\u5ba2\u6237\u7aef\u5730\u5740\u957f\u5ea6\u7684\u6307\u9488，\u82e5\u4e0d\u4e3aNULL，\u51fd\u6570\u8fd4\u56de\u65f6，\u8be5\u6307\u9488\u6307\u5411\u5b9e\u9645\u7684\u5ba2\u6237\u7aef\u5730\u5740\u957f\u5ea6
\n ssize_t n = ::recvfrom(_sockfd, inbuffer, sizeof(inbuffer) – 1, 0,
\n CONV(&peer), &peerlen);
\n if (n > 0) {
\n \/\/ \u5c06\u82f1\u6587\u5355\u8bcd \u8f6c\u6362\u4e3a \u4e2d\u6587
\n std::string result = _func(inbuffer);
\n ::sendto(_sockfd, result.c_str(), result.size(), 0, CONV(&peer),
\n peerlen);
\n }
\n }
\n}<\/p>\n🏳\ufe0f\u200d🌈\u4e8c\u3001Dictionary \u5b57\u5178\u7c7b\u8bbe\u8ba1<\/h2>\n
2.1 \u57fa\u672c\u7ed3\u6784<\/h3>\n
\n private:
\n \/\/ \u52a0\u8f7d\u5b57\u5178\u6587\u4ef6
\n void LoadDictionary(const std::string& path);
\n public:
\n \/\/ \u6784\u9020\u51fd\u6570
\n Dictionary(const std::string& path);
\n \/\/ \u7ffb\u8bd1
\n std::string Translate(const std::string& word);
\n \/\/ \u6790\u6784\u51fd\u6570
\n ~Dictionary();
\n private:
\n std::unordered_map<std::string, std::string> _dict; \/\/ \u5b57\u5178\u7ed3\u6784
\n std::string _dict_path; \/\/ \u6587\u4ef6\u8def\u5f84
\n};<\/p>\n2.2 \u52a0\u8f7d\u5b57\u5178\u6587\u4ef6 – LoadDictionary(const std::string& path)<\/h3>\n
\n
\nvoid LoadDictionary(const std::string& path) {
\n \/\/ 1. \u8bfb\u65b9\u5f0f\u6253\u5f00\u6587\u4ef6
\n std::ifstream in(path);
\n if (!in.is_open()) {
\n LOG(LogLevel::FATAL) << "open " << path.c_str() << " failed";
\n Die(1);
\n }
\n std::string line;<\/p>\n
\n while (std::getline(in, line)) {
\n LOG(LogLevel::DEBUG) << line.c_str() << "load success";
\n if (line.empty())
\n continue; \/\/ \u4e2d\u95f4\u6709\u7a7a\u683c\u60c5\u51b5<\/p>\n
\n if (pos == std::string::npos)
\n continue; \/\/ \u627e\u4e0d\u5230\u5206\u9694\u7b26，\u8df3\u8fc7\u8be5\u884c<\/p>\n
\n if (key.empty())
\n continue; \/\/ \u952e\u4e3a\u7a7a，\u8df3\u8fc7\u8be5\u884c<\/p>\n
\n if (value.empty())
\n continue; \/\/ \u503c\u4e3a\u7a7a，\u8df3\u8fc7\u8be5\u884c<\/p>\n
\n }
\n LOG(LogLevel::INFO) << path.c_str() << " load success";<\/p>\n
\n in.close();
\n}<\/p>\n2.3 \u6784\u9020\u51fd\u6570<\/h3>\n
\nDictionary(const std::string& path = gpath + gdictname) { LoadDictionary(path); }<\/p>\n2.4 \u7ffb\u8bd1\u51fd\u6570<\/h3>\n
\nstd::string Translate(const std::string& word) {
\n auto iter = _dict.find(word);
\n if (iter == _dict.end())
\n return "None";
\n return iter->second;
\n}<\/p>\n2.5 \u670d\u52a1\u7aef\u8fd0\u884c\u66f4\u65b0<\/h3>\n
\n#include "Dictionary.hpp"<\/p>\n
\n{
\n if(argc != 2){
\n std::cerr << "Usage: " << argv[0] << " localport" << std::endl;
\n Die(1);
\n }<\/p>\n
\n std::cout << "|" << word << "|" << std::endl;
\n return dict_ptr->Translate(word);
\n });<\/p>\n
\n usvr->Start(); \/\/ \u542f\u52a8\u670d\u52a1\u7aef
\n return 0;
\n}<\/p>\n![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250422080616-68074df8a3aff.png\")
<\/p>\n🏳\ufe0f\u200d🌈\u4e09\u3001\u6574\u4f53\u4ee3\u7801<\/h2>\n
\n#include <string>
\n#include <memory>
\n#include <cstring>
\n#include <functional>
\n#include <cerrno> \/\/ \u8fd9\u4e2a\u5934\u6587\u4ef6\u5305\u542b\u4e86errno\u5b9a\u4e49，\u7528\u4e8e\u5b58\u653e\u7cfb\u7edf\u8c03\u7528\u7684\u8fd4\u56de\u503c
\n#include <strings.h> \/\/ \u5c5e\u4e8ePOSIX\u6269\u5c55\u200b（\u975e\u6807\u51c6C\/C++），\u5e38\u89c1\u4e8eUnix\/Linux\u7cfb\u7edf，\u63d0\u4f9b\u989d\u5916\u5b57\u7b26\u4e32\u51fd\u6570（\u5982 bcopy, bzero）<\/p>\n
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h><\/p>\n
\n#include "Log.hpp"
\n#include "Common.hpp"<\/p>\n
\nconst static std::string gdefaultip = "127.0.0.1"; \/\/ \u8868\u793a\u672c\u5730\u4e3b\u673a
\nconst static uint16_t gdefaultport = 8080;<\/p>\n
\nusing func_t = std::function<std::string(std::string)>;<\/p>\n
\n public:
\n nocopy(){}
\n ~nocopy(){}
\n nocopy(const nocopy&) = delete; \/\/ \u7981\u6b62\u62f7\u8d1d\u6784\u9020\u51fd\u6570
\n const nocopy& operator=(const nocopy&) = delete; \/\/ \u7981\u6b62\u62f7\u8d1d\u8d4b\u503c\u8fd0\u7b97\u7b26
\n};<\/p>\n
\n public:
\n UdpServer(uint16_t localport = gdefaultport, func_t func = nullptr)
\n : _sockfd(gsockfd),
\n _localport(localport),
\n _isrunning(false),
\n _func(func)
\n {}
\n void InitServer(){
\n \/\/ 1. \u521b\u5efa\u5957\u63a5\u5b57
\n \/\/ socket(int domain, int type, int protocol)
\n \/\/ \u8fd4\u56de\u4e00\u4e2a\u65b0\u7684\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26，\u6216\u8005\u5728\u51fa\u9519\u65f6\u8fd4\u56de-1
\n \/\/ \u53c2\u6570domain：\u534f\u8bae\u65cf，AF_INET，\u8868\u793aIPv4\u534f\u8bae\u65cf
\n \/\/ \u53c2\u6570type：\u5957\u63a5\u5b57\u7c7b\u578b，SOCK_DGRAM，\u8868\u793aUDP\u5957\u63a5\u5b57
\n \/\/ \u53c2\u6570protocol：\u534f\u8bae，0，\u8868\u793a\u9ed8\u8ba4\u534f\u8bae
\n _sockfd = ::socket(AF_INET, SOCK_DGRAM, 0);
\n if(_sockfd < 0){
\n LOG(LogLevel::FATAL) << "socket: " << strerror(errno);
\n \/\/ exit(SOCKET_ERR) \u8868\u793a\u7a0b\u5e8f\u8fd0\u884c\u5931\u8d25，\u5e76\u8fd4\u56de\u6307\u5b9a\u7684\u9519\u8bef\u7801
\n exit(SOCKET_ERR);
\n }
\n LOG(LogLevel::DEBUG) << "socket success, sockfd is: " << _sockfd;<\/p>\n
\n \/\/ sockaddr_in
\n struct sockaddr_in local;
\n \/\/ \u5c06local\u5168\u90e8\u7f6e\u96f6，\u4ee5\u4fbf\u540e\u9762\u8bbe\u7f6e
\n memset(&local, 0, sizeof(local));
\n local.sin_family = AF_INET; \/\/ IPv4\u534f\u8bae\u65cf
\n local.sin_port = htons(_localport); \/\/ \u7aef\u53e3\u53f7，\u7f51\u7edc\u5b57\u8282\u5e8f
\n local.sin_addr.s_addr = htonl(INADDR_ANY); \/\/ \u672c\u5730IP\u5730\u5740，\u7f51\u7edc\u5b57\u8282\u5e8f<\/p>\n
\n \/\/ bind(int sockfd, const struct sockaddr* addr, socklen_t addrlen)
\n \/\/ \u7ed1\u5b9a\u4e00\u4e2a\u5957\u63a5\u5b57\u5230\u4e00\u4e2a\u5730\u5740，\u4f7f\u5f97\u5957\u63a5\u5b57\u53ef\u4ee5\u63a5\u6536\u6765\u81ea\u8be5\u5730\u5740\u7684\u6570\u636e\u62a5
\n \/\/ \u53c2\u6570sockfd：\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26
\n \/\/ \u53c2\u6570addr：\u6307\u5411sockaddr_in\u7ed3\u6784\u4f53\u7684\u6307\u9488，\u8868\u793a\u8981\u7ed1\u5b9a\u7684\u5730\u5740
\n \/\/ \u53c2\u6570addrlen：\u5730\u5740\u957f\u5ea6，\u5373sizeof(sockaddr_in)
\n \/\/ \u8fd4\u56de0\u8868\u793a\u6210\u529f，-1\u8868\u793a\u51fa\u9519
\n int n = ::bind(_sockfd, (struct sockaddr* )&local, sizeof(local));
\n if(n < 0){
\n LOG(LogLevel::FATAL) << "bind: " << strerror(errno);
\n exit(BIND_ERR);
\n }
\n LOG(LogLevel::DEBUG) << "bind success";
\n }
\n void Start(){
\n _isrunning = true;
\n while(true){
\n char inbuffer[1024]; \/\/ \u63a5\u6536\u7f13\u51b2\u533a
\n struct sockaddr_in peer; \/\/ \u63a5\u6536\u5ba2\u6237\u7aef\u5730\u5740
\n socklen_t peerlen = sizeof(peer); \/\/ \u8ba1\u7b97\u63a5\u6536\u7684\u5ba2\u6237\u7aef\u5730\u5740\u957f\u5ea6<\/p>\n
\n \/\/ recvfrom(int sockfd, void* buf, size_t len, int flags, struct sockaddr* src_addr, socklen_t* addrlen)
\n \/\/ \u4ece\u5957\u63a5\u5b57\u63a5\u6536\u6570\u636e，\u5e76\u5b58\u5165buf\u6307\u5411\u7684\u7f13\u51b2\u533a\u4e2d，\u8fd4\u56de\u5b9e\u9645\u63a5\u6536\u7684\u5b57\u8282\u6570
\n \/\/ \u53c2\u6570sockfd：\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26
\n \/\/ \u53c2\u6570buf：\u6307\u5411\u63a5\u6536\u7f13\u51b2\u533a\u7684\u6307\u9488，c_str()\u51fd\u6570\u53ef\u4ee5\u5c06\u5b57\u7b26\u4e32\u8f6c\u6362\u4e3achar*，\u4ee5\u4fbf\u5b58\u5165\u7f13\u51b2\u533a
\n \/\/ \u53c2\u6570len：\u63a5\u6536\u7f13\u51b2\u533a\u7684\u957f\u5ea6
\n \/\/ \u53c2\u6570flags：\u63a5\u6536\u6807\u5fd7，\u4e00\u822c\u8bbe\u4e3a0
\n \/\/ \u53c2\u6570src_addr：\u6307\u5411\u5ba2\u6237\u7aef\u5730\u5740\u7684\u6307\u9488，\u82e5\u4e0d\u4e3aNULL，\u51fd\u6570\u8fd4\u56de\u65f6，\u8be5\u6307\u9488\u6307\u5411\u5ba2\u6237\u7aef\u7684\u5730\u5740，\u662f\u7f51\u7edc\u5b57\u8282\u5e8f
\n \/\/ \u53c2\u6570addrlen：\u5ba2\u6237\u7aef\u5730\u5740\u957f\u5ea6\u7684\u6307\u9488，\u82e5\u4e0d\u4e3aNULL，\u51fd\u6570\u8fd4\u56de\u65f6，\u8be5\u6307\u9488\u6307\u5411\u5b9e\u9645\u7684\u5ba2\u6237\u7aef\u5730\u5740\u957f\u5ea6
\n ssize_t n = ::recvfrom(_sockfd, inbuffer, sizeof(inbuffer) – 1, 0, CONV(&peer), &peerlen);
\n if(n > 0){
\n \/\/ \u5c06\u82f1\u6587\u5355\u8bcd \u8f6c\u6362\u4e3a \u4e2d\u6587
\n std::string result = _func(inbuffer);
\n ::sendto(_sockfd, result.c_str(), result.size(), 0, CONV(&peer), peerlen);
\n }
\n }
\n }
\n ~UdpServer(){
\n \/\/ \u5224\u65ad _sockfd \u662f\u5426\u662f\u4e00\u4e2a\u6709\u6548\u7684\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26
\n \/\/ \u6709\u6548\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26（\u5982\u5957\u63a5\u5b57\u3001\u6253\u5f00\u7684\u6587\u4ef6\u7b49）\u662f\u975e\u8d1f\u6574\u6570\u200b（>= 0）
\n if(_sockfd > -1) ::close(_sockfd);
\n }
\n private:
\n int _sockfd; \/\/ \u6587\u4ef6\u63cf\u8ff0\u7b26
\n uint16_t _localport; \/\/ \u7aef\u53e3\u53f7
\n std::string _localip; \/\/ \u672c\u5730IP\u5730\u5740
\n bool _isrunning; \/\/ \u8fd0\u884c\u72b6\u6001<\/p>\n
\n};<\/p>\n
\n#include "Dictionary.hpp"<\/p>\n
\n{
\n if(argc != 2){
\n std::cerr << "Usage: " << argv[0] << " localport" << std::endl;
\n Die(1);
\n }<\/p>\n
\n std::cout << "|" << word << "|" << std::endl;
\n return dict_ptr->Translate(word);
\n });<\/p>\n
\n usvr->Start(); \/\/ \u542f\u52a8\u670d\u52a1\u7aef
\n return 0;
\n}<\/p>\n
\n#include <iostream>
\n#include <cstring>
\n#include <string>
\n#include <cstdlib>
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h><\/p>\n
\n if(argc != 3){
\n std::cerr << argv[0] << " serverip server" << std::endl;
\n Die(USAGE_ERR);
\n }
\n std::string serverip = argv[1];
\n uint16_t serverport = std::stoi(argv[2]);<\/p>\n
\n int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
\n if(sockfd < 0){
\n std::cerr << "create socket error" << std::endl;
\n Die(SOCKET_ERR);
\n }<\/p>\n
\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
\n while(true){
\n std::cout << "Please Enter# ";
\n std::string msg;
\n std::getline(std::cin, msg);<\/p>\n
\n \/\/ \u5ba2\u6237\u7aef\u9996\u6b21 sendto \u6d88\u606f\u7684\u65f6\u5019，\u7531OS\u81ea\u52a8bind
\n \/\/ 1. \u5982\u4f55\u7406\u89e3 client \u81ea\u52a8\u968f\u673abind\u7aef\u53e3\u53f7？ \u4e00\u4e2a\u7aef\u53e3\u53f7，\u53ea\u80fd\u8bfb\u4e00\u4e2a\u8fdb\u7a0bbind
\n \/\/ 2. \u5982\u4f55\u7406\u89e3 server \u8981\u663e\u793a\u5730bind？ \u5fc5\u987b\u7a33\u5b9a！\u5fc5\u987b\u662f\u4f17\u6240\u5468\u77e5\u4e14\u4e0d\u80fd\u8f7b\u6613\u6539\u53d8\u7684
\n int n = ::sendto(sockfd, msg.c_str(), msg.size(), 0, CONV(&server), sizeof(server));
\n (void)n;<\/p>\n
\n socklen_t len = sizeof(temp);
\n char buffer[1024];
\n n = ::recvfrom(sockfd, buffer,sizeof(buffer) – 1, 0, CONV(&temp), &len);
\n if(n > 0){
\n buffer[n] = 0;
\n std::cout << buffer << std::endl;
\n }
\n }
\n return 0;
\n}<\/p>\n
\n do \\\\
\n { \\\\
\n exit(code); \\\\
\n } while (0)<\/p>\n
\n{
\n USAGE_ERR = 1,
\n SOCKET_ERR,
\n BIND_ERR
\n};<\/p>\n
\n#include <sys\/types.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include "Common.hpp"<\/p>\n
\n{
\nprivate:
\n void PortNet2Host()
\n {
\n _port = ::ntohs(_net_addr.sin_port);
\n }
\n void IpNet2Host()
\n {
\n char ipbuffer[64];
\n const char *ip = ::inet_ntop(AF_INET, &_net_addr.sin_addr, ipbuffer, sizeof(ipbuffer));
\n (void)ip;
\n }<\/p>\n
\n InetAddr(){}
\n InetAddr(const struct sockaddr_in &addr) : _net_addr(addr)
\n {
\n PortNet2Host();
\n IpNet2Host();
\n }
\n InetAddr(uint16_t port) : _port(port), _ip("")
\n {
\n _net_addr.sin_family = AF_INET;
\n _net_addr.sin_port = htons(_port);
\n _net_addr.sin_addr.s_addr = INADDR_ANY;
\n }
\n struct sockaddr *NetAddr() { return CONV(&_net_addr); }
\n socklen_t NetAddrLen() { return sizeof(_net_addr); }
\n std::string Ip() { return _ip; }
\n uint16_t Port() { return _port; }
\n ~InetAddr()
\n {
\n }<\/p>\n
\n struct sockaddr_in _net_addr;
\n std::string _ip;
\n uint16_t _port;
\n};<\/p>\n
\n#include <string>
\n#include <fstream>
\n#include <unordered_map>
\n#include "Log.hpp"
\n#include "Common.hpp"<\/p>\n
\nconst static std::string gpath = ".\/";
\nconst static std::string gdictname = "dict.txt";<\/p>\n
\n private:
\n \/\/ \u52a0\u8f7d\u5b57\u5178\u6587\u4ef6
\n void LoadDictionary(const std::string& path){
\n \/\/ 1. \u8bfb\u65b9\u5f0f\u6253\u5f00\u6587\u4ef6
\n std::ifstream in(path);
\n if(!in.is_open()){
\n LOG(LogLevel::FATAL) << "open " << path.c_str() << " failed";
\n Die(1);
\n }
\n std::string line;<\/p>\n
\n while(std::getline(in, line)){
\n LOG(LogLevel::DEBUG) << line.c_str() << "load success";
\n if(line.empty())
\n continue; \/\/ \u4e2d\u95f4\u6709\u7a7a\u683c\u60c5\u51b5<\/p>\n
\n if(pos == std::string::npos)
\n continue; \/\/ \u627e\u4e0d\u5230\u5206\u9694\u7b26，\u8df3\u8fc7\u8be5\u884c<\/p>\n
\n if(key.empty())
\n continue; \/\/ \u952e\u4e3a\u7a7a，\u8df3\u8fc7\u8be5\u884c<\/p>\n
\n if(value.empty())
\n continue; \/\/ \u503c\u4e3a\u7a7a，\u8df3\u8fc7\u8be5\u884c<\/p>\n
\n }
\n LOG(LogLevel::INFO) << path.c_str() << " load success";<\/p>\n
\n in.close();
\n }
\n public:
\n \/\/ \u6784\u9020\u51fd\u6570
\n Dictionary(const std::string& path = gpath + gdictname){
\n LoadDictionary(path);
\n }
\n \/\/ \u7ffb\u8bd1
\n std::string Translate(const std::string& word){
\n auto iter = _dict.find(word);
\n if(iter == _dict.end()) return "None";
\n return iter->second;
\n }
\n \/\/ \u6790\u6784\u51fd\u6570
\n ~Dictionary(){}
\n private:
\n std::unordered_map<std::string, std::string> _dict; \/\/ \u5b57\u5178\u7ed3\u6784
\n std::string _dict_path; \/\/ \u6587\u4ef6\u8def\u5f84
\n};<\/p>\n
\n#include <cstdio>
\n#include <string>
\n#include <fstream>
\n#include <sstream>
\n#include <memory>
\n#include <filesystem> \/\/C++17
\n#include <unistd.h>
\n#include <time.h>
\n#include "Mutex.hpp"<\/p>\n
\n{
\n using namespace LockModule;<\/p>\n
\n std::string CurrentTime()
\n {
\n time_t time_stamp = ::time(nullptr);
\n struct tm curr;
\n localtime_r(&time_stamp, &curr); \/\/ \u65f6\u95f4\u6233，\u83b7\u53d6\u53ef\u8bfb\u6027\u8f83\u5f3a\u7684\u65f6\u95f4\u4fe1\u606f5<\/p>\n
\n \/\/ bug
\n snprintf(buffer, sizeof(buffer), "%4d-%02d-%02d %02d:%02d:%02d",
\n curr.tm_year + 1900,
\n curr.tm_mon + 1,
\n curr.tm_mday,
\n curr.tm_hour,
\n curr.tm_min,
\n curr.tm_sec);<\/p>\n
\n }<\/p>\n
\n \/\/ 1. \u65e5\u5fd7\u6587\u4ef6\u7684\u9ed8\u8ba4\u8def\u5f84\u548c\u6587\u4ef6\u540d
\n const std::string defaultlogpath = ".\/log\/";
\n const std::string defaultlogname = "log.txt";<\/p>\n
\n enum class LogLevel
\n {
\n DEBUG = 1,
\n INFO,
\n WARNING,
\n ERROR,
\n FATAL
\n };<\/p>\n
\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 "None";
\n }
\n }<\/p>\n
\n class LogStrategy
\n {
\n public:
\n virtual ~LogStrategy() = default;
\n virtual void SyncLog(const std::string &message) = 0;
\n };<\/p>\n
\n class ConsoleLogStrategy : public LogStrategy
\n {
\n public:
\n ConsoleLogStrategy()
\n {
\n }
\n ~ConsoleLogStrategy()
\n {
\n }
\n void SyncLog(const std::string &message)
\n {
\n LockGuard lockguard(_lock);
\n std::cout << message << std::endl;
\n }<\/p>\n
\n Mutex _lock;
\n };<\/p>\n
\n class FileLogStrategy : public LogStrategy
\n {
\n public:
\n FileLogStrategy(const std::string &logpath = defaultlogpath, const std::string &logname = defaultlogname)
\n : _logpath(logpath),
\n _logname(logname)
\n {
\n \/\/ \u786e\u8ba4_logpath\u662f\u5b58\u5728\u7684.
\n LockGuard lockguard(_lock);<\/p>\n
\n {
\n return;
\n }
\n try
\n {
\n std::filesystem::create_directories(_logpath);
\n }
\n catch (std::filesystem::filesystem_error &e)
\n {
\n std::cerr << e.what() << "\\\\n";
\n }
\n }
\n ~FileLogStrategy()
\n {
\n }
\n void SyncLog(const std::string &message)
\n {
\n LockGuard lockguard(_lock);
\n std::string log = _logpath + _logname; \/\/ .\/log\/log.txt
\n std::ofstream out(log, std::ios::app); \/\/ \u65e5\u5fd7\u5199\u5165，\u4e00\u5b9a\u662f\u8ffd\u52a0
\n if (!out.is_open())
\n {
\n return;
\n }
\n out << message << "\\\\n";
\n out.close();
\n }<\/p>\n
\n std::string _logpath;
\n std::string _logname;<\/p>\n
\n Mutex _lock;
\n };<\/p>\n
\n class Logger
\n {
\n public:
\n Logger()
\n {
\n \/\/ \u9ed8\u8ba4\u91c7\u7528ConsoleLogStrategy\u7b56\u7565
\n _strategy = std::make_shared<ConsoleLogStrategy>();
\n }
\n void EnableConsoleLog()
\n {
\n _strategy = std::make_shared<ConsoleLogStrategy>();
\n }
\n void EnableFileLog()
\n {
\n _strategy = std::make_shared<FileLogStrategy>();
\n }
\n ~Logger() {}
\n \/\/ \u4e00\u6761\u5b8c\u6574\u7684\u4fe1\u606f: [2024-08-04 12:27:03] [DEBUG] [202938] [main.cc] [16] + \u65e5\u5fd7\u7684\u53ef\u53d8\u90e8\u5206(<< "hello world" << 3.14 << a << b;)
\n class LogMessage
\n {
\n public:
\n LogMessage(LogLevel level, const std::string &filename, int line, Logger &logger)
\n : _currtime(CurrentTime()),
\n _level(level),
\n _pid(::getpid()),
\n _filename(filename),
\n _line(line),
\n _logger(logger)
\n {
\n std::stringstream ssbuffer;
\n ssbuffer << "[" << _currtime << "] "
\n << "[" << Level2String(_level) << "] "
\n << "[" << _pid << "] "
\n << "[" << _filename << "] "
\n << "[" << _line << "] – ";
\n _loginfo = ssbuffer.str();
\n }
\n template <typename T>
\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 }<\/p>\n
\n std::string _currtime; \/\/ \u5f53\u524d\u65e5\u5fd7\u7684\u65f6\u95f4
\n LogLevel _level; \/\/ \u65e5\u5fd7\u7b49\u7ea7
\n pid_t _pid; \/\/ \u8fdb\u7a0bpid
\n std::string _filename; \/\/ \u6e90\u6587\u4ef6\u540d\u79f0
\n int _line; \/\/ \u65e5\u5fd7\u6240\u5728\u7684\u884c\u53f7
\n Logger &_logger; \/\/ \u8d1f\u8d23\u6839\u636e\u4e0d\u540c\u7684\u7b56\u7565\u8fdb\u884c\u5237\u65b0
\n std::string _loginfo; \/\/ \u4e00\u6761\u5b8c\u6574\u7684\u65e5\u5fd7\u8bb0\u5f55
\n };<\/p>\n
\n LogMessage operator()(LogLevel level, const std::string &filename, int line)
\n {
\n return LogMessage(level, filename, line, *this);
\n }<\/p>\n
\n std::shared_ptr<LogStrategy> _strategy; \/\/ \u65e5\u5fd7\u5237\u65b0\u7684\u7b56\u7565\u65b9\u6848
\n };<\/p>\n
\n#define ENABLE_CONSOLE_LOG() logger.EnableConsoleLog()
\n#define ENABLE_FILE_LOG() logger.EnableFileLog()
\n}<\/p>\n
\n#include <iostream>
\n#include <pthread.h><\/p>\n
\n{
\n class Mutex
\n {
\n public:
\n Mutex(const Mutex&) = delete;
\n const Mutex& operator = (const Mutex&) = delete;
\n Mutex()
\n {
\n int n = ::pthread_mutex_init(&_lock, nullptr);
\n (void)n;
\n }
\n ~Mutex()
\n {
\n int n = ::pthread_mutex_destroy(&_lock);
\n (void)n;
\n }
\n void Lock()
\n {
\n int n = ::pthread_mutex_lock(&_lock);
\n (void)n;
\n }
\n pthread_mutex_t *LockPtr()
\n {
\n return &_lock;
\n }
\n void Unlock()
\n {
\n int n = ::pthread_mutex_unlock(&_lock);
\n (void)n;
\n }<\/p>\n
\n pthread_mutex_t _lock;
\n };<\/p>\n
\n {
\n public:
\n LockGuard(Mutex &mtx):_mtx(mtx)
\n {
\n _mtx.Lock();
\n }
\n ~LockGuard()
\n {
\n _mtx.Unlock();
\n }
\n private:
\n Mutex &_mtx;
\n };
\n}<\/p>\n
\nall:server_udp client_udp<\/p>\n
\ng++ -o $@ $^ -std=c++17<\/p>\n
\ng++ -o $@ $^ -std=c++17<\/p>\n
\nclean:
\nrm -f server_udp client_udp<\/p>\n
\n👥\u603b\u7ed3<\/h2>\n