WebLogic Tuxedo コネクタクライアント EJB の開発



\| WebLogic Server ホーム \| WTC ATMI プログラマーズガイド \| 前へ \| 次へ \| 目次 \| 索引 \| PDF 版

注意: WebLogic Tuxedo コネクタ JATMI の詳細については、WebLogic Server クラスの Javadocを参照してください。WebLogic Tuxedo コネクタクラスは、weblogic.wtc.jatmi および weblogic.wtc.gwt パッケージに含まれています。

次の節では、ユーザの入力を受け取り、サーバプロセスまたはリクエストされたサービスを提供する発信オブジェクトにサービスリクエストを送信するクライアント EJB の作成方法について説明します。

WebLogic Tuxedo コネクタ JATMI クライアントクラスは、Tuxedo で検出されたサービスにアクセスするクライアントを作成するために使用します。

アプリケーションとの接続および切断

Tuxedo および WebLogic Tuxedo コネクタは、それぞれ異なった方法でサービスに接続します。

アプリケーションへの接続

次の節では、Tuxedo および WebLogic Tuxedo コネクタがアプリケーションに接続する方法を比較します。

Tuxedo は、アプリケーションに接続するために tpinit() を使用します。
WebLogic Tuxedo コネクタは、BDMCONFIG XML コンフィグレーションファイルを使用して、Tuxedo サービスへのパスを作成するために必要な情報を提供します。BDMCONFIG XML コンフィグレーションファイルの T_DM_REMOTE_TDOMAIN および T_DM_IMPORT セクションをコンフィグレーションすることによって、セキュリティおよびクライアント認証を提供します。この経路は WebLogic Server が起動され、WebLogic Tuxedo コネクタ XML コンフィグレーションファイルがロードされたときに作成されます。
WebLogic Tuxedo コネクタは TuxedoConnection を使用して Tuxedo オブジェクトを取得したのち、getTuxedoConnection() を使用して Tuxedo オブジェクトへの接続を作成します。次の例は、WebLogic Server アプリケーションが WebLogic Tuxedo コネクタを使用してどのように Tuxedo アプリケーションに接続するのかを示しています。
コードリスト 2-1 Tuxedo アプリケーションに接続するためのクライアントコード例
```
.
.
.
    try {
     ctx = new InitialContext();
     tcf = 
          (TuxedoConnectionFactory)           ctx.lookup("tuxedo.services.TuxedoConnection");
     } catch (NamingException ne) {

// tuxedo オブジェクトを取得できなかった場合に TPENOENT を送出する
throw new TPException(TPException.TPENOENT, 
     "Could not get TuxedoConnectionFactory : " + ne);
     } 

myTux = tcf.getTuxedoConnection();
.
.
.
```

アプリケーションからの切断

次の節では、Tuxedo および WebLogic Tuxedo コネクタがアプリケーションとの接続を切断する方法を比較します。

Tuxedo は、アプリケーションとの接続を切断するために tpterm() を使用します。
WebLogic Tuxedo コネクタは、JATMI プリミティブ tpterm() を使用して Tuxedo オブジェクトへの接続を終了します。
WebLogic Tuxedo コネクタは、WebLogic Server の停止時に Tuxedo サービスへの経路を閉じます。

クライアントの基本操作

クライアントプロセスは、Java および JATMI プリミティブを使用して、次の基本アプリケーションタスクを提供します。

クライアントは、アプリケーションとの接続を切断する前に、いくつでもサービスリクエストを送信および受信できます。

Tuxedo オブジェクトの取得

TuxedoConnectionFactory を使用して JNDI ツリーで「tuxedo.services.TuxedoConnection」をルックアップすることによって、リモートドメインへの接続を確立し、getTuxedoConnection() を使用して TuxedoConnection オブジェクトを取得します。

メッセージバッファリングの実行

アプリケーションと Tuxedo 間でメッセージの送信および受信を行うときは、次のバッファタイプを使用します。

表2-1 TypedBuffers

