ICE系列培训(二).ppt

3. 4 示例 服务端声明文件代码： #include Hello.h #include WorkQueue.h class HelloI : virtual public Demo::Hello { public: HelloI(const WorkQueuePtr); // 分派函数 virtual void sayHello_async(const Demo::AMD_Hello_sayHelloPtr, int, const Ice::Current); virtual void shutdown(const Ice::Current); private: WorkQueuePtr _workQueue; }; 3. 4 示例 服务端实现文件代码： HelloI::HelloI(const WorkQueuePtr workQueue) : _workQueue(workQueue) { } void HelloI::sayHello_async( const Demo::AMD_Hello_sayHelloPtr cb, int delay, const Ice::Current) { if(delay == 0) { cout Hello World! endl; cb-ice_response(); } else { _workQueue-add(cb, delay); } } void HelloI::shutdown(const Ice::Current curr) { cout Shutting down... endl; _workQueue-destroy(); curr.adapter-getCommunicator()-shutdown(); } 3. 4 示例 服务端实现文件代码： int AsyncServer::run(int argc, char* argv[]) { if(argc 1) { cerr appName() : too many arguments endl; return EXIT_FAILURE; } callbackOnInterrupt(); Ice::ObjectAdapterPtr adapter = communicator()-createObjectAdapter(Hello); _workQueue = new WorkQueue(); Demo::HelloPtr hello = new HelloI(_workQueue); //定义服务端servrant adapter-add(hello, communicator()-stringToIdentity(“hello”)); // 将serverant加入适配器 // 启动工作队列 _workQueue-start(); adapter-activate(); // communicator()-waitForShutdown(); _workQueue-getThreadControl().join();//等待工作队列停止 return EXIT_SUCCESS; } 3. 4 示例 服务端实现文件代码： class WorkQueue : public IceUtil::Thread { public: WorkQueue(); virtual void run(); // 将回调对象加入队列 void add(const Demo::AMD_Hello_sayHelloPtr, int); void destroy(); private: //存储回调对象以及调用参数的的结构体 struct CallbackEntry { Demo::AMD_Hello_sayHelloPtr cb; int delay; }; IceUtil::MonitorIceUtil::Mutex _monitor; std::listCallbackEntry _callbacks; bool _done; }; typedef IceUtil::HandleWorkQueue WorkQueuePtr; 3. 4 示例 服务端实现文件代码：