当前位置：首页 > news >正文

【C++】Json-Rpc框架项目介绍（1）

news 来源：原创 2025/7/20 10:23:36

项目介绍

RPC（Remote Procedure Call）即远程过程调用，是一种通过网络从远程计算机程序中请求服务而不需要了解底层网络实现细节的一种协议。
RPC（Remote Procedure Call）可以使用多种网络协议进行通信，如 HTTP 、TCP 、UDP等。就像调用本地方法一样调用远程方法。

RPC框架

序列化协议
通信协议
连接复用
服务注册
服务发现
服务订阅和通知
负载均衡
服务监控
同步调用
异步调用

技术选型

目前RPC的实现方案主要有两种：

- client和server继承公共接口：
- 根据IDL（接口描述语言）定义公共接口
- 编写代码生成器根据 IDL 语言生成相关的C++、Java代码
- 客户端和服务器向上继承公共接口
- 缺点：使用Protobuf、json可以定义IDL接口，并生成RPC相关代码，其中Protobuf需要通过protoc生成强类型代码，灵活性受限，且对理解不友好，如果用Json定义IDL语言，需要自己编写代码生成器，难度较大，暂不考虑这种方案
实现一个远程调用接口call，然后传入函数名参数来调用RPC接口，我们采用这种方案
网络传输的参数和返回值映射到对应RPC接口上：
使用JSON类型，设计好参数和返回值协议
网络传输：
使用muduo库来实现网络传输
序列化和反序列化
使用JSON来实现

开发环境LInux

Linux （Centos-7.6 / Ubuntu6.4）
Vscode / Vim
g++ / gdb
Makefile

Muduo库

muduo是是由陈硕大佬开发，是一个基于 非阻塞IO 和 事件驱动 的C++高并发TCP网络编程库。它是一款基于主从Reactor模型的网络库，其使用的线程模型是 one loop per thread：

一个线程只能有一个事件循环，用于响应计时器和IO时间
一个文件描述符只能由一个线程进行读写，也就是一个TCP连接必须归属于某个EventLoop

C++11异步操作

std::future

std::future是C++11标准库中的一个模版类，它表示一个 异步操作的结果 ，当我们在多线程编程中使用异步任务时，std::future可以帮助我们在需要的时候获取任务的执行结果。它的一个主要特性就是能够阻塞当前线程，直到异步操作完成，确保我们在获取结果时不会遇到未完成的操作。
应用场景：

异步任务：当我们在后台执行一些耗时操作时，如网络请求和计算密集型任务等，std::future可以表示异步执行的结果。通过创建新线程执行任务，实现任务的并行处理，提高程序的效率
并发控制：我们可以通过使用std::future是线程之间的同步，确保任务完成后再获取结果并继续执行后续操作
结果获取：std::future提供了一种安全的方式来获取异步任务的结果，我们可以使用 std::future::get()函数来获取异步任务的执行结果，并且这个函数会阻塞当前线程，直到异步操作完成，确保后序操作在结果获取后执行，同时保证了线程之间的同步。

std::async

std::async 是一种将任务与 std::future 关联的方法，它创建并运行一个异步任务，并返回一个与任务关联的 future 对象。
其中 std::async 是否启动一个新线程，或者在等待 futrue 时，任务是否同步运行都取决于你给的参数 std::launch:

std::launch::deferred 表明该函数会被延迟调用，直到调用 get() 或者 wait() 才会开始执行任务
std::launch::async表示函数会在自己创建的线程上面运行
std::launch::deferred | std::launch::async 取决于系统内部的资源的自动决策，当高资源可用时，采用 std::launch::async ，创建新线程实现并发，相反，则采std::launch::deferred 策略，在调用线程上执行，避免资源竞争和崩溃风险。

示例代码

#include <iostream>
#include <future>
#include <chrono>std::string async_task()
{std::cout << "任务执行中" << std::endl;return "获取成功";
}int main()
{std::future<std::string> result = std::async(std::launch::deferred,async_task);std::this_thread::sleep_for(std::chrono::seconds(10));std::cout << "任务在等待10s后再执行" << std::endl;std::string name = result.get();std::cout << name << std::endl;return 0;
}

