C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング

会話型クライアントおよびサーバーのコーディング

このトピックには次の項が含まれます:

会話型通信の概要

会話型通信はOracle Tuxedoシステムのメッセージ交換のパラダイムで、人の会話に似た通信がATMIクライアントおよびサーバー間で実装されています。この通信方法では、クライアント(イニシエータ)とサーバー(サブオーディネート)間で仮想接続が行われて、双方で会話の状態に関する情報が保持されます。この接続は、接続を終了するイベントが発生するまで継続します。

会話型通信では、クライアントとサーバー間に半二重接続が確立されます。半二重接続では、メッセージが1方向だけに送信されます。接続に関する制御は、イニシエータからサブオーディネートへ、またはその逆に移ります。制御を持つプロセスがメッセージを送信でき、持たないプロセスは受信しかできません。

図7-1の銀行業務のオンライン・アプリケーションを例に、Oracle Tuxedo ATMIアプリケーションで行われる会話型通信について説明します。この例では、銀行の顧客が過去2か月間の当座預金の明細書をリクエストしています。

リクエスト/レスポンス型通信の場合と同じように、Oracle Tuxedoシステムでは型付きバッファを使用してデータが渡されます。アプリケーションがバッファ・タイプを認識できることが必要です。バッファ・タイプの詳細は、「型付きバッファの概要」を参照してください。

会話型のクライアントおよびサーバーには、次の特徴があります。

会話型通信は、次の点でリクエスト/レスポンス型通信と異なります。

アプリケーションへの参加

会話型クライアントは、サービスへの接続を確立する前に、tpinit()を呼び出してアプリケーションに参加する必要があります。詳細は、「クライアントのコーディング」を参照してください。

接続の確立

tpconnect(3c)関数は、会話を行うための接続を確立します。

tpconnect()関数の呼出しには、次のシグネチャを使用します。

int
tpconnect(char *name, char *data, long len, long flags)

表7-1は、tpconnect()関数の引数を示しています。

tpconnect()によって接続が確立されると、Oracle Tuxedoシステムから接続記述子(cd)が返されます。このcdは、特定の会話で以降に送られるメッセージを識別するために使用されます。クライアントまたは会話型サービスは、複数の会話に同時に参加できます。最大64個の会話を同時に行うことができます。

tpconnect()関数の呼出しが失敗すると-1が返され、対応するエラー・コードがtperrnoに設定されます。エラー・コードについては、『Oracle Tuxedo ATMI C言語関数リファレンス』の「tpconnect(3c)」を参照してください。

リスト7-1は、tpconnect()関数の使用方法を示しています。

#include atmi.h
#define    FAIL    -1
int cd1;        /* Connection Descriptor */
main()
{
 if ((cd = tpconnect(“AUDITC”,NULL,0,TPSENDONLY)) == -1) {
   error routine
 }
}

メッセージの送受信

Oracle Tuxedoシステムで会話型接続が確立されると、イニシエータとサブオーディネート間の通信は送信呼出しと受信呼出しを使用して行われます。接続の制御を持つプロセスは、tpsend(3c)関数を使用してメッセージを送信できます。制御がないプロセスは、tprecv(3c)関数を使用してメッセージを受信できます。

メッセージの送信

メッセージを送信するには、tpsend(3c)関数を使用します。この関数には、次のシグネチャを使用します。

int
tpsend(int cd, char *data, long len, long flags, long *revent)

表7-2は、tpsend()関数の引数を示しています。

tpsend()関数の呼出しが失敗すると-1が返され、対応するエラー・コードがtperrno(5)に設定されます。エラー・コードについては、『Oracle Tuxedo ATMI C言語関数リファレンス』の「tpsend(3c)」を参照してください。

tpsend()関数を呼び出すたびに、制御を渡す必要はありません。一部のアプリケーションでは、tpsend()の呼出しを認められているプロセスが、制御をほかのプロセスに渡すまで、現在のタスクで必要な回数だけ呼出しを実行できます。ただし、プログラムのロジックによっては、会話が継続する間は常に1つのプロセスが接続の制御を持たなければならないアプリケーションもあります。

