(57)【要約】【課題】更新ログの高速転送を実現しつつ、障害発生時等によって更新ログが急激に滞留した場合であっても確実にレプリケーションを実行し得る、レプリケーションシステム、業務処理システム、レプリケーション方法、及びプログラムを提供する。【解決手段】業務処理システム１００とバックアップシステム２００とを備える。業務処理システム１００は、更新対象データとその更新ログとを格納する記憶装置３０ａと、記憶装置３０ａよりも読み出し速度及び書き込み速度は低いが記憶容量が大きい記憶装置４０ｂと、記憶装置３０ａ上の更新ログをバックアップシステム２００に送信する更新ログ送信部７と、設定条件下で、記憶装置３０ａ上の複数の更新ログを含む更新ログファイル１１を作成し、更新ログファイル１１を記憶装置４０ａに一旦格納した後、更新ログファイル１１をバックアップシステム２００に送信する、更新ログ退避部５とを備える。【選択図】図１
2014170448.tif 000002
【特許請求の範囲】
【請求項１】
業務処理を実行するための業務処理システムと、前記業務処理システムをバックアップするためのバックアップシステムとを備え、
前記業務処理システムは、
更新対象となるデータと前記データの更新ログとを格納する、第１の記憶装置と、
前記第１の記憶装置よりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい、第２の記憶装置と、
前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、更新ログ送信部と、
設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを前記第２の記憶装置に一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、更新ログ退避部と、
を備えている、ことを特徴とするレプリケーションシステム。
【請求項２】
前記設定条件が、前記バックアップシステムへの送信が終了していない更新ログの数が閾値を超えていることである、
請求項１に記載のレプリケーションシステム。
【請求項３】
前記バックアップシステムが、
前記更新対象となるデータのバックアップデータと、前記更新ログ送信部によって送信されてきた前記更新ログとを格納する、第３の記憶装置と、
前記更新ログ退避部によって送信されてきた前記更新ログファイルを格納する、第４の記憶装置と、
前記第４の記憶装置に前記更新ログファイルが格納されていない場合に、前記第３の記憶装置に格納されている前記更新ログに基づいて、前記バックアップデータを更新し、前記第４の記憶装置に前記更新ログファイルが格納されている場合に、前記更新ログファイルに基づいて、前記バックアップデータを更新する、更新ログ反映部と、
を備えている、請求項１または２に記載のレプリケーションシステム。
【請求項４】
前記更新ログに対し、発生した順に通番が付与されており、前記第１の記憶装置が、前記更新ログと共に、前記バックアップシステムへの送信が完了した更新ログの通番と前記バックアップシステムへの送信が完了していない更新ログの通番とを特定する通番情報を格納し、
前記更新ログ送信部は、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを前記バックアップシステムに送信し、
前記更新ログ退避部は、設定条件が満たされる場合に、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを用いて、前記更新ログファイルを作成する、
請求項１〜３のいずれかに記載のレプリケーションシステム。
【請求項５】
バックアップシステムと連携してレプリケーションを実行する業務処理システムであって、
更新対象となるデータと前記データの更新ログとを格納する、第１の記憶装置と、
前記第１の記憶装置よりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい、第２の記憶装置と、
前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、更新ログ送信部と、
設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを前記第２の記憶装置に一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、更新ログ退避部と、
を備えている、ことを特徴とする業務処理システム。
【請求項６】
前記設定条件が、前記バックアップシステムへの送信が終了していない更新ログの数が閾値を越えていることである、
請求項５に記載の業務処理システム。
【請求項７】
前記更新ログに対し、発生した順に通番が付与されており、前記第１の記憶装置が、前記更新ログと共に、前記バックアップシステムへの送信が完了した更新ログの通番と前記バックアップシステムへの送信が完了していない更新ログの通番とを特定する通番情報を格納し、
前記更新ログ送信部は、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを前記バックアップシステムに送信し、
前記更新ログ退避部は、設定条件が満たされる場合に、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを用いて、前記更新ログファイルを作成する、
請求項５または６に記載の業務処理システム。
【請求項８】
業務処理を実行するための業務処理システムと、前記業務処理システムをバックアップするためのバックアップシステムとを用いたレプリケーション方法であって、
（ａ）前記業務処理システムにおいて、更新対象となるデータと前記データの更新ログとを、第１の記憶装置に格納するステップと、
（ｂ）前記業務処理システムにおいて、前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、ステップと、
（ｃ）前記業務処理システムにおいて、設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを、前記第１の記憶装置よりも読み出し速度及び書き込み速度は低いが記憶容量は大きい前記第２の記憶装置に、一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、ステップと、
を有する、ことを特徴とするレプリケーション方法。
【請求項９】
コンピュータに、バックアップシステムとの連携によるレプリケーションを実行させるためのプログラムであって、
前記コンピュータに、
（ａ）更新対象となるデータと前記データの更新ログとを、前記コンピュータが備える第１の記憶装置に格納するステップと、
（ｂ）前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、ステップと、
（ｃ）設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを、前記コンピュータに備えられ、且つ前記第１の記憶装置よりも読み出し速度及び書き込み速度は低いが記憶容量は大きい前記第２の記憶装置に、一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、ステップと、
を実行させるプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、業務処理システムのバックアップを行なうための、レプリケーションシステム、業務処理システム、レプリケーション方法、及びこれらを実現するためのプログラムに関する。
【背景技術】
【０００２】
従来から、データをバックアップする手法の一つとして、レプリケーションが用いられている。レプリケーションでは、オンラインで業務を処理する業務処理システム上のデータは、別の拠点にある予備のシステムに複製され、常に、複製されたデータの内容は最新のデータと同期される（例えば、特許文献１〜３参照）。なお、本明細書においては、以降において、オンラインで業務を処理する業務処理システムを「フロントシステム」と表記し、予備のシステムを「バックアップシステム」と表記する。
【０００３】
ところで、このようなレプリケーションを採用する場合は、フロントシステムでの障害発生時に、業務処理への影響を抑えるため、フロントシステムでの更新ログをバックアップシステムに速やかに反映させる必要がある。このため、例えば、特許文献３においては、フロントシステムは、データベースのレコードのキーに基づき、レコードが同一となる更新ログが同一の処理系列となるように、更新ログを分割し、分割した状態でバックアップシステムに転送する。その後、バックアップシステムにおいて、速やかに更新ログが反映される。
【先行技術文献】
【特許文献】
【０００４】
【特許文献１】特開平６−６７９５９号公報
【特許文献２】特開平１０−４９４１８号公報
【特許文献３】特開２０１２−１３３４１７号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
ところで、上記特許文献３に開示されたシステムでは、フロントシステムからバックアップシステムへと、高速に更新ログを転送して、反映させる必要があるため、更新ログは、各システムのメモリデータベースに格納される。
【０００６】
しかしながら、メモリデータベースは、ディスク装置によるデータベースに対して上述の点では優れているが、容量限界値が低いため、障害発生時等によって更新ログが急激に滞留した場合に、更新ログをバックアップシステム２０に送信しきれない状態、即ち、更新ログが溢れてしまう状態が発生する可能性がある。このような場合、レプリケーションが実行できなくなる危険性がある。
【０００７】
本発明の目的の一例は、上記問題を解消し、更新ログの高速転送を実現しつつ、障害発生時等によって更新ログが急激に滞留した場合であっても確実にレプリケーションを実行し得る、レプリケーションシステム、業務処理システム、レプリケーション方法、及びプログラムを提供することにある。
【課題を解決するための手段】
【０００８】
上記目的を達成するため、本発明の一側面におけるレプリケーションシステムは、業務処理を実行するための業務処理システムと、前記業務処理システムをバックアップするためのバックアップシステムとを備え、
前記業務処理システムは、
更新対象となるデータと前記データの更新ログとを格納する、第１の記憶装置と、
前記第１の記憶装置よりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい、第２の記憶装置と、
前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、更新ログ送信部と、
設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを前記第２の記憶装置に一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、更新ログ退避部と、
を備えている、ことを特徴とする。
【０００９】
上記目的を達成するため、本発明の一側面における業務処理システムは、バックアップシステムと連携してレプリケーションを実行する業務処理システムであって、
更新対象となるデータと前記データの更新ログとを格納する、第１の記憶装置と、
前記第１の記憶装置よりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい、第２の記憶装置と、
前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、更新ログ送信部と、
設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを前記第２の記憶装置に一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、更新ログ退避部と、
を備えている、ことを特徴とする。
【００１０】
また、上記目的を達成するため、本発明の一側面におけるレプリケーション方法は、業務処理を実行するための業務処理システムと、前記業務処理システムをバックアップするためのバックアップシステムとを用いたレプリケーション方法であって、
（ａ）前記業務処理システムにおいて、更新対象となるデータと前記データの更新ログとを、第１の記憶装置に格納するステップと、
（ｂ）前記業務処理システムにおいて、前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、ステップと、
（ｃ）前記業務処理システムにおいて、設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを、前記第１の記憶装置よりも読み出し速度及び書き込み速度は低いが記憶容量は大きい前記第２の記憶装置に、一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、ステップと、
を有する、ことを特徴とする。
【００１１】
更に、上記目的を達成するため、本発明の一側面におけるプログラムは、コンピュータに、バックアップシステムとの連携によるレプリケーションを実行させるためのプログラムであって、
前記コンピュータに、
（ａ）更新対象となるデータと前記データの更新ログとを、前記コンピュータが備える第１の記憶装置に格納するステップと、
（ｂ）前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、ステップと、
（ｃ）設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを、前記コンピュータに備えられ、且つ前記第１の記憶装置よりも読み出し速度及び書き込み速度は低いが記憶容量は大きい前記第２の記憶装置に、一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、ステップと、
を実行させることを特徴とする。
【発明の効果】
【００１２】
以上のように、本発明によれば、更新ログの高速転送を実現しつつ、障害発生時等によって更新ログが急激に滞留した場合であっても確実にレプリケーションを実行することができる。
【図面の簡単な説明】
【００１３】
【図１】図１は、本発明の実施の形態におけるレプリケーションシステムの概略構成を示す図である。
【図２】図２は、本発明の実施の形態におけるレプリケーションシステムの構成を示すブロック図である。
【図３】図３は、本実施の形態においてフロントシステムで格納される更新ログ格納表の一例を示す図である。
【図４】図４は、本実施の形態においてフロントシステム及びバックアップシステムで格納される通番表の一例を示す図である。
【図５】図５は、本実施の形態においてフロントシステムで用いられる滞留閾値の一例を示す図である。
【図６】図６は、本実施の形態においてバックアップシステムで格納される更新ログ格納表の一例を示す図である。
【図７】図７は、本発明の実施の形態におけるフロントシステム（業務処理システム）の更新ログ送信処理時の動作を示すフロー図である。
【図８】図８は、通常時におけるレプリケーションシステムの処理の流れを示す説明図である。
【図９】図９は、通常時におけるレプリケーションシステムの更新ログの流れを示す説明図である。
【図１０】図１０は、本発明の実施の形態で用いられる更新ログ電文の一例を示す図である。
【図１１】図１１は、本発明の実施の形態におけるフロントシステム（業務処理システム）の更新ログ退避処理時の動作を示すフロー図である。
【図１２】図１２は、更新ログ滞留時におけるレプリケーションシステムの処理の流れを示す説明図である。
【図１３】図１３は、更新ログ滞留時におけるレプリケーションシステムの更新ログの流れを示す説明図である。
【図１４】図１４は、本実施の形態で作成される更新ログファイルの一例を示す図である。
【図１５】図１５は、本実施の形態で用いられるファイル転送通知電文の一例を示す図である。
【図１６】図１６は、本発明の実施の形態におけるバックアップシステムの更新ログ受信処理時の動作を示すフロー図である。
【図１７】図１７は、本発明の実施の形態におけるバックアップシステムの更新ログ反映処理時の動作を示すフロー図である。
【図１８】図１８は、本発明の実施の形態におけるフロントシステム（業務処理システム）を実現するコンピュータの一例を示すブロック図である。
【発明を実施するための形態】
【００１４】
（実施の形態）
以下、本発明の実施の形態における、レプリケーションシステム、業務処理システム、レプリケーション方法、及びプログラムについて、図１〜図１８を参照しながら説明する。
【００１５】
［システム構成：全体構成］
最初に、図１を用いて、本実施の形態におけるレプリケーションシステムのシステム構成について説明する。図１は、本発明の実施の形態におけるレプリケーションシステムの概略構成を示す図である。
【００１６】
図１に示すように、本実施の形態におけるレプリケーションシステム３００は、業務処理を実行するための業務処理システム１００と、業務処理システム１００をバックアップするためのバックアップシステム２００とを備えている。本実施の形態において、業務処理システム１００とバックアップシステム２００とは、ネットワークを介して接続されている。なお、本実施の形態では、以降において、業務処理システムを「フロントシステム」と表記する。
【００１７】
また、図１に示すように、フロントシステム１００は、第１の記憶装置３０ａと、第２の記憶装置４０ａと、更新ログ送信部７と、更新ログ退避部５とを備えている。このうち、第１の記憶装置３０ａは、更新対象となるデータと、このデータの更新ログとを格納している。第２の記憶装置４０ａは、第１の記憶装置３０ａよりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい記憶装置である。
【００１８】
更新ログ送信部７は、第１の記憶装置３０ａに格納されている更新ログを、バックアップシステム２００に送信する。よって、業務処理システム１００で生成された更新ログは、バックアップシステム２００においてバックアップされる。
【００１９】
また、更新ログ退避部５は、設定条件が満たされる場合、例えば、更新ログが急激に増加するような場合に、まず、第１の記憶装置３０ａに格納されている複数の更新ログを含む更新ログファイル１１を作成する。続いて、更新ログ退避部５は、作成した更新ログファイル１１を、第２の記憶装置４０ａに一旦格納した後、格納した更新ログファイル１１をバックアップシステム２００に送信する。
【００２０】
このように、本実施の形態では、更新ログは、通常、読み出し速度及び書き込み速度の速い第１の記憶装置３０ａに格納されているので、更新ログの高速転送を実現できる。そして、障害の発生、業務処理の一時的な増加等によって更新ログが滞留した場合は、更新ログは、更新ログファイルにまとめられ、容量の大きな第２の記憶装置に格納されてから、バックアップシステム２００へと送られる。このため、更新ログが溢れてしまう事態の発生が回避され、上述の場合であっても、確実にレプリケーションが実行される。
【００２１】
続いて、図２〜図６を用いて、本実施の形態におけるレプリケーションシステムの構成について更に具体的に説明する。図２は、本発明の実施の形態におけるレプリケーションシステムの構成を示すブロック図である。
【００２２】
［システム構成：フロントシステム］
図２に示すように、本実施の形態では、フロントシステム１００は、第１の記憶装置３０ａとしてメモリ記憶装置を備え、第２の記憶装置３０４０ａとしてディスク装置を備えている。また、メモリ記憶装置の記憶領域に構築されたメモリデータベース（以下「メモリＤＢ」と表記する。）に、更新対象となるデータ及び更新ログが格納される。以降の説明においては、メモリＤＢ３０ａ、ディスク装置４０ａと表記する。
【００２３】
また、本実施の形態では、フロントシステム１００において実行されるアプリケーションプログラム（以下「ＡＰ」と表記する）１によって、更新対象となるデータが更新される。具体的には、更新対象となるデータは、メモリＤＢ３０ａに格納されているユーザ表２である。ユーザ表２は、メモリＤＢ３０ａのレコードを表わすキー（Key）と、ユーザを表わす値（Value）とで構成されているものとする。
【００２４】
また、ＡＰ１は、ユーザ表２の更新によって更新ログが発生すると、それが備える更新ログ格納処理部３をＡＰＩとして呼び出す。更新ログ格納処理部３は、呼び出されると、発生した更新ログに、発生した順に通番を付与し、これらをメモリＤＢ３０ａに格納する。具体的には、通番が付与された更新ログは、更新ログ格納処理部３に格納されている更新ログ格納表３として、メモリＤＢ３０ａに格納されている。
【００２５】
図３に示すように、更新ログ格納表４は、更新ログ毎に、その通番と、各更新ログが更新ログファイル１１としての転送対象かどうかを示すフラグと、更新ログの内容とを登録している。図３は、本実施の形態においてフロントシステムで格納される更新ログ格納表の一例を示す図である。なお、「更新ログの内容」としては、ユーザ表２の更新内容が挙げられる。
【００２６】
また、更新ログ格納処理部３は、格納した更新ログの通番を、「登録済通番」として通番表６に登録する。通番表６は、図４に示すように、処理済通番と登録済通番とを特定する通番情報である。図４は、本実施の形態においてフロントシステム及びバックアップシステムで格納される通番表の一例を示す図である。
【００２７】
なお、処理済通番とは、バックアップシステム２００への送信が完了した更新ログの通番である。登録済通番とは、更新ログ格納処理部３によって登録された通番であって、バックアップシステム２００への送信が完了していない更新ログの通番である。
【００２８】
また、本実施の形態では、更新ログ送信部７は、通常時において、メモリＤＢ３０ａ上の更新ログ格納表４及び通番表６を参照し、更新ログを、更新ログ電文（後述の図１０参照）によって、バックアップシステム２００の更新ログ受信部１３に送信する。また、このとき、更新ログ送信部７は、メモリＤＢ３０ａに格納されている通番表６の処理済通番を更新する。なお、「通常時」とは、上述の設定条件が満たされず、更新ログ退避部５が処理を行なっていない場合をいう。
【００２９】
上述したように、更新ログ退避部５は、設定条件が満たされる場合に、更新ログ格納表４から複数の更新ログを取得し、これらをまとめて更新ログファイル１１（後述の図１４参照）として、ディスク装置４０ａへ退避させる。また、更新ログ退避部５は、退避した更新ログを、メモリＤＢ３０ａの更新ログ格納表４から削除する。
【００３０】
また、ディスク装置４０ａに格納された更新ログファイル１１は、更新ログ退避部５によるＦＴＰ（File Transfer Protocol）などのファイル転送によって、バックアップシステム２００に転送される。また、ファイル転送が成功した場合、ディスク装置４０ａは、更新ログファイル１１を削除する。
【００３１】
更新ログ退避部５は、更新ログ格納表４においてファイル転送対象（図３参照）となっている全ての更新ログについて、退避、ファイル転送を繰り返す。ファイル転送対象となっている全ての更新ログの退避、ファイル転送の終了後、更新ログ退避部５は、ファイル転送通知電文を更新ログ受信部１３に通知する。このファイル転送通知電文では、ファイル転送対象となった複数の更新ログの最初の通番（開始通番）と、同更新ログの最後の通番（終了通番）とが記録されている（後述の図１５参照）。
【００３２】
また、本実施の形態では、設定条件としては、フロントシステム１００において、更新ログが滞留した場合、具体的には、滞留数（＝登録済通番−処理済通番）が滞留閾値以上になった場合である。滞留閾値は、滞留閾値９として、メモリＤＢ３０ａに格納されている。図５は、本実施の形態においてフロントシステムで用いられる滞留閾値の一例を示す図である。
【００３３】
更に、図２に示すように、メモリＤＢ３０ａ上には、ロット数１０が格納されている。ロット数１０は、更新ログファイルに含められる更新ログの数の設定値である。また、本実施の形態では、滞留閾値９及びロット数１０は、設定部８によって設定される。設定部８は、フロントシステム１００の管理者からの指示に応じて、又は予め設定されたルールに応じて、滞留閾値９及びロット数１０を設定する。
【００３４】
［システム構成：バックアップシステム］
図２に示すように、バックアップシステム２００は、フロントシステム１００に障害が発生した場合に備えて、レプリケーションデータ、即ち、更新対象となるデータと更新ログとを保持するため、記憶装置３０ｂと、記憶装置４０ｂとを備えている。
【００３５】
このうち、記憶装置３０ｂは、フロントシステム１００のメモリＤＢ３０ａと同様に、メモリＤＢが構築されたメモリ装置である。また、記憶装置４０ｂは、フロントシステム１００のディスク装置４０ａと同様に、ディスク装置である。以降の説明においては、メモリＤＢ３０ｂ、ディスク装置４０ｂと表記する。
【００３６】
メモリＤＢ３０ｂには、更新対象となるデータのバックアップデータとして、ユーザ表２と同様のユーザ表１７が格納される。更に、メモリＤＢ３０ｂには、通番表６と同様の通番表１５、更新ログ退避部５から送信されてきたファイル転送通知電文中の開始通番１９及び終了通番２０も、格納されている。
【００３７】
また、メモリＤＢ３０ｂには、更新ログ送信部７から送信されてきた更新ログが、更新ログ格納表１４として格納される。図６は、本実施の形態においてバックアップシステムで格納される更新ログ格納表の一例を示す図である。図６に示すように、更新ログ格納表１４は、更新ログ毎に、その通番と、終端フラグと、更新ログの内容とを格納している。
【００３８】
終端フラグは、更新ログの更新処理時（反映時）における更新ログの参照先を、更新ログ格納表１４からディスク装置４０ｂに格納される更新ログファイル１１に切り替える際のポイントを示している。
【００３９】
また、ディスク装置４０ｂは、メモリＤＢ３０ｂよりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい記憶装置である。このため、ディスク装置４０ｂには、フロントシステム１００の更新ログ退避部５によって送信されてきた更新ログファイル１１が格納される。
【００４０】
また、図２に示すように、バックアップシステム２００は、更新ログ受信部１３と、更新ログ反映部１６とを備えている。このうち、更新ログ受信部１３は、更新ログ電文によって、更新ログを受信すると、これを、メモリＤＢ３０ｂ上の更新ログ格納表１４に格納し、通番表１５の登録済通番を更新する。また、更新ログ受信部１３は、更新ログ退避部５から、ファイル転送通知電文を受信した場合は、メモリＤＢ３０ｂ上の開始通番１９と終了通番２０とを更新する。
【００４１】
更新ログ反映部１６は、ディスク装置４０ｂに更新ログファイル１１が格納されていない場合は、メモリＤＢ３０ｂに格納されている更新ログ（更新ログ格納表１４）に基づいて、ユーザ表１７を更新する。また、更新ログ反映部１６は、ディスク装置４０ｂに更新ログファイル１１が格納されている場合、具体的には、上述の終端フラグがＹＥＳに設定されている場合（図６参照）は、更新ログファイル１１に基づいて、ユーザ表１７を更新する。
【００４２】
具体的には、後者の場合、更新ログ反映部１６は、メモリＤＢ３０ｂ上の通番表１５、更新ログ格納表４、及びディスク装置４０ｂを参照し、受信した更新ログファイル１１に基づいて、メモリＤＢ３０ｂ上のユーザ表１７を更新する。更に、この場合、更新ログ反映部１６は、メモリＤＢ３０ｂ上の通番表１５の処理済通番も更新する。更新ログ反映部１６は、更新処理が成功した時点で、更新処理の終了した更新ログファイル１１を削除する。
【００４３】
［システム動作］
次に、本発明の実施の形態におけるレプリケーションシステム３００の動作について図７〜図１７を用いて説明する。以下の説明においては、適宜図１〜図６を参酌する。また、本実施の形態では、レプリケーションシステム３００を動作させることによって、レプリケーション方法が実施される。よって、本実施の形態におけるレプリケーション方法の説明は、以下のレプリケーションシステム３００の動作説明に代える。
【００４４】
［システム動作：通常処理］
最初に、図７〜図１０を用いて、通常時におけるレプリケーションシステム３００の通常処理について説明する。
【００４５】
フロントシステム：
図７は、本発明の実施の形態におけるフロントシステム（業務処理システム）の更新ログ送信処理時の動作を示すフロー図である。図８は、通常時におけるレプリケーションシステムの処理の流れを示す説明図である。図９は、通常時におけるレプリケーションシステムの更新ログの流れを示す説明図である。図１０は、本発明の実施の形態で用いられる更新ログ電文の一例を示す図である。
【００４６】
まず、最初に、図８及び図９に示すように、フロントシステム１００において、ＡＰ１がメモリＤＢ上のユーザ表２を更新すると、更新ログ格納処理部３が、ＡＰＩとして呼び出され、メモリＤＢ３０ａ上の更新ログ格納表４に更新ログを格納する。また、更新ログ格納処理部３は、通番表６（図４参照）の登録済通番を更新する。
【００４７】
次に、図７に示すように、フロントシステム１００において、更新ログ送信部７は、一定間隔で、更新ログ格納表４を監視し、更新ログ格納表４に未処理（処理済通番＋１）の更新ログが存在しているかどうかを判定する（ステップＡ１）。
【００４８】
ステップＡ１の判定の結果、未処理の更新ログが存在していない場合は、更新ログ送信部７は待機状態となる。一方、ステップＡ１の判定の結果、未処理の更新ログが存在している場合は、更新ログ送信部７は、未処理の更新ログを読み込み、更新ログ電文を作成する（ステップＡ２）。
【００４９】
具体的には、ステップＡ２では、更新ログ送信部７は、図８に示すように、通番表６から処理済通番を特定する。そして、更新ログ送信部７は、更新ログ格納表４（図３参照）から、特定した処理済通番に１を加算した値以上の通番が付与され、且つ、ファイル転送対象が対象外に設定された更新ログを一定数分読み出す。
【００５０】
そして、更新ログ送信部７は、読み出した一定数分の更新ログを用いて、図１０に示す更新ログ電文を作成する。図１０に示すように、更新ログ電文には、一定数分の更新ログそれぞれ毎に、通番、サイズ、更新ログ自体が含まれている。なお、本実施の形態では、「一定数」は、予めフロントシステム１００の管理者によって固定値として設定されている。
【００５１】
次に、更新ログ送信部７は、ステップＡ２で作成した更新ログ電文を、バックアップシステム２００の更新ログ受信部１３に送信する（ステップＡ３）。そして、更新ログ送信部７は、送信後に、通番表６の処理済通番を一定数分だけインクリメントする（ステップＡ４）。
【００５２】
その後、更新ログ送信部７は、送信済の更新ログを、更新ログ格納表４から削除する（ステップＡ５）。ステップＡ５の実行後は、更新ログ送信部７は、再度、ステップＡ１を実行する。
【００５３】
バックアップシステム：
また、ステップＡ１〜Ａ５が実行されると、図８及び図９に示すように、バックアップシステム２００においては、更新ログ受信部１３は、更新ログを受信する。そして、更新ログ受信部１３は、受信した更新ログを、メモリＤＢ３０ｂ上の更新ログ格納表１４に格納し、通番表１５（図４参照）の登録済通番を更新する。
【００５４】
その後、更新ログ反映部１６は、一定間隔で更新ログ格納表１４を監視し、更新ログ格納表１４から未処理の更新ログ（通番＝処理済通番＋１）を読み込み、読み込んだ更新ログの内容をユーザ表１７に反映する。また、更新ログ反映部１６は、通番表１５（図４参照）の処理済通番を更新する。
【００５５】
［システム動作：更新ログ退避処理］
次に、図１１〜図１７を用いて、更新ログ滞留時におけるレプリケーションシステム３００の更新ログ退避処理について説明する。
【００５６】
フロントシステム：
図１１は、本発明の実施の形態におけるフロントシステム（業務処理システム）の更新ログ退避処理時の動作を示すフロー図である。図１２は、更新ログ滞留時におけるレプリケーションシステムの処理の流れを示す説明図である。図１３は、更新ログ滞留時におけるレプリケーションシステムの更新ログの流れを示す説明図である。図１４は、本実施の形態で作成される更新ログファイルの一例を示す図である。図１５は、本実施の形態で用いられるファイル転送通知電文の一例を示す図である。
【００５７】
まず、図１２及び図１３に示すように、通常時の状態から業務処理が増加し、更新ログの滞留数が増加しているとする。
【００５８】
図１１に示すように、更新ログ退避部５は、一定間隔で通番表６（図４参照）の登録済通番と処理済通番とを参照して、更新ログの滞留数（＝登録済通番−処理済通番）を算出し、滞留数が滞留閾値（図５参照）以上となっているかどうかを判定する（ステップＢ１）。
【００５９】
ステップＢ１の判定の結果、滞留数が滞留閾値以上となっていない場合は、更新ログ退避部５は、待機状態となる。一方、ステップＢ１の判定の結果、滞留数が滞留閾値以上となっている場合は、更新ログ退避部５は、更新ログ格納表４（図３参照）の現時点の処理済通番に１を加算した値（処理済通番＋１）の通番から登録済通番までの更新ログについて、ファイル転送対象を「対象」に変更する（ステップＢ２）。
【００６０】
次に、更新ログ退避部５は、更新ログ格納表４にファイル転送対象が「対象」に設定された更新ログが存在するかどうかを判定する（ステップＢ３）。
【００６１】
ステップＢ３の判定の結果、更新ログ格納表４にファイル転送対象が「対象」に設定された更新ログが存在する場合は、更新ログ退避部５は、更新ログ格納表４から、ロット数１０を取得する。そして、更新ログ退避部５は、ロット数分の更新ログを一つのファイルにまとめ、これを更新ログファイル１１とし、この更新ログファイル１１をディスク装置４０ａへ格納する（ステップＢ４）。
【００６２】
本実施の形態では、更新ログファイル１１は、図１４に示すように、ロット数分の更新ファイルの、通番、サイズ、更新ログ自体で構成されている。また、更新ログファイル１１のファイル名は、開始通番と終了通番とで作成されている。
【００６３】
また、ステップＢ４では、更新ログ格納表４において、ファイル転送対象が「対象」の更新ログがロット数未満である場合は、更新ログ退避部５は、更新ログ格納表４に存在する未処理の更新ログ全てを用いて、更新ログファイル１１を作成する。また、更新ログ退避部５は、更新ログファイル１１の作成の際、更新ログ格納表４から、未処理の最も通番が若い更新ログから順に取り出し、更新ログファイル１１に登録する。
【００６４】
次に、更新ログ退避部５は、ロット数分の更新ログを更新ログファイル１１に退避させると、更新ログ格納表４から退避させた更新ログを削除する（ステップＢ５）。
【００６５】
次に、更新ログ退避部５は、ディスク装置４０ａ上に退避した更新ログファイル１１を、ＦＴＰなどのファイル転送を実行して、バックアップシステム２００側のディスク装置４０ｂへと転送する（ステップＢ６）。次に、ファイル転送後、更新ログ退避部５は、ディスク装置４０ａ上の更新ログファイル１１を削除する（ステップＢ７）。
【００６６】
更新ログ退避部５は、この更新ログの退避、ファイル転送の一連の処理（ステップＢ４〜Ｂ７）を、更新ログ格納表４において、ファイル転送対象が「対象」の更新ログがある限り繰り返し実行する。
【００６７】
また、上述のステップＢ３の判定の結果、更新ログ格納表４にファイル転送対象が「対象」に設定された更新ログが存在しない場合は、更新ログ退避部５は、退避させた最後の更新ログの通番が処理済通番よりも大きいかどうかを判定する（ステップＢ８）。
【００６８】
ステップＢ８の判定の結果、退避させた最後の更新ログの通番が処理済通番よりも大きい場合は、更新ログ退避部５は、通番表６の処理済通番を更新する（ステップＢ９）。その後、更新ログ退避部５は、ステップＢ１０を実行する。
【００６９】
一方、ステップＢ８の判定の結果、退避させた最後の更新ログの通番が処理済通番よりも大きくない場合は、既に、更新ログ送信部７によって処理済通番が更新されていて、処理済通番は、更新ログファイル１１の最後の更新ログの通番以上となっている。よって、更新ログ退避部５は、この場合は更新せず、ステップＢ１０を実行する。
【００７０】
ステップＢ１０では、更新ログ退避部５は、図１５に示すファイル転送通知電文によって、更新ログ受信部１３に対して、ファイル転送対象が「対象」となっている更新ログの最初の通番を開始通番とし、最後の通番を終了通番として通知する。その後、更新ログ退避部５は、再度ステップＢ１を実行する。
【００７１】
また、本実施の形態では、ステップＢ１〜Ｂ１０が実行されている間（ファイル転送が実行されている）間、この処理と並行して、更新ログ送信部７は、以下の処理を実行する。まず、更新ログ送信部７は、更新ログ格納表４から、ファイル転送対象が「対象外」となっている、一定数分の更新ログを読み込み、バックアップシステム２００の更新ログ受信部１３に、電文によって一定数分の更新ログを転送する。
【００７２】
次に、更新ログ送信部７は、転送終了後、通番表６の処理済通番を、一定数分だけインクリメントする。なお、「一定数」は、上述のステップＡ２の場合と同様に、予めフロントシステム１００の管理者によって固定値として設定されている。
【００７３】
バックアップシステム：
図１６は、本発明の実施の形態におけるバックアップシステムの更新ログ受信処理時の動作を示すフロー図である。図１７は、本発明の実施の形態におけるバックアップシステムの更新ログ反映処理時の動作を示すフロー図である。
【００７４】
上述の図１１に示すステップＢ１〜Ｂ１０が実行されると、バックアップシステムでは、図１６に示す更新ログ受信処理と、図１７に示す更新ログ反映処理とが実行される。以下に、これらの処理について説明する。
【００７５】
図１６に示すように、更新ログ受信部１３は、フロントシステム１００の更新ログ送信部７から、更新ログ電文を受信しているかどうかを判定する（ステップＣ１）。
【００７６】
ステップＣ１の判定の結果、更新ログ電文を受信している場合は、更新ログ受信部１３は、それに含まれる更新ログの通番が、メモリＤＢ３０ｂ上の開始通番１９以上、終了通番２０以下であるかどうかを判定する（ステップＣ２）。
【００７７】
ステップＣ２の判定の結果、更新ログの通番が、既に受信しているファイル転送通知の開始通番１９以上、終了通番２０以下である場合は、既に更新ログをファイル転送通知によって受信しているので、更新ログ受信部１３は、待機状態となる。
【００７８】
一方、ステップＣ２の結果、更新ログの通番が、既に受信しているファイル転送通知の開始通番１９以上、終了通番２０以下でない場合は、更新ログ受信部１３は、受信した更新ログ電文に含まれる更新ログを、メモリＤＢ３０ｂの更新ログ格納表１４に格納する（ステップＣ３）。
【００７９】
次に、ステップＣ３の実行後、更新ログ受信部１３は、更新ログの通番が、メモリＤＢ３０ｂ上の終了通番２０より大きいかどうかを判定する（ステップＣ４）。ステップＣ４の判定の結果、更新ログの通番が、終了通番２０より大きい場合は、更新ログ受信部１３は、その更新ログの通番で、通番表１５の登録済通番を更新する（ステップＣ５）。その後、更新ログ受信部１３は、再度、ステップＣ１を実行する。
【００８０】
一方、ステップＣ４の判定の結果、更新ログの通番が、終了通番２０より大きくない（終了通番２０以下）である場合は、更新ログ受信部１３は、更新ログの通番が、開始通番１９から１を減算した値（開始通番−１）となっているかどうかを判定する（ステップＣ６）。
【００８１】
ステップＣ６の判定の結果、更新ログの通番が開始通番１９から１を減算した値となっていない場合は、更新ログ受信部１３は、再度ステップＣ５を実行する。一方、ステップＣ６の判定の結果、更新ログの通番が開始通番から１を減算した値となっている場合は、更新ログ受信部１３は、メモリＤＢ３０ｂ上の終了通番２０の値で、通番表１５の登録済通番を更新する（ステップＣ７）。その後、更新ログ受信部１３は、再度、ステップＣ１を実行する。
【００８２】
また、上述のステップＣ１の判定の結果、更新ログ電文を受信していない場合は、更新ログ受信部１３は、フロントシステム１００の更新ログ退避部５からファイル転送通知電文を受信したかどうかを判定する（ステップＣ８）。
【００８３】
ステップＣ８の判定の結果、ファイル転送通知電文を受信していない場合は、更新ログ受信部１３は待機状態となる。一方、ステップＣ８の結果、ファイル転送通知電文を受信している場合は、更新ログ受信部１３は、受信したメモリＤＢ３０ｂ上の開始通番と終了通番とを更新する（ステップＣ９）。
【００８４】
次に、更新ログ受信部１３は、メモリＤＢ３０ｂ上の更新ログ格納表１４に、開始通番１９から１を減算した値（開始通番−１）が通番となった更新ログが存在しているかどうかを判定する（ステップＣ１０）。
【００８５】
ステップＣ１０の判定の結果、開始通番１９から１を減算した値が通番となった更新ログが存在してない場合は、更新ログ受信部１３は、再度、ステップＣ１を実行する。
【００８６】
一方、ステップＣ１０の判定の結果、開始通番１９から１を減算した値が通番となった更新ログが存在している場合は、更新ログ受信部１３は、更新ログ格納表１４（図６参照）において、通番が開始通番１９から１を減算した値となっている更新ログの終端フラグを「ＹＥＳ」とする（ステップＣ１１）。その後、更新ログ受信部１３は、再度、ステップＣ１を実行する。
【００８７】
以上のステップＣ１〜Ｃ１１により、バックアップシステム２００において、更新ログが更新される。
【００８８】
また、図１７に示すように、最初に、更新ログ反映部１６は、メモリＤＢ３０ｂ上の通番表１５（図４参照）を参照し、登録済通番が処理済通番よりも大きいかどうかを判定する（ステップＤ１）。
【００８９】
ステップＤ１の判定の結果、登録済通番が処理済通番よりも大きくない（処理済通番以下である）場合は、更新ログ反映部１６は、待機状態となる。一方、ステップＤ１の判定の結果、登録済通番が処理済通番よりも大きい場合は、更新ログ反映部１６は、メモリＤＢ３０ｂ上の更新ログ格納表１４を参照し、処理済通番に１を加算した値の通番を持った更新ログが存在しているかどうかを判定する（ステップＤ２）。
【００９０】
ステップＤ２の判定の結果、処理済通番に１を加算した値の通番を持った更新ログが存在していない場合は、更新ログ反映部１６は、後述のステップＤ８を実行する。
【００９１】
一方、ステップＤ２の判定の結果、処理済通番に１を加算した値の通番を持った更新ログが存在している場合は、更新ログ反映部１６は、処理済通番に１を加算した値の通番から、一定数分の更新ログを読み込む（ステップＤ３）。そして、更新ログ反映部１６は、読み込んだ更新ログを、ユーザ表１７に反映する（ステップＤ４）。なお、本実施の形態では、一定数は固定値として予め設定されている。
【００９２】
ステップＤ４の実行後、更新ログ反映部１６は、通番表１５の処理済通番を更新し（ステップＤ５）、更に、更新ログ格納表１４から、処理済通番以下の更新ログを削除する（ステップＤ６）。
【００９３】
次に、更新ログ反映部１６は、更新ログ格納表１４に、終端フラグがＹＥＳとなった更新ログ、又は処理済通番に１を加算した値の通番を持った更新ログが存在しているかどうかを判定する（ステップＤ７）。
【００９４】
ステップＤ７の判定の結果、いずれかの更新ログが存在していない場合は、更新ログ反映部１６は、再度ステップＤ１を実行する。
【００９５】
一方、ステップＤ７の判定の結果、いずれかの更新ログが存在している場合は、更新ログ反映部１６は、ディスク装置４０ｂ上に、処理済通番に１を加算した値の通番が開始通番以上終了通番以下となる、更新ログファイル１１が存在しているかどうかを判定する（ステップＤ８）。
【００９６】
ステップＤ８の判定の結果、上述の更新ログファイル１１が存在していない場合は、更新ログ反映部１６は、再度ステップＤ１を実行する。
【００９７】
一方、ステップＤ８の判定の結果、上述の更新ログファイル１１が存在している場合は、更新ログ反映部１６は、更に、処理済通番が終了通番２０より小さいかどうかを判定する（ステップＤ９）。
【００９８】
ステップＤ９の判定の結果、処理済通番が終了通番２０より小さい場合は、更新ログ反映部１６は、ディスク装置４０ｂ上の更新ログファイル１１から、一定数分の更新ログを読み込む（ステップＤ１０）。なお、この場合の、一定数も、上述のステップＤ３と同様に、固定値として予め設定されている。
【００９９】
次に、更新ログ反映部１６は、読み込んだ一定数分の更新ログを、ユーザ表１７に反映し（ステップＤ１１）、通番表１５の処理済通番を更新する（ステップＤ１２）。その後、更新ログ反映部１６は、再度ステップＤ９を実行する。ステップＤ９〜Ｄ１２は、処理済通番が終了通番より小さい限り、繰り返し実行され、更新ログファイル１１の内容がユーザ表に反映される。
【０１００】
また、上述のステップＤ９の判定の結果、処理済通番が処理通番２０より小さくない（終了通番２０以上）である場合は、更新ログ反映部１６は、ディスク装置４０ｂ上にある更新ログファイル１１を処理済ファイルとして削除する（ステップＤ１３）。その後、更新ログ反映部１６は、再度ステップＤ１を実行する。
【０１０１】
以上のステップＤ１〜Ｄ１３により、バックアップシステム２００において、更新ログの内容が、ユーザ表に反映され、フロントシステム１００のレプリケーションが完了する。
【０１０２】
［本実施の形態における効果］
以上のように本実施の形態では、更新ログは、読み出し速度及び書き込み速度の速いメモリＤＢに格納されるので、更新ログの高速転送が実現される。そして、障害の発生、業務処理の一時的な増加等によって更新ログが滞留した場合は、更新ログは、更新ログファイルとして、ディスク装置に一旦格納された後、バックアップシステムへと転送される。このため、更新ログが溢れてしまう事態の発生が回避され、上述の場合であっても、確実にレプリケーションが実行される。
【０１０３】
またフロントシステム１００のメモリＤＢから転送されてきた更新ログと、ファイル転送によって転送されてきた更新ログとは、発生順に付与された通番によって管理されている。従って、更新ログが重複して転送された場合であっても、バックアップシステム２００において、順序性が保証された状態で、メモリＤＢへ反映されるので、レプリケーションが実現する。
【０１０４】
［変形例］
上述の実施の形態では、フロントシステム１００は、設定部８によって、滞留閾値９及びロット数１０の値を設定している。しかし、本実施の形態は、これに限定されず、フロントシステム１００において、滞留閾値９及びロット数１０のデフォルト値が予め設定されており、フロントシステム１００は、設定部８を備えていない構成であっても良い。
【０１０５】
また、本実施の形態では、複数のフロントシステム１００に対して、一つのバックアップシステム２００が対応している態様であっても良い。この態様では、処理の停滞を防止するため、バックアップシステム２００における各記憶装置の読み出し速度及び書き込み速度は、各フロントシステム１００における対応する記憶装置の読み出し速度及び書き込み速度よりも高いのが好ましい。
【０１０６】
［プログラム］
本実施の形態におけるプログラムは、コンピュータに、図７に示すステップＡ１〜Ａ５、図１１に示すステップＢ１〜Ｂ１０を実行させるプログラムであれば良い。このプログラムをコンピュータにインストールし、実行することによって、本実施の形態におけるフロントシステムとレプリケーション方法とを実現することができる。この場合、コンピュータのＣＰＵ（Central Processing Unit）は、更新ログ退避部５、及び更新ログ送信部７として機能し、処理を行なう。
【０１０７】
ここで、本実施の形態におけるプログラムを実行することによって、フロントシステム１００を実現するコンピュータについて図１８を用いて説明する。図１８は、本発明の実施の形態におけるフロントシステム（業務処理システム）を実現するコンピュータの一例を示すブロック図である。
【０１０８】
図１８に示すように、コンピュータ１１０は、ＣＰＵ１１１と、メインメモリ１１２と、記憶装置１１３と、入力インターフェイス１１４と、表示コントローラ１１５と、データリーダ／ライタ１１６と、通信インターフェイス１１７とを備える。これらの各部は、バス１２１を介して、互いにデータ通信可能に接続される。
【０１０９】
ＣＰＵ１１１は、記憶装置１１３に格納された、本実施の形態におけるプログラム（コード）をメインメモリ１１２に展開し、これらを所定順序で実行することにより、各種の演算を実施する。メインメモリ１１２は、典型的には、ＤＲＡＭ（Dynamic Random Access Memory）等の揮発性の記憶装置である。また、本実施の形態におけるプログラムは、コンピュータ読み取り可能な記録媒体１２０に格納された状態で提供される。なお、本実施の形態におけるプログラムは、通信インターフェイス１１７を介して接続されたインターネット上で流通するものであっても良い。
【０１１０】
また、記憶装置１１３の具体例としては、ハードディスクドライブの他、フラッシュメモリ等の半導体記憶装置が挙げられる。入力インターフェイス１１４は、ＣＰＵ１１１と、キーボード及びマウスといった入力機器１１８との間のデータ伝送を仲介する。表示コントローラ１１５は、ディスプレイ装置１１９と接続され、ディスプレイ装置１１９での表示を制御する。
【０１１１】
データリーダ／ライタ１１６は、ＣＰＵ１１１と記録媒体１２０との間のデータ伝送を仲介し、記録媒体１２０からのプログラムの読み出し、及びコンピュータ１１０における処理結果の記録媒体１２０への書き込みを実行する。通信インターフェイス１１７は、ＣＰＵ１１１と、他のコンピュータとの間のデータ伝送を仲介する。
【０１１２】
また、記録媒体１２０の具体例としては、ＣＦ（Compact Flash（登録商標））及びＳＤ（Secure Digital）等の汎用的な半導体記憶デバイス、フレキシブルディスク（Flexible Disk）等の磁気記憶媒体、又はＣＤ−ＲＯＭ（Compact Disk Read Only Memory）などの光学記憶媒体が挙げられる。
【０１１３】
上述した実施の形態の一部又は全部は、以下に記載する（付記１）〜（付記１４）によって表現することができるが、以下の記載に限定されるものではない。
【０１１４】
（付記１）
業務処理を実行するための業務処理システムと、前記業務処理システムをバックアップするためのバックアップシステムとを備え、
前記業務処理システムは、
更新対象となるデータと前記データの更新ログとを格納する、第１の記憶装置と、
前記第１の記憶装置よりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい、第２の記憶装置と、
前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、更新ログ送信部と、
設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを前記第２の記憶装置に一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、更新ログ退避部と、
を備えている、ことを特徴とするレプリケーションシステム。
【０１１５】
（付記２）
前記設定条件が、前記バックアップシステムへの送信が終了していない更新ログの数が閾値を超えていることである、
付記１に記載のレプリケーションシステム。
【０１１６】
（付記３）
前記バックアップシステムが、
前記更新対象となるデータのバックアップデータと、前記更新ログ送信部によって送信されてきた前記更新ログとを格納する、第３の記憶装置と、
前記更新ログ退避部によって送信されてきた前記更新ログファイルを格納する、第４の記憶装置と、
前記第４の記憶装置に前記更新ログファイルが格納されていない場合に、前記第３の記憶装置に格納されている前記更新ログに基づいて、前記バックアップデータを更新し、前記第４の記憶装置に前記更新ログファイルが格納されている場合に、前記更新ログファイルに基づいて、前記バックアップデータを更新する、更新ログ反映部と、
を備えている、付記１または２に記載のレプリケーションシステム。
【０１１７】
（付記４）
前記更新ログに対し、発生した順に通番が付与されており、前記第１の記憶装置が、前記更新ログと共に、前記バックアップシステムへの送信が完了した更新ログの通番と前記バックアップシステムへの送信が完了していない更新ログの通番とを特定する通番情報を格納し、
前記更新ログ送信部は、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを前記バックアップシステムに送信し、
前記更新ログ退避部は、設定条件が満たされる場合に、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを用いて、前記更新ログファイルを作成する、
付記１〜３のいずれかに記載のレプリケーションシステム。
【０１１８】
（付記５）
バックアップシステムと連携してレプリケーションを実行する業務処理システムであって、
更新対象となるデータと前記データの更新ログとを格納する、第１の記憶装置と、
前記第１の記憶装置よりも、読み出し速度及び書き込み速度は低いが、記憶容量が大きい、第２の記憶装置と、
前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、更新ログ送信部と、
設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを前記第２の記憶装置に一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、更新ログ退避部と、
を備えている、ことを特徴とする業務処理システム。
【０１１９】
（付記６）
前記設定条件が、前記バックアップシステムへの送信が終了していない更新ログの数が閾値を超えていることである、
付記５に記載の業務処理システム。
【０１２０】
（付記７）
前記更新ログに対し、発生した順に通番が付与されており、前記第１の記憶装置が、前記更新ログと共に、前記バックアップシステムへの送信が完了した更新ログの通番と前記バックアップシステムへの送信が完了していない更新ログの通番とを特定する通番情報を格納し、
前記更新ログ送信部は、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを前記バックアップシステムに送信し、
前記更新ログ退避部は、設定条件が満たされる場合に、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを用いて、前記更新ログファイルを作成する、
付記５または６に記載の業務処理システム。
【０１２１】
（付記８）
業務処理を実行するための業務処理システムと、前記業務処理システムをバックアップするためのバックアップシステムとを用いたレプリケーション方法であって、
（ａ）前記業務処理システムにおいて、更新対象となるデータと前記データの更新ログとを、第１の記憶装置に格納するステップと、
（ｂ）前記業務処理システムにおいて、前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、ステップと、
（ｃ）前記業務処理システムにおいて、設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを、前記第１の記憶装置よりも読み出し速度及び書き込み速度は低いが記憶容量は大きい前記第２の記憶装置に、一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、ステップと、
を有する、ことを特徴とするレプリケーション方法。
【０１２２】
（付記９）
前記設定条件が、前記バックアップシステムへの送信が終了していない更新ログの数が閾値を超えていることである、
付記８に記載のレプリケーション方法。
【０１２３】
（付記１０）
（ｄ）前記バックアップシステムにおいて、前記更新対象となるデータのバックアップデータと、前記更新ログ送信部によって送信されてきた前記更新ログとを、第３の記憶装置に格納する、ステップと、
（ｅ）前記バックアップシステムにおいて、前記（ｂ）のステップで送信されてきた前記更新ログファイルを、第４の記憶装置に格納する、ステップと、
（ｆ）前記第４の記憶装置に前記更新ログファイルが格納されていない場合に、前記第３の記憶装置に格納されている前記更新ログに基づいて、前記バックアップデータを更新する、ステップと、
（ｅ）前記第４の記憶装置に前記更新ログファイルが格納されている場合に、前記更新ログファイルに基づいて、前記バックアップデータを更新する、ステップと、
を更に有する、付記８または９に記載のレプリケーション方法。
【０１２４】
（付記１１）
前記更新ログに対し、発生した順に通番が付与されており、前記（ａ）のステップにおいて、前記第１の記憶装置が、前記更新ログと共に、前記バックアップシステムへの送信が完了した更新ログの通番と前記バックアップシステムへの送信が完了していない更新ログの通番とを特定する通番情報を格納し、
前記（ｂ）のステップにおいて、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを前記バックアップシステムに送信し、
前記（ｃ）のステップにおいて、設定条件が満たされる場合に、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを用いて、前記更新ログファイルを作成する、
付記８〜１０のいずれかに記載のレプリケーション方法。
【０１２５】
（付記１２）
コンピュータに、バックアップシステムとの連携によるレプリケーションを実行させるためのプログラムであって、
前記コンピュータに、
（ａ）更新対象となるデータと前記データの更新ログとを、前記コンピュータが備える第１の記憶装置に格納するステップと、
（ｂ）前記第１の記憶装置に格納されている更新ログを、前記バックアップシステムに送信する、ステップと、
（ｃ）設定条件が満たされる場合に、前記第１の記憶装置に格納されている複数の更新ログを含む更新ログファイルを作成し、作成した前記更新ログファイルを、前記コンピュータに備えられ、且つ前記第１の記憶装置よりも読み出し速度及び書き込み速度は低いが記憶容量は大きい前記第２の記憶装置に、一旦格納した後、格納した前記更新ログファイルを前記バックアップシステムに送信する、ステップと、
を実行させるプログラム。
【０１２６】
（付記１３）
前記設定条件が、前記バックアップシステムへの送信が終了していない更新ログの数が閾値を超えていることである、
付記１２に記載のプログラム。
【０１２７】
（付記１４）
前記更新ログに対し、発生した順に通番が付与されており、前記（ａ）のステップにおいて、前記第１の記憶装置が、前記更新ログと共に、前記バックアップシステムへの送信が完了した更新ログの通番と前記バックアップシステムへの送信が完了していない更新ログの通番とを特定する通番情報を格納し、
前記（ｂ）のステップにおいて、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを前記バックアップシステムに送信し、
前記（ｃ）のステップにおいて、設定条件が満たされる場合に、前記通番情報に基づいて、前記バックアップシステムへの送信が完了していない更新ログを特定し、特定した更新ログを用いて、前記更新ログファイルを作成する、
付記１２または１３に記載のプログラム。
【産業上の利用可能性】
【０１２８】
以上のように、本発明によれば、更新ログの高速転送を実現しつつ、障害発生時等によって更新ログが急激に滞留した場合であっても確実にレプリケーションを実行することができる。本発明は、レプリケーションが必要な種々のシステムに有効である。
【符号の説明】
【０１２９】
１  アプリケーションプログラム
２  ユーザ表
３  更新ログ格納処理部
４  更新ログ格納表
５  更新ログ退避部
６  通番表
７  更新ログ送信部
８  設定部
９  滞留閾値
１０  ロット数
１１  更新ログファイル
１３  更新ログ受信部
１４  更新ログ格納表
１５  通番表
１６  更新ログ反映部
１７  ユーザ表
１９  開始通番
２０  終了通番
３０ａ  メモリＤＢ（フロントシステム）
３０ｂ  メモリＤＢ（バックアップシステム）
４０ａ  ディスク装置（フロントシステム）
４０ｂ  ディスク装置（バックアップシステム）
１００  フロントシステム
１１０  コンピュータ
１１１  ＣＰＵ
１１２  メインメモリ
１１３  記憶装置
１１４  入力インターフェイス
１１５  表示コントローラ
１１６  データリーダ／ライタ
１１７  通信インターフェイス
１１８  入力機器
１１９  ディスプレイ装置
１２０  記録媒体
１２１  バス
２００  バックアップシステム
３００  レプリケーションシステム
【図１】
2014170448.tif 000003
【図２】
2014170448.tif 000004
【図３】
2014170448.tif 000005
【図４】
2014170448.tif 000006
【図５】
2014170448.tif 000007
【図６】
2014170448.tif 000008
【図７】
2014170448.tif 000009
【図８】
2014170448.tif 000010
【図９】
2014170448.tif 000011
【図１０】
2014170448.tif 000012
【図１１】
2014170448.tif 000013
【図１２】
2014170448.tif 000014
【図１３】
2014170448.tif 000015
【図１４】
2014170448.tif 000016
【図１５】
2014170448.tif 000017
【図１６】
2014170448.tif 000018
【図１７】
2014170448.tif 000019
【図１８】
2014170448.tif 000020