Ice笔记---异步程序设计demo

最近学习了异步通信这一章：异步包括服务端的异步分派（AMD）以及客户端的异步调用（AMI）。

下面介绍一下如何实现简单的异步通信（主要实现了客户端的异步调用，AMD暂未体现）：

1.首先编写Ice文件:Demo.ice

[cpp] view plaincopy

module Demo{
interface Employee{
["amd"]void add(int a, int b, out int sum);
};
};

["amd"]表示的是元数据，指定服务器端将提供异步分派的方法函数。该add函数中有两个in参数；一个out参数，作为回传参数。

2.映射到C++代码：使用命令 slice2cpp Demo.ice

经过映射之后，程序将生成Demo.h与Demo.cpp文件，如下面部分代码所示Demo.h

[cpp] view plaincopy

// ....More code before
namespace Demo
{
class Employee : virtual public ::Ice::Object
{
public:
typedef EmployeePrx ProxyType;
typedef EmployeePtr PointerType;
virtual ::Ice::ObjectPtr ice_clone() const;
virtual bool ice_isA(const ::std::string&, const ::Ice::Current& = ::Ice::Current()) const;
virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& = ::Ice::Current()) const;
virtual const ::std::string& ice_id(const ::Ice::Current& = ::Ice::Current()) const;
static const ::std::string& ice_staticId();
virtual void add_async(const ::Demo::AMD_Employee_addPtr&, ::Ice::Int, ::Ice::Int, const ::Ice::Current& = ::Ice::Current()) = 0;
// ... More code here
};
// ...

3. 实现服务端程序

新建Server.cpp文件，将Demo.h中的虚方法add_async()实现。并新建servant类来继承Ice::application类,初始化Ice run time ,同时将servant注册到对象适配器中去。

[cpp] view plaincopy

#include <Demo.h>
#include <Ice/Application.h>
#include <IceUtil/Monitor.h>
#include <iostream>
using namespace std;
using namespace Demo;
class Manager : virtual public Employee,public IceUtil::Monitor<IceUtil::Mutex>
{
public:
Manager():_sum(0){}
~Manager(){}
virtual void add_async(const ::Demo::AMD_Employee_addPtr& add_ptr, int a, int b, const ::Ice::Current& =::Ice::Current())
{
_sum = a+b;
sleep(1);
cout<< "The sum is " <<_sum<<"."<<endl;
add_ptr->ice_response(_sum); //数据处理完之后，回调函数，调用客户端实现的方法
}
private:
int _sum;
};
class myApplication : virtual public Ice::Application
{
public:
virtual int run(int argc , char* argv[])
{
Ice::ObjectAdapterPtr adapter =
communicator()->createObjectAdapterWithEndpoints("GameServer", "default -p 10000");
Ice::ObjectPtr Manptr = new Manager;
adapter->add(Manptr, communicator()->stringToIdentity("ManServer"));//将servant类对象指针ManPtr注册到适配器中
adapter->activate(); //激活适配器，使客户端能够访问适配器中已添加的servant活动表
communicator()->waitForShutdown();
}
};
int main(int argc , char * argv[])
{
myApplication app;
app.main(argc , argv);
return 0;
}

4.实现客户端程序

新建Client.cpp文件，实现回调函数，创建访问指定servant的代理。

[cpp] view plaincopy

