アプリケーション開発者は、新しいPOAを作成するときに、新しいPOA用に選択した特定のポリシーを宣言し、異なるアダプタ・アクティベータおよびサーバント・マネージャ (これらは、必要時のPOAの起動とサーバントの起動を行うためにPOAが使用するコールバック・オブジェクト)を提供できます。 オブジェクトIDはPOAに対して相対的に解釈されるため、アプリケーション開発者は、新しいPOAを作成することによってさらにオブジェクトの名前空間の区分けも行うことができます。 また、新しいPOAを作成すると、開発者は、複数のオブジェクトのセットに対する要求の処理を個別に制御できます。
アダプタ・アクティベータはオプションです。 アダプタ・アクティベータは、要求の処理中にPOAを作成する必要がある場合に使用します。 アプリケーションの初期化時に、必要なPOAがすべて作成されている場合は、アダプタ・アクティベータは必要ありません。
アダプタ・アクティベータを使用すると、POAは、必要に応じて子POAを作成できるようになります(子POA (または複数の子のどれか)を指定した要求を受信したときの副作用として、あるいは起動パラメータ値TRUEを使用してfind_POAメソッドが呼び出されたとき)。 ORBは、存在していない子POAへの要求を受け取ると、アダプタ・アクティベータのオペレーションを呼び出します。 アダプタ・アクティベータは必要なPOAをその場で作成します。
要求は、ターゲット・オブジェクトのオブジェクトIDと、ターゲット・オブジェクト参照を作成したPOAの識別情報を伝達できる必要があります。 クライアントから要求が発行されると、ORBは、初めに適切なサーバーを探し(必要な場合は起動する)、次にそのサーバー内で適切なPOAを探します。
サーバー・プロセス内にPOAが存在しない場合、アプリケーションは、アダプタ・アクティベータを使用して必要なPOAを再作成することができます。 アダプタ・アクティベータは、ユーザーによって実装されるオブジェクトで、POAに関連付けることができます。 アダプタ・アクティベータは、存在していないPOAへの要求を受け取ったときに、ORBによって呼び出されます。 ここでアダプタ・アクティベータに、必要なPOAを作成する機会が与えられます。 そうしない場合、クライアントはADAPTER_NONEXISTENT例外を受け取ります。
ORBは、必要なPOAを見つけると、そのPOAに要求を渡します。 そのあとの要求の処理は、POAに関連付けられているポリシーと、オブジェクトの現在の起動状態によって異なります。
次のコードは、要求の処理中にPOAを作成できるようにするためにアダプタ・アクティベータを使用するアプリケーションの例を示しています。 このアプリケーションは、「Hello World」の例を基にして作成したものです。 この例には次のファイルが含まれています。
この例を実行する方法については、「アダプタ・アクティベータのアプリケーション例の実行」を参照してください。
サンプル・クライアントのためのコードで、ORBを初期化し、HelloServantを解決し、sayHello()メソッドを呼び出します。
//Client.java
import org.omg.CORBA.ORB;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextHelper;
import org.omg.CosNaming.NameComponent;
public class Client {
public void run(String[] args) {
try {
//initialize the orb
ORB orb = ORB.init(args, null);
System.out.println("ORB initialized");
NamingContext namingContext = NamingContextHelper.narrow(
orb.resolve_initial_references("NameService"));
NameComponent[] nc = { new NameComponent("HelloServer", "") };
//resolve HelloServant and invoke sayHello()
Hello helloRef = HelloHelper.narrow(namingContext.resolve(nc));
System.out.println("Resolved HelloServant");
System.out.println(helloRef.sayHello());
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new Client().run(args);
}
}
サーバーのためのコードで、次のような処理を行います。
//Server.java
import org.omg.CORBA.ORB;
import org.omg.CORBA.LocalObject;
import org.omg.CORBA.Policy;
import org.omg.PortableServer.POA;
import org.omg.PortableServer.POAHelper;
import org.omg.PortableServer.AdapterActivator;
import org.omg.PortableServer.IdAssignmentPolicyValue;
import org.omg.PortableServer.LifespanPolicyValue;
import org.omg.PortableServer.ImplicitActivationPolicyValue;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextHelper;
import org.omg.CosNaming.NameComponent;
public class Server {
public void run(String[] args) {
try {
//initialize the orb
ORB orb = ORB.init(args, null);
System.out.println("ORB initialized");
//resolve RootPOA
POA rootPOA = POAHelper.narrow(
orb.resolve_initial_references("RootPOA"));
//register adapter activator with rootPOA so that child POAs can
//be created on demand
rootPOA.the_activator(new MyAdapterActivator());
//find_POA with an activate parameter TRUE would cause the
//adapter activator associated with rootPOA to be invoked if
//'HelloPOA' does not exist
POA childPOA = rootPOA.find_POA("HelloPOA", true);
//Create the object reference for HelloServant
//and register with naming service
org.omg.CORBA.Object obj = childPOA.id_to_reference(
"abcd".getBytes());
Hello helloRef = HelloHelper.narrow(obj);
NamingContext namingContext = NamingContextHelper.narrow(
orb.resolve_initial_references("NameService"));
NameComponent[] nc = { new NameComponent("HelloServer", "") };
namingContext.rebind(nc, helloRef);
//Destroy 'HelloPOA'. This POA will be transparently recreated when
//ORB receives a request on HelloPOA using the adapter activator we
//registered with the RootPOA
childPOA.destroy(true, true);
//activate rootPOA
rootPOA.the_POAManager().activate();
//wait for incoming requests
System.out.println("Server ready and running....");
orb.run();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new Server().run(args);
}
}
class MyAdapterActivator extends LocalObject implements AdapterActivator {
public boolean unknown_adapter(POA parent, String name) {
System.out.println("unknown_adapter() invoked for POA - " + name);
try {
// create the POA with appropriate policies
// this sample uses PERSISTENT, NO_IMPLICIT_ACTIVATION
// and USER_ID policies
Policy[] policy = new Policy[3];
policy[0] = parent.create_lifespan_policy(
LifespanPolicyValue.PERSISTENT);
policy[1] = parent.create_id_assignment_policy(
IdAssignmentPolicyValue.USER_ID);
policy[2] = parent.create_implicit_activation_policy(
ImplicitActivationPolicyValue.NO_IMPLICIT_ACTIVATION);
POA child = parent.create_POA(name, null, policy);
//Associate the servant with the new POA
HelloServant hello = new HelloServant();
child.activate_object_with_id("abcd".getBytes(), hello);
//activate the new POA
child.the_POAManager().activate();
return true;
} catch (Exception e) {
e.printStackTrace();
}
return false;
}
}
interface Hello { string sayHello(); };
//HelloServant.java
public class HelloServant extends HelloPOA {
public String sayHello() {
return "Hello :)";
}
}
makeプログラムは、Solaris、LinuxまたはMac OS Xのシェルが実行する一連のコマンドを生成します。
JAVA_HOME=<path_to_your_Java_installation_bin_directory>
#setup tools
JAVA=$(JAVA_HOME)/bin/java
JAVAC=$(JAVA_HOME)/bin/javac
IDLJ=$(JAVA_HOME)/bin/idlj
ORBD=$(JAVA_HOME)/bin/orbd
all : clean build run
clean :
- rm -rf classes orb.db
build :
mkdir -p classes
$(IDLJ) -fall -td classes Hello.idl
$(JAVAC) -classpath classes -d classes HelloServant.java Server.java Client.java
run : runorbd register runclient
runorbd :
$(ORBD) -ORBInitialPort 10001 &
sleep 20
register:
#servertool does not support script based register due to a bug
#using class instead
#Please note that the name of the servertool
#class may change in future releases.
$(JAVA) com.sun.corba.se.internal.Activation.ServerTool \
-ORBInitialPort 10001 -cmd \
register -server Server -classpath classes
runclient :
$(JAVA) -classpath classes Client -ORBInitialPort 10001
batユーティリティは、Microsoft Windowsのコマンド・シェルが実行する一連のコマンドを生成します。
SET JAVA_HOME=<path_to_your_Java_installation_build_directory>
mkdir classes
%JAVA_HOME%\bin\idlj -fall -td classes Hello.idl
%JAVA_HOME%\bin\javac -classpath classes -d classes HelloServant.java Server.java Client.java
REM - Start the ORB daemon
start %JAVA_HOME%\bin\orbd -ORBInitialPort 10001 -ORBDebug orbd
@echo Wait 10-15 seconds for the orbd to start
@pause
REM - Register the persistent server with orbd using servertool
REM - Please note that the name of the servertool
REM - class may change in future releases.
%JAVA_HOME%\bin\java com.sun.corba.se.internal.Activation.ServerTool -ORBInitialPort 10001 -cmd register -server Server -classpath classes
%JAVA_HOME%\bin\java -classpath classes Client -ORBInitialPort 10001
この例を実行するには、次のようにします。
Makefileを実行すると、端末ウィンドウに次の例のような出力が表示されます。
rm -rf classes orb.db mkdir -p classes /j2sdk1.5.0/bin/idlj -fall -td classes Hello.idl /j2sdk1.5.0/bin/javac -classpath classes -d classes HelloServant.java Server.java Client.java /j2sdk1.5.0/bin/orbd -ORBInitialPort 10001 & sleep 20 #servertool does not support script based register due to a bug #using class instead #Please note that the name of the servertool
#class may change in future releases.
/j2sdk1.5.0/bin/java com.sun.corba.se.internal.Activation.ServerTool \
-ORBInitialPort 10001 -cmd \
register -server Server -classpath classes
server registered (serverid = 257).
/j2sdk1.5.0/bin/java -classpath classes Client -ORBInitialPort 10001
ORB initialized
Resolved HelloServant
Hello :)
この例を実行し終えたら、ORBDをシャットダウンします。
pkill orbdと入力します。Ctrl+Cと入力。