结果：

任务在等待10s后再执行
任务执行中
获取成功

std::string async_task()
{std::cout << "任务正在执行" << std::endl;return "获取成功";
}int main()
{std::future<std::string> result = std::async(std::launch::async,async_task);std::this_thread::sleep_for(std::chrono::seconds(10));std::string name = result.get();std::cout << name << std::endl;return 0;
}

结果：

任务正在执行
获取成功

std::packaged_task

std::packaged_task就是将任务和 std::future 绑定在一起的模版，是一种对任务的封装，我们可以通过std::packaged_task对象获取任务相关联的std::future对象，通过调用 get_future() 方法获得。std::packaged_task的模版参数是函数签名。
可以把std::future 和 std::async 看成是分开的，而std::packaged_task则是一个整体

示例代码

#include <iostream>
#include <future>
#include <thread>
#include <utility>std::string async_task() 
{std::cout << "任务执行中" << std::endl;return "获取成功";
}int main() 
{// 1. 创建 packaged_task 并获取 futurestd::packaged_task<std::string()> task(async_task);std::future<std::string> result = task.get_future();// 2. 将任务移动到新线程中异步执行std::thread t(std::move(task));t.detach();  // 或 t.join()// 3. 获取结果（阻塞直到任务完成）std::string name = result.get();  // 若任务未执行会在此阻塞std::cout << name << std::endl;return 0;
}

结果：

任务执行中
获取成功

std::promise

std::promise提供了一种设置值的方式，它可以在设置之后通过相关联的 std::futrue对象进行读取。其实就是之前std::futrue需要等待异步函数的返回值，但std::promise提供了一种手动方式让std::futrue就绪

示例代码

void task(std::promise<int> promise_result)
{int result = 2;std::cout << "task result: " << result << std::endl;std::this_thread::sleep_for(std::chrono::seconds(5));promise_result.set_value(result);
}int main()
{std::promise<int> promise_result;std::future<int> future_result = promise_result.get_future();std::thread task_thread(task,std::move(promise_result));task_thread.detach();std::this_thread::sleep_for(std::chrono::seconds(1));std::cout << "执行其他操作" << std::endl;int result = future_result.get();std::cout << "result: " << result << std::endl;return 0;
}

结果：

task result: 2
执行其他操作
result: 2

【C++】Json-Rpc框架项目介绍（1）

项目介绍 RPC（Remote Procedure Call）即远程过程调用，是一种通过网络从远程计算机程序中请求服务而不需要了解底层网络实现细节的一种协议。 RPC（Remote Procedure Call）可以使用多种网络协议进行通信，如…...

编程日记 2025/7/20 10:23:36

数据结构图论基础知识（一）

文章目录 1. 图的基本概念2. 图的一些现实的应用2.1 ABCDE各个城市之间的关系2.2 社交关系 3. 图的存储结构3.1邻接矩阵3.2 邻接矩阵的实现3.3 邻接表 1. 图的基本概念 1. （graph）图由边（edge）和顶点（Vertex&#xff…...

编程日记 2025/7/17 6:58:27

安宝特案例 | AR如何大幅提升IC封装厂检测效率？

前言：如何提升IC封装厂检测效率？ 在现代电子产品的制造过程中，IC封装作为核心环节，涉及到复杂处理流程和严格质量检测。这是一家专注于IC封装的厂商，负责将来自IC制造商的晶圆进行保护、散热和导通处理。整个制程繁琐…...

编程日记 2025/7/20 9:42:02

2024年ESWA SCI1区TOP：量子计算蜣螂算法QHDBO，深度解析+性能实测

目录 1.摘要2.蜣螂优化算法DBO原理3.改进策略4.结果展示5.参考文献6.代码获取 1.摘要蜣螂优化算法是一种群体智能优化算法，具有较强的优化能力和快速收敛性，但容易在优化过程后期陷入局部最优解。本文提出了一种量子计算和多策略混合的蜣螂优化算法&am…...

编程日记 2025/7/20 9:39:19

数据结构*链表- LinkedList

