关于ZeroC Ice C++异步invoke,整合ProtoBuf对象

2024-04-15 11:48

本文主要是介绍关于ZeroC Ice C++异步invoke,整合ProtoBuf对象,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

导读

      • 前奏
      • 问题马上就来了
      • 没办法只能自己摸索了
        • 1. 先来看看其定义
        • 2. 参数的准备
        • 3. 准备回调函数
        • 4. 正式调用
        • 5. 到此客户端就完成了,服务端怎么办呢?
      • 现在大家喜欢用ProtoBuf,怎么来整合到Ice中

前奏

本文并不是一篇教程,只是提供了一个思路,最好先熟悉了Ice相关概念,动手调试运行了官方Demo后,再来看。

我们知道Ice的一般使用方式,是通过Slice文件生成的对应的类来操作,Ice为我们封装了网络通信的过程,只需调用Slice中定义类方法即可,如下Slice文件定义所示:

module Demo {interface AskPerson {string AskNumber(string sName);string AskName(string sName);};
};

客户端通过该类的Proxy直接调用该类的方,对于客户端来说Proxy就是代表着该类。我们可以按照如下的方式调用,也可以学习官方Demo。

// 从配置文件读取属性信息
Ice::InitializationData initData;
initData.properties = Ice::createProperties();
initData.properties->load("config.client");ic = Ice::initialize(argc, argv,initData);// 从配置文件中读取Ice::Object即我们的目标对象的标识号
Ice::ObjectPrx base = ic->propertyToProxy("AskPerson.Proxy");
AskPersonPrx askerPrx = AskPersonPrx::checkedCast(base);
if (!askerPrx)
{throw "Invalid proxy";
}std::cout<<"client get"<<askerPrx->AskName("xx")<<std::endl;

很简单,读一下Demo和网上的文章基本就能学会使用,但是可能这个技术有点Old,所以好多文章都是2012年之前的,也鲜有人讨论。

问题马上就来了

假设一个项目中有50个这样的对象,各个业务模块,难道都需要创建对象askPerson1~50?且万一类名改变了怎么办?在业务模块经常因为这样的变动而修改代码,肯定没有人会感觉到很舒服。

首先想到的是封装一层,这些生成的对象都有Ice基类的,但方法名是个麻烦事儿,Ice不可能在Ice::Object中提前定义好我们需要的虚函数。

幸好,Ice提供了invoker方法,我们只需提供函数名和参数,invoker会帮我们发起RPC调用。

同步方式调用invoker很简单,跟直接调AskName差不多,只是返回值,变成了输出参数,官方Demo也有比较简单的例子,就不赘述了。invoker定义如下:

bool ice_invoke(const ::std::string& operation,::Ice::OperationMode mode,const ::std::vector< ::Ice::Byte>& inParams,::std::vector< ::Ice::Byte>& outParams)

可奇怪的是,官方Demo中只讲了生成类AskPerson直接调成员方法的async,没有讲invoker的async。网上的文章也几乎没有讨论的。

没办法只能自己摸索了

直接上结论了,Ice提供了begin_ice_invoke,其实就是围绕它来完成异步的。我们按照begin_ice_invoke的要求,准备参数,准备回调函数。

