自定义协议、序列化与反序列化

在编写TCP和UDP程序的时候，我们很自然的就使用了读取的函数对数据进行获取，对于UDP来说提供的是无连接的以数据报的形式进行传输，对于TCP来说是面向数据流的，在之前的程序中我们只是进行了读取的操作，但是并没有对读取的内容进行分析。那如果我们要传输一些结构化的数据的话，那么就需要引入"协议"这个概念。

网络版计算器

在本文中将实现一个服务器版本的加法器，需要客户端把要计算的两个加数发过去,然后由服务器进行计算, 最后再把结果返回给客户端。

协议的约定

我们在这里约定信息，让协议能够更好的进行实现：

  • 客户端发送一个形如"1+1"的字符串；
  • 这个字符串中有两个操作数, 都是整形；
  • 两个数字之间会有一个字符是运算符, 运算符只能是 “±*/%”；
  • 数字和运算符之间没有空格；

序列化与反序列化

  • 定义结构体来表示我们需要交互的信息；
  • 发送数据时将这个结构体按照一个规则转换成字符串, 接收到数据的时候再按照相同的规则把字符串转化回结构体；
  • 同时通过使用Jsoncpp的库进行协议的序列化与反序列化

TcpServer.hpp

namespace tcpserver_ns{using namespace protocol_ns; // 使用自定义协议的工作空间class TcpServer;using func_t = std::function<Response (const Request&)>;    class ThreadData{public:ThreadData(int sock, std::string ip, uint16_t port, TcpServer *tsvrp): _sock(sock) , _ip(ip) ,_port(port), _tsvrp(tsvrp){}~ThreadData(){}public:int _sock;std::string _ip;uint16_t _port;TcpServer* _tsvrp;};class TcpServer{public:TcpServer(func_t func, uint16_t port) : _func(func), _port(port){}void InitServer(){ // 初始化相关的套接字信息_listensock.Socket();_listensock.Bind(_port);_listensock.Listen();logMessage(Info, "init server done, listensock: %d", _listensock.Fd());}static void* ThreadRoutine(void* args){pthread_detach(pthread_self());logMessage(Debug, "thread running ...");ThreadData* td = static_cast<ThreadData*>(args);td->_tsvrp->ServiceIO(td->_sock, td->_ip, td->_port); // 调用ServiceIO进行数据的读取与写入logMessage(Debug, "thread quit, client quit ... ");delete td;return nullptr;}void Start(){ // Accept 建立连接for(;;){std::string clientip;uint16_t clientport;int sock = _listensock.Accept(&clientip, &clientport);if (sock < 0) continue;logMessage(Debug, "get a new client, client info : [%s:%d]", clientip.c_str(), clientport);pthread_t tid;ThreadData *td = new ThreadData(sock, clientip, clientport, this); // 构建线程的数据信息pthread_create(&tid, nullptr, ThreadRoutine, td); // 创建线程运行ThreadRoutine}} // 这个函数是被多线程调用的// 这里如果我们直接使用前面的文章中使用的read函数进行读取就无法保证获取的数据是我们想要的与计算相关的信息，// 因此此时需要我们自己根据自定义的协议来处理数据 -- 在这里我们规定每次我们需要的完整的报文是 "7"\r\n"10 + 20"\r\n 这样的形式，前面的数字表示有效报文的长度，报文长度与有效载荷之间通过"\r\n"来隔开void ServiceIO(int sock, const std::string &ip, const uint16_t &port){std::string inbuffer; // 放在外面，防止每次循环被释放while(true){// 0. 怎么保证读到的是一个完整的字符串报文？ "7"\r\n""10 + 20"\r\nstd::string package;int n = ReadPackage(sock, inbuffer, &package); // 对获取的数据流进行处理，分出协议所需要的报文if (n == -1)break;else if (n == 0)continue;else{// 一定得到了一个 "7"\r\n""10 + 20"\r\n// 1. 你需要的只是有效载荷 "10 + 20"package = RemoveHeader(package, n); // 对报文的有效载荷进行分离，获取有效载荷// decode// 2. 假设已经读到了一个完整的string "10 + 20"Request req;req.Deserialize(package); // 对读到的request字符串要进行反序列化// 3. 直接提取用户的请求数据啦Response resp = _func(req); // 业务逻辑！处理响应的计算业务// 4. 给用户返回响应 - 序列化std::string send_string;resp.Serialize(&send_string); // 对计算完毕的response结构要进行序列化，形成可发送字符串// 5. 添加报头send_string = AddHeader(send_string); // 给需要返回的结果添加报头//encode// 6. 发送到网络 -- 弱化send(sock, send_string.c_str(), send_string.size(), 0); // 简易版本的发送}}close(sock);}~TcpServer(){_listensock.Close();}private:uint16_t _port;Sock _listensock;func_t _func;};
}

