Interstage Application Server アプリケーション作成ガイド （CORBAサービス編）

6.16.3 Servant Activator使用例 （Factory-2方式）

(1)IDL定義

  module ODsample{
      interface intf{
          readonly  attribute  long  value; 
          void  add( in  long  a ); 
          void  sub( in  long  b ); 
      };
      interface Factory {
          intf   create();
          void   destroy( in  intf  obj ); 
      };
  };

(2)ネーミングサービスの登録

  OD_or_adm -c IDL:ODsample/Factory:1.0 -n ODsample::POAsample3

(3)アプリケーション構成概要図

(4)クライアントアプリケーション

  import java.io.*; 
  import org.omg.CORBA.*; 
  import org.omg.CosNaming.*; 
  import ODsample.*; 

  public class Client {
      public static void main(String args[]) {

          try {
              // ORBの生成と初期化
              ORB Orb = ORB.init( args, null ); 

              // ネーミングサービスのオブジェクトリファレンスの取得
              org.omg.CORBA.Object _tmpObj =
                      Orb.resolve_initial_references( "NameService" ); 
              NamingContextExt Cos = NamingContextExtHelper.narrow( _tmpObj ); 

              // ネーミングサービスのresolveメソッドを発行し、
              // サーバアプリケーションのオブジェクトリファレンスの獲得
              String NCid = new String( "ODsample::POAsample3" ); // オブジェクト名
              String NCkind = new String( "" );  // オブジェクトタイプ
              NameComponent nc =  new NameComponent( NCid, NCkind ); 
              NameComponent NCo[] = { nc };
              org.omg.CORBA.Object  Obj = Cos.resolve( NCo ); 

              // Factoryのオブジェクトリファレンス獲得
              Factory target = FactoryHelper.narrow( Obj ); 

              // Factoryでインタフェース用オブジェクトリファレンスを作成する
              intf _intf = target.create();

              int    in   = 0;    // inパラメタ用変数
              String line = null; 

              try {
                  // サーバアプリケーションのメソッド呼出し
                  System.out.println( "value = " + _intf.value() ); 

                  System.out.print( "add => " ); 
                  line =
                    new BufferedReader( new InputStreamReader( System.in ) ).readLine();
                  in = Integer.parseInt( line ); 

                  // サーバアプリケーションのメソッド呼出し
                  _intf.add( in ); 
                  System.out.println( "value = " + _intf.value() ); 

                  System.out.print( "sub => " ); 
                  line =
                    new BufferedReader( new InputStreamReader( System.in ) ).readLine();
                  in = Integer.parseInt( line ); 

                  // サーバアプリケーションのメソッド呼出し
                  _intf.sub( in ); 
                  System.out.println( "value = " + _intf.value() ); 

                  // インスタンスの解放
                  target.destroy( _intf ); 
              }
              catch ( java.lang.NumberFormatException e ) {
                  System.exit( 255 ); 
              }
          }
          catch( org.omg.CORBA.SystemException se ) {
              System.out.println( "ERROR : " + se.getClass().getName()
                   + " : minor = 0x" + java.lang.Integer.toHexString(se.minor) );
               System.exit( 255 );
          }
          catch( org.omg.CORBA.UserException ue ) {
              System.out.println( "ERROR : " + ue.getClass().getName() );
              System.exit( 255 );
          }
          catch ( Exception e ) {
              System.err.println( "ERROR : " + e ); 
              System.exit( 255 ); 
          }
      }
  }

