目次

Oracle Tuxedo /Qの概要

はじめに

キュー・システムのコンポーネントとタスク

図1-1 キュー・サービスの呼出し

管理者のタスク

図1-2 ピア・ツー・ピア通信

プログラマのタスク

トランザクション管理

図1-3 トランザクション境界の判定

応答メッセージの処理

エラー処理

サマリー

Oracle Tuxedo /Qの管理

はじめに

サンプル・プログラムqsample

構成

QMサーバー・グループの指定

メッセージ・キュー・サーバーの指定

操作のタイムアウト

キュー・スペース名、キュー名、およびサービス名

データ依存型ルーティング

バッファ・タイプのカスタマイズ

バッファ・サブタイプ

メッセージ転送サーバーの指定

キュー名およびサービス名(-qオプション)

トランザクション・タイムアウトの指定(-tオプション)

アイドル時間の指定(-iオプション)

サーバー終了の指定(-eオプション)

サービスの異常終了後のメッセージの削除(-dオプション)

バッファ・タイプのカスタマイズ

動的な構成

キュー・スペースとキューの作成

qmadminのコマンドの使用方法

汎用デバイス・リストのエントリの作成(crdl)

キュー・スペースの作成(qspacecreate)

キューの作成(qcreate)

キューの順序の指定

順序を無視したキュー登録

再試行パラメータの指定

キューの容量の上限の使用

応答キューおよび異常終了キュー

エラー・キュー

暗号化メッセージ・バッファの処理

Oracle Tuxedo /Q機能の保守

キュー・スペースのエクステントの追加

キュー・スペースのバックアップの作成および移動

キュー・スペースの異種マシンへの移動

TMQFORWARDおよび非グローバルのトランザクション

TMQFORWARDおよびコミット制御

トランザクション・タイムアウトの処理

TMQFORWARDおよび利用できないサービスに対する再試行

Windows標準入出力

Oracle Tuxedo /QのC言語プログラミング

はじめに

前提知識

リクエストの発信元

デフォルトの場合の注意事項

メッセージのキューへの登録

tpenqueue(3c)の引数

tpenqueue(): qspace引数

tpenqueue(): qname引数

tpenqueue(): dataおよびlen引数

tpenqueue(): flags引数

TPNOTRAN

TPNOBLOCK

TPNOTIME

TPSIGRSTRT

TPQCTL構造体

リスト3-1 tpqctl_t構造体

リスト3-1 tpqctl_t構造体

#define TMQNAMELEN 127 #define TMMSGIDLEN 32 #define TMCORRIDLEN 32struct tpqctl_t { /* control parameters to queue primitives */ long flags; /* indicates which of the values are set */ long deq_time; /* absolute/relative time for dequeuing */ long priority; /* enqueue priority */ long diagnostic; /* indicates reason for failure */ char msgid[TMMSGIDLEN]; /* ID of message before which to queue */ char corrid[TMCORRIDLEN]; /* correlation ID used to identify message */ char replyqueue[TMQNAMELEN+1]; /* queue name for reply message */ char failurequeue[TMQNAMELEN+1]; /* queue name for failure message */ CLIENTID cltid; /* client identifier for originating client */ long urcode; /* application user-return code */ long appkey; /* application authentication client key */ long delivery_qos; /* delivery quality of service */ long reply_qos; /* reply message quality of service */ long exp_time; /* expiration time */ }; typedef struct tpqctl_t TPQCTL;

TPNOFLAGS

TPQTOP

TPQBEFOREMSGID

TPQTIME_ABS

TPQTIME_REL

TPQPRIORITY

TPQCORRID

TPQREPLYQ

TPQFAILUREQ

TPQDELIVERYQOS、TPQREPLYQOS

TPQQOSDEFAULTPERSIST

TPQQOSPERSISTENT

TPQQOSNONPERSISTENT

TPQEXPTIME_ABS

TPQEXPTIME_REL

TPQEXPTIME_NONE

TPQMSGID

[QMEINVAL]

[QMEBADRMID]

[QMENOTOPEN]

[QMETRAN]

[QMEBADMSGID]

[QMESYSTEM]

[QMEOS]

[QMEABORTED]

[QMEPROTO]

[QMEBADQUEUE]

[QMENOSPACE]

[QMERELEASE]

[QMESHARE]

キューの順序の無効化

キューの優先度の無効化

メッセージの使用可能時間の設定

tpenqueue()とトランザクション

メッセージのキューからの取出し

tpdequeue(3c)の引数

tpdequeue(): qspace引数

tpdequeue(): qname引数

tpdequeue(): dataおよびlen引数

tpdequeue(): flags引数

TPNOTRAN

TPNOBLOCK

TPNOTIME

TPNOCHANGE

TPSIGRSTRT

TPQCTL構造体

TPNOFLAGS

TPQGETBYMSGID

TPQGETBYCORRID

TPQWAIT

TPQPEEK

TPQPRIORITY

TPQMSGID

TPQCORRID

TPQDELIVERYQOS

TPQREPLYQOS

TPQREPLYQ

TPQFAILUREQ

[QMENOMSG]

[QMEINUSE]

TPQWAITの使用

TMQFORWARDサービス使用時のエラー処理

TMQFORWARDを通して呼び出されたサービスからの応答をキューから取り出す手順

