(57)【要約】【課題】複数の情報処理装置間のトランザクション処理で発生した障害の調査を行う際に障害調査の時間を短くすることが可能な技術を提供する。【解決手段】第１の情報処理装置のトランザクション処理を識別する為の第１のローカルＩＤと、第１及び第２の情報処理装置のトランザクション処理を対応付ける為の標準ＩＤとを対応付けて第１のマッピングテーブル内に格納するステップと、前記標準ＩＤ及びトランザクション処理要求を第２の情報処理装置へ送信して第２の情報処理装置でのトランザクション処理の実行を要求するステップと、前記実行を要求したトランザクション処理で障害が発生した場合に、当該トランザクション処理の標準ＩＤを指定してそのトランザクション処理を識別する為の第２のローカルＩＤの問い合わせを行うステップと、前記指定した標準ＩＤに対応する第１のローカルＩＤと前記送信された第２のローカルＩＤとを対応付けたマッピング情報を生成するステップとを有するものである。【選択図】        図１
2004302635.tif 000002
【特許請求の範囲】
【請求項１】
第１の情報処理手段のトランザクション処理を識別する為の第１のＩＤと、第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤとを対応付けて第１のマッピングテーブル内に格納するステップと、
前記第２のＩＤ及びトランザクション処理要求を第２の情報処理手段へ送信して第２の情報処理手段でのトランザクション処理の実行を要求し、前記実行を要求したトランザクション処理で障害が発生した場合に、当該トランザクション処理の第２のＩＤを指定してそのトランザクション処理を識別する為の第３のＩＤの問い合わせを行い、前記指定した第２のＩＤに対応する第１のＩＤと前記送信された第３のＩＤとを対応付けたマッピング情報を生成するステップとを有することを特徴とするトランザクション処理方法。
【請求項２】
第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤ及びトランザクション処理要求を第１の情報処理手段から受信し、前記第２のＩＤと、第２の情報処理手段のトランザクション処理を識別する為の第３のＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行するステップと、
前記実行したトランザクション処理で障害が発生した場合に、そのトランザクション処理の第２のＩＤと第３のＩＤとを対応付けた第２のマッピングテーブル中のレコードを所定時間保持するステップと、
前記第２のＩＤを指定した問い合わせが行われた場合に、その指定された第２のＩＤに対応する第３のＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理手段へ送信するステップとを有することを特徴とするトランザクション処理方法。
【請求項３】
第１の情報処理手段のトランザクション処理を識別する為の第１のＩＤと、第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤとを対応付けて第１のマッピングテーブル内に格納するステップと、
前記第２のＩＤ及びトランザクション処理要求を第２の情報処理手段へ送信して第２の情報処理手段でのトランザクション処理の実行を要求し、前記第２のＩＤ及びトランザクション処理要求を第１の情報処理手段から受信し、前記第２のＩＤと、第２の情報処理手段のトランザクション処理を識別する為の第３のＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行するステップと、
前記実行したトランザクション処理で障害が発生した場合に、そのトランザクション処理の第２のＩＤと第３のＩＤとを対応付けた第２のマッピングテーブル中のレコードを所定時間保持するステップと、
前記実行したトランザクション処理で障害が発生した場合に、当該トランザクション処理の第２のＩＤを指定してそのトランザクション処理を識別する為の第３のＩＤの問い合わせを行い、前記第２のＩＤを指定した問い合わせが行われた場合に、その指定された第２のＩＤに対応する第３のＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理手段へ送信するステップと、
前記指定した第２のＩＤに対応する第１のＩＤと前記送信された第３のＩＤとを対応付けたマッピング情報を生成するステップとを有することを特徴とするトランザクション処理方法。
【請求項４】
前記第１の情報処理手段が前記問い合わせを行う情報処理手段であるかどうかに応じて前記レコードを保持する為の所定時間の値を変更することを特徴とする請求項２または請求項３のいずれかに記載されたトランザクション処理方法。
【請求項５】
第１の情報処理手段のトランザクション処理を識別する為の第１のＩＤと、第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤとを対応付けて第１のマッピングテーブル内に格納し、前記第２のＩＤ及びトランザクション処理要求を第２の情報処理手段へ送信して第２の情報処理手段でのトランザクション処理の実行を要求するトランザクション実行要求処理部と、
前記実行を要求したトランザクション処理で障害が発生した場合に、当該トランザクション処理の第２のＩＤを指定してそのトランザクション処理を識別する為の第３のＩＤの問い合わせを行うＩＤ問い合わせ処理部と、
前記指定した第２のＩＤに対応する第１のＩＤと前記送信された第３のＩＤとを対応付けたマッピング情報を生成するマッピング情報生成処理部とを備えることを特徴とするトランザクション処理装置。
【請求項６】
第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤ及びトランザクション処理要求を第１の情報処理手段から受信し、前記第２のＩＤと、第２の情報処理手段のトランザクション処理を識別する為の第３のＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行するトランザクション実行処理部と、
前記実行したトランザクション処理で障害が発生した場合に、そのトランザクション処理の第２のＩＤと第３のＩＤとを対応付けた第２のマッピングテーブル中のレコードを所定時間保持するレコード保持処理部と、
前記第２のＩＤを指定した問い合わせが行われた場合に、その指定された第２のＩＤに対応する第３のＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理手段へ送信するＩＤ応答処理部とを備えることを特徴とするトランザクション処理装置。
【請求項７】
第１の情報処理手段のトランザクション処理を識別する為の第１のＩＤと、第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤとを対応付けて第１のマッピングテーブル内に格納し、前記第２のＩＤ及びトランザクション処理要求を第２の情報処理手段へ送信して第２の情報処理手段でのトランザクション処理の実行を要求するトランザクション実行要求処理部と、
前記第２のＩＤ及びトランザクション処理要求を第１の情報処理手段から受信し、前記第２のＩＤと、第２の情報処理手段のトランザクション処理を識別する為の第３のＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行するトランザクション実行処理部と、
前記実行したトランザクション処理で障害が発生した場合に、そのトランザクション処理の第２のＩＤと第３のＩＤとを対応付けた第２のマッピングテーブル中のレコードを所定時間保持するレコード保持処理部と、
前記実行したトランザクション処理で障害が発生した場合に、当該トランザクション処理の第２のＩＤを指定してそのトランザクション処理を識別する為の第３のＩＤの問い合わせを行うＩＤ問い合わせ処理部と、
前記第２のＩＤを指定した問い合わせが行われた場合に、その指定された第２のＩＤに対応する第３のＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理手段へ送信するＩＤ応答処理部と、
前記指定した第２のＩＤに対応する第１のＩＤと前記送信された第３のＩＤとを対応付けたマッピング情報を生成するマッピング情報生成処理部とを備えることを特徴とするトランザクション処理システム。
【請求項８】
第１の情報処理手段のトランザクション処理を識別する為の第１のＩＤと、第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤとを対応付けて第１のマッピングテーブル内に格納し、前記第２のＩＤ及びトランザクション処理要求を第２の情報処理手段へ送信して第２の情報処理手段でのトランザクション処理の実行を要求するトランザクション実行要求処理部と、
前記実行を要求したトランザクション処理で障害が発生した場合に、当該トランザクション処理の第２のＩＤを指定してそのトランザクション処理を識別する為の第３のＩＤの問い合わせを行うＩＤ問い合わせ処理部と、
前記指定した第２のＩＤに対応する第１のＩＤと前記送信された第３のＩＤとを対応付けたマッピング情報を生成するマッピング情報生成処理部としてコンピュータを機能させることを特徴とするプログラム。
【請求項９】
第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤ及びトランザクション処理要求を第１の情報処理手段から受信し、前記第２のＩＤと、第２の情報処理手段のトランザクション処理を識別する為の第３のＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行するトランザクション実行処理部と、
前記実行したトランザクション処理で障害が発生した場合に、そのトランザクション処理の第２のＩＤと第３のＩＤとを対応付けた第２のマッピングテーブル中のレコードを所定時間保持するレコード保持処理部と、
前記第２のＩＤを指定した問い合わせが行われた場合に、その指定された第２のＩＤに対応する第３のＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理手段へ送信するＩＤ応答処理部としてコンピュータを機能させることを特徴とするプログラム。
【請求項１０】
第１の情報処理手段のトランザクション処理を識別する為の第１のＩＤと、第１及び第２の情報処理手段のトランザクション処理を対応付ける為の第２のＩＤとを対応付けて第１のマッピングテーブル内に格納し、前記第２のＩＤ及びトランザクション処理要求を第２の情報処理手段へ送信して第２の情報処理手段でのトランザクション処理の実行を要求するトランザクション実行要求処理部と、
前記第２のＩＤ及びトランザクション処理要求を第１の情報処理手段から受信し、前記第２のＩＤと、第２の情報処理手段のトランザクション処理を識別する為の第３のＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行するトランザクション実行処理部と、
前記実行したトランザクション処理で障害が発生した場合に、そのトランザクション処理の第２のＩＤと第３のＩＤとを対応付けた第２のマッピングテーブル中のレコードを所定時間保持するレコード保持処理部と、
前記実行したトランザクション処理で障害が発生した場合に、当該トランザクション処理の第２のＩＤを指定してそのトランザクション処理を識別する為の第３のＩＤの問い合わせを行うＩＤ問い合わせ処理部と、
前記第２のＩＤを指定した問い合わせが行われた場合に、その指定された第２のＩＤに対応する第３のＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理手段へ送信するＩＤ応答処理部と、
前記指定した第２のＩＤに対応する第１のＩＤと前記送信された第３のＩＤとを対応付けたマッピング情報を生成するマッピング情報生成処理部としてコンピュータを機能させることを特徴とするプログラム。
【発明の詳細な説明】
【０００１】
【発明の属する技術分野】
本発明は複数の情報処理装置間でトランザクション処理を連携させるトランザクション処理システムに適用して有効な技術に関するものである。
【０００２】
【従来の技術】
現在、多くの業務システムとしてトランザクション処理システムが用いられており、銀行業務や旅行代理店の予約業務等の多くの業務処理でトランザクション処理システムが活用されている。また、それらのトランザクション処理システムは、他のトランザクション処理システムと連携する処理も行われており、例えばＡ銀行の預金を引き出してＢ銀行へ振り込む場合、Ａ銀行の口座ＤＢの更新を行うトランザクション処理とＢ銀行の口座ＤＢの更新を行うトランザクションが連携して動作している。
【０００３】
前記の様にシステム間でトランザクション処理を連携させた場合、各システムの内部で管理されているトランザクションのＩＤ（ローカルＩＤ）は、当然ながら各システム毎に異なっている場合が多いので、システム間でトランザクション処理を結び付ける為には、お互いに認識することのできるＩＤ（所定仕様に基づいて生成されたＩＤをここでは標準ＩＤと呼ぶ）を使用する必要がある。この標準ＩＤは、システム間で共通の標準フォーマットとなっており、標準化団体等で規定されている。
【０００４】
前記標準ＩＤを用い、システム間で複数のトランザクションを連携させた場合に、どちらかのトランザクション処理で障害が発生すると、そのシステムではこれを検知して障害情報を記録する。この障害情報の中にはそのシステムのローカルＩＤは必ず含まれているが、連携時に用いられた標準ＩＤが障害情報に含まれていない場合があり、障害が発生すると標準ＩＤとローカルＩＤを対応付けている対応テーブル上のエントリが削除されてしまうので、障害調査に時間がかかってしまうことが多かった。
【０００５】
なお複数の情報処理システムを連携させて情報処理を行う場合において各情報処理が正確に行われたか否かを確認できるように各情報処理の追跡性を確保し得る情報処理追跡性確保方法が提案されている（例えば特許文献１参照）。
【０００６】
【特許文献１】
特開２００２−３２４００１号公報
【０００７】
【発明が解決しようとする課題】
前記の様に従来のトランザクション処理システムでは、システム間で連携させているトランザクション処理で障害が発生した場合、標準ＩＤとローカルＩＤを対応付けている情報が削除されてしまうので、障害調査に時間がかかるという問題がある。
本発明の目的は上記問題を解決し、複数の情報処理装置間のトランザクション処理で発生した障害の調査を行う際に障害調査の時間を短くすることが可能な技術を提供することにある。
【０００８】
【課題を解決するための手段】
本発明は、複数の情報処理装置間でトランザクション処理を連携させるトランザクション処理システムにおいて、トランザクション処理の連携中に障害が発生した場合に、その標準ＩＤ及びローカルＩＤを所定時間保持し、各情報処理装置でのローカルＩＤを対応付けたマッピング情報を生成するものである。
【０００９】
本発明のトランザクション処理システムでは、第１の情報処理装置で開始したトランザクション処理で第２の情報処理装置でのトランザクション処理を行う必要が生じた場合に、まず第１及び第２の情報処理装置のトランザクション処理を対応付ける為の標準ＩＤを生成した後、第１の情報処理装置のトランザクション処理を識別する為の第１のローカルＩＤと前記生成した標準ＩＤとを対応付けて第１のマッピングテーブル内に格納する。
【００１０】
次に、前記標準ＩＤ及びトランザクション処理要求を第２の情報処理装置へ送信して第２の情報処理装置でのトランザクション処理の実行を要求する。
第２の情報処理装置では、前記標準ＩＤ及びトランザクション処理要求を第１の情報処理装置から受信すると、第２の情報処理装置のトランザクション処理を識別する為の第２のローカルＩＤを生成した後、前記受信した標準ＩＤと前記生成した第２のローカルＩＤとを対応付けて第２のマッピングテーブル内に格納し、要求されたトランザクション処理を実行する。
【００１１】
第２の情報処理装置で実行中の前記トランザクション処理で障害が発生した場合には、そのトランザクション処理の標準ＩＤと第２のローカルＩＤとを対応付けた第２のマッピングテーブル中のレコードに、その障害が発生した時刻を示す情報を格納して当該レコードを所定時間保持し、実行要求元の第１の情報処理装置へ障害発生を通知する。
【００１２】
第１の情報処理装置では、障害発生の通知を前記標準ＩＤと共に第２の情報処理装置から受信すると、前記標準ＩＤを指定してそのトランザクション処理の第２のローカルＩＤの問い合わせを行う。
【００１３】
第２の情報処理装置では、前記標準ＩＤを指定した問い合わせを第１の情報処理装置から受信すると、その指定された標準ＩＤに対応する第２のローカルＩＤを前記第２のマッピングテーブルから読み出して第１の情報処理装置へ送信する。
【００１４】
第１の情報処理装置では、第２の情報処理装置から送信された第２のローカルＩＤを受信した後、前記指定した標準ＩＤに対応する第１のローカルＩＤを前記第１のマッピングテーブルから読み出して、その第１のローカルＩＤと前記送信された第２のローカルＩＤとを対応付けたマッピング情報を生成する。
【００１５】
そして前記発生した障害の調査を行う場合には、第１のローカルＩＤを用いて第１の情報処理装置の障害情報を収集した後、前記マッピング情報中でその第１のローカルＩＤに対応付けられた第２のローカルＩＤを用いて第２の情報処理装置の障害情報を収集することにより、標準ＩＤの調査を無くして障害調査の時間を短くすることができる。また前記マッピング情報により第１のローカルＩＤと第２のローカルＩＤとが対応付けられているので、多大な労力を必要とするローカルＩＤ同士の突き合わせ作業を削減することができる。
【００１６】
以上の様に本発明のトランザクション処理システムによれば、トランザクション処理の連携中に障害が発生した場合に、その標準ＩＤ及びローカルＩＤを所定時間保持し、各情報処理装置でのローカルＩＤを対応付けたマッピング情報を生成するので、複数の情報処理装置間のトランザクション処理で発生した障害の調査を行う際に障害調査の時間を短くすることが可能である。
【００１７】
【発明の実施の形態】
以下に複数の情報処理装置間でトランザクション処理を連携させる一実施形態のトランザクション処理システムについて説明する。
【００１８】
図１は本実施形態のトランザクション処理システムの概略構成を示す図である。トランザクション処理装置１０１及び１０２は、トランザクション管理プログラムが実行されている計算機または情報処理装置である。図１のトランザクション１１、トランザクション２１とは、トランザクション処理装置上で動作する業務アプリケーションプログラムのことである。
【００１９】
図１に示す様に本実施形態のトランザクション処理システムでは、複数のトランザクション処理装置１０１及び１０２でトランザクション１１及び２１を連携中に、トランザクション２１で障害が発生した場合、その標準ＩＤ「Ａ」及びローカルＩＤ「２１」（ローカルＩＤがトランザクションＩＤの２１であることを示す）を所定時間が経過するまでマッピングテーブル２中に保持し、トランザクション処理装置１０１からの問い合わせによりローカルＩＤ「２１」をトランザクション処理装置１０１へ送信し、ローカルＩＤ「１１」とローカルＩＤ「２１」とを対応付けたマッピング情報１を生成する。
【００２０】
そして、前記トランザクションの連携中に発生した障害の調査を行う場合には、ローカルＩＤ「１１」を用いてトランザクション処理装置１０１の障害情報１を収集した後、マッピング情報１中のローカルＩＤ「２１」を用いてトランザクション処理装置１０２の障害情報２を収集することにより、標準ＩＤ「Ａ」に関する調査を無くして障害調査の時間を短くすることができる。
【００２１】
図２は本実施形態のトランザクション処理装置１０１の概略構成を示す図である。図２に示す様に本実施形態のトランザクション処理装置１０１は、ＣＰＵ２０１と、メモリ２０２と、磁気ディスク装置２０３と、入力装置２０４と、出力装置２０５と、ＣＤ−ＲＯＭ装置２０６と、通信装置２０７と、マッピングテーブル２０８とを有している。
【００２２】
ＣＰＵ２０１は、トランザクション処理装置１０１全体の動作を制御する装置である。メモリ２０２は、トランザクション処理装置１０１全体の動作を制御する際にその為の各種処理プログラムやデータをロードする記憶装置である。
【００２３】
磁気ディスク装置２０３は、前記各種処理プログラムやデータを格納しておく記憶装置である。入力装置２０４は、障害発生時に自装置及び連携先装置のローカルＩＤを対応付けたマッピング情報を生成する為の各種入力を行う装置である。
【００２４】
出力装置２０５は、前記マッピング情報の生成に伴う各種出力を行う装置である。ＣＤ−ＲＯＭ装置２０６は、前記各種処理プログラムを記録したＣＤ−ＲＯＭの内容を読み出す装置である。通信装置２０７は、インターネットやイントラネット等のネットワークを介して他の処理装置との通信を行う装置である。マッピングテーブル２０８は、自装置のローカルＩＤと標準ＩＤとを対応付けて格納するテーブルである。
【００２５】
またトランザクション処理装置１０１は、トランザクション実行要求処理部２１１と、ローカルＩＤ問い合わせ処理部２１２と、マッピング情報生成処理部２１３とを有している。
【００２６】
トランザクション実行要求処理部２１１は、トランザクション処理装置１０１のトランザクション１１を識別する為のローカルＩＤ「１１」と、トランザクション処理装置１０１及び１０２のトランザクション処理を対応付ける為の標準ＩＤとを対応付けてマッピングテーブル２０８内に格納し、前記標準ＩＤ及びトランザクション処理要求をトランザクション処理装置１０２へ送信してトランザクション処理装置１０２でのトランザクション２１の実行を要求する処理部である。
【００２７】
ローカルＩＤ問い合わせ処理部２１２は、前記実行を要求したトランザクション２１で障害が発生した場合に、トランザクション２１の標準ＩＤを指定してそのトランザクション２１を識別する為のローカルＩＤ「２１」の問い合わせを行う処理部である。マッピング情報生成処理部２１３は、前記指定した標準ＩＤに対応するローカルＩＤ「１１」と前記送信されたローカルＩＤ「２１」とを対応付けたマッピング情報を生成する処理部である。
【００２８】
トランザクション処理装置１０１をトランザクション実行要求処理部２１１、ローカルＩＤ問い合わせ処理部２１２及びマッピング情報生成処理部２１３として機能させる為のプログラムは、ＣＤ−ＲＯＭ等の記録媒体に記録され磁気ディスク等に格納された後、メモリにロードされて実行されるものとする。なお前記プログラムを記録する記録媒体はＣＤ−ＲＯＭ以外の他の記録媒体でも良い。また前記プログラムを当該記録媒体から情報処理装置にインストールして使用しても良いし、ネットワークを通じて当該記録媒体にアクセスして前記プログラムを使用するものとしても良い。
【００２９】
図３は本実施形態のトランザクション処理装置１０２の概略構成を示す図である。図３に示す様に本実施形態のトランザクション処理装置１０２は、ＣＰＵ３０１と、メモリ３０２と、磁気ディスク装置３０３と、入力装置３０４と、出力装置３０５と、ＣＤ−ＲＯＭ装置３０６と、通信装置３０７と、マッピングテーブル３０８と、要求元毎監視時間管理テーブル３０９とを有している。
【００３０】
ＣＰＵ３０１は、トランザクション処理装置１０２全体の動作を制御する装置である。メモリ３０２は、トランザクション処理装置１０２全体の動作を制御する際にその為の各種処理プログラムやデータをロードする記憶装置である。
【００３１】
磁気ディスク装置３０３は、前記各種処理プログラムやデータを格納しておく記憶装置である。入力装置３０４は、標準ＩＤ及び自装置のローカルＩＤを障害発生後の所定時間保持する為の各種入力を行う装置である。
【００３２】
出力装置３０５は、標準ＩＤ及びローカルＩＤの保持に伴う各種出力を行う装置である。ＣＤ−ＲＯＭ装置３０６は、前記各種処理プログラムを記録したＣＤ−ＲＯＭの内容を読み出す装置である。通信装置３０７は、インターネットやイントラネット等のネットワークを介して他の処理装置との通信を行う装置である。
【００３３】
マッピングテーブル３０８は、自装置のローカルＩＤと標準ＩＤとを対応付けて格納するテーブルである。要求元毎監視時間管理テーブル３０９は、障害の発生したトランザクションのレコードをマッピングテーブル３０８から削除する為の時間情報を格納するテーブルである。
【００３４】
またトランザクション処理装置１０２は、トランザクション実行処理部３１１と、レコード保持処理部３１２と、ローカルＩＤ応答処理部３１３とを有している。
【００３５】
トランザクション実行処理部３１１は、トランザクション処理装置１０１及び１０２のトランザクション処理を対応付ける為の標準ＩＤ及びトランザクション処理要求をトランザクション処理装置１０１から受信し、前記標準ＩＤと、トランザクション処理装置１０２のトランザクション２１を識別する為のローカルＩＤ「２１」とを対応付けてマッピングテーブル３０８内に格納し、要求されたトランザクション２１を実行する処理部である。
【００３６】
レコード保持処理部３１２は、前記実行したトランザクション２１で障害が発生した場合に、そのトランザクション２１の標準ＩＤとローカルＩＤ「２１」とを対応付けたマッピングテーブル３０８中のレコードを所定時間保持する処理部である。
【００３７】
ローカルＩＤ応答処理部３１３は、前記標準ＩＤを指定した問い合わせが行われた場合に、その指定された標準ＩＤに対応するローカルＩＤ「２１」をマッピングテーブル３０８から読み出してトランザクション処理装置１０１へ送信する処理部である。
【００３８】
トランザクション処理装置１０２をトランザクション実行処理部３１１、レコード保持処理部３１２及びローカルＩＤ応答処理部３１３として機能させる為のプログラムは、ＣＤ−ＲＯＭ等の記録媒体に記録され磁気ディスク等に格納された後、メモリにロードされて実行されるものとする。なお前記プログラムを記録する記録媒体はＣＤ−ＲＯＭ以外の他の記録媒体でも良い。また前記プログラムを当該記録媒体から情報処理装置にインストールして使用しても良いし、ネットワークを通じて当該記録媒体にアクセスして前記プログラムを使用するものとしても良い。
【００３９】
図２及び図３に示す様に本実施形態では、トランザクション実行要求側とトランザクション実行側とを、それぞれ異なる構成の情報処理装置として説明しているが、図２及び図３の両方の構成を備え、他の装置へのトランザクション実行要求と他の装置から要求されたトランザクションの実行の両方を実行可能な情報処理装置を用いるものとしても良い。
【００４０】
図４は本実施形態のトランザクション実行要求側の処理の処理手順を示すフローチャートである。図４に示す様にステップ４０１でトランザクション処理装置１０１のトランザクション実行要求処理部２１１は、トランザクション処理装置１０１で開始したトランザクション１１の処理中に、トランザクション処理装置１０２でのトランザクション処理を行う必要が生じると、まずトランザクション処理装置１０１及び１０２の各トランザクション処理を対応付ける為の標準ＩＤ「Ａ」を生成した後、トランザクション処理装置１０１のトランザクション１１を識別する為のローカルＩＤ「１１」と前記生成した標準ＩＤとを対応付けてマッピングテーブル２０８内に格納する処理を行う。
【００４１】
この様に、あるトランザクション処理装置で開始したトランザクションの処理中に、他のトランザクション処理装置でのトランザクション処理を行う必要が生じる処理としては、銀行のオンライン処理システムや旅行代理店のオンライン処理システムがある。
【００４２】
図５は本実施形態の銀行オンライン処理システムの処理例を示す図である。図５に示す通り、Ａ銀行システム５０１は業務アプリケーション５０２が稼働しており、ＴＰモニタ５０３、及びＤＢＭＳ５０４が使われている。また銀行システム５０６では業務アプリケーション５０７が稼働しており、ＴＰモニタ５０８、及びＤＢＭＳ５０９が使われている。業務アプリケーション５０２は、振り込み要求を行った後に口座ＤＢから指定の金額だけを減らすアプリケーションプログラムであり、業務アプリケーション５０７は振り込み要求を受けて口座ＤＢに指定の金額分増やすアプリケーションプログラムである。
【００４３】
これらの振り込み要求は、ＴＰモニタ５０３、ＴＰモニタ５０８を介して行われるが、これらのＴＰモニタは異なるベンダのものである可能性が高い。この為、トランザクション開始要求のトランザクション指示５１１やトランザクション決着要求であるトランザクション指示５１２は、ＴＰモニタ内で使用しているローカルなＩＤではなく、お互いに認識することのできる標準ＩＤが使用される。この標準ＩＤを使用することにより、異なるＴＰモニタ間で連携してトランザクションの同期をとることが可能になり、異なる銀行間での振り込み処理ができる様になる。
【００４４】
同様に本実施形態として、旅行オンライン処理システムの処理を図６に示す。標準プロトコルで規定された標準ＩＤは、図５の様なＴＰモニタ間だけの処理に限った話ではない。図６に示す様にＴＰモニタとＤＢＭＳ間でも成立する。
【００４５】
Ａ旅行代理店システム６０１上では業務アプリケーション６０２とＴＰモニタ６０３が動作しており、トランザクションの管理を行っている。Ｃ航空会社搭乗予約システムでは、ＤＢＭＳ６０５が動作しており、搭乗予約ＤＢの管理を行っている。またＤホテル宿泊予約システムでは、ＤＢＭＳ６０８が動作しており、宿泊予約ＤＢ６０９の管理を行っている。
【００４６】
業務アプリケーション６０２では、ＴＰモニタ６０３を介してＤＢＭＳ６０５とＤＢＭＳ６０８の２つに対してトランザクションの開始を指示する。次に、それぞれ搭乗予約処理と宿泊予約処理を実行する。最後にＴＰモニタ６０３を介してＤＢＭＳ６０５とＤＢＭＳ６０８の２つに対してトランザクションの決着を指示する。
【００４７】
業務アプリケーション６０２は、それぞれのＤＢＭＳに対する処理を１つのトランザクションとして扱っている為、搭乗予約及び宿泊予約の両方が成功した場合のみ、コミット決着が指示される。どちらか、若しくは両方が失敗した場合にはロールバック決着となる為、片方だけが予約されてしまうことにはならない。
【００４８】
この場合も、ＴＰモニタからＤＢＭＳへトランザクション指示では、標準ＩＤが使用される。ＴＰモニタ６０３やＤＢＭＳ６０５、ＤＢＭＳ６０８が標準ＩＤを扱うことのできるものであれば、これらのベンダが異なっていても構わない。Ｂ旅行代理店システムで標準ＩＤを採用しているＴＰモニタ６１２を使用しているのであれば、業務アプリケーション６１１からもこのシステムに参加することが可能になる。
【００４９】
この様に異なる銀行や、旅行代理店、航空会社、ホテル等の間でトランザクション処理を連携させる場合、それぞれ採用されているシステムが異なり、用いられるローカルＩＤも異なるのが通常であるので、この様な場合には、それぞれのシステムで連携されるトランザクション同士を対応付ける為の標準ＩＤが使用されている。
【００５０】
図７は本実施形態の標準ＩＤの概要を示す図である。標準ＩＤのフォーマットは図７に示す様に規定されており、そのフォーマットを識別する為のフォーマットＩＤ７０１と、グローバルトランザクション識別子のサイズを示すグローバルトランザクション識別子サイズ７０２と、ブランチ修飾子のサイズを示すブランチ修飾子サイズ７０３と、グローバルトランザクション識別子及びブランチ修飾子を格納したデータ部７０４で構成されている。
【００５１】
この標準ＩＤ中のグローバルトランザクション識別子は、トランザクションの実行要求を行ったトランザクション処理装置を識別する為の情報が含まれており、この内容を参照することにより、どのトランザクション処理装置から実行要求が行われたかを識別することができるものとする。
【００５２】
次にステップ４０２でトランザクション実行要求処理部２１１は、前記生成した標準ＩＤ及びトランザクション処理要求をトランザクション処理装置１０２へ送信してトランザクション処理装置１０２でのトランザクション２１の実行を要求する。
【００５３】
図８は本実施形態のトランザクション実行側の処理の処理手順を示すフローチャートである。図８に示す様にステップ８０１でトランザクション処理装置１０２のトランザクション実行処理部３１１は、前記標準ＩＤ及びトランザクション処理要求をトランザクション処理装置１０１から受信するとステップ８０２の処理へ進む。
【００５４】
ステップ８０２では、トランザクション処理装置１０２で開始するトランザクション２１を識別する為のローカルＩＤ「２１」を生成した後、前記受信した標準ＩＤ「Ａ」と前記生成したローカルＩＤ「２１」とを対応付けてマッピングテーブル３０８内に格納する。また前記受信した標準ＩＤのデータ部７０４からグローバルトランザクション識別子を読み出して、そのトランザクション処理要求を送信した要求元のトランザクション処理装置を識別する情報を読み出し、マッピングテーブル３０８の要求元の欄に格納する。
【００５５】
そしてステップ８０３では、前記要求されたトランザクション２１の実行を開始し、その実行状態を監視する。前記実行を開始したトランザクション２１の終了が検知されるとステップ８０４の処理へ進む。
【００５６】
ステップ８０４では、終了したトランザクション２１の終了状態を示す情報を参照してトランザクション２１が異常終了していないかどうかを調べることにより、そのトランザクション２１で障害が発生したかどうかを判定し、障害発生が検知された場合にはステップ８０５へ進み、そうでない場合にはステップ８０６へ進む。
【００５７】
ステップ８０５でトランザクション処理装置１０２のレコード保持処理部３１２は、マッピングテーブル３０８を参照し、前記実行したトランザクション２１のローカルＩＤ「２１」に一致するレコードをマッピングテーブル３０８から検索して対応する標準ＩＤ「Ａ」を読み出した後、その標準ＩＤ「Ａ」とローカルＩＤ「２１」とを対応付けたレコード中に、前記障害の発生時刻を示す情報を格納し、そのレコードを削除せずに保持する処理を行う。
【００５８】
一方、ステップ８０６では、前記実行したトランザクション２１のローカルＩＤ「２１」に一致するレコードをマッピングテーブル３０８から検索して対応する標準ＩＤ「Ａ」を読み出した後、その標準ＩＤ「Ａ」とローカルＩＤ「２１」とを対応付けたレコードを削除する。
【００５９】
ステップ８０７では、前記実行したトランザクション２１の処理結果を示す情報を生成し、前記ステップ８０５またはステップ８０６で読み出した標準ＩＤ「Ａ」と共に実行要求元のトランザクション処理装置１０１へ通知する。
【００６０】
トランザクション処理装置１０２からトランザクション２１の処理結果が通知されると、図４のステップ４０３でトランザクション処理装置１０１のトランザクション実行要求処理部２１１は、その通知された処理結果を参照して、ステップ４０２で実行要求を行ったトランザクション２１で障害が発生したかどうかを調べ、障害が発生している場合にはステップ４０４へ進む。
【００６１】
ステップ４０４でローカルＩＤ問い合わせ処理部２１２は、前記処理結果と共に受信している標準ＩＤ「Ａ」を指定し、その障害の発生したトランザクション２１を識別する為のローカルＩＤ「２１」をトランザクション処理装置１０２へ問い合わせる。
【００６２】
トランザクション処理装置１０２のローカルＩＤ応答処理部３１３は、前記標準ＩＤ「Ａ」を指定した問い合わせをトランザクション処理装置１０１から受信すると、その指定された標準ＩＤ「Ａ」に対応するローカルＩＤ「２１」をマッピングテーブル３０８から読み出してトランザクション処理装置１０１へ送信する。
【００６３】
トランザクション処理装置１０２からトランザクション２１のローカルＩＤ「２１」が送信されると、図４のステップ４０５でトランザクション処理装置１０１のマッピング情報生成処理部２１３は、前記指定した標準ＩＤ「Ａ」に一致するレコードをマッピングテーブル２０８から検索して対応するローカルＩＤ「１１」を読み出した後、そのローカルＩＤ「１１」と前記送信されたローカルＩＤ「２１」とを対応付けたマッピング情報を生成する。
【００６４】
一方、ステップ４０３で調べた結果、トランザクション２１で障害が発生していない場合にはステップ４０６へ進み、その処理結果と共に通知された標準ＩＤ「Ａ」に一致するレコードをマッピングテーブル２０８から検索して削除する。
【００６５】
図９は本実施形態のトランザクション２１で障害が発生した場合の処理例を示す図である。図９に示す様にトランザクション処理装置１０２で実行中のトランザクション２１で障害が発生すると、トランザクション処理装置１０２のレコード保持処理部３１２は、マッピングテーブル３０８を検索し、その障害の発生したトランザクション２１のローカルＩＤ「２１」に一致するレコード中の時刻の欄に障害の発生時刻を示す情報を格納した後、要求元毎監視時間管理テーブル３０９に示された所定の削除経過時間が経過するまで当該レコードを削除せずに保持する処理を行う。
【００６６】
この要求元毎監視時間管理テーブル３０９には、テーブルの監視を行う時間間隔を示すテーブル監視間隔と、障害が発生してからマッピングテーブル３０８中の該当レコードを削除するまでの時間を示す削除経過時間とが格納されており、障害発生時にローカルＩＤの問い合わせを行うローカルＩＤ問い合わせ処理部２１２の機能を備えるシステム１（トランザクション処理装置１０１）の削除経過時間を短く設定し、そうでないシステムＸの削除経過時間を長く設定することにより、多くのレコードが長時間削除されずに残るのを防ぐ。また、ローカルＩＤ問い合わせ機能を持たないシステムＸ等の管理者が手動で問い合わせを行った場合でも、できるだけローカルＩＤの取得が可能となる。
【００６７】
図１０は本実施形態のテーブルエントリ削除チェックの処理手順を示すフローチャートである。図１０に示す様にトランザクション処理装置１０２のレコード保持処理部３１２は、要求元毎監視時間管理テーブル３０９の情報に従ってマッピングテーブル３０８中のレコードを監視し、障害が発生した時刻から削除経過時間で示される時間が経過したレコードを削除する処理を行う。
【００６８】
すなわち、ステップ１００１でレコード保持処理部３１２は、マッピングテーブル３０８中のレコードを参照して、その時刻の欄に値が格納されているかどうかを調べ、値が格納されている場合にはステップ１００２へ進み、そうでない場合にはステップ１００４へ進む。
【００６９】
ステップ１００２では、ステップ１００１で参照したレコード中の要求元を読み出して要求元毎監視時間管理テーブル３０９を参照し、前記読み出した要求元に対応するテーブル監視間隔と削除経過時間を読み出す。そして、その削除経過時間で示される時間が前記レコード中の時刻から経過しているかどうかを調べ、経過している場合にはステップ１００３へ進み、マッピングテーブル３０８からそのレコードを削除する。
【００７０】
その後、ステップ１００４でマッピングテーブル３０８の次のエントリのレコードを読み出して、最終エントリまでチェックが完了したかどうかをステップ１００５で判定し、チェックが完了した場合にはステップ１００６に進み、そうでない場合にはステップ１００１へ戻って次のエントリを処理する。
【００７１】
ステップ１００６では、ステップ１００２で読み出したテーブル監視間隔に指定された値だけスリープ処理を行った後、ステップ１００１へ戻り、先頭のエントリから再び処理を行う。
【００７２】
図１１は本実施形態のトランザクション処理装置１０１でのマッピングテーブル２０８の作成概要を示す図である。図１１に示す様にトランザクション処理装置１０１は、トランザクション１１等複数のトランザクションの処理中にトランザクション処理装置１０２でのトランザクション処理を行う必要が生じると、それらのトランザクションのローカルＩＤ「１１」〜ローカルＩＤ１３と標準ＩＤ「Ａ」〜標準ＩＤ「Ｂ」とを対応付けてマッピングテーブル２０８内に格納し、トランザクション開始要求等を送信してトランザクションの実行をトランザクション処理装置１０２に要求する。
【００７３】
図１２は本実施形態のローカルＩＤ「１１」とローカルＩＤ「２１」のマッピング情報の作成概要を示す図である。図１２に示す様にトランザクション２１の障害を検知すると、トランザクション処理装置１０１では、標準ＩＤ「Ａ」を指定してトランザクション２１のローカルＩＤの取得要求を行い、ローカルＩＤ「２１」を取得してマッピング情報１２０１を生成する。
【００７４】
その後、前記トランザクションの連携中に発生した障害の調査を行う場合には、ローカルＩＤ「１１」を用いてトランザクション処理装置１０１の障害情報を収集した後、マッピング情報１２０１中でそのローカルＩＤ「１１」に対応付けられたローカルＩＤ「２１」を用いてトランザクション処理装置１０２の障害情報を収集することにより、標準ＩＤに関する調査を無くして障害調査の時間を短くすることができる。またマッピング情報１２０１によりローカルＩＤ「１１」とローカルＩＤ「２１」とが対応付けられているので、多大な労力を必要とするローカルＩＤ同士の突き合わせ作業を無くすことができる。
【００７５】
またトランザクション処理装置１０１が、標準ＩＤ「Ａ」を指定してトランザクション２１のローカルＩＤの取得要求を行う際に、トランザクション処理装置１０２の障害情報の格納位置を示すポインタ等の情報も取得してマッピング情報１２０１中に格納しておき、ローカルＩＤ「１１」を用いてトランザクション処理装置１０１の障害情報を収集した後、ローカルＩＤ「２１」のポインタを用いてトランザクション処理装置１０２の障害情報をオンラインで収集し、各トランザクションが連携した時系列に従って各システムでの障害情報を表示して障害調査の実行を支援するものとしても良い。
【００７６】
以上説明した様に本実施形態のトランザクション処理システムによれば、トランザクション処理の連携中に障害が発生した場合に、その標準ＩＤ及びローカルＩＤを所定時間保持し、各情報処理装置でのローカルＩＤを対応付けたマッピング情報を生成するので、複数の情報処理装置間のトランザクション処理で発生した障害の調査を行う際に障害調査の時間を短くすることが可能である。
【００７７】
【発明の効果】
本発明によればトランザクション処理の連携中に障害が発生した場合に、複数の情報処理装置間のトランザクション処理で発生した障害の調査を行う際に障害調査の時間を短くすることが可能である。
【図面の簡単な説明】
【図１】本実施形態のトランザクション処理システムの概略構成を示す図である。
【図２】本実施形態のトランザクション処理装置１０１の概略構成を示す図である。
【図３】本実施形態のトランザクション処理装置１０２の概略構成を示す図である。
【図４】本実施形態のトランザクション実行要求側の処理の処理手順を示すフローチャートである。
【図５】本実施形態の銀行オンライン処理システムの処理例を示す図である。
【図６】本実施形態の旅行代理店オンライン処理システムの処理例を示す図である。
【図７】本実施形態の標準ＩＤの概要を示す図である。
【図８】本実施形態のトランザクション実行側の処理の処理手順を示すフローチャートである。
【図９】本実施形態のトランザクション２１で障害が発生した場合の処理例を示す図である。
【図１０】本実施形態のテーブルエントリ削除チェックの処理手順を示すフローチャートである。
【図１１】本実施形態のトランザクション処理装置１０１でのマッピングテーブル２０８の作成概要を示す図である。
【図１２】本実施形態のローカルＩＤ「１１」とローカルＩＤ「２１」のマッピング情報の作成概要を示す図である。
【符号の説明】
１０１及び１０２…トランザクション処理装置、２０１…ＣＰＵ、２０２…メモリ、２０３…磁気ディスク装置、２０４…入力装置、２０５…出力装置、２０６…ＣＤ−ＲＯＭ装置、２０７…通信装置、２０８…マッピングテーブル、２１１…トランザクション実行要求処理部、２１２…ローカルＩＤ問い合わせ処理部、２１３…マッピング情報生成処理部、３０１…ＣＰＵ、３０２…メモリ、３０３…磁気ディスク装置、３０４…入力装置、３０５…出力装置、３０６…ＣＤ−ＲＯＭ装置、３０７…通信装置、３０８…マッピングテーブル、３０９…要求元毎監視時間管理テーブル、３１１…トランザクション実行処理部、３１２…レコード保持処理部、３１３…ローカルＩＤ応答処理部、７０１…フォーマットＩＤ、７０２…グローバルトランザクション識別子サイズ、７０３…ブランチ修飾子サイズ、７０４…データ部、１２０１…マッピング情報。
【図１】
2004302635.tif 000003
【図２】
2004302635.tif 000004
【図３】
2004302635.tif 000005
【図４】
2004302635.tif 000006
【図５】
2004302635.tif 000007
【図６】
2004302635.tif 000008
【図７】
2004302635.tif 000009
【図８】
2004302635.tif 000010
【図９】
2004302635.tif 000011
【図１０】
2004302635.tif 000012
【図１１】
2004302635.tif 000013
【図１２】
2004302635.tif 000014