ICE的Glacier2使用

末蓝、 2022-08-14 00:47 276阅读 0赞

1、使用Glacier2的步骤：  
 A、编写一个Glacier2的配置文件，参见样例  
 B、设置Glacier2的访问鉴权（密码或者证书），passwords文件每行样例"test xxMqsnnDcK8tw" 可以通过openssl的passwd命令创建密码  
 C、定制Glacier2的session管理对象   
 D、启动Glacier2，glacier2router --Ice.Config=config  
 E、修改客户端的配置使用router  
 F、获取Glacier2.router并创建session  
 G、附加线程保持session的激活状态  
  
2、Glacire2的配置样例：  
 Glacier2.InstanceName=MyRouter  
 Glacier2.Client.Endpoints=tcp -h 5.6.7.8 -p 4063  
 Glacier2.Client.PublishedEndpoints=tcp -h 5.6.7.8 -p 4064  
 Glacier2.Server.Endpoints=default  
 Glacier2.SessionManager=MySessionManager:tcp -h 127.0.0.1 -p 10001  
 Glacier2.PermissionsVerifier=MySessionVerifier:tcp -h 127.0.0.1 -p 10002  
 Glacier2.SSLPermissionsVerifier=MySSLSessionVerifier:tcp -h 127.0.0.1 -p 10003  
 Glacier2.SessionTimeout=60  
 Glacier2.SessionManager.LocatorCacheTimeout=30  
 Glacier2.SSLSessionManager.LocatorCacheTimeout=30  
 Glacier2.CryptPasswords=passwords  
 Glacier2.AddConnectionContext=1  
 Glacier2.Client.ForwardContext=1  
 Glacier2.Server.ForwardContext=1  
 Glacier2.Trace.Session=1  
 Glacier2.Client.Trace.Request=1  
 Glacier2.Filter.Address.Accept=10.0.1.\[5,6\]:\[10000-11000\]  
 Glacier2.Filter.Address.Reject=10.0.1.\[5,6\]:\[10500,10501\]  
 Glacier2.Filter.Category.Accept=cat1 cat2  
 Glacier2.Filter.Identity.Accept=id1 id2  
 Glacier2.Filter.AdapterId.Accept=Adapter1 Adapter2  
 Glacier2.RoutingTable.MaxSize=10000  
 Glacier2.Filter.ProxySizeMax=10000  
  
3、客户端使用Glacier2  
 A、配置默认router：Ice.Default.Router=MyRouter/router:tcp -h 5.6.7.8 -p 4063  
 B、关闭ACM，Ice.ACM.Client=0 Ice.RetryIntervals=-1  
 C、创建Session  
 Ice::RouterPrx defaultRouter = communicator->getDefaultRouter();  
 Glacier2::RouterPrx router = Glacier2::RouterPrx::checkedCast(defaultRouter);  
 Glacier2::SessionPrx session = router->createSession(username, password); //创建基于密码方式的session  
 Glacier2::SessionPrx sslSession = router->createSessionFromSecureConnection(); // 基于ssl的证书方式创建session  
 D、创建额外的线程，在线程中隔段时间调用router->refreshSession()来确保session的存活  
 也可以通过调用session对象的ice\_ping()方法来刷新session的过期时间  
 E、为了能够让服务器端使用回调，客户端试图传递一个回调的代理对象CallBackPrx给服务器端，让服务器端在合适的时机来进行回调  
 首先需要有一个adapter，其router已经设置，可动态创建createObjectAdapterWithRouter，也可静态配置  
 CallbackAdapter.Router=Glacier2/router:tcp -h 5.6.7.8 -p 4063  
 F、在该adapter上增加CallBack对象，返回CallBackPrx对象，可以通过各种方式传递给服务器端  
 G、如果在客户端会存在一个嵌套的调用，即客户端在处理请求的同时需要处理回调，注意一定要增加客户端的线程数Client.ThreadPool.Size  
 H、有时客户端为了简化代码逻辑处理，可以使用Glacier2::Application类来编程程序，其自动获取router代理和管理session  
 class Application : public Ice::Application   
 \{   
 public:  
 Application();  
 Application(Ice::SignalPolicy policy);  
 virtual int runWithSession(int argc, char\* argv\[\]) = 0; // 成功返回0，非0表示失败  
 virtual Glacier2::SessionPrx createSession() = 0; // 创建session对象  
 virtual void sessionDestroyed(); // 释放session  
 static Glacier2::RouterPrx router(); // 获取router代理  
 static Glacier2::SessionPrx session(); // 获取创建好的session代理  
 void restart();   
 std::string categoryForClient(); // 获取session的分类  
 Ice::Identity createCallbackIdentity(const std::string& name); // 获取一个回调对象的ID  
 Ice::ObjectPrx addWithUUID(const Ice::ObjectPtr& servant); // 加入一个回调处理对象，返回回调代理  
 Ice::ObjectAdapterPtr objectAdapter(); // 获取用于回调的adapter  
 \};  
  
4、服务器端使用Glacier2  
 A、实现Glacier2的session管理  
 class MySessionManagerI : public Glacier2::SessionManager  
 \{   
 public:  
 virtual ::Glacier2::SessionPrx create(const std::string& User, const ::Glacier2::SessionControlPrx&, const ::Ice::Current& current);  
 \};  
 class MySSLSessionManagerI : public Glacier2::SSLSessionManager  
 \{   
 public:  
 virtual ::Glacier2::SessionPrx create(const ::Glacier2::SSLInfo&, const ::Glacier2::SessionControlPrx&, const ::Ice::Current& current);   
 \};  
 B、注意在上述session管理对象的create方法中，必须返回一个Session的代理对象，该session的代理对象必须要包含对应的router属性  
 可以通过current.adapter->addWithUUID(new MySession);获得  
 C、实现Session对象接口  
 class MySession : public ::Glacier2::Session  
 \{   
 public:  
 virtual void destory();  
 \};  
 D、实现Glacier2的鉴权接口，当然你也可以使用ssl的鉴权方式  
 class MySessionVerifier : public Glacier2::PermissionsVerifier  
 \{   
 public:  
 bool checkPermissions(string userId, string password, out string reason);  
 \};  
 class MySSLSessionVerifier : public Glacier2::SSLPermissionsVerifier  
 \{   
 public:  
 bool authorize(SSLInfo info, out string reason);  
 \}  
 E、可以在SessionManager的create方法中通过SessionControlPrx对象动态的设置session的访问过滤  
 interface SessionControl \{   
 StringSet\* categories();  
 StringSet\* adapterIds();  
 IdentitySet\* identities();  
 void destroy();