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

5.3.7.6 AdapterActivator使用例 （リクエスト受信時）

(1)IDL定義

  module ODsample{
      interface    intf1{
          long  add( in long a, in long b ); 
      }; 
      interface  intf2{
          long  sub( in long a, in long b ); 
      }; 
  };

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

  OD_or_adm -c IDL:ODsample/intf1:1.0  -a Imple_POAsample10 -n ODsample::POAsample10-1
  OD_or_adm -c IDL:ODsample/intf2:1.0  -a Imple_POAsample10 -n ODsample::POAsample10-2

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

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

  #include <stdlib.h>
  #include <iostream.h>
  #include "orb_cplus.h"
  #include "CosNaming_cplus.h"
  #include "simple.h"

  static  CORBA::Object_var             obj; 
  static  CORBA::Environment            env; 
  static  CORBA::ORB_var                orb; 
  static  CosNaming::NamingContext_var  cos_naming; 
  static  CosNaming::Name               name; 
  static  CosNaming::Name               name2; 
   
  int main( int argc, char* argv[] ) 
  {
      CORBA::Long   val1 = 0;      // inパラメタ用変数
      CORBA::Long   val2 = 0;      // inパラメタ用変数

      try {
          // ORBの生成と初期化
          orb = CORBA::ORB_init( argc, argv, FJ_OM_ORBid, env ); 

          // ネーミングサービスのオブジェクトリファレンスの取得
          obj = orb->resolve_initial_references( CORBA_ORB_ObjectId_NameService, env ); 
          cos_naming = CosNaming::NamingContext::_narrow( obj ); 

          // ネーミングサービスのresolveメソッドを発行し、
          // サーバアプリケーションのオブジェクトリファレンスの獲得
          name.length( 1 ); 
          name[0]->id   = ( const CORBA::Char* )"ODsample::POAsample10-1"; 
          name[0]->kind = ( const CORBA::Char* )""; 
          obj = cos_naming->resolve( name, env ); 

          // サーバアプリケーションのオブジェクトリファレンス獲得
          ODsample::intf1* target1 = ODsample::intf1::_narrow( obj ); 

          printf( "val1=>" ); 
          scanf( "%d", &val1 ); 
          printf( "val2=>" ); 
          scanf( "%d", &val2 ); 

          // サーバアプリケーションのメソッド呼出し
          CORBA::Long  ret1 = target1->add( val1, val2, env ); 

          // メソッドの結果表示
          printf( "val1 + val2 = %d\n", ret1 ); 

          CORBA::release( target1 ); 

          // ネーミングサービスのresolveメソッドを発行し、
          // サーバアプリケーションのオブジェクトリファレンスの獲得
          name2.length( 1 ); 
          name2[0]->id   = ( const CORBA::Char* )"ODsample::POAsample10-2"; 
          name2[0]->kind = ( const CORBA::Char* )""; 
          obj = cos_naming->resolve( name2, env ); 

          // サーバアプリケーションのオブジェクトリファレンス獲得
          ODsample::intf2* target2 = ODsample::intf2::_narrow( obj ); 

          printf( "val1=>" ); 
          scanf( "%d", &val1 ); 
          printf( "val2=>" ); 
          scanf( "%d", &val2 ); 

          // サーバアプリケーションのメソッド呼出し
          CORBA::Long  ret2 = target2->sub( val1, val2, env ); 

          // メソッドの結果表示
          printf( "val1 - val2 = %d\n", ret2 ); 

          CORBA::release( target2 ); 
      } catch( CORBA::SystemException&  se ) {
          cout << "exception-id: " << se.id() << endl; 
          exit(1); 
      } catch( CORBA::Exception&  e ) {
          cout << "exception-id: " << e.id() << endl; 
          exit(1); 
      }
      return 0; 
  }

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

  #include <iostream.h>
  #include <stdlib.h>
  #include "orb_cplus.h"
  #include "poa.h"
  #include "CosNaming_cplus.h"
  #include "simple.h"

  static CORBA::ORB_var                   orb; 
  static CORBA::Object_var                obj; 
  static CORBA::Environment               env; 
  static PortableServer::POA_var          rootPOA; 
  static CORBA::PolicyList                policies( 4 ); 
  static PortableServer::POAManager_var   poa_manager; 

  // ユーザアプリケーション：メイン処理クラス
  int main( int argc, char* argv[] ) 
  {
      int current_argc = argc; 
      try{
          // ORBの生成と初期化
          orb         = CORBA::ORB_init( current_argc, argv, FJ_OM_ORBid, env ); 

          // RootPOAのオブジェクトリファレンスの取得
          obj         = orb->resolve_initial_references( "RootPOA", env ); 
          // RootPOAのPOAオブジェクト獲得
          rootPOA     = PortableServer::POA::_narrow( obj ); 

          // AdapterActivatorの生成
          PortableServer::AdapterActivator_var adp = new UserAdapterActivator(); 
          // インプリ用POAのAdapterActivatorに設定
          rootPOA->the_activator( adp, env ); 

          // POAマネージャの獲得
          poa_manager = rootPOA->the_POAManager( env ); 
          // POAマネージャのactivate
          poa_manager->activate( env ); 

          orb->run( env ); 
      } catch( CORBA::SystemException&  se ) {
          cout << "exception-id: " << se.id() << endl; 
          exit(1); 
      } catch( CORBA::Exception&  e ) {
          cout << "exception-id: " << e.id() << endl; 
          exit(1); 
      }
      return 0; 
  }

  // AdapterActivator：POA生成クラス（AdapterActivatorを継承）
  class UserAdapterActivator : public PortableServer::AdapterActivator
  {
  public: 
      UserAdapterActivator() {};
      ~UserAdapterActivator() {};

      CORBA::Boolean  unknown_adapter(
                                PortableServer::POA_ptr parent, 
                                const CORBA::Char*      name, 
                                CORBA::Environment&     env ) 
                                throw( CORBA::Exception ) 
      {
          // ポリシリスト作成
          CORBA::PolicyList    policies( 4 ); 
          policies.length( 4 ); 
          policies[0] = rootPOA->create_servant_retention_policy(
                                 PortableServer::NON_RETAIN, env ); 
          policies[1] = rootPOA->create_request_processing_policy(
                                 PortableServer::USE_DEFAULT_SERVANT, env ); 
          policies[2] = rootPOA->create_id_assignment_policy(
                                 PortableServer::SYSTEM_ID, env ); 
          policies[3] = rootPOA->create_id_uniqueness_policy(
                                 PortableServer::MULTIPLE_ID, env ); 
          try {
              if( !strcmp( name, "IDL:ODsample/intf1:1.0" ) ) {
                  // intf1用のPOA作成
                  PortableServer::POA_ptr intf_POA
                    = parent->create_POA( name, NULL, policies, env ); 

                  // Servantの生成
                  ODsample_intf1_impl* svt = new ODsample_intf1_impl(); 

                  // Default Servantに設定
                  intf_POA->set_servant( svt, env ); 

                  return( CORBA_TRUE ); 
              }
              else if( !strcmp( name, "IDL:ODsample/intf2:1.0" ) ) {
                  // intf2用のPOA作成
                  PortableServer::POA_ptr intf_POA
                      = parent->create_POA( name, NULL, policies, env ); 

                  // Servantの生成
                  ODsample_intf2_impl* svt = new ODsample_intf2_impl(); 

                  // Default Servantに設定
                  intf_POA->set_servant( svt, env ); 

                  return( CORBA_TRUE ); 
              }
          } catch( CORBA::SystemException&  se ) {
              cout << "exception-id: " << se.id() << endl; 
              return( CORBA_FALSE ); 
          } catch( CORBA::UserException&  ue ) {
              cout << "exception-id: " << ue.id() << endl; 
              return( CORBA_FALSE ); 
          } catch( CORBA::Exception&  e ) {
              cout << "exception-id: " << e.id() << endl; 
              return( CORBA_FALSE ); 
          }
          return CORBA_TRUE; 
      }; 
  }; 

  // メソッド実装
  CORBA::Long  ODsample_intf1_impl::add(
                                      CORBA::Long          a, 
                                      CORBA::Long          b, 
                                      CORBA::Environment&  env ) 
                                      throw( CORBA::Exception ) 
  {
      return a + b; 
  }; 

  CORBA::Long  ODsample_intf2_impl::sub(
                                     CORBA::Long  a, 
                                     CORBA::Long  b, 
                                     CORBA::Environment&  env ) 
                                     throw( CORBA::Exception ) 
  {
      return a - b; 
  };

(6)例外情報の獲得

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