Oracle Tuxedoアプリケーションを開発する前に
Oracle Tuxedoのアプリケーション・トランザクション・モニター・インタフェース(ATMI)を開発する場合、まず設計に関連する各種の概念や利用できるツールを確認しておきます。たとえば、
クライアント(外部からの入力データを業務のために収集および処理する様々な方法)、および
サーバー(入力データを処理するビジネス・ロジックが定義されたプログラム)について理解しておきます。また、
型付きバッファ (クライアント・プログラムがメモリー領域を割り当て、別のプログラムにデータを送る方法)についても理解しておきます。Oracle Tuxedoの
メッセージング・パラダイムも、確認が必要になる重要な概念です。ATMIクライアント・プログラムは、ATMIライブラリを呼び出すことによって、Oracle Tuxedoシステムにアクセスします。ATMIライブラリのほとんどの呼出しでは、リクエスト/レスポンス型や会話型などの通信方法がサポートされています。これらの通信は、Oracle Tuxedoアプリケーションの基本部分です。
アプリケーション・キュー、イベント・ベースの通信、ATMIの使用方法の概念、および使用できるツールの詳細は、
『Oracle Tuxedo ATMIの紹介』の
Oracle Tuxedo ATMI環境の基本アーキテクチャに関する項を参照してください。アプリケーションのプログラミングの詳細は、
『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』および
『COBOLを使用したOracle Tuxedo ATMIアプリケーションのプログラミング』を参照してください。
Oracle Tuxedo ATMIクライアントの作成
Oracle Tuxedoのクライアントは、CまたはC++などのプログラミング言語でプログラムを作成するのと同じように作成できます。Oracle Tuxedoシステムには、Oracle Tuxedo ATMIと呼ばれるC言語に基づいたプログラミング・インタフェースが用意されています。ATMIは、Oracle Tuxedoのクライアントとサーバーの開発をサポートする使いやすいインタフェースです。
|
注意:
|
Oracle Tuxedo ATMIでは、COBOLインタフェースもサポートされています。図1-1は、C/C++ APIの例です。 |
クライアントでは、次のような基本タスクが行われます。
|
•
|
tpchkauth()を呼び出して、アプリケーションに参加するために必要なセキュリティ・レベルを決定します。戻り値として返されるセキュリティ・レベルには、セキュリティなし、アプリケーション・パスワード、アプリケーション認証、アクセス制御リスト、リンク・レベル暗号化、公開鍵の暗号化、監査などがあります。これらの値は、セキュリティ・レベルを設定している場合にのみ返されます。
|
|
•
|
tpinit()を呼び出して、Oracle Tuxedoアプリケーションに接続します。必要なセキュリティ情報は、 tpinit()の引数としてアプリケーションに渡されます。
|
|
•
|
tpterm()を呼び出して、Oracle Tuxedoアプリケーションとの接続を解除します。
|
|
•
|
『Oracle Tuxedo C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の クライアントのコーディングに関する項
|
|
•
|
『CORBAアプリケーションにおけるセキュリティの使用』の セキュリティの管理に関する項
|
|
•
|
『Oracle Tuxedo ATMIの紹介』の 型付きバッファに関する項
|
|
•
|
『Oracle Tuxedo ATMIの紹介』の「ATMIの使用」
|
Oracle Tuxedo ATMIサーバーの作成
Oracle Tuxedoのクライアントとサーバーは、ATMIプログラミング・インタフェースを使用して作成できます。ただし、Oracle Tuxedoサーバーは完全なプログラム、つまり標準的な
main関数を使ったプログラムとして開発されたものではありません。かわりに、アプリケーション開発者は、サービスと呼ばれる特定のビジネス関数を使用します。この関数は、Oracle Tuxedoのバイナリ形式でコンパイルされて、実行可能サーバーが生成されます。
Oracle Tuxedoサーバーが起動すると、停止メッセージを受信するまで稼働し続けます。通常、Oracle Tuxedoサーバーは停止して再起動するまでに、何千ものサービス呼出しを行います。
|
•
|
アプリケーション開発者が記述したコードにより、Oracle Tuxedo ATMIサーバーは起動時に tpsvrinit()関数を呼び出します。プログラマは、この関数を使用して、後で使用するアプリケーション・リソース(データベースなど)を開きます。 |
|
•
|
アプリケーション開発者が記述したコードにより、Oracle Tuxedo ATMIサーバーは、停止時に tpsvrdone()関数を呼び出します。プログラマは、この関数を使用して、 tpsvrinit()によって開かれたアプリケーション・リソースを閉じます。 |
|
•
|
アプリケーション開発者が記述したコードにより、Oracle Tuxedo ATMIサーバーは、クライアントのリクエストを処理するアプリケーション・サービスをリクエストします。Oracle Tuxedo ATMIクライアントは、 サーバーを名前で呼び出すのではなく、 サービスを呼び出します。Oracle Tuxedo ATMIクライアントは、リクエストを処理するサーバーの場所を認識しません。 |
|
•
|
ATMIサーバーは、 tpreturn()関数を呼び出してサービス・リクエストを終了させ、必要に応じて呼出し側のクライアントにバッファを返します。 |
|
•
|
『Oracle Tuxedo C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』の サーバーのコーディングに関する項
|
|
•
|
『Oracle Tuxedo ATMIの紹介』の 型付きバッファに関する項
|
|
•
|
『Oracle Tuxedo ATMIの紹介』の ATMIの使用に関する項
|
Oracle Tuxedoシステムでは、すべての通信が型付きバッファを使用して行われます。Oracle Tuxedoシステムには通信を行うための各種のバッファ型があり、アプリケーション開発者がその型を選択することができます。Oracle Tuxedoシステムで渡されるすべてのバッファには特殊なヘッダーがあり、Oracle Tuxedo ATMI (
tpalloc()、
tprealloc()、および
tpfree())を介してバッファの割当てや解放が行われます。
型付きバッファ機能によって同じバッファ型を共有できるようになり、どの種類のネットワークやプロトコルでも、Oracle Tuxedoシステムでサポートされるどの種類のCPUアーキテクチャやオペレーティング・システムにも、データを送ることができるようになります。分散型の環境で型付きバッファを使用すると、各種の通信ネットワークを介してリンクされた異種コンピュータ間でデータを転送する場合に、クライアントおよびサーバーでデータを準備するための処理が簡略化されます。そのため、プログラマはこのような機能をプログラムに組み込む必要がなくなり、本来のビジネス・ロジックの開発に集中することができます。
|
•
|
『Oracle Tuxedo ATMIの紹介』の 型付きバッファに関する項
|
「アプリケーションでのOracle Tuxedoメッセージング・パラダイム」
Oracle Tuxedo ATMIには、アプリケーションで使用できる次のような通信モデルがあります。
同期呼出しを行う場合、Oracle Tuxedo ATMIクライアントはATMI関数
tpcall()を使用して、Oracle Tuxedo ATMIサーバーにリクエストを送ります。この関数は、Oracle Tuxedoサーバーを名前で呼び出すのではなく、指定されたサービスを呼び出します。指定されたサービスは、そのサービスを提供できる任意のサーバーによって提供されます。クライアントは、送信したサービス・リクエストが処理されるまで待機します。このリクエストに対する応答を受け取るまで、クライアントはほかの操作を行うことができません。つまり、クライアントでは、応答を受信するまで操作が「ブロック」されます。
|
•
|
『Oracle Tuxedo ATMIの紹介』の リクエスト/レスポンス型通信に関する項
|
非同期呼出しを行う場合、クライアントは2つのATMI関数を呼び出します。つまり、tpacall(3c)関数を使用してサービスをリクエストし、tpgetrply(3c)関数を使用して応答を受け取ります。
この方法は、クライアントがリクエストを送り、その応答を受け取るまでに別の操作を行う場合に使用します。
|
•
|
『Oracle Tuxedo ATMIの紹介』の リクエスト/レスポンス型通信に関する項
|
サービスは、Oracle Tuxedo ATMI
クライアントとして動作して、別のOracle Tuxedoサービスを呼び出すことができます。つまり、サービスをリクエストして、そのサービスが別のサービスをリクエストすることができます。たとえば、Oracle TuxedoクライアントがサービスXを呼び出し、その応答を待ちます。その後、サービスXはサービスYを呼び出し、その応答を待ちます。サービスXが応答を受け取ると、サービスXは呼出し側のクライアントにその応答を返します。この方法では、サービスXがサービスYからの応答を取得し、その応答になんらかの処理を行い、返されたバッファを変更してから最終的な応答をクライアントに返すことができます。
|
•
|
『Oracle Tuxedo ATMIの紹介』の ネストされたリクエストに関する項
|
呼出しを転送すると、ネストされたサービスが、最初に呼び出されたサービスを経由せずに直接ATMI
クライアントに応答を返すことができます。このため、最初のサービスは他のリクエストを処理できるようになります。この機能は、最初に呼び出されたサービスが配信エージェントとしてのみ機能し、ネストされたサービスから返された応答にデータを追加しない場合に使用します。
呼出しを転送する場合、クライアントによって呼び出されたサービスはtpforward(3c)関数を使用して、別のサービスYにリクエストを渡します。このような処理でのみ、Oracle Tuxedoサービスはtpreturn(3c)を呼び出さずに、サービス呼出しを終了できます。
呼出しの転送は、クライアントに透過的に行われます。つまり、同じクライアント・コードを使用して、1つのサービスによって処理されるサービス・リクエストも、複数のサービスによって処理されるサービス・リクエストも扱うことができます。
|
•
|
『Oracle Tuxedo ATMIの紹介』の リクエストの転送に関する項
|
Oracle Tuxedo ATMI
クライアントとOracle Tuxedoサービス間で、ステートフルに複数のバッファを送信する必要がある場合は、Oracle Tuxedoの会話型通信を使用します。
サーバーが一度会話に参加すると、会話が終了するまでそのサーバーを利用できなくなるため、Oracle Tuxedo会話型通信は慎重に使用します。会話型通信を実装するには、次の手順をコードに記述します。
|
1.
|
Oracle Tuxedoクライアントは、tpconnect()関数を使用して会話を開始します。
|
|
2.
|
Oracle Tuxedoクライアントおよび会話型サーバーは、tpsend()およびtprecv()関数を使用してバッファを交換します。サービス呼出しには特定のフラグが設定され、クライアントとサーバーのどちらが会話を制御しているのかが示されます。
|
|
3.
|
サーバーがtpreturn()または tpdiscon()関数を呼び出すと、会話は正常に終了します。
|
|
•
|
『Oracle Tuxedo ATMIの紹介』の 会話型通信に関する項
|
非請求通知を有効にするには、Oracle Tuxedo ATMI
クライアントでtpsetunsol()関数を使用して非請求メッセージ・ハンドルを作成します。
非請求メッセージを送信する場合、Oracle Tuxedoクライアントまたはサーバーは、単一のクライアントにメッセージを送信するときはtpnotify()関数、複数のクライアントに同時にメッセージを送信するときは
tpbroadcast()関数
を使用します。クライアントがメッセージを受信すると、Oracle Tuxedoシステムはクライアントの非請求ハンドラ関数を呼び出します。
シグナル・ベースのシステムでは、クライアントは非請求メッセージをポーリングする必要はありません。ただし、非シグナル・ベースのシステムでは、クライアントはtpchkunsol()関数を使用して、非請求メッセージを確認する必要があります。
クライアントがサービス・リクエストを作成すると、暗黙的にtpchkunsol()が呼び出されます。
|
注意:
|
tpackフラグ・ビットを設定してtpnotify()を呼び出すと、リクエストに対する肯定応答が送信されます。
|
|
•
|
『Oracle Tuxedo ATMIの紹介』の 非請求通信に関する項
|
イベント・ベースの通信では、イベントをアプリケーション・キュー、ログ・ファイル、およびシステム・コマンドにポストできます。Oracle Tuxedo ATMI
クライアントは、tpsubscribe()関数を使用してユーザー定義のイベントをサブスクライブし、Oracle Tuxedoサービスまたはクライアントがtppost()関数を呼び出したときに非請求メッセージを受信できます。また、ATMI
クライアントは、Oracle Tuxedoシステムがイベントを検出したときにトリガーされるシステム定義のイベントをサブスクライブすることもできます。たとえば、サーバーが異常終了すると、.SysServerDiedイベントがポストされます。このイベントのポストはOracle Tuxedoシステムによって行われるため、アプリケーション・サーバーがポストする必要がありません。
|
•
|
『Oracle Tuxedo ATMIの紹介』の イベントの通知に関する項
|
/Qシステムとのインタフェースとして、Oracle Tuxedoクライアントは2つのATMI関数を使用します。つまり、キュー・スペースにメッセージを格納するtpenqueue()関数と、
キュー・スペースからメッセージを取得するtpdequeue()関数を使用します。
次の図は、ピア・ツー・ピアの非同期メッセージングを表しています。この例では、クライアントはtpenqueue()を使用してサービスにメッセージを登録します。オプションで、tpenqueue()の呼出しに、応答キューおよび異常終了キューの名前を指定できます。クライアントは、メッセージに付ける相関識別子の値を指定することもできます。この値は、キュー間で同じです。そのため、キューのメッセージに対応付けられたどの応答メッセージまたは異常終了メッセージも、応答キューまたは異常終了キューから読み取られるときに識別できます。
クライアントは、デフォルトのキューの順序付けを使用するか(たとえば、メッセージがキューから出されるまでの時間)、またはデフォルトのキューの順序付けの無効化を指定すること(たとえば、メッセージをキューの先頭に置くこと、またはキューの別のメッセージの前に置くこと)ができます。tpenqueue()は、TMQUEUEサーバーにメッセージを送信し、そのメッセージは安定ストレージのキューに登録され、肯定応答がクライアントに送信されます。肯定応答は、クライアントが直接確認することはできません。ただし、クライアントが正常な戻り値を取得すると、肯定応答が送られたと見なすことができます。異常終了の戻り値には、異常終了の内容についての情報が含まれています。キュー・マネージャによって割り当てられたメッセージ識別子は、アプリケーションに返されます。この識別子は、特定のメッセージをキューから取り出す場合に使用します。また、この識別子は、別のtpenqueue()内で使用して、キューに次に登録されるメッセージの前にあるメッセージを識別できます。
キューに登録されたメッセージをキューから取り出すには、そのメッセージをキューに登録しているトランザクションが正常にコミットされる必要があります。クライアントはtpdequeue()を使用して、キューからメッセージを取り出します。
次の図は、別のサーバーへのメッセージ転送を示しています。
クライアントはサーバー上のサービスXへのメッセージをキューに登録します。サービスは、メッセージがアクティブになった場合、およびメッセージの処理条件が満たされた場合に、メッセージを受信します。たとえば、メッセージが金曜日の午後6時にアクティブになるようにエンコードされている場合などに、メッセージを受け取ります。サービスが完了すると、キュー・スペースに応答が返されます。クライアントは、そこから応答を取得します。
この方法は、サービスに透過的です。つまり、同じアプリケーション・コードを使用して、キューを経由してサービスを呼び出すことも、tp(a)call関数を使用して直接サービスを呼び出すこともできます。
|
•
|
『Oracle Tuxedo ATMIの紹介』の メッセージ・キューイング通信に関する項
|
トランザクションを実装する場合、アプリケーション・プログラマは次の3つのATMI関数を使用します。
|
•
|
2フェーズ・コミット・プロセスを開始する tpcommit() |
|
•
|
即座にトランザクションを取り消す tpabort() |
トランザクションに含まれるコードは、開始、コミット、および停止のみです。
次の例では、クライアントがトランザクションを開始し、2つのサービスをリクエストし、トランザクションをコミットしています。サービス・リクエストはトランザクションが開始されてからコミットされるまでの間に作成されるため、どちらのサービスも同じトランザクションに参加します。
