《编写服务端程序》PPT课件.ppt

第五章编写服务端程序,Agenda,对象适配器可移植对象适配器设计POA策略使用POA活动对象映射表伺服对象管理器,对象适配器,作用：管理服务器端伺服对象，对象标识，CORBA对象以及它们之间关联的主要工具是对象适配器决定在收到一个客户请求时应调用哪一个伺服对象，然后调用该伺服对象上的合适操作POA的可移植性指建立在POA基础上的服务端程序不依赖于特定的ORB产品，从而在不同ORB产品之间是可移植的,可移植对象适配器,POA是对象实现与ORB其他组件之间的中介，它将客户请求传送到伺服对象，按需创建子POA，提供管理伺服对象的策略。对CORBA对象发出的所有调用请求都必须经过POA，即使目标对象是本地的（即伺服对象与客户程序处于同一地址空间），这样POA能够统一地应用POA策略,CORBA对象与伺服对象,CORBA对象与具体的伺服对象是两个不同抽象层次的概念：它们之间的彻底分离使得CORBA独立于任何特定程序设计语言，并为服务端程序的可移植性打下基础。对象适配器（objectadapter）是一个重要的ORB组件，它负责将抽象的CORBA对象映射到具体的伺服对象。CORBA对象可看作是一个具有对象标识、对象接口及对象实现的抽象实体。之所以称为抽象的，是因为并没有硬性规定CORBA对象的实现机制。由于独立于程序设计语言和特定ORB产品，一个CORBA对象的引用又称可互操作的对象引用（InteroperableObjectReference）。从客户程序的角度看，IOR中包含了对象的标识、接口类型及其他信息以查找对象实现。,CORBA对象与伺服对象,伺服对象（servant）是指具体程序设计语言的对象或实体，通常存在于一个服务程序进程之中。客户程序通过对象引用发出的请求经过ORB担当中介角色，转换为对特定的伺服对象的调用。在一个CORBA对象的生命期中，它可能与多个伺服对象相关联，因而对该对象的请求可能被发送到不同的伺服对象。对象标识（ObjectID）是一个用于在POA中标识一个CORBA对象的字符串。它既可由程序员指派，也可由对象适配器自动分配，这两种方式都要求对象标识在创建它的对象适配器中必须具有唯一性。,CORBA对象与伺服对象,伺服对象通过对象标识关联到CORBA对象。建立一个伺服对象与一个CORBA对象之间关联的过程称为“激活”（activate）或“体现”（incarnate），反之，撤销这种关联的过程称为“冻结”（deactivate）或“净化”（etherealize）。经过激活或体现后，CORBA对象、伺服对象以及对象标识均可称为活动的（active），否则称它们为非活动的（inactive）。不是简单的new持久对象（persistentobject）可在创建它的服务程序进程之外存在，瞬时对象（transientobject）只能在创建它的服务程序进程中存在。它们都是指一个CORBA对象。,Corba对象伺服对象ID,POA体系结构,POA体系结构,可移植对象适配器,客户请求的传递过程客户程序发出的请求中包含:创建对象引用的POA名字、对象标识及目标机器与端口等信息。如果目标POA不存在，ORB还允许调用适配器激活器创建所需的POA。,一旦请求被ORB传送到正确的机器与端口，监听该端口的POA管理器负责检查对象关键码（objectkey），对象关键码中含有POA名字与对象标识；POA管理器利用对象关键码将请求传送给正确的POA,POA利用对象关键码确定对象标识，根据POA的策略集直接或间接地利用对象标识将请求传送到正确的伺服对象。,客户请求的传递,客户程序,POA管理器正在监听的端口号,ORB,1.客户程序向ORB发出请求,对象定位信息,请求内容,目标机器、端口,对象关键码,ORB,2.ORB根据其中的目标机器和端口信息将请求发送到指定端口,目标机器、端口,对象关键码,客户请求的传递,POA名字,对象标识,name1POA,3.POA管理器根据请求中的POA名字将请求发送到特定的POA,请求内容,name2POA,POA管理器管理多个POA,.,POA名字,伺服对象1,伺服对象2,伺服对象3,对象标识,请求内容,4.POA根据对象标识将请求传到正确的伺服对象,POA接口,/POA接口interfacePOA/POA属性readonlyattributestringthe_name;readonlyattributePOAthe_parent;readonlyattributePOAListthe_children;readonlyattributePOAManagerthe_POAManager;attributeAdapterActivatorthe_activator;/异常定义exceptionAdapterAlreadyExists;exceptionAdapterNonExistent;exceptionInvalidPolicyunsignedshortindex;exceptionNoServant;exceptionObjectAlreadyActive;exceptionObjectNotActive;exceptionServantAlreadyActive;exceptionServantNotActive;exceptionWrongAdapter;exceptionWrongPolicy;,POA接口,POA接口,/创建与撤销POAPOAcreate_POA(instringadapter_name,inPOAManagera_POAManager,inCORBA:PolicyListpolicies)raises(AdapterAlreadyExists,InvalidPolicy);POAfind_POA(instringadapter_name,inbooleanactivate_it)raises(AdapterNonExistent);voiddestroy(inbooleanetherealize_objects,inbooleanwait_for_completion);/用于创建策略对象的factory操作ThreadPolicycreate_thread_policy(inThreadPolicyValuevalue);LifespanPolicycreate_lifespan_policy(inLifespanPolicyValuevalue);/.,POA接口,POA接口,/伺服对象管理器的注册ServantManagerget_servant_manager()raises(WrongPolicy);voidset_servant_manager(inServantManagerimgr)raises(WrongPolicy);/为USE_DEFAULT_SERVANT策略提供的操作Servantget_servant()raises(NoServant,WrongPolicy);voidset_servant(inServantp_servant)raises(WrongPolicy);/对象激活与冻结ObjectIdactivate_object(inServantp_servant)raises(ServantAlreadyActive,WrongPolicy);voidactivate_object_with_id(inObjectIdid,inServantp_servant)raises(ServantAlreadyActive,ObjectAlreadyActive,WrongPolicy);voiddeactivate_object(inObjectIdoid)raises(ObjectNotActive,WrongPolicy);,POA接口,POA接口,/创建CORBA对象引用的操作Objectcreate_reference(inCORBA:RepositoryIdintf)raises(WrongPolicy);Objectcreate_reference_with_id(inObjectIdoid,inCORBA:RepositoryIdintf)raises(WrongPolicy);/对象标识映射操作ObjectIdservant_to_id(inServantp_servant)raises(ServantNotActive,WrongPolicy);Objectservant_to_reference(inServantp_servant)raises(ServantNotActive,WrongPolicy);Servantreference_to_servant(inObjectreference)raises(ObjectNotActive,WrongAdapter,WrongPolicy);ObjectIdreference_to_id(inObjectreference)raises(WrongAdapter,WrongPolicy);Servantid_to_servant(inObjectIdoid)raises(ObjectNotActive,WrongPolicy);Objectid_to_reference(inObjectIdoid)raises(ObjectNotActive,WrongPolicy);,POA接口,为什么要有多个POA，如果只有一个的话，也不需要什么管理器了,POA层次一个服务程序进程中可使用多个POA，不同POA以名字区分。这些POA的集合呈现一种层次结构，即每个POA都有一个父POA，所有POA都是根POA的后代。每个ORB在创建时都自动带有一个根POA，可根据需要从根POA创建其他子POA。POA层次为服务程序中的对象标识提供了一个层次化的名字空间。通常每个伺服对象最多仅与一个POA相关联，POA“拥有（包括POA策略）”这些对象并负责删除这些对象，当POA被删除时其中的所有对象以及子POA也将被删除。,POA管理器POA管理器（POAManager）是一个对象，它将一个或多个POA组织在一起，为其中的POA提供共同的操作，POA管理器的状态代表了它所管理的所有POA的状态。例如开发人员可通过POA管理器提供的操作决定是否接收或丢弃POA的请求，也可利用POA管理器终止POA。,活动对象映射表每一个POA中都有一个活动对象映射表（ActiveObjectMap），表中保存了活动对象的对象标识及与之关联的伺服对象，其作用是将活动对象通过对象标识映射到伺服对象。在一个特定的POA中，对象标识唯一地标识了一个CORBA对象。为将伺服对象转换为一个可供远程调用的CORBA对象，必须建立CORBA对象与伺服对象之间的关联。此外，POA还允许单个伺服对象（即缺省伺服对象）同时与多个CORBA对象相关联，这种特性对开发大规模应用意义重大。,伺服对象管理器伺服对象管理器（servantmanager）是程序员自己提供的代码，用于取代POA活动对象映射表的功能。如果应用程序需要以一种更复杂的方案将对象标识映射到伺服对象，这时开发人员可设计专用的伺服对象管理器。伺服对象管理器负责决定一个CORBA对象是否存在，然后查找伺服对象并将伺服对象指派给CORBA对象。为满足不同的应用需要，开发人员可设计多个伺服对象管理器。有两类伺服对象管理器可供选择：伺服对象激活器和伺服对象定位器，开发人员可利用POA策略决定选用哪一种类型。,什么是POA策略?,POA策略是一个对象，负责控制相关POA的行为及这些POA所管理的对象，使用POA前应仔细考虑应用程序所需的策略集。POA策略可为不同的应用程序设计目标而配置不同的POA。目前CORBA规范定义了7种标准的POA策略，不同的ORB产品从可伸缩性或可靠性等因素考虑引入一些新的POA策略。,选用POA策略,选用POA策略时应注意某些策略值之间存在依赖关系（选用了一种，隐含的选用另一种）。线程策略该策略指定POA使用的线程模型，它有两种取值：ORB_CTRL_MODEL（缺省值）：表示由ORB负责将对POA的请求指派到线程。在多线程环境中，并发请求可以用多线程传送。SINGLE_THREAD_MODEL：这时只有一个线程，POA顺序地处理请求。,选用POA策略,生命期策略该策略指定POA中对象实现的使用期限，它可有以下值：TRANSIENT（缺省值）：由POA创建的对象引用是瞬时的，这些对象在创建它的POA之外不可存在。一旦POA被冻结为非活动状态，调用该POA创建的任何对象引用将引发OBJECT_NOT_EXIST异常。对话型对象通常设计为瞬时对象。PERSISTENT：由POA创建的持久对象可在创建它的POA之外存在，因而使用这一策略通常还会同时采用USER_ID策略。对持久对象的请求可能导致隐式地激活一个进程、一个POA以及实现该对象的伺服对象，这意味着POA应注册伺服对象定位器或激活器。实体型对象通常设计为持久对象。,选用POA策略,对象标识唯一性策略该策略允许多个抽象对象共享一个伺服对象，它可取下列值：UNIQUE_ID（缺省值）：被激活的伺服对象仅支持一个对象标识，POA不允许一个伺服对象与多个CORBA对象相关联。MULTIPLE_ID：被激活的伺服对象可以有一个或多个对象标识，在运行时刻调用伺服对象的操作时必须由操作内部决定对象标识。应指出的是，对象标识在特定的POA中总是唯一的，对象标识唯一性策略指的是对象标识与伺服对象之间关联的唯一性或多重性。,选用POA策略,对象标识指派策略该策略指定对象标识是由程序员编写的服务程序生成还是由POA自动生成，它可取以下值：USER_ID：由应用程序为POA的对象引用指定对象标识。SYSTEM_ID（缺省值）：由POA为它的对象引用分配对象标识。如果同时还采用了PERSISTENT策略，则在同一POA的所有实例中对象标识必须是唯一的。典型情况将是USER_ID策略用于持久对象，将SYSTEM_ID策略用于瞬时对象。如果想将SYSTEM_ID策略用于持久对象，可从伺服对象或对象引用中提取对象标识。,选用POA策略,伺服对象保持策略该策略指定POA是否将活动伺服对象保存在活动对象映射表中，它有两种取值：RETAIN（缺省值）：POA利用活动对象映射表跟踪对象的激活情况，通常与伺服对象激活器或POA显式激活方式结合使用。NON_RETAIN：POA不在活动对象映射表中保存活动的伺服对象，通常结合伺服对象定位器一起使用。该策略决定POA是否利用活动对象映射表跟踪对象标识与伺服对象之间的关联。如果选择NON_RETAIN策略则意味着不使用活动对象映射表，因而使用该策略的应用程序必须提供一个伺服对象定位器类型的伺服对象管理器。,选用POA策略,请求处理策略该策略指定POA如何处理请求，它有三种取值：USE_ACTIVE_OBJECT_MAP_ONLY（缺省值）：POA仅依赖于活动对象映射表决定哪些对象标识可用及对象标识关联到哪些伺服对象。如果在活动对象映射表中找不到对象标识，则引发OBJECT_NOT_EXIST异常。该值必须结合RETAIN策略使用。USE_DEFAULT_SERVANT：如果POA在活动对象映射表中找不到对象标识，或已设置NON_RETAIN策略，则将请求分派给一个缺省伺服对象。缺省伺服对象必须先注册，如果未注册则引发OBJ_ADAPTER异常。该值必须结合MULTIPLE_ID策略使用。USE_SERVANT_MANAGER：如果POA在活动对象映射表中找不到对象标识，或已设置了NON_RETAIN策略，则POA使用一个伺服对象管理器激活或定位伺服对象。,选用POA策略,隐式激活策略该策略指定POA是否支持伺服对象的隐式激活，它可取以下值：IMPLICIT_ACTIVATION：POA支持隐式激活，服务程序可调用servant_to_reference操作或servant_to_id操作将伺服对象添加到活动对象映射表并转换为对象引用，也可调用伺服对象的_this方法激活伺服对象。该值要求同时使用SYSTEM_ID和RETAIN策略。NO_IMPLICIT_ACTIVATION（缺省值）：POA不支持伺服对象的隐式激活，只有通过显式的调用才可将伺服对象与一个对象标识相关联。,POA管理器与适配器激活器接口,POA管理器与适配器激活器接口,/POA管理器接口interfacePOAManagerexceptionAdapterInactive;enumStateHOLDING,ACTIVE,DISCARDING,INACTIVE;voidactivate()raises(AdapterInactive);voidhold_requests(inbooleanwait_for_completion)raises(AdapterInactive);voiddiscard_requests(inbooleanwait_for_completion)raises(AdapterInactive);voiddeactivate(inbooleanetherealize_objects,inbooleanwait_for_completion)raises(AdapterInactive);Stateget_state();/适配器激活器接口interfaceAdapterActivatorbooleanunknown_adapter(inPOAparent,instringname);,使用POA,调用ORB伪对象的resolve_initial_references()操作获取根POA的对象引用利用根POA提供的操作定义应用程序所需的POA策略集用自定义POA策略集在根POA下创建一个子POA甚至一个完整的POA层次激活POA管理器，通常整个服务程序只需使用一个POA管理器创建或激活对象引用,使用POA,publicclassServerpublicstaticvoidmain(Stringargs)tryorg.omg.CORBA.ORBorb=org.omg.CORBA.ORB.init(args,null);POArootPOA=POAHelper.narrow(orb.resolve_initial_references(RootPOA);org.omg.CORBA.Policypolicies=rootPOA.create_lifespan_policy(LifespanPolicyValue.PERSISTENT);POAmyPOA=rootPOA.create_POA(BankPOA,rootPOA.the_POAManager(),policies);AccountManagerImplmanagerServant=newAccountManagerImpl();myPOA.activate_object_with_id(BankManager.getBytes(),managerServant);rootPOA.the_POAManager().activate();System.out.println(帐户管理员BankManager已就绪.n);orb.run();catch(Exceptionexc)exc.printStackTrace();,服务程序Server.java,初始化ORB并取根POA的引用,初始化ORB,作用：获取ORB伪对象的引用，以备调用ORB内核提供的操作时使用伪对象(pseudoobject)：在CORBA基础设施中一个对象,开发人员可以用一种统一的观点看待所有对象CORBA规范中，伪对象也采用IDL定义，称为伪IDL(PIDL),获取根POA的对象引用,所有CORBA服务程序必须获取根POA的对象引用根POA即可直接管理对象，也可创建不同策略集的子POA有一个预定义的策略集，由于仅当创建POA时才可设置POA的策略集，而不可更改已有的策略集，因此根POA的策略集不可更改,/解析”RootPOA”为一个通用对象Org.omg.CORBA.Objectobj=orb.resolve_initial_references(“RootPOA”);/将通用对象类型窄化为POA类型POArootPOA=POAHelper.narrow(obj);,创建自定义策略的POA,创建一个新的子POA的主要目的是为了获取不同的POA行为，例如使用持久对象或使用伺服对象管理器等注：POA层次结构并不意味着POA策略也具有相应的层次结构，子POA并不继承其父POA的任何策略利用create_POA()方法可以创建一个新的POA作为该POA的子POA,可以根据实际需要以这种方式创建多个子POA，从而形成一个POA层次,org.omg.CORBA.Policypolicies=rootPOA.create_lifespan_policy(LifesPERSISTENT);POAmyPOA=rootPOA.create_POA(“ABC”,rootPOA.the_POAManager(),policies);,服务程序创建子POA只需提供子POA的名字，客户程序必须使用完整的POA名字指定一个子POA一个完整的POA名字记录了该子POA名字在内的整个层次路径，层次之间用”/”分割，如“/A/B/C”，”/”表示根POA,使用POA管理器,POA管理器的状态以及引起状态转换的操作如下面状态转换图所示。,使用POA管理器,活动状态当POA管理器处于活动状态时，由它控制的所有POA将接收并开始处理请求。调用POA管理器的activate操作可将POA管理器从持有或丢弃状态改为活动状态。voidactivate()raises(AdapterInactive);注意即使在活动状态下，由于ORB实现或系统资源限制等原因，POA也可能需要将来不及处理的请求排队。每一个ORB产品都会限制请求队列的最大长度，超过该限制时POA会返回一个TRANSIENT异常给客户程序。,使用POA管理器,持有状态POA管理器被创建后即处于持有状态，在该状态下所有接入的请求被引导到一个队列中等候处理，POA并没有对请求作任何处理。为分派这些请求，必须将POA管理器转换为活动状态，即利用POA管理器的activate操作激活该POA管理器。例如代码rootPOA.the_POAManager().activate();将根POA的POA管理器激活为活动状态。,使用POA管理器,丢弃状态当POA管理器处于丢弃状态时，由它控制的所有POA丢弃任何未开始处理的请求，此外不会调用注册到这些POA的任何适配器激活器。引入丢弃状态为服务程序提供了一种流量控制手段，例如为避免服务程序被突如其来的大量请求淹没，可利用该状态拒绝接入请求，这时ORB会返回TRANSIENT异常通知客户程序它们的请求已被丢弃，由客户程序决定是否重新发送请求。,使用POA管理器,非活动状态当POA管理器处于此状态时，由它控制的所有POA拒绝接入请求。与丢弃状态不同，仅当POA管理器要关闭时才使用该状态，因为处于该状态的POA管理器不能再转换到任何其他状态，否则会引发AdapterInactive异常。,激活与冻结对象,对象引用：是客户程序操纵CORBA对象的句柄，服务端程序必须向客户端程序输出对象引用才可为客户程序提供进一步的信息或服务激活：对象引用通过对象标识与伺服对象建立关联如果POA采用RETAIN策略，可有三种激活方式：显示激活，隐式激活，按需激活；若采用NON_RETAIN策略，对象只能按需激活,显式激活,调用POA的activate_object_with_id()或activate_obj()显式地建立伺服对象与一个对象标识的关联activate_object_with_id()：将对象标识和一个伺服对象的关联登记在活动对象映射表中activate_obj()：提供一个伺服对象，由系统自动指派一个对象标识，然后将两者关联登记在活动对象映射表中，最后返回系统分配的对象标识符,隐式激活,调用POA的servant_to_reference(),servant_to_id()操作或调用伺服对象的_this()操作隐式地激活对象同时采用的策略：IMPLICIT_ACTIVATION,SYSTEM_ID,RETAIN,为什么要有伺服对象管理器，直接通过活动对象映射表就可以了,伺服对象管理器,是程序员自己编写的代码，主要作用是查找并返回一个伺服对象并不是所有CORBA应用程序都需要使用伺服对象管理器有两类伺服对象管理器：伺服对象激活器和伺服对象定位器。要使用伺服对象管理器，必须为POA设置USE_SERVANT_MANAGER策略，并结合伺服对象保持策略决定使用哪一种类型的伺服对象管理器。采用RETAIN表示使用伺服对象激活器，常用于激活持久对象；采用NON_RETAIN表示使用伺服对象定位器，常用于查找瞬时对象。,伺服对象激活器,由ServantActivator类型的伺服对象管理器激活的对象被记录在活动对象映射表中。,POA首先查找活动对象映射表,以对象标识与POA作为参数调用伺服对象激活器的incarnate操作,调用伺服对象的合适操作并将结果返回给客户程序,查找并返回一个合适的伺服对象,将该伺服对象登记到活动对象映射表中,找到对象标识,实际应用需要决定是将伺服对象继续保留在活动对象映射表中还是冻结该伺服对象,Y,N,伺服对象激活器,/一个伺服对象激活器类型的伺服对象管理器importorg.omg.PortableServer.*;publicclassAccountManagerActivatorextendsServantActivatorPOApublicServantincarnate(byteoid,POAadapter)throwsForwardRequestServantservant;System.out.println(incarnatewithID=+newString(oid);if(newString(oid).equalsIgnoreCase(Zhang3)servant=(Servant)newAccountManagerImpl_1();elseservant=(Servant)newAccountManagerImpl_2();newDeactivateThread(oid,adapter).start();returnservant;publicvoidetherealize(byteoid,POAadapter,Servantserv,booleancleanup_in_progress,booleanremaining_activations)System.out.println(etherealizewithID=+newString(oid);System.gc();,实现伺服对象激活器,伺服对象激活器,classDeactivateThreadextendsThreadbyte_oid;POA_adapter;publicDeactivateThread(byteoid,POAadapter)_oid=oid;_adapter=adapter;publicvoidrun()tryThread.currentThread().sleep(15000);System.out.println(dactivatewithID=+newString(_oid);_adapter.deactivate_object(_oid);catch(Exceptionexc)exc.printStackTrace();,实现伺服对象激活器,伺服对象定位器,在许多应用场合，POA的活动对象映射表可能变得很大并占用大量内存，这时可考虑以USE_SERVANT_MANAGER结合NON_RETAIN策略创建POA，这意味着伺服对象与CORBA对象的关联不保存在活动对象映射表中。由于没有保存任何关联，每一次请求都导致POA直接以对象标识、POA等参数调用已注册的伺服对象定位器的preinvoke操作。伺服对象定位器负责查找合适的伺服对象返回给POA，由POA调用伺服对象的合适操作并将结果返回给客户程序后，再调用伺服对象定位器的postinvoke操作。,伺服对象定位器,/一个伺服对象定位器类型的伺服对象管理器importorg.omg.PortableServer.*;importorg.omg.PortableServer.ServantLocatorPackage.CookieHolder;publicclassAccountManagerLocatorextendsServantLocatorPOApublicServantpreinvoke(byteoid,POAadapter,java.lang.Stringoperation,CookieHolderthe_cookie)throwsForwardRequestSystem.out.println(preinvokewithID=+newString(oid);if(newString(oid).equalsIgnoreCase(Zhang3)returnnewAccountManagerImpl_1();returnnewAccountManagerImpl_2();publicvoidpostinvoke(byteoid,POAadapter,java.lang.Stringoperation,java.lang.Objectthe_cookie,Servantthe_servant)System.out.println(postinvokewithID=+newString(oid);,实现伺服对象定位器,