1. 先来看看其定义
    ::Ice::AsyncResultPtr begin_ice_invoke(const ::std::string& operation,::Ice::OperationMode mode,const ::std::vector< ::Ice::Byte>& inParams, //RPC调用的参数const ::Ice::Context& __ctx,const ::Ice::CallbackPtr& __del,             //回调函数指针const ::Ice::LocalObjectPtr& __cookie = 0)

其中operation就是slice文件中定义的成员方法,例如下面代码中的GoNameAsync:

#ifndef ASKPERSON_ICE
#define ASKPERSON_ICE[["cpp:include:person.pb.h"]]
[["cpp:include:StreamProtobuf.h"]]module Demo {["cpp:type:PersonModule::Person"] sequence<byte> Person;interface AskPerson {string AskNumber(string sName);string AskName(string sName);["amd"] void GoNameAsync(string sName);["amd"] void GoNumberAsync(int nGid,string sName);["amd"] void GoPerson(Person p);};
};#endif

而inParams就是GoNameAsync的参数,只不过是序列化后的;Ice::CallbackPtr是一个回调函数的指针,用于异步的方式返回数据。

GoNameAsynce的返回值为void,服务器也可以返回一个序列化的数据,目前还不清楚内部实现。

2. 参数的准备

利用Ice提供的输入输出流,将数据直接序列化为buffer,如下代码所示,将字符串write到Ice的字节序列ByteSeq中,ByteSeq的实质是std::vector< ::Ice::Byte>

Ice::InitializationData initData;
initData.properties = Ice::createProperties();
initData.properties->load("config.client");//ic = Ice::initialize(argc, argv,initData);
ic = Ice::initialize(initData);...Ice::ByteSeq inParams;
Ice::OutputStreamPtr out = Ice::createOutputStream(ic);
out->startEncapsulation();
out->write("tom");
out->endEncapsulation();
out->finished(inParams);

上例我们向输出流里写入了一个字符串"tom",如果一个RPC调用有多个参数,只需多次调用out->write()方法,该方法重载了多种类型,我们传值就可以了。

最后直接将流里面的数据,刷新到缓冲区(Ice::ByteSeq字节序列)。

3. 准备回调函数

这里有点特殊,有参数类型要求,不是随便写一个函数指针就可以的,多写写就习惯了。

class CallBack :public IceUtil::Shared
{// 这个回调函数名不限制,但是参数类型要给正确void response(const Ice::AsyncResultPtr& p){Ice::ByteSeq datas;// 从invoke中获取字节序列p->getProxy()->end_ice_invoke(datas,p);// 通过输入流将该字节序,直接读取Ice::InputStreamPtr in = Ice::createInputStream(p->getCommunicator(), datas);// 具体的数据是哪种类型,要看服务端怎么发的std::string message;in->read(message);in->readPendingObjects();in->endEncapsulation();std::cout<<"get response"<<message<<std::endl;}
};

回调函数被调用后,我们首先获取字节序列,然后通过输入流,直接读取数据到对应的类型变量中。字节序列+流的形式,封装了解析细节,使用起来非常方便。

4. 正式调用

通过Ice::newCallback方法创建回调函数的指针。并发起async RPC调用。

CallbackPtr cb = new Callback();
// 这个context现在我还没用过,初次使用直接创建对象吧,不要犹豫
Ice::Context context;// CallbackPtr是ICE定义的,重点关注newCallback这个方法
Ice::CallbackPtr cbPtr = Ice::newCallback(cb, &Callback::response);// 正式发起RPC调用,输入参数,等待回调
Ice::AsyncResultPtr asyncPtr = base->begin_ice_invoke("AskNameAsync",Ice::Normal,inParams,context,cbPtr);
asyncPtr->waitForCompleted();
5. 到此客户端就完成了,服务端怎么办呢?

服务端可以采用同步方式处理(即使客户端采用异步),也可以采用异步(AMD模式),两端是独立的,这是很基本的概念。

服务端采用异步方式,开线程搞个workqueue是一般步骤,下面来看看具体的目标服务对象怎么定义的,由于是invoker方式,就不能搞一个类然后继承Demo::AskPerson了。要像下面这样:

class AskPersonInvokerAsync : public Ice::BlobjectAsync
{
public:AskPersonInvokerAsync(const WorkQueuePtr& workQueue):_workQueue(workQueue){}virtual void ice_invoke_async(const Ice::AMD_Object_ice_invokePtr& cb, const std::vector<Ice::Byte>&inParam, const Ice::Current& current){_workQueue->add(cb,inParam,current);}private:WorkQueuePtr _workQueue;
};

注意ice_invoke_async第一个参数(即回调函数的指针)的类型;WorkQueue就是官方Demo中的,直接拿来用的哈,流程就走完了。

现在大家喜欢用ProtoBuf,怎么来整合到Ice中

原理就是不用PB来序列化,只是用PB的对象,而采用Ice输入输出流,直接序列化PB对象到Ice::ByteSeq中。

https://github.com/zeroc-ice/ice-protobuf中有例子,但没有invoke的,我们把它的序列化头文件StreamProtobuf.h直接拿来用。

该文件中定义的模板StreamHelper是一个特化模板,将PB对象序列化的具体实现,Ice中也定义了这样的一个模板,如此一来,PB就可以很方便的整合进Ice的输入输出流,编译时会自动匹配这个特化模板,使用时像如下代码:

// 定义的一个PB类
PersonModule::Person testPerson;
testPerson.set_age(15);
testPerson.set_name("kyle");
...Ice::ByteSeq inParams;
Ice::OutputStreamPtr out = Ice::createOutputStream(ic);
out->startEncapsulation();// 注意通过输出流write对象时,记得填模板参数
out->write<PersonModule::Person>(testPerson);
out->endEncapsulation();
out->finished(inParams);

注意是用Ice::OutputStream来序列化,而不用PB来序列化

然后就可以传参,调用了。

这篇关于关于ZeroC Ice C++异步invoke,整合ProtoBuf对象的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

在java中如何将inputStream对象转换为File对象(不生成本地文件)

《在java中如何将inputStream对象转换为File对象(不生成本地文件)》:本文主要介绍在java中如何将inputStream对象转换为File对象(不生成本地文件),具有很好的参考价... 目录需求说明问题解决总结需求说明在后端中通过POI生成Excel文件流,将输出流(outputStre

一文详解如何从零构建Spring Boot Starter并实现整合

《一文详解如何从零构建SpringBootStarter并实现整合》SpringBoot是一个开源的Java基础框架,用于创建独立、生产级的基于Spring框架的应用程序,:本文主要介绍如何从... 目录一、Spring Boot Starter的核心价值二、Starter项目创建全流程2.1 项目初始化(

Python 中的异步与同步深度解析(实践记录)

《Python中的异步与同步深度解析(实践记录)》在Python编程世界里,异步和同步的概念是理解程序执行流程和性能优化的关键,这篇文章将带你深入了解它们的差异,以及阻塞和非阻塞的特性,同时通过实际... 目录python中的异步与同步:深度解析与实践异步与同步的定义异步同步阻塞与非阻塞的概念阻塞非阻塞同步

C++ 中的 if-constexpr语法和作用

《C++中的if-constexpr语法和作用》if-constexpr语法是C++17引入的新语法特性,也被称为常量if表达式或静态if(staticif),:本文主要介绍C++中的if-c... 目录1 if-constexpr 语法1.1 基本语法1.2 扩展说明1.2.1 条件表达式1.2.2 fa

Spring Boot 整合 MyBatis 连接数据库及常见问题

《SpringBoot整合MyBatis连接数据库及常见问题》MyBatis是一个优秀的持久层框架,支持定制化SQL、存储过程以及高级映射,下面详细介绍如何在SpringBoot项目中整合My... 目录一、基本配置1. 添加依赖2. 配置数据库连接二、项目结构三、核心组件实现(示例)1. 实体类2. Ma

Java 中实现异步的多种方式

《Java中实现异步的多种方式》文章介绍了Java中实现异步处理的几种常见方式,每种方式都有其特点和适用场景,通过选择合适的异步处理方式,可以提高程序的性能和可维护性,感兴趣的朋友一起看看吧... 目录1. 线程池(ExecutorService)2. CompletableFuture3. ForkJoi

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法:给并发装上"节流阀"三、进阶控制

C++中::SHCreateDirectoryEx函数使用方法

《C++中::SHCreateDirectoryEx函数使用方法》::SHCreateDirectoryEx用于创建多级目录,类似于mkdir-p命令,本文主要介绍了C++中::SHCreateDir... 目录1. 函数原型与依赖项2. 基本使用示例示例 1:创建单层目录示例 2:创建多级目录3. 关键注

C++从序列容器中删除元素的四种方法

《C++从序列容器中删除元素的四种方法》删除元素的方法在序列容器和关联容器之间是非常不同的,在序列容器中,vector和string是最常用的,但这里也会介绍deque和list以供全面了解,尽管在一... 目录一、简介二、移除给定位置的元素三、移除与某个值相等的元素3.1、序列容器vector、deque

C++常见容器获取头元素的方法大全

《C++常见容器获取头元素的方法大全》在C++编程中,容器是存储和管理数据集合的重要工具,不同的容器提供了不同的接口来访问和操作其中的元素,获取容器的头元素(即第一个元素)是常见的操作之一,本文将详细... 目录一、std::vector二、std::list三、std::deque四、std::forwa