_Linux (网络版计算器简易实现)

2023-11-23 12:59

本文主要是介绍_Linux (网络版计算器简易实现),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

  • 1. 协议
  • 2. 网络版计算器简易实现代码链接
  • 3. 网络版计算器
    • 2-1. 约定的协议方案有两种
    • 2-3. 协议代码框架
      • 1. 自定义的协议方案
      • 2. json(库里的完整协议方案)
    • 2-4. send和recv单独使用不安全
    • 2-5. 剩余代码写法讲解参考如下:
    • 2-6. 代码运行结果示意图:
  • 4. 守护进程
    • 4-1. 守护进程概念
    • 4-2. 守护代码方法
    • 4-3. 守护进程后的相关示意图:

1. 协议

  • 注意:我们程序员写的一个个解决我们实际问题, 满足我们日常需求的网络程序, 都是在应用层。
  • 协议是一种 “约定”

socket api的接口, 在读写数据时, 都是按 “字符串” 的方式来发送接收的. 如果我们要传输一些"结构化的数据" 怎么做呢?

  • 发送数据时将这个结构体按照一个规则转换成字符串, 接收到数据的时候再按照相同的规则把字符串转化回结构体。

2. 网络版计算器简易实现代码链接

  • 完整代码我放到git仓库了哈~
  • 链接:
    https://gitee.com/ding-xushengyun/linux__cpp/tree/master/NetCal

3. 网络版计算器

2-1. 约定的协议方案有两种

约定方案一:

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

约定方案二(我们的代码实现采用方案二):

  • 定义结构体来表示我们需要交互的信息;
  • 发送数据时将这个结构体按照一个规则转换成字符串, 接收到数据的时候再按照相同的规则把字符串转化回结构体;
  • 这个过程叫做 “序列化” 和 “反序列化”

注意:无论我们采用方案一, 还是方案二, 还是其他的方案, 只要保证, 一端发送时构造的数据, 在另一端能够正确的进行解析, 就是ok的. 这种约定, 就是应用层协议。

  • 当然我们自己简单实现的协议比较简陋(不能应用于任何场景);库里的json更强大。

2-3. 协议代码框架

结果和计算过程都有序列和反序列化