リスト7-2は、tpsend()関数の呼出し方法を示しています。

if (tpsend(cd,line,0,TPRECVONLY,revent) == -1) {
              (void)userlog(“%s: tpsend failed tperrno %d”,
                    argv[0],tperrno);
              (void)tpabort(0);
              (void)tpterm();
              exit(1);
        }

メッセージの受信

オープン接続を介してデータを受信するには、tprecv(3c)関数を使用します。この関数には、次のシグネチャを使用します。

int
tprecv(int cd, char **data, long *len, long flags, long *revent)

次の表は、tprecv()関数の引数を示しています。

処理が成功すると、*dataが受信データを指し、lenにバッファのサイズが格納されます。lenがtprecv()を呼び出す前のバッファの合計サイズより大きい場合、バッファのサイズは変更されていて、lenはバッファの新しいサイズを示しています。len引数が0の場合、受信データがないことを示します。

リスト7-3は、tprecv()関数の使用方法を示しています。

if (tprecv(cd,line,len,TPNOCHANGE,revent) != -1) {
           (void)userlog(“%s: tprecv failed tperrno %d revent %ld”,
               argv[0],tperrno,revent);
            (void)tpabort(0);
            (void)tpterm();
            exit(1);
}

会話の終了

次の場合、接続が切断されて会話が正常に終了します。

以下の項では、会話を正常に終了する方法について、2つの例を挙げて説明します。これらの会話には、tpreturn()関数を使用するグローバル・トランザクションは含まれていません。

最初の例では、2つのコンポーネント間の単純な会話を終了する方法を示します。2番目の例では、会話が階層構造になっている複雑な会話を終了する方法を示します。

接続がオープンになっているときに会話を終了すると、エラーが返されます。その場合、tpcommit()またはtpreturn()は失敗します。

例: 単純な会話の終了

図7-2は、正常に終了するAとB間の単純な会話を示しています。

次の順序で処理が行われます。

例: 階層構造の会話の終了

図7-3は、正常に終了する階層構造の会話を示しています。

この例では、サービスBは会話のメンバーで、2番目のサービスCとの接続を開始しています。つまり、A - B間とB - C間という2つのアクティブな接続が存在しています。Bがこの両方の接続を制御している場合にtpreturn()の呼出しを行うと、呼出しは失敗し、すべてのオープン接続にTPEV_SVCERRイベントが通知され、接続が切断されます。

両方の接続を正常に終了するには、次の処理を順に行います。

会話の切断

エラーの発生により切断する唯一の方法は、tpdiscon(3c)関数を呼び出すことです(「プラグを抜くこと」と同じです)。この関数を呼び出すことができるのは、会話のイニシエータ(クライアント)のみです。

tpdiscon()関数の呼出しには、次のシグネチャを使用します。

int
tpdiscon(int cd)

cd引数は、接続が確立したときにtpconnect()関数によって返される接続記述子を指定します。

tpdiscon()関数は、接続の相手側のサービスに対してTPEV_DISCONIMMイベントを生成し、cdを無効にします。トランザクションが実行中の場合、そのトランザクションは中断され、データは失われます。

cdで接続の開始側と識別されていないサービスからtpdiscon()が呼び出されると、その呼出しは失敗し、エラー・コードTPEBADDESCが生成されます。

イベントおよびエラー・コードの全リストとその説明については、『Oracle Tuxedo ATMI C言語関数リファレンス』の「tpdiscon(3c)」を参照してください。

会話型のクライアントおよびサーバーのビルド

次のコマンドを使用して、会話型のクライアントおよびサーバーをビルドします。

会話型サービスとリクエスト/レスポンス型サービスでは、次の操作を行うことはできません。

会話型通信イベントの理解

Oracle Tuxedoシステムの会話型通信では、5つのイベントが認識されます。これらのイベントはすべてtprecv()に通知でき、そのうちの3つはtpsend()にも通知できます。

表7-3は、イベント、そのイベントを受け取る関数、および各イベントの詳細な説明を示しています。