[Linux#55][网络协议] 序列化与反序列化 | TcpCalculate为例

目录

1. 理解协议

1.1 结构化数据的传输

序列化与反序列化

代码感知:

Request 类

1. 构造函数

2. 序列化函数:Serialize()

3. 反序列化函数:DeSerialize()

补充

4. 成员变量

Response 类

1. 构造函数

2. 序列化函数:Serialize()

3. 反序列化函数:DeSerialize()

4. 成员变量

总结

2. 实验:网络版计算器

2.1 定义请求和响应协议

2.2 TCP 服务端设计

2.3 业务处理逻辑

3. TCP 客户端实现

4. 序列化与反序列化的重要性


在网络编程中,协议是一个关键概念。协议本质上是一种“约定”,规定了两方在通信时如何格式化和处理数据。本文将深入探讨如何通过协议进行结构化数据的传输,并且通过一个具体的网络版计算器( TCP服务器-客户端)示例,展示序列化与反序列化的实现。

学习导图:

1. 理解协议

协议,简单来说,就是通信双方都遵守的规则。在前面的例子中,我们使用了父亲和儿子通过电话沟通的场景。父亲告诉儿子会在特定时间打电话,这就是一种约定——协议。

1.1 结构化数据的传输

在网络通信中,数据通常以字节流的形式发送和接收。当我们需要传输的是结构化数据时,例如在QQ群聊中,除了文字消息外,还包含头像、时间和昵称。这些信息都需要以某种方式发送给对方。如果我们逐个发送这些数据,不仅麻烦,接收方也难以处理,因此需要对这些数据进行打包。

为什么要把字符串转成结构化数据呢?未来这个结构化的数据一定是一个对象,然后使用它的时候,直接对象.url 、对象.time 拿到。

而这里的结构体如message就是传说中的业务协议
因为它规定了我们聊天时网络通信的数据。

序列化与反序列化

为了简化结构化数据的传输,我们通常将多个独立的信息合并为一个报文。这就是序列化的过程:将数据打包成一个字符串或字节流,再通过网络发送。接收方收到数据后,需要通过反序列化,将收到的数据解析回原来的结构化数据。

代码感知:

这段代码的核心功能是实现请求(Request)和响应(Response)的序列化与反序列化。序列化的作用是将类中的成员变量转换成字符串格式,方便在网络中传输;反序列化的作用是将字符串解析回类的成员变量,恢复为结构化数据。以下是对该代码的详细解释:

Request

class Request
{
public:
    // 定义常量字符串分隔符和其长度
    static const char SPACE = ' ';
    static const int SPACE_LEN = 1;

这个类表示客户端发送给服务器的计算请求,包含两个操作数(_x_y)以及一个操作符(_op)。它提供了序列化和反序列化的能力。

1. 构造函数
Request()
{}

这个是默认构造函数,不进行任何初始化操作,只是声明了 Request 对象。

Request(int x, int y, int op)
    : _x(x), _y(y), _op(op)
{}

这是一个带参数的构造函数,它接受两个整数操作数 xy 和一个字符操作符 op,并将它们赋值给类中的成员变量 _x_y_op

2. 序列化函数:Serialize()
std::string Serialize()
{
    std::string str;
    str = std::to_string(_x);
    str += SPACE;
    str += _op;
    str += SPACE;
    str += std::to_string(_y);
    return str;
}
  • 功能:将 Request 对象中的数据成员 _x_op_y 组合成一个字符串。返回组合好的字符串。最终结果类似 "1 + 2" 的格式。
3. 反序列化函数:DeSerialize()

bool DeSerialize(const std::string &str)
{
    size_t left = str.find(SPACE);
    if(left == std::string::npos)
    {
        return false;
    }

    size_t right = str.rfind(SPACE);
    if (right == std::string::npos)
    {
        return false;
    }

    _x = atoi(str.substr(0, left).c_str());
    _y = atoi(str.substr(right + SPACE_LEN).c_str());
    
    if(left + SPACE_LEN < str.size())
    {
        _op = str[left + SPACE_LEN];
        return true;
    }
    else
    {
        return false;
    }
}
  • 功能:从输入的字符串中提取出操作数 _x_y 以及操作符 _op,并将它们存储到 Request 对象的成员变量中。
  • 步骤
    1. str.find(SPACE):在字符串 str 中查找第一个空格的位置,用作分隔符。如果找不到,返回 false
    2. str.rfind(SPACE):查找最后一个空格的位置,表示第二个操作数的开头。如果找不到,返回 false
    3. 使用 atoi 函数从字符串中提取整数操作数 _x_ysubstr(0, left) 获取左侧字符串,即第一个操作数,substr(right + SPACE_LEN) 获取右侧字符串,即第二个操作数。
    4. 从字符串 str 中获取操作符 _op,位于第一个空格后的位置。
    5. 如果解析成功,返回 true;否则返回 false

设计思路:

补充

  1. 上面代码中的atoi是怎么使用的,介绍一下atoi接口
  2. 是如何从字符串 str 中获取操作符 _op
  1. atoi 函数的使用:
    atoi 是 C++ 标准库函数之一,它位于 <cstdlib> 头文件中。该函数的作用是将一个字符串(以空字符结尾的字符数组)转换为 int 类型的整数。其原型如下:
int atoi(const char *str);

参数 str 是指向要转换的以空字符结尾的字符串的指针。atoi 会从字符串的开头开始转换,直到遇到第一个非数字字符或到达字符串的结尾。如果字符串以数字开头,atoi 会返回这些数字对应的整数值。如果字符串不是以数字开头,或者字符串为空,atoi 会返回 0。
以下是一些使用 atoi 的例子:

#include <cstdlib>
#include <iostream>
int main() {
    const char *str1 = "123";
    const char *str2 = "12abc34";
    const char *str3 = "abc123";
    int num1 = atoi(str1); // num1 will be 123
    int num2 = atoi(str2); // num2 will be 12
    int num3 = atoi(str3); // num3 will be 0 (no digits at the start)
    std::cout << "num1: " << num1 << std::endl;
    std::cout << "num2: " << num2 << std::endl;
    std::cout << "num3: " << num3 << std::endl;
    return 0;
}

需要注意的是,atoi 不进行错误检查,如果字符串不能完全转换为数字,那么未转换的部分将被忽略。此外,atoi 无法处理整数溢出,如果转换的数字超出了 int 的表示范围,结果是不确定的。


🎢2. 从字符串 str 中获取操作符 _op
Request 类的 DeSerialize 方法中,以下是获取操作符 _op 的代码片段:

if(left + SPACE_LEN < str.size())
{
    _op = str[left + SPACE_LEN];
    return true;
}
else
{
    return false;
}

这里的 leftstr 中第一个空格字符的位置,SPACE_LEN 是空格字符的长度,通常为 1。所以 left + SPACE_LEN 是第一个空格字符之后的位置,即操作符 _op 应该出现的位置。str[left + SPACE_LEN] 获取该位置的字符并将其赋值给 _op


4. 成员变量
public:
    int _x;
    int _y;
    char _op;
};

Response

Response 类表示服务器的响应,包含两个数据成员:计算结果 _ret 和状态码 _code

1. 构造函数
Response()
{}

这是默认构造函数,不初始化任何成员。

Response(int ret, int code)
    : _code(code), _ret(ret)
{}

这是一个带参数的构造函数,用来初始化响应结果 ret 和状态码 code

2. 序列化函数:Serialize()
std::string Serialize()
{
    std::string str = std::to_string(_code);
    str += SPACE;
    str += std::to_string(_ret);
    return str;
}
  • 功能:将 Response 对象的两个成员变量 _code_ret 组合成字符串。
3. 反序列化函数:DeSerialize()
bool DeSerialize(std::string &str)
{
    size_t pos = str.find(SPACE);
    if(pos == std::string::npos)
    {
        return false;
    }

    _code = atoi(str.substr(0, pos).c_str());
    _ret = atoi(str.substr(pos + SPACE_LEN).c_str());
    return true;
}
  • 功能:从输入的字符串中解析出状态码 _code 和计算结果 _ret,并存入 Response 对象。
4. 成员变量
int _ret;  // 计算结果
int _code; // 状态码

Response 类包含两个成员变量:

  • _ret:存储服务器的计算结果(例如:加法、减法的结果)。
  • _code:存储状态码,0 表示成功,非 0 表示错误(例如:除以 0 错误时 _code 可能为 1)。

总结

class Request
{
public:
    Request()
    {}

    Request(int x, int y, int op)
    : _x(x), _y(y), _op(op)
    {}

    ~Request()
    {}
    // _x _op _y
    std::string Serialize()
    {
        std::string str;
        str = std::to_string(_x);
        str += SPACE;
        str += _op;
        str += SPACE;
        str += std::to_string(_y);
        return str;
    }

    bool DeSerialize(const std::string &str)
    {
        size_t left = str.find(SPACE);
        if(left == std::string::npos)
        {
            return false;
        }

        size_t right = str.rfind(SPACE);
        if (right == std::string::npos)
        {
            return false;
        }

        _x = atoi(str.substr(0, left).c_str());
        _y = atoi(str.substr(right + SPACE_LEN).c_str());
        
        if(left + SPACE_LEN < str.size())
        {
            _op = str[left + SPACE_LEN];
            return true;
        }
        else
        {
            return false;
        }
    }

public:
    int _x;
    int _y;
    char _op;
};

class Response
{
public:
    Response()
    {}

    Response(int ret, int code)
    : _code(code)
    , _ret(ret)
    {}

    ~Response()
    {}

    // _code _ret
    std::string Serialize()
    {
        std::string str = std::to_string(_code);
        str += SPACE;
        str += std::to_string(_ret);
        return str;
    }

    bool DeSerialize(std::string &str)
    {
        size_t pos = str.find(SPACE);
        if(pos == std::string::npos)
        {
            return false;
        }

        _code = atoi(str.substr(0, pos).c_str());
        _ret = atoi(str.substr(pos + SPACE_LEN).c_str());
        return true;
    }

public:
    int _ret;  // 计算结果
    int _code; // 计算结果的状态码
};

代码展示了如何将 RequestResponse 对象进行序列化和反序列化,以便在网络中传输结构化数据。序列化将对象转换为字符串进行网络传输,反序列化将接收到的字符串重新解析为对象,方便在应用程序中处理。

  • Request 主要表示操作请求,包括两个操作数和一个操作符。
  • Response 表示服务器的响应,包括计算结果和状态码。
  • 序列化与反序列化是网络编程中常用的技术,能有效将复杂的结构化数据转化为适合网络传输的简单格式。

2. 实验:网络版计算器

为了加深理解,我们通过实现一个简单的TCP服务端来展示协议、序列化和反序列化的运作过程。这个服务端会处理简单的数学运算请求,客户端发送请求,服务端进行计算并返回结果。

2.1 定义请求和响应协议

我们定义了一个 Request 类来表示计算请求,包含两个操作数和一个操作符。同时,我们定义了 Response 类来表示响应结果,包含计算结果和状态码。

class Request {
public:
    Request(int x, int y, char op) : _x(x), _y(y), _op(op) {}

    // 序列化:将请求转换为字符串格式
    bool serialize(string *out) {
        *out = to_string(_x) + " " + _op + " " + to_string(_y);
        return true;
    }

    // 反序列化:从字符串解析出请求内容
    bool deserialize(const string &in) {
        auto left = in.find(' ');
        auto right = in.rfind(' ');
        if (left == string::npos || right == string::npos || left == right)
            return false;
        _x = stoi(in.substr(0, left));
        _op = in[left + 1];
        _y = stoi(in.substr(right + 1));
        return true;
    }

public:
    int _x; // 操作数1
    int _y; // 操作数2
    char _op; // 操作符
};

class Response {
public:
    Response(int exitcode, int result) : _exitcode(exitcode), _result(result) {}

    // 序列化:将响应转换为字符串格式
    bool serialize(string *out) {
        *out = to_string(_exitcode) + " " + to_string(_result);
        return true;
    }

    // 反序列化:从字符串解析出响应内容
    bool deserialize(const string &in) {
        auto pos = in.find(' ');
        if (pos == string::npos) return false;
        _exitcode = stoi(in.substr(0, pos));
        _result = stoi(in.substr(pos + 1));
        return true;
    }

public:
    int _exitcode; // 状态码
    int _result;   // 计算结果
};

2.2 TCP 服务端设计

我们设计了一个简单的TCP服务器 CalServer,用于处理客户端的请求并返回响应。

  • handlerEntry 函数:负责处理单个客户端连接。接收请求、反序列化、执行计算、序列化响应并发送回客户端。
  • CalServer 类:负责监听端口并处理多个客户端连接。
class CalServer {
public:
    CalServer(const uint16_t port) : _port(port), _listensock(-1) {}

    void initServer() {
        _listensock = socket(AF_INET, SOCK_STREAM, 0);
        struct sockaddr_in local;
        local.sin_family = AF_INET;
        local.sin_port = htons(_port);
        local.sin_addr.s_addr = INADDR_ANY;

        bind(_listensock, (struct sockaddr*)&local, sizeof(local));
        listen(_listensock, 5);
    }

    void start(func_t func) {
        signal(SIGCHLD, SIG_IGN);
        while (true) {
            int sock = accept(_listensock, nullptr, nullptr);
            if (fork() == 0) {
                handlerEntry(sock, func);
                close(sock);
                exit(0);
            }
            close(sock);
        }
    }
};

2.3 业务处理逻辑

处理请求的逻辑被封装在 Cal 函数中。它根据请求中的操作符计算结果并填充响应:

void Cal(const Request &req, Response &resp) {
    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._exitcode = 1; else resp._result = req._x / req._y; break;
        default: resp._exitcode = 2; break;
    }
}

