施磊老师rpc(三)

文章目录

  • mprpc框架项目动态库编译
    • 框架生成动态库
    • 框架初始化函数-文件读取
      • 1. 为什么要传入 `argc, argv`
      • 2. 读取参数逻辑
      • 3. 配置文件设计
    • init部分实现
  • mprpc配置文件加载(一)
    • 配置文件加载类
      • 成员变量
      • 主要方法
      • **src/include/mprpcconfig.h**
    • 配置文件
      • **bin/test.conf**
    • 实现配置文件加载类
      • **src/include/mprpcapplication.h**
      • 注意substr第二个参数的自动截断
      • **src/mprpcconfig.cc**
    • 补充测试框架类init
    • 问题1
      • 问题描述:新增源文件后,没重新生成 Makefile,编译器“看不到”新文件
    • 问题2:
  • mprpc配置文件加载(二)
    • cmake添加
      • `-g` 是什么?
      • `Debug` 模式在 CMake 中
    • gdb调试exe的某个源文件
    • 优化读取
    • 测试
    • 错误

mprpc框架项目动态库编译

框架生成动态库

src/CMakeLists.txt

aux_source_directory(. SRC_LIST)
add_library(mprpc SHARED ${SRC_LIST})  # 生成动态库

example/callee/CMakeLists.txt

set(SRC_LIST userservice.cc ../user.pb.cc)add_executable(provider ${SRC_LIST})target_link_libraries(provider mprpc protobuf)  # 链接动态库

正常编译即正确

框架初始化函数-文件读取

MprpcApplication::Init()

