远程过程调用-buttonrpc源码解析6-函数调用

2024-04-02 04:20
文章标签 源码 过程 调用 解析 远程 函数调用 buttonrpc

本文主要是介绍远程过程调用-buttonrpc源码解析6-函数调用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前一篇文章讲述了服务端如何利用std::bind绑定函数，统一函数调用形式。本片文章继续分析服务端如何调用绑定后的函数。
解惑：前一篇里buttonrpc源码采用了buttonrpc::callproxy<F>或buttonrpc::callproxy<F, S>函数作为绑定的调用对象，而将func作为绑定的参数。那为什么不直接使用型如std::bind(func, args...)或std::bind(func, struct, args...)的方式呢？因为我们无法将func的参数统一成最后几个参数类型相同，也不应该统一，func应该表达其本身函数的意思。因此，需要借助委托函数buttonrpc::callproxy<F>或buttonrpc::callproxy<F, S>来统一函数的最后几个参数，本节将进行重点分析。

1、服务端调用的第一层函数
服务端会通过反序列化得到函数名称，之后得到参数数据指针data和数据长度len。接着调用call_函数，并将返回值序列化到ds对象中返回。其中，auto fun = m_handlers[name]得到的就是当初绑定时的委托函数callproxy。

inline Serializer* buttonrpc::call_(std::string name, const char* data, int len)
{Serializer* ds = new Serializer();if (m_handlers.find(name) == m_handlers.end()) {(*ds) << value_t<int>::code_type(RPC_ERR_FUNCTIION_NOT_BIND);(*ds) << value_t<int>::msg_type("function not bind: " + name);return ds;}auto fun = m_handlers[name];fun(ds, data, len);ds->reset();return ds;
}

2、重点：委托函数callproxy，统一函数最后三个参数

template<typename F>
inline void buttonrpc::callproxy( F fun, Serializer* pr, const char* data, int len )
{callproxy_(fun, pr, data, len);
}template<typename F, typename S>
inline void buttonrpc::callproxy(F fun, S * s, Serializer * pr, const char * data, int len)
{callproxy_(fun, s, pr, data, len);
}

3、重点：函数callproxy_负责拆分callproxy中的模板F的具体类型

// 函数指针
template<typename R, typename... Params>
void callproxy_(R(*func)(Params...), Serializer* pr, const char* data, int len)
{callproxy_(std::function<R(Params...)>(func), pr, data, len);
}// 类成员函数指针
template<typename R, typename C, typename S, typename... Params>
void callproxy_(R(C::* func)(Params...), S* s, Serializer* pr, const char* data, int len)
{using args_type = std::tuple<typename std::decay<Params>::type...>;Serializer ds(StreamBuffer(data, len));constexpr auto N = std::tuple_size<typename std::decay<args_type>::type>::value;args_type args = ds.get_tuple < args_type >(std::make_index_sequence<N>{});// 以下代码作用：函数调用+处理返回值auto ff = [=](Params... ps)->R {return (s->*func)(ps...);};typename type_xx<R>::type r = call_helper<R>(ff, args);value_t<R> val;val.set_code(RPC_ERR_SUCCESS);val.set_val(r);(*pr) << val;
}// functional
template<typename R, typename... Params>
void callproxy_(std::function<R(Params... ps)> func, Serializer* pr, const char* data, int len)
{	using args_type = std::tuple<typename std::decay<Params>::type...>;Serializer ds(StreamBuffer(data, len));constexpr auto N = std::tuple_size<typename std::decay<args_type>::type>::value;args_type args = ds.get_tuple < args_type > (std::make_index_sequence<N>{});// 以下代码作用：函数调用+处理返回值typename type_xx<R>::type r = call_helper<R>(func, args);value_t<R> val;val.set_code(RPC_ERR_SUCCESS);val.set_val(r);(*pr) << val;
}

由于callproxy_里的func函数在std::bind的时候已经绑定过了，因此可以明确知道func参数的类型和个数，便可以得到std::tuple的类型args_type和元素数量N，最终反序列化到元组args：

using args_type = std::tuple<typename std::decay<Params>::type...>;
constexpr auto N = std::tuple_size<typename std::decay<args_type>::type>::value;
args_type args = ds.get_tuple < args_type > (std::make_index_sequence<N>{});

而在拆分类成员函数内，出现了lambda表达式，而没采用std::bind：

auto ff = [=](Params... ps)->R {return (s->*func)(ps...);
};

这是因为如果采用std::bind的方式，需要添加参数占位符std::placeholders::_1，而面对可变参的时候无法确定应该填写几个，所以采用lambda表达式。
4、若不考虑函数返回值，则可以直接调用invoke函数