3. TCP 客户端实现

客户端通过发送序列化后的请求并接收响应。

class CalClient {
public:
    CalClient(const string &ip, const uint16_t &port) : _serverip(ip), _serverport(port), _sockfd(-1) {}

    void initClient() {
        _sockfd = socket(AF_INET, SOCK_STREAM, 0);
        struct sockaddr_in server;
        server.sin_family = AF_INET;
        server.sin_port = htons(_serverport);
        server.sin_addr.s_addr = inet_addr(_serverip.c_str());
        connect(_sockfd, (struct sockaddr*)&server, sizeof(server));
    }

    void run() {
        while (true) {
            string msg;
            cout << "Enter calculation: ";
            getline(cin, msg);
            Request req = parseInput(msg);
            string req_str;
            req.serialize(&req_str);
            send(_sockfd, req_str.c_str(), req_str.size(), 0);

            char buffer[1024];
            recv(_sockfd, buffer, sizeof(buffer), 0);
            Response resp;
            resp.deserialize(buffer);
            cout << "Result: " << resp._result << endl;
        }
    }

private:
    string _serverip;
    uint16_t _serverport;
    int _sockfd;
};

4. 序列化与反序列化的重要性

  • 序列化:将结构化的数据(如对象)转换为字节流或字符串,以便传输。
  • 反序列化:将字节流或字符串重新解析为结构化数据,供应用程序使用。