什么是链表相较于ArrayList顺序表来说，链表是物理存储结构上非连续存储结构（也就是地址不是连续的）。链表由一系列节点构成，每个节点包含数据和指向下一个节点的引用。链表的各个节点在内存里并非连续存储，而是通过引…...

编程日记 2025/6/29 11:49:42

WebRTC服务器Coturn服务器用户管理和安全性

1、概述 Coturn服务器对用户管理和安全方面也做了很多的措施，以下会介绍到用户方面的设置 1.1、相关术语 1.1.1 realm 在 coturn 服务器中，域（realm）是一种逻辑上的分组概念，用于对不同的用户群体、应用或者服务进行区…...

编程日记 2025/6/29 9:37:54

MySQL聚簇索引和非聚簇索引

聚簇索引（Clustered Index）和非聚簇索引（Non-Clustered Index）是数据库中常用的两种索引类型，它们在数据存储和检索方式上有显著的区别。一、聚簇索引（Clustered Index） 聚簇索引是数据表中的…...

编程日记 2025/6/29 9:37:18

QT加入阿里云OSS上传图片SDK，编译报错：error LNK2019: 无法解析的外部符号 EVP_MD_CTX_init

参考此链接把OSS上传图片的SDK，cmake成lib库，如下图将lib库放入自己的项目文件夹下，并在pro文件中添加此lib库。而解决 “无法解析的外部符号 EVP_MD_CTX_init” 问题，则需要将third_party文件夹下的一些依赖库和头文件都放到自己…...

编程日记 2025/7/17 18:07:17

正点原子TFTLCD扩展

声明：该文章代码是在正点原子教学下写出的LCD驱动代码上进行了修改能兼容更多字号( ˘ ˘)❤️ 如有侵权，请私信联系删除文章目录前言代码lcd.clcd.hfont.h 前言由于TFTLCD4.3寸屏幕太大了，正点原子的代码只能显示12/16/24字号的字符或者…...

编程日记 2025/6/29 11:58:49

部署Megatron - LM，快速上手使用

安装Megatron - LM 首先检查一下当前环境是否已经有 NVIDIA 驱动和 CUDA： nvidia-smi 直接在当前环境安装运行 PyTorch 和 Megatron-LM不使用 Docker 之前我们看到目前的环境有 NVIDIA V100 GPU 和 CUDA 12.1，我们可以安装对应的 GPU 版本 PyTorch。…...

编程日记 2025/6/29 9:37:13

赛灵思 XC7K325T-2FFG900I FPGA Xilinx Kintex‑7

XC7K325T-2FFG900I 是 Xilinx Kintex‑7 系列中一款工业级 (I) 高性能 FPGA，基于 28 nm HKMG HPL 工艺制程，核心电压标称 1.0 V，I/O 电压可在 0.97 V–1.03 V 之间灵活配置，并可在 –40 C 至 100 C 温度范围内稳定运行。该器件提供…...

编程日记 2025/7/20 10:21:23

20.1Linux的PWM驱动实验(知识点)_csdn

PWM 是很常用到功能，我们可以通过 PWM 来控制电机速度，也可以使用 PWM 来控制LCD 的背光亮度。本章我们就来学习一下如何在 Linux 下进行 PWM 驱动开发。在之前学过STM32的就知道这部分内容，利用占空比来调节电机的转速。 1、PWM 驱动简析 …...

编程日记 2025/6/29 9:37:17

如何在 Java 中从 PDF 文件中删除页面（教程）

由于 PDF 文件格式不是 Java 原生支持的，因此要从 PDF 中删除页面，你需要使用外部库。本教程介绍如何使用 JPedal 来实现这一功能。开始使用 • 将 JPedal 添加到你的类路径或模块路径中（可从官网下载安装试用版 JAR 文件） •…...

编程日记 2025/6/29 11:48:46

2026《数据结构》考研复习笔记五（栈、队列）

栈、队列一、栈1.卡特兰数2.不合法的出栈序列二、队列1.循环队列2.输入输出受限队列（四个数1234） 三、算法1.栈在括号匹配中的应用2.中缀表达式求值（通过转化为后缀表达式再后缀表达式求值）3.中缀表达式转化为后缀表达式4.后缀表…...

编程日记 2025/6/29 9:47:41