// 具体实现函数模板：用tuple做参数调用函数模板类
template<typename Function, typename Tuple, std::size_t... Index>
decltype(auto) invoke_impl(Function&& func, Tuple&& t, std::index_sequence<Index...>)
{return func(std::get<Index>(std::forward<Tuple>(t))...);
}// 函数模板：作为一个接口，负责调用相关函数并传递参数 
template<typename Function, typename Tuple>
decltype(auto) invoke(Function&& func, Tuple&& t)
{constexpr auto size = std::tuple_size<typename std::decay<Tuple>::type>::value;return invoke_impl(std::forward<Function>(func), std::forward<Tuple>(t), std::make_index_sequence<size>{});
}

修改后，调用invoke方式如下：

// 类成员函数
template<typename R, typename C, typename S, typename... Params>
void callproxy_(R(C::* func)(Params...), S* s, Serializer* pr, const char* data, int len)
{using args_type = std::tuple<typename std::decay<Params>::type...>;Serializer ds(StreamBuffer(data, len));constexpr auto N = std::tuple_size<typename std::decay<args_type>::type>::value;args_type args = ds.get_tuple < args_type >(std::make_index_sequence<N>{});// 不考虑返回值，修改如下auto ff = [=](Params... ps)->R {return (s->*func)(ps...);};invoke(ff, args);
}// 普通函数
template<typename R, typename... Params>
void callproxy_(std::function<R(Params... ps)> func, Serializer* pr, const char* data, int len)
{using args_type = std::tuple<typename std::decay<Params>::type...>;Serializer ds(StreamBuffer(data, len));constexpr auto N = std::tuple_size<typename std::decay<args_type>::type>::value;args_type args = ds.get_tuple < args_type > (std::make_index_sequence<N>{});// 不考虑返回值，修改如下invoke(func, args);
}

这篇关于远程过程调用-buttonrpc源码解析6-函数调用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/868949。

相关文章

网页解析 lxml 库--实战

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库，完全使用 Python 语言编写，它对 XPath表达式提供了良好的支 持，因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块，该模块专门用来解析 HTML/XML 文档，下面来介绍一下 lxml 库
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
作业提交过程之HDFSMapReduce

作业提交过程之HDFSMapReduce

作业提交全过程详解 （1）作业提交 第1步：Client调用job.waitForCompletion方法，向整个集群提交MapReduce作业。 第2步：Client向RM申请一个作业id。 第3步：RM给Client返回该job资源的提交路径和作业id。 第4步：Client提交jar包、切片信息和配置文件到指定的资源提交路径。 第5步：Client提交完资源后，向RM申请运行MrAp
阅读更多...
JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
【C++】_list常用方法解析及模拟实现

【C++】_list常用方法解析及模拟实现

相信自己的力量，只要对自己始终保持信心，尽自己最大努力去完成任何事，就算事情最终结果是失败了，努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一：什么是list？ •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二：list常用接口 •🌰1.默认成员函数 🔥构造函数（⭐） 🔥析构函数 •🌰2.list对象
阅读更多...
如何在页面调用utility bar并传递参数至lwc组件

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件： 2.调用utility bar api的方式有两种： 方法一，通过lwc调用： import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca
阅读更多...
【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

引言 高斯过程（Gaussian Process，简称GP）是一种概率模型，用于描述一组随机变量的联合概率分布，其中任何一个有限维度的子集都具有高斯分布 文章目录 引言一、高斯过程1.1 基本定义1.1.1 随机过程1.1.2 高斯分布 1.2 高斯过程的特性1.2.1 联合高斯性1.2.2 均值函数1.2.3 协方差函数（或核函数） 1.3 核函数1.4 高斯过程回归（Gauss
阅读更多...
Java ArrayList扩容机制 （源码解读）

Java ArrayList扩容机制 （源码解读）

结论：初始长度为10，若所需长度小于1.5倍原长度，则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1：数组默认长度         2:这是一个共享的空数组实例，用于明确创建长度为0时的ArrayList ，比如通过 new ArrayList<>(0)，ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL
阅读更多...
如何在Visual Studio中调试.NET源码

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时，发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null，再判断Count。 看了一下Count的源码如下： 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get
阅读更多...
工厂ERP管理系统实现源码（JAVA）

工厂ERP管理系统实现源码（JAVA）

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本，并实时掌握各环节的运营状况。 在采购管理方面，系统能够处理采购订单、供应商管理和采购入库等流程，确保采购过程的透明和高效。仓库管理方面，实现库存的精准管理，包括入库、出库、盘点等操作，确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2