通过序列化与反序列化,应用程序与网络通信得到了有效解耦。这种设计使得复杂的数据可以轻松地在网络中传输,并且为上层应用提供了灵活的操作方式。

对于网络版计算器所有部分的完整代码,之后将上传 gitee,下篇文章将对于设计思路和一些坑点继续讲解~

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【软件基础知识】什么是 API,详细解读

想象一下,你正在使用智能手机上的天气应用。你打开应用,瞬间就能看到实时天气、未来预报,甚至是空气质量指数。但你有没有想过,这些数据是如何神奇地出现在你的屏幕上的?答案就在三个字母中:API。 API,全称Application Programming Interface(应用程序编程接口),是现代软件世…

MYSQL面试知识点手册

第一部分&#xff1a;MySQL 基础知识 1.1 MySQL 简介 MySQL 是世界上最流行的开源关系型数据库管理系统之一&#xff0c;它以性能卓越、稳定可靠和易用性而闻名。MySQL 主要应用在 Web 开发、大型互联网公司、企业级应用等场景&#xff0c;且广泛用于构建高并发、高可用的数据…

工程师 - PFM介绍

在电子电路设计中&#xff0c;PFM&#xff08;Pulse Frequency Modulation&#xff0c;脉冲频率调制&#xff09;是一种调制技术&#xff0c;其主要特点是在负载变化时调整脉冲的频率&#xff0c;而保持脉冲的宽度&#xff08;时间长度&#xff09;相对恒定。与PWM&#xff08;…