本地部署DeepSeek大模型

本地部署 ollama 下载Ollama ollama支持的模型：Ollama Search 直接下载，发现默认是下载C盘，并且不能选择安装目录，这对我C盘的压力太大了。查阅资料：发现可以修改参考将Ollama安装到非C盘路径_ollama不安装在c盘…...

编程日记 2025/6/29 9:37:19

C++ / 引用 | 类

引用本作用： 给变量起别名语法： 数据类型 & 别名原名； 应用代码 #include <iostream>using namespace std;int main() {int a 10;int& b a;b 100;cout << "a " << a << endl;cout <…...

编程日记 2025/6/29 12:27:54

在任意路径下简单开启jupyter notebook

正常的开启方式为： 安装anaconda, 在anaconda界面开启jupyter. 但是启动后root的路径不好改变。可以直接通过cmd方式打开jupyter. cd D: # cd到d盘 jupyter notebook # 启动此时开启jupyter notebook, root为D盘路径。按此方式可以在任意路径启动jupyter noteb…...

编程日记 2025/7/19 21:12:50

2025年阿里云云计算ACP高级工程师认证模拟试题（附答案解析）

这篇文章的内容是阿里云云计算ACP高级工程师认证考试的模拟试题。所有模拟试题由AI自动生成，主要为了练习和巩固知识，并非所谓的 “题库”，考试中如果出现同样试题那真是纯属巧合。 1、设计云上架构时，如果能充分了解云服务的特…...

编程日记 2025/6/29 11:19:41

锂电池4.2V升压24V推荐哪些升压芯片?高效率国产SL4013输入耐压2.7V-25V

SL4013作为一款高性能升压型DC-DC转换芯片，在单节锂电池（4.2V）升压至24V的应用中展现出以下核心优势： 一、宽输入电压适应性 SL4013支持2.7V-25V的输入范围，尤其适合单节锂电池（3.7V-4.2V）的宽…...

编程日记 2025/7/19 20:03:37

中电金信联合阿里云推出智能陪练Agent

在金融业加速数智化转型的今天，提升服务效率与改善用户体验已成为行业升级的核心方向。面对这一趋势，智能体与智能陪练的结合应用，正帮助金融机构突破传统业务模式，开拓更具竞争力的创新机遇。在近日召开的阿里云AI势能大会期间&…...

编程日记 2025/7/16 1:39:09

基于扣子（Coze.cn）与火山引擎构建高性能智能体的实践指南

1. 引言 1.1. 背景与目标人工智能（AI）智能体（Agent）平台的兴起，例如扣子（Coze），正显著改变我们构建复杂 AI 应用的方式 1。这些平台旨在降低技术门槛，让不同技能水平的…...

编程日记 2025/6/29 9:37:53

w~视觉~3D~合集2

我自己的原文哦~ https://blog.51cto.com/whaosoft/13766161 #Sin3DGen 最近有点忙可能给忘了,贴了我只是搬运工发这些给自己看, 还有下面不是隐藏是发布出去 ~ 北京大学xxx团队联合山东大学和xxx AI Lab的研究人员，提出了首个基于单样例场景无需训练便可生…...

编程日记 2025/7/7 3:27:02

SAS宏核心知识与实战应用

1. SAS宏基础 1.1 核心概念 1.1.1 宏处理器宏处理器在SAS程序运行前执行，用于生成动态代码，可实现代码的灵活定制。通过宏处理器，可基于输入参数动态生成不同的SAS代码，提高代码复用性。 1.1.2 宏变量宏变量是存储文本值的容器，用&符号引用，如&var，用于存储…...

编程日记 2025/6/29 11:45:26

windows使用openssl生成IIS自签证书全流程

使用 OpenSSL 生成适用于 IIS 的证书，通常需要经过以下步骤：生成私钥、生成证书签名请求（CSR）、生成自签名证书或通过 CA 签名，最后将证书转换为 IIS 所需的 PFX 格式。以下是详细步骤： 1. 安装 OpenSSL …...

编程日记 2025/6/29 11:47:12

笔记本电脑研发笔记：BIOS，Driver，Preloader详记

