\u7262\u84af\u7684\u6e90\u7801\u5728\u4e0b\u9762\u7684\u4ed3\u5e93\u91cc，\u5404\u4f4d\u5927\u4f6c\u53ef\u4ee5\u81ea\u884c\u53d6\u7528，\u53e4\u6cd5\u7f16\u7a0b，\u96be\u514d\u6709bug，\u5927\u4f6c\u4eec\u53ef\u5728\u8bc4\u8bba\u533a\u6307\u51fa\u9519\u8bef\u3002<\/p>\n
https:\/\/gitee.com\/laotian666\/linux_storage.git<\/p>\n
UDP\u5c5e\u4e8e\u65e0\u8fde\u63a5\u4f20\u8f93\u534f\u8bae，\u901a\u4fe1\u53cc\u65b9\u4e0d\u9700\u8981\u9884\u5148\u5efa\u7acb\u8fde\u63a5\u3002\u672c\u9879\u76ee\u5168\u90e8\u57fa\u4e8eUDP\u5957\u63a5\u5b57\u63a5\u53e3\u5f00\u53d1，\u5728\u9605\u8bfb\u9879\u76ee\u4ee3\u7801\u524d，\u5148\u719f\u6089\u9879\u76ee\u7528\u5230\u7684\u7cfb\u7edf\u7ed3\u6784\u4f53\u4e0e\u7cfb\u7edf\u8c03\u7528\u3002<\/p>\n
sockaddr_in\u662fIPv4\u4e13\u7528\u5730\u5740\u7ed3\u6784\u4f53，\u7528\u4e8e\u4fdd\u5b58IP\u5730\u5740\u3001\u7aef\u53e3\u3001\u534f\u8bae\u65cf\u4fe1\u606f\u3002\u7cfb\u7edf\u5957\u63a5\u5b57\u63a5\u53e3\u7684\u5f62\u53c2\u7edf\u4e00\u4e3a\u901a\u7528\u7ed3\u6784\u4f53struct sockaddr，\u4f7f\u7528\u7684\u65f6\u5019\u5fc5\u987b\u505a\u5f3a\u5236\u7c7b\u578b\u8f6c\u6362\u3002<\/p>\n
struct sockaddr_in
\n{
\n sa_family_t sin_family;
\n in_port_t sin_port;
\n struct in_addr sin_addr;
\n unsigned char sin_zero[8];
\n};<\/p>\n
struct in_addr
\n{
\n uint32_t s_addr;
\n};<\/p>\n
\u7279\u6b8a\u5b8fINADDR_ANY，\u53ef\u4ee5\u8ba9\u670d\u52a1\u7aef\u7ed1\u5b9a\u672c\u673a\u6240\u6709\u7f51\u5361，\u63a5\u6536\u672c\u673a\u4efb\u610f\u7f51\u5361\u4e0a\u5230\u6765\u7684\u5ba2\u6237\u7aef\u8bf7\u6c42\u3002\u5c06sockaddr_in\u4f20\u7ed9bind\u3001recvfrom\u3001sendto\u63a5\u53e3\u65f6，\u5fc5\u987b\u5f3a\u8f6c\u4e3astruct sockaddr*\u7c7b\u578b\u3002<\/p>\n
\u7f51\u7edc\u4f20\u8f93\u7edf\u4e00\u4f7f\u7528\u5927\u7aef\u5b57\u8282\u5e8f，\u5bb6\u7528\u8ba1\u7b97\u673a\u4e3b\u673a\u5927\u591a\u662f\u5c0f\u7aef\u6a21\u5f0f，\u4e3b\u673a\u4e0e\u7f51\u7edc\u4e4b\u95f4\u9700\u8981\u8fdb\u884c\u5b57\u8282\u5e8f\u8f6c\u6362\u3002<\/p>\n
uint16_t htons(uint16_t hostshort);
\nuint16_t ntohs(uint16_t netshort);<\/p>\n
\u7aef\u53e3\u662f16\u4f4d\u77ed\u6574\u578b，\u6240\u4ee5\u4f7f\u7528\u8fd9\u4e00\u7ec4\u63a5\u53e3，IP\u5730\u5740\u8f6c\u6362\u4f7f\u7528inet_ntop\u3001inet_pton\u3002<\/p>\n
recvfrom\u662fUDP\u63a5\u6536\u6570\u636e\u7684\u4e13\u7528\u63a5\u53e3，\u63a5\u6536\u62a5\u6587\u7684\u540c\u65f6，\u5185\u6838\u4f1a\u586b\u5145\u53d1\u9001\u65b9\u7684\u7f51\u7edc\u5730\u5740\u4fe1\u606f\u3002<\/p>\n
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
\n struct sockaddr *src_addr, socklen_t *addrlen);<\/p>\n
\u8fd4\u56de\u503c\u5927\u4e8e0\u4ee3\u8868\u6210\u529f\u63a5\u6536\u7684\u5b57\u8282\u6570，\u8fd4\u56de-1\u4ee3\u8868\u8c03\u7528\u51fa\u9519\u3002<\/p>\n
\u26a0\ufe0f\u91cd\u8981：UDP\u62a5\u6587\u4e0d\u4f1a\u81ea\u5e26\u5b57\u7b26\u4e32\u7ed3\u675f\u7b26\\\\0，\u62ff\u5230\u8fd4\u56de\u5b57\u8282\u6570\u4e4b\u540e，\u9700\u8981\u624b\u52a8\u5728\u7f13\u51b2\u533a\u672b\u5c3e\u8865\\\\0，\u624d\u53ef\u4ee5\u5f53\u505aC++\u5b57\u7b26\u4e32\u5904\u7406\u3002<\/p>\n
UDP\u53d1\u9001\u6570\u636e\u7684\u7cfb\u7edf\u8c03\u7528，\u56e0\u4e3aUDP\u6ca1\u6709\u8fde\u63a5\u7684\u6982\u5ff5，\u6bcf\u6b21\u53d1\u9001\u6570\u636e\u90fd\u5fc5\u987b\u663e\u5f0f\u6307\u5b9a\u76ee\u6807\u5ba2\u6237\u7aef\u5730\u5740\u3002<\/p>\n
ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
\n const struct sockaddr *dest_addr, socklen_t addrlen);<\/p>\n
\u8c03\u7528\u6210\u529f\u8fd4\u56de\u5b9e\u9645\u53d1\u9001\u5b57\u8282\u6570，\u5931\u8d25\u8fd4\u56de-1\u3002\u6bcf\u8c03\u7528\u4e00\u6b21sendto\u5c31\u4f1a\u751f\u6210\u4e00\u4e2a\u5b8c\u6574UDP\u6570\u636e\u62a5\u3002<\/p>\n
int socket(int domain, int type, int protocol);<\/p>\n
\u672c\u9879\u76ee\u8c03\u7528\u5f62\u5f0f\u4e3asocket(AF_INET, SOCK_DGRAM, 0)\u3002<\/p>\n
\u8c03\u7528\u6210\u529f\u8fd4\u56de\u5957\u63a5\u5b57\u6587\u4ef6\u63cf\u8ff0\u7b26，\u5931\u8d25\u8fd4\u56de-1\u3002<\/p>\n
int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);<\/p>\n
\u670d\u52a1\u7aef\u7a0b\u5e8f\u9700\u8981\u8c03\u7528bind，\u628asocket\u548c\u672c\u673aIP\u3001\u7aef\u53e3\u7ed1\u5b9a，\u64cd\u4f5c\u7cfb\u7edf\u624d\u53ef\u4ee5\u628a\u5bf9\u5e94\u7aef\u53e3\u6536\u5230\u7684\u62a5\u6587\u4ea4\u7ed9\u5f53\u524d\u8fdb\u7a0b\u5904\u7406\u3002<\/p>\n
💡UDP\u5ba2\u6237\u7aef\u4e00\u822c\u4e0d\u9700\u8981\u624b\u52a8bind，\u64cd\u4f5c\u7cfb\u7edf\u4f1a\u81ea\u52a8\u5206\u914d\u4e34\u65f6\u7aef\u53e3\u3002\u642d\u914dINADDR_ANY\u53ef\u4ee5\u76d1\u542c\u672c\u673a\u5168\u90e8\u7f51\u5361\u3002<\/p>\n
const char *inet_ntop(int af, const void *src, char *dst, socklen_t size);
\nint inet_pton(int af, const char *src, void *dst);<\/p>\n
\u2757\u91cd\u70b9：\u820d\u5f03\u8001\u65e7\u63a5\u53e3inet_ntoa\u3002inet_ntoa\u5185\u90e8\u4f7f\u7528\u9759\u6001\u7f13\u51b2\u533a，\u591a\u7ebf\u7a0b\u73af\u5883\u8c03\u7528\u4f1a\u51fa\u73b0\u6570\u636e\u8986\u76d6，\u7ebf\u7a0b\u4e0d\u5b89\u5168，\u9879\u76ee\u4e2d\u7edf\u4e00\u4f7f\u7528inet_ntop\u3002<\/p>\n
\u670d\u52a1\u7aef\u6267\u884c\u6d41\u7a0b：\u8c03\u7528socket\u521b\u5efaUDP\u5957\u63a5\u5b57 \u2192 \u586b\u5145sockaddr_in\u7ed3\u6784\u4f53\u6267\u884cbind\u7ed1\u5b9a\u7aef\u53e3 \u2192 \u5faa\u73af\u8c03\u7528recvfrom\u7b49\u5f85\u63a5\u6536\u5ba2\u6237\u7aef\u62a5\u6587 \u2192 \u6267\u884c\u4e1a\u52a1\u903b\u8f91\u5904\u7406\u6570\u636e \u2192 \u8c03\u7528sendto\u5c06\u7ed3\u679c\u56de\u4f20\u7ed9\u5ba2\u6237\u7aef\u3002<\/p>\n
\u5ba2\u6237\u7aef\u6267\u884c\u6d41\u7a0b：\u8c03\u7528socket\u521b\u5efaUDP\u5957\u63a5\u5b57 \u2192 \u586b\u5145\u670d\u52a1\u7aef\u5730\u5740\u7ed3\u6784\u4f53 \u2192 \u8c03\u7528sendto\u53d1\u9001\u8bf7\u6c42\u62a5\u6587 \u2192 \u8c03\u7528recvfrom\u63a5\u6536\u670d\u52a1\u7aef\u5e94\u7b54\u3002<\/p>\n
\u2728UDP\u65e0\u8fde\u63a5\u7279\u6027，\u6bcf\u6b21\u6536\u53d1\u6570\u636e\u90fd\u9700\u8981\u643a\u5e26\u5bf9\u65b9\u5730\u5740\u4fe1\u606f，\u56e0\u6b64UDP\u4e00\u822c\u4f7f\u7528recvfrom\u3001sendto，\u800c\u4e0d\u4f7f\u7528\u7b80\u5355\u7684read\u3001write\u63a5\u53e3\u3002<\/p>\n
\u672c\u9879\u76ee\u4f7f\u7528C++\u5b9e\u73b0\u4e00\u4e2aUDP\u7248\u672c\u82f1\u6c49\u8bcd\u5178\u7ffb\u8bd1\u670d\u52a1\u5668\u3002\u5ba2\u6237\u7aef\u901a\u8fc7UDP\u53d1\u9001\u82f1\u6587\u5355\u8bcd，\u670d\u52a1\u7aef\u8bfb\u53d6\u672c\u5730\u8bcd\u5178\u6587\u4ef6\u5b8c\u6210\u5355\u8bcd\u67e5\u8be2，\u5c06\u4e2d\u6587\u91ca\u4e49\u8fd4\u56de\u5ba2\u6237\u7aef；\u67e5\u8be2\u4e0d\u5230\u5355\u8bcd\u5219\u8fd4\u56deNone\u3002<\/p>\n
\u9879\u76ee\u91c7\u7528\u5206\u5c42\u89e3\u8026\u8bbe\u8ba1，\u5c06\u4e92\u65a5\u9501\u3001\u65e5\u5fd7\u7cfb\u7edf\u3001\u7f51\u7edc\u5730\u5740\u5c01\u88c5\u3001UDP\u7f51\u7edc\u670d\u52a1\u3001\u8bcd\u5178\u4e1a\u52a1\u76f8\u4e92\u89e3\u8026\u3002 \u7528\u5230\u7684\u6280\u672f\u70b9\u5305\u542b：RAII\u601d\u60f3\u3001\u7b56\u7565\u6a21\u5f0f\u3001std::function\u56de\u8c03\u51fd\u6570\u3001UDP\u5957\u63a5\u5b57\u7f16\u7a0b\u3001C++17\u6587\u4ef6\u7cfb\u7edf\u5e93\u3002<\/p>\n
\u539f\u751fpthread\u5e93\u9501\u5bb9\u6613\u51fa\u73b0\u5fd8\u8bb0\u89e3\u9501\u9020\u6210\u6b7b\u9501，\u8fd9\u91cc\u505a\u9762\u5411\u5bf9\u8c61\u5c01\u88c5，\u5e76\u4e14\u5b9e\u73b0RAII\u5b88\u536b\u9501，\u51fa\u4f5c\u7528\u57df\u81ea\u52a8\u91ca\u653e\u9501\u8d44\u6e90，\u907f\u514d\u5fd8\u8bb0unlock\u3002<\/p>\n
#ifndef __MUTEX_HPP__
\n#define __MUTEX_HPP__
\n#include <pthread.h>
\nnamespace MyMutex
\n{
\n class Mutex
\n {
\n public:
\n Mutex()
\n {
\n pthread_mutex_init(&_mutex,nullptr);
\n }
\n void Lock()
\n {
\n int n = pthread_mutex_lock(&_mutex);
\n (void)n;
\n }
\n void UnLock()
\n {
\n int n = pthread_mutex_unlock(&_mutex);
\n (void)n;
\n }
\n ~Mutex()
\n {
\n pthread_mutex_destroy(&_mutex);
\n }
\n pthread_mutex_t* Get()
\n {
\n return &_mutex;
\n }
\n private:
\n pthread_mutex_t _mutex ;
\n };<\/p>\n
class GuardMutex
\n {
\n public:
\n \/\/\u2757\u4fee\u590d\u539fbug：\u5fc5\u987b\u4f20\u5f15\u7528，\u4e0d\u80fd\u503c\u62f7\u8d1dMutex\u5bf9\u8c61
\n GuardMutex(Mutex& mutex)
\n :_mutex(mutex)
\n {
\n _mutex.Lock();
\n }
\n ~GuardMutex()
\n {
\n _mutex.UnLock();
\n }
\n private:
\n Mutex& _mutex ;
\n };
\n}
\n#endif <\/p>\n
\u2757\u539f\u59cb\u4ee3\u7801bug：GuardMutex\u503c\u4f20\u9012Mutex\u5bf9\u8c61，\u4f1a\u62f7\u8d1d\u9501\u5bf9\u8c61，\u9501\u903b\u8f91\u5b8c\u5168\u5931\u6548，\u672c\u9879\u76ee\u4fee\u590d\u4e3a\u5f15\u7528\u4f20\u9012\u3002<\/p>\n
\u65e5\u5fd7\u6a21\u5757\u4f7f\u7528\u7b56\u7565\u6a21\u5f0f，\u62bd\u8c61\u65e5\u5fd7\u5237\u65b0\u57fa\u7c7b，\u6d3e\u751f\u51fa\u63a7\u5236\u53f0\u6253\u5370\u7b56\u7565\u3001\u6587\u4ef6\u5199\u5165\u7b56\u7565\u3002 \u6bcf\u6761\u65e5\u5fd7\u81ea\u52a8\u643a\u5e26：\u65f6\u95f4\u6233\u3001\u65e5\u5fd7\u7b49\u7ea7\u3001\u8fdb\u7a0bPID\u3001\u6e90\u7801\u6587\u4ef6\u540d\u3001\u4ee3\u7801\u884c\u53f7\u3002\u501f\u52a9\u5b8f\u81ea\u52a8\u6355\u83b7__FILE__\u4e0e__LINE__，\u4f7f\u7528\u6d41\u5f0f<<\u5199\u6cd5\u8f93\u51fa\u65e5\u5fd7\u3002<\/p>\n
#pragma once
\n#include<iostream>
\n#include<string>
\n#include"Mutex.hpp"
\n#include<fstream>
\n#include<cstdio>
\n#include<memory>
\n#include<unistd.h>
\n#include<ctime>
\n#include <filesystem>
\n#include<sstream>
\nnamespace LogModule
\n{
\n const std::string gsep = "\\\\r\\\\n";
\n using namespace MyMutex;<\/p>\n
\/\/\u65e5\u5fd7\u7b56\u7565\u62bd\u8c61\u57fa\u7c7b
\n class LogStrategy
\n {
\n public:
\n ~LogStrategy() = default;
\n virtual void SyncLog(const std::string& message) = 0;
\n };<\/p>\n
\/\/\u63a7\u5236\u53f0\u8f93\u51fa\u7b56\u7565
\n class ConsoleLogStrategy: public LogStrategy
\n {
\n public:
\n virtual void SyncLog(const std::string& message) override
\n {
\n GuardMutex lockGuard(_mutex);
\n std::cout << message << "\\\\r\\\\n";
\n }
\n ~ConsoleLogStrategy() {}
\n private:
\n Mutex _mutex;
\n };<\/p>\n
const std::string defaultpath = ".\/log";
\n const std::string defaultfile = "my.log";
\n \/\/\u6587\u4ef6\u843d\u76d8\u8f93\u51fa\u7b56\u7565
\n class FileLogStrategy: public LogStrategy
\n {
\n public:
\n FileLogStrategy(const std::string& path = defaultpath,const std::string& file = defaultfile)
\n :_path(path)
\n ,_file(file)
\n {
\n GuardMutex lock_guard(_mutex);
\n if(std::filesystem::exists(_path))
\n {
\n return;
\n }
\n try
\n {
\n \/\/C++17 \u521b\u5efa\u76ee\u5f55
\n std::filesystem::create_directories(_path);
\n }
\n catch(const std::filesystem::filesystem_error &e)
\n {
\n std::cout << e.what() << '\\\\n';
\n }
\n }
\n virtual void SyncLog(const std::string& message) override
\n {
\n GuardMutex lockGuard(_mutex);
\n std::string filename = _path + (_path.back() == '\/' ? "" : "\/") + _file;
\n std::ofstream out(filename,std::ios::app);
\n if(!out.is_open())
\n {
\n return;
\n }
\n out << message << gsep;
\n out.close();
\n }
\n ~FileLogStrategy() {}
\n private:
\n std::string _path;
\n std::string _file;
\n Mutex _mutex;
\n };<\/p>\n
\/\/\u65e5\u5fd7\u7b49\u7ea7，\u4ece\u4f4e\u5230\u9ad8 DEBUG < INFO < WARNNING < ERROR < FATAL
\n enum class LogLevel
\n {
\n DEBUG,
\n INFO,
\n WARNNING,
\n ERROR,
\n FATAL
\n };<\/p>\n
inline std::string Level2Str(LogLevel level)
\n {
\n switch(level)
\n {
\n case LogLevel::DEBUG:
\n return "DEBUG";
\n case LogLevel::INFO:
\n return "INFO";
\n case LogLevel::WARNNING:
\n return "WARNNING";
\n case LogLevel::ERROR:
\n return "ERROR";
\n case LogLevel::FATAL:
\n return "FATAL";
\n default:
\n return "Unknown!";
\n }
\n }<\/p>\n
inline std::string GetTimeStamp()
\n {
\n time_t curr = time(nullptr);
\n struct tm curr_tm;
\n localtime_r(&curr,&curr_tm);
\n char buffer[128];
\n snprintf(buffer,sizeof(buffer),"%4d-%02d-%02d %02d:%02d:%02d",
\n curr_tm.tm_year + 1900,
\n curr_tm.tm_mon + 1,
\n curr_tm.tm_mday,
\n curr_tm.tm_hour,
\n curr_tm.tm_min,
\n curr_tm.tm_sec
\n );
\n return buffer;
\n }<\/p>\n
class Logger
\n {
\n public:
\n Logger()
\n {
\n EnableConsoleLogStrategy();
\n }
\n \/\/\u5207\u6362\u65e5\u5fd7\u8f93\u51fa\u5230\u6587\u4ef6
\n void EnableFileLogStrategy()
\n {
\n _fflush_strategy = std::make_unique<FileLogStrategy>();
\n }
\n \/\/\u5207\u6362\u65e5\u5fd7\u8f93\u51fa\u5230\u63a7\u5236\u53f0
\n void EnableConsoleLogStrategy()
\n {
\n _fflush_strategy = std::make_unique<ConsoleLogStrategy>();
\n }<\/p>\n
\/\/\u4e34\u65f6\u6d88\u606f\u7c7b，\u6790\u6784\u7684\u65f6\u5019\u771f\u6b63\u8f93\u51fa\u65e5\u5fd7
\n class LogMessage
\n {
\n public:
\n LogMessage(LogLevel level,std::string src_file,int line_number,Logger& logger)
\n :_level(level)
\n ,_src_file(src_file)
\n ,_line_number(line_number)
\n ,_pid(getpid())
\n ,_logger(logger)
\n ,_time(GetTimeStamp())
\n {
\n std::stringstream ss;
\n ss << "[" << _time << "]"
\n << "[" << Level2Str(_level) << "]"
\n << "[" << _pid << "]"
\n << "[" << _src_file << "]"
\n << "[" << _line_number << "]"
\n << "- ";
\n _log_info = ss.str();
\n }
\n template<typename T>
\n LogMessage& operator << (const T& info)
\n {
\n std::stringstream ss;
\n ss << info;
\n _log_info += ss.str();
\n return *this;
\n }
\n \/\/\u2757**\u5173\u952e：\u4e34\u65f6\u5bf9\u8c61\u6790\u6784，\u624d\u6267\u884c\u65e5\u5fd7\u843d\u5730\u8f93\u51fa**
\n ~LogMessage()
\n {
\n if(_logger._fflush_strategy)
\n {
\n _logger._fflush_strategy->SyncLog(_log_info);
\n }
\n }
\n private:
\n std::string _time;
\n LogLevel _level;
\n pid_t _pid;
\n std::string _src_file;
\n int _line_number;
\n std::string _log_info;
\n Logger& _logger;
\n };<\/p>\n
LogMessage operator()(LogLevel level,std::string src_file,int line_number)
\n {
\n return LogMessage(level,src_file,line_number,*this);
\n }
\n ~Logger()
\n {}
\n private:
\n std::unique_ptr<LogStrategy> _fflush_strategy;
\n };<\/p>\n
extern Logger log;
\n \/\/\u5b8f\u81ea\u52a8\u586b\u5145__FILE__ __LINE__，\u7b80\u5316\u8c03\u7528
\n #define LOG(level) log(level,__FILE__,__LINE__)
\n #define Enable_File_Log_Strategy() log.EnableFileLogStrategy()
\n #define Enable_Console_Log_Strategy() log.EnableConsoleLogStrategy()
\n}<\/p>\n
\u65e5\u5fd7\u4f7f\u7528\u793a\u4f8b：<\/p>\n
LOG(LogLevel::INFO) << "\u670d\u52a1\u5668\u542f\u52a8\u6210\u529f";
\nEnable_File_Log_Strategy();<\/p>\n
\u65e5\u5fd7\u8f93\u51fa\u6837\u4f8b：<\/p>\n
[2026-10-24 16:20:10][INFO][14523][UdpServer.hpp][40]- \u521b\u5efa\u5957\u63a5\u5b57\u6210\u529f，\u5957\u63a5\u5b57\u503c\u4e3a：4<\/p>\n
💡\u6838\u5fc3\u539f\u7406：LogMessage\u662f\u4e34\u65f6\u5bf9\u8c61，\u6267\u884c\u5b8cLOG(xxx) << "xxx";\u8fd9\u4e00\u884c，\u5bf9\u8c61\u6790\u6784，\u624d\u8c03\u7528SyncLog\u5b8c\u6210\u65e5\u5fd7\u8f93\u51fa\u3002<\/p>\n
\u5c06\u5185\u6838\u8fd4\u56de\u7684sockaddr_in\u7ed3\u6784\u4f53\u8fdb\u884c\u5c01\u88c5，\u628a\u7f51\u7edc\u5b57\u8282\u5e8f\u7684\u7aef\u53e3\u3001\u4e8c\u8fdb\u5236IP\u8f6c\u6362\u6210\u7a0b\u5e8f\u53ef\u8bfb\u7684\u5b57\u7b26\u4e32\u4e0euint16_t\u7c7b\u578b\u3002<\/p>\n
\u2757\u539f\u59cb\u4ee3\u7801inet_ntoa\u4f7f\u7528\u9759\u6001\u7f13\u51b2\u533a，\u591a\u7ebf\u7a0b\u4e0d\u5b89\u5168，\u672c\u9879\u76ee\u66ff\u6362\u4e3a\u7ebf\u7a0b\u5b89\u5168\u7684inet_ntop\u3002<\/p>\n
#pragma once
\n#include<iostream>
\n#include<sys\/socket.h>
\n#include<sys\/types.h>
\n#include<netinet\/in.h>
\n#include<arpa\/inet.h>
\n#include"Log.hpp"
\n#include<string>
\n#include<strings.h>
\n#include<functional><\/p>\n
class InetAddr
\n{
\npublic:
\n InetAddr(struct sockaddr_in& addr)
\n :_addr(addr)
\n {
\n \/\/\u7f51\u7edc\u7aef\u53e3\u8f6c\u4e3b\u673a\u5b57\u8282\u5e8f
\n _port = ntohs(_addr.sin_port);
\n char ipbuf[INET_ADDRSTRLEN];
\n \/\/\u4e8c\u8fdb\u5236ip\u8f6c\u70b9\u5206\u5341\u8fdb\u5236\u5b57\u7b26\u4e32
\n inet_ntop(AF_INET,&_addr.sin_addr,ipbuf,INET_ADDRSTRLEN);
\n _ip = ipbuf;
\n }
\n std::string IP()
\n {
\n return _ip;
\n }
\n uint16_t Port()
\n {
\n return _port;
\n }
\n ~InetAddr()
\n {}
\nprivate:
\n struct sockaddr_in _addr;
\n std::string _ip;
\n uint16_t _port;
\n};<\/p>\n
UDP\u670d\u52a1\u5668\u7c7b，\u8d1f\u8d23socket\u521b\u5efa\u3001bind\u7ed1\u5b9a\u7aef\u53e3，\u5faa\u73af\u6267\u884crecvfrom\u63a5\u6536\u5ba2\u6237\u7aef\u62a5\u6587\u3002<\/p>\n
\u2728\u8bbe\u8ba1\u4eae\u70b9：\u4f7f\u7528std::function\u56de\u8c03，\u5f7b\u5e95\u89e3\u8026\u7f51\u7edcIO\u4e0e\u4e0a\u5c42\u4e1a\u52a1\u4ee3\u7801，\u7f51\u7edc\u6a21\u5757\u4e0d\u9700\u8981\u5173\u5fc3\u5177\u4f53\u662f\u8bcd\u5178\u7ffb\u8bd1\u8fd8\u662f\u5176\u4ed6\u4e1a\u52a1\u3002<\/p>\n
#pragma once
\n#include<iostream>
\n#include<sys\/socket.h>
\n#include<sys\/types.h>
\n#include<netinet\/in.h>
\n#include<arpa\/inet.h>
\n#include"Log.hpp"
\n#include<string>
\n#include<strings.h>
\n#include<functional>
\n#include"InetAddr.hpp"
\nusing namespace LogModule;
\n\/\/\u56de\u8c03\u51fd\u6570\u7b7e\u540d：\u8f93\u5165\u5ba2\u6237\u7aef\u5b57\u7b26\u4e32+\u5ba2\u6237\u7aef\u5730\u5740，\u8fd4\u56de\u5904\u7406\u5b8c\u6210\u8981\u53d1\u9001\u7684\u5b57\u7b26\u4e32
\nusing func = std::function<std::string(const std::string&,InetAddr&)>;
\nconst int defaultfd = -1;<\/p>\n
class UdpServer
\n{
\npublic:
\n UdpServer(uint16_t port,func func)
\n :_sockfd(defaultfd)
\n ,_port(port)
\n ,_isrunning(false)
\n ,_func(func)
\n {}
\n void Init()
\n {
\n _sockfd = socket(AF_INET,SOCK_DGRAM,0);
\n if(_sockfd < 0)
\n {
\n LOG(LogLevel::FATAL) << "\u521b\u5efa\u5957\u63a5\u5b57\u5931\u8d25";
\n exit(1);
\n }
\n LOG(LogLevel::INFO) << "\u521b\u5efa\u5957\u63a5\u5b57\u6210\u529f，\u5957\u63a5\u5b57\u503c\u4e3a：" << _sockfd;<\/p>\n
struct sockaddr_in local;
\n bzero(&local,sizeof(local));
\n local.sin_family = AF_INET;
\n local.sin_port = htons(_port);
\n \/\/\u2757INADDR_ANY\u76d1\u542c\u672c\u673a\u6240\u6709\u7f51\u5361
\n local.sin_addr.s_addr = INADDR_ANY;<\/p>\n
int n = bind(_sockfd,(struct sockaddr*)&local,sizeof(local));
\n if(n < 0)
\n {
\n LOG(LogLevel::FATAL) << "\u7ed1\u5b9a\u5931\u8d25";
\n exit(2);
\n }
\n LOG(LogLevel::INFO) << "\u7ed1\u5b9a\u6210\u529f,\u5957\u63a5\u5b57\u4e3a：" << _sockfd;
\n }
\n void Start()
\n {
\n _isrunning = true;
\n while(_isrunning)
\n {
\n char buffer[1024];
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n ssize_t s = recvfrom(_sockfd,buffer,sizeof(buffer) – 1,0,(struct sockaddr*)&peer,&len);
\n if(s > 0)
\n {
\n InetAddr client(peer);
\n \/\/\u2757UDP\u4e0d\u4f1a\u81ea\u5e26\\\\0，\u624b\u52a8\u8865\u5b57\u7b26\u4e32\u7ed3\u675f\u7b26
\n buffer[s] = 0;
\n \/\/\u8c03\u7528\u5916\u90e8\u4f20\u5165\u7684\u56de\u8c03\u51fd\u6570，\u6267\u884c\u4e1a\u52a1\u903b\u8f91
\n std::string res = _func(buffer,client);
\n sendto(_sockfd,res.c_str(),res.size(),0,(struct sockaddr*)&peer,len);
\n }
\n }
\n }
\n ~UdpServer(){}
\nprivate:
\n int _sockfd;
\n uint16_t _port;
\n bool _isrunning;
\n func _func;
\n};<\/p>\n
\u8bcd\u5178\u4e1a\u52a1\u7c7b，\u4ece\u672c\u5730\u6587\u672c\u6587\u4ef6\u8bfb\u53d6\u8bcd\u5178\u5185\u5bb9，\u6309\u82f1\u6587: \u4e2d\u6587\u5206\u5272，\u5b58\u5165unordered_map\u54c8\u5e0c\u8868\u505a\u9ad8\u901f\u67e5\u8be2\u3002\u5bf9\u5916\u63d0\u4f9bTranslate\u63a5\u53e3\u3002<\/p>\n
\u2757\u539f\u59cb\u4ee3\u7801bug：DickLoad\u786c\u7f16\u7801\u5199\u6b7b\u6587\u4ef6\u540d，\u5ffd\u7565\u6784\u9020\u51fd\u6570\u4f20\u5165\u7684\u8def\u5f84\u6210\u5458\u53d8\u91cf，\u672c\u9879\u76ee\u505a\u4fee\u590d\u3002<\/p>\n
#pragma once
\n#include<iostream>
\n#include<string>
\n#include<unordered_map>
\n#include"Log.hpp"
\n#include<fstream>
\n#include"InetAddr.hpp"
\nconst std::string defaultdict = ".\/Dictionary.txt";
\nconst std::string gap = ": ";
\nusing namespace LogModule;<\/p>\n
class Dick
\n{
\npublic:
\n Dick(const std::string& path = ::defaultdict)
\n :_dick_path(path)
\n {}
\n bool DickLoad()
\n {
\n \/\/\u4f7f\u7528\u6210\u5458\u53d8\u91cf，\u652f\u6301\u81ea\u5b9a\u4e49\u8bcd\u5178\u8def\u5f84
\n std::ifstream in(_dick_path);
\n if(!in.is_open())
\n {
\n LOG(LogLevel::FATAL) << "\u5b57\u5178:" << _dick_path << "\u6253\u5f00\u5931\u8d25";
\n return false;
\n }
\n std::string line;
\n while(std::getline(in,line))
\n {
\n auto pos = line.find(gap);
\n if(pos == std::string::npos)
\n {
\n LOG(LogLevel::WARNNING) << "\u67e5\u627e\u9519\u8bef！";
\n continue;
\n }
\n std::string english = line.substr(0,pos);
\n std::string chinese = line.substr(pos + gap.size());
\n if(english.empty() || chinese.empty())
\n {
\n LOG(LogLevel::WARNNING) << "\u6ca1\u6709\u6709\u6548\u5185\u5bb9" << line;
\n continue;
\n }
\n _dick.insert(std::make_pair(english,chinese));
\n LOG(LogLevel::INFO) << "\u8f7d\u5165: " << line << "\u6210\u529f";
\n }
\n in.close();
\n return true;
\n }
\n \/\/\u7ffb\u8bd1\u63a5\u53e3：\u4f20\u5165\u5355\u8bcd\u4e0e\u5ba2\u6237\u7aef\u5730\u5740，\u8fd4\u56de\u91ca\u4e49，\u627e\u4e0d\u5230\u8fd4\u56de"None"
\n std::string Translate(const std::string& word,InetAddr& client)
\n {
\n auto iter = _dick.find(word);
\n if(iter == _dick.end())
\n {
\n return "None";
\n }
\n LOG(LogLevel::DEBUG) << "\u5df2\u8fdb\u5165\u7ffb\u8bd1\u6a21\u5757，" << "[" << client.IP() << ":" <<client.Port() << "]# " << word << iter->second;
\n return iter->second;
\n }
\n ~Dick()
\n {}
\nprivate:
\n std::string _dick_path;
\n std::unordered_map<std::string,std::string> _dick;
\n};<\/p>\n
\u26a0\ufe0f\u683c\u5f0f\u4e25\u683c：\u5206\u5272\u7b26\u5fc5\u987b\u662f\u5192\u53f7+\u7a7a\u683c : ，\u8981\u548c\u4ee3\u7801\u4e2dgap\u5e38\u91cf\u4fdd\u6301\u4e00\u81f4\u3002<\/p>\n
apple: \u82f9\u679c
\nbanana: \u9999\u8549
\ncat: \u732b
\ndog: \u72d7
\nbook: \u4e66
\npen: \u7b14
\nhappy: \u5feb\u4e50\u7684
\nsad: \u60b2\u4f24\u7684
\nrun: \u8dd1
\njump: \u8df3
\nteacher: \u8001\u5e08
\nstudent: \u5b66\u751f
\ncar: \u6c7d\u8f66
\nbus: \u516c\u4ea4\u8f66
\nlove: \u7231
\nhate: \u6068
\nhello: \u4f60\u597d
\ngoodbye: \u518d\u89c1
\nsummer: \u590f\u5929
\nwinter: \u51ac\u5929<\/p>\n
\u7ec4\u88c5\u5168\u90e8\u6a21\u5757，\u5c06\u8bcd\u5178\u7ffb\u8bd1\u65b9\u6cd5\u4f5c\u4e3alambda\u56de\u8c03\u4f20\u5165UdpServer，\u542f\u52a8\u670d\u52a1\u5668\u3002\u8865\u5145\u5168\u5c40log\u5bf9\u8c61\u7684\u5b9a\u4e49，\u89e3\u51b3\u5934\u6587\u4ef6extern\u58f0\u660e\u94fe\u63a5\u62a5\u9519\u3002<\/p>\n
#include"UdpServer.hpp"
\n#include"Dick.hpp"
\n\/\/\u2757\u5168\u5c40log\u5bf9\u8c61\u5b9a\u4e49，\u89e3\u51b3\u94fe\u63a5\u95ee\u9898
\nnamespace LogModule{
\n Logger log;
\n}<\/p>\n
int main()
\n{
\n Enable_File_Log_Strategy();<\/p>\n
Dick dict;
\n if(!dict.DickLoad())
\n {
\n LOG(LogLevel::FATAL) << "\u8bcd\u5178\u52a0\u8f7d\u5931\u8d25";
\n return 1;
\n }<\/p>\n
uint16_t port = 8080;
\n \/\/lambda\u8868\u8fbe\u5f0f\u4f5c\u4e3a\u56de\u8c03，\u7f51\u7edc\u5c42\u6536\u5230\u62a5\u6587\u5c31\u4f1a\u6267\u884c\u8fd9\u4e2alambda
\n UdpServer server(port,[&dict](const std::string& word,InetAddr& client){
\n return dict.Translate(word,client);
\n });<\/p>\n
server.Init();
\n server.Start();<\/p>\n
return 0;
\n}<\/p>\n
\u672c\u9879\u76ee\u4f9d\u8d56C++17\u6807\u51c6，\u7528\u5230filesystem\u5e93，\u7f16\u8bd1\u5fc5\u987b\u6307\u5b9a-std=c++17，\u94fe\u63a5\u7ebf\u7a0b\u5e93-lpthread\u3002<\/p>\n
CC=g++
\nCFLAGS=-std=c++17 -g -lpthread<\/p>\n
src=main.cc
\ntarget=dick_server<\/p>\n
$(target):$(src)
\n$(CC) $(src) -o $(target) $(CFLAGS)<\/p>\n
.PHONY:clean
\nclean:
\nrm -f $(target)
\nrm -rf log<\/p>\n
\u628a\u6240\u6709\u5934\u6587\u4ef6\u3001\u6e90\u6587\u4ef6\u653e\u5230\u540c\u4e00\u76ee\u5f55，\u6267\u884cmake\u547d\u4ee4\u5b8c\u6210\u7f16\u8bd1\u3002<\/p>\n
make<\/p>\n
.\/dick_server<\/p>\n
\u6253\u5f00\u65b0\u7ec8\u7aef，\u4f7f\u7528nc\u5de5\u5177\u8fdb\u884cUDP\u4ea4\u4e92\u6d4b\u8bd5\u3002<\/p>\n
nc -u 127.0.0.1 8080<\/p>\n
\u8f93\u5165\u82f1\u6587\u5355\u8bcd，\u670d\u52a1\u7aef\u8fd4\u56de\u4e2d\u6587\u91ca\u4e49，\u4e0d\u5b58\u5728\u5355\u8bcd\u8fd4\u56deNone\u3002<\/p>\n
apple
\n\u82f9\u679c
\ndog
\n\u72d7
\ntest
\nNone<\/p>\n
\u7262\u84af\u7684\u6e90\u7801\u5728\u4e0b\u9762\u7684\u4ed3\u5e93\u91cc，\u5404\u4f4d\u5927\u4f6c\u53ef\u4ee5\u81ea\u884c\u53d6\u7528，\u53e4\u6cd5\u7f16\u7a0b，\u96be\u514d\u6709bug，\u5927\u4f6c\u4eec\u53ef\u5728\u8bc4\u8bba\u533a\u6307\u51fa\u9519\u8bef\u3002
\nhttps:\/\/gitee.com\/laotian666\/linux_storage.git 0 \u524d\u7f6e\u77e5\u8bc6：UDP\u7f51\u7edc\u7f16\u7a0b\u6838\u5fc3\u63a5\u53e3\u4e0e\u7ed3\u6784\u4f53
\nUDP\u5c5e\u4e8e\u65e0\u8fde\u63a5\u4f20\u8f93\u534f\u8bae，\u901a\u4fe1\u53cc\u65b9\u4e0d\u9700\u8981\u9884\u5148\u5efa\u7acb\u8fde\u63a5\u3002\u672c\u9879\u76ee\u5168\u90e8\u57fa\u4e8eUDP\u5957\u63a5\u5b57\u63a5\u53e3\u5f00\u53d1，\u5728\u9605\u8bfb\u9879\u76ee\u4ee3\u7801\u524d，\u5148\u719f\u6089\u9879\u76ee\u7528\u5230\u7684<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[868,58,43,78,44],"topic":[],"class_list":["post-117752","post","type-post","status-publish","format-standard","hentry","category-server","tag-868","tag-linux","tag-43","tag-78","tag-44"],"yoast_head":"\n