记忆化搜索专题——算法简介力扣实战应用

目录 1、记忆化搜索算法简介 1.1 什么是记忆化搜索 1.2 如何实现记忆化搜索 1.3 记忆化搜索与动态规划的区别 2、算法应用【leetcode】 2.1 题一&#xff1a;斐波那契数 2.1.1 递归暴搜解法代码 2.1.2 记忆化搜索解法代码 2.1.3 动态规划解法代码 2.2 题二&#xff1…

Transformer预测 | 基于Transformer心率时间序列预测(tensorflow)

效果一览 基本介绍 Transformer预测 | 基于Transformer心率时间序列预测(tensorflow) 程序设计 import pandas as pd from pandas.plotting import lag_plot from statsmodels.graphics

加密与安全_优雅存储二要素(AES-256-GCM )

文章目录 什么是二要素如何保护二要素&#xff08;姓名和身份证&#xff09;加密算法分类场景选择算法选择AES - ECB 模式 (不推荐)AES - CBC 模式GCM&#xff08;Galois/Counter Mode&#xff09;AES-256-GCM简介AES-256-GCM工作原理安全优势 应用场景其他模式 和 敏感数据加密…

AIoT智能工控板

在当今竞争激烈的商业环境中&#xff0c;企业需要强大的科技力量来助力腾飞&#xff0c;AIoT智能工控板就是这样的力量源泉。 其领先的芯片架构设计&#xff0c;使得主板的性能得到了极大的提升。无论是数据的处理速度、图形的渲染能力&#xff0c;还是多任务的并行处理能力&a…