#pragma once#include <iostream>
#include <string>
#include <cstring>
#include <sys/types.h>
#include <sys/socket.h>
#include <jsoncpp/json/json.h>using std::cout;
using std::endl;
using std::string;namespace ns_protocol
{
#define MYSELF 1#define SPACE " "
#define SPACE_LINE strlen(SPACE)
#define SEP "\r\n"
#define SEP_LINE strlen(SEP)class Request //  计算数据{public://  "_x _op _y"string Serialize() //  序列化{
#ifdef MYSELF//	自己模拟的协议
#else//	json
#endif}//  "111 + 222"bool Deserialized(const string &str) //  反序列化{
#ifdef MYSELF//	自己模拟的协议#else// jsonreturn true;#endif}Request() {}Request(int x, int y, int op) : _x(x), _y(y), _op(op){}public:int _x;int _y;char _op; // '+' '-' '*' '/' '%'};class Response //  结果{public://  _code _resultstring Serialize() //  序列化{
#ifdef MYSELF//	自己模拟的协议#else// json
#endif}//  1 333bool Deserialized(const string &str) //  反序列化{
#ifdef MYSELF//	自己模拟的协议return true;
#else//	json 
#endif}Response() {}Response(int result, int code) : _result(result), _code(code){}public:int _result; //  计算结果int _code;   //   计算结果的状态码};//	下面是接受和发送数据函数(recv, send)bool Recv(int sock, string *out) //  接受信息/数据{char buffer[1024];ssize_t s = recv(sock, buffer, sizeof buffer - 1, 0);if (s > 0){buffer[s] = 0;*out += buffer;}else if (s == 0){// cout << "我也要退出了" << endl;return false;}else{// cout << "接受失败" << endl;return false;}return true;}void Send(int sock, string &str) //  发送信息/数据{ssize_t s = send(sock, str.c_str(), str.size(), 0);if (s < 0){cout << "发送消息失败" << endl;}}

1. 自定义的协议方案

客户发过来的数据例如:2+1

序列化过程:("_x _op _y") 就是把值(类的成员函数)拿出来变成字符串
_x :左值;_op:运算符;_y:右值(例如:2 + 1)
"2+1" -> "2 + 1"	// 字符个数从3变为5,我们以空格作为分割符。
		string Serialize() //  序列化{string str;str = std::to_string(_x);str += SPACE;str += _op;str += SPACE;str += std::to_string(_y);return str;}
反序列化过程:就是把字符串解析出来存起来(类的成员函数)

以空格作为分割符;解析出来客户发的数据。

		bool Deserialized(const string &str) //  反序列化{size_t left = str.find(' ');if (left == string::npos)return false;size_t right = str.rfind(' ');if (right == string::npos)return false;_x = stoi(str.substr(0, left));_y = stoi(str.substr(right + SPACE_LINE));if (left + SPACE_LINE > str.size())return false;else_op = str[left + SPACE_LINE];return true;}

结果序列化和反序列化(例如:3)

序列化过程:("_x _op _y") 就是把值(类的成员函数)拿出来变成字符串
code表示结果状态值,result:表示结果 (例如:0 3)
"03" -> "0 3"	// 字符个数从2变为3,我们以空格作为分割符。
		string Serialize() //  序列化{string str;str = std::to_string(_code);str += SPACE;str += std::to_string(_result);return str;}
反序列化过程:就是把字符串解析出来存起来(类的成员函数)

以空格作为分割符;解析出来客户发的数据。

		bool Deserialized(const string &str) //  反序列化{size_t left = str.find(' ');if (left == string::npos)return false;_code = stoi(str.substr(0, left));_result = stoi(str.substr(left + SPACE_LINE));return true;}

2. json(库里的完整协议方案)

下载json库指令; 我们下载后这个库就在系统路径下(我们使用这个库记住,编译的适合链接就可以了跟线程库一样。)

例如:
在这里插入图片描述

sudo yum install -y jsoncpp-devel
  • json库使用方法固定用法哈~

客户发过来的数据例如:2+1

序列化过程:("_x _op _y") 就是把值(类的成员函数)拿出来变成字符串
_x :左值;_op:运算符;_y:右值(例如:2 + 1)
		string Serialize() //  序列化{Json::Value root;root["x"] = _x;root["y"] = _y;root["op"] = _op;Json::FastWriter write;return write.write(root);}
反序列化过程:就是把字符串解析出来存起来(类的成员函数)
		bool Deserialized(const 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;}

结果序列化和反序列化(例如:3)

序列化过程:("_x _op _y") 就是把值(类的成员函数)拿出来变成字符串
code表示结果状态值,result:表示结果 (例如:0 3)
		string Serialize() //  序列化{Json::Value root;root["code"] = _code;root["result"] = _result;Json::FastWriter write;return write.write(root);}
反序列化过程:就是把字符串解析出来存起来(类的成员函数)
		bool Deserialized(const string &str) //  反序列化{Json::Value root;Json::Reader reader;reader.parse(str, root);_code = root["code"].asInt();_result = root["result"].asInt();return true;}

2-4. send和recv单独使用不安全

多路转接的时候,出现的发送的问题,我们暂时不考虑。

  • 这里的“不安全” 是指send数据发了好多数据,而recv读取数据不完整那就造成解析失败进而结果不正确。

  • send/write:你是把数据发送到网络甚至是对方的主机中错误的!(你只是把数据发的缓存中,数据通过io拷贝出来滴!)
    在这里插入图片描述
    那么我们怎么保证自己读到的数据完整?通过加一些东西作为分割。

我们通过添加字符串长度和加"\r\n"(传统做法)

  • 例如:length\r\nxxxxx\r\n

    • 我们可以通过length来确定数据的准确新(xxxxx)
  • a. 解析先查找\r\n确定length长度,通过长度来确定这次读到数据是否>=一个完整的数据报。

  • b. 添加就是先加长度和分割符最后末尾加上分割符(“\r\n”)

    //  length\r\nxxxxx\r\nstring Decode(string &buffer) //  解析{int pos = buffer.find(SEP);if (string::npos == pos) // 没找到{return "";}int size = stoi(buffer.substr(0, pos));int length = buffer.size() - SEP_LINE * 2 - pos;if (size < length) // 读取到的数据不完整{return "";}// 读取到一个完成数据报buffer.erase(0, pos + SEP_LINE);   // 去掉length\r\nstring s = buffer.substr(0, size); // 取出buffer.erase(0, size + SEP_LINE);  // 去掉xxxxx\r\n//  解析数据完成return s;}//  xxxxxvoid Encode(string &s) //  添加{string tmp = std::to_string(s.size()); //  lengthtmp += SEP;                            // length\r\ntmp += s;                              //  length\r\nxxxxxtmp += SEP;                            // length\r\nxxxxx\r\nswap(s, tmp);}
}

2-5. 剩余代码写法讲解参考如下:

剩余写法详情参考这篇文章中的TCP网络简单实现:
链接:https://blog.csdn.net/Dingyuan0/article/details/129074597?spm=1001.2014.3001.5501

2-6. 代码运行结果示意图:

我们把结果输入到日志中,便于查看。

  • 自定义协议运行结果:
    在这里插入图片描述
  • json库协议运行结果:
    注意:我们把字符(运算符)转换为整数了。
    在这里插入图片描述

4. 守护进程

用户退出后,服务器还在运行;如果我们的服务器也退出就不合理;就产生了守护进程。