在笔记本电脑的研发过程中，Driver（驱动程序）、BIOS（基本输入输出系统）和 Preloader（预加载程序）之间存在着密切的相互关系和影响，具体如下： 相互关系 BIOS 与 Preload…...

编程日记 2025/7/14 11:40:02

鸿蒙生态：鸿蒙生态校园行心得

（个人观点，仅供参考） 兄弟们，今天来浅浅聊一聊这次的设立在长沙的鸿蒙生态行活动。老样子，我们先来了解一下这个活动： Ｈａｒｍｏｎ&#x…...

编程日记 2025/6/29 9:37:33

云原生周刊：KubeSphere 平滑升级

开源项目推荐 Kagent Kagent 是一个开源的 K8s 原生框架，旨在帮助 DevOps 和平台工程师在 K8s 环境中构建和运行 AI 代理（Agentic AI）。与传统的生成式 AI 工具不同，Kagent 强调自主推理和多步骤任务的自动化执行，适…...

编程日记 2025/6/29 11:31:48

Uniapp：swiper(滑块视图容器)

目录一、基本概述二、属性说明三、基本使用一、基本概述一般用于左右滑动或上下滑动，比如banner轮播图二、属性说明属性名类型默认值说明平台差异说明indicator-dotsBooleanfalse是否显示面板指示点indicator-colorColorrgba(0, 0, 0, .3)指示点颜色indicat…...

编程日记 2025/6/29 12:11:40

开源的自动驾驶模拟器

以下是目前主流的 ‌开源自动驾驶模拟器‌，适用于算法开发、测试和研究： ‌1. CARLA‌ ‌官网/GitHub‌: carla.org | GitHub‌许可证‌: MIT‌特点‌: 基于虚幻引擎（Unreal Engine），提供高保真城市场景（支…...

编程日记 2025/7/19 0:38:08

Uniapp：scroll-view(区域滑动视图)

目录一、基本概述二、属性说明三、基本使用3.1 纵向滚动3.2 横向滚动一、基本概述 scroll-view，可滚动视图区域。用于区域滚动。二、属性说明属性名类型默认值说明平台差异说明scroll-xBooleanfalse允许横向滚动scroll-yBooleanfalse允许纵向滚动三、基本使…...

编程日记 2025/6/29 9:37:28

【漏洞复现】Struts2系列

【漏洞复现】Struts2系列 1. 了解Struts21. Struts2 S2-061 RCE （CVE-2020-17530）1. 漏洞描述2. 影响版本3. 复现过程 1. 了解Struts2 Apache Struts2是一个基于MVC设计模式的Web应用框架，会对某些标签属性（比如 id）的…...

编程日记 2025/7/19 20:40:45

洗车小程序系统前端uniapp 后台thinkphp

洗车小程序系统前端uniapp 后台thinkphp 支持多门店分销在线预约套餐卡等...

编程日记 2025/7/16 10:15:56

【RuleUtil】适用于全业务场景的规则匹配快速开发工具

一、RuleUtil 开发背景 1.1 越来越多，越来越复杂的业务规则 1、规则的应用场景多 2、规则配置的参数类型多（ID、数值、文本、日期等等） 3、规则的参数条件多（大于、小于、等于、包含、不包含、区间等等） 4、规则的结…...

编程日记 2025/7/15 20:38:12

多表查询之嵌套查询

目录引言一、标量嵌套查询二、列嵌套查询三、行嵌套查询四、表嵌套查询引言 1、概念 SQL语句中嵌套 select 语句，称为嵌套查询，又称子查询。嵌套查询外部的语句可以是 insert / update / delete / select 的任何一个。嵌套…...

编程日记 2025/7/17 19:29:35

js原型链prototype解释

function Person(){} var personnew Person() console.log(啊啊,Person instanceof Function);//true console.log(,Person.__proto__Function.prototype);//true console.log(,Person.prototype.__proto__ Object.prototype);//true console.log(,Function.prototype.__prot…...

编程日记 2025/6/29 11:54:32

项目介绍

RPC框架

技术选型

开发环境LInux

Muduo库

C++11异步操作

std::future

std::async

示例代码

std::packaged_task

示例代码

std::promise

示例代码

相关文章：