Ceph官方文档_01_Ceph简介

目录 Ceph介绍Ceph介绍 Ceph可用于向云平台提供Ceph对象存储,Ceph可用于向云平台提供Ceph块设备服务。Ceph可用于部署Ceph文件系统。所有Ceph存储群集部署开始都是先设置每个Ceph节点,然后再设置网络。 Ceph存储集群需要以下内容:至少一个Ceph监视器和至少一个Ceph管理器,…

毕业设计选题:基于ssm+vue+uniapp的捷邻小程序

开发语言&#xff1a;Java框架&#xff1a;ssmuniappJDK版本&#xff1a;JDK1.8服务器&#xff1a;tomcat7数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09;数据库工具&#xff1a;Navicat11开发软件&#xff1a;eclipse/myeclipse/ideaMaven包&#xff1a;M…

Linux top命令详解与重点内容说明

文章目录 重点说明基本信息进程(任务)信息cpu占用信息%Cpu(s)内存信息交换内存信息每列含义说明交互命令多窗口模式颜色配置命令参数 重点说明 top命令非常强大&#xff0c;也非常复杂&#xff0c;很难面面俱到&#xff0c;也没有必要&#xff0c;这篇文章的目的是介绍重点&am…

en造数据结构与算法C# 群组行为优化 和 头鸟控制

