1.2.1. WebOTX AS CORBAアプリケーション

• はじめに
• WebOTXプログラミングの流れ
• Java言語を用いたサーバアプリケーションの作成
• Java言語を用いたクライアントアプリケーションの作成
• C++言語を用いたサーバアプリケーションの作成
• C++言語を用いたクライアントアプリケーションの作成
• COBOL言語を用いたサーバアプリケーションの作成
• コマンドリファレンス
• WebOTXのORBについて
• WebOTXが使用しているPOAについて

1.2.1.1. はじめに

WebOTXの特徴

図1.2.1.1-1

図1.2.1.1-2

ステート(ステートフル、ステートレス)

スレッドモデル(アパートメント、フリースレッド)

サーバオブジェクトとファクトリオブジェクト

R5形式とR4形式

interface foo     // ステートフルオブジェクト
{
    void op(in string a, out in string a);
};

interface barFactory
{
    foo creObj();
    ^^^ ^^^^^^^^
    |          +------------------------ オペレーション名は任意です
    +----------------------------------- ステートフルオブジェクトのインタフェース

    void relObj(in foo obj);
    ^^^^ ^^^^^^ ^^^^^^^^^^
    |    |      +----------------------- 上記メソッドの返却値を設定。
    |    |                               これ以外の値は渡してはいけない
    |    +------------------------------ オペレーション名は任意です
    +----------------------------------- 返却値はvoid固定です
};

サーバオブジェクトの事前生成機能

常駐オブジェクト機能

共有プロパティ機能

共有プロパティ概要

共有コンポーネント機能

データベース自動接続/切断機能

非同期トランザクション機能

WebOTX Transaction Serviceを用いたOTS連携機能

コールバック機能

クライアント管理ライブラリ機能

1.2.アプリケーション作成に必要なソフトウェア

1.2.1.2. WebOTXプログラミングの流れ

システム全体の構成を決める

利用言語を決める

作成方法を決める

IDLファイルを作成する

IDLファイルをコンパイルする

サーバAPの作成

クライアントAPの作成

デバッグ

実業務環境への登録

再評価

動作がおかしいと思ったら

1.2.1.3. Java言語を用いたサーバアプリケーションの作成

Javaサーバアプリケーションの作成の流れ

開発環境の設定

UNIX

>set path=( $path /opt/ObjectSpinner/bin )
>set path=( $path /opt/WebOTX/dev/command )
:
:
>setenv LD_LIBRARY_PATH  /opt/ObjectSpinner/lib:/opt/WebOTX/dev/lib
:
:
>setenv CLASSPATH /opt/WebOTX/modules/jsocks.jar
>setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/modules/wo-orb110.jar
>setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/modules/omgorb110.jar
>setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/dev/javalib/svsimj.jar
>setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/dev/javalib/WOTXBS90.jar
:

Windows

IDLファイルの作成とコンパイル(Java)

R5形式(ファクトリを使用しない場合)

1: module sample
2: {
3:     interface LoopBackSample : WO_Base // (サンプルではWO_Baseからの派生はありません)
4:     {
5:         long LoopBack(in string inputChar, out string outputChar);
6:         long LowerCase(in string inputChar, out string outputChar);
7:         long UpperCase(in string inputChar, out string outputChar);
8:     };
9: };

i2j -i -lstub <IDLファイル名> (woi2jとは異なり、"loopback.idl"のように.idlも必要です)
    ^^ ^^^^^^
    |     +-----ローカルスタブを使用。非同期VD呼び出しには必須のオプションです
    +-----------ifファイルの生成を行います。WebOTXに登録するために必須のオプションです。

/opt/ObjectSpinner/bin/i2j.sh -i -lstub <IDLファイル名>

i2j -i -lstub -rpjp.co.nec.WebOTX -Rwobase.idl <IDLファイル名> (.idlも必要)
              ^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^
                    |               +-----wobase.idl を参照します。
                    |                     WO_Baseを使用するために必須のオプションです。
                    +----------IDL定義が jp.co.nec.WebOTXパッケージに置かれているものとして生成します。
                               WO_Baseを使用するために必須のオプションです。

/opt/ObjectSpinner/bin/i2j.sh -i -lstub -rpjp.co.nec.WebOTX -Rwobase.idl <IDLファイル名>

R5形式(ファクトリを使用する場合)

1: module sample 
2: {
3:     interface LoopBackSample : WO_Base 
4:                             // (サンプルではWO_Baseからの派生はありません)
5:     {
6:         long LoopBack(in string inputChar, out string outputChar);
7:         long LowerCase(in string inputChar, out string outputChar);
8:         long UpperCase(in string inputChar, out string outputChar);
9:     };
10:
11:     interface WO_Factory_LoopBackSample : WO_BaseFactory 
12:                           // (サンプルではWO_BaseFactoryからの派生はありません)
13:     {
14:         LoopBackSample CreateServerObject();
15:         void ReleaseServerObject(in LoopBackSample obj);
16:     };
17: };

i2j -i -lstub <IDLファイル名> (woi2jとは異なり、"loopback.idl"のように.idlも必要です)
    ^^ ^^^^^^
    |    +-----ローカルスタブを使用。非同期VD呼び出しには必須のオプションです
    +----------ifファイルの生成を行います。WebOTXに登録するために必須のオプションです。

/opt/ObjectSpinner/bin/i2j.sh -i -lstub <IDLファイル名>

i2j -i -lstub -rpjp.co.nec.WebOTX -Rwobase.idl <IDLファイル名> (.idlも必要)
              ^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^
               |                   +-----wobase.idl を参照します。
               |                         WO_Baseを使用するために必須のオプションです。
               +----------IDL定義が jp.co.nec.WebOTXパッケージに置かれているものとして
               コードを生成します。WO_Baseを使用するために必須のオプションです。

/opt/ObjectSpinner/bin/i2j.sh -i -lstub -rpjp.co.nec.WebOTX -Rwobase.idl <IDLファイル名>

サーバント(実装部分)のコーディング(Java)

R5形式(ファクトリを使用しない場合)

//
// 実装クラス(LoopBackSampleObj.java)
//
package sample;

import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;

public class LoopBackSampleObj extends LoopBackSamplePOA {

    public LoopBackSampleObj() {
    }

    public int LoopBack(java.lang.String inputChar, 
                        org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar;
        return outputChar.value.length();
    }

    public int LowerCase(java.lang.String inputChar, 
                         org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar.toLowerCase();
        return outputChar.value.length();
    }

    public int UpperCase(java.lang.String inputChar, 
                         org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar.toUpperCase();
        return outputChar.value.length();
    }

    // WO_Base interface
    public void OnTPSAbort(int status) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_ERR, 
                                     "*** OnTPSAbort() called. ***");
          WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_ERR, 
                                     "    status="+status);
      }

    public void OnTPSDisconnect() {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_INFO,
                                     "*** OnTPSDisconnect() called. ***");
    }

    public void OnTPSMessageNotified(java.lang.String mes) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_INFO,
                                     "*** OnTPSMessageNotified("+mes+") called. ***");
    }
}

woixj  <ifファイル名>  [-options]　(拡張子ifは不要)
使用例: woixj loopback

//
// 実装情報定義クラス(LoopBackSampleObjInfo.java)
//
import jp.co.nec.WebOTX.WOServantCallback;
public class LoopBackSampleObjInfo implements WOServantCallback
{
    public String _name()
    {
        return "sample_LoopBackSampleJava";
    }
    public String _id()
    {
        return "IDL:sample/LoopBackSample:1.0";
    }
    public org.omg.PortableServer.Servant _newInstance()
    {
        return new sample.LoopBackSampleObj();
    }
}

//
// コンポーネント初期化クラス(LoopBackInit.java)
//
import jp.co.nec.WebOTX.WOComponent;
import jp.co.nec.WebOTX.WOUserComponent;
public class LoopBackInit implements WOUserComponent {
    public void init() {
        WOComponent.add(new LoopBackSampleObjInfo());
    }
}

>mkdir classes

