(57)【要約】【課題】障害時に切替え後に発生するデータの不整合を解消し、３つのシステム間で同期が取れた状態にデータを復旧する。【解決手段】接続システム２Ａ、２Ｂは、センタシステム３Ａ、３Ｂから取得したセンタシステムの第１のデータ処理状態と、当該接続システムの第２のデータ処理状態とを比較し、第１のデータ処理状態に合わせて第２のデータ処理状態を更新する更新ステップと、更新後の第２のデータ処理状態をユーザシステム１に送信する送信ステップと、を行い、ユーザシステム１は、接続システム２Ａ、２Ｂが送信した更新後の第２のデータ処理状態と当該ユーザシステム１の第３のデータ処理状態とを比較し、第３のデータ処理状態を更新後の第２のデータ処理状態に同期させる同期ステップを行う。【選択図】図１
2008242715.tif 000002
【特許請求の範囲】
【請求項１】
ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとが行う障害時のデータ復旧方法であって、
前記接続システムは、
前記センタシステムから取得したセンタシステムの第１のデータ処理状態と、当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第２のデータ処理状態を更新する更新ステップと、
更新後の第２のデータ処理状態を前記ユーザシステムに送信する送信ステップと、を行い、
前記ユーザシステムは、
前記接続システムが送信した更新後の第２のデータ処理状態と当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記更新後の第２のデータ処理状態に同期させる同期ステップを行うこと
を特徴とするデータ復旧方法。
【請求項２】
請求項１記載のデータ復旧方法であって、
前記更新ステップは、前記第１のデータ処理状態と前記第２のデータ処理状態とを比較して、第２のデータ処理状態が第１のデータ処理状態より遅れている場合、前記センタシステムから差分データを取得し、取得した差分データに基づいて第２のデータ処理状態を更新すること
を特徴とするデータ復旧方法。
【請求項３】
請求項１記載のデータ復旧方法であって、
前記更新ステップは、前記第１のデータ処理状態と前記第２のデータ処理状態とを比較して、第２のデータ処理状態が第１のデータ処理状態より進んでいる場合、差分データを第２のデータ処理状態から削除および／または差分データのステータスを更新すること
を特徴とするデータ復旧方法。
【請求項４】
請求項１記載のデータ復旧方法であって、
前記同期ステップは、前記第３のデータ処理状態と更新後の第２のデータ処理状態とを比較し、第３のデータ処理状態が更新後の第２のデータ処理状態より進んでいる場合、前記接続システムに差分データを送信すること
を特徴とするデータ復旧方法。
【請求項５】
ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとが行う障害時のデータ復旧方法であって、
前記接続システムは、
前記センタシステムの第１のデータ処理状態を取得し、前記ユーザシステムに送信する状態取得ステップと、
前記第１のデータ処理状態と当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第２のデータ処理状態を更新する更新ステップと、を行い、
前記ユーザシステムは、
前記接続システムから送信された第１のデータ処理状態と、当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記更新後の第２のデータ処理状態に同期させる同期ステップを行うこと
を特徴とするデータ復旧方法。
【請求項６】
請求項５記載のデータ復旧方法であって、
前記更新ステップは、前記第１のデータ処理状態と前記第２のデータ処理状態とを比較して、第２のデータ処理状態が第１のデータ処理状態より遅れている場合、前記センタシステムから差分データを取得し、取得した差分データに基づいて第２のデータ処理状態を更新すること
を特徴とするデータ復旧方法。
【請求項７】
請求項５記載のデータ復旧方法であって、
前記更新ステップは、前記第１のデータ処理状態と前記第２のデータ処理状態とを比較して、第２のデータ処理状態が第１のデータ処理状態より進んでいる場合、差分データを第２のデータ処理状態から削除および／または差分データのステータスを更新すること
を特徴とするデータ復旧方法。
【請求項８】
請求項５記載のデータ復旧方法であって、
前記同期ステップは、前記第３のデータ処理状態と前記第１のデータ処理状態とを比較し、第３のデータ処理状態が第１のデータ処理状態より進んでいる場合、当該ユーザシステムの差分データを削除すること
を特徴とするデータ復旧方法。
【請求項９】
ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとを有するデータ復旧システムであって、
前記接続システムは、
前記センタシステムの第１のデータ処理状態を取得する状態取得手段と、
前記第１のデータ処理状態と当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第２のデータ処理状態を更新し、更新後の第２のデータ処理状態をユーザシステムに送信する更新手段と、を有し、
前記ユーザシステムは、
前記接続システムから送信された更新後の第２のデータ処理状態と、当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記更新後の第２のデータ処理状態に同期させる同期手段を有すること
を特徴とするデータ復旧システム。
【請求項１０】
ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとを有するデータ復旧システムであって、
前記接続システムは、
前記センタシステムの第１のデータ処理状態を取得し、前記ユーザシステムに送信する状態取得手段と、
前記第１のデータ処理状態と当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第１のデータ処理状態を更新する更新手段と、を有し、
前記ユーザシステムは、
前記接続システムから送信された第１のデータ処理状態と、当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記第１のデータ処理状態に同期させる同期手段を有すること
を特徴とするデータ復旧システム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、障害発生時のデータ復旧技術に関し、特に、複数のシステム間でデータの送受信を行う場合のデータ復旧技術に関する。
【背景技術】
【０００２】
広域災害に備え、現用システムが稼動するメインサイトの他に、遠隔地にバックアップサイトを設け、メインサイトが被害を受けても、バックアップサイトで業務を再開できるディザスタリカバリが行われている。
【０００３】
例えば特許文献１には、現用系システムから予備系システムへの切替え時に、受信データの系列の不連続点を検出し不連続点以降のデータを復元するデータ復元方法が記載されている。
【特許文献１】特開２０００−３４１１７４
【発明の開示】
【発明が解決しようとする課題】
【０００４】
ところで、メインサイトでは、レプリケーション処理により更新データをバックアップサイトに反映させる。しかしながら、レプリケーション処理にはタイムラグが発生するため、メインサイトが被災した時点において、バックアップサイトではデータが反映されない場合があり、この場合、データの整合性を確保する必要がある。
【０００５】
例えば、３つのシステム間でデータを送受信する場合、いずれかのシステムがバックアップサイトに切り替わると、バックアップサイトのデータと他のシステムのデータとの同期をとる作業が必要となる。しかしながら、３つのシステム間でデータの同期を取る場合、その作業負荷が大きく、障害回復処理に時間を要する。また、一般的なデータの同期処理では、処理が遅れているシステムの状態に他のシステムを合わせるが、例えば複数のシステムが接続されたセンタシステムでは、処理が遅れているシステムの状態に合わせることが困難な場合がある。
【０００６】
本発明は上記事情に鑑みてなされたものであり、本発明の目的は、障害時に発生するデータの不整合を解消し、３つのシステム間で同期が取れた状態にデータを復旧することにある。
【課題を解決するための手段】
【０００７】
上記課題を解決するために、本発明は、ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとが行う障害時のデータ復旧方法であって、前記接続システムは、前記センタシステムから取得したセンタシステムの第１のデータ処理状態と、当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第２のデータ処理状態を更新する更新ステップと、更新後の第２のデータ処理状態を前記ユーザシステムに送信する送信ステップと、を行い、前記ユーザシステムは、前記接続システムが送信した更新後の第２のデータ処理状態と当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記更新後の第２のデータ処理状態に同期させる同期ステップを行う。
【０００８】
また、本発明は、ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとが行う障害時のデータ復旧方法であって、前記接続システムは、前記センタシステムの第１のデータ処理状態を取得し、前記ユーザシステムに送信する状態取得ステップと、前記第１のデータ処理状態と当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第２のデータ処理状態を更新する更新ステップと、を行い、前記ユーザシステムは、前記接続システムから送信された第１のデータ処理状態と、当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記更新後の第２のデータ処理状態に同期させる同期ステップを行う。
【０００９】
また、本発明は、ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとを有するデータ復旧システムであって、前記接続システムは、前記センタシステムの第１のデータ処理状態を取得する状態取得手段と、前記第１のデータ処理状態と当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第２のデータ処理状態を更新し、更新後の第２のデータ処理状態をユーザシステムに送信する更新手段と、を有し、前記ユーザシステムは、前記接続システムから送信された更新後の第２のデータ処理状態と、当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記更新後の第２のデータ処理状態に同期させる同期手段を有する。
【００１０】
また、本発明は、ユーザシステムと、当該ユーザシステムをセンタシステムに接続する接続システムとを有するデータ復旧システムであって、前記接続システムは、前記センタシステムの第１のデータ処理状態を取得し、前記ユーザシステムに送信する状態取得手段と、前記第１のデータ処理状態と当該接続システムの第２のデータ処理状態とを比較し、前記第１のデータ処理状態に合わせて第１のデータ処理状態を更新する更新手段と、を有し、前記ユーザシステムは、前記接続システムから送信された第１のデータ処理状態と、当該ユーザシステムの第３のデータ処理状態とを比較し、第３のデータ処理状態を前記第１のデータ処理状態に同期させる同期手段を有する。
【発明の効果】
【００１１】
本発明では、障害時に発生するデータの不整合を解消し、３つのシステム間で同期が取れた状態にデータを復旧することができる。
【発明を実施するための最良の形態】
【００１２】
以下、本発明の実施の形態について説明する。
【００１３】
図１は、本発明の一実施形態が適用されたシステムの全体構成図である。図示するシステムは、複数のユーザシステム１と、接続システム２Ａ、２Ｂと、センタシステム３Ａ、３Ｂとを有する。接続システムは、メインサイトの接続システム２Ａ（現用系）と、広域災害に備えたバックアップサイトの接続システム２Ｂ（予備系）とを備える。また、センタシステムも同様に、メインサイトのセンタシステム３Ａ（現用系）と、広域災害に備えたバックアップサイトのセンタシステム３Ｂ（予備系）とを備える。
【００１４】
通常時において、メインサイトの接続システム２Ａは、専用線などのネットワークにより複数のユーザシステム１と接続されるとともに、メインサイトのセンタシステム３Ａに接続されている。なお、本実施形態では、センタシステム３Ａ、３Ｂが日銀ネット（日本銀行金融ネットワークシステム）の場合を例に以下説明するが、これに限定されるものではない。
【００１５】
ユーザシステム１は、例えば、各種銀行、証券会社等の金融機関のシステムであって、接続システム２Ａを介して日銀ネット３Ａとデータの送受信を行う。図示するユーザシステムは、所定の業務処理を行う業務処理部１１と、障害時にデータの同期処理を行う同期処理部１２と、送信データおよび受信データを記憶する記憶部１３とを有する。
【００１６】
メインサイトの接続システム２Ａは、各ユーザシステム１が送信したデータを日銀ネット３Ａに接続するとともに、日銀ネット３Ａが送信したデータを各ユーザシステム１に接続する。なお、本実施形態では、各ユーザシステム１は、接続システム２Ａを共同利用するものとする。
【００１７】
図示する接続システム２Ａは、所定の業務処理を行う業務処理部２１と、レプリケーション部２２と、状態取得部２３と、更新部２４と、同期指示部２５と、記憶部２６とを有する。レプリケーション部２２は、記憶部２６に対する更新データをバックアップサイトの接続システム２Ｂに送信し、メインサイトの記憶部２６の内容をバックアップサイトの記憶部２６に反映させる。状態取得部２３は、日銀ネット３Ａの記憶部３１のデータ処理状態および各ユーザシステムの記憶部１３のデータ処理状態を取得する。
【００１８】
更新部２４は、日銀ネット３Ａのデータ処理状態に合わせて、記憶部２６のデータ処理状態を更新する。同期指示部２５は、ユーザシステムのデータ処理状態を日銀ネット３Ａのデータ処理状態に同期させるための同期指示をユーザシステムに送信する。あるいは、同期指示部２５は、更新後の記憶部２６のデータ処理状態または日銀ネット３Ａのデータ処理状態を、ユーザシステムに送信する。記憶部２６には、送信データおよび受信データが記憶されている。
【００１９】
なお、バックアップサイトの接続システム２Ｂは、メインサイトの接続システム２Ａと同様の構成である。
【００２０】
日銀ネット３Ａ、３Ｂは、日本銀行と取引先金融機関との資金や国債の決済をオンラインで処理する。メインサイトの日銀ネット３Ａおよびバックアップサイトの日銀ネット３Ｂは、各ユーザシステムに対する送受信データが記憶された記憶部３１を有する。なお、メインサイトの日銀ネット３Ａは、レプリケーション処理により記憶部３１の内容を、バックアップサイトの記憶部３１に反映させるものとする。
【００２１】
上記説明した、ユーザシステム１および接続システム２Ａ、２Ｂは、いずれも、例えば図２に示すようなＣＰＵ９０１と、メモリ９０２と、ＨＤＤ等の外部記憶装置９０３と、キーボードやマウスなどの入力装置９０４と、ディスプレイやプリンタなどの出力装置９０５と、ネットワークと接続するための通信制御装置９０６と、を備えた汎用的なコンピュータシステムを用いることができる。このコンピュータシステムにおいて、ＣＰＵ９０１がメモリ９０２上にロードされた所定のプログラムを実行することにより、各装置の各機能が実現される。
【００２２】
例えば、ユーザシステム１および接続システム２Ａ、２Ｂの各機能は、ユーザシステム１用のプログラムの場合はユーザシステム１のＣＰＵ９０１が、接続システム２Ａ、２Ｂ用のプログラムの場合は接続システム２Ａ、２ＢのＣＰＵ９０１が、それぞれ実行することにより実現される。なお、入力装置９０４および出力装置９０５については、各装置が必要に応じて備えるものとする。また、ユーザシステム１の記憶部１３には、ユーザシステム１のメモリ９０２または外部記憶装置９０３が用いられる。また、接続システム２Ａ、２Ｂの記憶部２６には、接続システム２Ａ、２Ｂのメモリ９０２または外部記憶装置９０３が用いられる。
【００２３】
次に、本実施形態におけるデータの流れについて説明する。
【００２４】
図３は、ユーザシステム１から日銀ネット３へ送信されるＩＮＱデータ（処理要求）と、当該ＩＮＱデータに対するＲＥＳデータ（応答）のシーケンス図である。
【００２５】
ユーザシステム１の業務処理部１１は、ＩＮＱデータを接続システム２に送信する（Ｓ１１）。そして、接続システム２の業務処理部２１は、ユーザシステム１が送信したＩＮＱデータを、日銀ネット３に送信する（Ｓ１２）。そして、日銀ネット３は、ＩＮＱデータに対するＲＥＳデータを接続システム２に送信する（Ｓ１３）。そして、接続システム２の業務処理部２１は、日銀ネット３が送信したＲＥＳデータをユーザシステム１に送信する（Ｓ１４）。
【００２６】
そして、ユーザシステム１の記憶部１３および接続システム２の記憶部２６には、送受信したＩＮＱデータおよびＲＥＳデータが通番およびステータスとともに記憶されている。また、日銀ネット３の記憶部３１には、受信したＩＮＱデータが通番およびステータスとともに記憶されている。
【００２７】
図示する例では、各システム１、２、３の記憶部１３、２６、３１には、ＩＮＱ通番１から６までのＩＮＱデータが処理され、ＲＥＳ通番１から６までのＲＥＳデータが処理されていることを示している。すなわち、ユーザシステム１、接続システム２および日銀ネット３のシステム間で、データ処理状況の同期が取れていることを示している。
【００２８】
なお、ユーザシステム１のステータス「ＲＥＳ受信済」は、接続システム２から当該ＩＮＱ通番に対するＲＥＳデータを受信済みであることを示している。また、接続システム２のテータス「ＲＥＳ受信済」は、当該ＩＮＱ通番に対する日銀ネット３からのＲＥＳデータを受信済みであることを示している。また、接続システム２のテータス「送信済」は、当該ＲＥＳ通番に対する日銀ネット３からのＲＥＳを、ユーザシステム１に送信済みであることを示している。また、日銀ネット３のテータス「処理済」は、当該ＩＮＱ通番に対するＩＮＱデータを受信し、かつＲＥＳデータを送信済みであることを示している。
【００２９】
図４は、日銀ネット３からユーザシステム１へ送信されるＥＸデータ（通知）のシーケンス図である。
【００３０】
日銀ネット３は、ＥＸデータを接続システム２に送信する（Ｓ２１）。そして、接続システム２の業務処理部２１は、日銀ネット３が送信したＥＸデータを、ユーザシステム１に送信する（Ｓ２２）。図示する例では、ユーザシステム１、接続システム２および日銀ネット３の各記憶部１３、２６、３１には、ＥＸ通番１から３までのＥＸデータが処理されていることを示している。すなわち、ユーザシステム１、接続システム２および日銀ネット３のシステム間で、ＥＸデータの処理状況の同期が取れていることを示している。
【００３１】
なお、日銀ネット３のテータス「処理済」は、当該ＥＸ通番に対するＥＸデータを接続システム２に送信済みであることを示している。接続システム２のステータス「送信済」は、当該ＥＸ通番に対するＥＸデータを、ユーザシステム１に送信済みであることを示している。
【００３２】
次に、障害時において、接続システムおよび／または日銀ネットを、バックアップシステムに切替えた際に、データの不整合が発生する場合について説明する。
【００３３】
図５（ａ）は、メインサイトの接続システム２Ａのみが被災し、バックアップサイトの接続システム２Ｂに切替える場合を示している。図示する例では、被災直前では、メインサイトの接続システム２Ａおよび日銀ネット３Ａでは、通番１から５までのデータ（ＩＮＱまたはＥＸ）を処理済である。しかしながら、切替え後のバックアップサイトの接続システム２Ｂでは、レプリケーションのタイムラグにより、通番１から４までのデータしか反映されていない。すなわち、接続システム２Ｂのデータ処理は、日銀ネット３Ａより遅れた状態であることを示している。
【００３４】
図５（ｂ）は、メインサイトの日銀ネット３Ａのみが被災し、バックアップサイトの日銀ネット３Ｂに切替える場合を示している。図示する例では、図５（ａ）と同様に、被災直前では、通番１から５までのデータを処理済である。しかしながら、切替え後のバックアップサイトの日銀ネット３Ｂでは、レプリケーションのタイムラグにより、通番１から４までのデータしか反映されていない。すなわち、日銀ネット３Ｂのデータ処理は、接続システム２Ａより遅れた状態であることを示している。
【００３５】
図５（ｃ）は、メインサイトの接続システム２Ａおよび日銀ネット３Ａがともに被災し、バックアップサイトの接続システム２Ｂおよび日銀ネット３Ｂに切替える場合を示している。図示する例では、図５（ａ）と同様に、被災直前では、通番１から５までのデータを処理済である。しかしながら、切替え後のいずれかのバックアップサイトでは、レプリケーションのタイムラグにより、１から４までのデータしか反映されていない。すなわち、接続システム２Ｂのデータ処理が日銀ネット３Ｂより遅れた状態である場合と、接続システム２Ｂのデータ処理が日銀ネット３Ｂより進んだ状態である場合と、を示している。
【００３６】
次に、接続システムおよび／または日銀ネットをバックアップサイトのシステムに切替えた際に、ユーザシステム１、接続システム２Ａ、２Ｂおよび日銀ネット３Ａ、３Ｂの３つのシステム間でデータの同期をとるためのデータ復旧処理について説明する。なお、これ以降、メインサイトおよびバックアップサイトの接続システム２Ａ、２Ｂを、接続システム２とする。また、メインサイトおよびバックアップサイトの日銀ネット３Ａ、３Ｂを、日銀ネット３とする。
【００３７】
本実施形態のデータ復旧方法は、日銀ネット３を基準とし、日銀ネット３のデータ処理状態に接続システム２およびユーザシステム１を合わせるものとする。また、データ復旧方法には、第１の方法と、第２の方法とが考えられ、まず、第１の方法について説明する。第１のデータ復旧方法は、接続システム２が自記憶部２６のデータ処理状態を日銀ネット３に合わせて更新するとともに、ユーザシステム１のデータ処理状態を日銀ネット３に合わせるための同期指示をユーザシステム１に送信する。
【００３８】
図６は、ＩＮＱおよびＲＥＳの第１のデータ復旧処理のシーケンス図である。また、図７および図８は、接続システム２のデータ処理状態が日銀ネット３より遅れた場合における、各システムの記憶部１３、２６、３１のデータの状態遷移を模式的に示した図である。なお、ユーザシステム１のデータ処理状態は、バックアップサイトへの切替えがないため、接続システム２および日銀ネット３より進んでいるものとする。
【００３９】
図７（ａ）は、接続システム２および／または日銀ネット３をバックアップサイトに切替えた後の各システムのデータ処理状態を示している。前述のとおり、ユーザシステム１のデータ処理状態（第３のデータ処理状態）が最も進んでいて、次に日銀ネット３のデータ処理状態（第１のデータ処理状態）が接続システム２のデータ処理状態（第２のデータ処理状態）より進んでおり、３システム間でデータ処理状態が不整合になっている。
【００４０】
まず、接続システム２は、ユーザシステム１と接続し、処理を開始する（Ｓ３１）。これにより、図７（ｂ）に示すデータ処理状態となる。すなわち、接続システム２の業務処理部２１は、図７（ａ）でステータスが「未送信」のＲＥＳ通番１について、当該ＲＥＳをユーザシステム１に送信し、ステータスを「送信済」に更新する（Ｓ３２）。「未送信」は、ＲＥＳを日銀ネット３から受信したが、ユーザシステム１に未だ送信していないことを示している。ユーザシステム１は、既にＲＥＳ通番１のＲＥＳを受信しているため、受信したＲＥＳを破棄し、ステータスに「重複受信」を設定する。
【００４１】
そして、接続システム２の状態取得部２３は、日銀ネット３のデータ処理状態を、日銀ネット３に要求する（Ｓ３３）。日銀ネット３は、記憶部３１に記憶されたデータの処理状態（例えば、ＩＮＱ通番、処理通番、ステータス）を送信する（Ｓ３４）。そして、接続システム２の更新部２４は、自記憶部２６のデータ処理状態と日銀ネット３のデータ処理状態とを比較（マッチング）する（Ｓ３５）。そして、接続システム２の更新部２４は、日銀ネット３から取得したデータに基づいて、自記憶部２６のデータを更新する（Ｓ３６）。
【００４２】
図７（ｂ）に示すように、接続システム２のデータ処理は、日銀ネット３より遅れた状態にある。この場合、接続システム２の更新部２４は、自記憶部２６のデータ処理状態を日銀ネット３に合わせるため、差分データのリセンド（再送）要求を日銀ネット３に送信する（Ｓ３６１）。すなわち、図７（ｂ）では、ＩＮＱ通番１については両者で同期が取れているが、ＩＮＱ通番２から４については日銀ネット３のみが処理済で、接続システム２では処理が終了していない。したがって、更新部２４は、日銀ネット３に対して、差分データであるＩＮＱ通番２から４のリセンド要求（記憶部３１のＩＮＱ通番２から４のＩＮＱの再送要求）を送信する。日銀ネット３は、リセンド要求のデータを記憶部３１から読み出し送信する（Ｓ３６２）。
【００４３】
そして、接続システム２の更新部２４は、ＩＮＱ通番２から４のＩＮＱに基づいて、自記憶部２６のデータを更新する。これにより、図８（ｃ）に示すデータ処理状態となる。すなわち、更新部２４は、ＩＮＱ通番２および３については、当該レコードのステータスを「ＲＥＳ受信済」に更新する。また、更新部２４は、ＩＮＱ通番４については、ステータスが「ＲＥＳ受信済」のレコードを新たに生成する。これにより、業務処理部２１は、ＲＥＳ通番２から４のＲＥＳをユーザシステム１に送信し、当該ＲＥＳのレコードを記憶部２６に登録する。なお、ユーザシステム１では、既にＲＥＳ通番２から４のＲＥＳを受信しているため、受信したＲＥＳを破棄し、ステータスに「重複受信」を設定する。
【００４４】
そして、接続システム２は、日銀ネット３と接続し、処理を開始する（Ｓ３７）。そして、接続システム２の状態取得部２３は、ユーザシステム１にデータ処理状態を要求する（Ｓ３８）。ユーザシステム１の同期処理部１２は、記憶部１３に記憶されたデータ処理状態（例えば、ＩＮＱ通番、処理通番、ステータス）を送信する（Ｓ３９）。そして、接続システム２の同期指示部２５は、自記憶部２６の更新後のデータ処理状態（または日銀ネット３のデータ処理状態）と、ユーザシステム１のデータ処理状態とを比較する（Ｓ４０）。
【００４５】
図８（ｃ）に示すように更新後の接続システム２のデータ処理状態は、ユーザシステム１より遅れた状態にある。この場合、接続システム２の同期指示部２５は、自記憶部２６の状態とユーザシステム１の状態との同期を合わせるため、未処理分の差分データの再送をユーザシステム１に要求する（Ｓ４１）。図８（ｃ）に示す場合、ＩＮＱ通番５および６については、接続システム２および日銀ネット３では未処理である。したがって、同期指示部２５は、差分データであるＩＮＱ通番５および６（または、ＩＮＱ通番５以降）のＩＮＱの再送要求を、ユーザシステム１に送信する。ユーザシステム１の同期処理部１２は、再送要求されたＩＮＱを記憶部１３から読み出して送信する（Ｓ４２）。
【００４６】
これにより、接続システム２の業務処理部２１は、図３で説明した通常の処理により、ユーザシステム１から受信したＩＮＱ（通番５、６）を日銀ネット３に送信し、日銀ネット３からＲＥＳ（通番５、６）を受信し、ユーザシステム１に送信する。これにより、図８（ｄ）に示すデータ処理状態となり、全てのＩＮＱおよびＲＥＳについて、ユーザシステム１、接続システム２および日銀ネット３間で同期が取れた状態となる。
【００４７】
次に、ＩＮＱおよびＲＥＳのデータ復旧処理において、接続システム２のデータ処理状態が、日銀ネット３より進んでいる場合について説明する。なお、ユーザシステム１のデータ処理は、接続システム２および日銀ネット３より進んでいるものとする。
【００４８】
図９および図１０は、接続システム２のデータ処理が日銀ネット３より進んでいる場合における、各システムの記憶部１３、２６、３１のデータの状態遷移を模式的に示した図である。
【００４９】
図９（ａ）は、接続システム２および／または日銀ネット３をバックアップサイトに切替えた後の各システムのデータ処理状態を示している。前述のとおり、ユーザシステム１のデータ処理状態が最も進んでいて、次に接続システム２が日銀ネット３より進んでおり、３システム間でデータ処理状態が不整合になっている。
【００５０】
まず、接続システム２は、ユーザシステム１と接続し、処理を開始する（図６：Ｓ３１）。これにより、図９（ｂ）に示すデータ処理状態となる。すなわち、接続システム２の業務処理部２１は、図９（ａ）でステータスが「未送信」のＲＥＳ通番１および２について、当該ＲＥＳをユーザシステム１に送信し、ステータスを「送信済」に更新する（Ｓ３２）。ユーザシステム１は、既にＲＥＳ通番１および２のＲＥＳを受信しているため、受信したＲＥＳを破棄し、ステータスに「重複受信」を設定する。
【００５１】
そして、接続システム２の状態取得部２３は、日銀ネット３の記憶部３１のデータ処理状態を要求する（Ｓ３３）。日銀ネット３は、記憶部３１に記憶されたデータ処理状態（例えば、ＩＮＱ通番、処理通番、ステータス）を送信する（Ｓ３４）。そして、接続システム２の更新部２４は、自記憶部２６のデータ処理状態と日銀ネット３のデータ処理状態とを比較する（Ｓ３５）。そして、更新部２４は、日銀ネット３から取得したデータに基づいて、自記憶部２６のデータを更新する（Ｓ３６）。
【００５２】
図９（ｂ）に示すように、接続システム２のデータ処理は、日銀ネット３より進んだ状態にある。この場合、接続システム２の更新部２４は、自記憶部３１のデータ処理状態を日銀ネット３に合わせるため、差分データの削除やステータスを変更する。すなわち、図９（ｂ）では、ＩＮＱ通番１および４については両者で同期が取れているが、ＩＮＱ通番２および３については、同期が取れていない。したがって、更新部２４は、ＩＮＱ通番２については、ＩＮＱ通番２のステータスを「未処理」に更新するとともに、ＲＥＳ通番２のレコードを削除する。また、更新部２４は、ＩＮＱ通番３については、ステータスを「未処理」に更新する。これにより、図１０（ｃ）に示すデータ処理状態となる。
【００５３】
そして、接続システム２は、日銀ネット３と接続し、処理を開始する（Ｓ３７）。これにより、図１０（ｄ）に示すデータ処理状態となる。すなわち、図３で説明した通常の処理により、接続システム２の業務処理部２１は、ＩＮＱ通番２から４のＩＮＱを日銀ネット３に送信するとともに、日銀ネット３からＲＥＳを受信し、ユーザシステム１に送信する。なお、ユーザシステム１では、既にＲＥＳ通番２から４のＲＥＳを受信しているため、受信したＲＥＳを破棄し、ステータスに「重複受信」を設定する。
【００５４】
そして、接続システム２の状態取得部２３は、ユーザシステム１にデータ処理状態を要求する（Ｓ３８）。ユーザシステム１は、記憶部１３に記憶されたデータ処理状態を送信する（Ｓ３９）。そして、接続システム２の同期指示部２５は、自記憶部２６の更新後のデータ処理状態（または日銀ネット３のデータ処理状態）と、ユーザシステム１のデータ処理状態とを比較する（Ｓ４０）。
【００５５】
図１０（ｄ）に示すように更新後の接続システム２のデータ処理は、ユーザシステム１より遅れた状態にある。この場合、接続システム２の同期指示部２５は、図８（ｃ）で説明したように、自記憶部３１の状態とユーザシステム１の状態との同期を合わせるため、未処理分の差分データ（ＩＮＱ通番５、６）の再送をユーザシステム１に要求する（Ｓ４１）。ユーザシステム１の同期処理部１２は、再送要求されたＩＮＱのデータを記憶部１３から読み出して送信する（Ｓ４２）。
【００５６】
これにより、接続システム２の業務処理部２１は、図３で説明した通常の処理により、ユーザシステム１から受信したＩＮＱ（通番５、６）を日銀ネット３に送信し、日銀ネット３からＲＥＳ（通番５、６）を受信し、ユーザシステム１に送信する。これにより、図１０（ｅ）に示すデータ処理状態となり、全てのＩＮＱおよびＲＥＳについて、ユーザシステム１、接続システム２および日銀ネット３間で同期が取れた状態となる。
【００５７】
次に、ＥＸの第１のデータ復旧処理について説明する。
【００５８】
図１１は、ＥＸの第１のデータ復旧処理のシーケンス図である。また、図１２は、接続システム２のデータ処理が日銀ネット３より遅れている場合における、各システムの記憶部１３、２６、３１のデータの状態遷移を模式的に示した図である。なお、ユーザシステム１のデータ処理は接続システム２および日銀ネット３より進んでいるものとする。
【００５９】
図１２（ａ）は、接続システム２および／または日銀ネット３をバックアップサイトに切替えた後の各システムのデータ処理状態を示している。図示する例では、ユーザシステム１のデータ処理状態が最も進んでいて、次に日銀ネット３が接続システム２より進んでおり、３システム間でデータ処理状態が不整合になっている。
【００６０】
まず、接続システム２は、ユーザシステム１と接続し、処理を開始する（Ｓ５１）。これにより、１２（ｂ）に示すデータ処理状態となる。すなわち、接続システム２の業務処理部２１は、図１２（ａ）でステータスが「未送信」９１のＥＸ通番１について、当該ＥＸをユーザシステム１に送信し、ステータスを「送信済」に更新する（Ｓ５２）。「未送信」は、ＥＸを日銀ネット３から受信したが、ユーザシステム１に未だ送信していないことを示している。ユーザシステム１では、既にＥＸ通番１のＥＸを受信しているため、受信したＥＸを破棄し、ステータスに「重複受信」を設定する。
【００６１】
そして、接続システム２の状態取得部２３は、日銀ネット３にデータ処理状態を要求する（Ｓ５３）。日銀ネット３は、記憶部３１に記憶されたデータ処理状態（例えば、ＩＮＱ通番、処理通番、ステータス）を送信する（Ｓ５４）。また、接続システム２の状態取得部２３は、ユーザシステム１にデータ処理状態を要求する（Ｓ５５）。ユーザシステム１の同期処理部１２は、記憶部１３に記憶されたデータ処理状態を送信する（Ｓ５６）。なお、接続システム２の状態取得部２３は、先にユーザシステム１にデータ処理状態を要求し、または日銀ネット３とユーザシステム１に対して同時にデータ処理状態を要求することとしてもよい。
【００６２】
そして、接続システム２の同期指示部２５は、日銀ネット３のデータ処理状態とユーザシステム１のデータ処理状態とを比較する（Ｓ５７）。そして、同期指示部２５は、ユーザシステム１の状態を日銀ネット３の状態を合わせるための同期指示を生成し、ユーザシステム１に送信する（Ｓ５８）。図１２（ｂ）に示す場合、日銀ネット３のデータ処理はユーザシステム１より遅れた状態にある。すなわち、ＥＸ通番１および２については両者で同期が取れているが、ＥＸ通番３ついてはユーザシステム１のみが処理済で、日銀ネット３では未処理の状態である。したがって、同期指示部２５は、差分データであるＥＸ通番３（またはＥＸ通番３以降）のＥＸの削除要求を生成し、ユーザシステム１に送信する。ユーザシステム１の同期処理部１２は、接続システム２からの同期指示を受け付けて、ＥＸ通番３のデータを記憶部１３から削除する（Ｓ５９）。これにより、図１２（ｃ）に示すデータ処理状態となる。
【００６３】
そして、接続システム２の更新部２４は、自記憶部２６のデータ処理状態と、日銀ネット３のデータ処理状態とを比較する（Ｓ６０）。そして、更新部２４は、日銀ネット３から取得したデータ処理状態に基づいて、自記憶部２６のデータを更新する（Ｓ６１）。
【００６４】
図１２（ｃ）に示すように、接続システム２のデータ処理は日銀ネット３より遅れた状態にある。この場合、接続システム２の更新部２４は、自記憶部２６のデータ処理状態を日銀ネット３に合わせるため、差分データのリセンド要求を日銀ネット３に送信する（Ｓ６１１）。すなわち、図１２（ｃ）では、ＥＸ通番１については両者で同期が取れているが、ＥＸ通番２については日銀ネット３のみが処理済で、接続システム２では未処理である。したがって、更新部２４は、日銀ネット３に対して、差分データであるＥＸ通番２のリセンド要求（記憶部３１のＥＸ通番２のＥＸの再送要求）を送信する。日銀ネット３は、リセンド要求のデータを記憶部３１から読み出し送信する（Ｓ６１２）。
【００６５】
接続システム２の更新部２４は、ＥＸ通番２のＥＸを受信し、当該ＥＸに基づいて記憶部２６のデータを更新する。これにより、１２（ｄ）に示すデータ処理状態となる。すなわち、更新部２４は、受信したＥＸ通番２のＥＸを、「未送信」のステータスで記憶部２６に登録する。そして、業務処理部２１は、ＥＸ通番２のＥＸをユーザシステム１に送信し、当該ＥＸ通番２のステータスを「送信済」に更新する。なお、ユーザシステム１では、既にＥＸ通番２のＥＸを受信しているため、受信したＥＸを破棄し、ステータスに「重複受信」を設定する。
【００６６】
なお、図１２（ｄ）のデータ処理状態は、全てのＥＸについて、ユーザシステム１、接続システム２および日銀ネット３間で同期が取れている。そして、接続システム２は、日銀ネット３と接続し、処理を開始する（Ｓ６２）。日銀ネット３は、新たなＥＸを送信する際には、図１２（ｅ）に示すように、最後の通番に「１」カウントアップした通番（ＥＸ通番３）を採番し、送信する。
【００６７】
次に、ＥＸのデータ復旧処理において、接続システム２のデータ処理が日銀ネット３より進んでいる状態について説明する。なお、ユーザシステム１のデータ処理は、接続システム２および日銀ネット３より進んでいるものとする。
【００６８】
図１３は、接続システム２のデータ処理が日銀ネット３より進んでいる場合における、各システムの記憶部１３、２６、３１のデータの状態遷移を模式的に示した図である。
【００６９】
図１３（ａ）は、接続システム２および／または日銀ネット３をバックアップサイトに切替えた後の各システムのデータ処理状態を示している。図示する例では、前述のとおりユーザシステム１のデータ処理状態が最も進んでいて、次に接続システム２が日銀ネット３より進んでおり、３システム間でデータ処理状態が不整合になっている。
【００７０】
まず、接続システム２は、ユーザシステム１と接続し、処理を再開する（Ｓ５１）。これにより、接続システム２の業務処理部は、図１３（ａ）でステータスが「未送信」のＥＸ通番１および２について、当該ＥＸをユーザシステム１に送信し、１３（ｂ）に示すようにステータスを「送信済」に更新する（Ｓ５２）。ユーザシステム１では、既にＥＸ通番１および２のＥＸを受信しているため、受信したＥＸを破棄し、ステータスに「重複受信」を設定する。
【００７１】
そして、接続システム２の状態取得部２３は、前述のとおり、日銀ネット３およびユーザシステム１のデータ処理状態を要求する（Ｓ５３、Ｓ５５）。日銀ネット３およびユーザシステム１は、各記憶部３１、１３に記憶されたデータ処理状態を送信する（Ｓ５４、Ｓ５６）。
【００７２】
そして、接続システム２の同期指示部２５は、日銀ネット３のデータ処理状態とユーザシステム１のデータ処理状態とを比較する（Ｓ５７）。そして、同期指示部２５は、ユーザシステム１の状態を日銀ネット３の状態を合わせるための同期指示を生成し、ユーザシステム１に送信する（Ｓ５８）。図１３（ｂ）に示す場合、ＥＸ通番１については両者で同期が取れているが、ＥＸ通番２および３については、ユーザシステム１のみが処理済で、日銀ネット３では未処理の状態である。したがって、同期指示部２５は、差分データであるＥＸ通番２および３（またはＥＸ通番２以降）のＥＸの削除要求を生成し、ユーザシステム１に送信する。
【００７３】
ユーザシステム１の同期処理部１２は、接続システム２からの同期指示を受け付けて、ＥＸ通番２および３のデータを記憶部１３から削除する（Ｓ５９）。これにより、図１３（ｃ）に示すデータ処理状態となる。
【００７４】
そして、接続システム２の更新部２４は、自記憶部２６のデータ処理状態と、日銀ネット３のデータ処理状態とを比較する（Ｓ６０）。そして、接続システム２の更新部２４は、日銀ネット３のデータ処理状態に基づいて、自記憶部２６のデータを更新する（Ｓ６１）。図１３（ｃ）に示すように接続システム２のデータ処理は日銀ネット３より進んだ状態にある。この場合、接続システム２の更新部２４は、自記憶部２６の状態を日銀ネット３の状態を合わせるため、差分データであるＥＸ通番２を記憶部２６から削除する。これにより、１３（ｄ）に示すデータ処理状態となり、全てのＥＸについて、ユーザシステム１、接続システム２および日銀ネット３間で同期が取れた状態となる。
【００７５】
そして、接続システム２は、日銀ネット３と接続し、処理を開始する（Ｓ６２）。日銀ネット３は、新たなＥＸを送信する際には、図１３（ｅ）に示すように、最後の通番に「１」カウントアップした通番（ＥＸ通番２）を採番し、送信する。
【００７６】
次に、第２のデータ復旧方法について説明する。
【００７７】
第２のデータ復旧方法は、接続システム２が自記憶部２６のデータ処理状態を日銀ネット３に合わせて更新するとともに、更新後の自記憶部２６のデータ処理状態または日銀ネットのデータ処理状態をユーザシステムに送信する。そして、ユーザシステム１は、自記憶部１３のデータ処理状態を接続システムから送信されたデータ処理状態に同期させる同期処理を行う。
【００７８】
図１４は、ＩＮＱおよびＲＥＳの第２のデータ復旧処理のシーケンス図である。
【００７９】
Ｓ７１からＳ７７については、図６で説明した第１のデータ復旧処理のＳ３１からＳ７７と同様であるため、ここでは説明を省略する。
【００８０】
Ｓ７８において、接続システム２の同期指示部２５は、Ｓ７６において更新した後のデータ処理状態を自記憶部２６から抽出し、ユーザシステム１に送信する。例えば、図８（ｃ）のデータ処理状態の場合、同期指示部２５は、ＩＮＱ通番１から４を、または、最後のＩＮＱ通番４のみをユーザシステム１に送信する。なお、同期指示部２５は、Ｓ７４で取得した日銀ネット３のデータ処理状態をユーザシステムに送信することとしてもよい。
【００８１】
そして、ユーザシステム１の同期処理部１２は、接続システム２から送信されたデータ処理状態と自記憶部１３のデータ処理状態とを比較する（Ｓ７９）。これにより、同期処理部１２は、同期のとれていない差分データを特定する。例えば、図８（ｃ）および図１０（ｄ）に示す場合、同期処理部１２は、差分データとしてＩＮＱ５および６を特定する。そして、同期処理部１２は、差分データであるＩＮＱ通番５および６のデータを記憶部１３から読み出して、接続システム２に再送する（Ｓ８０）。
【００８２】
これにより、接続システム２の業務処理部２１は、図３で説明した通常の処理により、ユーザシステム１から受信したＩＮＱ（通番５、６）を日銀ネット３に送信し、日銀ネット３からＲＥＳ（通番５、６）を受信し、ユーザシステム１に送信する。これにより、図８（ｄ）または図１０（ｅ）に示すデータ処理状態となり、全てのＩＮＱおよびＲＥＳについて、ユーザシステム１、接続システム２および日銀ネット３間で整合性が取れた状態となる。
【００８３】
図１５は、ＥＸの第２のデータ復旧処理のシーケンス図である。
【００８４】
Ｓ９１からＳ９４については、図１１で説明した第１のデータ復旧処理のＳ５１からＳ５４と同様であるため、ここでは説明を省略する。
【００８５】
Ｓ９５において、接続システム２の同期指示部２５は、Ｓ９４で取得した日銀ネット３のデータ処理状態を、ユーザシステム１に送信する（Ｓ９５）。例えば、図１２（ｃ）のデータ処理状態の場合、同期指示部２５は、ＥＸ通番１および２を、または、最後のＥＸ通番２のみをユーザシステム１に送信する。また、図１３（ｃ）のデータ処理状態の場合、同期指示部２５は、ＥＸ通番１をユーザシステム１に送信する。
【００８６】
そして、ユーザシステム１の同期処理部１２は、日銀ネット３のデータ処理状態とユーザシステム１のデータ処理状態とを比較する（Ｓ９６）。これにより、同期処理部１２は、日銀ネット３と同期のとれていない差分データを特定する。例えば、図１２（ｃ）の場合はＥＸ通番３を、また図１３（ｃ）の場合はＥＸ通番２および３を、差分データとして特定する。そして、同期処理部１２は、特定した差分データを記憶部１３から削除する（Ｓ９７）。
【００８７】
以降のＳ９８からＳ１００については、図１１で説明した第１のデータ復旧処理のＳ６０からＳ６２と同様であるため、ここでは説明を省略する。これにより、ユーザシステム１、接続システム２および日銀ネット３間で整合性が取れた状態となる。
【００８８】
以上説明した本実施形態のデータ復旧処理により、接続システム２および／または日銀ネット３をバックアップサイトに切替え後に発生するデータの不整合を解消し、各システム１、２、３間で同期が取れた状態にデータを復旧することができる。
【００８９】
また、本実施形態のデータ復旧処理は、センタシステムである日銀ネット３を基準とし、日銀ネット３のデータ処理状態に接続システム２およびユーザシステム１を合わせる。これにより、複数のユーザシステムが接続されたセンタシステムにおいて、ユーザシステム毎にどちらのデータ処理状態を基準にデータ復旧処理を行うかの判断が不要となるため、標準化した効率のよいデータ復旧処理を行うことができる。
【００９０】
また、本実施形態では、複数のユーザシステム１は接続システム２を共同利用し、接続システムが各ユーザシステム１に対して、日銀ネット３のデータ処理状態に同期をさせる同期指示、あるいは、日銀ネット３のデータ処理状態をユーザシステム１に送信する。これにより、ユーザシステム１側でのシステム運用負荷およびシステムコストを低減することができる。
【００９１】
なお、本発明は上記の実施形態に限定されるものではなく、その要旨の範囲内で数々の変形が可能である。
【図面の簡単な説明】
【００９２】
【図１】本発明の一実施形態が適用されたデータ復旧システムの構成図である。
【図２】各装置のハードウェア構成例を示す図である。
【図３】通常時のＩＮＱおよびＲＥＳのデータ送受信のシーケンス図である。
【図４】通常時のＥＸのデータ送受信のシーケンス図である。
【図５】バックアップシステムに切替えた際に発生するデータの不整合を模式的に示す図である。
【図６】ＩＮＱおよびＲＥＳの第１のデータ復旧処理のシーケンス図である。
【図７】ＩＮＱおよびＲＥＳのデータ復旧処理における、各システムのデータの状態遷移を模式的に示した図である。
【図８】ＩＮＱおよびＲＥＳのデータ復旧処理における、各システムのデータの状態遷移を模式的に示した図である。
【図９】ＩＮＱおよびＲＥＳのデータ復旧処理における、各システムのデータの状態遷移を模式的に示した図である。
【図１０】ＩＮＱおよびＲＥＳのデータ復旧処理における、各システムのデータの状態遷移を模式的に示した図である。
【図１１】ＥＸの第１のデータ復旧処理のシーケンス図である。
【図１２】ＥＸのデータ復旧処理における、各システムのデータの状態遷移を模式的に示した図である。
【図１３】ＥＸのデータ復旧処理における、各システムのデータの状態遷移を模式的に示した図である。
【図１４】ＩＮＱおよびＲＥＳの第２のデータ復旧処理のシーケンス図である。
【図１５】ＥＸの第２のデータ復旧処理のシーケンス図である。
【符号の説明】
【００９３】
１：ユーザシステム、１１：業務処理部、１２：同期処理部、１３：記憶部、２：接続システム、２１：業務処理部、２２：レプリケーション部、２３：状態取得部、２４：更新部、２５：同期指示部、２６：記憶部、３：日銀ネット、３１：記憶部
【図１】
2008242715.tif 000003
【図２】
2008242715.tif 000004
【図３】
2008242715.tif 000005
【図４】
2008242715.tif 000006
【図５】
2008242715.tif 000007
【図６】
2008242715.tif 000008
【図７】
2008242715.tif 000009
【図８】
2008242715.tif 000010
【図９】
2008242715.tif 000011
【図１０】
2008242715.tif 000012
【図１１】
2008242715.tif 000013
【図１２】
2008242715.tif 000014
【図１３】
2008242715.tif 000015
【図１４】
2008242715.tif 000016
【図１５】
2008242715.tif 000017