1. 为什么要传入 argc, argv

  • 为了支持从命令行读取配置文件路径(如 ./provider -i config.conf
  • 这样可以让多个部署节点通过不同的配置文件指定自己的网络参数、ZooKeeper地址等

2. 读取参数逻辑

  • 使用 getopt(需引入 <unistd.h>
  • 支持参数格式:-i config.conf
  • 如果参数错误或缺失,调用 ShowArgsHelp() 提示用户正确格式,并 exit(EXIT_FAILURE)

3. 配置文件设计

格式为 key=value 的文本文件,包含 4 项内容,例如:

rpcserverip=127.0.0.1
rpcserverport=8000
zookeeperip=127.0.0.1
zookeeperport=2181

init部分实现

getopt函数 自行查看 man 3

RETURN VALUEIf an option was successfully found, then getopt() returns the option character.  If all command-line  optionshave  been  parsed, then getopt() returns -1.  If getopt() encounters an option character that was not in opt‐string, then '?' is returned.  If getopt() encounters an option with a missing argument, then the return valuedepends on the first character in optstring: if it is ':', then ':' is returned; otherwise '?' is returned.
void MprpcApplication::Init(int argc, char **argv)
{if (argc < 3){// std::cout << "error: argc < 3" << std::endl;// exit(1);ShowArgsHelp();exit(EXIT_FAILURE); // EXIT_FAILURE 是一个宏,表示程序异常退出}std::string config_file; // 配置文件// 解析命令行参数int c = 0;while ((c = getopt(argc, argv, "i:")) != -1) // getopt函数解析命令行参数{switch (c){case 'i':config_file = optarg; // optarg是一个全局变量,存储当前选项的参数break;case '?':  // '?'表示没有找到对应的选项std::cout << "invalid option: " << (char)c<< std::endl;ShowArgsHelp();exit(EXIT_FAILURE);case ':':  // ':'表示选项缺少参数std::cout << "need config_file " << std::endl;ShowArgsHelp();exit(EXIT_FAILURE);default:ShowArgsHelp();exit(EXIT_FAILURE);}} // 读取配置文件----单独写 .h和.cc文件----解耦-且 代码 也不是很少}

编译测试一下,

mprpc配置文件加载(一)

配置文件加载类

成员变量

  • 使用 std::unordered_map<std::string, std::string> 存储配置项的键值对。

主要方法

  • load_config_file(const char* config_file)
    
    • 打开配置文件,逐行读取内容。
    • 处理注释行(以 # 开头)、空行、以及前后多余的空格。
    • 解析合法的键值对(通过 = 分隔)。
    • 将键值对存入 unordered_map
  • load(const std::string& key)
    
    • 根据键查询配置项的值。
    • 如果键不存在,返回空字符串。

src/include/mprpcconfig.h

#pragma once#include <unordered_map>
#include <string>// 框架读取配置文件的类
class MprpcConfig
{public:// 负责解析加载配置文件void LoadConfigFile(const char* config_file);// 查询配置项std::string Load(const std::string& key);private:std::unordered_map<std::string, std::string> m_configMap; // 存储配置文件的键值对
};

配置文件

bin/test.conf

# rpc节点的ip地址
rpcserverip=127.0.0.1
# rpc节点的端口
rpcserverport=8000
# zk节点的ip地址
zookeeperip=127.0.0.1
# zk节点的端口
zookeeperport=5000

实现配置文件加载类

src/include/mprpcapplication.h

#include "mprpcconfig.h"....static MprpcConfig m_config; // 配置文件对象

类内的静态成员函数不能直接访问普通的成员变量。

静态成员函数不依赖于类的具体实例,而是属于类本身,因此它不能访问实例成员变量,因为实例成员变量是与具体对象实例相关联的。

多了解字符串类型, 面试问的很多, 要熟悉其各种方法,多运用
见知识补充

注意substr第二个参数的自动截断

src/mprpcconfig.cc

#include "mprpcconfig.h"
#include <iostream>// 负责解析加载配置文件
void MprpcConfig::LoadConfigFile(const char* config_file)  
{FILE* pf = fopen(config_file, "r");if(pf == nullptr){std::cout << "error: config file is not exist" << std::endl;exit(EXIT_FAILURE);}while(!feof(pf)) // feof函数判断文件是否到达末尾{char buffer[512] = {0}; // 定义一个字符数组, 用于存储一行数据fgets(buffer, sizeof(buffer), pf); // 读取一行数据// 去掉多余空格std::string src_buf(buffer); // 将字符数组转换为字符串int idx = src_buf.find_first_not_of(" \t"); // 查找第一个不是空格或制表符的位置if(idx != std::string::npos){src_buf = src_buf.substr(idx, src_buf.size() - idx); // 截取字符串}// 去掉注释if(src_buf[0] == '#' || src_buf.empty()) // 如果是注释或空行{continue; // 跳过 这一行}// 解析配置项idx = src_buf.find('='); // 查找第一个等号的位置if(idx!= std::string::npos){std::string key = src_buf.substr(0, idx); // 截取键std::string value = src_buf.substr(idx + 1, src_buf.size() - idx - 1); // 截取值// 可以考虑conf书写不规范, 去掉多余空格// 存储配置项m_configMap.insert({key, value}); // 将键值对插入到map中}}}// 查询配置项
std::string MprpcConfig::Load(const std::string& key)
{// return m_configMap[key]; // 错误的, 不要用中括号, 不存在 会自动插入一个空值auto it = m_configMap.find(key); // 查找键if(it == m_configMap.end()) // 如果没有找到{std::cout << "error: key is not exist" << std::endl;return "";}return it->second; // 返回值
}

补充测试框架类init

MprpcConfig MprpcApplication::m_config;  // 静态成员变量, 需要在类外初始化void MprpcApplication::Init(int argc, char **argv)
{if (argc < 3){// std::cout << "error: argc < 3" << std::endl;// exit(1);ShowArgsHelp();exit(EXIT_FAILURE); // EXIT_FAILURE 是一个宏,表示程序异常退出}std::string config_file; // 配置文件// 解析命令行参数int c = 0;while ((c = getopt(argc, argv, "i:")) != -1) // getopt函数解析命令行参数{switch (c){case 'i':config_file = optarg; // optarg是一个全局变量,存储当前选项的参数break;case '?':  // '?'表示没有找到对应的选项ShowArgsHelp();exit(EXIT_FAILURE);case ':':  // ':'表示选项缺少参数ShowArgsHelp();exit(EXIT_FAILURE);default:ShowArgsHelp();exit(EXIT_FAILURE);}m_config.LoadConfigFile(config_file.c_str()); // 加载配置文件, config_file是一个std::string类型的变量, 文件名字std::cout<<"rpcserverip:"<<m_config.Load("rpcserverip")<<std::endl;std::cout<<"rpcserverport:"<<m_config.Load("rpcserverport")<<std::endl;std::cout<<"zookeeperip:"<<m_config.Load("zookeeperip")<<std::endl;std::cout<<"zookeeperport:"<<m_config.Load("zookeeperport")<<std::endl;} // 读取配置文件----单独写 .h和.cc文件----解耦-且 代码 也不是很少// rpcserver_ip   rpcserver_port  zookeeper_ip zookeeper_port }

问题1

直接进行cmake 编译, 会报错!!

[build] /usr/bin/ld: ../../src/libmprpc.so: undefined reference to `MprpcApplication::m_config'
[build] collect2: error: ld returned 1 exit status
[build] gmake[2]: *** [example/callee/CMakeFiles/provider.dir/build.make:114: ../bin/provider] Error 1
[build] gmake[1]: *** [CMakeFiles/Makefile2:157: example/callee/CMakeFiles/provider.dir/all] Error 2
[build] gmake: *** [Makefile:91: all] Error 2

问题描述:新增源文件后,没重新生成 Makefile,编译器“看不到”新文件

场景如下:

  • CMake 使用了 file(GLOB ...)aux_source_directory(...) 收集源文件;
  • 然后你手动在代码目录中添加了新的 .cpp 文件;
  • 但是你没有清除 CMake 缓存或重新运行 cmake 命令
  • 结果:Makefile 没更新,新文件不会被编译,也不在目标构建中。

问题2:

[!WARNING]

MprpcConfig MprpcApplication::m_config; // 静态成员变量, 需要在类外初始化

mprpc配置文件加载(二)

cmake添加

-g 是什么?

  • -g 是 GCC/Clang 的编译器选项,用于生成调试信息(供 GDB 等调试器使用)。
  • 编译出来的程序体积更大,但可以逐行调试、查看变量值等。

Debug 模式在 CMake 中

cmake复制编辑
set(CMAKE_BUILD_TYPE "Debug")

这条语句告诉 CMake 使用 Debug 配置,其效果通常是:

  • 自动添加 -g
  • 开启 -O0(不优化,便于调试)
  • 设置调试宏(如 _DEBUG
set(CMAKE_BUILD_TYPE "Debug")  # 设置 Debug 模式并开启调试信息

gdb调试exe的某个源文件

gdb ./provider
break mprpcconfig.cc:<行数>

优化读取

为了 适应 更多不规范的 conf 文件

封装一下 去除前后空格—> 不仅可以一行前后去空格, 还可以取出 = 前后 再去空格

void MprpcConfig::Trim(std::string &src_buf);
// 去除前后空格
void MprpcConfig::Trim(std::string &src_buf)
{int idx = src_buf.find_first_not_of(" "); // 查找第一个不是空格的位置if (idx != std::string::npos){src_buf = src_buf.substr(idx, src_buf.size() - idx); // 截取字符串}idx = src_buf.find_last_not_of(" "); // 查找最后一个不是空格的位置if (idx != std::string::npos){src_buf = src_buf.substr(0, idx + 1); // 截取字符串}
}

src/mprpcconfig.cc

// 负责解析加载配置文件
void MprpcConfig::LoadConfigFile(const char *config_file)
{FILE *pf = fopen(config_file, "r");if (pf == nullptr){std::cout << "error: config file is not exist" << std::endl;exit(EXIT_FAILURE);}while (!feof(pf)) // feof函数判断文件是否到达末尾{char buffer[512] = {0};            // 定义一个字符数组, 用于存储一行数据fgets(buffer, sizeof(buffer), pf); // 读取一行数据// 去掉多余空格std::string read_buf(buffer); // 将字符数组转换为字符串Trim(read_buf);              // 去掉前后空格// 去掉注释if (read_buf[0] == '#' || read_buf.empty()) // 如果是注释或空行{continue; // 跳过 这一行}// 解析配置项int idx = read_buf.find('='); // 查找第一个等号的位置if (idx != std::string::npos){std::string key = read_buf.substr(0, idx);                              // 截取键Trim(key); // 去掉前后空格// 先去\nint endidx = read_buf.find_last_not_of("\r\n", read_buf.size()-1); // 查找最后一个不是回车或换行的位置std::string value;if (endidx != std::string::npos){value = read_buf.substr(idx+1, endidx-idx); // 截取字符串}Trim(value); // 再去掉前后空格// 下面这段不对, \n本身就是最后一个, 要是 \n之前紧挨着空格呢/*// 还有换行idx = value.find_last_not_of("\r\n"); // 查找最后一个不是回车或换行的位置if (idx != std::string::npos){value = value.substr(0, idx); // 截取值}*/// 存储配置项m_configMap.insert({key, value}); // 将键值对插入到map中}}
}

测试

自行测试

可能还不是最好的 处理 所有情况, 但是 要给用户 一定容错!!

错误

出现错误, 不要着急解决, 先去定位!!!

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

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

相关文章

文献分享:通过简单的生物偶联策略将肽双特异性抗体(pBsAbs)应用于免疫治疗

背景 双特异性抗体是将单克隆抗体的两个不同抗原结合位点融合成一个单一实体的人工分子。它们已经成为一种很有前景的下一代抗癌治疗方法。尽管双特异性抗体的应用令人着迷&#xff0c;但双特异性抗体的设计和生产仍然繁琐而富有挑战性&#xff0c;导致研发过程漫长&#xff0…

二、shell脚本--变量与数据类型

1. 变量的定义与使用 定义变量&#xff1a;简单直接 在 Shell 里定义变量相当容易&#xff1a; 基本格式: variable_namevalue关键点 ❗&#xff1a;赋值号 的两边绝对不能有空格&#xff01;这绝对是初学者最容易踩的坑之一 &#x1f628;&#xff0c;务必留意&#xff01…

java_Lambda表达式

1、背景 lambda表达式是Java SE 8中一个重要的新特性。lambda表达式允许你通过表达式来代替功能接口。lambda表达式就和方法一样样&#xff0c;它提供了一个正常的参数列表和一个使用这些参数的主体&#xff08;body&#xff0c;可以是一个表达式和一个代码块&#xff09;。La…

给QCustomPlot添加一个QScrollBar滚动条、限制缩放范围、自动设置大小和右边栏垂直缩放

实现效果 实现思路 从QCustomPlot类派生一个类,进行个性化设置,在轴矩形的上边设置Margin,放一个滚动条,设置滚动条的样式 常量定义 #define NQSCRB 1000构造函数初始化 // 设置QScrollBar的样式// 顶部空--5,左侧空--6

实验-组合电路设计1-全加器和加法器(数字逻辑)

目录 一、实验内容 二、实验步骤 2.1 全加器的设计 2.2 加法器的设计 三、调试过程 3.1 全加器调试过程 2.加法器的调试过程 四、实验使用环境 五、实验小结和思考 一、实验内容 a) 介绍 在这次实验中&#xff0c;你将熟悉 Logisim 的操作流程&#xff0c;并且学习…

Linux进程控制与替换详解

进程创建 fork函数初识 在linux中fork函数是非常重要的函数,它从已存在进程中创建⼀个新进程。新进程为子进程,而原进程为父进程。 进程调用fork,当控制转移到内核中的fork代码后,内核做: • 分配新的内存块和内核数据结构给子进程 • 将父进程部分数据结构内容拷贝至…

Vue3学习笔记2——路由守卫

路由守卫 全局 router.beforeEach((to, from, next) > {})router.afterEach((to, from, next) > {}) 组件内守卫 beforeRouteEnter((to, from, next) > {})beforeRouteUpdate((to, from, next) > {})beforeRouteLeave((to, from, next) > {}) 路由独享 be…

AI与无人零售:如何通过智能化技术提升消费者体验和运营效率?

引言&#xff1a;无人零售不只是无人值守 你走进一家无人便利店&#xff0c;没有迎宾、没有收银员&#xff0c;甚至没有一个人在场&#xff0c;但你刚拿起商品&#xff0c;货架旁的摄像头就悄悄“看懂”了你的动作&#xff0c;系统已经在后台为你记账。你以为只是没人管&#x…

如何在3dMax中使用UVW展开修改器?

UVW展开(Unwrap UVW)修改器是3dmax中的一个强大工具,允许对纹理如何应用于3D模型进行精确控制。 与更简单的UVW Map修改器不同,Unwrap UVW修改器提供了高级选项,用于手动编辑纹理映射,对于详细和复杂的模型来说是必不可少的。 在本文中,我们将探讨增强您对Unwrap UVW修…

【Linux】进程优先级与进程切换理解

&#x1f31f;&#x1f31f;作者主页&#xff1a;ephemerals__ &#x1f31f;&#x1f31f;所属专栏&#xff1a;Linux 目录 前言 一、进程优先级 1. 什么是进程优先级 2. 为什么有进程优先级 3. 进程优先级的作用 4. Linux进程优先级的本质 5. 修改进程优先级 二、进…

【Hive入门】Hive高级特性:事务表与ACID特性详解

目录 1 Hive事务概述 2 ACID特性详解 3 Hive事务表的配置与启用 3.1 启用Hive事务支持 3.2 创建事务表 4 Hive事务操作流程 5 并发控制与隔离级别 5.1 Hive的锁机制 5.2 隔离级别 6 Hive事务的限制与优化 6.1 主要限制 6.2 性能优化建议 7 事务表操作示例 7.1 基本…

二叉树算法精解(Java 实现):从遍历到高阶应用

引言 二叉树&#xff08;Binary Tree&#xff09;作为算法领域的核心数据结构&#xff0c;在搜索、排序、数据库索引、编译器语法树构建等众多场景中都有着广泛应用。无论是初学者夯实算法基础&#xff0c;还是求职者备战技术面试&#xff0c;掌握二叉树相关算法都是不可或缺的…

ES6入门---第二单元 模块二:关于数组新增

一、扩展运算符。。。 1、可以把ul li转变为数组 <script>window.onloadfunction (){let aLi document.querySelectorAll(ul li);let arrLi [...aLi];arrLi.pop();arrLi.push(asfasdf);console.log(arrLi);};</script> </head> <body><ul><…

Nature正刊:新型折纸启发手性超材料,实现多模式独立驱动,变形超50%!

机械超材料是一种结构化的宏观结构&#xff0c;其几何排列方式具有独特的几何结构&#xff0c;从而具有独特的力学性能和变形模式。超材料的宏观特性取决于中观尺度晶胞的具体形状、尺寸和几何取向。经典的结构化晶胞&#xff0c;例如以拉伸为主的八面体桁架单元和以弯曲为主的…

Servlet(二)

软件架构 1. C/S 客户端/服务器端 2. B/S 浏览器/服务器端&#xff1a; 客户端零维护&#xff0c;开发快 资源分类 1. 静态资源 所有用户看到相同的部分&#xff0c;如&#xff1a;html,css,js 2. 动态资源 用户访问相同资源后得到的结果可能不一致&#xff0c;如&#xff1a;s…

循环缓冲区

# 循环缓冲区 说明 所谓消费&#xff0c;就是数据读取并删除。 循环缓冲区这个数据结构与生产者-消费者问题高度适配。 生产者-产生数据&#xff0c;消费者-处理数据&#xff0c;二者速度不一致&#xff0c;因此需要循环缓冲区。 显然&#xff0c;产生的数据要追加到循环缓…

嵌入式硬件篇---STM32 系列单片机型号命名规则

文章目录 前言一、STM32 型号命名规则二、具体型号解析1. STM32F103C8T6F103:C:8:T6:典型应用2. STM32F103RCT6F103:R:C:T6:典型应用三、命名规则扩展1. 引脚数与封装代码2. Flash 容量代码3. 温度范围代码四、快速识别技巧性能定位:F1/F4后缀差异硬件设计参考:引脚数…

MySQL 中日期相减的完整指南

MySQL 中日期相减的完整指南 在 MySQL 中&#xff0c;日期相减有几种不同的方法&#xff0c;具体取决于你想要得到的结果类型&#xff08;天数差、时间差等&#xff09;。 1. 使用 DATEDIFF() 函数&#xff08;返回天数差&#xff09; SELECT DATEDIFF(2023-05-15, 2023-05-…

传奇各版本迭代时间及内容变化,屠龙/嗜魂法杖/逍遥扇第一次出现的时间和版本

​【早期经典版本】 1.10 三英雄传说&#xff1a;2001 年 9 月 28 日热血传奇正式开启公测&#xff0c;这是传奇的第一个版本。游戏中白天与黑夜和现实同步&#xff0c;升级慢&#xff0c;怪物爆率低&#xff0c;玩家需要靠捡垃圾卖金币维持游戏开销&#xff0c;遇到高级别法师…

重塑数学边界:人工智能如何引领数学研究的新纪元

目录 一、人工智能如何重新定义数学研究的边界 &#xff08;一&#xff09;数学与AI的关系&#xff1a;从基础理论到创新思维的回馈 &#xff08;二&#xff09;AI的创造力&#xff1a;突破传统推理的局限 &#xff08;三&#xff09;AI对数学研究的潜在贡献&#xff1a;创…