トップ :: G 物理学 :: G06 計算;計数




【発明の名称】 センターカット処理方式
【発明者】 【氏名】浅野 郁久
【要約】 【課題】先の入力データファイルに、追加の入力データファイルがあっても、全体の処理時間の延長を極力抑制したセンターカット処理方式を提供する。

【解決手段】入力済みの複数の処理対象データに加え、新規に処理対象データを格納可能なファイルを複数備えてなる入力データファイル群格納手段４と、入力データファイル群格納手段中から入力データファイルを選択し、自己以外の他の処理管理手段による前記選択した入力データファイルの参照を禁止すると共に、該選択した入力データファイル以外の参照を許可する処理管理手段（ＡＰブローカ）3-1，3-2と、処理管理手段からの選択した入力データファイルの指定に対応して入力データファイル群格納手段中の入力データファイルを処理する処理実行手段（ＡＰ処理サーバ）6-1，6-2とを備えた。
【特許請求の範囲】
【請求項１】 入力済みの複数の処理対象データに加え、新規に処理対象データを格納可能なファイルを複数備えてなる入力データファイル群格納手段と、該入力データファイル群格納手段中から入力データファイルを選択し、自己以外の他の処理管理手段による前記選択した入力データファイルの参照を禁止すると共に、該選択した入力データファイル以外の参照を許可する処理管理手段と、該処理管理手段からの選択した入力データファイルの指定に対応して前記入力データファイル群格納手段中の入力データファイルを処理する処理実行手段とを備えたことを特徴とするセンターカット処理方式。
【請求項２】 前記処理管理手段は、前記入力データファイル群格納手段中の処理対象となる入力データファイルの選択を行う時点における、該入力ファイルデータ中で未処理件数最大の入力データファイルを選択し、該入力データファイル中の一回の要求で処理する件数を指定する手段を備え、前記処理実行手段は、前記処理管理手段からの未処理件数最大の入力データファイルおよび一回の処理要求件数の指定に対応して、前記入力データファイルを処理する手段を備えたことを特徴とする請求項１記載のセンターカット処理。
【請求項３】 前記センターカット処理方式を、電子商取引に適用することを特徴とする請求項１または請求項２記載のセンターカット処理方式。
【発明の詳細な説明】【０００１】
【発明の属する技術分野】本発明は、センターカット処理方式に関し、特に先の入力データファイルに対して、新たな追加の入力データファイルを加えても、全体の処理時間が長くならないようにしたセンターカット処理方式に関する。
【０００２】
【従来の技術】例えばバンキングシステムにおいて、一度に大量の入力データを処理する場合に、オンライン処理（オンライントランザクション処理）であれば随時発生する要求に対し発生順に処理を行っている（図７（A）参照）。これに対してセンターカット処理方式では、要求と要求に付随するデータを入力データファイルとして保存し、システム全体での負荷分散のためにオンラインでの処理量が少ない時間などに入力データの処理を行っている。ここに、センターカット処理方式とは、オンライントランザクション処理と同じトランザクションモニタ，アプリケーションを利用し、入力データとしてクライアントからの受信データではなく、ファイルデータを用いて、一度に大量のトランザクション処理を行う仕掛けをいう。
【０００３】従来のセンターカット処理方式では、入力データファイル群に含まれる入力データファイルを未処理件数の多い順にソートを行い、ソート結果に従い処理対象を選択したり、或いは予め決められた処理計画に沿って処理を行っている（図７（B）参照）。
【０００４】
【発明が解決しようとする課題】しかしながら、従来のセンターカット処理方式は、一度に大量の入力データを扱うためオンライン処理方式に比べ処理の効率は上がるものの、入力データファイル群に対し新たに入力データファイルを追加した場合、追加された入力データファイルの処理が、追加以前の入力データファイル群の処理終了後に行われていた（図８（Ａ）参照）。そのため追加された入力データファイルに含まれるデータの件数分だけ処理時間が伸びてしまうという問題点があった（図８（Ｂ）参照）。また、予め決めた処理計画を再生成する必要があるという問題点があった。
【０００５】そこで本発明の課題は、先の入力データファイルに、新たな追加の入力データファイルが加わった場合であっても、全体の処理時間の延長を極力抑制したセンターカット処理方式を提供することである。
【０００６】
【課題を解決するための手段】前記課題を解決するために本発明は、入力済みの複数の処理対象データに加え、新規に処理対象データを格納可能なファイルを複数備えてなる入力データファイル群格納手段と、該入力データファイル群格納手段中から入力データファイルを選択し、自己以外の他の処理管理手段（ＡＰブローカ）による前記選択した入力データファイルの参照を禁止すると共に、該選択した入力データファイル以外の参照を許可する処理管理手段（ＡＰブローカ）と、該処理管理手段からの選択した入力データファイルの指定に対応して前記入力データファイル群格納手段中の入力データファイルを処理する処理実行手段（ＡＰ処理サーバ）とを備えたことを特徴とする。
【０００７】このようにすれば、例えば図４に示すように、先の入力データファイルに対して追加の入力データファイルがあった場合に、先の入力データファイルと追加の入力データファイルとを平行処理することが可能となるので、入力データファイルのトータルの処理時間を短縮することが可能となる。
【０００８】
【発明の実施の形態】（１）本発明の概要説明先ず、図３を参照しつつ本発明の概要を説明する。本発明は、複数のデータファイルの処理を行うセンターカットにおいて処理時間を短縮することを目的とする。
【０００９】図１〜図３において、先の入力データファイル群に対して追加の入力データファイルがある場合を想定する（ステップＳ１）。第１，第２のＡＰブローカ3-1，3-2の何れかが第１，第２のＡＰ処理サーバ6-1，6-2の何れかに対し処理を要求する際、入力データファイル群４より処理対象となる入力データファイルの選択を行う。この際、ＡＰブローカが処理対象を選択する際に、選択を行う時点で入力データファイル群から最も未処理件数の多い入力データファイルを選択し処理対象とする（ステップＳ２）。次いで処理対象とした入力データファイルへの参照を禁止すると共に（ステップＳ３）、選択した処理対象以外の入力データファイルの参照を許可しステップＳ１に戻る（ステップＳ４）。
【００１０】ＡＰ処理サーバ6-1，6-2ではＡＰブローカ3-1，3-2からの一回の要求で入力データファイルに含まれる全ての未処理データを処理せず、要求の際に指定された件数分のデータを処理し（ステップＳ５）、処理終了をＡＰブローカに報告（応答）する（ステップＳ６）と共に、ステップＳで禁止した参照を解除し（ステップＳ７）、ステップＳ１に戻る。再びＡＰブローカではＡＰ処理サーバから処理完了の応答を受けると、入力データファイル群から、その時点で最も未処理件数の多い入力データファイルを選択し処理を行うようＡＰ処理サーバに要求を行う（ステップＳ１〜Ｓ２）。
【００１１】このようにして入力データファイル群に入力データファイル追加が行われた場合に、追加前の入力データファイル群の処理と平行して追加された入力データファイルの処理が行えるため、センターカットでの処理時間の短縮を行うことが可能となる（図４参照）。
【００１２】（２）実施例の説明以下、本発明のセンターカット処理方式を図示の実施例に基づいて説明する。
（2‐1）実施例の構成図1を参照すると、本実施例のセンターカット処理システムＳＳは、ブローカ管理プロセス１、「処理管理手段」である第１，第２のＡＰブローカ3-1，3-2、「処理実行手段」である第１，第２のＡＰ処理サーバ6-1，6-2、データ登録コマンド８と、動作情報ファイル２、入力データファイル群４、処理件数データファイル５、出力データファイル７から構成される。
【００１３】ブローカ管理プロセス１は、ＡＰブローカ動作情報ファイル２のブローカ同時実行数（ＡＰブローカを同時に幾つ立ち上げるかを指定）に従い、第１，第２のＡＰブローカ3-1，3-2の起動を行う。即ち、ブローカ管理プロセス１のシステムの動作中にブローカ同時実行数が変更された場合に、値が増加した場合には増加分の第１，第２のＡＰブローカ3-1，3-2を起動し、値が減少した場合には減少分の第１，第２のＡＰブローカ3-1，3-2を停止する。動作情報ファイル２は、一回当処理件数2-1、第１，第２のＡＰブローカ3-1，3-2が同時に実行可能なブローカ同時実行数2-2を含む。ここに、一回当処理件数とは、第１，第２のＡＰブローカ3-1，3-2が第１，第２のＡＰ処理サーバ6-1，6-2に対して入力データファイルの処理を要求した際に、第１，第２のＡＰ処理サーバ6-1，6-2では入力データファイルの全てのデータを処理するのではなく、指示した件数分のデータだけ処理することを期待する。この「指示した件数」が「一回当処理件数」である。
【００１４】入力データファイル群４は、入力データファイル4-a，4-b，4-c，4-dを含む。入力データファイルは図２に示す形式で、入力データファイルに含まれるデータ件数とデータを含む。処理件数データファイル５と出力データファイル群７は、入力データファイル群４の入力データファイル4-a，4-b，4-c，4-ｄに対応する件数データ5-a，5-b，5-c，5-ｄと、処理結果7-a，7-b，7-cをそれぞれ含む。
【００１５】第１，第２のＡＰブローカ3-1，3-2は入力データファイル群４，処理件数データファイル５を監視し、未処理のデータを含むデータファイルの存在を調査する。未処理のデータを含むデータファイルを発見した場合、発見したデータファイルのうち最も未処理件数の多いファイルを一つ決定する。次いで動作情報ファイル２の一回当りの処理件数を取得し、第１，第２のＡＰ処理サーバ6-1，6-2に対し未処理件数の多いファイルを一回当りの処理件数分だけ処理するよう要求する。第１，第２のＡＰ処理サーバ6-1，6-2から処理完了の応答が返却された後、処理件数データファイルを更新し、入力データファイル群４，処理件数データファイル５の監視を行う。
【００１６】第１，第２のＡＰ処理サーバ6-1，6-2は第１，第２のＡＰブローカ3-1，3-2から要求されたデータを、要求された件数分の処理を行う。処理を開始する件数は処理件数データファイル５を参照し、得られた件数の次から行う。処理を完了後、結果を出力データファイルへ記録する。その後、第１，第２のＡＰ処理サーバ6-1，6-2に対し要求を行った第１，第２のＡＰブローカに対し処理完了の応答を行う。データ登録コマンド８は、入力データファイル群４，処理件数データファイル５に対し、それぞれ新規データと対応する処理件数データを作成する。
【００１７】（2‐2）実施例の動作次に、図1，２，５，６を参照しつつ本実施例の全体の動作について詳細に説明する。図５はＡＰブローカの動作フローチャートであり、図６はＡＰ処理サーバの動作フローチャートである。
【００１８】図５に示すように、まず、ブローカ管理プロセス１が動作情報ファイル２を参照する。動作情報ファイル２よりブローカ同時実行数2-2の示す数値’２’を取得する。ブローカ同時実行数2-2に従い第１，第２のＡＰブローカ3-1，3-2を起動する（ステップＳ１１）。ブローカ管理プロセス１により起動された第１のＡＰブローカ3-1は、入力データファイル群４，処理件数データファイル５に対し、他のＡＰブローカ（この場合は第２のＡＰブローカ3-2）が参照しないように、これらのファイルに対してロックを行い、ロック完了後にファイルの参照を行う（排他的に参照を行う）（ステップＳ１２，Ｓ１３）。
【００１９】第１のＡＰブローカ3-1は入力データファイル群４の入力データファイル4-a，4-b，4-c，4-dのデータ件数と処理件数データファイルの処理件数データ5-a，5-b，5-c，5-dを参照し（ステップＳ１４）、「データ件数 - 処理件数」の演算により得られる未処理件数の最も多い入力データファイル4-cを選択する。例えば、「（入力データファイル4-aのデータ件数7168−処理件数データファイル5-aの処理件数3000＝4168）」に対し、「（入力データファイル4-cのデータ件数5120−処理件数データファイル5-cの処理件数200＝4920）」なので、未処理件数が最も多いのは、入力データファイル4-cである。
【００２０】選択した入力データファイル4-cに対し排他ロックを行い第２のＡＰブローカ3-2による参照が行われないようにする（ステップＳ１５）。入力データファイル4-cに対する排他ロックが完了後、入力データファイル群４，処理件数データファイル５に対するロックを解除する（ステップＳ１６）。このロック解除の結果、入力データファイル4-cのみがロックされた状態で、ステップＳ１１に戻りその他の入力データファイル4-a，4-b，4-dに対しては参照可能となる。従って、前記ステップＳ１１〜Ｓ１４の処理を繰り返し、入力データファイル4-cを除外した時点における最大未処理件数の入力データファイル4-aを選択することとなる。（段落番号００２５で後述）
【００２１】前記ステップＳ１６に続いて動作情報ファイル２を参照し、一回当処理件数2-1で示される値'10' を取得する（ステップＳ１７）。第１のＡＰブローカ3-1 はＡＰ処理サーバ6-1 に対し、残り件数の最も多いデータ4-cを一回当処理件数2-1で示される値'10'件で処理するよう要求を行う（ステップＳ１８）。第１のＡＰブローカ3-1 は第１のＡＰ処理サーバ6-1に対する入力データファイル4-cの処理要求後、第１のＡＰ処理サーバ 6-1より処理完了の応答を待つ（ステップＳ１９、次に説明する図６のステップＳ３６に示す「応答」を待つ）。
【００２２】図６に示すように、第１のＡＰブローカ3-1より要求「残り件数の最も多いデータ4-cを一回当処理件数2-1で示される値'10'件で処理する」を受けた第１のＡＰ処理サーバ6-1は、処理件数データファイル５ を参照する（ステップＳ３１〜Ｓ３３）。処理件数データファイル５より前記入力データ4-cに対応する処理件数5-cで示される値'200'を取得する（ステップＳ３３）。次に処理件数5-cで示される値'200'の次の値'201'件目のデータを入力データ4-cより取得し処理を行う（ステップＳ３４）。その後201件目から一回当処理件数2-1で示される値'10'件後の210件目データまで処理を行い、処理結果を出力データファイル７の処理結果7-cへ記録する（ステップＳ３５）。記録終了後処理完了の応答を第１のＡＰブローカ3-1へと返却する（ステップＳ３６）。
【００２３】図５に示すように、第１のＡＰブローカ3-1は第１のＡＰ処理サーバ6-1より処理完了の応答が返された後（ステップＳ１９：ＹＥＳ）、処理件数データファイル５の処理件数5-cを値210に更新する（ステップＳ２０）。更新後処理件数データファイル５のロックを解除し（ステップＳ２１）、入力データファイル4-cに対する排他ロックを解除し（ステップＳ２２）、再び第１のＡＰブローカ3-1は入力データファイル群４，処理件数データファイル５に対し排他的に参照を行う（ステップＳ１２，Ｓ１３）。
【００２４】前記ステップＳ１４において、未処理のデータがない場合は、処理件数データファイル５を解除し（ステップＳ２３）、入力データファイル群４を解除し（ステップＳ２４）、再び第１のＡＰブローカ3-1は入力データファイル群４，処理件数データファイル５に対し排他的に参照を行う（ステップＳ１２，Ｓ１３）。
【００２５】第２のＡＰブローカ3-2も第１のＡＰブローカ3-1と同様に入力データファイル群４，処理件数データファイル５に対し排他的に参照を行う。このとき第１のＡＰブローカ3-1により入力データ4-cに対する排他ロックが行われている場合、第２のＡＰブローカ3-2は処理対象のデータ（最大未処理件数を持つデータ、段落番号００２０で先述）として入力データ4-aを選択し、排他ロックを行う。排他ロック完了後、第２のＡＰ処理サーバ6-2に対し入力データ4-aを行い、第２のＡＰ処理サーバ6-2からの処理完了応答を待つ。
【００２６】第２のＡＰブローカ3-2より入力データ4-aの処理要求を受けた第２のＡＰ処理サーバ6-2は処理件数データファイルを参照し、処理件数5-aの示す値'3000'を取得する。入力データファイル4の入力データ4-aの3001件目のデータから3010件目までのデータを処理した後、処理結果を出力データファイル７の処理結果7-aに記録し、第２のＡＰブローカ3-2に処理完了応答を返す。第２のＡＰブローカ3-2は第２のＡＰ処理サーバ6-2より処理完了の応答が返された後、処理件数データファイル５の処理件数5-aを値3010に更新する。更新後入力データファイル4-a に対する排他ロックを解除する。その後再び第１のＡＰブローカ3-1は入力データファイル群４，処理件数データファイル５に対し排他的に参照を行う。
【００２７】データ登録コマンド８が実行されると、データ登録コマンド８は入力データファイル群４，処理件数データファイル５に対してそれぞれ入力データファイル4-dと4-d に対応する処理件数5-dを追加する。データ登録コマンド８による入力データファイル4-d，処理件数5-dの追加が行われた後、第１，第２のＡＰブローカ3-1，3-2は入力データファイル4-a，4-b，4-c、処理件数 5-a，5-b，5-cに加えそれぞれ入力データファイル4-d，処理件数5-dを処理対象として処理を続行する。
【００２８】なお、本実施例によれば、例えば電子商取引におけるシステムにおいて、アプリケーションサーバでの障害対応や保守中に、クライントからの入力データがあった場合であっても、平行処理が可能なので、クライアントへの悪影響を最小限にすることが可能となる。
【００２９】
【発明の効果】以上説明したように本発明によれば、センターカット処理において入力データファイル追加による処理時間の増加を必要最小限に押さえることである。その理由としては追加された入力データファイルの処理を現在処理中の入力データファイル群の処理後に行うのではなく、並行して処理を行うためである。
【出願人】 【識別番号】０００００４２３７
【氏名又は名称】日本電気株式会社
【出願日】 平成１２年１０月２０日（２０００．１０．２０）
【代理人】 【識別番号】１０００９３８３８
【弁理士】
【氏名又は名称】小橋川 洋二
【公開番号】 特開２００２−１３２５５３（Ｐ２００２−１３２５５３Ａ）
【公開日】 平成１４年５月１０日（２００２．５．１０）
【出願番号】 特願２０００−３２０３２６（Ｐ２０００−３２０３２６）