Protocol.hpp

自定义协议类以及Jsoncpp库使用：

#include <jsoncpp/json/json.h>
#include "Util.hpp"
#define MYSELF 1
namespace protocol_ns{#define SEP " "#define SEP_LEN strlen(SEP)#define HEADER_SEP "\r\n"#define HEADER_SEP_LEN strlen(HEADER_SEP)// "长度"\r\n""_x _op _y"\r\n// "10 + 20" => "7"\r\n""10 + 20"\r\n => 报头 + 有效载荷// 请求/响应 = 报头\r\n有效载荷\r\nstd::string AddHeader(const std::string &str){ // 添加报头std::cout << "AddHeader 之前:\n" << str << std::endl;std::string s = std::to_string(str.size());s += HEADER_SEP;s += str;s += HEADER_SEP;std::cout << "AddHeader 之后:\n" << s << std::endl;return s;}// "7"\r\n""10 + 20"\r\n => "10 + 20"std::string RemoveHeader(const std::string &str, const int &len){ // 移除报头std::cout << "RemoveHeader 之前:\n" << str << std::endl;std::string res = str.substr(str.size() - HEADER_SEP_LEN - len, len);std::cout << "RemoveHeader 之后:\n" << res << std::endl;return res;}int ReadPackage(int sock, std::string &inbuffer, std::string *package){ // 正确读取需要的报文std::cout << "ReadPackage inbuffer 之前:\n" << inbuffer << std::endl;// 边读取char buffer[1024];ssize_t s = recv(sock, buffer, sizeof(buffer) - 1, 0);if (s <= 0)return -1; // 读取出错buffer[s] = 0;inbuffer += buffer;std::cout << "ReadPackage inbuffer 之中:\n" << inbuffer << std::endl;// 边分析auto pos = inbuffer.find(HEADER_SEP);if (pos == std::string::npos)return 0;                                                    // 读取的不完善std::string lenStr = inbuffer.substr(0, pos);                    // 获取了头部字符串int len = Util::toInt(lenStr);                                   // "123" -> 123int targetpackageLen = lenStr.size() + len + 2 * HEADER_SEP_LEN; // 添加了报头的目标字符串长度if (inbuffer.size() < targetpackageLen)return 0;                                    // 读取的不完善*package = inbuffer.substr(0, targetpackageLen); // 提取报文// 到此为止，inbuffer 什么都没动inbuffer.erase(0, targetpackageLen); // 从inbuffer中直接移除整个报文std::cout << "ReadPackage inbuffer 之后:\n" << inbuffer << std::endl;return len; // 读取成功}// Request && Response都要提供序列化和反序列化功能class Request{public:Request(){}Request(int x, int y, char op) : _x(x), _y(y), _op(op){}// 目前 "_x _op _y"bool Serialize(std::string *outStr){*outStr = "";
#ifdef MYSELFstd::string x_string = std::to_string(_x);std::string y_string = std::to_string(_y);*outStr = x_string + SEP + _op + SEP + y_string;std::cout << "Request Serialize:\n" << *outStr << std::endl;
#elseJson::Value root; // Value：一种万能对象，接受任意的kv对象root["x"] = _x;root["y"] = _y;root["op"] = _op; // 填充字段// Json::FastWriter writer; // Writer：是用来进行序列化的 struct -> stringJson::StyledWriter writer; // 将Json转成好看一点的字符串// {//     "op" : 43,//     "x" : 1,//     "y" : 1// }*outStr = writer.write(root);
#endif return true;}bool Deserialize(const std::string &inStr){
#ifdef MYSELF// inStr : 10 + 20 => [0]=>10, [1]=>+, [2]=>20// string -> vectorstd::vector<std::string> result;Util::StringSplit(inStr, SEP, &result);if (result.size() != 3)return false;if (result[1].size() != 1)return false;_x = Util::toInt(result[0]);_y = Util::toInt(result[2]);_op = result[1][0];
#elseJson::Value root;Json::Reader reader; // Reader：用来进行反序列化的reader.parse(inStr, root);_x = root["x"].asInt();_y = root["y"].asInt();_op = root["op"].asInt();
#endifreturn true;}~Request(){}public:// _x + _op + _yint _x;int _y;char _op;};class Response{public:Response(){}Response(int result, int code) : _result(result), _code(code){}bool Serialize(std::string *outStr){*outStr = "";
#ifdef MYSELFstd::string res_string = std::to_string(_result);std::string code_string = std::to_string(_code);*outStr = res_string + SEP + code_string;std::cout << "Response Serialize:\n" << *outStr << std::endl;
#elseJson::Value root;root["result"] = _result;root["code"] = _code;// Json::FastWriter writer;Json::StyledWriter writer;*outStr = writer.write(root);
#endifreturn true;}bool Deserialize(const std::string &inStr){
#ifdef MYSELFstd::vector<std::string> result;Util::StringSplit(inStr, SEP, &result);if (result.size() != 2)return false;_result = Util::toInt(result[0]);_code = Util::toInt(result[1]);
#elseJson::Value root;Json::Reader reader; // Reader：用来进行反序列化的reader.parse(inStr, root);_result = root["result"].asInt();_code = root["code"].asInt();
#endifreturn true;}~Response(){}public:int _result;int _code; // 0->success 1,2,3,4代表不同的错误};
}// Util.hpp 工具类的实现
class Util
{
public:// 输入: const &// 输出: *// 输入输出: &static bool StringSplit(const string &str, const string &sep, vector<string> *result){size_t start = 0;// + 20// "abcd efg" -> for(int i = 0; i < 10; i++) !=  for(int i = 0; i <= 9; i++)while (start < str.size()){auto pos = str.find(sep, start);if (pos == string::npos) break;result->push_back(str.substr(start, pos-start));// 位置的重新reloadstart = pos + sep.size();}if(start < str.size())  result->push_back(str.substr(start));return true;}static int toInt(const std::string &s){return atoi(s.c_str());}

CalculatorServer.cc

Response calculate(const Request &req){ // 主体的计算处理模块Response resp(0, 0);switch (req._op){case '+':resp._result = req._x + req._y;break;case '-':resp._result = req._x - req._y;break;case '*':resp._result = req._x * req._y;break;case '/':if (req._y == 0)resp._code = 1;elseresp._result = req._x / req._y;break;case '%':if (req._y == 0)resp._code = 2;elseresp._result = req._x % req._y;break;default:resp._code = 3;break;}return resp;
}int main(){uint16_t port = 8081;std::unique_ptr<TcpServer> tsvr(new TcpServer(calculate, port)); // TODOtsvr->InitServer();tsvr->Start();return 0;
}

CalculatorClient.cc

using namespace protocol_ns;
static void usage(std::string proc){std::cout << "Usage:\n\t" << proc << " serverip serverport\n"<< std::endl;
}
enum{LEFT,OPER,RIGHT
};
// 10+20
Request ParseLine(const std::string &line){ // 将输入的数据通过ParseLine函数进行分割并添加到请求所需要的变量中std::string left, right;char op;int status = LEFT;int i = 0;while(i < line.size()){// if(isdigit(e)) left.push_back;switch (status){case LEFT:if (isdigit(line[i]))left.push_back(line[i++]);elsestatus = OPER;break;case OPER:op = line[i++];status = RIGHT;break;case RIGHT:if (isdigit(line[i]))right.push_back(line[i++]);break;}}Request req;std::cout << "left: " << left << std::endl;std::cout << "right: " << right << std::endl;std::cout << "op: " << op << std::endl;req._x = std::stoi(left);req._y = std::stoi(right);req._op = op;return req;
}// ./tcpclient serverip serverport
int main(int argc, char *argv[]){if (argc != 3){usage(argv[0]);exit(USAGE_ERR);}std::string serverip = argv[1];uint16_t serverport = atoi(argv[2]);Sock sock;sock.Socket();int n = sock.Connect(serverip, serverport);if (n != 0)return 1;std::string buffer;while (true){std::cout << "Enter# "; // 1+1,2*9 // 这里的目标是要将输入的数据构建成前面的形式std::string line;std::getline(std::cin, line);Request req = ParseLine(line);std::cout << "test: " << req._x << req._op << req._y << std::endl;// 1. 序列化std::string sendString;req.Serialize(&sendString);// 2. 添加报头sendString = AddHeader(sendString);// 3. sendsend(sock.Fd(), sendString.c_str(), sendString.size(), 0);// 4. 获取响应std::string package;int n = 0;START:n = ReadPackage(sock.Fd(), buffer, &package);if (n == 0)goto START;else if (n < 0)break;else{}// 5. 去掉报头package = RemoveHeader(package, n);// 6. 反序列化Response resp;resp.Deserialize(package);std::cout << "result: " << resp._result << "[code: " << resp._code << "]" << std::endl;}sock.Close();return 0;
}

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/84095.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

修复Ripro主题扫码后空白或null或array的问题

修复Ripro主题扫码后空白或null或array的问题

WordPress Ripro主题使用的人比较多&#xff0c;绝大部分用的盗版主题&#xff0c;RiPro主题使用虎皮椒V3支付接口在使用弹窗支付的时候&#xff0c;微信或者支付宝扫码后出现null或array&#xff0c;会发生在ripro所有版本中。下面是修复方法&#xff1a; 打开ripro主题inc目…
阅读更多...
安科瑞为工业能效提升行动计划提供EMS解决方案-安科瑞黄安南

安科瑞为工业能效提升行动计划提供EMS解决方案-安科瑞黄安南

摘要: 2022年6月29日工信部、发改委、财政部、生态环境部、国资委、市场监管总局六部门联合下发《关于印发工业能效提升行动计划的通知》&#xff08;工信部联节〔2022〕76号&#xff0c;以下简称《行动计划》&#xff09;&#xff0c;主要目的是为了提高工业领域能源利用效率&…
阅读更多...
Hbase分布式集群部署

Hbase分布式集群部署

目录 一、环境说明 二、部署Hbase 2.1 解压Hbase 2.2 移动解压包 2.3 修改 hbase-env.sh文件 2.4 修改环境变量 2.5 修改hbase-site.xml文件 2.6 修改regionservers 文件 2.7 分发hbase 2.7.1 分发hbase包 2.7.2 分发环境配置 2.8 启动hbase服务 2.8.1 环境生效 …
阅读更多...
Tungsten Fabric数据量过大问题处理初探

Tungsten Fabric数据量过大问题处理初探

开源SDN系统Tungsten Fabric面临数据产生过多问题。 经排查&#xff0c;产生数据多出自analytics组件的Cassandra数据库()。很多分析数据会存储至Cassandra库&#xff0c;并持久化处理。 没有特殊调整的话&#xff0c;目录在 /var/lib/docker/volumes/analytics_database_an…
阅读更多...
抗锯齿的线

抗锯齿的线

抗锯齿的线 右下角的时候h是0,到顶部 h是1&#xff0c;然后中间y相距4个像素&#xff0c;那dy就是0.25 如果让h abs(fract(h - 0.5) - 0.5) 中间一行0.5&#xff0c;第一行 第三行都是0.25&#xff0c;两端都是0 根据插值来看 这里是 如果用h/dy 那么第一行以上&#xff0…
阅读更多...
【ROS入门】创建工作空间与功能包

【ROS入门】创建工作空间与功能包

文章结构 工作空间文件结构创建工作空间流程创建工作空间编译工作空间设置环境变量/创建功能包创建功能包编译功能包 检查环境变量 工作空间文件结构 工作空间(workspace)是一个存放工程开发相关文件的文件夹&#xff0c;类似于在windows中使用IDE创建的工程。主要分为以下四个…
阅读更多...
【element-ui】form表单动态修改rules校验项

【element-ui】form表单动态修改rules校验项

在项目开发过程中&#xff0c;该页面有暂存和提交两个按钮&#xff0c;其中暂存和提交必填项校验不一样&#xff0c;此时需要动态增减必填项校验 &#xff0c;解决方法如下&#xff1a; 增加rules校验项 this.$set(this.formRules,name,[{required:true,message:请输入名称,t…
阅读更多...
Layui快速入门之第十三节 日期与时间选择器

Layui快速入门之第十三节 日期与时间选择器

目录 一&#xff1a;基本用法 API 渲染 属性 弹出提示 2.8 获取实例 2.8 解除实例绑定 2.8 关闭日期面板 2.7 获取某月的最后一天 二&#xff1a;常规用法 三&#xff1a;多类型选择器 四&#xff1a;范围选择 五&#xff1a;直接静态显示 六&#xff1a;更多功能…
阅读更多...
断点测试怎么做？一文教你用Charles 工具做好接口测试！

断点测试怎么做？一文教你用Charles 工具做好接口测试！

在测试工作过程中&#xff0c;我们经常会在程序的某一行或者某一环节设置断点&#xff0c;在程序请求的过程中&#xff0c;修改断点处的参数、请求或者响应&#xff0c;借此定位问题&#xff0c;这就是所谓的断点测试。这类断点测试主要用于接口测试。 断点测试可以通过查看接…
阅读更多...
C语言关于自定义字符函数和字符串函数的相关笔试题（找工作必看）

C语言关于自定义字符函数和字符串函数的相关笔试题（找工作必看）

本篇字符函数和字符串函数 求字符串长度 strlen 长度不受限制的字符串函数 strcpy strcat strcmp 长度受限制的字符串函数介绍 strncpy strncat strncmp 字符串查找 strstr strtok 错误信息报告 strerror 内存操作函数 memcpy memmove memset memcmp 在我们笔试时&#xff0c;很…
阅读更多...
mysql限制用户登录失败次数,限制时间

mysql限制用户登录失败次数,限制时间

mysql用户登录限制设置 mysql 需要进行用户登录次数限制,当使用密码登录超过 3 次认证链接失败之后,登录锁住一段时间,禁止登录这里使用的 mysql: 8.1.0 这种方式不用重启数据库. 配置: 首先进入到 mysql 命令行:然后需要安装两个插件: 在 mysql 命令行中执行: mysql> INS…
阅读更多...
易基因｜ONT：三代原核甲基化在痤疮杆菌噬菌体表观遗传印迹中的工程选择性研究

易基因｜ONT：三代原核甲基化在痤疮杆菌噬菌体表观遗传印迹中的工程选择性研究

大家好&#xff0c;这里是专注表观组学十余年&#xff0c;领跑多组学科研服务的易基因。 痤疮表皮杆菌&#xff08;Cutibacterium acnes&#xff0c;C.acnes&#xff09;是一种革兰氏阳性细菌&#xff0c;是人类皮肤微生物组成员。尽管是最丰富的皮肤共生体&#xff0c;但某些…
阅读更多...
详细介绍下VLAN隔离与VLAN之间互联

详细介绍下VLAN隔离与VLAN之间互联

什么VLAN&#xff1f; VLAN代表虚拟局域网&#xff08;Virtual Local Area Network&#xff09;&#xff0c;它是一种在物理网络基础上创建逻辑上独立的虚拟网络的技术。VLAN允许将一个局域网划分为多个虚拟的逻辑网络&#xff0c;这些虚拟网络在逻辑上相互隔离&#xff0c;就…
阅读更多...
支付宝开发问题：很抱歉，系统监测到你的支付宝账号有异常，入驻失败，如需帮助请拨打热线

支付宝开发问题：很抱歉，系统监测到你的支付宝账号有异常，入驻失败，如需帮助请拨打热线

想开发个支付宝小程序&#xff0c;结果困难重重啊 妹的&#xff0c;这一个星期一直都被这个问题困扰&#xff0c;找了一个个体户资质&#xff0c;一直失败&#xff0c;专门去注册了一个公司&#xff0c;还是提交失败。 给支付宝客服打电话&#xff0c;跟没打一样&#xff0c;…
阅读更多...
外包干了2个月，技术退步明显.......

外包干了2个月，技术退步明显.......

先说一下自己的情况&#xff0c;大专生&#xff0c;18年通过校招进入武汉某软件公司&#xff0c;干了接近4年的功能测试&#xff0c;今年年初&#xff0c;感觉自己不能够在这样下去了&#xff0c;长时间呆在一个舒适的环境会让一个人堕落! 而我已经在一个企业干了四年的功能测…
阅读更多...
Windows系统如何部署Wing FTP Server与公网远程访问【内网穿透】

Windows系统如何部署Wing FTP Server与公网远程访问【内网穿透】

Wing FTP Server安装配置结合内网穿透实现公网访问本地站点 文章目录 Wing FTP Server安装配置结合内网穿透实现公网访问本地站点前言1.Wing FTP Server下载安装2.Wing FTP Server配置部署3.安装cpolar内网穿透3.1 注册账号3.2 下载cpolar客户端3.3 登录cpolar web ui管理界面3…
阅读更多...
使用 sklearn 进行数学建模的通用模板

使用 sklearn 进行数学建模的通用模板

前言 无论是本科和研究生都会有的数学建模含金量还是很高的&#xff0c;下面将介绍一下进行数学建模的一些基本操作方法&#xff0c;这里主要是利用sklearn 进行建模&#xff0c;包括前期的一些数据预处理以及一些常用的机器学习模型以及一些简单粗暴的通用建模步骤&#xff0…
阅读更多...
在 Simscape Electrical 中对两区 MVDC 电动船的建模和仿真（Simulink实现）

在 Simscape Electrical 中对两区 MVDC 电动船的建模和仿真（Simulink实现）

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…
阅读更多...
springboot集成mybatis-plus

springboot集成mybatis-plus

一、在spring boot中配置mybatis-plus 1、创建一个spring boot项目&#xff0c;注意勾选mysql 2、在pom.xml文件中添加mybatis-plus的依赖包 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0&qu…
阅读更多...
Llama-2 推理和微调的硬件要求总结：RTX 3080 就可以微调最小模型

Llama-2 推理和微调的硬件要求总结：RTX 3080 就可以微调最小模型

大语言模型微调是指对已经预训练的大型语言模型&#xff08;例如Llama-2&#xff0c;Falcon等&#xff09;进行额外的训练&#xff0c;以使其适应特定任务或领域的需求。微调通常需要大量的计算资源&#xff0c;但是通过量化和Lora等方法&#xff0c;我们也可以在消费级的GPU上…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023