| Interstage Application Server アプリケーション作成ガイド （CORBAサービス編） |
|
目次
索引
|
| 第5章 アプリケーションの開発（C++言語） | > 5.3 サーバアプリケーションのプログラミング（Portable Object Adapter：POA） | > 5.3.8 サーバアプリケーションのプログラミング例 |
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 );
};
};
OD_or_adm -c IDL:ODsample/Factory:1.0 -a Imple_POAsample3 -n ODsample::POAsample3
#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;
int main( int argc, char *argv[] )
{
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::POAsample3";
name[0]->kind = ( const CORBA::Char* )"";
obj = cos_naming->resolve( name, env );
// Factoryのオブジェクトリファレンス獲得
ODsample::Factory* target = ODsample::Factory::_narrow( obj );
// Factoryでインタフェース用オブジェクトリファレンスを作成する
ODsample::intf* obj2 = target->create( env );
CORBA::Long a = 10; // inパラメタ用変数
CORBA::Long b = 5;
// サーバアプリケーションのメソッド呼出し
CORBA::Long ret = obj2->value( env );
printf( "value = %d\n", ret );
obj2->add( a, env );
printf( "add( %d )\n", a );
ret = obj2->value( env );
printf( "value = %d\n", ret );
obj2->sub( b, env );
printf( "sub( %d )\n", b );
ret = obj2->value( env );
printf( "value = %d\n", ret );
// インスタンスの解放
target->destroy( obj2, env );
CORBA::release( target );
CORBA::release( obj2 );
} 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;
}
#include <iostream.h>
#include <stdlib.h>
#include "poa.h"
#include "CosNaming_cplus.h"
#include "orb_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 PortableServer::POA_var factoryPOA;
static PortableServer::POA_var childPOA;
static CORBA::PolicyList factory_policies( 4 );
static CORBA::PolicyList intf_policies( 4 );
static PortableServer::POAManager_var poa_manager;
static long val = 10;
// ユーザアプリケーション：メイン処理クラス
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 );
// Factoryインタフェース用のPOA作成
// ポリシリスト作成
factory_policies.length( 4 );
factory_policies[0] = rootPOA->create_servant_retention_policy(
PortableServer::NON_RETAIN, env );
factory_policies[1] = rootPOA->create_request_processing_policy(
PortableServer::USE_DEFAULT_SERVANT, env );
factory_policies[2] = rootPOA->create_id_assignment_policy(
PortableServer::SYSTEM_ID, env );
factory_policies[3] = rootPOA->create_id_uniqueness_policy(
PortableServer::MULTIPLE_ID, env );
factoryPOA = rootPOA->create_POA( "IDL:ODsample/Factory:1.0",
PortableServer::POAManager::_nil(), factory_policies ,env);
// インタフェース用のPOA作成
// ポリシリスト作成
intf_policies.length( 4 );
intf_policies[0] = rootPOA->create_servant_retention_policy(
PortableServer::RETAIN, env );
intf_policies[1] = rootPOA->create_request_processing_policy(
PortableServer::USE_SERVANT_MANAGER, env );
intf_policies[2] = rootPOA->create_id_assignment_policy(
PortableServer::SYSTEM_ID, env );
intf_policies[3] = rootPOA->create_id_uniqueness_policy(
PortableServer::MULTIPLE_ID, env );
childPOA = rootPOA->create_POA( "childPOA",
PortableServer::POAManager::_nil(), intf_policies ,env );
// FactoryServantの生成
ODsample_Factory_impl* svt = new ODsample_Factory_impl();
// Factoryインタフェース用POAのDefault Servantに設定
factoryPOA->set_servant( svt, env );
// ServantActivatorの生成
PortableServer::ServantActivator_var svtact = new UserServantActivator();
// インタフェース用POAのServantManagerとして登録
childPOA->set_servant_manager( svtact, 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;
}
// ODsample_Factory_impl::create：Factoryメソッド実装クラス
ODsample::intf_ptr ODsample_Factory_impl::create(
CORBA::Environment& env )
throw( CORBA::Exception )
{
try{
// オブジェクトリファレンスの生成
CORBA::Object_var _tmpObj
= childPOA->create_reference( "IDL:ODsample/intf:1.0", env );
ODsample::intf_ptr ior = ODsample::intf::_narrow( _tmpObj );
return ior;
} catch( CORBA::Exception& e ) {
cout << "exception-id: " << e.id() << endl;
throw( e );
}
};
// ODsample_Factory_impl::destroy：Factoryメソッド実装クラス
void ODsample_Factory_impl::destroy(
ODsample::intf_ptr obj,
CORBA::Environment& env )
throw( CORBA::Exception )
{
try{
// オブジェクトリファレンスからオブジェクトIDを求める
PortableServer::ObjectId_var oid = childPOA->reference_to_id( obj, env );
// Servantをdeactiveにする
childPOA->deactivate_object( *oid, env );
} catch( CORBA::Exception& e ) {
cout << "Exception: " << opname << endl;
cout << "exception-id: " << e.id() << endl;
throw( e );
}
};
// ServantActivator：Servant生成クラス（ServantActivatorを継承）
class UserServantActivator: public PortableServer::ServantActivator
{
public:
UserServantActivator() {};
~UserServantActivator() {};
PortableServer::Servant incarnate(
const PortableServer::ObjectId& oid,
PortableServer::POA_ptr adapter,
CORBA::Environment& env )
throw( CORBA::Exception )
{
// Servantの生成
PortableServer::Servant svt = new ODsample_intf_impl();
return( svt );
};
void etherealize( const PortableServer::ObjectId& oid,
PortableServer::POA_ptr adapter,
PortableServer::Servant serv,
CORBA::Boolean cleanup_in_progress,
CORBA::Boolean remaining_activations,
CORBA::Environment& env )
throw( CORBA::Exception )
{
// Servantオブジェクトの削除。
serv->servant_delete();
}
};
// ODsample_intf_impl：メソッド実装クラス
void ODsample_intf_impl::add(
CORBA::Long a,
CORBA::Environment& env)
throw( CORBA::Exception ){
cout << "ODsample::intf::add()" << endl;
cout << " val : " << val << endl;
cout << " a : " << a << endl;
val = val + a;
cout << " result: " << val << endl;
};
void ODsample_intf_impl::sub(
CORBA::Long b,
CORBA::Environment& env)
throw( CORBA::Exception ){
cout << "ODsample::intf::sub()" << endl;
cout << " val : " << val << endl;
cout << " b : " << b << endl;
val = val - b;
cout << " result: " << val << endl;
};
CORBA::Long ODsample_intf_impl::value(
CORBA::Environment& env)
throw( CORBA::Exception ){
return val;
};
サーバアプリケーションで例外を獲得する方法の詳細については、“サーバアプリケーションの例外処理”を参照してください。
|
目次
索引
|