Windows
>javac -d classes *.java sample\*.java
Unix
>javac -d classes *.java sample/*.java

>cd classes
>jar cvf LoopBackSample.jar *.class sample

R5形式(ファクトリを使用する場合)

//
// 実装クラス(LoopBackSampleObj.java)
//
package sample;

import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;

public class LoopBackSampleObj extends LoopBackSamplePOA {

    public LoopBackSampleObj() {
    }

    public int LoopBack(java.lang.String inputChar, 
                        org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar;
        return outputChar.value.length();
    }

    public int LowerCase(java.lang.String inputChar, 
                         org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar.toLowerCase();
        return outputChar.value.length();
    }

    public int UpperCase(java.lang.String inputChar, 
                         org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar.toUpperCase();
        return outputChar.value.length();
    }

    // WO_Base interface
    public void OnTPSAbort(int status) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_ERR, 
                                     "*** OnTPSAbort() called. ***");
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_ERR, 
                                     "    status="+status);
    }

    public void OnTPSDisconnect() {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_INFO, 
                                     "*** OnTPSDisconnect() called. ***");
    }

    public void OnTPSMessageNotified(java.lang.String mes) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_INFO, 
                                     "*** OnTPSMessageNotified("+mes+") called. ***");
    }
}

woixj  <ifファイル名>  [-options]　(拡張子ifは不要)
使用例: woixj loopback

//
// ファクトリ実装クラス(WO_Factory_LoopBackSampleObj.java)
//
package sample;

import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;
import jp.co.nec.WebOTX.WOServantCallback;
import jp.co.nec.WebOTX.WOServantManager;
import org.omg.CORBA.IntHolder;
import org.omg.CORBA.StringHolder;

public class WO_Factory_LoopBackSampleObj extends WO_Factory_LoopBackSamplePOA {
    public WO_Factory_LoopBackSampleObj() {
    }

    public LoopBackSample CreateServerObject() {
        WOServantCallback servInfo = new LoopBackSampleObjInfo();
        org.omg.CORBA.Object obj = WOServantManager.CreateServant(servInfo);
        return LoopBackSampleHelper.narrow(obj);
    }

    public void ReleaseServerObject(LoopBackSample obj) {
        WOServantCallback servInfo = new LoopBackSampleObjInfo();
        WOServantManager.ReleaseServant(servInfo, obj);
    }

    public void GetID(IntHolder port, StringHolder host, StringHolder termid) {
        WoServerWrapper.TPSGetIDs(port, host, termid);
    }
}

//
// 実装情報定義クラス(LoopBackSampleObjInfo.java)
//
import jp.co.nec.WebOTX.WOServantCallback;

public class LoopBackSampleObjInfo implements WOServantCallback {
    public String _name() {
        return "sample_LoopBackSampleJava";
    }
 
    public String _id() {
        return "IDL:sample/LoopBackSample:1.0";
    }

    public org.omg.PortableServer.Servant _newInstance() {
        return new sample.LoopBackSampleObj();
    }
}

//
// 実装情報定義クラス(WO_Factory_LoopBackSampleObjInfo.java)
//
import jp.co.nec.WebOTX.WOServantCallback;

public class WO_Factory_LoopBackSampleObjInfo implements WOServantCallback {

    public String _name() {
        return "sample_WO_Factory_LoopBackSampleJava";
    }

    public String _id() {
        return "IDL:sample/WO_Factory_LoopBackSample:1.0";
    }

    public org.omg.PortableServer.Servant _newInstance() {
        return new WO_Factory_LoopBackSampleObj();
    }
}

//
// コンポーネント初期化クラス(LoopBackInit.java)
//
import jp.co.nec.WebOTX.WOComponent;
import jp.co.nec.WebOTX.WOUserComponent;

public class LoopBackInit implements WOUserComponent
{
    public void init()
    {
        WOComponent.add(new LoopBackSampleObjInfo());
        WOComponent.add(new WO_Factory_LoopBackSampleObjInfo());
    }
}

>mkdir classes

Windows
>javac -d classes *.java sample\*.java
Unix
>javac -d classes *.java sample/*.java

>cd classes
>jar cvf LoopBackSample.jar *.class sample

複雑なIDLの場合のコーディング例(Java)

---- IDLファイル ---- IDLファイル ---- IDLファイル ----
module AAAA {
    module BBBB {
        module CCCC {
            interface DDDD {
                void op1();
            };
        };
    };
};
 
---- 実装部分(DDDDObj.java) ---- 実装部分(DDDDObj.java) ----
package AAAA.BBBB.CCCC;
 
import AAAA.BBBB.CCCC.DDDDPOA;
 
public class DDDDObj extends DDDDPOA {
    public DDDDObj() {
    }

    public void op1() {
    }
}

---- IDLファイル ---- IDLファイル ---- IDLファイル ----
interface AAA {
    struct BBB {
        long ID;
        string NAME;
        short  AGE;
    };

    typedef sequence < BBB > SEQ001;
    void GET_DATA (in SEQ001 inARG, out SEQ001 outARG, inout SEQ001 inoutARG);
};
 
---- 実装部分(AAAObj.java) ---- 実装部分(AAAObj.java) ----
import AAA;
import AAAHelper;
import AAAHolder;
import AAAOperations;
import AAAPOA;
 
public class AAAObj extends AAAPOA {
    public AAAObj() {
    }

    public void GET_DATA(AAAPackage.BBB[] inARG,
                         AAAPackage.SEQ001Holder outARG,
                         AAAPackage.SEQ001Holder inoutARG) {
        int i=0;
        // inARGは値が設定されています。参照のみ可能です
        int inARGlen = inARG.length;
        for(i=0; i < inARGlen; i++) {
            int id = inARG[i].ID;
        }

        // outARGはBBB::SEQ001をnewしてAAAPackage.SEQ001Holder.valueに
        // 設定しなければなりません
        int outARGlen = 100;
        outARG.value = new AAAPackage.BBB[outARGlen];
        for(i=0; i < outARGlen; i++) {
            outARG.value[i] = new AAAPackage.BBB();
            outARG.value[i].ID = 10;
        }

        // inoutARGは値が設定されています。また書き換えもできます
        int inoutARGlen = inoutARG.value.length;
        for(i=0; i < inoutARGlen; i++) {
            inoutARG.value[i].ID = inoutARG.value[i].ID * 2;
        }
    }
}

TIEアプローチを用いたコーディング(Java)

R5形式 
>i2j -tie -i -lstun loopback.idl
>woixj loopback -tie

> /opt/ObjectSpinner/bin/i2j.sh -tie -i -lstun loopback.idl
>woixj loopback -tie

package sample;

import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;

public class LoopBackSampleObj implements LoopBackSampleOperations {
///////////////////////////////^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ここが違います。
    public LoopBackSampleObj() {
    }

    public int LoopBack(java.lang.String inputChar, 
                        org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar;
        return outputChar.value.length();
    }

    public int LowerCase(java.lang.String inputChar, 
                         org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar.toLowerCase();
        return outputChar.value.length();
    }

    public int UpperCase(java.lang.String inputChar, 
                         org.omg.CORBA.StringHolder outputChar) {
        outputChar.value = inputChar.toUpperCase();
        return outputChar.value.length();
    }

    // WO_Base interface
    public void OnTPSAbort(int status) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_ERR, 
                                     "*** OnTPSAbort() called. ***");
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_ERR, 
                                     "    status="+status);
    }

    public void OnTPSDisconnect() {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_INFO, 
                                     "*** OnTPSDisconnect() called. ***");
    }

    public void OnTPSMessageNotified(java.lang.String mes) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_INFO,
                                     "*** OnTPSMessageNotified("+mes+") called. ***");
    }
}

サーバシミュレータによる動作確認(Java)

>java -Dorg.omg.CORBA.ORBClass=jp.co.nec.orb.OSPORB 
      -Dorg.omg.CORBA.ORBSingletonClass=jp.co.nec.orb.OSPORBSingleton 
      ServerSimulator コンポーネント初期化クラス名

>java -Dorg.omg.CORBA.ORBClass=jp.co.nec.orb.OSPORB 
      -Dorg.omg.CORBA.ORBSingletonClass=jp.co.nec.orb.OSPORBSingleton 
      ServerSimulator LoopBackInit -B LoopBackSampleJava=
      corbaname://127.0.0.1#NEC/WebOTX/WO_Default/LoopBackSample/1

実行環境への登録(Java)

常駐オブジェクトの使い方

単一常駐オブジェクトのコーディング方法

import jp.co.nec.WebOTX.WO_PUOObjectListener;
import jp.co.nec.WebOTX.WO_PUOOperationListener;

public class preObjhoo1 implements WO_PUOObjectListener, WO_PUOOperationListener {
    String m_ID;

    public preObjhoo1() {
    }

    public void OnTPSPUOCreateObject() {
       // 生成時に特別な処理を行うときに記述
    }

    public void OnTPSPUOReleaseObject() {
       // 解放時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationStart(String intf, String opname) {
        // オペレーション開始時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationNormal(String intf, String opname) {
        // オペレーション正常終了時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationAbnormal(String intf, String opname, int status) {
        // オペレーション異常終了時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationAbort(String intf, String opname, int status) {
        // オペレーションアボート時に特別な処理を行うときに記述
    }

    // 常駐オブジェクトとしてのオペレーション
    public int set(String ID) {
        m_ID = id;
        return m_ID.length();
    }
}

単一常駐オブジェクトのコーディング方法

public interface jp.co.nec.WebOTX.WO_PUOObjectListener {
    public void OnTPSPUOCreateObject();
    public void OnTPSPUOReleaseObject();
}

public interface jp.co.nec.WebOTX.WO_PUOOperationListener {
    public void OnTPSPUOOperationStart(String intf, String opname);
    public void OnTPSPUOOperationNormal(String intf, String opname);
    public void OnTPSPUOOperationAbnormal(String intf, String opname, int status);
    public void OnTPSPUOOperationAbort(String intf, String opname, int status);
}

複数常駐オブジェクトのコーディング方法

preObjhoo2.java

import jp.co.nec.WebOTX.WO_PUOObjectListenerForPlural;
import jp.co.nec.WebOTX.WO_PUOOperationListenerForPlural;

public class preObjhoo2 implements WO_PUOObjectListenerForPlural, 
                                   WO_PUOOperationListenerForPlural {
    String m_ID;

    public preObjhoo2() {
    }

    public void OnTPSPUOCreateObject(String ident) {
       // 生成時に特別な処理を行うときに記述
    }

    public void OnTPSPUOReleaseObject(String ident) {
       // 解放時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationStart(String ident, String intf, String opname) {
        // オペレーション開始時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationNormal(String ident, String intf, String opname) {
        // オペレーション正常終了時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationAbnormal(String ident, String intf, 
                                          String opname, int status) {
        // オペレーション異常終了時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationAbort(String ident, String intf, 
                                       String opname, int status) {
        // オペレーションアボート時に特別な処理を行うときに記述
    }

    // 常駐オブジェクトとしてのオペレーション
    public int set(String ID) {
        m_ID = id;
        return m_ID.length();
    }
}

preObjhoo3.java
import jp.co.nec.WebOTX.WO_PUOObjectListener;
import jp.co.nec.WebOTX.WO_PUOOperationListener;

public class preObjhoo3 implements WWO_PUOObjectListenerForPlural, 
                                   WO_PUOOperationListenerForPlural {
    int m_len;
    public preObjhoo3() {
    }

    public void OnTPSPUOCreateObject(String ident) {
       // 生成時に特別な処理を行うときに記述
    }

    public void OnTPSPUOReleaseObject() {
       // 解放時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationStart(String ident, String intf, String opname) {
        // オペレーション開始時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationNormal(String ident, String intf, String opname) {
        // オペレーション正常終了時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationAbnormal(String ident, String intf, 
                                          String opname, int status) {
        // オペレーション異常終了時に特別な処理を行うときに記述
    }

    public void OnTPSPUOOperationAbort(String ident, String intf, 
                                       String opname, int status) {
        // オペレーションアボート時に特別な処理を行うときに記述
    }

    // 常駐オブジェクトとしてのオペレーション
    public void set(int len) {
        m_len = len;
    }
}

複数常駐オブジェクトのコールバックについて

public interface jp.co.nec.WebOTX.WO_PUOObjectListenerForPlural {
    public void OnTPSPUOCreateObject(String ident);
    public void OnTPSPUOReleaseObject(String ident);
}

public interface jp.co.nec.WebOTX.WO_PUOOperationListenerForPlural {
    public void OnTPSPUOOperationStart(String ident, String intf, String opname);
    public void OnTPSPUOOperationNormal(String ident, String intf, String opname);
    public void OnTPSPUOOperationAbnormal(String ident, String intf, 
                                          String opname, int status);
    public void OnTPSPUOOperationAbort(String ident, String intf, 
                                       String opname, int status);
}

常駐オブジェクトを用いたサーバアプリケーションの作成方法

import foo.*;
import preObjhoo1;
import preObjhoo2;
import preObjhoo3;
import jp.co.nec.WebOTX.orbsvwpr.*;

public class fooObj extends fooPOA {
    public fooObj() {
    }

    public int op1(java.lang.String ID) {
        preObjhoo1 preobj1;
        preObjhoo2 preobj2;
        preObjhoo3 preobj3;

        // 単一常駐オブジェクトの取得
        preObjhoo1 = (preObjhoo1)WoServerWrapper.TPSGetPrecreatedUsersObject();

        // メソッドの呼び出し(本来ならnullチェックが必要)
        if (preObjhoo1 != null) {
            preObjhoo1.set(ID);
        } else {
            // エラー処理
        }

        // 複数常駐オブジェクトの取得
        try{
            // hoo2とhoo3は運用管理ツールで指定。
            // 大文字小文字を区別するので注意が必要
            preObjhoo2 =
               (preObjhoo2)
                   WoServerWrapper.TPSGetPrecreatedUsersObjectForPlural("hoo2");
            preObjhoo3 =
               (preObjhoo3)
                   WoServerWrapper.TPSGetPrecreatedUsersObjectForPlural("hoo3");
        }catch(Exception e){
            e.printStackTrace();
            return -1;
        }

        // メソッドの呼び出し(例外処理しているので nullチェックは不要)
        return preObjhoo3.set(preObjhoo2.set(ID));
    }
}

共有プロパティの利用方法

共有プロパティ概要

プロパティグループの作成、取得、解放

    ：
import jp.co.nec.WebOTX.WOPropertyGroupManager;
import jp.co.nec.WebOTX.WOPropertyGroup;
import jp.co.nec.WebOTX.WOProperty;
import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;
import propPOA;

public class foo extends propPOA {

    WOPropertyGroupManager pgm = new WOPropertyGroupManager();

    public int Lock() {
        WOPropertyGroup[] pg = new WOPropertyGroup[1];      // オブジェクトを得るため
        int area = WOPropertyGroupManager.WOSP_AREATYPE_HOST; // ホスト内共通
        java.lang.String pgname = "SamplePGName";   // PropertyGroup名

        // プロパティグループの生成
        ong nRet = pgm.TPSCreatePropertyGroup(pgname, area, pg);
        if (nRet < 0) {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                    " Lock(): TPSCreatePropertyGroup() ==> " + nRet);
            return (int)nRet;
        } else {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                    " Lock(): TPSCreatePropertyGroup() ==> " + nRet);
        }

        // ロック(5秒間の待ち合わせあり)を行う
        int waitmode = WOPropertyGroup.WO_PG_WAIT;        // 待ち合わせあり
        int waittime = 5000;                              // 5秒間待ち合わせ(単位ms)

        nRet = pg[0].Lock(waitmode, waittime);
        if (nRet < 0) {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                    " Lock(): Lock() ==> " + nRet);
            return (int)nRet;
        } else {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                    " Lock(): Lock() ==> " + nRet);
        }

        // プロパティの生成
        WOProperty pro[] = new WOProperty[1];
        nRet = pg[0].CreateProperty(pname, pro);
        if (nRet < 0) {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                    " SetValue(): CreateProperty() ==> " + nRet);
            return (int)nRet;
        } else {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                    " SetValue(): CreateProperty() ==> " + nRet);
        }

        // 値の取得
        int[] getvalue = new int[1];
        nRet = pro[0].Get(getvalue);
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     " GetValue(): Get() value ==> " +getvalue[0]);
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     " GetValue(): Get() nRet ==> " + nRet);

        // プロパティグループのアンロック
        nRet = pg[0].Unlock();
        if (nRet != 0) {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     " Unlock(): Unlock() ==> " + nRet);
            return (int)nRet;
        } else {
            WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     " Unlock(): Unlock() ==> " + nRet);
        }
        return (int)nRet;
    }
}

プロパティの生成/取得

値の設定/取得

プロパティグループのロック

WebOTX Transaction Serviceとの連携

共有コンポーネント機能

共有コンポーネントの作成方法

共有コンポーネントの利用方法

共有コンポーネントの登録方法

クライアントアプリケーションについて

非同期トランザクションについて

非同期トランザクションとは

仮想宛先(VD:Vritual Destination)とは

非同期トランザクションの利用方法

初期化/終了関数

コーディング例:
package jp.co.nec.WebOTX.Objectcreator;

import org.omg.CORBA.ORB;
import jp.co.nec.WebOTX.WO_InitTerm;
import jp.co.nec.WebOTX.WebOTX_Information;
import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;

public class InitTerm implements WO_InitTerm {
    public void initialize(ORB orb, WebOTX_Information info) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     "===***=== initialize");
    // 初期化処理
    }

    public void terminate(ORB orb, WebOTX_Information info) {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     "===***=== terminate");
        // 終了処理
    }
}

(例)
((org.omg.CORBA_2_3.ORB)orb).register_value_factory(NamesHelper.id(), new NamesValueFactory_impl());

オブジェクト生成/消滅のコールバックインタフェースについて

jp.co.nec.WebOTX.WO_ObjectListenerインタフェース
public interface jp.co.nec.WebOTX.WO_ObjectListener {
    public void OnTPSCreateObject();
    public void OnTPSReleaseObject();
}

アプリケーション初期プロセスについて

アプリケーション初期プロセス用インタフェース

利用可能なサーバAPIについて

障害発生時の処理について

例外発生時のコールバックについて

クライアントとのセッション切断について

サーバプロセスメッセージ通知について

データベースオブジェクトの登録と自動ロールバックについて

import jp.co.nec.WebOTX.WebOTX_DB;
import jp.co.nec.WebOTX.orbsvwpr.WoServerWrapper;

public class MyDB implements WebOTX_DB {
    public MyDB () {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     " **** called MyDB.");
        // データベース初期化処理
    }

    public void rollback() {
        WoServerWrapper.TPSUserTrace(WoServerWrapper.LOG_DEBUG,
                                     " **** called MyDB.rollback()");
        // データベースロールバック処理 (異常終了時に呼ばれる)
    }
}

1.2.1.4. Java言語を用いたクライアントアプリケーションの作成

Javaクライアントアプリケーションの作成の流れ

開発環境の設定

UNIX

> set path=( $path /opt/ObjectSpinner/bin )
> set path=( $path /opt/WebOTX/dev/command )
> setenv LD_LIBRARY_PATH> /opt/ObjectSpinner/lib:/opt/WebOTX/dev/lib
> setenv CLASSPATH /opt/WebOTX/modules/jsocks.jar
> setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/modules/wo-orb110.jar
> setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/modules/omgorb110.jar
> setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/dev/javalib/WOTXTRM.jar
> setenv CLASSPATH ${CLASSPATH}:/opt/WebOTX/dev/javalib/WOTXBS90.jar

Windows

IDLファイルの作成とコンパイル(Java)

クライアントアプリケーションの作成方法(Java)

ファクトリを使用しない場合

//
// クライアント(LoopBackSampleClient.java)
//
import org.omg.CosNaming.*;
import sample.*;

public class LoopBackSampleClient {
    private org.omg.CORBA.ORB orb = null;
    private LoopBackSample serverobj = null;

    public static void main(String args[]) {
        LoopBackSampleClient ap = new LoopBackSampleClient();

        if (ap.init(args) == false) {
            System.exit(1);
        }

        String org = "AbCdEfGhIj";
        String strRet;

        // call loopback 
        strRet = ap.call_LoopBack(org);
        if (strRet != null && strRet.equals(org)) {
            System.out.println("LoopBack OK!");
            System.out.println(" org=" + org);
            System.out.println(" res=" + strRet);
        } else {
            System.out.println("LoopBack NG!");

            if (strRet != null) {
                System.out.println(" org=" + org);
                System.out.println(" res=" + strRet);
            } else {
                System.out.println(" res=null");
            }

            System.exit(1);
        }

        // call lowercase 
        strRet = ap.call_LowerCase(org);
        if (strRet != null) {
            System.out.println("LowerCase OK!");
            System.out.println(" org=" + org);
            System.out.println(" res=" + strRet);
        } else {
            System.out.println("LowerCase NG!");
            System.out.println(" org=" + org);
            System.out.println(" res=null");
            System.exit(1);
        }

        // call uppercase 
        strRet = ap.call_UpperCase(org);
        if (strRet != null) {
            System.out.println("UpperCase OK!");
            System.out.println("  org=" + org);
            System.out.println("  res=" + strRet);
        } else {
            System.out.println("UpperCase NG!");
            System.out.println("  org=" + org);
            System.out.println("  res=null");
            System.exit(1);
        }

        ap.destroy();
    }

    public boolean init(String args[]) {
        try {
            orb = org.omg.CORBA.ORB.init(args, null);

            // get naming service object reference
            org.omg.CORBA.Object nsobj = null;
            NamingContext ns = null;
            nsobj = orb.resolve_initial_references("NameService");
            ns = NamingContextHelper.narrow(nsobj);

            // make name path of server object reference
            NameComponent ncseq[] = { 
                new NameComponent("NEC", ""),
                new NameComponent("WebOTX", ""),
                new NameComponent("WO_Default", ""),
                new NameComponent("sample", ""),
                new NameComponent("LoopBackSample", ""),
                new NameComponent("1", "")
            };

            serverobj = LoopBackSampleHelper.narrow(ns.resolve(ncseq));
            if (serverobj == null) {
                System.out.println("Server object is null.");
            }

            return true;
        } catch (Exception e) {
            System.out.println("ERROR : " + e) ;
            e.printStackTrace(System.out);
            return false;
        }
    }

    public void destroy() {
        if (serverobj != null) {
            serverobj = null;
        }
        if (orb != null) {
            try {
                // コネクション切断 (Object BrokerローカルAPI)
                jp.co.nec.orb.ConnectionManager.close_all_client_connections();
                boolean wait_for_completion = true;
                orb.shutdown(wait_for_completion); 
            } catch(Exception e) {
                System.out.println("ERROR : " + e) ;
                e.printStackTrace(System.out);
            }
        }
    }

    public String call_LoopBack(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.LoopBack(in,outputChar);
            returnoutputChar.value;
        }catch(Exception e){
            System.out.println("ERROR:" + e);
            e.printStackTrace(System.out);
            return null;
        }
    }

    public String call_LowerCase(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.LowerCase(in, outputChar);
            return outputChar.value;
        }catch(Exception e){
            System.out.println("ERROR:" + e);
            e.printStackTrace(System.out);
            return null;
        }
    }

    public String call_UpperCase(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.UpperCase(in, outputChar);
            return outputChar.value;
        }catch(Exception e){
            System.out.println("ERROR:" + e);
            e.printStackTrace(System.out);
            return null;
        }
    }
}

>mkdir classes

Windows
>javac -d classes *.java sample\*.java
Unix
>javac -d classes *.java sample/*.java

>cd classes
>jar cvf LoopBackSampleClient.jar *.class sample

ファクトリを使用する場合

//
// クライアント(LoopBackSampleClient.java)
//
import org.omg.CosNaming.*;
import sample.*;

public class LoopBackSampleClient
{
    private org.omg.CORBA.ORB orb = null;
    private WO_Factory_LoopBackSample factoryobj = null;
    private LoopBackSample serverobj = null;

    public static void main(String args[]) {
        LoopBackSampleClient ap = new LoopBackSampleClient();
 
        if (ap.init(args) == false) {
            System.exit(1);
        }
 
        String org = "AbCdEfGhIj";
        String strRet;
 
        // call loopback 
        strRet = ap.call_LoopBack(org);
        if (strRet != null && strRet.equals(org)) {
            System.out.println("LoopBack OK!");
            System.out.println("  org=" + org);
            System.out.println("  res=" + strRet);
        } else {
            System.out.println("LoopBack NG!");
            if (strRet != null) {
                System.out.println("  org=" + org);
                System.out.println("  res=" + strRet);
            } else {
                System.out.println("  res=null");
            }
            System.exit(1);
        }
        
        // call lowercase 
        strRet = ap.call_LowerCase(org);
        if (strRet != null) {
            System.out.println("LowerCase OK!");
            System.out.println("  org=" + org);
            System.out.println("  res=" + strRet);
        } else {
            System.out.println("LowerCase NG!");
            System.out.println("  org=" + org);
            System.out.println("  res=null");
            System.exit(1);
        }

        // call uppercase 
        strRet = ap.call_UpperCase(org);
        if (strRet != null) {
            System.out.println("UpperCase OK!");
            System.out.println("  org=" + org);
            System.out.println("  res=" + strRet);
        } else {
            System.out.println("UpperCase NG!");
            System.out.println("  org=" + org);
            System.out.println("  res=null");
            System.exit(1);
        }
        ap.destroy();
    }

    public boolean init(String args[]) {
        try {
            orb = org.omg.CORBA.ORB.init(args, null);

            // get naming service object reference
            org.omg.CORBA.Object nsobj = null;
            NamingContext ns = null;
            nsobj = orb.resolve_initial_references("NameService");
            ns = NamingContextHelper.narrow(nsobj);

            // make name path of server object reference
            NameComponent ncseq[] = { 
                new NameComponent("NEC", ""),
                new NameComponent("WebOTX", ""),
                new NameComponent("WO_Default", ""),
                new NameComponent("sample", ""),
                new NameComponent("WO_Factory_LoopBackSample", ""),
                new NameComponent("1", "")
            };

            factoryobj = WO_Factory_LoopBackSampleHelper.narrow(ns.resolve(ncseq));

            if (factoryobj == null) {
                System.out.println("Factory object is null.");
            }

            serverobj = factoryobj.CreateServerObject();
            if (serverobj == null) {
                System.out.println("Server object is null.");
            }

            return true;
        } catch (Exception e) {
            System.out.println("ERROR : " + e) ;
            e.printStackTrace(System.out);
            return false;
        }
    }

    public void destroy() {
        if (factoryobj != null && serverobj != null) {
            factoryobj.ReleaseServerObject(serverobj);
            serverobj = null;
            factoryobj = null;
        }

        if (orb != null) {
            try {
                // コネクション切断 (Object BrokerローカルAPI)
                jp.co.nec.orb.ConnectionManager.close_all_client_connections();
                boolean wait_for_completion = true;
                orb.shutdown(wait_for_completion); 
            } catch(Exception e) {
                System.out.println("ERROR : " + e) ;
                e.printStackTrace(System.out);
            }
        }
    }

    public String call_LoopBack(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.LoopBack(in,outputChar);
            return outputChar.value;
        } catch (Exception e) {
             System.out.println("ERROR : " + e) ;
             e.printStackTrace(System.out);
             return null;
        }
    }

    public String call_LowerCase(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.LowerCase(in,outputChar);
            return outputChar.value;
        } catch (Exception e) {
             System.out.println("ERROR : " + e) ;
             e.printStackTrace(System.out);
             return null;
        }
    }

    public String call_UpperCase(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.UpperCase(in,outputChar);
            return outputChar.value;
        } catch (Exception e) {
             System.out.println("ERROR : " + e) ;
             e.printStackTrace(System.out);
             return null;
        }
    }
}

> mkdir classes

Windows
> javac -d classes *.java sample\*.java
Unix
> javac -d classes *.java sample/*.java

> cd classes
> jar cvf LoopBackSampleClient.jar *.class

複雑なIDLの場合のコーディング例(Java)

Javaのクライアント管理ライブラリ

//
// クライアント(LoopBackSampleClient.java)
//
import org.omg.CosNaming.*;
import sample.*;
import jp.co.nec.WebOTX.TerminalManager;

public class LoopBackSampleClient {
    private org.omg.CORBA.ORB orb = null;
    private WO_Factory_LoopBackSample factoryobj = null;
    private LoopBackSample serverobj = null;
    private TerminalManager tm = new TerminalManager();

    public static void main(String args[]) {
        LoopBackSampleClient ap = new LoopBackSampleClient();

        if (ap.init(args) == false) {
            System.exit(1);
        }

        String org = "AbCdEfGhIj";
        String strRet;

        // call loopback 
        strRet = ap.call_LoopBack(org);
        if (strRet != null && strRet.equals(org)) {
            System.out.println("LoopBack OK!");
            System.out.println("     org=" + org);
            System.out.println("     res=" + strRet);
        } else {
            System.out.println("LoopBack NG!");

            if (strRet != null) {
                System.out.println("     org=" + org);
                System.out.println("     res=" + strRet);
            } else {
                System.out.println("     res=null");
            }

            System.exit(1);
        }

        // call lowercase 
        strRet = ap.call_LowerCase(org);
        if (strRet != null) {
            System.out.println("LowerCase OK!");
            System.out.println("     org=" + org);
            System.out.println("     res=" + strRet);
        } else {
            System.out.println("LowerCase NG!");
            System.out.println("     org=" + org);
            System.out.println("     res=null");
            System.exit(1);
        }

        // call uppercase 
        strRet = ap.call_UpperCase(org);
        if (strRet != null) {
            System.out.println("UpperCase OK!");
            System.out.println("     org=" + org);
            System.out.println("     res=" + strRet);
        } else {
            System.out.println("UpperCase NG!");
            System.out.println("     org=" + org);
            System.out.println("     res=null");
            System.exit(1);
        }
        ap.destroy();
    }

    public boolean init(String args[]) {
        try {
            orb = org.omg.CORBA.ORB.init(args, null);

            // get naming service object reference
            org.omg.CORBA.Object nsobj = null;
            NamingContext ns = null;
            nsobj = orb.resolve_initial_references("NameService");
            ns = NamingContextHelper.narrow(nsobj);

            // make name path of server object reference
            NameComponent ncseq[] = { 
                new NameComponent("NEC", ""),
                new NameComponent("WebOTX", ""),
                new NameComponent("WO_Default", ""),
                new NameComponent("sample", ""),
                new NameComponent("WO_Factory_LoopBackSample", ""),
                new NameComponent("1", "")
            };

            factoryobj = WO_Factory_LoopBackSampleHelper.narrow(ns.resolve(ncseq));
            if (factoryobj == null) {
                System.out.println("Factory object is null.");
            }

            serverobj = factoryobj.CreateServerObject();
            if (serverobj == null) {
                System.out.println("Server object is null.");
            }

            tm.SetFactoryObject(orb, factoryobj);
            tm.SetMessageType(TerminalManager.TM_MESSAGE_SYSTEMOUT);

            return true;
        } catch (Exception e) {
            System.out.println("ERROR : " + e) ;
            e.printStackTrace(System.out);
            return false;
        }
    }

    public void destroy() {
        if (factoryobj != null && serverobj != null) {
            factoryobj.ReleaseServerObject(serverobj);
            serverobj = null;
            factoryobj = null;
        }

        tm.Term();

        tm = null;
        if (orb != null) {
            try {
                // コネクション切断 (Object BrokerローカルAPI)
                jp.co.nec.orb.ConnectionManager.close_all_client_connections();

                boolean wait_for_completion = true;
                orb.shutdown(wait_for_completion); 
            } catch(Exception e) {
                System.out.println("ERROR : " + e) ;
                e.printStackTrace(System.out);
            }
        }
    }

    public String call_LoopBack(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.LoopBack(in,outputChar);

            return outputChar.value;
        } catch (Exception e) {
            System.out.println("ERROR : " + e) ;
            e.printStackTrace(System.out);
            return null;
        }
    }

    public String call_LowerCase(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.LowerCase(in,outputChar);

            return outputChar.value;
        } catch (Exception e) {
            System.out.println("ERROR : " + e) ;
            e.printStackTrace(System.out);

            return null;
        }
    }

    public String call_UpperCase(String in) {
        try{
            org.omg.CORBA.StringHolder outputChar = new org.omg.CORBA.StringHolder();
            serverobj.UpperCase(in,outputChar);

            return outputChar.value;
        } catch (Exception e) {
            System.out.println("ERROR : " + e) ;
            e.printStackTrace(System.out);
            return null;
        }
    }
}

ORBのプロパティ定義

例外処理について

1.2.1.5. C++言語を用いたサーバアプリケーションの作成

C++サーバアプリケーションの作成の流れ

開発環境の設定

UNIX

   :
set path=( $path /opt/ObjectSpinner/bin )
set path=( $path /opt/WebOTX/dev/command )
   :
setenv LD_LIBRARY_PATH /opt/ObjectSpinner/lib: \
                       /opt/ObjectSpinner/namespace/lib: \
                       /opt/WebOTX/dev/lib
   :

Windows(Intel x86)

Windows(Intel 64)

IDLファイルの作成とコンパイル(C++)

R5形式(ファクトリを使用しない場合)

1:  module sample
2:  {
3:       interface LoopBackSample : WO_Base 
4:                        // (サンプルではWO_Baseからの派生はありません)
5:       {
6:            long LoopBack(in string inputChar, out string outputChar);
7:            long LowerCase(in string inputChar, out string outputChar);
8:            long UpperCase(in string inputChar, out string outputChar);
9:       };
10: };

i2cc -i -Xdii -lstub <IDLファイル名> 
     ^^ ^^^^^ ^^^^^^       (woigenxx とは異なり、"loopback.idl"のように.idlも必要です)
      |    |     +-----ローカルスタブを使用。非同期VD呼び出しには必須のオプションです。
      |    +-----------フックが使用可能になります。
      |                非同期VD呼び出しには必須のオプションです。
      +----------------ifファイルの生成を行います。
                       WebOTXに登録するために必須のオプションです。

i2cc -i -Xdii -lstub -E <IDLファイル名> 
     ^^ ^^^^^ ^^^^^^ ^^    (woigenxx とは異なり、"loopback.idl"のように.idlも必要です)
      |    |     |    +--スタブとスケルトンを__declspec(dllexport)可能にします。
      |    |     +-------ローカルスタブを使用。
      |    |             非同期VD呼び出しには必須のオプションです
      |    +-------------フックが使用可能になります。
      |                  非同期VD呼び出しには必須のオプションです
      +------------------ifファイルの生成を行います。
                         WebOTXに登録するために必須のオプションです。

i2cc -i -Xdii -lstub -Rwobase.idl <IDLファイル名> (woigenxx とは異なり、
     ^^ ^^^^^ ^^^^^^ ^^^^^^^^^^^^                  "loopback.idl"のように.idlも必要です)
      |    |     |       +--wobase.idl を参照します。
      |    |     |          WO_Baseを使用するために必須のオプションです。
      |    |     +----------ローカルスタブを使用。
      |    |                非同期VD呼び出しには必須のオプションです。
      |    +------------フックが使用可能になります。
      |                 非同期VD呼び出しには必須のオプションです。
      +-----------------ifファイルの生成を行います。
                        WebOTXに登録するために必須のオプションです。

R5形式(ファクトリを使用する場合)

1:  module sample
2:  {
3:      interface LoopBackSample : WO_Base 
4:                         //（サンプルではWO_Baseからの派生はありません)
5:      {
6:          long LoopBack(in string inputChar, out string outputChar);
7:          long LowerCase(in string inputChar, out string outputChar);
8:          long UpperCase(in string inputChar, out string outputChar);
9:      };
10
11:     interface WO_Factory_LoopBackSample : WO_BaseFactory 
12:                        // (サンプルではWO_BaseFactoryからの派生はありません)
13:     {
14:         LoopBackSample CreateServerObject();
15:         void ReleaseServerObject(in LoopBackSample obj);
16:     };
17: };
 

  i2cc -i -Xdii -lstub <IDLファイル名> 
       ^^ ^^^^^ ^^^^^^       (woigenxx とは異なり、"loopback.idl"のように.idlも必要です)
        |    |     +-----ローカルスタブを使用。
        |    |           非同期VD呼び出しには必須のオプションです
        |    +-----------フックが使用可能になります。
        |                非同期VD呼び出しには必須のオプションです
        +----------------ifファイルの生成を行います。
                         WebOTXに登録するために必須のオプションです。

  i2cc -i -Xdii -lstub -E <IDLファイル名> 
       ^^ ^^^^^ ^^^^^^ ^^    (woigenxx とは異なり、"loopback.idl"のように.idlも必要です)
        |    |     |    +--スタブとスケルトンを__declspec(dllexport)可能にします。
        |    |     +-------ローカルスタブを使用。
        |    |             非同期VD呼び出しには必須のオプションです。
        |    +-------------フックが使用可能になります。
        |                  非同期VD呼び出しには必須のオプションです。
        +------------------ifファイルの生成を行います。
                           WebOTXに登録するために必須のオプションです。

  i2cc -i -Xdii -lstub -Rwobase.idl <IDLファイル名> (woigenxx とは異なり、
       ^^ ^^^^^ ^^^^^^ ^^^^^^^^^^^^                  "loopback.idl"のように.idlも必要です)
        |    |     |       +---wobase.idl を参照します。
        |    |                 WO_Baseを使用するために必須のオプションです。
        |    |     +-----------ローカルスタブを使用。
        |    |                 非同期VD呼び出しには必須のオプションです。
        |    +-----------------フックが使用可能になります。
        |                      非同期VD呼び出しには必須のオプションです。
        +----------------------ifファイルの生成を行います。
                               WebOTXに登録するために必須のオプションです。

サーバント(実装部分)のコーディング(C++)

R5形式

R5形式におけるUNIXのMakefileについて

IDLコンパイラが生成したファイルを使用して、サーバアプリケーションの共有ライブラリを作成します。 必要なファイルは、以下のほかに利用者が作成した実装コードとヘッダファイル(サンプルではloopback_i.hとloopback_i.C)です。

コンパイル時のオプション

リンク時のオプション

     -DOB_<IDLファイル名の大文字>CMN_EXPORT -DOB_<IDLファイル名の大文字>IMP_EXPORT
      ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
                           |                 +-------スケルトンをdllexportする
                           +-------------------------スタブをdllexportする

#-----------------------------------------------------------------------
#  for HP-UX(Itanium 2)
#-----------------------------------------------------------------------

CC      = /opt/aCC/bin/aCC
I2CC    = /opt/ObjectSpinner/bin/i2cc
IDLFLAGS= -i -Xdii -lstub -Rwobase.idl
BASENAME= loopback
LIBS    =
OBJS    = ${BASENAME}cmn.o \
          ${BASENAME}imp.o \
          ${BASENAME}_i.o
INC     = -I/opt/WebOTX/dev/include \
          -I/opt/ObjectSpinner/namespace/include
LDFLAGS = -b -mt -Wl,-E +DD64
C++FLAGS= +Z -mt -DOB_HPUX_KT +DD64
TARGET  = ${BASENAME}.so
all : ${OBJS} ${TARGET}
${TARGET} : ${OBJS}
       ${CC} -o $@ ${C++FLAGS} ${LDFLAGS} ${OBJS} ${LIBS}
${BASENAME}cmn.o :      ${BASENAME}cmn.C ${BASENAME}.h
${BASENAME}imp.o :      ${BASENAME}imp.C ${BASENAME}.h
${BASENAME}_i.o :       ${BASENAME}_i.C ${BASENAME}.h ${BASENAME}_i.h

.C.o :
       ${CC} ${INC} ${C++FLAGS} -c $*.C
idl:
       ${I2CC} ${IDLFLAGS} ${BASENAME}.idl
clean:
       /bin/rm -rf *.o ${TARGET}

#-----------------------------------------------------------------------
#  for Linux
#-----------------------------------------------------------------------

CC      = /usr/bin/g++
I2CC    = /opt/ObjectSpinner/bin/i2cc
IDLFLAGS= -i -Xdii -lstub -Rwobase.idl
BASENAME= loopback
LIBS    =
OBJS    = ${BASENAME}cmn.o \
          ${BASENAME}imp.o \
          ${BASENAME}_i.o
INC     = -I/opt/WebOTX/dev/include \
          -I/opt/ObjectSpinner/namespace/include
LDFLAGS = -shared
C++FLAGS= -D_REENTRANT -D_GNU_SOURCE -fPIC
TARGET  = ${BASENAME}.so
all : ${OBJS} ${TARGET}
${TARGET} : ${OBJS}
       ${CC} -o $@ ${C++FLAGS} ${LDFLAGS} ${OBJS} ${LIBS}
${BASENAME}cmn.o :      ${BASENAME}cmn.C ${BASENAME}.h
${BASENAME}imp.o :      ${BASENAME}imp.C ${BASENAME}.h
${BASENAME}_i.o :       ${BASENAME}_i.C ${BASENAME}_i.h

.C.o :
       ${CC} ${INC} ${C++FLAGS} -c $*.C
idl:
       ${I2CC} ${IDLFLAGS} ${BASENAME}.idl
clean:
       /bin/rm -rf *.o ${TARGET}

#-----------------------------------------------------------------------
#  for SUN Solaris 10
#-----------------------------------------------------------------------

CC      = /opt/SUNWspro/bin/CC
I2CC    = /opt/ObjectSpinner/bin/i2cc
IDLFLAGS= -i -Xdii -lstub -Rwobase.idl
BASENAME= loopback
LIBS    =
OBJS    = ${BASENAME}cmn.o \
          ${BASENAME}imp.o \
          ${BASENAME}_i.o
INC     = -I/opt/WebOTX/dev/include \
          -I/opt/ObjectSpinner/namespace/include
LDFLAGS = -G -mt -m64
C++FLAGS= -D_REENTRANT -mt -m64 -xcode=pic32
TARGET  = ${BASENAME}.so
all : ${OBJS} ${TARGET}
${TARGET} : ${OBJS}
       ${CC} -o $@ ${C++FLAGS} ${LDFLAGS} ${OBJS} ${LIBS}
${BASENAME}cmn.o :      ${BASENAME}cmn.C ${BASENAME}.h
${BASENAME}imp.o :      ${BASENAME}imp.C ${BASENAME}.h
${BASENAME}_i.o :       ${BASENAME}_i.C ${BASENAME}_i.h

.C.o :
       ${CC} ${INC} ${C++FLAGS} -c $*.C
idl:
       ${I2CC} ${IDLFLAGS} ${BASENAME}.idl
clean:
       /bin/rm -rf *.o ${TARGET}

R5形式　Windows(Intel x86)のプロジェクト設定について

     OB_<IDLファイル名の大文字>CMN_EXPORT,OB_<IDLファイル名の大文字>IMP_EXPORT
      ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
                           |                        +-------スケルトンをdllexportする
                           +--------------------------------スタブをdllexportする

R5形式　Windows(Intel 64)のMakefile(プロジェクト設定)について

/D "OB_<IDLファイル名の大文字>CMN_EXPORT" /D "OB_<IDLファイル名の大文字>IMP_EXPORT"
      ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
                           |                    +----------------スケルトンをdllexportする
                           +-------------------------------------スタブをdllexportする

#-----------------------------------------------------------------------
#  for Windows(Intel 64)
#-----------------------------------------------------------------------

!include 

OUTDIR=.\Release
INTDIR=.\Release
# Begin Custom Macros
OutDir=.\Release
# End Custom Macros

OTXDIR=C:\Program Files\NEC\WebOTX
OSPIDIR=$(OTXDIR)\ObjectBroker

ALL : "$(OUTDIR)\$(BASENAME).dll"

"$(OUTDIR)" :
    if not exist "$(OUTDIR)/$(NULL)" mkdir "$(OUTDIR)"

CPP=cl.exe
CPP_PROJ=/nologo /MD /W3 /EHsc /O2 \
    /I "$(OSPIDIR)\namespace\include" \
    /I "$(OTXDIR)\dev\include" \
    /D "WIN32" /D "WIN64" /D "NDEBUG" /D "_WINDOWS" /D "_MBCS" /D "_USRDLL" \
    /Fo"$(INTDIR)\\" /Fd"$(INTDIR)\\" /c 

.c{$(INTDIR)}.obj::
   $(CPP) @<<

   $(CPP_PROJ) $< 
<<

.cpp{$(INTDIR)}.obj::
   $(CPP) @<<
   $(CPP_PROJ) $< 
<<

.cxx{$(INTDIR)}.obj::
   $(CPP) @<<
   $(CPP_PROJ) $< 

<<

LINK=link.exe
LINK_FLAGS=nosp9011.lib nOrbW971.lib nWOBS97.lib \
    /nologo /dll /incremental:no /pdb:"$(OUTDIR)\$(BASENAME).pdb" \
    /machine:AMD64 /out:"$(OUTDIR)\$(BASENAME).dll" \
    /implib:"$(OUTDIR)\$(BASENAME).lib" \
    /libpath:"$(OSPIDIR)\namespace\lib" \
    /libpath:"$(OTXDIR)\dev\lib" 

LINK_OBJS= \
    "$(INTDIR)\$(BASENAME)_i.obj" \
    "$(INTDIR)\$(BASENAME)cmn.obj" \
    "$(INTDIR)\$(BASENAME)imp.obj"

"$(OUTDIR)\$(BASENAME).dll" : "$(OUTDIR)" $(DEF_FILE) $(LINK_OBJS)
    $(LINK) @<<

  $(LINK_FLAGS) $(LINK_OBJS)
<<

SOURCE=.\$(BASENAME)_i.cpp
"$(INTDIR)\$(BASENAME)_i.obj" : $(SOURCE) "$(INTDIR)"

SOURCE=.\$(BASENAME)cmn.cpp
"$(INTDIR)\$(BASENAME)cmn.obj" : $(SOURCE) "$(INTDIR)"

SOURCE=.\$(BASENAME)imp.cpp
"$(INTDIR)\$(BASENAME)imp.obj" : $(SOURCE) "$(INTDIR)"

R5形式　コーディング(ファクトリを使用しない場合)

woixcpp <ifファイル名>  [-options]　(拡張子ifは不要)
使用例: woixcpp loopback

// loopback_i.h //
// loopback_i.h //
#ifndef LOOPBACK_I_H
#define LOOPBACK_I_H
#include "loopback.h"

namespace sample
{
// 実装クラスの定義
class LoopBackSample_i : public virtual POA_sample::LoopBackSample
{
public:
    // constructor
    LoopBackSample_i();
    // destructor
    virtual ~LoopBackSample_i();
public:
    CORBA::Long LoopBack(
     const char* inputChar,
char*& outputChar,
           CORBA::Environment& _env = Ob_default_environment());
    CORBA::Long LowerCase(
           const char* inputChar,
char*& outputChar,
           CORBA::Environment& _env = Ob_default_environment());
    CORBA::Long UpperCase(
           const char* inputChar,
char*& outputChar,
           CORBA::Environment& _env = Ob_default_environment());
    void OnTPSAbort(
           CORBA::Long status,
CORBA::Environment& _env = Ob_default_environment());
    void OnTPSDisconnect(
           CORBA::Environment& _env = Ob_default_environment());
    void OnTPSMessageNotified(
           const char* mes,
           CORBA::Environment& _env = Ob_default_environment());
};
};
//////////////////////////////////////////////////////
// 実装情報の定義
class loopbackCallback_i : public virtual WebOTX::WOServantCallback
{
public:
       loopbackCallback_i() {}
       const char* _name();
       const char* _id();
       PortableServer::Servant _newInstance();
       void _deleteInstance(PortableServer::Servant servant);
};
#endif

//loopback_i.C
#include "orb.h"
#include "wotxexps.h"
#include "loopback.h"
#include "loopback_i.h"
#include <string.h>
#include <ctype.h>

// constructor
sample::LoopBackSample_i::LoopBackSample_i()
{
}
// destructor
sample::LoopBackSample_i::~LoopBackSample_i()
{
}
CORBA::Long sample::LoopBackSample_i::LoopBack(
           const char* inputChar,
           char*& outputChar,
           CORBA::Environment& _env)
{
    outputChar = CORBA::string_dup(inputChar);
    return strlen(outputChar);
}
CORBA::Long sample::LoopBackSample_i::LowerCase(
           const char* inputChar,
           char*& outputChar,
           CORBA::Environment& _env)
{
    int len = strlen(inputChar);
    char* tmpstring = new char[len+1];
    for (int i = 0; i < len && inputChar[i] != '\n'; i++)
        tmpstring[i] = tolower((char)inputChar[i]);
    tmpstring[len] = '\0';
    outputChar = CORBA::string_dup((const char*)tmpstring);
    delete[] tmpstring;
    return len;
}
CORBA::Long sample::LoopBackSample_i::UpperCase(
           const char* inputChar,
           char*& outputChar,
           CORBA::Environment& _env)
{
    int len = strlen(inputChar);
    char* tmpstring = new char[len+1];
    for (int i = 0; i < len && inputChar[i] != '\n'; i++)
        tmpstring[i] = toupper((char)inputChar[i]);
    tmpstring[len] = '\0';
    outputChar = CORBA::string_dup((const char*)tmpstring);
    delete[] tmpstring;
    return len;
}
void sample::LoopBackSample_i::OnTPSAbort(
           CORBA::Long status,
           CORBA::Environment& _env)
{
    char buf[256];
    sprintf(buf, "Called OnTPSAbort.");
    TPSUserTrace(LOG_ERR, buf);
    // Abort時の処理を記述
}
void sample::LoopBackSample_i::OnTPSDisconnect(
           CORBA::Environment& _env)
{
    char buf[256];
    sprintf(buf, "Called OnTPSDisconnect");
    TPSUserTrace(LOG_ERR, buf);
    // クライアント切断時の処理を記述
}
void sample::LoopBackSample_i::OnTPSMessageNotified(
    const char* mes,
    CORBA::Environment& _env)
{
    // フェールオーバ時の処理を記述
}
//////////////////////////////////////////////////////
// コンポーネント初期化関数
#ifdef              _WINDOWS
#define            LOOPBACKEXPORT  __declspec(dllexport)
#else
#define            LOOPBACKEXPORT
#endif
extern "C" LOOPBACKEXPORT void loopbackinit();
//                             ^^^^^^^^^^^^これがコンポーネント初期化関数になります
extern "C" LOOPBACKEXPORT void loopbackinit()
{
//      実装情報を登録します
        WebOTX::WOComponent::add(new loopbackCallback_i);
}
//////////////////////////////////////////////////////
// 実装情報の設定部分
const char* loopbackCallback_i::_name()
{
       return (const char*)"loopback";
}
const char* loopbackCallback_i::_id()
{
       return (const char*)"IDL:sample/LoopBackSample:1.0";
}
PortableServer::Servant loopbackCallback_i::_newInstance()
{
    sample::LoopBackSample_i* iobj = new sample::LoopBackSample_i;
    return iobj;
}
void loopbackCallback_i::_deleteInstance(PortableServer::Servant servant)
{
       delete servant;
}

コンパイル中...
U:\TestAPcl\loopbackcmn.cpp(980) : fatal error C1010: 
プリコンパイル済みヘッダーの検索中に予期しない EOF を検出しました。

R5形式　コーディング(ファクトリを使用する場合)

woixcpp <ifファイル名>  [-options]　(拡張子ifは不要)
使用例: woixcpp loopback

// loopback_i.h //
#ifndef LOOPBACK_I_H
#define LOOPBACK_I_H
#include "loopback.h"

namespace sample
{
// 実装クラスの定義
class LoopBackSample_i : public virtual POA_sample::LoopBackSample
{
public:
    // constructor
    LoopBackSample_i();
    // destructor
    virtual ~LoopBackSample_i();
public:
    CORBA::Long LoopBack(
              const char* inputChar,
char*& outputChar,
              CORBA::Environment& _env = Ob_default_environment());
    CORBA::Long LowerCase(
              const char* inputChar,
char*& outputChar,
              CORBA::Environment& _env = Ob_default_environment());
    CORBA::Long UpperCase(
              const char* inputChar,
char*& outputChar,
              CORBA::Environment& _env = Ob_default_environment());
    void OnTPSAbort(
              CORBA::Long status,
CORBA::Environment& _env = Ob_default_environment());
    void OnTPSDisconnect(
              CORBA::Environment& _env = Ob_default_environment());
    void OnTPSMessageNotified(
              const char* mes,
              CORBA::Environment& _env = Ob_default_environment());
};
class WO_Factory_LoopBackSample_i : public virtual POA_sample
                                  ::WO_Factory_LoopBackSample
{
public:
    // constructor
    WO_Factory_LoopBackSample_i();
    // destructor
    virtual ~WO_Factory_LoopBackSample_i();
public:
    LoopBackSample_ptr CreateServerObject(
              CORBA::Environment& _env = Ob_default_environment());
    void ReleaseServerObject(
              LoopBackSample_ptr obj,
              CORBA::Environment& _env = Ob_default_environment());
};
};
//////////////////////////////////////////////////////
// 実装情報の定義
class loopbackCallback_i : public virtual WebOTX::WOServantCallback
{
public:
    loopbackCallback_i() {}
    const char* _name();
    const char* _id();
    PortableServer::Servant _newInstance();
    void _deleteInstance(PortableServer::Servant servant);
};
class WO_Factory_loopbackCallback_i : public virtual WebOTX::WOServantCallback
{
public:
    WO_Factory_loopbackCallback_i() {}
    const char* _name();
    const char* _id();
    PortableServer::Servant _newInstance();
    void _deleteInstance(PortableServer::Servant servant);
};
#endif

//loopback_i.C
//loopback_i.C
#include "orb.h"
#include "wotxexps.h"
#include "loopback.h"
#include "loopback_i.h"
#include <string.h>
#include <ctype.h>

// constructor
sample::LoopBackSample_i::LoopBackSample_i()
{
}
// destructor
sample::LoopBackSample_i::~LoopBackSample_i()
{
}
CORBA::Long sample::LoopBackSample_i::LoopBack(
           const char* inputChar,
           char*& outputChar,
           CORBA::Environment& _env)
{
    outputChar = CORBA::string_dup(inputChar);
    return strlen(outputChar);
}
CORBA::Long sample::LoopBackSample_i::LowerCase(
           const char* inputChar,
           char*& outputChar,
           CORBA::Environment& _env)
{
    int len = strlen(inputChar);
    char* tmpstring = new char[len+1];
    for (int i = 0; i < len && inputChar[i] != '\n'; i++)
        tmpstring[i] = tolower((char)inputChar[i]);
    tmpstring[len] = '\0';
    outputChar = CORBA::string_dup((const char*)tmpstring);
    delete[] tmpstring;
    return len;
}
CORBA::Long sample::LoopBackSample_i::UpperCase(
           const char* inputChar,
           char*& outputChar,
           CORBA::Environment& _env)
{
    int len = strlen(inputChar);
    char* tmpstring = new char[len+1];
    for (int i = 0; i < len && inputChar[i] != '\n'; i++)
        tmpstring[i] = toupper((char)inputChar[i]);
    tmpstring[len] = '\0';
    outputChar = CORBA::string_dup((const char*)tmpstring);
    delete[] tmpstring;
    return len;
}
void sample::LoopBackSample_i::OnTPSAbort(
           CORBA::Long status,
           CORBA::Environment& _env)
{
    char buf[256];
    sprintf(buf, "Called OnTPSAbort.");
    TPSUserTrace(LOG_ERR, buf);
    // Abort時の処理を記述
}
void sample::LoopBackSample_i::OnTPSDisconnect(
           CORBA::Environment& _env)
{
    char buf[256];
    sprintf(buf, "Called OnTPSDisconnect");
    TPSUserTrace(LOG_ERR, buf);
    // クライアント切断時の処理を記述
}
void sample::LoopBackSample_i::OnTPSMessageNotified(
    const char* mes,
    CORBA::Environment& _env)
{
    // フェールオーバ時の処理を記述
}
//////////////////////////////////////////////////////
// constructor
sample::WO_Factory_LoopBackSample_i::WO_Factory_LoopBackSample_i()
{
}
// destructor
sample::WO_Factory_LoopBackSample_i::~WO_Factory_LoopBackSample_i()
{
}
sample::LoopBackSample_ptr sample::WO_Factory_LoopBackSample_i::CreateServerObject(
           CORBA::Environment& _env)
{
    WebOTX::WOServantCallback* servInfo = new loopbackCallback_i();
    CORBA::Object_ptr obj = WebOTX::WOServantManager::CreateServant(servInfo);
    delete servInfo;
    return LoopBackSample::_narrow(obj);
}
void sample::WO_Factory_LoopBackSample_i::ReleaseServerObject(
           sample::LoopBackSample_ptr obj,
           CORBA::Environment& _env)
{
    WebOTX::WOServantCallback* servInfo = new WO_Factory_loopbackCallback_i();
    WebOTX::WOServantManager::ReleaseServant(servInfo, obj);

    delete servInfo;
}
//////////////////////////////////////////////////////
// コンポーネント初期化関数
#ifdef              _WINDOWS
#define            LOOPBACKEXPORT  __declspec(dllexport)
#else
#define            LOOPBACKEXPORT
#endif
extern "C" LOOPBACKEXPORT void loopbackinit();
//                             ^^^^^^^^^^^^これがコンポーネント初期化関数になります
extern "C" LOOPBACKEXPORT void loopbackinit()
{
    // 実装情報を登録します
    WebOTX::WOComponent::add(new loopbackCallback_i);
    WebOTX::WOComponent::add(new WO_Factory_loopbackCallback_i);
}
//////////////////////////////////////////////////////
// 実装情報の設定部分
const char* loopbackCallback_i::_name()
{
    return (const char*)"loopback";
}
const char* loopbackCallback_i::_id()
{
    return (const char*)"IDL:sample/LoopBackSample:1.0";
}
PortableServer::Servant loopbackCallback_i::_newInstance()
{
    sample::LoopBackSample_i* iobj = new sample::LoopBackSample_i;
    return iobj;
}
void loopbackCallback_i::_deleteInstance(PortableServer::Servant servant)
{
    delete servant;
}
//////////////////////////////////////////////////////
const char* WO_Factory_loopbackCallback_i::_name()
{
    return (const char*)"WO_Factory_loopback";
}
const char* WO_Factory_loopbackCallback_i::_id()
{
    return (const char*)"IDL:sample/WO_Factory_LoopBackSample:1.0";
}
PortableServer::Servant WO_Factory_loopbackCallback_i::_newInstance()
{
    sample::WO_Factory_LoopBackSample_i* iobj = 
                                     new sample::WO_Factory_LoopBackSample_i;
    return iobj;
}
void WO_Factory_loopbackCallback_i::_deleteInstance(PortableServer::Servant servant)
{
    delete servant;
}

コンパイル中...
U:\TestAPcl\loopbackcmn.cpp(980) : fatal error C1010: 
プリコンパイル済みヘッダーの検索中に予期しない EOF を検出しました。

複雑なIDLの場合のコーディング例(C++)

IDL: test1.idl
module AAAA {
   module BBBB {
     module CCCC {
       interface DDDD {
         void op1();
       };
     };
   };
};
C++: test1_i.h
namespace AAAA {
  namespace BBBB {
    namespace CCCC {
      class DDDD_i : public virtual POA_AAAA::BBBB::CCCC::DDDD {
public:
          DDDD_i();
          virtual ~DDDD_i();
          void op1(CORBA::Environment& _env = Ob_default_environment());
      };
    };
  };
};

C++: test1_i.C(test1_i.cpp)

AAAA::BBBB::CCCC::DDDD_i::DDDD_i()
{
   :
}

AAAA::BBBB::CCCC::DDDD_i::~DDDD_i()
{
   :
}

void AAAA::BBBB::CCCC::DDDD_i::op1(CORBA::Environment& _env)
{
   :
}

IDL: test2.idl
interface AAA {
   struct BBB {
      long   ID;
      string NAME;
      short  AGE;
    };
    typedef sequence < BBB > SEQ001;
    void GET_DATA (in SEQ001 inARG, out SEQ001 outARG, inout SEQ001 inoutARG);
};

C++: test2_i.h
class AAA_i : public virtual POA_AAA {
public:
   AAA_i();
   virtual ~AAA_i();
   void GET_DATA(const AAA::SEQ001& inARG,
                 AAA::SEQ001*& outARG,
                 AAA::SEQ001& inoutARG,
                 CORBA::Environment& _env = Ob_default_environment()
   );
};

C++: test2_i.C(test2_i.cpp)

AAA_i::AAA_i()
{
   :
}

AAA_i::~AAA_i()
{
   :
}

void AAA_i::GET_DATA(
     const AAA::SEQ001& inARG,
     AAA::SEQ001*& outARG,
     AAA::SEQ001& inoutARG,
     CORBA::Environment& _env
   )
{
   // inARGは値が設定されています。参照のみ可能です
   CORBA::ULong inARGlen = inARG.length();
   CORBA::ULong i;
   for(i=0; i < inARGlen; i++) {
      CORBA::ULong id = inARG[i].ID;
          :
   }

   // outARGはAAA::SEQ001をnewして値を設定しなければなりません
   CORBA::ULong outARGlen = 5000;
   outARG = new AAA::SEQ001;
   outARG->length(outARGlen);
   for(i=0; i < outARGlen; i++) {
      (*outARG)[i].ID = 10;
          :
   }

   // inoutARGは値が設定されている。また書き換えもできます
   CORBA::ULong inoutARGlen = inoutARG.length();
   for(i=0; i < outARGlen; i++) {
      inoutARG[i].ID = 10;
          :
   }
      :
}

サーバシミュレータによる動作確認(C++)

nsvsimc コンポーネントファイル名 コンポーネント初期化関数名

HP-UX(Itanium 2),  Linux,  SUN Solaris 10: 
nsvsimc loopback.so loopbackinit -b \
        loopback=corbaname://127.0.0.1#NEC/WebOTX/WO_Default/sample/LoopBackSample/1

Windows:
nsvsimc loopback.dll loopbackinit -vc2017 -b \
        loopback=corbaname://127.0.0.1#NEC/WebOTX/WO_Default/sample/LoopBackSample/1

nsvsimc コンポーネントファイル名 コンポーネント初期化関数名 \
        -p 常駐オブジェクト共有ライブラリファイル名(or DLL名)

HP-UX(Itanium 2), Linux,  SUN Solaris 10: 
nsvsimc loopback.so loopbackinit -p libprecreated.so \
        -b loopback=corbaname://127.0.0.1#NEC/WebOTX/WO_Default/sample/LoopBackSample/1

Windows:
nsvsimc loopback.dll loopbackinit -vc2017 -p precreated.dll \
        -b loopback=corbaname://127.0.0.1#NEC/WebOTX/WO_Default/sample/LoopBackSample/1

実行環境への登録(C++)

常駐オブジェクトの使い方

単一常駐オブジェクトのコーディング方法

単一常駐オブジェクトコーディング例

preobj1.def(Windowsのみ必要)
-------------------------------
EXPORTS
       OnTPSPrecreatedUsersObject
       OnTPSReleasePrecreatedUsersObject
       OnTPSOperationStart
       OnTPSOperationNormal
       OnTPSOperationAbnormal
       OnTPSOperationAbort

preobj1.h
-------------------------------
#ifndef            PREOBJ1_H_
#define            PREOBJ1_H_

#if defined(WIN32)
#if defined(PREOBJ1_EXPORTS)
#ifndef            PREOBJ1_EXPORTDEF
#define PREOBJ1_EXPORTDEF __declspec(dllexport)
#endif
#else // !defined(PREOBJ1_EXPORTS)
#define PREOBJ1_EXPORTDEF __declspec(dllimport)
#endif
#endif
#else              // !WIN32
#define            PREOBJ1_EXPORTDEF
#endif
#endif

class PREOBJ1_EXPORTDEF preobj1 {
       int m_db;
public:
       preobj1();
       ~preobj1();

       void set(int db);
       int get();
};

#endif

preobj1.C(Windowsの場合は.cpp)
-------------------------------
#include 

#include "preobj1.h"
#include "wotxexps.h"

extern "C" PREOBJ1_EXPORTDEF
   void* OnTPSPrecreatedUsersObject();
extern "C" PREOBJ1_EXPORTDEF
   void  OnTPSReleasePrecreatedUsersObject(void* ptr);
extern "C" PREOBJ1_EXPORTDEF
   void  OnTPSOperationStart(void* ptr, 
                             const char* repositoryID, 
                             const char* opname);
extern "C" PREOBJ1_EXPORTDEF
   void  OnTPSOperationNormal(void* ptr, 
                              const char* repositoryID, 
                              const char* opname);
extern "C" PREOBJ1_EXPORTDEF
   void  OnTPSOperationAbnormal(void* ptr, 
                                const char* repositoryID, 
                                const char* opname, int status);
extern "C" PREOBJ1_EXPORTDEF
   void  OnTPSOperationAbort(void* ptr, 
                             const char* repositoryID, 
                             const char* opname, int status);

//==========================================================//
PREOBJ1_EXPORTDEF  preobj1::preobj1()
{
  // 単一常駐オブジェクトのコンストラクタ
  m_db = 0;
}

PREOBJ1_EXPORTDEF  preobj1::~preobj1()
{
  // 単一常駐オブジェクトのデストラクタ
}

PREOBJ1_EXPORTDEF void preobj1::set(int db)
{
  // 単一常駐オブジェクトのメソッド
  m_db = db;
}

PREOBJ1_EXPORTDEF int preobj1::get()
{
  // 単一常駐オブジェクトのメソッド
  return m_db;

//==========================================================//
extern "C" PREOBJ1_EXPORTDEF
    void* OnTPSPrecreatedUsersObject()
{
    // 単一常駐オブジェクトオブジェクトの生成
    return (void*)new preobj1;
}

extern "C" PREOBJ1_EXPORTDEF
    void OnTPSReleasePrecreatedUsersObject(void* ptr)
{
    // 単一常駐オブジェクトオブジェクトの解放
    delete (preobj1*)ptr;
}

extern "C" PREOBJ1_EXPORTDEF
    void OnTPSOperationStart(void* ptr, 
                             const char* repositoryID, 
                             const char* opname)
{
    // オペレーション開始時に特別な処理を行う時に記述
}

extern "C" PREOBJ1_EXPORTDEF
    void OnTPSOperationNormal(void* ptr, 
                              const char* repositoryID, 
                              const char* opname)
{
    // オペレーション正常終了時に特別な処理を行う時に記述
}

extern "C" PREOBJ1_EXPORTDEF
    void OnTPSOperationAbnormal(void* ptr, 
                                const char* repositoryID, 
                                const char* opname, 
                                int status)
{
    // オペレーション異常終了時に特別な処理を行う時に記述
}

extern "C" PREOBJ1_EXPORTDEF
    void OnTPSOperationAbort(void* ptr, 
                             const char* repositoryID, 
                             const char* opname, 
                             int status)
{
    // オペレーションアボート時に特別な処理を行う時に記述
}
//==========================================================//

単一常駐オブジェクトのコールバックについて

複数常駐オブジェクトのコーディング方法

mpreobj2.def(Windowsのみ必要)
-------------------------------
EXPORTS
       OnTPSPrecreatedUsersObjectForPlural
       OnTPSReleasePrecreatedUsersObjectForPlural
       OnTPSOperationStartForPlural
       OnTPSOperationNormalForPlural
       OnTPSOperationAbnormalForPlural
       OnTPSOperationAbortForPlural

mpreobj2.h
-------------------------------
#ifndef            MPREOBJ2_H_
#define            MPREOBJ2_H_

#if defined(WIN32)
#if defined(MPREOBJ2_EXPORTS)
#ifndef            MPREOBJ2_EXPORTDEF
#define MPREOBJ2_EXPORTDEF __declspec(dllexport)
#endif
#else // !defined(PREOBJ1_EXPORTS)
#define MPREOBJ2_EXPORTDEF __declspec(dllimport)
#endif
#endif
#else              // !WIN32
#define            MPREOBJ2_EXPORTDEF
#endif
#endif

class MPREOBJ2_EXPORTDEF mpreobj2 {
       int m_db;
public:
       mpreobj2();
       ~mpreobj2();

       void set(int db);
       int get();
};

#endif

mpreobj2.C(Windowsの場合は.cpp)
-------------------------------
#include 

#include "mpreobj2.h"
#include "wotxexps.h"

extern "C" MPREOBJ2_EXPORTDEF
   void* OnTPSPrecreatedUsersObjectForPlural(
       const char* ID
   );
extern "C" MPREOBJ2_EXPORTDEF
   void OnTPSReleasePrecreatedUsersObjectForPlural(
       void* ptr,
       const char* ID
   );
extern "C" MPREOBJ2_EXPORTDEF
   void OnTPSOperationStartForPlural(
       void* ptr,
       const char* ID,
       const char* repositoryID,
       const char* opname
   );
extern "C" MPREOBJ2_EXPORTDEF
   void  OnTPSOperationNormalForPlural(
       void* ptr,
       const char* ID,
       const char* repositoryID,
       const char* opname
   );
extern "C" MPREOBJ2_EXPORTDEF
   void  OnTPSOperationAbnormalForPlural(
       void* ptr,
       const char* ID,
       const char* repositoryID,
       const char* opname,
       int status
   );
extern "C" MPREOBJ2_EXPORTDEF
   void  OnTPSOperationAbortForPlural(
       void* ptr,
       const char* ID,
       const char* repositoryID,
       const char* opname,
       int status
   );

//==========================================================//
MPREOBJ2_EXPORTDEF  mpreobj2::mpreobj2()
{
  // 複数常駐オブジェクトのコンストラクタ
  m_db = 0;
}

MPREOBJ2_EXPORTDEF  mpreobj2::~mpreobj2()
{
  //  複数常駐オブジェクトのデストラクタ
}

MPREOBJ2_EXPORTDEF void mpreobj2::set(int db)
{
  // 複数常駐オブジェクトのメソッド
  m_db = db;
}

MPREOBJ2_EXPORTDEF int mpreobj2::get()
{
  // 複数常駐オブジェクトのメソッド
  return m_db;
}

//==========================================================//
extern "C" MPREOBJ2_EXPORTDEF
    void* OnTPSPrecreatedUsersObjectForPlural(
              const char* ID
    )
{
    // 複数常駐オブジェクトオブジェクトの生成
    return (void*)new mpreobj2;
}

extern "C" MPREOBJ2_EXPORTDEF
    void OnTPSReleasePrecreatedUsersObjectForPlural(
        void* ptr,
        const char* ID
    )
{
    // 複数常駐オブジェクトオブジェクトの解放
    delete (mpreobj2*)ptr;
}

extern "C" MPREOBJ2_EXPORTDEF
    void OnTPSOperationStartForPlural(
        void* ptr,
        const char* ID,
        const char* repositoryID,
        const char* opname
    )
{
    // オペレーション開始時に特別な処理を行う時に記述
}

extern "C" MPREOBJ2_EXPORTDEF
    void OnTPSOperationNormalForPlural(
        void* ptr,
        const char* ID,
        const char* repositoryID,
        const char* opname
    )
{
    // オペレーション正常終了時に特別な処理を行う時に記述
}

extern "C" MPREOBJ2_EXPORTDEF
    void OnTPSOperationAbnormalForPlural(
        void* ptr,
        const char* ID,
        const char* repositoryID,
        const char* opname,
        int status
        )
{
    // オペレーション異常終了時に特別な処理を行う時に記述
}

extern "C" MPREOBJ2_EXPORTDEF
    void OnTPSOperationAbortForPlural(
        void* ptr,
        const char* ID,
        const char* repositoryID,
        const char* opname,
        int status
    )
{
    // オペレーションアボート時に特別な処理を行う時に記述
}
//==========================================================//

複数常駐オブジェクトのコールバックについて

常駐オブジェクトを用いたサーバアプリケーションの作成方法

#include "orb.h"
#include "wotxexps.h"

#include "preobj1.h"

#include "mpreobj2.h"

CORBA_Long foo_i::op1(CORBA_Long id, CORBA::Environment& _env)
{
       // 常駐オブジェクトの変数を設定
       preobj1*  pPreobj1 = NULL;
       mpreobj2* pMpreobj2 = NULL;

       // 単一常駐オブジェクトの取得と呼び出し
       TPSGetPrecreatedUsersObject((void**)&pPreobj1);
       if (pPreobj1 != NULL) {
正常時の処理
常駐オブジェクトのメソッドを呼び出す
       } else {
異常時の処理
ユーザ定義の例外やエラー返却値を設定
       }
       // 複数常駐オブジェクトの取得と呼び出し
       int nRet = TPSGetPrecreatedUsersObjectForPlural(
                     "mpreobj2",
                     (void**)&pMpreobj2
       );

       if (nRet == ERROR_PREOBJ_NO) {
正常時の処理
常駐オブジェクトのメソッドを呼び出す
       } else {
異常時の処理
ユーザ定義の例外やエラー返却値を設定
       }
}

共有プロパティの利用方法

共有プロパティ概要

プロパティグループの作成、取得、解放

：
    ：
    ：
void foo::hoo ()
{
    const char* pgname = "PropertyGroupFoo"; // プロパティグループ名
    long area = WOSP_AREATYPE_HOST;  // ホスト内共有
    WOPropertyGroup* wopg = NULL;
    long result = TPSCreatePropertyGroup(pgname, area, &wopg);
    if (result == WOSP_RC_DONE) {
        // 新規作成なのでプロパティも新規作成する
        const char* propertyName = "fooProperty";
        WOProperty* woproperty = NULL;
        result = wopg->CreateProperty(propertyName, &woproperty);
        if (result != WOSP_RC_DONE) {
            :
        }
        // プロパティグループのロック
        WO_PG_WAITFLAG inWaitflag;
        inWaitflag = WO_PG_WAIT;  // ロック取得まで待ち合わせる
        long waitsec = 3 * 1000;  // 待ちあわせ時間
        result = wopg->Lock(inWaitflag, waitsec);
        if (result != WOSP_RC_DONE) {
               :
        }
        // 値を設定
        int nValue = 100;
        if (result == WOSP_RC_DONE || result == WOSP_RC_ALREADY) {
            woproperty->Set(nValue);
        } else {
            // 異常系処理
            :
            :
 }
：
：
        // プロパティグループのアンロック
        result = wopg->Unlock();
        if (result != WOSP_RC_DONE) {
            :
        }
    } else {
        // 既に存在するので、プロパティを取得する
        const char* propertyName = "fooProperty";
        WOProperty* woproperty = NULL;
        result = wopg->GetProperty(propertyName, &woproperty);
        if (result != WOSP_RC_DONE) {
            :
        }
        // プロパティグループのロック
        WO_PG_WAITFLAG inWaitflag;
        inWaitflag = WO_PG_WAIT;    // ロック取得まで待ち合わせる
        long waitsec = 3 * 1000;    // 待ちあわせ時間
        result = wopg->Lock(inWaitflag, waitsec);
        if (result != WOSP_RC_DONE) {
             :
        }
        // 値の取得
        int nValue;
        if (result == WOSP_RC_DONE || result == WOSP_RC_ALREADY) {
            woproperty->Get(nValue);
        } else {
            // 異常系処理
            :
            :
        }
            :
            :
        // プロパティグループのアンロック
        result = wopg->Unlock();
        if (result != WOSP_RC_DONE) {
            :
        }
    }
}
    ：
    ：

プロパティの生成/取得

値の設定/取得

プロパティグループのロック

データベース自動接続/切断機能の利用方法

環境設定について

サーバアプリケーションの作成方法

WebOTX Transaction Service

共有コンポーネント機能

共有コンポーネントの作成方法

共有コンポーネントの利用方法

共有コンポーネントの登録方法

クライアントアプリケーションについて

非同期トランザクションについて

仮想宛先(VD:Vritual Destination)とは

非同期トランザクションの利用方法

初期化/終了関数

extern "C" WO_USER_EXPORT int WebOTX_Init()
{
  return 0;
}
extern "C" WO_USER_EXPORT void WebOTX_Term()
{
  return ;
}

アプリケーション初期プロセスについて

アプリケーション初期プロセス用インタフェース

利用可能なサーバAPIについて

障害発生時の処理について

// MyDB.hファイル
#include "orb.h"
#include "wotxexps.h"
#ifndef            MYDB_H
#define            MYDB_H
class MyDB : public WebOTX_DB
{
  public:
  MyDB();
  ~MyDB();
  独自の機能
  void commit();                          // 独自の機能
  void rollback();                        // 純仮想関数に対する定義
};
#endif
// MyDB.C(WindowsではMyDB.CPP)ファイル
#include "orb.h"
#include "wotxexps.h"
#include "MyDB.h"
MyDB::MyDB()
{
  // DBへの接続処理(独自処理)
}
MyDB::~MyDB()
{
  // DBとの切断処理(独自処理)
}
void MyDB::insert(char* data1, char* data2)
{
  // テーブルにデータを追加(独自処理)
}
void MyDB::commit()
{
  // コミット処理(独自処理)
}
void MyDB::rollback()
{
  // ロールバック処理(例外時に呼ばれる)
}

1.2.1.6. C++言語を用いたクライアントアプリケーションの作成

C++クライアントアプリケーションの作成の流れ

開発環境の設定

UNIX

:
>set path=( $path /opt/ObjectSpinner/bin )
>set path=( $path /opt/WebOTX/dev/command )
:
>setenv LD_LIBRARY_PATH /opt/ObjectSpinner/lib:\
/opt/ObjectSpinner/namespace/lib:\
/opt/WebOTX/dev/lib
:

Windows(Intel x86)

Windows(Intel 64)

IDLファイルの作成とコンパイル(C++)

6.4. クライアントアプリケーションの作成方法(C++)

UNIXのMakefileについて

#-----------------------------------------------------------------------
#  for HP-UX(Itanium 2)
#-----------------------------------------------------------------------
CC       = /opt/aCC/bin/aCC
WOIGENXX = /opt/WebOTX/dev/command/woigenxx
BASENAME = loopback
LIBS     = -L/opt/ObjectSpinner/namespace/lib -lnsospi \
-L/opt/WebOTX/dev/lib -lnWOBSE91
OBJS     = ${BASENAME}cmn.o \
${BASENAME}cl.o
INC      = -I/opt/WebOTX/dev/include \
-I/opt/ObjectSpinner/namespace/include
LDFLAGS  = -mt -Wl,-E +DD64
C++FLAGS = +Z -mt -DOB_HPUX_KT +DD64
TARGET   = ${BASENAME}cl
all : ${OBJS} ${TARGET}
${TARGET} : ${OBJS}
${CC} -o $@ ${C++FLAGS} ${LDFLAGS} ${OBJS} ${LIBS}
${BASENAME}cmn.o :      ${BASENAME}cmn.C ${BASENAME}.h
.C.o :
${CC} ${INC} ${C++FLAGS} -c $*.C
idl:
${WOIGENXX} ${BASENAME}
clean:
/bin/rm -rf *.o ${TARGET}

#-----------------------------------------------------------------------
#  for Linux
#-----------------------------------------------------------------------
CC       = /usr/bin/g++
WOIGENXX = /opt/WebOTX/dev/command/woigenxx
BASENAME = loopback
LIBS     = -lpthread -ldl \
-L/opt/ObjectSpinner/namespace/lib -lnsospi \
-L/opt/WebOTX/dev/lib -lnWOBSE91
OBJS     = ${BASENAME}cmn.o \
${BASENAME}cl.o
INC      = -I/opt/WebOTX/dev/include \
-I/opt/ObjectSpinner/namespace/include
LDFLAGS  = 
C++FLAGS = -D_REENTRANT -D_GNU_SOURCE -fPIC
TARGET   = ${BASENAME}cl
all : ${OBJS} ${TARGET}
${TARGET} : ${OBJS}
${CC} -o $@ ${C++FLAGS} ${LDFLAGS} ${OBJS} ${LIBS}
${BASENAME}cmn.o :      ${BASENAME}cmn.C ${BASENAME}.h
.C.o :
${CC} ${INC} ${C++FLAGS} -c $*.C
idl:
${WOIGENXX} ${BASENAME}
clean:
/bin/rm -rf *.o ${TARGET}

#-----------------------------------------------------------------------
#  for SUN Solaris 10
#-----------------------------------------------------------------------
CC       = /opt/SUNWspro/bin/CC
WOIGENXX = /opt/WebOTX/dev/command/woigenxx
BASENAME = loopback
LIBS     = -m -m64 -ldl -lgen -lsocket -lnsl -lposix4 \
-L/opt/ObjectSpinner/namespace/lib -lnsospi \
-L/opt/WebOTX/dev/lib -lnWOBSE91
OBJS     = ${BASENAME}cmn.o \
${BASENAME}cl.o
INC      = -I/opt/WebOTX/dev/include \
-I/opt/ObjectSpinner/namespace/include
LDFLAGS  = -mt
C++FLAGS = -D_REENTRANT -mt -m64 -xcode=pic32
TARGET   = ${BASENAME}cl
all : ${OBJS} ${TARGET}
${TARGET} : ${OBJS}
${CC} -o $@ ${C++FLAGS} ${LDFLAGS} ${OBJS} ${LIBS}
${BASENAME}cmn.o :      ${BASENAME}cmn.C ${BASENAME}.h
.C.o :
${CC} ${INC} ${C++FLAGS} -c $*.C
idl:
${WOIGENXX} ${BASENAME}
clean:
/bin/rm -rf *.o ${TARGET}

Windows(Intel x86)のプロジェクト設定について

Windows(Intel 64)のMakefileについて

#-----------------------------------------------------------------------
#  for Windows(Intel 64)
#-----------------------------------------------------------------------
!include 
OUTDIR=.\Release
INTDIR=.\Release
# Begin Custom Macros
OutDir=.\Release
# End Custom Macros
OTXDIR=C:\Program Files\NEC\WebOTX
OSPIDIR=$(OTXDIR)\ObjectBroker
ALL : "$(OUTDIR)\$(BASENAME)cl.exe"
"$(OUTDIR)" :
if not exist "$(OUTDIR)/$(NULL)" mkdir "$(OUTDIR)"
CPP=cl.exe
CPP_PROJ = /nologo /MD /W3 /GX /O2 \
/I "$(OSPIDIR)\namespace\include" \
/I "$(OTXDIR)\dev\include" \
/D "WIN32" /D "WIN64" /D "NDEBUG" /D "_WINDOWS" /D "_MBCS" \
/Fo"$(INTDIR)\\" /Fd"$(INTDIR)\\" /c 
.c{$(INTDIR)}.obj::
$(CPP) @<<
$(CPP_PROJ) $< 
<< 
.cpp{$(INTDIR)}.obj::
$(CPP) @<<
$(CPP_PROJ) $< 
<< 
.cxx{$(INTDIR)}.obj::
$(CPP) @<<
$(CPP_PROJ) $< 
<< 
LINK=link.exe
LINK_FLAGS=nosp9011.lib nWOBS97.lib \
/nologo /incremental:no /pdb:"$(OUTDIR)\$(BASENAME)cl.pdb" \
/machine:AMD64 /out:"$(OUTDIR)\$(BASENAME)cl.exe" \
/libpath:"$(OSPIDIR)\namespace\lib" \
/libpath:"$(OTXDIR)\dev\lib" 
LINK_OBJS= \
"$(INTDIR)\$(BASENAME)cl.obj" \
"$(INTDIR)\$(BASENAME)cmn.obj"
"$(OUTDIR)\$(BASENAME)cl.exe" : "$(OUTDIR)" $(DEF_FILE) $(LINK32_OBJS)
$(LINK32) @<<
$(LINK32_FLAGS) $(LINK32_OBJS)
<< 
SOURCE=.\$(BASENAME)cl.cpp
"$(INTDIR)\$(BASENAME)cl.obj" : $(SOURCE) "$(INTDIR)"
SOURCE=.\$(BASENAME)cmn.cpp
"$(INTDIR)\$(BASENAME)cmn.obj" : $(SOURCE) "$(INTDIR)"

コーディング(ファクトリを使用しない場合)

#include <stdio.h>
#include "orb.h"
#include "loopback.h"
int main (int argc, char **argv) {
  // ORBの初期化
  try {
    CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "");

    // 名前サーバオブジェクトリファレンスの取得
    CORBA::Object_var obj = orb->resolve_initial_references("NameService");
    CosNaming::NamingContext_var nmctx = CosNaming::NamingContext::_narrow(obj);

    // サーバオブジェクトリファレンスの取得
    CosNaming::Name objname;
    objname.length(6);   // コンテキスト+1
    objname[0].id = (const char*)"NEC";
    objname[0].kind = (const char*)"";
    objname[1].id = (const char*)"WebOTX";
    objname[1].kind = (const char*)"";
    objname[2].id = (const char*)"WO_Default";
    objname[2].kind = (const char*)"";
    objname[3].id = (const char*)"sample";
    objname[3].kind = (const char*)"";
    objname[4].id = (const char*)"LoopBackSample";
    objname[4].kind = (const char*)"";
    objname[5].id = (const char*)"1";   // バージョン番号
    objname[5].kind = (const char*)"";
    obj = nmctx->resolve(objname);
    sample::LoopBackSample_ptr svobj = sample::LoopBackSample::_narrow(obj);

    // オペレーション呼出し
    const char* instr = "AaBbCc";
    char* outstr;
    int result = svobj->LoopBack (instr,outstr);
    printf("LoopBack %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);
    result = svobj->LowerCase (instr,outstr);
    printf("LowerCase %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);
    result = svobj->UpperCase (instr,outstr);
    printf("UpperCase %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);

    // サーバオブジェクトリファレンスの解放
    CORBA::release(svobj);
    return 0;
  } catch (CORBA::SystemException& e) {
    printf("Occurred exception.");
    printf(" ID=%s minor=%d\n",e.__id(), e.minor());
    return -1;
  } catch (CORBA::Exception& e) {
    printf("Occurred exception.");
    printf(" ID=%s \n", e.__id());
    return -1;
  }
}

コーディング(ファクトリを使用する場合)

#include <stdio.h>
#include "orb.h"
#include "loopback.h"
int main (int argc, char **argv) {
  // ORBの初期化
  try {
    CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "");

    // 名前サーバオブジェクトリファレンスの取得
    CORBA::Object_var obj = orb->resolve_initial_references("NameService");
    CosNaming::NamingContext_var nmctx = CosNaming::NamingContext::_narrow(obj);

    // ファクトリオブジェクトリファレンスの取得
    CosNaming::Name objname;
    objname.length(6);   // コンテキスト+1
    objname[0].id = (const char*)"NEC";
    objname[0].kind = (const char*)"";
    objname[1].id = (const char*)"WebOTX";
    objname[1].kind = (const char*)"";
    objname[2].id = (const char*)"WO_Default";
    objname[2].kind = (const char*)"";
    objname[3].id = (const char*)"sample";
    objname[3].kind = (const char*)"";
    objname[4].id = (const char*)"WO_Factory_LoopBackSample";
    objname[4].kind = (const char*)"";
    objname[5].id = (const char*)"1";   // バージョン番号
    objname[5].kind = (const char*)"";
    obj = nmctx->resolve(objname);
    sample::WO_Factory_LoopBackSample_ptr fobj = 
    sample::WO_Factory_LoopBackSample::_narrow(obj);

    // サーバオブジェクトリファレンスの取得
    sample::LoopBackSample_ptr svobj = fobj->CreateServerObject();

    // オペレーション呼出し
    const char* instr = "AaBbCc";
    char* outstr;
    int result = svobj->LoopBack (instr,outstr);
    printf("LoopBack %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);
    result = svobj->LowerCase (instr,outstr);
    printf("LowerCase %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);
    result = svobj->UpperCase (instr,outstr);
    printf("UpperCase %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);

    // サーバオブジェクトリファレンスの解放
    fobj->ReleaseServerObject(svobj);
    CORBA::release(svobj);

    // ファクトリオブジェクトリファレンスの解放
    CORBA::release(fobj);
    return 0;
  } catch (CORBA::SystemException& e) {
    printf("Occurred exception.");
    printf(" ID=%s minor=%d\n",e.__id(), e.minor());
    return -1;
  } catch (CORBA::Exception& e) {
    printf("Occurred exception.");
    printf(" ID=%s \n", e.__id());
    return -1;
  }
}

複雑なIDLの場合のコーディング例(C++)

C++のクライアント管理ライブラリ

#include <stdio.h>
#include "orb.h"
#include "loopback.h"
#include "WOTrmMan.h"
int main (int argc, char **argv)
{
  try {
    // ORBの初期化
    CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "");

    // 名前サーバオブジェクトリファレンスの取得
    CORBA::Object_var obj = orb->resolve_initial_references("NameService");
    CosNaming::NamingContext_var nmctx = CosNaming::NamingContext::_narrow(obj);

    // ファクトリオブジェクトリファレンスの取得
    CosNaming::Name objname;
    objname.length(6);
    objname[0].id = (const char*)"NEC";
    objname[0].kind = (const char*)"";
    objname[1].id = (const char*)"WebOTX";
    objname[1].kind = (const char*)"";
    objname[2].id = (const char*)"WO_Default";
    objname[2].kind = (const char*)"";
    objname[3].id = (const char*)"sample";
    objname[3].kind = (const char*)"";
    objname[4].id = (const char*)"WO_Factory_LoopBackSample";
    objname[4].kind = (const char*)"";
    objname[5].id = (const char*)"1";   // バージョン番号
    objname[5].kind = (const char*)"";
    obj = nmctx->resolve(objname);
    sample::WO_Factory_LoopBackSample_ptr fobj = 
    sample::WO_Factory_LoopBackSample::_narrow(obj);

    // クライアント管理ライブラリへの登録
    WO_TerminalManager woterm;
    woterm.SetFactoryObject(fobj);

    // サーバオブジェクトリファレンスの取得
    sample::LoopBackSample_ptr svobj = fobj->CreateServerObject();

    // オペレーション呼出し
    const char* instr = "AaBbCc";
    char* outstr;
    int result = svobj->LoopBack (instr,outstr);
    printf("Loopback %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);
    result = svobj-> LowerCase (instr,outstr);
    printf("LowerCase %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);
    result = svobj-> UpperCase (instr,outstr);
    printf("UpperCase %s -> %s\n",instr,outstr);
    CORBA::string_free(outstr);

    // サーバオブジェクトリファレンスの解放
    fobj->ReleaseServerObject(svobj);
    CORBA::release(svobj);

    // ファクトリオブジェクトリファレンスの解放
    CORBA::release(fobj);
    return 0;
  } catch (CORBA::SystemException& e) {
    printf("Occurred exception.");
    printf(" ID=%s minor=%d\n",e.__id(), e.minor());
    return -1;
  } catch (CORBA::Exception& e) {
    printf("Occurred exception.");
    printf(" ID=%s \n", e.__id());
    return -1;
  }
}

例外処理について

1.2.1.7. COBOL言語を用いたサーバアプリケーションの作成

COBOLとは

COBOLサーバコンポーネントの構成

+----------------------------------------+
|C++スタブ/スケルトンコードのオブジェクト| IDLコンパイラが自動生成部分
+----------------------------------------+
|COBOLを呼び出すC++のコードのオブジェクト| サーバント部分
+==============extern "C"================+
|       COBOLコードのオブジェクト        | COBOL部分
+----------------------------------------+

COBOLサーバコンポーネントの注意/制限事項

1.2.1.8. コマンドリファレンス

Java用

• woi2j

  表1.2.1.8-1

  形式	woi2j IDLファイル名(拡張子.idlは削除) [-tie] [-R IDLファイル名]* [-wofactoryless [-wobase]]
  機能	WebOTXのJava用IDLコンパイルの実行
  オプション	IDLファイル名(拡張子.idlは削除) 指定されたIDLファイルを入力としてIDLコンパイルします。 パスの指定はできません。IDLファイルが存在するディレクトリで実行してください。 -tie TIEアプローチを使用する時に指定します。 -R IDLファイル名 指定されたIDLファイル名を参照します。複数記述できます。 パスの指定はできません。対象のファイルをカレントディレクトリにコピーして実行してください。 -wofactoryless WO_Factoryに関連するIDLの変更、クラスファイルの生成を行いません。主に他社ORBとの連携に使用します。 -wobase -wofactorylessオプションを指定すると、WO_Baseへの参照をしません。これは、他社ORBにはないWebOTX固有のIDLだからです。 しかし、コールバック機能を使用するためにWO_Baseインタフェースを継承している場合は定義が必要になるため、 その場合にのみ指定してください。-wofactorylessの場合はWO_Baseへの参照は推奨いたしませんので、本オプションの使用も推奨いたしません。 -notimport IDL定義にmodule宣言が無い場合、パッケージ名が無いimport 文が出力されjavacのコンパイルエラーとなることがあります。 パッケージ名が無いimport 文を出力しないようにするには本オプションを指定して下さい。
  注意事項

• woixj

  表1.2.1.8-2

  形式	woixj ifファイル名(拡張子ifは不要) [-init コンポーネント初期化クラス名]　[-I <インタフェース名>,<実装クラス名>]* [-f設定ファイル名] [-tie] [-out出力先ディレクトリパス] [-prop プロパティファイル名]
  機能	コンポーネント初期化クラス、実装情報定義クラスを生成します
  オプション	ifファイル名(拡張子ifは不要) パスの指定はできません。ifファイルが存在するディレクトリで実行してください。 -init <コンポーネント初期化クラス名> コンポーネント初期化クラス名を指定します。 コンポーネント初期化クラス名が指定されていない場合のクラス名は<ifファイル名+Init>となります。 下記の-fオプションとは併用できません。 -I <インタフェース名>,<実装クラス名> それぞれのインタフェースに対応する実装クラス名を指定します。 複数のインタフェースに対して実装クラス名を指定したい場合は、インタフェース名と実装クラス名とのペアを繰り返し記述します。 指定されていないインタフェースの実装クラス名は<ifファイル名+Obj>となります。 下記の-fオプションとは併用できません。 -f <設定ファイル名> 設定ファイルに各設定を指定します。 コンポーネント初期化クラス名が指定されていない場合のクラス名は<ifファイル名+Init>となります。 指定されていないインタフェースの実装クラス名は<ifファイル名+Obj>となります。 上記の-Iオプション、-initオプションとは併用できません。 設定ファイルは以下の書式に従います。Module名、package名はそれぞれ繰り返して記述することができます。 コンポーネント初期化クラス名: @<package名>.<コンポーネント初期化クラス名>(改行) 実装クラス名: <module名>.<インタフェース名>,<package名>.<実装クラス名>(改行) -tie TIEアプローチによりコード生成を行います。 -out <出力先ディレクトリパス> 出力先ディレクトリを指定します。 相対パスでも絶対パスでも指定できます。 指定のない場合はカレントディレクトリに出力されます。 -prop <プロパティファイル名> プロパティファイル名を指定します。 指定のない場合は”corbaap.properties”に出力されます。 既に同名ファイルが存在する場合は上書きされます オプションを使用した場合の記述例は以下のようになります。 コンポーネント初期化クラス名をloopbackInitTestに、インタフェースLoopBackSampleに対応する実装クラス名をLoopBackSampleTest、package名をsampleTestに設定しコード生成を行う場合についての記述例は以下のとおりです。 例1: -initオプション、-I オプションを用いてクラス名を設定する場合 woixj loopback -init loopbackInitTest \ -I sample.LoopBackSample,sampleTest.LoopBackSampleTest 例2: 設定ファイルを指定してクラス名を設定する場合 woixj loopback -f classname.txt ----- [classname.txt] @loopbackInitTest sample.LoopBackSample,sampleTest.LoopBackSampleTest -----
  注意事項

• ServerSimulator

  表1.2.1.8-3

  形式	java ServerSimulator コンポーネント初期化クラス名 [/O] [/P 常駐オブジェクトクラス名] [/B 名前サーバ登録名]
  機能	WebOTXのJava用サーバシミュレータの実行 環境設定の方法は「プログラミングの手引き」-「サーバシミュレータによる動作確認(Java)」 をご覧ください。
  オプション	コンポーネント初期化クラス名 コンポーネントを初期化するのに使用する、コンポーネント初期化クラスの名前を指定します。 /O(省略可能) WebOTX Transaction Service連携を行う時に指定します。 /P 常駐オブジェクトクラス名 指定された常駐オブジェクトを生成します。但し、単一機能のみです。またコールバックの呼び出しはありません。 /B 名前サーバ登録名 ＜実装識別名＞=＜URL＞ の形式で指定します。URLは、corbaname形式で指定してください。指定した実装識別名に対応するリファレンスを、URLの位置に登録します。
  注意事項

C++用

• woigenxx

  表1.2.1.8-4

  形式	woigenxx IDLファイル名(拡張子.idlは削除) [-tie] [-R IDLファイル名]* [-wofactoryless [-wobase]]
  機能	WebOTXのC++用IDLコンパイルの実行
  オプション	IDLファイル名(拡張子.idlは削除) 指定されたIDLファイルを入力としてIDLコンパイルします。 パスの指定はできません。IDLファイルが存在するディレクトリで実行してください。 /R IDLファイル名 指定されたIDLファイル名を参照します。複数記述できます。 パスの指定はできません。対象のファイルをカレントディレクトリにコピーして実行してください。 -wofactoryless WO_Factoryに関連するIDLの変更、クラスファイルの生成を行いません。主に他社ORBとの連携に使用します。 -wobase -wofactorylessオプションを指定すると、WO_Baseへの参照をしません。これは、他社ORBにはないWebOTX固有のIDLだからです。 しかし、コールバック機能を使用するためにWO_Baseインタフェースを継承している場合は定義が必要になるため、 その場合にのみ指定してください。-wofactorylessの場合はWO_Baseへの参照は推奨いたしませんので、本オプションの使用も推奨いたしません。
  注意事項

• woixcpp

  表1.2.1.8-5

  形式	woixcpp ifファイル名(拡張子ifは不要) [-init コンポーネント初期化クラス名]　[-I <インタフェース名>,<実装クラス名>]* [-f設定ファイル名] [-out出力先ディレクトリパス] [-prop プロパティファイル名]
  機能	コンポーネント初期化クラス、実装情報定義クラスを生成します
  オプション	ifファイル名(拡張子ifは不要) パスの指定はできません。ifファイルが存在するディレクトリで実行してください。 -init <コンポーネント初期化クラス名> コンポーネント初期化クラス名を指定します。 コンポーネント初期化クラス名が指定されていない場合のクラス名は<ifファイル名+Init>となります。 下記の-fオプションとは併用できません。 -I <インタフェース名>,<実装クラス名> それぞれのインタフェースに対応する実装クラス名を指定します。 複数のインタフェースに対して実装クラス名を指定したい場合は、インタフェース名と実装クラス名とのペアを繰り返し記述します。 指定されていないインタフェースの実装クラス名は<ifファイル名+_i>となります。 下記の-fオプションとは併用できません。 -f <設定ファイル名> 設定ファイルに各設定を指定します。 コンポーネント初期化クラス名が指定されていない場合のクラス名は<ifファイル名+Init>となります。 指定されていないインタフェースの実装クラス名は<ifファイル名+_i>となります。 上記の-Iオプション、-initオプションとは併用できません。 設定ファイルは以下の書式に従います。Module名、namespace名はそれぞれ繰り返して記述することができます。 コンポーネント初期化クラス名: @<コンポーネント初期化クラス名>(改行) 実装クラス名: <module名>::<インタフェース名>,<namespace名>::<実装クラス名>(改行) -out <出力先ディレクトリパス> 出力先ディレクトリを指定します。 相対パスでも絶対パスでも指定できます。 指定のない場合はカレントディレクトリに出力されます。 -prop <プロパティファイル名> プロパティファイル名を指定します。 指定のない場合は”corbaap.properties”に出力されます。 既に同名ファイルが存在する場合は上書きされます。 オプションを使用した場合の記述例は以下のようになります。 コンポーネント初期化クラス名をloopbackInitTestに、インタフェースLoopBackSampleに対応する実装クラス名をLoopBackSampleTest、namespace名をsampleTestに設定しコード生成を行う場合についての記述例は以下のとおりです。 例1: -initオプション、-I オプションを用いてクラス名を設定する場合 woixcpp loopback -init loopbackInitTest \ -I sample::LoopBackSample,sampleTest::LoopBackSampleTest 例2: 設定ファイルを指定してクラス名を設定する場合 woixcpp loopback -f classname.txt ----- [classname.txt] @loopbackInitTest sample::LoopBackSample,sampleTest::LoopBackSampleTest -----
  注意事項

• Nsvsimc

  表1.2.1.8-6

  形式	nsvsimc DLL(またはso)ファイル名 コンポーネント初期化関数名 [/vc2005] [/t TimeOut] [/o db1,db2,...] [/p 常駐オブジェクトDLL(またはso)ファイル名] [/b 名前サーバ登録名]
  機能	WebOTXのC++用サーバシミュレータの実行 環境設定の方法は「プログラミングの手引き」-「サーバシミュレータによる動作確認(C++)」をご覧ください。
  オプション	DLL(またはso)ファイル名 サーバコンポーネントのDLLを指定します。 コンポーネント初期化関数名 コンポーネントを初期化時に呼び出す、コンポーネント初期化関数の名前を指定します。 /o db1,db2,...(省略可能) WebOTX Transaction Service連携を行う時に指定します。db1にはデータベース名(運用管理ツールで指定した文字列)を指定してください。複数記述することができます。複数記述する時は間に空白を入れないでください。 /p 常駐オブジェクトDLL(またはso)ファイル名 指定されたDLLにある常駐オブジェクトを生成します。但し、単一機能のみです。またコールバックの呼び出しはありません。 /b 名前サーバ登録名 ＜実装識別名＞=＜URL＞ の形式で指定します。URLは、corbaname形式で指定してください。指定した実装識別名に対応するリファレンスを、URLの位置に登録します。 /vc2005 /vc2008 /vc2010 /vc2012 /vc2013 /vc2015 /vc2017 動作させる VC++ のライブラリを指定します。何れか１つのみ指定。複数記述した場合は先頭のみ有効となります。
  注意事項

1.2.1.9. WebOTXのORBについて

利用できない機能

利用できない型

利用できないAPI

• Object Broker Java(TM)で利用できないAPI

  表1.2.1.9-1

  パッケージ名	クラス	メソッド
  org.omg.CORBA	ORB	poll_next_response()
  		get_next_response()
  		work_pending()
  		perform_work()
  		run()
  jp.co.nec.orb	Config	setServerRecvTimeout()
  		getServerRecvTimeout()
  		setServerPort()
  		synchronizedPerObject()
  		asynchronizedPerObject()
  		setPerClientThreadPolicy()
  		setPooledThreadPolicy()
  		setNoDelay()
  		corbalocAskWithMT
  		setCorbalocServerPort

• Object Broker C++で利用できないAPI

  表1.2.1.9-2

  名前空間	クラス	メソッド
  CORBA	ORB	poll_next_response()
  		get_next_response()
  		work_pending()
  		perform_work()
  		run()
  	Environment	__connection ()
  	Ob_SvrCon	get_peer()
  なし	Ob_SvrInitialArg	Ob_SvrInitialArg()
  		this_object()

推奨しない機能

推奨しない型

推奨しないAPI

• Object Broker Java(TM)で推奨しないAPI

  表1.2.1.9-3

  パッケージ名	クラス	メソッド
  jp.co.nec.orb	HookObj	全て(サーバアプリケーション)

• Object Broker C++で推奨しないAPI

  表1.2.1.9-4

  パッケージ名	クラス	メソッド
  なし	Ob_MesBufHook	全て(サーバアプリケーション)
  CORBA	orb	__stop()
  		__is_active()

1.2.1.10. WebOTXが使用しているPOAについて

全体構成

/
+---- リポジトリID;ファイル名 (例: IDL:LoopBackSample:1.0;loopback.jar)
+---- リポジトリID;ファイル名
|                 :
|                 :
+---- リポジトリID;ファイル名

ステートレスオブジェクト用のPOA

• C++言語

  CORBA::PolicyList policies(5);
  policies.length(5);
  policies[0] = rootPOA->create_servant_retention_policy(
  PortableServer::NON_RETAIN);
  policies[1] = rootPOA->create_id_uniqueness_policy(
  PortableServer::MULTIPLE_ID);
  policies[2] = rootPOA->create_request_processing_policy(
  PortableServer::USE_SERVANT_MANAGER);
  policies[3] = rootPOA->create_lifespan_policy(
  PortableServer::PERSISTENT);
  policies[4] = rootPOA->create_id_assignment_policy(
  PortableServer::USER_ID);
  

• Java言語

  Policy[] policies = new Policy[5];
  policies[0] = rootPOA.create_servant_retention_policy(
  ServantRetentionPolicyValue.NON_RETAIN);
  policies[1] = rootPOA.create_id_uniqueness_policy(
  IdUniquenessPolicyValue.MULTIPLE_ID);
  policies[2] = rootPOA.create_request_processing_policy(
  RequestProcessingPolicyValue.USE_SERVANT_MANAGER);
  policies[3] = rootPOA.create_lifespan_policy(
  LifespanPolicyValue.PERSISTENT);
  policies[4] = rootPOA.create_id_assignment_policy(
  IdAssignmentPolicyValue.USER_ID);
  

  ステートフルオブジェクト用のPOA

  以下のポリシーを指定しています。

• C++言語

  CORBA::PolicyList policies(4);
  policies.length(4);
  policies[0] = rootPOA->create_servant_retention_policy(
  PortableServer::NON_RETAIN);
  policies[1] = rootPOA->create_request_processing_policy(
  PortableServer::USE_SERVANT_MANAGER);
  policies[2] = rootPOA->create_lifespan_policy(
  PortableServer::PERSISTENT);
  policies[3] = rootPOA->create_id_assignment_policy(
  PortableServer::USER_ID);
  

• Java言語

  Policy policies[] = new Policy[4];
  policies[0] = rootPOA.create_servant_retention_policy(
  ServantRetentionPolicyValue.NON_RETAIN);
  policies[1] = rootPOA.create_request_processing_policy(
  RequestProcessingPolicyValue.USE_SERVANT_MANAGER);
  policies[2] = rootPOA.create_lifespan_policy(
  LifespanPolicyValue.PERSISTENT);
  policies[3] = rootPOA.create_id_assignment_policy(
  IdAssignmentPolicyValue.USER_ID);