TCP自定义协议实现计算器——遇到的问题+补充知识

目录粘包问题为什么 read() 会这样模板方法模式问题场景多个类有相同的流程但细节不同解决方法模板方法模式bugJSON测试JSON的便捷解析\r与\n粘包问题问TCP通信中什么叫“第三个参数buf”可能只读取到一个半单词而非完整单词ssize_t n read (AcceptSockfd, buf, sizeof (buf) - 1);为什么read()会这样因为TCP 是流式协议数据像水流一样text客户端发送 [Hello] [World] ↓ ↓ TCP缓冲区 [HelloWorld] ← 合并成连续字节流 ↓ 服务端read 取走任意长度由缓冲区大小和网络状态决定read()读取多少字节取决于你给的缓冲区大小sizeof(buf) - 1 1023内核接收缓冲区中现有数据量网络延迟数据可能还没到齐TCP 的流控机制接收窗口大小所以read()的哲学是你让我读能读多少我就读多少绝不保证读完一个完整消息。模板方法模式问题场景多个类有相同的流程但细节不同// 两个网络请求类流程一样但解析方式不同 class HttpRequest { public: void Process() { Connect(); SendRequest(); ParseResponse(); // 具体解析逻辑不同 Disconnect(); } // ... 具体实现 }; class FtpRequest { public: void Process() { Connect(); SendRequest(); ParseResponse(); // 这里解析FTP协议 Disconnect(); } // ... 具体实现 };解决方法模板方法模式class BaseRequest { // 定义骨架 public: void Process() { // 模板方法 Connect(); SendRequest(); ParseResponse(); // 交给子类 Disconnect(); } protected: virtual void Connect() { /* 通用实现 */ } virtual void SendRequest() { /* 通用实现 */ } virtual void Disconnect() { /* 通用实现 */ } virtual void ParseResponse() 0; // 纯虚函数子类必须实现 }; class HttpRequest : public BaseRequest { protected: void ParseResponse() override { /* HTTP解析 */ } }; class FtpRequest : public BaseRequest { protected: void ParseResponse() override { /* FTP解析 */ } };bugvoid CommonSetAddr(struct sockaddr_in addr, const char* IP) { //清楚 bzero (addr, sizeof (addr)); addr.sin_family AF_INET; // addr.sin_addr.s_addr inet_pton() /////// int ret inet_pton (*sockfd, IP, addr.sin_addr); //err第一个参数int __af代表地址家族不是sockfd套接字!!! int ret inet_pton (AF_INET, IP, addr.sin_addr); if(ret 0) { if(ret 0) { LOG (LogLevel::FATAL) 无效IP: IP; exit (INETPTON_ERROR); } LOG (LogLevel::FATAL) IP转换发生错误; exit (INETPTON_ERROR); } }JSON测试int main() { Json::Value root; root[age] 18; root[_age] 18; Json::FastWriter write; std::string s write.write (root); std::cout s std::endl; return 0; }JSON的便捷解析JSON格式“key” “” “[空格]” “value”// {x: 10, y : 20, oper : } bool Deserialize(std::string in) { // 10 20 - 以空格作为分隔符 - 10 20 Json::Value root; Json::Reader reader; bool ok reader.parse(in, root); if (ok) { _x root[x].asInt(); _y root[y].asInt(); _oper root[oper].asInt(); //? } return ok; }其中parse的解析原则输入字符串: {x: 10, y : 20, oper : } ↓ 1. 词法分析Tokenizer→ 拆成 token 流 { x : 10 , y : 20 , oper : } ↓ 2. 语法分析Parser→ 按 JSON 语法规则解析 Object: { x: Number(10), y: Number(20), oper: String() } ↓ 3. 构建 Json::Value 树 Json::Value root: root[x] 10 root[y] 20 root[oper] ↓ 4. 返回 true解析成功\r与\n字符ASCII码含义动作\r0x0D(13)回车Carriage Return把打印头移到行首不换行\n0x0A(10)换行Line Feed把纸张向上移动一行不归位自定义协议设计原则由基层到顶层依次设计、服务封装写代码不仅是写更要理解其中的架构。就像顶层(计算服务)协议层(计算结果加密解密)服务器层通信、接收计算、处理计算、发送计算结果实现返回一个特定返回值、特定参数的函数的函数有哪些方法要求返回一个 using func_t std::functionResponse (Request request); 的fun_t模块。错误1.lambda表达式return [this] (Request request) -Response{ \ return this-ComCaculate(request); \ };lambda表达式本身作为GetHandle的返回值使用了lambda表达式本质是一个匿名类对象函数对象。2.使用typedef ....typedef Response (*Handle)Request;// 定义函数类型 typedef Response (*HandlerFunc)(Request); // 普通函数 Response handleRequest(Request req) { // 处理请求 return Response(); } // 返回函数指针 HandlerFunc getHandler() { return handleRequest; }3.类函数成员静态化// 类静态函数 class Server { public: static Response staticHandler(Request req) { // 静态处理 return Response(); } HandlerFunc getStaticHandler() { return Server::staticHandler; } };