#include<Ice/Ice.h>
#include<Demo.h>
#include<iostream>
#include<IceUtil/IceUtil.h>using namespace std;
using namespace Demo;class Client_add:public AMD_Employee_add
{
public:
virtual void ice_response(int sum)
{
cout << "receive from server--The sum is "<<sum<<"."<<endl;
}
virtual void ice_exception(){}
virtual void ice_exception(const std::exception& e){}
void failed_operation(const Ice::Exception &e){}
};
typedef IceUtil::Handle<Client_add> ClientAddPtr;class ClientApp : virtual public Ice::Application
{
public:
virtual int run(int argc , char* argv[])
{
Ice::ObjectPrx base = communicator()->stringToProxy("ManServer:default -p 10000"); EmployeePrx emp = EmployeePrx::checkedCast(base); if(!emp)throw "Invalid Proxy!"; ClientAddPtr amd_add = new Client_add;
Callback_Employee_addPtr addPtr=newCallback_Employee_add(amd_add,&Client_add::ice_response,&Client_add::failed_operation); //实现回调对象指针
emp->begin_add(10,20,addPtr); //第三个参数为回调类的智能指针 cout<<"I'm waiting for the data from,but not blocked."<<endl; }
};int main(int argc , char* argv[])
{
ClientApp app;
app.main(argc , argv); return 0;
}

5. 编译Server.cpp: g++ Demo.cpp Server.cpp -o Server -lIce -lIceUtil -I./ -I/opt/Ice-3.4.2/include -L/opt/Ice-3.4.2/lib

编译Client.cpp: g++ Demo.cpp Client.cpp -o Client -lIce -lIceUtil -I./ -I/opt/Ice-3.4.2/include -L/opt/Ice-3.4.2/lib

运行服务端:./Server 运行客户端：./Client

Ice笔记---异步程序设计demo相关推荐

Vue异步组件Demo
Vue异步组件Demo 在大型应用中,我们可能需要将应用拆分为多个小模块,按需从服务器下载.为了进一步简化,Vue.js 允许将组件定义为一个工厂函数,异步地解析组件的定义.Vue.js 只在组件需要 ...
go-pitaya学习笔记(9)-rate_limiting demo分析
学习笔记: 我家别墅靠大海/pitaya-learn 尝试集成功能:我家别墅靠大海/pitaya-game 如果你正在看此笔记,请你左边放笔记,右边放chatdemo的代码!! 我是按代码的顺序记的笔 ...
go-pitaya学习笔记(6)-cluster-protobuf demo分析
学习笔记: 我家别墅靠大海/pitaya-learn 尝试集成功能:我家别墅靠大海/pitaya-game 如果你正在看此笔记,请你左边放笔记,右边放chatdemo的代码!! 我是按代码的顺序记的笔 ...
go-pitaya学习笔记(7)-custom_metrics demo分析
学习笔记: 我家别墅靠大海/pitaya-learn 尝试集成功能:我家别墅靠大海/pitaya-game 如果你正在看此笔记,请你左边放笔记,右边放chatdemo的代码!! 我是按代码的顺序记的笔 ...
JavaScript 学习笔记 - 挂载事件 Demo
JavaScript 学习笔记 - 挂载事件 Demo 例子 addEventListener 监听事件挂载事件的同时带上参数 dispatchEvent 触发事件 removeEventListe ...
motan学习笔记三 motan Demo 分析
motan学习笔记一微博轻量级RPC框架Motan motan学习笔记二 motan架构分析 motan学习笔记三 motan Demo 分析 motan学习笔记四 motan Demo 之 ...
ZeroC ICE java异步实现方式（ami/amd）
首先说说ami 和amd 的区别(以下为个人见解,仅供参考.如有疑问欢迎提出来) ami (异步方法调用): 仅仅基于ice 的同步方式扩展了异步的扩展方式,其他理念改动不大,使用起来好理解,但是服务 ...
dubbo入门学习笔记之入门demo(基于普通maven项目)
注:本笔记接dubbo入门学习笔记之环境准备继续记录; (四)开发服务提供者和消费者并让他们在启动时分别向注册中心注册和订阅服务需求:订单服务中初始化订单功能需要调用用户服务的获取用户信息的接口(订 ...
ajax异步查询demo,ASP.NET中AJAX的异步加载（Demo演示）
此次的demo是一个页面,页面上有两行字,然后后面用ajax,使用一个下拉框去替换第一行文字[/code] 第一个是被替换的网页 var xmlhttprequest; function create ...

Ice笔记---异步程序设计demo

Ice笔记---异步程序设计demo相关推荐

最新文章

热门文章