4-1. 守护进程概念

  • 1.前台进程是和终端关联的进程。
  • 2.任何xshell登陆,只允许一个前台进程和多个后台进程。(例如:刚登录时bash是前台进程,我们运行我们的服务器后;bash不在是前台进程,我们的服务器是前台进程。)
  • 3.进程除了有自己的pid,ppid,还有一个组ID。
  • 4.在命令行中,同时用管道启动多个进程,多个进程是兄弟关系,父进程都是bash ->可以用匿名管道来进行通信。
  • 5.而同时被创建的多个进程可以成为一个进程组的概念,组长一般是第一个进程(组长不能成为守护进程)
  • 6.任何一次登陆,登陆的用户,需要有多个进程(组)来给这个用户提供服务的(bash),用户自己可以启动很多进程,或者进程组。我们把给用户提供服务的进程或者用户自己启动的所有的进程或者服务,整体都是要属于一个叫做会话的机制中的。
  • 7.如何将自己变成自成会话(就是守护进程)呢? 调用setsid()函数
  • 8.setsid要成功被调用,必须保证当前进程不是进程组的组长;怎么保证呐?fork()一下让它子进程成为守护进程。
  • 9.守护进程不能直接向显示器打印消息一旦打印,会被暂停、终止。
  • 10.fork()之后此时守护进程也可称为特殊的孤儿进程(因为它的父母是一号进程。)

用户登录时系统创建会话,相关示意图:
在这里插入图片描述

4-2. 守护代码方法

代码写法如下。

#include <signal.h>
#include <iostream>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>void MyDaemon()
{//  1. 忽略信号signal(SIGPIPE, SIG_IGN);signal(SIGCHLD, SIG_IGN);// 2 . 不成为组长if (fork() > 0)exit(0);// 3. 调用setsidsetsid();// 3. cin cout ceer 重定向,守护进程不直接向显示器中打印信息int devnull=open("/dev/null", O_RDONLY | O_WRONLY);if(devnull>0){dup2(0, devnull);dup2(1, devnull);dup2(2, devnull);close(devnull);}
}

4-3. 守护进程后的相关示意图:

无论我们怎样退出xshell重新登录,我们的服务器一直在运行。
在这里插入图片描述
在这里插入图片描述

这篇关于_Linux (网络版计算器简易实现)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/418123

相关文章

使用Redis快速实现共享Session登录的详细步骤

《使用Redis快速实现共享Session登录的详细步骤》在Web开发中,Session通常用于存储用户的会话信息,允许用户在多个页面之间保持登录状态,Redis是一个开源的高性能键值数据库,广泛用于... 目录前言实现原理:步骤:使用Redis实现共享Session登录1. 引入Redis依赖2. 配置R

SpringBoot实现RSA+AES自动接口解密的实战指南

《SpringBoot实现RSA+AES自动接口解密的实战指南》在当今数据泄露频发的网络环境中,接口安全已成为开发者不可忽视的核心议题,RSA+AES混合加密方案因其安全性高、性能优越而被广泛采用,本... 目录一、项目依赖与环境准备1.1 Maven依赖配置1.2 密钥生成与配置二、加密工具类实现2.1

在Java中实现线程之间的数据共享的几种方式总结

《在Java中实现线程之间的数据共享的几种方式总结》在Java中实现线程间数据共享是并发编程的核心需求,但需要谨慎处理同步问题以避免竞态条件,本文通过代码示例给大家介绍了几种主要实现方式及其最佳实践,... 目录1. 共享变量与同步机制2. 轻量级通信机制3. 线程安全容器4. 线程局部变量(ThreadL

在Linux系统上连接GitHub的方法步骤(适用2025年)

《在Linux系统上连接GitHub的方法步骤(适用2025年)》在2025年,使用Linux系统连接GitHub的推荐方式是通过SSH(SecureShell)协议进行身份验证,这种方式不仅安全,还... 目录步骤一:检查并安装 Git步骤二:生成 SSH 密钥步骤三:将 SSH 公钥添加到 github

python使用Akshare与Streamlit实现股票估值分析教程(图文代码)

《python使用Akshare与Streamlit实现股票估值分析教程(图文代码)》入职测试中的一道题,要求:从Akshare下载某一个股票近十年的财务报表包括,资产负债表,利润表,现金流量表,保存... 目录一、前言二、核心知识点梳理1、Akshare数据获取2、Pandas数据处理3、Matplotl

Linux线程同步/互斥过程详解

《Linux线程同步/互斥过程详解》文章讲解多线程并发访问导致竞态条件,需通过互斥锁、原子操作和条件变量实现线程安全与同步,分析死锁条件及避免方法,并介绍RAII封装技术提升资源管理效率... 目录01. 资源共享问题1.1 多线程并发访问1.2 临界区与临界资源1.3 锁的引入02. 多线程案例2.1 为

分布式锁在Spring Boot应用中的实现过程

《分布式锁在SpringBoot应用中的实现过程》文章介绍在SpringBoot中通过自定义Lock注解、LockAspect切面和RedisLockUtils工具类实现分布式锁,确保多实例并发操作... 目录Lock注解LockASPect切面RedisLockUtils工具类总结在现代微服务架构中,分布

Java使用Thumbnailator库实现图片处理与压缩功能

《Java使用Thumbnailator库实现图片处理与压缩功能》Thumbnailator是高性能Java图像处理库,支持缩放、旋转、水印添加、裁剪及格式转换,提供易用API和性能优化,适合Web应... 目录1. 图片处理库Thumbnailator介绍2. 基本和指定大小图片缩放功能2.1 图片缩放的

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连