【计算机网络学习之路】序列化，反序列化和初识协议

前言

本系列文章是计算机网络学习的笔记，欢迎大佬们阅读，纠错，分享相关知识。希望可以与你共同进步。

本篇博文正式开始应用层的学习，首先讲解应用层的序列化和反序列化，还有了解简单的应用层传输协议

一. 序列化和反序列化

在前篇TCP和UDP服务器编写时，业务只是简单的echo客户端发送的数据，但实际生活中，要传输的数据往往复杂的多。使用结构体或类可以保存更多数据，但传输过程中，可能会遇到网络通信两端的操作系统不同，结构体/类的大小不同，内存对齐策略不一致等问题。所以网络传输十分不建议传输结构体或类。
这时，序列化和反序列化诞生了。

序列化通俗来说，就是将结构体/类转化为字符串；而反序列化就是将字符串转化为结构体

序列化最重要的作用：在传递和保存对象时，保证对象的完整性和可传递性等问题。对象转换为有序字节流，以便在网络上传输或者保存在本地文件中。

反序列化最重要的作用：根据字节流中保存的对象状态及描述信息，通过反序列化重建对象

核心作用就是对象状态的保存和重建。（整个过程核心点就是字节流所保存的对象状态及描述信息）

1.自己实现

案例

假如我们现在要实现一个网络版本的计算器
我们把客户端发送的数据称为需求（Request），服务器返回的数据叫做响应（Responce）
此案例的需求有三个变量：数字x，数字y，操作数op
响应有两个变量：结果result，结果码code
需求和响应都需要有序列化和反序列化两个功能函数
代码如下：

使用分割符方便Request提取变量，分隔符——空格
1+1 =>(添加分隔符) 1 + 1

#define SEP " " //分隔符
#define SEP_LEN strlen(SEP)
// 请求
class Request
{
public:Request() {}// 序列化 结构体=>字符串bool Serialize(std::string *outStr){*outStr = "";std::string x_string = std::to_string(_x);std::string y_string = std::to_string(_y);//添加分隔符*outStr = x_string + SEP + _op + SEP + y_string;return true;}// 反序列化 字符串=>结构体bool Deserialize(const std::string &str){std::vector<std::string> result;Util::StringSplit(str, SEP, &result);//必须提取出三个变量if (result.size() != 3)return false;_x = atoi(result[0]);_op = result[1][0];_y = atoi(result[2]);return true;}
public:int _x;int _y;char _op;
};// 响应
class Responce
{
public:Responce() : _result(0), _code(0){}// 序列化 结构体->字符串bool Serialize(std::string *outStr){*outStr = "";std::string result_string = std::to_string(_result);std::string code_string = std::to_string(_code);*outStr = result_string + SEP + code_string;return true;}//反序列化 字符串->结构体bool Deserialize(const std::string &str){std::vector<std::string> result;Util::StringSplit(str, SEP, &result);if (result.size() != 2)return false;_result = atoi(result[0]);_code = atoi(result[1]);return true;}
public:int _result;int _code;
};

2. JSON

序列化一般我们不自己操作，可以使用别的封装好的序列化，比如：JSON，ProtocolBuffer，FlatBuffer，DIMBIN

本篇文章介绍json的使用
JSON 的语法规则总结起来有：

• 数组（Array）用方括号(“[]”)表示。
• 对象（0bject）用大括号(“{}”)表示。
• 名称/值对(name/value）组合成数组和对象。
• 名称(name）置于双引号中，值（value）有字符串、数值、布尔值、null、对象和数组。
• 并列的数据之间用逗号(“,”）分隔

序列化后可视效果也较好，比如：

{"x":10,"y":22,"op":*
}

代码：

// 请求
class Request
{
public:Request() {}// 结构体=>字符串bool Serialize(std::string *outStr){// Value，一种万能对象，接收任意的kv类型Json::Value root;root["x"] = _x;root["y"] = _y;root["op"] = _op;// 序列化Json::StyledWriter writer;*outStr = writer.write(root);return true;}// 字符串=>结构体bool Deserialize(const std::string &str){Json::Value root;// 反序列化Json::Reader reader;reader.parse(str, root);//提取变量_x = root["x"].asInt();_y = root["y"].asInt();_op = root["op"].asInt();return true;}
public:int _x;int _y;char _op;
};
// 响应
class Responce
{
public:Responce() : _result(0), _code(0){}// 结构体->字符串bool Serialize(std::string *outStr){Json::Value root;root["result"] = _result;root["code"] = _code;// 序列化Json::StyledWriter writer;*outStr = writer.write(root);return true;}bool Deserialize(const std::string &str){Json::Value root;//反序列化Json::Reader reader;reader.parse(str, root);//提取变量_result = root["result"].asInt();_code = root["code"].asInt();return true;}
public:int _result;int _code;
};

二. 初识协议

在网络通信中，客户端，服务器收发数据其实是如下这样的

我们调用的recv，send等接口，只是将我们定义的缓冲区的数据拷贝到TCP的缓冲区，或者将数据从TCP缓冲区拷贝到上层
TCP是面向字节流的，可以认为，数据是一个字节一个字节传输的
如果，客户端发送一个hello，recv接口会将发送缓冲区的数据一次性拷贝到上层，但可能此时通过网络传输，只传送了hel，服务器的接受缓冲区只有hel，此时recv并没有读取到完整报文，并且我们不知道什么时候读到了完整报文
协议就是为了解决这类问题而诞生的

基于本次网络计算机的案列，简单设计的协议比如，添加长度和\r\n报头
比如：“1 + 1” =>“5"”\r\n"“1 + 1"”\r\n"

解析：通过找到第一个\r\n，获取有效载荷（1 + 1）的长度，再根据长度提取有效载荷

代码如下：

#define HEADER_SEP "\r\n" // 报头分隔符
#define HEADER_SEP_LEN strlen(HEADER_SEP)
// 读取数据，并尝试提取一个完整报文
// 完整报文："有效载荷长度""\r\n""有效载荷""\r\n"
//inbuffer保存所有读取的数据，package是一个完整报文，需要输出
int ReadPackage(int sock, std::string &inbuffer, std::string *package)
{// 读数据char buffer[1024];int n = recv(sock, buffer, sizeof(buffer) - 1, 0);if (n > 0)buffer[n] = '\0';else if (n == 0)//写端关闭return -1;else if (n < 0)//读取异常return -2;//将本次读取的数据保存inbuffer += buffer;//开始查找报头分隔符size_t start = 0;auto pos = inbuffer.find(HEADER_SEP, start);if (pos == std::string::npos)return 0; //第一个分隔符都没有，不是完整报文//提取长度std::string lenStr = inbuffer.substr(0, pos);int len = Util::toInt(lenStr); // 有效载荷的长度// 完整报文的长度int targetPackageLen = lenStr.size() + len + 2 * HEADER_SEP_LEN;if (inbuffer.size() < targetPackageLen)return 0; //长度不足完整报文// 提取一个完整报文，并输出*package = inbuffer.substr(0, targetPackageLen);inbuffer.erase(0, targetPackageLen);return len;
}

结束语

本篇博客到此结束，感谢看到此处。
欢迎大家纠错和补充
如果觉得本篇文章对你有所帮助的话，不妨点个赞支持一下博主，拜托啦，这对我真的很重要。