JP2005031807A - Data update method and data processing system in data processing system - Google Patents
Data update method and data processing system in data processing system Download PDFInfo
- Publication number
- JP2005031807A JP2005031807A JP2003193790A JP2003193790A JP2005031807A JP 2005031807 A JP2005031807 A JP 2005031807A JP 2003193790 A JP2003193790 A JP 2003193790A JP 2003193790 A JP2003193790 A JP 2003193790A JP 2005031807 A JP2005031807 A JP 2005031807A
- Authority
- JP
- Japan
- Prior art keywords
- data
- business
- terminal
- data management
- contents
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Landscapes
- Information Transfer Between Computers (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
【課題】この発明は、業務を中断することなく、各業務端末でのデータの整合性がとれる。
【解決手段】この発明は、通信回線を使用して接続された複数の端末が個々に情報を持ち、個々に情報更新を行う環境下で、データ管理端末を用意し個々の端末の更新内容を全端末分反映させ、データ管理端末で反映させた更新内容を差分形式で各端末に送信し、この内容で個々の端末のデータを更新することで、複数端末のデータの整合性をとるようにしたものである。
【選択図】 図2The present invention provides data consistency at each business terminal without interrupting the business.
The present invention provides a data management terminal in an environment in which a plurality of terminals connected using communication lines individually have information and update information individually, and update contents of the individual terminals are displayed. The update contents reflected on all terminals and the update contents reflected on the data management terminal are transmitted to each terminal in a differential format, and the data of each terminal is updated with this content, so that the consistency of data of multiple terminals is taken. It is a thing.
[Selection] Figure 2
Description
【0001】
【発明の属する技術分野】
この発明は、それぞれ業務を行う複数の業務端末と、各業務端末と通信回線を介して接続されているデータ管理端末とを有するデータ処理システムに関する。
【0002】
【従来の技術】
異なる端末でデータを共有した上で整合性を保つ方式として、データを一元管理するサーバと、サーバ上のデータにアクセスする端末とがネットワークを介して接続された、クライアントサーバシステムが挙げられる。端末側でデータを保有せず、サーバにあるデータは唯一のデータであるため、複数端末で同レベルのデータを扱うことが可能となる。
【0003】
このような方法は、申請書記載の申請データ入力、入力したデータに対する発行審査、審査結果をもとにした証明書の作成を行う証明書発行システムなど、個々のデータに対してリアルタイムに流れ作業的な処理を行うシステムには有効である。
【0004】
その他の方法として、サーバに代わるデータ管理端末と複数台接続した端末の両方に同等のデータを持たせる方法もある。各端末はデータ更新毎に自身のデータを更新すると共に、更新内容をデータ管理端末に送信する。データ管理端末はそれぞれの端末から受信した更新内容をデータ管理端末内のデータに反映させる。こうすることでデータ管理端末内のデータは常に最新の状態に保たれる。ところが、各端末での更新内容はその他の端末に送信されないため、端末間のデータに差異が生じる。この差異をなくすため、一定期間毎にデータ管理端末内の全データを記憶媒体にコピーし、この記憶媒体を使用して各端末のデータを総入れ替えする方法をとることで、データの整合性を保つ。記憶媒体を使用せず、ネットワークを介して総入れ替えを行う方法で整合性を保つこともできる。
【0005】
規模がそれほど大きくない場合、例えばサーバ1台と端末が数台接続されており、通信回線も高速な線が利用できる場合、この構成は有効である。しかし、サーバ1台と端末数百台が接続されており、通信回線が低速である場合などは、サーバ−端末間の転送データ減少、数百台が1台のサーバ内データに集中的にアクセスすることによるサーバの一時的ロックが発生することが考えられる。
【0006】
また、データ管理端末を使用した方式では、記憶媒体/ネットワークを使用して端末内のデータの総入れ替えの作業を行っている最中は、端末での業務を停止せざるを得ない。
図1は、従来のデータ処理システムのシステム構成を模式した図である。(特許文献1参照)
データ管理端末1に、業務端末2〜6がネットワークを介して接続されている。データ管理端末1、業務端末2〜6はそれぞれ同種のデータ管理を行っている。業務端末2〜6のそれぞれで更新した内容は、データ管理端末1に更新される。更新内容の送信を受けたデータ管理端末1は、データ管理端末1内のデータに即座に更新内容を反映させる。これにより、データ管理端末1が保持しているデータは常に最新の状態であるが、業務端末2〜6が保持しているデータは他の業務端末の更新内容を反映していない状態がしばらく続く(例えば業務端末2は自身の更新内容は随時反映しているが、業務端末3〜6での更新内容の通知を受けていないため反映できない)。
【0007】
業務端末2〜6のデータ更新は、データ管理端末1のデータは常に最新であるため、データ管理端末1が特定の時期にデータ管理端末1で保有しているデータを記憶媒体に全件出力する。この記憶媒体の内容で業務端末2〜6のデータを総入れ替えすることで初めてデータ管理端末1と業務端末2〜6のデータが同一のものとなる。この方式だと、データ管理端末1で保有するデータ件数が増加するに従い、記憶媒体に出力するデータが増加し、この結果、業務端末2〜6での総入れ替えの時間が増加するという欠点があった。
【0008】
【特許文献1】
特開平10−091735号公報。
【0009】
【発明が解決しようとする課題】
この発明は、それぞれ業務を行う複数の業務端末と、各業務端末と低速の通信回線を介して接続され、各業務端末がそれぞれ各業務端末での処理内容を共通に記憶しているデータ管理端末とを有するものにおいて、業務を中断することなく、各業務端末でのデータの整合性がとれるデータ処理システムを提供することを目的としている。
【0010】
【課題を解決するための手段】
この発明のデータ処理システムにおけるデータ更新方法は、複数の業務端末と、各業務端末と通信回線を介して接続されているデータ管理端末とを有するものにおいて、データ管理端末と業務端末とで同等のデータを保有し、業務端末でのデータの更新内容を定期的に差分データの形式でデータ管理端末に送信し、それを受けたデータ管理端末は自身のデータを更新し、複数の業務端末からの更新用差分データを受けたデータ管理端末は、全更新内容を全データに対する差分データの形式で業務端末に送信し、それを受けた業務端末は自身のデータを更新するものである。
【0011】
この発明のデータ処理システムは、複数の業務端末と、各業務端末と通信回線を介して接続されているデータ管理端末とを有し、データ管理端末と業務端末とで同等のデータを保有するものにおいて、業務端末でのデータの更新内容を定期的に差分データの形式でデータ管理端末に送信する第1の送信手段と、この差分データにより、データ管理端末が自身のデータを更新する第1の更新手段と、複数の業務端末からの更新用差分データを受けたデータ管理端末が、全更新内容を全データに対する差分データの形式で各業務端末に送信する第2の送信手段と、この差分データにより、各業務端末が自身のデータを更新する第2の更新手段とを有する。
【0012】
この発明のデータ処理システムは、複数の業務端末と、各業務端末と通信回線を介して接続されているデータ管理端末とを有するものにおいて、上記業務端末が、各業務端末の時系列の処理内容を日時に対応するバージョン情報に基づいて記憶する第1の記憶手段と、該業務端末による業務処理の内容を上記第1の記憶手段の最新のバージョン情報を付与して上記データ管理端末に送信する第1の送信手段と、この第1の送信手段の送信に応答して得られる上記最新のバージョン情報以降の各業務端末の時系列の処理内容を上記第1の記憶手段に追加記憶する第1の処理手段とを有し、上記データ管理端末が、上記各業務端末から供給される業務処理の内容を、日時に対応するバージョン情報に基づいて順次記憶する第2の記憶手段と、上記各業務端末から供給される業務処理の内容とともに供給される上記各業務端末のバージョン情報と上記第1の記憶手段の最新のバージョン情報とを比較し、その差分の業務処理の内容をそのバージョン情報とともに上記各業務端末に送信する第2の送信手段とを有する。
【0013】
この発明のデータ処理システムは、複数の業務端末と、各業務端末と通信回線を介して接続されているデータ管理端末とを有するものにおいて、上記業務端末が、各業務端末の時系列の処理内容を日時に対応するバージョン情報に基づいて記憶する第1の記憶手段と、該業務端末による業務処理の内容を上記第1の記憶手段の最新のバージョン情報を付与して上記データ管理端末に送信する第1の送信手段と、この第1の送信手段の送信に応答して得られる上記最新のバージョン情報以降の各業務端末の時系列の処理内容を上記第1の記憶手段に追加記憶する第1の処理手段とを有し、上記データ管理端末が、上記各業務端末から供給される業務処理の内容を、日時に対応するバージョン情報に基づいて順次記憶する第2の記憶手段と、上記各業務端末から供給される業務処理の内容とともに供給される上記各業務端末のバージョン情報と上記第1の記憶手段の最新のバージョン情報とを比較し、上記各業務端末ごとに異なる差分の業務処理の内容をそのバージョン情報とともに上記各業務端末に送信する第2の送信手段とを有する。
【0014】
【発明の実施の形態】
以下、図面を参照してこの発明の実施形態のデータ処理システムを説明する。
図2は、この発明のデータ処理システムのシステム構成を模式した図である。
【0015】
データ管理端末11に、業務端末12〜16がネットワークを介して接続されている。データ管理端末11、業務端末12〜16はそれぞれ同種のデータ管理を行っている。業務端末12〜16のそれぞれで更新した内容は、データ管理端末11に更新される。更新内容の送信を受けたデータ管理端末11は、データ管理端末11内のデータに即座に更新内容を反映させる。これにより、データ管理端末11が保持しているデータは常に最新の状態であるが、業務端末12〜16が保持しているデータは他の業務端末の更新内容を反映していない状態がしばらく続く(例えば業務端末12は自身の更新内容は随時反映しているが、業務端末13〜16での更新内容の通知を受けていないため反映できない)。
【0016】
データ管理端末11は、業務端末12〜16から送信を受けた更新内容を使用して、一定時間毎に差分ファイルを作成する。この差分ファイルには業務端末12〜16での更新内容が全て反映されている。業務端末12〜16は、データ管理端末11での差分ファイル作成を定期的に監視し、差分ファイルの発生を検知すると、この差分ファイルを取得し、自身のデータに更新内容を反映させる。差分データには全業務端末でのデータ更新内容が含まれているため、差分データの内容を反映させた時点でデータ管理端末11保有のデータと業務端末保有のデータは同一のデータとなる。
【0017】
したがって、この発明によれば、従来の方式では、データの総入れ替えを行っているところを、定期的に作成する差分ファイルを適用することで、入れ替え時間の削減、わずかなタイムラグでのデータ整合性確保を実現可能である。
【0018】
次に、この発明による更新データの通知(業務端末12(13、…)→データ管理端末11)について、図2を用いて説明する。
(1) 業務端末12は、発生したデータを定期的にファイルへ出力し、データ管理端末11上の特定フォルダ21上にコピーする。
(2) データ管理端末11は定期的に特定フォルダ21を参照する。処理対象のファイルが存在すれば、これをもとに自身のデータ更新処理を実行する。実行後に、処理済みのファイルを削除し、データ管理端末11と業務端末12間の電文中に完了したファイルのバージョンをセットする。
(3) ファイルには、バージョンが付与される。
ファイル名(バージョン):データ種類_YYYYMMDDnnnn
データ種類:データ種類を識別するためのヘッダ
YYYYMMDD:西暦年月日
nnnn:定期的に作成されるデータの連番
(4) 業務端末12とデータ管理端末11間のファイルのやり取りの概念図は図3に示すようになっている。データ管理端末11側は特定のフォルダを参照して未処理ファイルを取得し、これをもとに自身のデータを更新する。
【0019】
次に、この発明による更新データの通知(データ管理端末11→業務端末12(13、…))について説明する。
(1)図4に示すように、データ管理端末11上の更新データは毎時間更新され、これを業務端末12に反映させるために更新内容を格納したファイル(差分データ)を作成する。
(2)図5に示すように、毎時間作成した差分データとは別に、これらを一日単位にまとめた日締めデータを作成する。
【0020】
次に、この発明によるバージョン付与形式について説明する。
(1) 更新用の差分データ・日締めデータは、図6に示すように、ファイルでデータ管理端末11に格納される。ファイルの作成順を識別するためバージョンを付与し、ファイル名に付ける。また、差分ファイルは特定フォルダ21に格納する。
ファイル名(バージョン):データ種類_YYYYMMDDnnnn
データ種類:データ種類を識別するためのヘッダ
YYYYMMDD:西暦年月日
nnnn:毎時間作成される差分データの連番
0000→当該日の最新版の全データ
9999→当該日の日締めデータ
(2) 図7に示すように、業務端末12内のデータのバージョンが「ABC_200211010000」であれば、業務端末12ではこれを適用後に、2002/11/01以降発生した差分データを取り込み適用すれば、データ管理端末11と同一の最新状態となる。
【0021】
次に、この発明による入手データの範囲について説明する。
(1) 最新バージョン
データの最新バージョンは、図8に示すように、データ管理端末11−業務端末12(13、…)間で送受信する電文中に格納される。業務端末12側はこれを参照することで、差分データの最新バージョンを入手することができる。
(2) 取り込み済みバージョン
業務端末12側は、取り込み済みの差分データのバージョンを管理する。業務端末12側は、たとえば、電源投入時に、データ管理端末11側から取り込み済みバージョン以降の差分データを入手する。
(3) 従って、図9に示すように、データ管理端末11側の最新バージョンが「200211040003」であり、業務端末12側の取り込み済みバージョンが「200211030001」であれば、この間の差分ファイルをデータ管理端末11から取得し適用することで、最新データを反映させることができる。
【0022】
次に、この発明による差分ファイルの一覧入手について、図10を用いて説明する。
(1) 業務端末12(13、…)側のデータを最新の状態にするために、データ管理端末11から差分ファイルを入手する。この処理に先立って、ファイル一覧を入手する必要がある。ファイル一覧の入手には、標準のFTPコマンドであるDirを使用する。
(2)差分ファイルを格納する特定フォルダ21に対してファイルの一覧を入手する際に、データ管理端末11へDirコマンドを無条件にコールすると、更新の完了しているバージョン情報も入手することになり、ネットワークのトラフィックやデータ管理端末11および業務端末12に負荷をかけることとなる。
(3) そこで、データ管理端末11と業務端末12間の電文上に格納する「最新バージョン」と業務端末12側で管理する「取り込み済みバージョン」から、入手するファイルの一覧を絞る。
1) 最新バージョン=取り込み済みバージョンの場合
入手すべき差分ファイルが存在しないため、Dirコマンドをコールしない。
2) 最新バージョンと取り込み済みバージョンの年月日が一致する場合
a) 連番部分の下4桁にワイルドカードを付与して、Dirコマンドをコールする。
【0023】
例)Dir ABC_20021105???? 結果格納ファイル名
b) これにより、ファイル一覧として20021104以前の不要なバージョンを入手しないで済む
3) 最新バージョンと取り込み済みバージョンの年月日の中、DD下1桁が一致しない場合
a) 連番部分の下4桁と日にちの下1桁にワイルドカードを付与して、Dirコマンドをコールする。
【0024】
例)Dir ABC_2002110?????
b) これにより、ファイル一覧として20021031以前の不要なバージョンを入手しないで済む
4) 以降、電文中の最新バージョンと業務端末12側の取り込み済みバージョンからDirコマンドの検索条件を生成し、入手するファイルの一覧を絞り込む。
【0025】
次に、この発明による差分ファイルと日締めファイルの選択について説明する。
(1) 入手したファイル一覧から、データ管理端末11から取得すべきファイルを判別する。
(2) バージョンの上限下限は、最新バージョンとの絞り込みバージョンから判別することが可能
(3) バージョン一覧中に日付部分が同値で、連番部分が0001〜nnnnまで存在しており、これに対応する日締めのデータ(連番部分が9999)が存在すれば、連番部分が0001〜nnnnまでのファイルを取得する必要はない。日締めファイルだけ入手すれば済む。
【0026】
この場合、図11に示すように、最新バージョン「20021106003」、絞り込みバージョン「200211030002」の際、NO10までのファイルの内容については取得済みのため、NO11の差分ファイル、NO16、NO19の日締めファイル、NO21、NO22、NO23の差分ファイルが取得対象となる。
【0027】
ただし、NO12の日締めファイルは対応する差分ファイルを取得しているため不要である。また、NO13からNO15の差分ファイルは対応するNO16の日締めファイルを取得しているため不要である。また、NO17からNO19の差分ファイルは対応するNO20の日締めファイルを取得しているため不要である。また、NO13からNO15の差分ファイルは対応する日締めファイルが存在しないため取得されている。
(4)バージョン一覧中に取り込み済みバージョンと最新バージョンの間で、日締めファイルが存在する場合でも、日付が同値の差分ファイルで適用が完了している場合は、日締めファイルではなく差分ファイルを適用する。
【0028】
この場合、図12に示すように、最新バージョン「20021106001」、絞り込みバージョン「200211050001」の際、NO17までのファイルの内容については取得済みのため、NO18、NO19、NO21の差分ファイルが取得対象となる。
【0029】
上記したように、データ管理端末と業務端末とで同等のデータを保有し、業務端末でのデータ更新内容は定期的に差分データの形式でデータ管理端末に送信し、それを受けたデータ管理端末は自身のデータに更新をかける。複数の業務端末からの更新用差分データを受けたデータ管理端末は、全更新内容を全データに対する差分データの形式で業務端末に送信し、それを受けた業務端末は自身のデータに更新をかける。
すなわち、業務を中断することなく、他端末とのデータの整合性がとれる。
【0030】
また、通信回線を使用して接続された複数の端末が個々に情報を持ち、個々に情報更新を行う環境下で、他端末での更新内容を自端末にも反映させる。
【0031】
また、通信回線を使用して接続された複数の端末が個々に情報を持ち、個々に情報更新を行う環境下で、データ管理端末を用意し個々の端末の更新内容を全端末分反映させる。データ管理端末で反映させた更新内容を差分形式で各端末に送信し、この内容で個々の端末のデータを更新することで、複数端末のデータの整合性をとる。
【0032】
これにより、夜間を利用したデータの総入れ替えなど、業務を一時停止することなく、通常業務中でもリアルタイムにデータの整合性が保てるため、業務停滞や夜間作業による作業時間を削減できる。
【0033】
また、オンライン/オフラインによるデータ総入れ替えを行うのではなく、差分データを用いて各端末のデータを更新するため、ネットワークへの負荷が軽減できる。
【0034】
また、複数の端末から複数の端末に対して更新内容を通知するのではなく、個々の端末から一台のデータ管理端末に対して更新内容を通知するためデータの制御が簡潔で、かつ、ネットワークを介したデータアクセスに比べて、ローカルデータへのアクセスであるため処理の高速化が可能となる。
【0035】
また、従来の方式では、データの総入れ替えを行っているところを、定期的に作成する差分ファイルを適用することで、入れ替え時間の削減、わずかなタイムラグでのデータ整合性確保を実現可能である。
【0036】
【発明の効果】
以上詳述したように、この発明によれば、それぞれ業務を行う複数の業務端末と、各業務端末と低速の通信回線を介して接続され、各業務端末がそれぞれ各業務端末での処理内容を共通に記憶しているデータ管理端末とを有するものにおいて、業務を中断することなく、各業務端末でのデータの整合性がとれるデータ処理システムを提供できる。
【図面の簡単な説明】
【図1】従来のデータ処理システムのシステム構成を示す概略図。
【図2】この発明のデータ処理システムのシステム構成を示す概略図。
【図3】業務端末とデータ管理端末間のファイルのやり取りの概念図。
【図4】差分データの作成処理を説明するための図。
【図5】日締めデータの作成処理を説明するための図。
【図6】バージョン付与形式を説明するための図。
【図7】バージョン付与形式を説明するための図。
【図8】データ管理端末−業務端末間で送受信する電文例を示す図。
【図9】差分データの入手処理を説明するための図。
【図10】差分データの入手処理を説明するための図。
【図11】差分データと日締めデータの入手処理を説明するための図。
【図12】差分データと日締めデータの入手処理を説明するための図。
【符号の説明】
11…データ管理端末、12…業務端末[0001]
BACKGROUND OF THE INVENTION
The present invention relates to a data processing system having a plurality of business terminals each performing business and a data management terminal connected to each business terminal via a communication line.
[0002]
[Prior art]
As a method for maintaining consistency while sharing data between different terminals, there is a client server system in which a server that centrally manages data and a terminal that accesses data on the server are connected via a network. Since no data is held on the terminal side and the data in the server is the only data, the same level of data can be handled by a plurality of terminals.
[0003]
Such a method works in real time on individual data, such as application data entry on the application form, issuance examination for the entered data, and a certificate issuance system that creates a certificate based on the examination results. It is effective for a system that performs typical processing.
[0004]
As another method, there is a method of giving equivalent data to both a data management terminal instead of a server and a plurality of connected terminals. Each terminal updates its own data every time data is updated, and transmits the updated contents to the data management terminal. The data management terminal reflects the update content received from each terminal in the data in the data management terminal. By doing so, the data in the data management terminal is always kept up-to-date. However, since the update content at each terminal is not transmitted to other terminals, there is a difference in data between terminals. In order to eliminate this difference, data consistency can be improved by copying all data in the data management terminal to a storage medium at regular intervals and using this storage medium to totally replace the data of each terminal. keep. Consistency can also be maintained by a method of performing total replacement via a network without using a storage medium.
[0005]
When the scale is not so large, for example, when one server and several terminals are connected and a high-speed communication line can be used, this configuration is effective. However, when one server and hundreds of terminals are connected and the communication line is low speed, etc., the data transferred between the server and the terminal is reduced, and hundreds of units concentrate on the data in one server. It is conceivable that a temporary lock of the server occurs due to this.
[0006]
Further, in the method using the data management terminal, the operation at the terminal must be stopped while the storage medium / network is used to perform total replacement of data in the terminal.
FIG. 1 is a diagram schematically showing a system configuration of a conventional data processing system. (See Patent Document 1)
[0007]
In the data update of the
[0008]
[Patent Document 1]
JP-A-10-091735.
[0009]
[Problems to be solved by the invention]
The present invention relates to a plurality of business terminals each performing business, and a data management terminal connected to each business terminal via a low-speed communication line, and each business terminal stores the processing contents of each business terminal in common. It is an object of the present invention to provide a data processing system that can maintain data consistency at each business terminal without interrupting the business.
[0010]
[Means for Solving the Problems]
The data update method in the data processing system according to the present invention includes a plurality of business terminals and a data management terminal connected to each business terminal via a communication line. Owns the data and periodically sends the data update contents in the business terminal to the data management terminal in the form of differential data, and the data management terminal that receives the data updates its own data and receives data from multiple business terminals. The data management terminal that has received the differential data for update transmits all the update contents to the business terminal in the form of differential data for all the data, and the business terminal that receives the data updates its own data.
[0011]
The data processing system of the present invention has a plurality of business terminals and a data management terminal connected to each business terminal via a communication line, and the data management terminal and the business terminal hold equivalent data The first transmission means for periodically transmitting the update contents of the data at the business terminal to the data management terminal in the form of differential data, and the first data management terminal updating its own data by the difference data. The update means, the second transmission means for receiving the update difference data from the plurality of business terminals, the second transmission means for sending all update contents to each business terminal in the form of differential data for all data, and the difference data Thus, each business terminal has second update means for updating its own data.
[0012]
The data processing system according to the present invention includes a plurality of business terminals and a data management terminal connected to each business terminal via a communication line. The business terminal is a time-series processing content of each business terminal. Is stored on the basis of the version information corresponding to the date and time, and the contents of the business process by the business terminal are given the latest version information of the first storage means and transmitted to the data management terminal A first transmission means, and a first series of time-series processing contents of each business terminal after the latest version information obtained in response to the transmission of the first transmission means is additionally stored in the first storage means. A second storage means for sequentially storing the contents of the business process supplied from the business terminals based on version information corresponding to the date and time, and the data management terminal The version information of each business terminal supplied together with the content of business processing supplied from the business terminal is compared with the latest version information of the first storage means, and the content of the business process of the difference together with the version information is compared. Second transmitting means for transmitting to each business terminal.
[0013]
The data processing system according to the present invention includes a plurality of business terminals and a data management terminal connected to each business terminal via a communication line. The business terminal is a time-series processing content of each business terminal. Is stored on the basis of the version information corresponding to the date and time, and the contents of the business process by the business terminal are given the latest version information of the first storage means and transmitted to the data management terminal A first transmission means, and a first series of time-series processing contents of each business terminal after the latest version information obtained in response to the transmission of the first transmission means is additionally stored in the first storage means. A second storage means for sequentially storing the contents of the business process supplied from the business terminals based on version information corresponding to the date and time, and the data management terminal The version information of each business terminal supplied together with the content of the business process supplied from the business terminal is compared with the latest version information of the first storage means, and the business process of the difference that differs for each business terminal is compared. Second transmission means for transmitting the contents together with the version information to each business terminal.
[0014]
DETAILED DESCRIPTION OF THE INVENTION
Hereinafter, a data processing system according to an embodiment of the present invention will be described with reference to the drawings.
FIG. 2 is a diagram schematically showing the system configuration of the data processing system of the present invention.
[0015]
[0016]
The
[0017]
Therefore, according to the present invention, in the conventional method, where the total data replacement is performed, the difference file created periodically is applied to reduce the replacement time and the data consistency with a slight time lag. Ensuring is feasible.
[0018]
Next, update data notification (business terminal 12 (13,...) → data management terminal 11) according to the present invention will be described with reference to FIG.
(1) The
(2) The
(3) A version is assigned to the file.
File name (version): Data type_YYYYMMDDnnnn
Data type: Header YYYYMMDD for identifying the data type: Year, month, day nnnn: Serial number of data created periodically (4) A conceptual diagram of file exchange between the
[0019]
Next, update data notification (
(1) As shown in FIG. 4, the update data on the
(2) As shown in FIG. 5, separately from the difference data created every hour, date closing data is created by collecting these data in units of one day.
[0020]
Next, a version assignment format according to the present invention will be described.
(1) The difference data / date closing data for update is stored in the
File name (version): Data type_YYYYMMDDnnnn
Data type: header for identifying the data type YYYYMMDD: year, month, day nnnn:
[0021]
Next, the range of obtained data according to the present invention will be described.
(1) The latest version of the latest version data is stored in a message sent and received between the
(2) Captured version The
(3) Therefore, as shown in FIG. 9, if the latest version on the
[0022]
Next, obtaining a list of difference files according to the present invention will be described with reference to FIG.
(1) In order to update the data on the business terminal 12 (13,...) Side, the difference file is obtained from the
(2) When the Dir command is unconditionally called to the
(3) Therefore, the list of files to be obtained is narrowed down from the “latest version” stored on the message between the
1) When the latest version = the imported version, there is no difference file to be obtained, so the Dir command is not called.
2) When the date of the latest version matches the date of the imported version a) Add a wild card to the last 4 digits of the serial number and call the Dir command.
[0023]
Example) Dir ABC_20021105? ? ? ? Result storage file name b) As a result, it is not necessary to obtain an unnecessary version before 200001104 as a file list. 3) When the last digit of DD does not match among the date of the latest version and the imported version a) Sequential number A wild card is assigned to the last 4 digits of the part and the last digit of the date, and the Dir command is called.
[0024]
Example) Dir ABC — 2002110? ? ? ? ?
b) As a result, it is not necessary to obtain unnecessary versions prior to 20021031 as a file list. 4) Thereafter, a search condition for the Dir command is generated from the latest version in the message and the imported version on the
[0025]
Next, selection of the difference file and the date closing file according to the present invention will be described.
(1) The file to be acquired from the
(2) The upper and lower limits of the version can be determined from the narrowed-down version with the latest version. (3) The date part has the same value in the version list, and the serial number part exists from 0001 to nnnn. If there is date closing data (serial number portion is 9999), it is not necessary to acquire files with serial number portions from 0001 to nnnn. You only need to get a date file.
[0026]
In this case, as shown in FIG. 11, when the latest version “20021106003” and the narrowed-down version “200211030002”, the contents of the files up to NO10 have already been acquired, so the difference files of NO11, NO16, NO19 day-end files, The difference files of NO21, NO22, and NO23 are to be acquired.
[0027]
However, the date closing file of NO12 is unnecessary because the corresponding difference file is acquired. Further, the difference file from NO13 to NO15 is unnecessary because the corresponding date closing file of NO16 is acquired. Further, the difference file from NO17 to NO19 is unnecessary because the corresponding date closing file of NO20 is acquired. Further, the difference file from NO13 to NO15 is acquired because there is no corresponding date closing file.
(4) Even if a date closing file exists between the version already imported and the latest version in the version list, if the application is completed with a difference file with the same date, the difference file is not the date closing file. Apply.
[0028]
In this case, as shown in FIG. 12, when the latest version “20021106001” and the narrowed-down version “200211050001”, the contents of the files up to NO17 have already been acquired, so the difference files of NO18, NO19, and NO21 are the acquisition targets. .
[0029]
As described above, the data management terminal and the business terminal have equivalent data, and the data update content at the business terminal is periodically transmitted to the data management terminal in the form of differential data, and the data management terminal that receives it Updates its own data. A data management terminal that receives differential update data from multiple business terminals sends all update contents to the business terminal in the form of differential data for all data, and the business terminal that receives the update updates its own data. .
In other words, data consistency with other terminals can be achieved without interrupting work.
[0030]
Also, in an environment in which a plurality of terminals connected using a communication line individually have information and the information is individually updated, the update contents at other terminals are reflected on the own terminal.
[0031]
A plurality of terminals connected using communication lines individually have information, and in an environment in which information is individually updated, a data management terminal is prepared and the updated contents of each terminal are reflected for all terminals. The update contents reflected by the data management terminal are transmitted to each terminal in a differential format, and the data of each terminal is updated with the contents, thereby ensuring the consistency of the data of a plurality of terminals.
[0032]
As a result, data consistency can be maintained in real time even during normal work without temporarily stopping the work, such as total replacement of data using the night, so that work hours due to business stagnation and night work can be reduced.
[0033]
In addition, since the data of each terminal is updated using the difference data instead of performing the total data exchange online / offline, the load on the network can be reduced.
[0034]
In addition, since the update contents are not notified from a plurality of terminals to a plurality of terminals, the update contents are notified from one terminal to one data management terminal, so that the data control is simple and the network Compared to data access via the network, access to local data makes it possible to increase the processing speed.
[0035]
Also, with the conventional method, it is possible to reduce the replacement time and ensure data consistency with a slight time lag by applying a differential file that is created periodically, where data is totally replaced. .
[0036]
【The invention's effect】
As described in detail above, according to the present invention, a plurality of business terminals each performing business, and each business terminal is connected to each business terminal via a low-speed communication line. A data processing system that can maintain data consistency in each business terminal without interrupting the business can be provided in a system having a data management terminal that is stored in common.
[Brief description of the drawings]
FIG. 1 is a schematic diagram showing a system configuration of a conventional data processing system.
FIG. 2 is a schematic diagram showing a system configuration of a data processing system according to the present invention.
FIG. 3 is a conceptual diagram of file exchange between a business terminal and a data management terminal.
FIG. 4 is a diagram for explaining difference data creation processing;
FIG. 5 is a view for explaining date closing data creation processing;
FIG. 6 is a diagram for explaining a version assignment format;
FIG. 7 is a diagram for explaining a version assignment format;
FIG. 8 is a diagram illustrating an example of a message transmitted and received between a data management terminal and a business terminal.
FIG. 9 is a diagram for explaining difference data acquisition processing;
FIG. 10 is a diagram for explaining difference data acquisition processing;
FIG. 11 is a diagram for explaining a process for obtaining difference data and date closing data.
FIG. 12 is a diagram for explaining a process for obtaining difference data and date closing data.
[Explanation of symbols]
11 ... Data management terminal, 12 ... Business terminal
Claims (4)
データ管理端末と業務端末とで同等のデータを保有し、業務端末でのデータの更新内容を定期的に差分データの形式でデータ管理端末に送信し、それを受けたデータ管理端末は自身のデータを更新し、複数の業務端末からの更新用差分データを受けたデータ管理端末は、全更新内容を全データに対する差分データの形式で業務端末に送信し、それを受けた業務端末は自身のデータを更新する
ことを特徴とするデータ処理システム。In a data update method in a data processing system having a plurality of business terminals and a data management terminal connected to each business terminal via a communication line,
The data management terminal and the business terminal have the same data, and the data update content on the business terminal is periodically sent to the data management terminal in the form of differential data. The data management terminal that received the update differential data from multiple business terminals sends all the update contents to the business terminal in the form of differential data for all data, and the business terminal that received the data updates its own data A data processing system characterized by updating.
業務端末でのデータの更新内容を定期的に差分データの形式でデータ管理端末に送信する第1の送信手段と、
この差分データにより、データ管理端末が自身のデータを更新する第1の更新手段と、
複数の業務端末からの更新用差分データを受けたデータ管理端末が、全更新内容を全データに対する差分データの形式で各業務端末に送信する第2の送信手段と、
この差分データにより、各業務端末が自身のデータを更新する第2の更新手段と、
を具備したことを特徴とするデータ処理システム。In a data processing system having a plurality of business terminals and a data management terminal connected to each business terminal via a communication line, and holding the same data in the data management terminal and the business terminal,
First transmission means for periodically transmitting data update contents in the business terminal to the data management terminal in the form of difference data;
With this difference data, the data management terminal updates its own data, a first update means,
A data management terminal that receives differential data for update from a plurality of business terminals, a second transmission means for transmitting all update contents to each business terminal in the form of differential data for all data;
With this difference data, each business terminal updates its own data, a second update means,
A data processing system comprising:
上記業務端末が、
各業務端末の時系列の処理内容を日時に対応するバージョン情報に基づいて記憶する第1の記憶手段と、
該業務端末による業務処理の内容を上記第1の記憶手段の最新のバージョン情報を付与して上記データ管理端末に送信する第1の送信手段と、
この第1の送信手段の送信に応答して得られる上記最新のバージョン情報以降の各業務端末の時系列の処理内容を上記第1の記憶手段に追加記憶する第1の処理手段とを有し、
上記データ管理端末が、
上記各業務端末から供給される業務処理の内容を、日時に対応するバージョン情報に基づいて順次記憶する第2の記憶手段と、
上記各業務端末から供給される業務処理の内容とともに供給される上記各業務端末のバージョン情報と上記第1の記憶手段の最新のバージョン情報とを比較し、その差分の業務処理の内容をそのバージョン情報とともに上記各業務端末に送信する第2の送信手段とを有する
ことを特徴とするデータ処理システム。In a data processing system having a plurality of business terminals and a data management terminal connected via a communication line with each business terminal,
The business terminal
First storage means for storing time-series processing contents of each business terminal based on version information corresponding to the date and time;
First transmission means for giving the latest version information of the first storage means and transmitting the contents of the business processing by the business terminal to the data management terminal;
First processing means for additionally storing time series processing contents of each business terminal after the latest version information obtained in response to transmission of the first transmission means in the first storage means; ,
The data management terminal
Second storage means for sequentially storing the contents of the business process supplied from each business terminal based on version information corresponding to the date and time;
The version information of each business terminal supplied together with the contents of the business process supplied from each business terminal is compared with the latest version information of the first storage means, and the contents of the business process of the difference are compared with the version. A data processing system comprising: second transmission means for transmitting information to each business terminal.
上記業務端末が、
各業務端末の時系列の処理内容を日時に対応するバージョン情報に基づいて記憶する第1の記憶手段と、
該業務端末による業務処理の内容を上記第1の記憶手段の最新のバージョン情報を付与して上記データ管理端末に送信する第1の送信手段と、
この第1の送信手段の送信に応答して得られる上記最新のバージョン情報以降の各業務端末の時系列の処理内容を上記第1の記憶手段に追加記憶する第1の処理手段とを有し、
上記データ管理端末が、
上記各業務端末から供給される業務処理の内容を、日時に対応するバージョン情報に基づいて順次記憶する第2の記憶手段と、
上記各業務端末から供給される業務処理の内容とともに供給される上記各業務端末のバージョン情報と上記第1の記憶手段の最新のバージョン情報とを比較し、上記各業務端末ごとに異なる差分の業務処理の内容をそのバージョン情報とともに上記各業務端末に送信する第2の送信手段とを有する
ことを特徴とするデータ処理システム。In a data processing system having a plurality of business terminals and a data management terminal connected to each business terminal via a communication line,
The business terminal
First storage means for storing time-series processing contents of each business terminal based on version information corresponding to the date and time;
First transmission means for giving the latest version information of the first storage means and transmitting the contents of the business processing by the business terminal to the data management terminal;
First processing means for additionally storing time series processing contents of each business terminal after the latest version information obtained in response to transmission of the first transmission means in the first storage means; ,
The data management terminal
Second storage means for sequentially storing the contents of the business process supplied from each business terminal based on version information corresponding to the date and time;
The version information of each business terminal supplied together with the contents of the business process supplied from each business terminal is compared with the latest version information of the first storage means, and the business of differences differing for each business terminal A data processing system comprising: a second transmission unit configured to transmit the content of processing to each of the business terminals together with version information thereof.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2003193790A JP2005031807A (en) | 2003-07-08 | 2003-07-08 | Data update method and data processing system in data processing system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2003193790A JP2005031807A (en) | 2003-07-08 | 2003-07-08 | Data update method and data processing system in data processing system |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JP2005031807A true JP2005031807A (en) | 2005-02-03 |
Family
ID=34205156
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2003193790A Pending JP2005031807A (en) | 2003-07-08 | 2003-07-08 | Data update method and data processing system in data processing system |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP2005031807A (en) |
Cited By (14)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2007048125A (en) * | 2005-08-11 | 2007-02-22 | Mitsubishi Electric Corp | Information distribution method |
| JP2012510118A (en) * | 2008-11-26 | 2012-04-26 | カルガリー・サイエンティフィック・インコーポレイテッド | Method and system for providing remote access to the state of an application program |
| US8949378B2 (en) | 2011-03-21 | 2015-02-03 | Calgary Scientific Inc. | Method and system for providing a state model of an application program |
| US9602581B2 (en) | 2012-03-02 | 2017-03-21 | Calgary Scientific Inc. | Remote control of an application using dynamic-linked library (DLL) injection |
| US9686205B2 (en) | 2013-11-29 | 2017-06-20 | Calgary Scientific Inc. | Method for providing a connection of a client to an unmanaged service in a client-server remote access system |
| US9720747B2 (en) | 2011-08-15 | 2017-08-01 | Calgary Scientific Inc. | Method for flow control and reliable communication in a collaborative environment |
| US9729673B2 (en) | 2012-06-21 | 2017-08-08 | Calgary Scientific Inc. | Method and system for providing synchronized views of multiple applications for display on a remote computing device |
| US9741084B2 (en) | 2011-01-04 | 2017-08-22 | Calgary Scientific Inc. | Method and system for providing remote access to data for display on a mobile device |
| US9986012B2 (en) | 2011-08-15 | 2018-05-29 | Calgary Scientific Inc. | Remote access to an application program |
| US10015264B2 (en) | 2015-01-30 | 2018-07-03 | Calgary Scientific Inc. | Generalized proxy architecture to provide remote access to an application framework |
| US10055105B2 (en) | 2009-02-03 | 2018-08-21 | Calgary Scientific Inc. | Method and system for enabling interaction with a plurality of applications using a single user interface |
| US10284688B2 (en) | 2011-09-30 | 2019-05-07 | Calgary Scientific Inc. | Tiered framework for proving remote access to an application accessible at a uniform resource locator (URL) |
| US10454979B2 (en) | 2011-11-23 | 2019-10-22 | Calgary Scientific Inc. | Methods and systems for collaborative remote application sharing and conferencing |
| US11310348B2 (en) | 2015-01-30 | 2022-04-19 | Calgary Scientific Inc. | Highly scalable, fault tolerant remote access architecture and method of connecting thereto |
-
2003
- 2003-07-08 JP JP2003193790A patent/JP2005031807A/en active Pending
Cited By (29)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2007048125A (en) * | 2005-08-11 | 2007-02-22 | Mitsubishi Electric Corp | Information distribution method |
| US9367365B2 (en) | 2008-11-26 | 2016-06-14 | Calgary Scientific, Inc. | Method and system for providing remote access to a state of an application program |
| US8799354B2 (en) | 2008-11-26 | 2014-08-05 | Calgary Scientific Inc. | Method and system for providing remote access to a state of an application program |
| JP2014222536A (en) * | 2008-11-26 | 2014-11-27 | カルガリー・サイエンティフィック・インコーポレイテッドCalgary Scientific Inc. | Method and system for providing remote access to state of application program |
| JP2015164071A (en) * | 2008-11-26 | 2015-09-10 | カルガリー・サイエンティフィック・インコーポレイテッドCalgary Scientific Inc. | Method for providing remote access to application program executed on server computer and device for remotely accessing application program |
| JP2012510118A (en) * | 2008-11-26 | 2012-04-26 | カルガリー・サイエンティフィック・インコーポレイテッド | Method and system for providing remote access to the state of an application program |
| US10965745B2 (en) | 2008-11-26 | 2021-03-30 | Calgary Scientific Inc. | Method and system for providing remote access to a state of an application program |
| US10334042B2 (en) | 2008-11-26 | 2019-06-25 | Calgary Scientific Inc. | Method and system for providing remote access to a state of an application program |
| US9871860B2 (en) | 2008-11-26 | 2018-01-16 | Calgary Scientific Inc. | Method and system for providing remote access to a state of an application program |
| US10055105B2 (en) | 2009-02-03 | 2018-08-21 | Calgary Scientific Inc. | Method and system for enabling interaction with a plurality of applications using a single user interface |
| US10410306B1 (en) | 2011-01-04 | 2019-09-10 | Calgary Scientific Inc. | Method and system for providing remote access to data for display on a mobile device |
| US9741084B2 (en) | 2011-01-04 | 2017-08-22 | Calgary Scientific Inc. | Method and system for providing remote access to data for display on a mobile device |
| US8949378B2 (en) | 2011-03-21 | 2015-02-03 | Calgary Scientific Inc. | Method and system for providing a state model of an application program |
| US10158701B2 (en) | 2011-03-21 | 2018-12-18 | Calgary Scientific Inc.. | Method and system for providing a state model of an application program |
| US9986012B2 (en) | 2011-08-15 | 2018-05-29 | Calgary Scientific Inc. | Remote access to an application program |
| US10474514B2 (en) | 2011-08-15 | 2019-11-12 | Calgary Scientific Inc. | Method for flow control and for reliable communication in a collaborative environment |
| US9992253B2 (en) | 2011-08-15 | 2018-06-05 | Calgary Scientific Inc. | Non-invasive remote access to an application program |
| US9720747B2 (en) | 2011-08-15 | 2017-08-01 | Calgary Scientific Inc. | Method for flow control and reliable communication in a collaborative environment |
| US10693940B2 (en) | 2011-08-15 | 2020-06-23 | Calgary Scientific Inc. | Remote access to an application program |
| US10904363B2 (en) | 2011-09-30 | 2021-01-26 | Calgary Scientific Inc. | Tiered framework for proving remote access to an application accessible at a uniform resource locator (URL) |
| US10284688B2 (en) | 2011-09-30 | 2019-05-07 | Calgary Scientific Inc. | Tiered framework for proving remote access to an application accessible at a uniform resource locator (URL) |
| US10454979B2 (en) | 2011-11-23 | 2019-10-22 | Calgary Scientific Inc. | Methods and systems for collaborative remote application sharing and conferencing |
| US9602581B2 (en) | 2012-03-02 | 2017-03-21 | Calgary Scientific Inc. | Remote control of an application using dynamic-linked library (DLL) injection |
| US9729673B2 (en) | 2012-06-21 | 2017-08-08 | Calgary Scientific Inc. | Method and system for providing synchronized views of multiple applications for display on a remote computing device |
| US9686205B2 (en) | 2013-11-29 | 2017-06-20 | Calgary Scientific Inc. | Method for providing a connection of a client to an unmanaged service in a client-server remote access system |
| US10728168B2 (en) | 2013-11-29 | 2020-07-28 | Calgary Scientific Inc. | Method for providing a connection of a client to an unmanaged service in a client-server remote access system |
| US9979670B2 (en) | 2013-11-29 | 2018-05-22 | Calgary Scientific Inc. | Method for providing a connection of a client to an unmanaged service in a client-server remote access system |
| US10015264B2 (en) | 2015-01-30 | 2018-07-03 | Calgary Scientific Inc. | Generalized proxy architecture to provide remote access to an application framework |
| US11310348B2 (en) | 2015-01-30 | 2022-04-19 | Calgary Scientific Inc. | Highly scalable, fault tolerant remote access architecture and method of connecting thereto |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP2005031807A (en) | Data update method and data processing system in data processing system | |
| CN112994935B (en) | prometheus management and control method, device, equipment and storage medium | |
| CN112000741A (en) | Intranet and extranet data exchange system, method, device, computer equipment and medium | |
| US9141480B2 (en) | Handling failed transaction peers in a distributed hash table | |
| CN111405019A (en) | Data processing method, data processing device, computer equipment and storage medium | |
| US6662222B2 (en) | Apparatus and method of managing system, and machine readable storage medium for storing program | |
| CN109710586A (en) | A kind of clustered node configuration file synchronous method and device | |
| KR20150083938A (en) | System for interoperation between dds and dbms | |
| JPWO2006095427A1 (en) | Server system, server device and method thereof | |
| CN113190620A (en) | Method, device, equipment and storage medium for synchronizing data between Redis clusters | |
| CN110958293B (en) | File transmission method, system, server and storage medium based on cloud server | |
| CN110196780B (en) | Method, device, storage medium and electronic device for determining server state | |
| CN106993026B (en) | Method and device for detecting and downloading newly added files of FTP server | |
| CN114466026B (en) | Update method and device of application program interface, storage medium and computing device | |
| JPH0528021A (en) | Management method of two-way arrangement data | |
| CN115237682A (en) | Block chain node fault synchronization method and device, computer equipment and storage medium | |
| CN110290163A (en) | A kind of data processing method and device | |
| JP2014102677A (en) | Information processing server, information processing method, and program | |
| JPH034339A (en) | System for updating data base in distributed processing system | |
| JPH10320040A (en) | Periodic data collection and storage system | |
| CN117668112A (en) | Method, device, equipment, storage medium and product for synchronizing data of multiple bins | |
| CN112035064B (en) | A distributed migration method for object storage | |
| CN117061535A (en) | Multi-activity framework data synchronization method, device, computer equipment and storage medium | |
| CN110933184B (en) | Resource publishing platform and resource publishing method | |
| CN118264524A (en) | Business service configuration method, related device, equipment and storage medium |