- 浏览: 491071 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
hypercube:
markin'
配置D语言编程环境 -
qiezi:
qiezi 写道yangyang_08 写道1 ...
我的编程语言学习经历 -
qiezi:
yangyang_08 写道1、现在如果做并发服务器,楼主选用 ...
我的编程语言学习经历 -
yangyang_08:
1、现在如果做并发服务器,楼主选用什么样的语言架构?2、lua ...
我的编程语言学习经历 -
dearplain:
我也是语言爱好者,不过我一直坚持使用c。
我的编程语言学习经历
前面简单写了点静态结构,这一次将主要关注动态模型以及调用方式。
这个系列的名字叫“为C++实现一个IDL”,实际上应该叫“为C++实现一个Remoting”可能更好一些,说是IDL,主要是想通过宏,使用简单的类型定义达到自动生成调用代码的目的。
一、首先来看看调用习惯。
从调用习惯入手,主要是因为看到目前有很多库/工具包在调用上都有很多不便之处。假如能在一开始就从这点出发,就能把调用接口设计得更好一些。
先来看看服务端如何开放一个服务。
{
// 发布为SOAP服务,先生成一个服务容器。
// 服务将发布在localhost的7911上,localhost用来绑定loopback网卡。
SOAPProxy soap_service (7911, “localhost”);
TestService test_service;
soap_service.addService (“test_service”, &test_service);
TestService service1;
soap_service.addService (“HelloService”, &service1);
try{
soap_service.run ();
} catch (SocketException& e)
{
} catch (SignalException& e)
{
}
return 0;
}
我希望就是这么简单,客户端调用有多种方式:
1、 使用服务的IDL定义,直接调用:
{
SOAPProxy soap_service (7911, “localhost”);
try{
TestService test_service (“test_service”, &soap_service);
test_service.method1 (/**/);
} catch (SocketException& e)
{
}
return 0;
}
这种方式比较简单,调用时会检查是否已经连接,然后发送调用请求,并处理调用结果。
2、 服务验证方式:
{
SOAPProxy soap_service (7911, “localhost”);
TestService test_service;
soap_service.getService (“test_service”, &test_service);
if (test_service)
{
try{
test_service.method1 (/**/);
} catch (SocketException& e)
{
}
}
return 0;
}
3、 服务发现方式:
{
SOAPProxy soap_service (7911, “localhost”);
vector <string> services_name = soap_service.getServiceNames ();
//
IService* test_service = soap_service.getService (“test_service”);
if (test_service)
{
vector <string> methods = test_service->getMethodNames ();
IMethod* method = test_service->getMethod (“method1”);
vector <Type*> types = method->getParameterType s()
method->addArg (3);
method->addArg (4);
//
method->invoke ();
//
}
return 0;
}
二、基本需求。
简单分析一下,上面一共涉及了哪些类型?
IProxy:
这是所有Proxy类的基类(和接口),它可以容纳多个服务对象,提供服务绑定、服务查询、服务发现、服务验证。
IService:
所有Service类的基类,可以容纳多个方法(Method),提供方法查询、服务验证。
IMethod:
所有Method模板类的基类,容纳多个参数,包括返回值,可通过查询参数类型获得方法的类型定义。
IParameter:
所有参数的基类,包含一个参数类型描述和一个参数值。
IType:
所有类型的基类,预定义了一些基本类型,可自定义类型。
看起来挺多的,其实很难接触到这些,只需要使用宏来定义一个服务,就可以通过模板的类型推导,自动生成这些复杂的定义。
三、调用过程。以下只简单分析一下同步调用,异步调用将是以后的扩充话题。
根据第二节的3种不同调用过程,简要描述如下:
- 直接调用。
- 生成SOAPProxy,让它连接到远程主机。
- 生成一个TestService对象,设置远程主机上的服务名称,并指定使用SOAPProxy,也即使用SOAP协议。
- 调用TestService::method1方法。根据method1的定义,把服务名称、方法名称、各个in参数等打包成一个“集合”,交给SOAPProxy处理。
- SOAPProxy把这个“集合”转换成SOAP消息,发送到远程主机,阻塞线程。
- 远程主机上的SOAPProxy对象收到数据,进行解析。当解析出一个服务调用时,把它交给TestService服务处理。
- TestService解析出一个方法调用,把它交给Method处理。
- Method解析出各个参数,验证参数类型、完整性等,并执行调用或返回错误。
- Method调用的返回信息(包括调用结果、返回值、out参数等)被打包成一个“集合”,交给TestService处理。
- TestService处理后,交给SOAPProxy。
- SOAPProxy把结果打包成SOAP消息,发回调用端。
- 调用端解析SOAP消息,把OUT参数值赋给调用者提供的对象,调用完成。
- 生成SOAPProxy,让它连接到远程主机。
- 服务验证方式。
- 生成SOAPProxy,让它连接到远程主机。
- 生成TestService对象,调用SOAPProxy的getService验证版本。
- SOAPProxy把TestService对象的信息(名称、成员及基类型等)发送到远程主机,阻塞。
- 远程主机解析收到的信息,查找服务名,并比较查找到的服务类型与解析得到的类型。
- 比较结果发回给调用端。
- 调用端接着采用直接调用的方式,调用远程服务。
这种方式看起来多了一些操作,不过验证的好处是能够减少调用时的异常。 - 生成SOAPProxy,让它连接到远程主机。
- 服务发现方式。
- 生成SOAPProxy,让它连接到远程主机。
- 查询远程开放的服务名称。(可省略)
- 查找特定服务,得到服务描述信息。
- 查找服务中的方法,得到方法描述信息。
- 压入各个参数,并执行调用。
- 调用前先判断参数是否与描述一致,然后调用SOAPProxy生成SOAP消息,发送到远程主机,阻塞。
- 远程主机解析出调用。。。后面过程与第1种方式相同,远程主机并不知道客户端使用的是哪种方式来调用。远程主机处理结束,将返回SOAP消息给调用端。
- 调用端解析出调用结果,并把各个OUT参数的值赋给method对象。
使用这种方式,调用端不需要服务的类型定义。 - 生成SOAPProxy,让它连接到远程主机。
四、异步调用/异步分派(AMI/AMD)。
同步调用时,调用端线程需要等待调用结果,服务端线程也要等待调用结束返回,才处理下一个调用。
为了在服务调用期间让线程能做更多的事:
调用端把调用交给线程池完成,并在调用完成后采用某种机制通知线程处理结果,或者直接由线程池中的调用线程调用结果处理函数。这种方式称为AMI(异步方法调用)。
服务端主线程则把接收到的消息解析后,放入处理队列,由线程池去处理调用过程。当调用完成后,结果放入结果队列,由主线程处理成消息,发送回调用端。这种方式称为AMD(异步方法分派)。
调用端和服务端依旧是使用通讯协议来沟通,双方都不知道对方是否采用了异步方式。
AMI和AMD对于静态定义的服务是有影响的,比如下面一个服务:
{
Method <void(in<int>, out<int>)> method1;
}
在同步调用时,它的调用方式:
int a;
service.method1 (3, a); // 或者 service.method1 (3, &a),打算兼容这2种方式。
异步调用时,调用方式:
TestService test_service;
test_service.method1.async_call(3, method1_result); // 调用完成后,让调用线程去调用method1_result通知调用结果。
// 或者像下面
IMethod* result = test_service.method1.async_call (3);
while (!result->done()) // 还有很多好办法,这里只是为了简单。
{
sleep (1);
}
cout << result->getArg(1)->toInt();
正如上面演示的一样,异步调用的结果有2种方式去处理。
一是由线程池调用完以后,接着调用一个函数以通知结果。它不需要轮询,不过涉及到了线程问题,增加了一些复杂性。
另一种方式调用结束后,原调用线程在某个适当的“时机”去查询调用结果。这个时机可以是定时查询,也可以是被线程消息通知而去处理。
五、其它。
这一篇加上前一篇,应该是提到了全部的要点。
目前剩下的唯一一个难点,可能是在处理异步调用时,Method的定义。
正如上面演示的,一个方法在同步调用和异步调用时,就有3种调用方式:
test_service.method1.async_call(3, method1_result);
IMethod* result = test_service.method1.async_call (3);
特别地,它如何根据in和个数和out的个数,产生那2个参数个数匹配的异步调用函数?
再来回顾一下method1的定义:
显然有一定的复杂性,不过我认为还是可以处理掉的。拿3个参数的偏特化版本来说明:
class Method <Out<Ret>(A,B,C)> : public MethodBase <Out<Ret>,A,B,C>
{
};
template <class Ret=NullType, class A=NullType, class B=NullType, class C=NullType, class D=NullType, IN_COUNT=InCount< A,B,C,D>::value >
class MethodBase
{
};
通过对MethodBase类的IN_COUNT参数定义偏特化,即可定义出这些不同的版本。
当然仅仅是知道了IN参数的个数,还没有提取出IN参数的类型,所以还不能生成函数的原型,或许需要把typelist加进来了(loki中的那个)。
这是后面要考虑的内容,今天先想到这。
发表评论
-
Cilk++,XL
2009-08-05 10:04 2704刚看到CSDN新闻:Intel获得Cilk++技术 多核处理器 ... -
关于内存管理的一点想法
2009-07-14 16:11 1774分布式轻量级线程框架(还没取名)最近几个修改: 1、消息对象采 ... -
增加了monitor_node功能
2009-07-13 14:57 1830给分布式框架增加了类似 erlang 的 monitor_no ... -
轻量级线程切换效率
2009-07-13 12:07 2468同事测试了libcoro,它的linux版本可以使用4种模式, ... -
Cache Pool 架构
2009-06-16 10:05 3259先比较一下Hadoop。 Hadoop 架构: Cach ... -
高可用性Cache池
2009-06-15 16:10 4362前段时间开发上线了一个Cache池,使用双层Cache池冗余, ... -
抛开析构函数
2007-08-15 22:19 3405内存管理通常指的是堆 ... -
C++程序设计
2007-03-25 13:37 104上周在修改扩充同事的代码,发现几个问题。 1、访问级别几乎全 ... -
突发奇想续
2006-12-13 09:50 1960简单写了点代码,把那个方程组生成树结构: #include ... -
为C++实现一个IDL (零)
2005-09-15 01:27 4697一、问题。这段时间考虑实现一个纯C++的分布式服务包装库 ... -
正式建立asgard项目 (因ancients已经被人使用了)
2005-09-20 10:30 1893“为C++实现一个IDL” ... -
为C++实现一个IDL (二)
2005-09-20 22:34 2418说明:要看懂后面那部分代码,即使用Typelist的部分 ... -
为C++实现一个IDL (三)
2005-09-21 20:34 2720一、修正错误。首先修正第二篇中的一些错误,错误的内容可见 ... -
为C++实现一个IDL (四)
2005-09-22 19:13 2042如《为C++实现一个IDL(三)》一文中所说,还剩最后一 ... -
asgard项目遗留问题 (2005-09-27更新)
2005-09-24 17:00 1808asgard项目已经准备了 ... -
C++实现简单的类型库
2005-09-26 17:31 2998很久以前看到有人问“如何在C++中实现动态加载类”时,简 ... -
为C++实现一个IDL (五)
2005-09-28 22:57 2067本篇没什么清晰的目的,只是解释一下前面的几个问题,并提出 ... -
自己写的一个max函数
2005-12-12 10:45 1924CSDN上看到有人问能否实现一个效率较高的max函数,效 ... -
C++之AOP
2005-12-15 15:43 5759AOP是近年炒得很热,但却用得很少的一门技术,不过这并不 ... -
[C++之AOP]实战Aspect C++之检查内存泄漏
2005-12-16 22:38 2733前面简单介绍了Aspect C++,相信没人看出它有什么 ...
相关推荐
C++ 11映射试图避免限制ORB开发人员的实现自由。对于每个OMG IDL构造,C++ 11映射解释使用C++ 11的构造的语法和语义。如果客户机或服务器程序使用C++ 11映射子句中所描述的结构,则符合此映射(是C++ 11)。
本书向读者提供了IDL的详细描述及如何使用IDL方面的知识,基于示例、由浅入深地阐述了各种IDL...第二部分的4个章节则提供了一个IDL类型、修饰符、关键字及属性的参考。 本书适合使用COM、微软事务服务器(MTS)、C++或
Creating a Template Interface in IDL with its Template Implementation in C++用IDL创建一个模板接口并用C++实现模板(6KB)
使用vs2008简单编写了一个com组件dll,后用vs2008分别用4中方法进行调用,方法详解在http://blog.csdn.net/angellove156/article/details/25633421
IDL精髓详细描述如何使用IDL方面的知识 实例由C++和VB实现
31.zip Creating a Template Interface in IDL with its Template Implementation in C++ 用IDL创建一个模板接口并用C++实现模板(6KB)<END><br>32,32.zip Building a World Class Application with MFC and...
该库也实现了一个不需要IDL的rpc,使用几个宏,很方便的自动完成函数参数的序列化,比MFC的MessageMap?还要方便。 使用时请checkout最新版,下载的那个版本比较旧了 @see ...
6.3.1 创建一个进程内自动化组件工程 6.3.2 分析新建工程文件 6.3.3 添加COM对象类 6.3.4 为接口添加属性 6.3.5 为接口添加方法 6.3.6 创建并测试组件 6.4 探讨MFC实现COM的内幕 6.4.1 MFC COM对象的实现 6.4.2 MFC ...
介绍RCP的实现原理 目录 1. 前言 2 2. 基本概念 3 2.1. IDL 3 2.2. 代理(Proxy) 3 2.3. 存根(Stub) 4 3. 三要素 4 3.1. 网络通讯 4 3.2. 消息编解码 5 3.3. IDL编译器 5 4. flex和bison 5 4.1. 准备概念 5 ...
更准确地说,它实现webgpu.h了与 WebGPU IDL 的一对一映射。Dawn 旨在作为更大系统的一部分集成,并且是 Chromium 中 WebGPU 的底层实现。 Dawn 提供了几个 WebGPU 构建块: 应用程序和其他构建块使用的 WebGPU C/...
该工程是Tars RPC框架C++语言的源代码 , C++语言框架rpc的源码实现,C++语言框架IDL工具的源码实现 。
1.1 创建一个类型为win32 dll工程 1.2 定义接口文件 1.3 增加注册功能 1.3.1 增加一个MathCOM.def文件 1.3.2 DllRegisterServer()和DllUnregisterServer() 1.4 MathCOM.cpp文件 1.5 小结 2. 实现ISmipleMath,...
C++源程序可以在Visual C++ 6.0里编写,也可以在记事本里编写,而同一个C++源程序可以用Visual C++ 6.0编译、执行,也可以用C++ Builder 5.0编译、执行,所以: C++ 不等于 Visual C++ 6.0 。 第二阶段:掌握一种...
最近在工作中遇到一个问题,为了跨平台在.net core中使用COM,不能使用Windows下的COM注册机制,但是可以直接把IUnknown指针传给C#,转换为指针,再转换为C#的接口(interface)。 做了这方面的研究,但最终我没有...
Thrift通过一个中间语言(IDL, 接口定义语言)来定义RPC的接口和数据类型,然后通过一个编译器生成不同语言的代码(目前支持C++,Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, Smalltalk和OCaml),并由...
但由于C++本身没有成熟的反射技术,对此进行了深入研究并提出一种实现方法。首先论述了反射机制的作用;然后描述了ATL动态链接库实现反射机制的基本原理,完善了ATL IDL文件接口标识符定义,利用前绑定或后绑定技术...
omniORB是CORBA(公用对象代理体系架构)的一种开发库,主要适用C++和python。CORBA 实现了异构系统的异种语言软体合并、协作。 CORBA的大体实现方式:使用IDL实现与其它编程语言的映射;客户端与服务端使用GIOP (主要...
2.1 C++实现接口的方式,使用抽象类 定义接口. 2.2 基于抽象类,派生出子类并实现 功能. 2.3 使用 interface 定义接口 interface ClassA { }; 目前VC中,interface其实就是struct 3 接口的动态导出 3.1 ...
IDL使得所有CORBA对象以一种方式被描述,仅仅需要一个由本地语言(C/C++、CORBA、Java)到IDL的“桥梁”。CORBA对象的互通信要以对象请求解析器(Object Request Broker)为中介,这种互通可以在多种流行通信协议之...
所谓基于COM的回调虚接口实现ActiveX控件和客户端程序的通讯,大致是这样的,就是在ActiveX工程的内部的idl文件定义一个虚接口,在客户端程序定义一个虚接口的派生类来实现回调函数,在客户端程序传递派生类对象指针...