实现&#xff1a; 1.给鸟类随机播放随机动画使得每一只鸟扇翅膀的频率都不尽相同 2.可以自行添加权重&#xff0c;并在最后 sumForce separationForce cohesionForce alignmentForce;分别乘上相应权重&#xff0c;这样鸟就能快速飞行和转向辣 using System.Collections.Ge…

Linux系统编程(基础指令)上

1.Linux常见目录介绍 Linux目录为树形结构 /&#xff1a;根目录&#xff0c;一般根目录下只存放目录&#xff0c;在Linux下有且只有一个根目录。所有的东西都是从这里开始。当你在终端里输入“/home”&#xff0c;你其实是在告诉电脑&#xff0c;先从/&#xff08;根目录&…

Unity3D入门(二) :Unity3D实现视角的丝滑过渡切换

1. 前言 上篇文章&#xff0c;我们已经初步了解了Unity3D&#xff0c;并新建并运行起来了一个项目&#xff0c;使相机视角自动围绕着立方体旋转。 这篇文章&#xff0c;我们来讲一下Unity3D怎么过渡地切换视角。 我们继续是我上篇文章中的项目&#xff0c;但是需要向把Camera…

​OpenAI最强模型o1系列:开启人工智能推理新时代

前不久OpenAI发布全新模型——o1模型&#xff0c;也就是业界说的“草莓模型”&#xff0c;包含三款型号&#xff1a;OpenAI o1、OpenAI o1-preview和OpenAI o1-mini。 其中&#xff0c;OpenAI o1-mini和 o1-preview已经对用户开放使用&#xff1a; OpenAI o1&#xff1a;高级推…

企业急于采用人工智能,忽视了安全强化

对主要云提供商基础设施上托管的资产的安全分析显示&#xff0c;许多公司为了急于构建和部署 AI 应用程序而打开安全漏洞。常见的发现包括对 AI 相关服务使用默认且可能不安全的设置、部署易受攻击的 AI 软件包以及不遵循安全强化指南。 这项分析由 Orca Security 的研究人员进…

Redis学习以及SpringBoot集成使用Redis

目录 一、Redis概述 二、Linux下使用Docker安装Redis 三、SpringBoot集成使用Redis 3.1 添加redis依赖 3.2 配置连接redis 3.3 实现序列化 3.4 注入RedisTemplate 3.5 测试 四、Redis数据结构 一、Redis概述 什么是redis&#xff1f; redis 是一个高性能的&#xf…

vue项目加载cdn失败解决方法

注释index.html文件中 找到vue.config.js文件注释、

【Python语言初识(二)】

一、分支结构 1.1、if语句 在Python中&#xff0c;要构造分支结构可以使用if、elif和else关键字。所谓关键字就是有特殊含义的单词&#xff0c;像if和else就是专门用于构造分支结构的关键字&#xff0c;很显然你不能够使用它作为变量名&#xff08;事实上&#xff0c;用作其他…

0基础带你入门Linux之使用

1.Ubuntu软件管理 回顾一下&#xff0c;我们之前使用su root切换到root模式&#xff0c;使用who 发现为什么显示的还是bd用户呢&#xff1f;为什么呢&#xff1f; 这个who是主要来查看的是我们登录的时候是以什么用户登录的 所以即使我们使用who进行查看的时候显示的还是bd用…

【JavaWeb】利用IDEA2024+tomcat10配置web6.0版本搭建JavaWeb开发项目

之前写过一篇文章&#xff1a;《【JavaWeb】利用IntelliJ IDEA 2024.1.4 Tomcat10 搭建Java Web项目开发环境&#xff08;图文超详细&#xff09;》详细讲解了如何搭建JavaWeb项目的开发环境&#xff0c;里面默认使用的Web版本是4.0版本的。但在某些时候tomcat10可能无法运行we…