(5)サーバアプリケーション

  import org.omg.CORBA.*; 
  import org.omg.PortableServer.*; 
  import ODsample.*; 

  // ユーザアプリケーション：メイン処理クラス
  public class Server {
      public static void main( String args[] ) {

          try {
              // ORBの生成と初期化
              ORB Orb = ORB.init( args, null ); 

              // RootPOAのオブジェクトリファレンスの取得
              org.omg.CORBA.Object _tmpObj =
                          Orb.resolve_initial_references( "RootPOA" ); 
              // RootPOAのPOAオブジェクト獲得
              POA rootPOA = POAHelper.narrow( _tmpObj ); 

              // Factoryインタフェース用のPOA作成
              // ポリシリスト作成
              org.omg.CORBA.Policy factory_policies[] = new org.omg.CORBA.Policy[4]; 
              factory_policies[0] = rootPOA.create_servant_retention_policy(
                                   ServantRetentionPolicyValue.NON_RETAIN ); 
              factory_policies[1] = rootPOA.create_request_processing_policy(
                                   RequestProcessingPolicyValue.USE_DEFAULT_SERVANT ); 
              factory_policies[2] = rootPOA.create_id_assignment_policy(
                                   IdAssignmentPolicyValue.SYSTEM_ID ); 
              factory_policies[3] = rootPOA.create_id_uniqueness_policy(
                                   IdUniquenessPolicyValue.MULTIPLE_ID ); 
              POA factory_POA = rootPOA.create_POA( "IDL:ODsample/Factory:1.0",
                                                 null, 
                                                 factory_policies ); 

              // インタフェース用のPOA作成
              // ポリシリスト作成
              org.omg.CORBA.Policy inf_policies[] = new org.omg.CORBA.Policy[4]; 
              inf_policies[0] = rootPOA.create_servant_retention_policy(
                                   ServantRetentionPolicyValue.RETAIN ); 
              inf_policies[1] = rootPOA.create_request_processing_policy(
                                   RequestProcessingPolicyValue.USE_SERVANT_MANAGER ); 
              inf_policies[2] = rootPOA.create_id_assignment_policy(
                                   IdAssignmentPolicyValue.SYSTEM_ID ); 
              inf_policies[3] = rootPOA.create_id_uniqueness_policy(
                                   IdUniquenessPolicyValue.MULTIPLE_ID ); 
              POA childPOA = rootPOA.create_POA( "childPOA", null, inf_policies ); 

              // FactoryServantの生成
              Servant svt = new FactoryServant( childPOA ); 
              // Factoryインタフェース用POAのDefault Servantに設定
              factory_POA.set_servant( svt ); 

              // ServantActivatorの生成
              ServantActivator svtact = new UserServantActivator();
              // インタフェース用POAのServantManagerとして登録
              childPOA.set_servant_manager( svtact ); 

              // POAマネージャの獲得
              POAManager poamanager = rootPOA.the_POAManager();

              // POAマネージャのactivate
              poamanager.activate();
              Orb.run();
          }
          catch( org.omg.CORBA.SystemException se ) {
              System.out.println( "ERROR : " + se.getClass().getName()
                   + " : minor = 0x" + java.lang.Integer.toHexString(se.minor) );
               System.exit( 255 );
          }
          catch( org.omg.CORBA.UserException ue ) {
              System.out.println( "ERROR : " + ue.getClass().getName() );
              System.exit( 255 );
          }
          catch ( Exception e ) {
              System.err.println( "ERROR : " + e ); 
              System.exit( 255 ); 
          }
      }
  }

  // FactoryServant：Factoryメソッド実装クラス（スケルトンを継承）
  class FactoryServant extends FactoryPOA {
      private POA poa = null; 

      // コンストラクタ
      public FactoryServant( POA poa ) {
          this.poa = poa; 
      }

      public intf create() {
          intf       ior;        // UserServantのオブジェクトリファレンス

          try {
              // オブジェクトリファレンスの生成
              org.omg.CORBA.Object _tmpObj =
                   this.poa.create_reference( "IDL:ODsample/intf:1.0" ); 
              ior = intfHelper.narrow( _tmpObj ); 
          }
          catch( org.omg.CORBA.UserException e ) {
              System.err.println( "create error: " + e ); 
              return( null ); 
          }

          return( ior ); 

      }

      public void destroy( intf obj ) {
          try {
              // オブジェクトリファレンスからオブジェクトIDを求める
              byte oid[] = this.poa.reference_to_id( obj ); 

              // Servantをdeactiveにする
              this.poa.deactivate_object( oid ); 
          }
          catch( org.omg.CORBA.UserException e ) {
              System.err.println( "destroy error: " + e ); 
          }
      }
  }

  // Servantアクティベータ：Servant生成クラス（ServantActivatorを継承）
  // JDK/JRE1.3以前を使用する場合
  // class UserServantActivator extends ServantActivator {
  // JDK/JRE1.4を使用する場合
  class UserServantActivator extends LocalObject implements ServantActivator {

      public Servant incarnate( byte[] oid, 
                              POA adapter ) {

          // Servantの生成
          Servant svt = new UserServant();
          return( svt ); 
      }

      public void etherealize( byte[] oid, 
                             POA adapter, 
                             Servant serv, 
                             boolean cleanup_in_progress, 
                             boolean remaining_activations ) {

          // 変数の初期化を行う。
          serv = null; 

      }
  }

  // Servant：メソッド実装クラス（スケルトンを継承）
  class UserServant extends intfPOA {

      private int    value = 0; 

      public int value() {
          return( this.value ); 
      }

      public void add( int a ) {
          this.value += a; 
      }

      public void sub( int b ) {
          this.value -= b; 
      }

  }

(6)例外情報の獲得

　サーバアプリケーションで例外を獲得する方法は、クライアントアプリケーションの例外処理と同様です。詳細については、“クライアントアプリケーションの例外処理”を参照してください。