バッファタイプ	説明
TypedString	データが NULL 文字で終了する文字の配列である場合に使用されるバッファタイプ。Tuxedo の等価タイプ : STRING。
TypedCArray	データが、NULL 可能な文字の未定義配列（バイト配列）である場合に使用されるバッファタイプ。Tuxedo の等価タイプ : CARRAY。
TypedFML	データが自己定義である場合に使用されるバッファタイプ。各データフィールドは独自の識別子、オカレンス番号、および可能であれば長さインジケータを保持する。Tuxedo の等価タイプ : FML。
TypedFML32	TypeFML に似たバッファタイプだが、より大きい文字フィールド、より多くのフィールド、およびより大きいバッファ全体に対して使用可能。Tuxedo の等価タイプ : FML32。
TypedXML	データが XML ベースのメッセージである場合に使用されるバッファタイプ。Tuxedo の等価タイプ : XML（Tuxedo リリース 7.1 以降）。

メッセージの送信および受信

WebLogic Tuxedo コネクタクライアントは、Tuxedo サービスアプリケーションとの間で以下の 2 タイプの通信をサポートしています。

要求/応答通信

WebLogic Tuxedo コネクタクライアントアプリケーションと Tuxedo 間で要求を行い、応答メッセージを受信するには、次の JATMI プリミティブを使用します。

表2-2 JATMI プリミティブ

名前	操作
`tpacall`	Tuxedo サービスの非同期呼び出しに使用する。
`tpcall`	Tuxedo サービスの同期呼び出しに使用する。
`tpdequeue`	Tuxedo /Q からのメッセージ受信に使用する。
`tpenqueue`	Tuxedo /Q にメッセージを配置するために使用する。
`tpgetrply`	Tuxedo サービスからの応答を検索するために使用する。

対話通信

注意: 対話通信の詳細については、 WebLogic Tuxedo コネクタ JATMI 対話を参照してください。

以下の JATMI プリミティブは、Tuxedo サービスと通信する対話クライアントを作成する際に使用します。

表2-3 WebLogic Tuxedo コネクタの対話クライアントのプリミティブ

名前	操作
`tpconnect`	Tuxedo 対話サービスとの接続を確立するために使用する。
`tpdiscon`	対話を管理するプロセスによって実行された場合に接続を中止し、TPEV_DISCONIMM イベントを生成するために使用する。
`tprecv`	Tuxedo アプリケーションからオープンな接続を介してデータを受信するために使用する。
`tpsend`	Tuxedo アプリケーションにオープンな接続を介してデータを送信するために使用する。

Tuxedo オブジェクトへの接続の終了

オブジェクトへの接続を終了し、このオブジェクトでは今後操作を行わないようにするには、tpterm() を使用します。

クライアント EJB の例

次の Java コードは、サーバに文字列引数を送信し、サーバから応答文字列を受信する ToupperBean.java クライアント EJB の例です。

コードリスト 2-2 クライアントアプリケーションの例

.
.
.
public String Toupper(String toConvert)
   throws TPException, TPReplyException
{
	     Context ctx;
	     TuxedoConnectionFactory tcf;
	     TuxedoConnection myTux;	
	     TypedString myData;
     	Reply myRtn;
	     int status;

	     log("toupper called, converting " + toConvert);

	         try {
          		ctx = new InitialContext();
		          tcf = (TuxedoConnectionFactory) ctx.lookup(
                			"tuxedo.services.TuxedoConnection");
	     }
	     catch (NamingException ne) {
		          // tuxedo オブジェクトを取得できなかった場合に TPENOENT を送出する
           		throw new TPException(TPException.TPENOENT, "Could not get TuxedoConnectionFactory : " + ne);
     	}
	
	     myTux = tcf.getTuxedoConnection();

	     myData = new TypedString(toConvert);

	     log("About to call tpcall");
     	    try {
		          myRtn = myTux.tpcall("TOUPPER", myData, 0);
	}
	     catch (TPReplyException tre) {
		          log("tpcall threw TPReplyExcption " + tre);
          		throw tre;
	     }
     	catch (TPException te) {
          		log("tpcall threw TPException " + te);
          		throw te;
     	}
     	catch (Exception ee) {
          		log("tpcall threw exception: " + ee);
          		throw new TPException(TPException.TPESYSTEM, "Exception: " + ee);
     	}
     log("tpcall successfull!");

     	myData = (TypedString) myRtn.getReplyBuffer();

     	myTux.tpterm();	// Tuxedo との関連付けの終了
	
     	return (myData.toString());
}
.
.
.