イベント・ベースの通信では、特定の状況(イベント)が発生すると、Oracle Tuxedoシステムのプロセスに通知されます。
Oracle Tuxedoシステムには、次の2種類のイベント・ベースの通信があります。
非請求イベントは、メッセージを待たないクライアント・プログラム、またはメッセージを要求しないクライアント・プログラムとの通信に使用されるメッセージです。
ブローカ・イベントを使用すると、メッセージの受信と配信を行う無名ブローカを介して、クライアントとサーバーが透過的に通信できるようになります。このようなブローカを使用した通信は、Oracle Tuxedoシステムの基本要素であるクライアント/サーバーのコミュニケーション・パラダイムの1つです。
イベント・ブローカは、イベント・ポスト・メッセージを受信してフィルタ処理し、それらのメッセージをサブスクライバに配布するOracle Tuxedoのサブシステムです。 ポスト元とは、特定のイベントが発生したときにそれをイベント・ブローカに報告(ポスト)するOracle Tuxedoシステムのプロセスです。 サブスクライバとは、特定のイベントがポストされたときに常に通知する必要があるOracle Tuxedoシステムのプロセスです。
Oracle Tuxedoシステムでは、サービスのリクエスト側と提供側の数の比率が一定である必要はなく、任意の数のポスト元が任意の数のサブスクライバに対してメッセージをポストできます。ポスト元は単にイベントをポストするだけで、情報を受信するプロセスや、情報の処理方法については関知しません。サブスクライバには指定されたイベントが通知されますが、その情報のポスト元は通知されません。このように、イベント・ブローカでは位置透過性が実現されます。
通常、イベント・ブローカ・アプリケーションは、例外イベントを処理します。 アプリケーションの設計者は、アプリケーション内でどのイベントを例外イベントとして定義して監視する必要があるのかを決定しなければなりません。 たとえば、銀行業務アプリケーションでは、高額な引出しがあったときにイベントがポストされるように設定し、すべての引出しに対してイベントがポストされる必要はありません。 また、すべてのユーザーがそのイベントをサブスクライブする必要はありません。支店長だけに通知すれば十分です。
イベントがポストされると、EventBrokerはイベントをサブスクライブしているクライアントまたはサーバー(あるいは両方)に対して、1つ以上の通知処理を実行します。表8-1は、EventBrokerが実行する通知処理の種類を示しています。
イベント通知メッセージは、TPDEQUEUE(3cbl)を使用して、Oracle Tuxedoシステムの高信頼性キューに格納されます。イベント通知レコードは、内容がリクエストされるまで格納されます。Oracle Tuxedoシステムのクライアントまたはサーバー・プロセスでTPDEQUEUE(3cbl)を呼び出して、この通知レコードを取り出すことができます。または、TMQFORWARD(5)を設定して、通知レコードを取り出すOracle Tuxedoシステムのサービス・ルーチンを自動的にディスパッチすることもできます。
|
アプリケーション管理者は、Oracle Tuxedoの管理用APIを使用して、次の通知処理を行うEVENT_MIB(5)エントリを作成できます。
注意: | EVENT_MIB(5)エントリを作成できるのは、Oracle Tuxedoアプリケーション管理者だけです。 |
EVENT_MIB(5)の詳細は、『ファイル形式、データ記述、MIBおよびシステム・プロセス・リファレンス』を参照してください。
TMUSREVT
はOracle Tuxedoシステムで提供されるサーバーで、ユーザー定義のイベントに対するイベント・ブローカとして動作します。 TMUSREVT
はイベント・レポート用のメッセージ・レコードを処理し、それらのレコードをフィルタ処理して配信します。 イベントのブローカ処理を行うには、Oracle Tuxedoアプリケーション管理者がこれらのサーバーを1つ以上起動する必要があります。
TMSYSEVT
はOracle Tuxedoシステムで提供されるサーバーで、システム定義のイベントに対するイベント・ブローカとして動作します。TMSYSEVT
とTMUSREVT
は似ています。ただし、別個のサーバーが提供されているので、アプリケーション管理者はこの2種類のイベント通知に対して異なる処理方法を取り入れることができます。詳細は、『Oracle Tuxedoアプリケーションの設定』を参照してください。
Oracle Tuxedoシステムでは、システムの警告と障害に関連する定義済みの特定のイベントが検出されてポストされます。これらの処理はイベント・ブローカによって行われます。たとえば、システム定義のイベントには、設定の変更、状態の変更、接続の障害、マシンの分断などがあります。イベント・ブローカによって検出されるシステム定義のイベントの全リストについては、『ファイル形式、データ記述、MIBおよびシステム・プロセス・リファレンス』の「EVENTS(5)」を参照してください。
システム定義のイベントは、Oracle Tuxedoシステム・コードで定義されているため、ポストする必要はありません。システム定義のイベント名は、アプリケーション定義のイベント名とは異なり、必ずドット(.)で始まります。アプリケーション定義のイベント名をドットで始めることはできません。
クライアントとサーバーは、システム定義のイベントをサブスクライブできます。 ただし、システム定義のイベントは、アプリケーション内のすべてのクライアントが使用するのではなく、主にアプリケーション管理者が使用します。
イベント・ブローカをアプリケーションに組み込む場合、イベント・ブローカが多数のサブスクライバに大量の配信を行うためのシステムではないことを考慮してください。 発生するすべての動作に対してイベントをポストしないでください。また、すべてのクライアントとサーバーがイベントをサブスクライブする必要はありません。 イベント・ブローカに負荷がかかると、システムのパフォーマンスに影響し、通知が行われなくなる場合があります。 負荷を最小限にするには、『Oracle Tuxedoシステムのインストール』で説明するように、アプリケーション管理者がオペレーティング・システムのIPCリソースを慎重に調整する必要があります。
イベント・ブローカ・プログラミング・インタフェースは、ワークステーションを含むすべてのOracle Tuxedoシステムのサーバー・プロセスおよびクライアント・プロセスに対してC言語およびCOBOL言語で使用できます。
サブスクライバへの通知方法には様々な方法(「通知処理」を参照)があり、イベントはフィルタ処理されます。通知処理とフィルタ処理は、プログラミング・インタフェースとOracle Tuxedoシステムの管理用APIを使用して設定します。
非請求メッセージ・ハンドラを定義するには、次の文法を使用してTPSETUNSOL(3cbl)ルーチンを呼び出します。
01 CURR-ROUTINE PIC S9(9) COMP-5.
01 PREV-ROUTINE PIC S9(9) COMP-5.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL "TPSETUNSOL" USING CURR-ROUTINE PREV-ROUTINE TPSTATUS-REC.
TPSETUNSOL
を使用すると、非請求メッセージがOracle Tuxedoシステム・ライブラリによって受信されたときに呼び出されるルーチンをクライアントが識別できるようになります。TPSETUNSOL
を初めて呼び出す前に、クライアントにかわってOracle Tuxedoシステム・ライブラリが受信した非請求メッセージはログに記録されるだけで無視されます。システムが通知や検出に使用する処理方法は、アプリケーションのデフォルト設定によって決まります。このデフォルト設定は、クライアントごとに変更できます。詳細は、『Oracle Tuxedo ATMI COBOL関数リファレンス』の「TPINITIALIZE(3cbl)」を参照してください。
CURR-ROUTINE
パラメータは、非請求メッセージを処理する16種類の定義済みルーチンを識別します。これらのルーチンには、Cルーチンとしてはtm_displatch1
- _tm_dispatch8
の8種類、COBOLルーチンとしてはTMDISPATCH9
- TMDISPATCH16
の8種類があります。また、CURR-ROUTINE
に0を設定した場合、Oracle Tuxedoシステム・ライブラリがクライアントにかわって受信した非請求メッセージはログに記録されるだけで無視されます。Cルーチンは、TPSETUNSOL(3cbl)のパラメータ定義に準拠している必要があります。COBOLルーチンを使用する場合は、TPGETUNSOL
を呼び出してデータを受信する必要があります。
次のサンプル・コードは、COBOLプログラムでの非請求ルーチンの設定方法を示しています。
*
* Call TPSETUNSOL - Set a COBOL unsolicited message handler
* Routine TMDISPATCH9 will be called
*
MOVE 9 to CURR-ROUTINE.
CALL "TPSETUNSOL" USING
CURR-ROUTINE
PREV-ROUTINE
TPSTATUS-REC.
IF NOT TPOK
Routine TMDISPATCH9 will receive unsolicited messages
ELSE
Process error condition
Oracle Tuxedoシステムでは、リクエスト/レスポンス型呼び出しまたは会話型通信の処理を妨げずに、クライアント・プロセスに非請求メッセージを送信できます。
非請求メッセージは、名前、または以前に処理されたメッセージと共に受信した識別子を使用して、クライアント・プロセスに送信できます。名前による送信にはTPBROADCAST(3cbl)、識別子による送信にはTPNOTIFY(3cbl)を使用します。 TPBROADCAST
で送信されるメッセージの発信元は、サービスまたは別のクライアントです。 TPNOTIFY
で送信されるメッセージの発信元は、サービスだけです。
TPBROADCAST(3cbl)ルーチンを使用すると、アプリケーションの登録されたクライアントにメッセージが送信されます。 TPBROADCASTルーチンは、サービスまたは別のクライアントから呼び出すことができます。 登録されたクライアントとは、TPINITIALIZE
を呼び出したが、まだTPTERM
を呼び出してはいないクライアントのことです。
TPBROADCAST
ルーチンの呼出しには、次の文法を使用します。
01 TPBCTDEF-REC.
COPY TPBCTDEF.
01 TPTYPE-REC.
COPY TPTYPE.
01 DATA-REC.
COPY User Data.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL "TPBROADCAST" USING TPBCTDEF-REC TPTYPE-REC DATA-REC TPSTATUS-REC.
表8-2は、PBCTDEF-REC
データ構造体のメンバーを示しています。
TPTYPE-REC
レコードの詳細は、『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の「サービスの定義」を参照してください。
次のサンプル・コードは、すべてのクライアントを送信先としてTPBROADCAST
を呼び出す方法を示しています。 送信メッセージは、STRING
型レコード内にあります。
. . .
**************************************************
* Prepare the record to broadcasted
**************************************************
MOVE "HELLO, WORLD" TO DATA-REC.
MOVE 11 TO LEN.
MOVE "STRING" TO REC-TYPE.
*
SET TPNOBLOCK TO TRUE.
SET TPNOTIME TO TRUE.
SET TPSIGRSTRT TO TRUE.
*
MOVE SPACES TO LMID.
MOVE SPACES TO USRNAME.
MOVE SPACES TO CLTNAME.
CALL "TPBROADCAST" USING TPBCTDEF-REC
TPTYPE-REC
DATA-REC
TPSTATUS-REC.
IF NOT TPOK
error processing
TPNOTIFY(3cbl)ルーチンを使用すると、以前に処理されたメッセージと一緒に受信した識別子を使用してメッセージがブロードキャストされます。これは、サービスからのみ呼び出すことができます。
TPNOTIFY
ルーチンの呼出しには、次の文法を使用します。
01 TPSVCDEF-REC.
COPY TPSVCDEF.
01 TPTYPE-REC.
COPY TPTYPE.
01 DATA-REC.
COPY User Data.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL "TPNOTIFY" USING TPSVCDEF-REC TPTYPE-REC DATA-REC TPSTATUS-REC.
TPSVCDEF-REC
データ構造体の詳細は、『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の「グローバル・トランザクションのコーディング」、TPTYPE-REC
レコードの詳細は、『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の「サービスの定義」を参照してください。
クライアントがディップ・イン通知モードで実行されている場合に非請求メッセージがあるかどうかを確認するには、次のシグネチャを使用してTPCHKUNSOL(3cbl)ルーチンを呼び出します。
01 MSG-NUM PIC S9(9) COMP-5.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL "TPCHKUNSOL" USING MSG-NUM TPSTATUS-REC.
未処理のメッセージがある場合、TPSETUNSOL
で指定された非請求メッセージ処理ルーチンが呼び出されます。 処理が終了すると、このルーチンは処理した非請求メッセージの数を返し、[TPOK
]にTP-STATUS
を設定します。
クライアントがシグナル・ベースまたはスレッド・ベースの通知モードで実行されている場合、またはクライアントが非請求メッセージを無視している場合にこのルーチンを呼び出すと、ルーチンは何も処理を行わずにすぐに制御を戻します。
次の例は、非請求メッセージが到着しているかどうかを確認する方法を示しています。
*
* Check for unsolicited messages
*
CALL "TPCHKUNSOL" USING MESS-NUM
TPSTATUS-REC.
*
IF TPOK
IF MESS-NUM IS = 0
No messages were processed by the
unsolicited routine
ELSE
MESS-NUM number of messages were
processed by the unsolicited routine
END-IF
ELSE
process error
END-IF
非請求メッセージを取得するには、TPGETUNSOL(3cbl)ルーチンを呼び出す必要があります。 このルーチンは、非請求メッセージ・ハンドラからのみ呼び出すことができます。 TPGETUNSOL
ルーチンの呼出しには、次の文法を使用します。
01 TPTYPE-REC.
COPY TPTYPE.
01 DATA-REC.
COPY User data.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL "TPGETUNSOL" USING TPTYPE-REC DATA-REC TPSTATUS-REC.
TPTYPE-REC
レコードの詳細は、『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の「サービスの定義」を参照してください。
IDENTIFICATION DIVISION.
PROGRAM-ID. TMDISPATCH9.
ENVIRONMENT DIVISION.
CONFIGURATION SECTION.
SOURCE-COMPUTER. USL-486.
OBJECT-COMPUTER. USL-486.
*
DATA DIVISION.
WORKING-STORAGE SECTION.
*
01 TPTYPE-REC.
COPY TPTYPE.
*
01 TPSTATUS-REC.
COPY TPSTATUS.
*
01 DATA-REC PIC X(1000).
*
PROCEDURE DIVISION.
*
A-000.
*
MOVE "CARRAY" TO REC-TYPE.
MOVE 1000 TO LEN.
CALL "TPGETUNSOL" USING TPTYPE-REC
DATA-REC
TPSTATUS-REC.
IF NOT TPOK
error processing
*
Process message
DISPLAY "TPGETUNSOL IS TPOK".
DISPLAY "MESSAGE IS" DATA-REC.
DISPLAY "LENGTH IS" LEN.
EXIT PROGRAM.
*
TPSUBSCRIBE(3cbl)ルーチンを使用すると、Oracle Tuxedoシステムのクライアントまたはサーバーがイベントをサブスクライブできるようになります。
サブスクライバは、非請求通知メッセージ、サービス呼び出し、高い信頼性のキュー、またはアプリケーション管理者が設定する別の通知方法によって、通知を受け取ります。 別の通知方法の設定については、『Oracle Tuxedoアプリケーションの設定』を参照してください。
TPSUBSCRIBE
ルーチンの呼出しには、次の文法を使用します。
01 TPEVTDEF-REC.
COPY TPEVTDEF.
01 TPQUEDEF-REC.
COPY TPQUEDEF.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL “TPSUBSCRIBE” USING TPEVTDEF-REC TPQUEDEF-REC TPSTATUS-REC
TPEVTDEF-REC
データ構造体の文法は、次のとおりです。
05 TPBLOCK-FLAG PIC S9(9) COMP-5.
88 TPBLOCK VALUE 0.
88 TPNOBLOCK VALUE 1.
05 TPTRAN-FLAG PIC S9(9) COMP-5.
88 TPTRAN VALUE 0.
88 TPNOTRAN VALUE 1.
05 TPREPLY-FLAG PIC S9(9) COMP-5.
88 TPREPLY VALUE 0.
88 TPNOREPLY VALUE 1.
05 TPTIME-FLAG PIC S9(9) COMP-5.
88 TPTIME VALUE 0.
88 TPNOTIME VALUE 1.
05 TPSIGRSTRT-FLAG PIC S9(9) COMP-5.
88 TPNOSIGRSTRT VALUE 0.
88 TPSIGRSTRT VALUE 1.
05 TPEV-METHOD-FLAG PIC S9(9) COMP-5.
88 TPEVNOTIFY VALUE 0.
88 TPEVSERVICE VALUE 1.
88 TPEVQUEUE VALUE 2.
05 TPEV-PERSIST-FLAG PIC S9(9) COMP-5.
88 TPEVNOPERSIST VALUE 0.
88 TPEVPERSIST VALUE 1.
05 TPEV-TRAN-FLAG PIC S9(9) COMP-5.
88 TPEVNOTRAN VALUE 0.
88 TPEVTRAN VALUE 1.
*
05 EVENT-COUNT PIC S9(9) COMP-5.
05 SUBSCRIPTION-HANDLE PIC S9(9) COMP-5.
05 NAME-1 PIC X(127).
05 NAME-2 PIC X(127).
05 EVENT-NAME PIC X(31).
05 EVENT-EXPR PIC X(255).
05 EVENT-FILTER PIC X(255).
次の表は、TPEVTDEF-REC
データ構造体のメンバーを示しています。
サブスクライブするイベント。正規表現を含み、NULL文字で終了する最大255文字の文字列を指定します。正規表現は、tpsubscribe(3c)で指定された形式です(『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』を参照)。たとえば、次のように |
|
イベント・ブローカがイベントをポストする前に、評価する必要のあるブール型のフィルタ規則を含む文字列。ポストするイベントを受け取ると、イベント・ブローカはそのイベントのデータにフィルタ規則(定義されている場合)を適用します。データが正しく評価された場合、イベント・ブローカは指定された通知方法を呼び出し、正しく評価されなかった場合、イベント・ブローカは指定された通知方法を無視します。呼出し側は、異なるフィルタ規則を利用して同じイベントを何度でもサブスクライブすることができます。
イベント・フィルタ機能を使用すると、サブスクライバは通知されるイベントを限定できます。たとえば、$10,000.00を超える額の引出しがあった場合に、イベントがポストされるとします。その場合、サブスクライバがもっと高い額(たとえば$50,000.00)の通知だけを必要とすることがあります。または、特定の顧客による高額の引出しの通知だけを必要とする場合があります。
フィルタ・ルールは、フィルタ・ルールの適用対象となる型付きレコードによって異なります。フィルタ規則の詳細は、『Oracle Tuxedo ATMI COBOL関数リファレンス』の「TPSUBSCRIBE(3cbl)」リファレンス・ページを参照してください。
|
|
TPQUEDEF-RECデータ構造体の詳細は、『ATMI /Qコンポーネントの使用』を参照してください。
システム定義のイベントとアプリケーション定義のイベントは、TPSUBSCRIBE
ルーチンを使用してサブスクライブできます。
サブスクリプション、およびMIB
を更新するためにOracle Tuxedoシステムのサーバー・プロセスで実行されるサービス・ルーチンは、信頼されたコードとみなされます。
このルーチンの詳細は、『Oracle Tuxedo ATMI COBOL関数リファレンス』の「TPSUBSCRIBE(3cbl)」を参照してください。
TPUNSUBSCRIBE(3cbl)ルーチンを使用すると、Oracle Tuxedoシステムのクライアントまたはサーバーがイベントに対するサブスクリプションを削除できます。
TPUNSUBSCRIBE
ルーチンの呼出しには、次の文法を使用します。
01 TPEVTDEF-REC.
COPY TPEVTDEF.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL “TPUNSUBSCRIBE” USING TPEVTDEF-REC TPSTATUS-REC
TPEVTDEF-REC
データ構造体の詳細は、「イベントのサブスクライブ」を参照してください。TPQUEDEF-RECデータ構造体の詳細は、『ATMI /Qコンポーネントの使用』を参照してください。
TPPOST(3cbl)ルーチンを使用すると、Oracle Tuxedoのクライアントまたはサーバーがイベントをポストできます。
01 TPEVTDEF-REC.
COPY TPEVTDEF.
01 TPTYPE-REC.
COPY TPSTATUS.
01 TPDATA-REC.
COPY TPSTATUS.
01 TPSTATUS-REC.
COPY TPSTATUS.
CALL “TPPST” USING TPEVTDEF-REC TPTYPE-REC TPDATA-REC TPSTATUS-REC
TPEVTDEF-REC
データ構造体の詳細は、「イベントのサブスクライブ」、TPTYPE-REC
レコードの詳細は、『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の「サービスの定義」を参照してください。