メッセージの順次処理

ピア・ツー・ピア通信でのキューの使用

Oracle Tuxedo/Q COBOL言語プログラミング

はじめに

前提知識

リクエストの発信元

デフォルトの場合の注意事項

メッセージのキューへの登録

01 TPQUEDEF-REC.COPY TPQUEDEF.01 TPTYPE-REC.COPY TPTYPE.01 DATA-REC.COPY User Data.01 TPSTATUS-REC.COPY TPSTATUS.CALL "TPENQUEUE" USING TPQUEDEF-REC TPTYPE-REC DATA-REC TPSTATUS-REC.

01 TPQUEDEF-REC. COPY TPQUEDEF.01 TPTYPE-REC. COPY TPTYPE.01 DATA-REC. COPY User Data.01 TPSTATUS-REC. COPY TPSTATUS.CALL "TPENQUEUE" USING TPQUEDEF-REC TPTYPE-REC DATA-REC TPSTATUS-REC.

TPENQUEUE()の引数

TPENQUEUE(): TPQUEDEF-REC引数内のQSPACE-NAME

TPENQUEUE(): TPQUEDEF-REC引数内のQNAME

TPENQUEUE(): DATA-RECおよびTPTYPE-REC引数内のLEN

TPENQUEUE(): TPQUEDEF-RECの設定値

TPNOTRAN

TPTRAN

TPNOBLOCK

TPBLOCK

TPNOTIME

TPTIME

TPSIGRSTRT

TPNOSIGRSTRT

TPQUEDEF-REC構造体

リスト4-1 TPQUEDEF-REC構造体

リスト4-1 TPQUEDEF-REC構造体

TPQTOP

TPQBEFOREMSGID

TPQTIME-ABS

TPQTIME-REL

TPQPRIORITY

TPQCORRID

TPQREPLYQ

TPQFAILUREQ

TPQDELIVERYQOSTPQREPLYQOS

TPQQOSDELIVERYDEFAULTPERSISTTPQQOSREPLYDEFAULTPERSIST

TPQQOSDELIVERYPERSISTENTTPQQOSREPLYPERSISTENT

TPQQOSDELIVERYNONPERSISTENTTPQQOSREPLYNONPERSISTENT

TPQEXPTIME-ABS

TPQEXPTIME-REL

TPQEXPTIME-NONE

TPQNOEXPTIME

TPQMSGID

[QMEINVAL]

[QMEBADRMID]

[QMENOTOPEN]

[QMETRAN]

[QMEBADMSGID]

[QMESYSTEM]

[QMEOS]

[QMEABORTED]

[QMEPROTO]

[QMEBADQUEUE]

[QMENOSPACE]

[QMERELEASE]

[QMESHARE]

キューの順序の無効化

キューの優先度の無効化

メッセージの使用可能時間の設定

TPENQUEUE()およびトランザクション

メッセージのキューからの取出し

01 TPQUEDEF-REC.COPY TPQUEDEF.01 TPTYPE-REC.COPY TPTYPE.01 DATA-REC.COPY User Data.01 TPSTATUS-REC.COPY TPSTATUS.CALL "TPDEQUEUE" USING TPQUEDEF-REC TPTYPE-REC DATA-REC TPSTATUS-REC.

01 TPQUEDEF-REC. COPY TPQUEDEF.01 TPTYPE-REC. COPY TPTYPE.01 DATA-REC. COPY User Data.01 TPSTATUS-REC. COPY TPSTATUS.CALL "TPDEQUEUE" USING TPQUEDEF-REC TPTYPE-REC DATA-REC TPSTATUS-REC.

TPDEQUEUE()の引数

TPDEQUEUE(): TPQUEDEF-REC引数内のQSPACE-NAME

TPDEQUEUE(): TPQUEDEF-REC引数内のQNAME

TPDEQUEUE(): DATA-RECおよびTPTYPE-REC引数内のLEN

TPDEQUEUE(): TPQUEDEF-RECの設定値

TPNOTRAN

TPTRAN

TPNOBLOCK

TPBLOCK

TPNOTIME

TPTIME

TPNOCHANGE

TPCHANGE

TPSIGRSTRT

TPNOSIGRSTRT

TPQUEDEF-REC構造体

TPQGETNEXT

TPQGETBYMSGID

TPQGETBYCORRID

TPQWAIT

TPQPEEK

TPQPRIORITY

TPQMSGID

TPQCORRID

TPQDELIVERYQOS

TPQREPLYQOS

TPQREPLYQ

TPQFAILUREQ

[QMENOMSG]

[QMEINUSE]

TPQWAITの使用

TMQFORWARDサービス使用時のエラー処理

TMQFORWARDを通して呼び出されたサービスからの応答をキューから取り出す手順

メッセージの順次処理

ピア・ツー・ピア通信でのキューの使用

サンプル・アプリケーション

概要

前提条件

qsampleとは

qsampleのビルド

README

setenv

crlog

crque

makefile

client.c

server.c

ubb.sample

runsample

rmipc

理解を深めるために

setenv:環境の設定

makefile:アプリケーションの作成

ubb.sample: ASCII構成ファイル

crlog:トランザクション・ログの作成

crque:キュー・スペースとキューの作成

アプリケーションの起動、実行、および停止

終了処理