JPH06215031A - 分散データ処理装置及び方法 - Google Patents

分散データ処理装置及び方法

Info

Publication number
JPH06215031A
JPH06215031A JP5274684A JP27468493A JPH06215031A JP H06215031 A JPH06215031 A JP H06215031A JP 5274684 A JP5274684 A JP 5274684A JP 27468493 A JP27468493 A JP 27468493A JP H06215031 A JPH06215031 A JP H06215031A
Authority
JP
Japan
Prior art keywords
data
copy
primary
data processor
remote
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
Application number
JP5274684A
Other languages
English (en)
Inventor
Geoffrey Sharman
シャーマン ジェフリー
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
International Business Machines Corp
Original Assignee
International Business Machines Corp
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by International Business Machines Corp filed Critical International Business Machines Corp
Publication of JPH06215031A publication Critical patent/JPH06215031A/ja
Pending legal-status Critical Current

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/23—Updating
    • G06F16/2308—Concurrency control
    • G06F16/2315—Optimistic concurrency control
    • G06F16/2322—Optimistic concurrency control using timestamps
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Databases & Information Systems (AREA)
  • Data Mining & Analysis (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Computing Systems (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

(57)【要約】 【目的】 局所的なデータに対して入手可能なパフォー
マンス及び使用可能性と可能な限り一致するパフォーマ
ンス及び使用可能性を備えた遠隔データへのアクセスを
提供する。 【構成】 分散データ処理方法は、少なくとも１つの遠
隔データプロセッサに第１データプロセッサで記憶され
る１次データレコードの複写された２次コピーを記憶す
るステップと、１次データレコードの更新を遠隔データ
プロセッサへ伝播するステップ(570) と、遠隔データプ
ロセッサの各々にそのデータプロセッサに記憶された各
２次コピーと対応する現行の満了時間を記憶するステッ
プと、データプロセッサのデータアクセスの要求に応じ
て、現行の満了時間が過ぎたかどうかを検査するステッ
プ(510) と、から成る。

Description

【発明の詳細な説明】
【０００１】
【産業上の利用分野】本発明は、分散データ処理システ
ムに関する。
【０００２】
【従来の技術】分散システムは、データ通信ネットワー
クによって相互接続される多くのデータ処理機械から成
る。分散システムの重要なクラスは、１つのサイトにあ
るデータがもう１つのサイトで実行するデータ処理プロ
グラムによって明らかにアクセス可能なことである。当
該分散データベースシステムの一般的な説明は、デート
著(C J Date)「分散データベースシステムとは何か (Wh
at is a Distributed Database System)」第１部、第２
部 (The Relational Journal, Nos 1 and 2, 1987 年)
に記載されている。
【０００３】分散データベースシステムにおいて、通信
ネットワークのデータ通信量を減少するため、データへ
アクセスするプロセスに近接してデータを配置する目的
によって、データは分割されて幾つかのサイトに記憶さ
れてもよい。しかしながら、通常、幾つかのサイトはも
う１つのサイトに配置されたデータへアクセスしなけれ
ばならない。この遠隔アクセスによってデータ処理操作
に含まれるコスト及び遅延が増加し、これらのサイトの
処理パフォーマンスはそれ自体のデータを持つ同等の独
立型システムの処理パフォーマンスよりも極めて悪い。
【０００４】他のネットワークのサイトにおいて通信リ
ンク又はデータ処理機械が故障すると、遠隔データは一
定の時間アクセスを妨げられるという追加の問題があ
る。従って、データの使用可能性は各サイトが独立型シ
ステムであったならばより一層悪くなる。分散システム
の目的はユーザがデータ資源を共用することだが、これ
らのマイナス効果はユーザが遠隔データアクセスに依存
するのを妨げようとする。これはまた、単純な集中シス
テムと比較すると分散システムの価値を下げている。
【０００５】
【発明が解決しようとする課題】従って、分散システム
のフィールドにおける不変の目的は、局所的な（ローカ
ル）データに対して入手可能なパフォーマンス及び使用
可能性と可能な限り一致するパフォーマンス及び使用可
能性を備えた遠隔データへのアクセスを提供することで
ある。この目的を達成するための１つの方法はネットワ
ークを介してデータを複写することであり、殆どのデー
タアクセスが必要なデータの局所的なコピー又は近くの
コピーによって満足可能である。この方法はサン(Sang
Hyuk Son)著(SIGMOD Record, Vol 17 No 4 (1988)) の
文献に記載されている。この技術では、データアクセス
のためのネットワーク通信量の減少と、データの複数の
コピーへ更新を伝播するのに必要な追加のネットワーク
通信量との間に均衡が見出されなければならない。
【０００６】データ複写は、キャッシングを用いるロー
カルエリアネットワークフィアルサーバから、複写され
たデータを用いる分散データベース管理システムに及ぶ
分散システムの幾つかのタイプに使用されている。複写
されたデータシステムの重要なクラスは、データオブジ
ェクトの１次コピーが単一のデータプロセッサに保持さ
れ、データオブジェクトの他の全てのコピーが２次コピ
ーとして指定される。更新のタイムシーケンスが正確な
ことを保証するために、先ず１次コピーが更新される。
次に、改訂された１次コピーに基づいて２次コピーが改
訂される。
【０００７】データオブジェクトが高い割合の読み取り
アクセスと、低い割合の書き込みアクセスとを有すると
き、データオブジェクトの複写は最も有用である。これ
は、読み取りアクセスが単一の２次コピーで実行される
一方、書き込みアクセスが１次コピーで実行されて、全
ての２次コピーへ伝播されなければならないためであ
る。従って、書き込みアクセスのコストは読み取りアク
セスのコストより高い。分散システムでは、データオブ
ジェクトの更新によって、データオブジェクトの遠隔２
次コピーが無効にされ、ネットワークを介して伝送され
る新たなコピーによって置換されて、ネットワークのコ
ストは他の更新のコストに追加されなければならない。
【０００８】この方法の極端な例として、意思決定支援
アプリケーションのために、読み取り専用の複写とされ
る「スナップショット(snapshots) 」を使用する。リン
ゼイ(B. Lindsay)他著、「スナップショット差動リフレ
ッシュアルゴリズム(Snapshot Differential Refresh A
lgorithm) 」(IBM Research Report RJ4992, 1986 年)
では、スナップショットを１次データの現行の状態によ
り近く保つためにスナップショットがどのように定期的
にリフレッシュ（再生）されるかが記載されている。し
かしながら、スナップショットは保全性が保証されてお
らず、トランザクション中のデータを更新するために使
用することができない。
【０００９】多数のユーザが共用されたファイル又はデ
ータベースを更新する場合、２次コピーがすばやく無効
にされ、多くのネットワーク通信量が生成されてもよ
い。この追加の通信量は、複写がもたらす予定のネット
ワーク通信量の減少を越えることすらある。実際の結果
として、シェール(A L Sherr) 著、「ネットワークのシ
ステムのための構造(Structures for Systems of Netwo
rks)」(IBM Systems Journal Vol 25, No 1, 1987 年)
に記載されるように、複写方法は、殆ど常に集中してい
る巨大な共用されたファイル及びデータベースに有用で
はない。
【００１０】従って、従来技術における重要な問題は、
データ複写が望ましくとも、データがユーザによって複
数のサイトで更新可能であることが重要な場合にはデー
タ複写を達成するのが極めて困難なことである。しかし
ながら、多くの実際の場合では、分散されたサイトにお
けるアプリケーションは最新のデータへのアクセスを必
要とせず、公知の制御された量によって使い古されてい
るデータで充分に機能することができる。この例とし
て、定期的に更新される比率テーブルを使用するアプリ
ケーション、及び現金の引き出しを許可するときに使い
古された口座残高を用いる自動窓口システムがある。
【００１１】
【発明が解決しようとする課題】従って、分散システム
のフィールドにおける不変の目的は、局所的な（ローカ
ル）データに対して入手可能なパフォーマンス及び使用
可能性と可能な限り一致するパフォーマンス及び使用可
能性を備えた遠隔データへのアクセスを提供することで
ある。
【００１２】
【課題を解決するための手段と作用】本発明に従って、
分散データ処理装置及び分散データ処理方法が提供され
る。本方法は、少なくとも１つの遠隔データプロセッサ
に第１データプロセッサで記憶される１次データレコー
ドの複写された２次コピーを記憶するステップと、前記
１次コピーの更新を遠隔データプロセッサへ伝播するス
テップと、遠隔データプロセッサの各々にそのデータプ
ロセッサに記憶された各２次コピーと対応する現行の満
了時間を記憶するステップと、そのデータプロセッサに
おけるデータアクセスの要求に応じて、現行の満了時間
が過ぎたかどうかを検査するステップと、から成る。
【００１３】好ましくは、肯定的又は否定的な有効性メ
ッセージが遠隔プロセッサに記憶され、肯定的なメッセ
ージは対応するコピーが有効でアクセスされてもよいこ
とを示す一方、否定的なメッセージはコピーがアクセス
されないことを示す。後者の場合、データレコードの無
効なコピーへアクセスを試みるアプリケーションプログ
ラムは、１次データレコードを保持するプロセッサへ向
けられる。
【００１４】無効性が決定されるときにコピー全体がリ
フレッシュされる必要がなく、１次データレコードのど
の部分が現行の期間内に更新されるかについてのレコー
ドが保持され、他のプロセッサへ更新のみが伝播される
のが好ましい。
【００１５】更に、全てのプロセッサへ全ての更新を伝
送するのが不要になる。即ち、現行の期間内に遠隔プロ
セッサが１次レコード又は更新された部分さえにもアク
セスを要求するならば、本発明の１態様に従って、１次
データレコードに対する更新が遠隔プロセッサのみに伝
播するシステムを提供するのが好ましい。
【００１６】分散データを処理する装置は、データレコ
ードの１次コピーを記憶するための手段を有する第１デ
ータプロセッサと、前記１次コピーの全て又は一部の２
次コピーを記憶するための手段と、各前記２次コピーと
対応する現行の満了時間を記憶するための手段と、前記
現行の満了時間が経過したかどうかを検査するための手
段と、を有する少なくとも１つの遠隔データプロセッサ
と、前記１次コピーへ行われる更新を前記２次コピーへ
伝播するための手段と、から成る。
【００１７】
【実施例】図１を参照すると、データ処理機械のネット
ワークの部分が示されて、データプロセッサ１００、２
００及び２５０がデータ通信ネットワーク２６０によっ
てリンクされている。データプロセッサ１００、２００
は、中央処理装置（ＣＰＵ）１１０、２１０から成り、
対応するユーザ端末１２０、２２０及びデータ記憶装置
１３０、２３０を備えている。データプロセッサはまた
自動窓口機（ＡＴＭ）又はプリンター等の追加の周辺装
置を有してもよい。追加の装置は、概略的に１４０、２
４０として示される。各プロセッサ１００乃至２５０
は、ライントランザクション処理アプリケーションを支
援するために、ＣＩＣＳ（顧客情報管理システム）とし
て知られるデータベース／データ通信プログラムを実行
する。ＣＩＣＳプログラムは、ＩＢＭの「ＣＩＣＳ一般
情報マニュアル(CICS General Information Manual) 」
(GC33-0155-3) に記載されている。
【００１８】データネットワークによってデータプロセ
ッサを互いにリンクすることは、ＩＢＭのマニュアル
「ＣＩＣＳ製品間通信(CICS Inter-Product Communicat
ion)」(SC33-0824-0) に記載されており、各データプロ
セッサはＣＩＣＳシステム間通信機能を用いてもう１つ
のデータプロセッサに記憶されるデータへアクセスする
ことができる。例えば、ＣＰＵ２１０によって必要とさ
れる特定のデータレコードが実際、記憶装置１３０に記
憶されるならば、ＣＩＣＳプログラムはネットワーク２
６０を介してデータプロセッサ２００からデータプロセ
ッサ１００へアクセス要求を送信して、要求されたデー
タレコードで応答する。この遠隔ファイルへアクセスす
る方法は、機能伝送として知られている。
【００１９】概してネットワーク２６０等のデータネッ
トワークは導入及び使用するのが高価なために、しばし
ばネットワーク通信量を可能な限り減らす努力がなされ
ている。通信量の減少を達成するための１つの方法とし
て、データファイルをネットワークの異なる機械の間で
分割する方法があり、そのデータを最も頻繁に使用する
データプロセッサにて、或いは、そのデータプロセッサ
に物理的に近いところにデータが記憶される。しかしな
がら、同一のデータファイルが多数のデータプロセッサ
によって使用されるならば、ネットワーク通信量を減ら
すようにはならない。なぜならば、これら機械の内の１
つを除く全てが、そのファイルがどこに保持されていよ
うと、ネットワークを用いて単一のファイルへアクセス
しなければならないからである。
【００２０】従って、第２の方法はデータファイルの複
数のコピーを作成して、ネットワークのさまざまなデー
タプロセッサにこれらのコピーを記憶することである。
このようにして、特定のファイルのコピーが各データプ
ロセッサで記憶されるか、或いは、少なくともこれらの
ファイルを通常用いるデータプロセッサで記憶される。
各データプロセッサでファイルを複写することによっ
て、データへのアクセスは局所的であり、ネットワーク
を介して伝送される必要のないことが保証される。
【００２１】複写されるコピーの内の１つは、「マスタ
ー(master)」コピー又は「１次(primary) 」コピーと称
される。ファイルが更新されるときはいつも最初にマス
ターコピーが更新され、他の２次コピーに対する更新は
マスターから取り出されて２次コピーへ伝播される。単
一のマスターコピーを最初に更新することによって、正
確なタイムシーケンスで更新が行われていることが保証
される。全てのファイルのマスターコピーが単一のデー
タプロセッサによって保持される必要はない。特定のフ
ァイルのマスターコピーの場所は、そのファイルへ最も
アクセスを必要とするデータプロセッサに、或いは、デ
ータプロセッサの近くに選択される。
【００２２】マスターコピーが更新されるといつも、そ
の更新されたレコード、或いは、更新されたファイルの
完全なコピーさえも２次コピーの各々に伝播される。し
かしながら、これによって、複写によってもたらされる
いかなる利点も十分に否定することが可能な大量のネッ
トワーク通信量が生じる可能性がある。本実施例におい
て、この問題は２次コピーの各々に所定の不確実度を許
容することによって処理される。これを達成するため、
２次コピーの各々は対応する現行の期間を有し、現行の
期間の満了時間がそのファイルに対応するＣＩＣＳ制御
ファイルに記憶される。マスターコピーが平均時間で更
新されたかどうかにかかわらず、現行の満了時間が過ぎ
るまで、２次コピーは有効であると仮定される。２次コ
ピーが１次コピーの全てのレコードを含む必要はなく、
２次サイトで頻繁に必要とされるレコードだけを含んで
もよい。従って、異なる２次コピーは異なるレコードを
含んでもよい。
【００２３】図２は、２次コピーを構成する記憶された
データレコードとの現行の満了時間の対応を示す概略図
である。図２において、データレコードはＣＩＣＳデー
タファイル３００に配置されるように示されている。フ
ァイル３００の各レコードに対応して、現行の満了時間
（Ｔ）３２０及び有効性フラグ（Ｖ）３３０があり、フ
ァイル制御テーブル３４０に記憶される。現行の満了時
間の起点は以下に記載される。データレコード３１０を
読み取ろうとするとき、データレコード３１０に対応す
る有効性フラグ３３０が最初に検査される。有効性フラ
グ３３０が「無効(invalid) 」と設定されなければ、現
行の満了時間３２０が経過したかどうかを決定するため
に現行の時間が検査される。現行の満了時間３２０が経
過していなければ、データレコード３１０が読み取ら
れ、動作は通常どおり続く。現行の満了時間３２０が経
過したならば、レコードは読み取られず、そのレコード
に対応する有効性フラグ３３０が「無効(invalid) 」と
設定され、２次コピーの更新が要求される。追加の動作
は図４にも示される。
【００２４】現行の満了時間Ｔは、個々のデータレコー
ド又は全体のファイルに対応する。データレコードへの
更新が伝播されるときはいつもマスターコピーのホルダ
によって伝播される。また、マスターから更新が受信さ
れるときはいつも、マスター更新が発生した時間に予め
定められた現行の期間を追加することで、現行の満了時
間は２次コピーのホルダによって再設定される。
【００２５】データレコードの実際の現行の期間（現行
の満了時間Ｔとマスターレコードが更新される時間との
差）は、ユーザによって、データレコードの性質、及び
任意ではあるが、現行の時間又は現行の日付に関連して
決定される。しかしながら、主にデータの性質に依存し
ている。一例として、分散システムに記憶されるデータ
が銀行の口座残高に関連する場合がある。（例えば、自
動窓口機（ＡＴＭ）を用いて）少額の現金の引出しを許
可する目的のために、ユーザとしての銀行は、局所的な
２次コピーで保持される残高を、例えば、２４時間毎よ
り頻繁に更新するのに、余分なネットワーキングコスト
及び処理コストを払う価値はないと考えるかもしれな
い。
【００２６】上記のように、現行の期間は現行の時間又
は日付によって変更可能である。例えば、更新がその時
間に特に頻繁に行われるならば、現行の期間は月曜日の
朝（営業週間の始まり）により一層短くする必要がある
かもしれない。同様に、現行の期間は殆どデータ更新動
作のない週末に延長することも可能である。
【００２７】図３は、少なくとも１つのデータレコード
の１次コピーから２次コピーへの更新を伝播するための
方法を示すフローチャートである。「ニュース速報 (ne
ws bulletin)」方法又は「プッシュダウン(pushdown)」
方法と称されるこの方法は、２次コピーの現行の満了時
間を知っているマスターコピーのホルダに依存するが、
いかなる読み取り要求が行われるかどうかに依存する必
要はない。
【００２８】フローチャートに示される幾つかのステッ
プは１次コピーのホルダによって実行され、残りは２次
コピーのホルダの各々によって実行される。１次コピー
ホルダと２次コピーホルダの間の通信は、ＣＩＣＳシス
テム間通信機能、或いは、信頼できるメッセージ機能等
の任意の同等の機能を介して達成される。
【００２９】プロセスはステップ４００で開始し、最後
の更新が２次コピーへ伝播されて以来、１次コピーホル
ダは１次コピーのどのデータレコードが更新されたかを
決定する。本実施例において、ステップ４００は２次コ
ピーで保持される現行の満了時間に達する前に実行され
る。ステップ４１０において、新たな現行の満了時間Ｔ
は、現行の時間及びデータレコードの性質に関連する所
定の情報に基づいてデータレコードのセットに対して計
算される。この現行の満了時間のレコードは、１次コピ
ーホルダによって保持される。
【００３０】ステップ４２０において、全体のファイル
と対応する現行の満了時間と共に、更新されたデータレ
コードは２次コピーホルダへ伝播される。２次コピーホ
ルダによって実行される第１ステップは、ステップ４３
０において更新を受信し、ファイルの２次コピーの更新
を行うことである。ステップ４５０において、データレ
コードに対応する新たな現行の満了時間が記憶される。
最後に、これらレコードと対応するあらゆる有効性フラ
グが、データレコードの有効性期間が満了したと示す
「無効(invalid) 」と設定されるならば、有効性フラグ
はステップ４６０において再設定される。この方法は、
現行の期間の満了の前に更新が２次コピーへ伝播される
ならば、各２次コピーは常に使用できることを保証す
る。
【００３１】図４は、ファイルの１次コピーから２次コ
ピーへ更新を伝播するための第２の方法を示すフローチ
ャートである。この方法は、「即時回答(on demand) 」
方法又は「プルダウン(pulldown)」方法と称される。ま
た、フローチャートで詳細に示される幾つかのステップ
は１次コピーホルダによって実行され、残りは２次コピ
ーホルダの各々によって実行される。
【００３２】図４に示されるプロセスは、２次コピーホ
ルダが２次コピーに保持されるデータレコードの読み取
り動作を開始するときに開始する。データレコードに対
応する有効性フラグは、ステップ５００で検査される。
フラグが「無効(invalid) 」と設定されるならば、制御
は直接ステップ５３０へ渡されて、そのデータレコード
に対する更新が要求される。これらの場合では、有効性
フラグを使用することによってデータレコードの有効性
を更に検査する必要性が取り除かれる。しかしながら、
有効性フラグが「有効(valid) 」と設定されるならば、
ステップ５１０において、現行の時間がデータレコード
と対応する現行の満了時間よりも遅いかどうかを決定す
るための追加の検査が行われる。現行の時間がＴよりも
早いならば、データレコードはステップ５４０において
局所的な２次コピーから読み取られて、プロセスは無事
に終了する。
【００３３】ステップ５１０において、現行の満了時間
が経過したならば、制御はステップ５２０に渡されて有
効性フラグが「無効(invalid) 」と設定され、ステップ
５３０に渡されてそのデータレコードに対する更新が１
次コピーホルダから要求される。しかしながら、この要
求が合わない場合がある。例えば、１次コピーホルダが
故障した、或いは、通信ネットワークが利用不可能とな
った場合である。ステップ５５０において更新要求が与
えられると、制御は１次コピーホルダへ渡され、ステッ
プ５６０において要求されたレコードを検索しようと試
みる。レコードが発見されると、１次コピーホルダは新
たは現行の満了時間を計算し、ステップ５７０において
更新されたレコード及び新たな時間の双方を２次コピー
ホルダへと伝送する。１次データレコードが最後に２次
コピーホルダへ送信されて以来、１次データレコードが
変更されていなかったならば、肯定信号及び新たな現行
の完了時間が代わりに送信されてもよい。
【００３４】ステップ５５０において、更新要求が与え
られなければ、プロセスは不成功に終わる。この場合
（データ利用不可）は、データレコードを読み取るため
の元の要求を作成したプログラムによって従来の方法で
処理される。
【００３５】ステップ５８０において、更新は２次コピ
ーホルダによって受信されて２次コピーへ適用される。
ステップ５９０において新たな現行の満了時間Ｔが保管
（セーブ）され、データレコードと対応する有効性フラ
グＶは「有効(valid) 」と再設定される。次にデータレ
コードの局所的なコピーがステップ５４０で読み取ら
れ、プロセスは無事に終了する。この方法はアプリケー
ションによって特別に要求されたときのみデータレコー
ドを伝送することでネットワーク通信量を最小限にし、
ときどき使用不可能なこれらのレコードを犠牲にして、
有効なコピーは局所的には存在しない。
【００３６】「即時回答(on demand) 」方法及び「ニュ
ース速報(news bulletin) 」方法の特徴を組み合わせ
る、組合せ更新方法を用いることは可能である。この場
合、遠隔サイトで保持される２次コピーは、いかなるデ
ータも保持しない空のファイルとして開始する。次に、
これは「即時回答(on demand) 」方法を用いる遠隔サイ
トの必要性に適したデータレコードのセットへと組み込
まれる。いったんデータレコードの作業セットが設定さ
れると（「即時回答(on demand) 」方法が適切な時間で
作動すると）、動作は「ニュース速報(news bulletin)
」方法へ切り替えることが可能である。また双方の方
法は同時に作動可能であり、その場合には遠隔サイトで
保持される２次コピーは、遠隔サイトによって必要とさ
れたデータレコード及び１次コピーで最近更新されたデ
ータレコードから成る。組合せの方法は２次コピーが作
成されるにつれて追加の処理を要するが、その後は「ニ
ュース速報(news bulletin) 」方法と同様に実行する。
組合せの方法は、２次コピーがいかなる理由で失われて
も自動的に回復されるという利点がある。
【００３７】分散複写システムのデータレコードの更新
が行われると、データレコードのあらゆる他のコピーが
更新される前に１次コピーが更新される。これは、更新
が正確なタイムシーケンスで行われることを保証するた
めである。しかしながら、多くの分散データ処理システ
ム（トランザクション処理システム等）において、デー
タは遠隔サイトで捕獲されて、１次コピーへ転送され
る。単一のサイトが全てのデータの１次コピーホルダな
らば、これらのデータ捕獲動作で１次コピーを更新しな
くてはならないために、それらのパフォーマンスは非複
写システムの場合と同じである。更新フローは図５に示
され、ここで遠隔データプロセッサは、現行のＣＩＣＳ
システム間通信機能を用いて１次コピーファイルを更新
する。ステップ６００において、遠隔データプロセッサ
は更新のためのレコードを用意し、ステップ６１０にお
いて、中央データプロセッサへそのレコードを伝送す
る。ステップ６２０においてこのレコードが受信され、
ファイルの１次コピーが更新される。ステップ６３０に
おいて更新の確認が生成されて遠隔サイトへ伝送され、
ステップ６４０で受信される。なお、ネットワーク故障
が発生する場合には、ステップ６１０において更新は完
全に失敗する。
【００３８】これらパフォーマンス問題及び利用可能性
問題に対する１つの解決法が図６に示され、ここで１次
コピー自体がネットワークを介して分散される。換言す
れば、各サイトは、可能な限り更新を一般的に必要とす
るそれらデータレコードの１次コピーホルダである。中
央サイトがそれらデータレコードの２次コピーを保持す
ることで、完全なファイルは他のサイトへの複写又は中
央処理のために利用することができる。
【００３９】図６は、図１に示される分散データ処理シ
ステムと同様の分散データ処理システムを示している。
データ記憶装置１３０、２３０に記憶されるデータは、
４つの区画Ａ、Ｂ、Ｃ及びＤから成るとして概略的に示
されている。中央側にあるデータプロセッサ１００は区
画Ｃの１次コピー６７０を保持し、データプロセッサ２
００は区画Ｂの１次コピー６８０を保持する。各データ
プロセッサは、そのデータプロセッサのデータアクセス
の必要性に適するならば他の区画の２次コピーを保持し
てもよい。区画は重なり合わないように画定されて、い
かなる所定のレコードにも１つの１次コピーしかないこ
とが重要である。これは、レコードをキー範囲又はあら
ゆる同様の方法で区分することによって達成可能であ
る。概して、各区画は対応する記述子６５０、６６０を
有して、データプロセッサに特定のレコードがこの区画
にあるかどうかを決定させる。
【００４０】改訂された更新フローは図７に示され、こ
こで遠隔データプロセッサがレコードを更新する。ステ
ップ７００において、遠隔データプロセッサは更新する
ためのレコードを用意し、ステップ７１０において、局
所的な区画記述子をテストして、レコードがそのサイト
で保持される１次コピー区画内に含まれるかどうかを決
定する。含まれるならば、ステップ７２０においてこの
区画に更新が行われ、ステップ７３０において更新の確
認が生成される。更新されたレコードが局所的な区画内
に含まれなければ、ステップ７４０において中央サイト
へ伝送され、ステップ７５０において受信され、中央フ
ァイル（及び異なるならば１次コピー）へ適用される。
ステップ７６０において、確認が生成され、遠隔サイト
へ伝送される。局所的な区画がそのサイトで更新される
レコードの大部分を含むように選ばれるならば、この方
法はネットワーク通信量をかなり減少することができ
る。この方法はまた、中央サイトへ伝送されなければな
らない更新だけがネットワーク故障のために失敗するた
め、利用可能性も増やす。
【００４１】ある場合において、特定の遠隔サイトはデ
ータレコードのセットのために１次コピーホルダとして
開始されてもよいが、異なる遠隔サイトは、その後多数
の更新をそれらデータレコードの１次コピーへ行う必要
がある。データ処理サイトの更新要求において、この変
化によって生成されるネットワーク故障及び追加のネッ
トワーク通信量による分裂の可能性は、分散１次コピー
を用いることによって達成される利点の幾つかを否定す
るかもしれない。この問題に対する解決法は、１次コピ
ーを保持する責任をサイト間で動的に転送するのを可能
にすることである。このような構成は「チェックアウト
／チェックイン(checkout/checkin)」方法と称され、図
８に関連して説明される。
【００４２】ステップ８００において、遠隔サイトにお
けるデータプロセッサは、中央サイトに区画記述子を伝
送することによって、ファイルの特定の区画に責任を要
求する。ステップ８１０でこの区画が検索され、ステッ
プ８２０において、制御ファイルに保持された既にチェ
ックアウトされた区画の記述子と比較される。要求され
た区画がもう１つのサイトへとチェックアウトされた
か、或いは、既にチェックアウトされた区画と重なり合
うならば、要求は失敗する。ステップ８３０において、
エラーメッセージが生成され、要求サイトへ伝送され
る。ステップ８４０において、このメッセージが受信さ
れて、プロセスが不成功に終わる。しかしながら、要求
された区画がチェックアウトされていなかったなれば、
その記述子はステップ８５０において制御ファイルに保
管される。確認メッセージがステップ８６０において作
成され、１次コピーホルダとなる遠隔サイトへ伝送され
る。このメッセージはステップ８７０で受信され、プロ
セスは無事に終了する。その後、遠隔データプロセッサ
はこの区画の制御を解放するために同様のプロセスを経
て、中央サイトへ「それをチェックインする(checking
it in)」。
【００４３】１次コピーの責任の動的な転送は、上記の
組合せ更新方法へと組み込まれる。データプロセッサの
ネットワークの動作の開始に際して、全てのデータの１
次コピーは中央サイトと称される単一のサイトで保持さ
れる。処理が行われるにつれて、データレコードのコピ
ーは「ニュース速報(news bulletin) 」処理又は「即時
回答(on demand) 」処理によってネットワークの回りに
分散される。しばらく後、分散サイトは特定の区画の所
有権を要求し、この区画の１次コピーの責任はその該当
するサイトへ動的に転送されてもよい。その後、ネット
ワークの負担が時間と共に変化するにつれて、責任は中
央サイトへ戻されるか、或いは、もう１つのサイトへ転
送されてもよい。
【００４４】
【発明の効果】本発明は上記より構成され、局所的なデ
ータに対して入手可能なパフォーマンス及び使用可能性
と可能な限り一致するパフォーマンス及び使用可能性を
備えた、遠隔データへのアクセスを提供する。
【図面の簡単な説明】
【図１】本発明が実施される分散データ処理システムの
部分を示す。
【図２】本発明に従って、図１のシステムで使用される
データ及び関連する制御テーブルを概略的に示す。
【図３】本発明に従って、分散データ処理システムで更
新を伝播するための「ニュース速報(news bulletin) 」
又は「プッシュダウン(pushdown)」方法を示すフローチ
ャートである。
【図４】本発明に従って、分散データ処理システムで更
新を伝播するための「即時回答(on demand) 」又は「プ
ルダウン(pulldown)」方法を示すフローチャートであ
る。
【図５】中央１次コピーへの更新を行うための従来の方
法を示す。
【図６】ファイルが分散１次コピーを有する分散データ
処理システムの部分を示す。
【図７】遠隔プロセッサが更新を行う図６のシステムで
使用される更新方法を示すフローチャートである。
【図８】図６のシステムにおいて中央サイトから遠隔サ
イトへのデータレコードの１次コピーの責任の転送を示
すフローチャートである。
【符号の説明】
１００、２００、２５０ データプロセッサ １１０、２１０ ＣＰＵ １２０、２２０ ユーザ端末 １３０、２３０ データ記憶装置 ２６０ データ通信ネットワーク ３００ データファイル ３１０ データレコード ３２０ 現行の満了時間 ３３０ 有効性フラグ ３４０ ファイル制御テーブル

Claims (10)

    【特許請求の範囲】
  1. 【請求項１】 分散データを処理する方法であって、少
    なくとも１つの遠隔データプロセッサ（２００、２５
    ０）において、第１データプロセッサ（１００）で記憶
    される１次データレコードの複写された２次コピー（３
    １０）を記憶するステップと、前記１次データレコード
    の更新を前記遠隔データプロセッサ（２００、２５０）
    へ伝播するステップ（４２０、５７０）と、前記遠隔デ
    ータプロセッサ（２００、２５０）の各々に前記遠隔デ
    ータプロセッサに記憶される各前記２次コピーと対応す
    る現行の満了時間（３２０）を記憶するステップと、前
    記遠隔データプロセッサのデータアクセスの要求に応じ
    て前記現行の満了時間（３２０）が経過したかどうかを
    検査するステップ（５１０）と、から成る分散データ処
    理方法。
  2. 【請求項２】 前記現行の満了時間内に更新が前記１次
    コピーに行われるときに有効性インジケータ（３３０）
    を設定するステップ（４６０、５９０）と、前記遠隔デ
    ータプロセッサにおけるデータアクセスの要求に応じ
    て、前記遠隔データプロセッサによって保持される前記
    ２次コピーが有効かどうかを決定するために前記有効性
    インジケータ（３３０）を検査するステップ（５００）
    と、を含む請求項１に記載の分散データ処理方法。
  3. 【請求項３】 非有効性及び現行の満了時間の経過の内
    の一方を決定するときに２次コピーの更新を要求するス
    テップ（５３０）を含む、請求項１又は請求項２に記載
    の分散データ処理方法。
  4. 【請求項４】 分散データを処理する装置であって、デ
    ータレコード（３１０）の１次コピーを記憶するための
    手段を有する第１データプロセッサ（１００）と、 前記１次コピーの全て又は一部の２次コピーを記憶する
    ための手段と、各前記２次コピーと対応する現行の満了
    時間を記憶するための手段と、前記現行の満了時間が経
    過したかどうかを検査するための手段と、を有する少な
    くとも１つの遠隔データプロセッサ（２００）と、 前記１次コピーへ行われる更新を前記２次コピーへ伝播
    する（４２０、５７０）ための手段と、 から成る分散データ処理装置。
  5. 【請求項５】 更新が前記１次コピーに行われるときに
    有効性インジケータ（３３０）を設定するための手段
    と、前記遠隔データプロセッサ（２００）におけるデー
    タアクセスの要求に応じて前記有効性インジケータ（３
    ３０）を検査する（５００）ことによって、前記コピー
    が有効かどうかを決定するための手段と、を含む請求項
    ４に記載の分散データ処理装置。
  6. 【請求項６】 非有効性及び現行の満了時間の経過の内
    の一方を決定するときに２次コピーの更新を要求する
    （５３０）ための手段を含む、請求項４又は請求項５に
    記載の分散データ処理装置。
  7. 【請求項７】 最後の更新が２次コピーを保持する前記
    遠隔データプロセッサに伝播されて以来、１次コピーの
    どのデータレコードが更新されたかを決定する（４０
    ０）ための手段と、前記遠隔データプロセッサへ前記更
    新されたデータレコードのコピーを伝播するための手段
    と、を有する請求項４乃至請求項６のいずれか１つに記
    載の分散データ処理装置。
  8. 【請求項８】 データレコードの更新されたコピーが前
    記１次コピーへアクセスするために前記遠隔データプロ
    セッサ（２００）からの要求のみで前記遠隔データプロ
    セッサ（２００）へ伝播され（５７０）、前記遠隔デー
    タプロセッサ（２００）が前記更新されたコピーを記憶
    するための手段を有する、請求項４乃至請求項７のいず
    れか１つに記載の分散データ処理装置。
  9. 【請求項９】 １次データレコードが前記１次データレ
    コードの異なる部分の前記１次コピーを保持するために
    異なるプロセッサに分散されるよう論理的に区分され
    る、請求項４乃至請求項８のいずれか１つに記載の分散
    データ処理装置。
  10. 【請求項１０】 時間可変の現行の期間を設定するため
    の手段を含む、請求項４乃至請求項９のいずれか１つに
    記載の分散データ処理装置。
JP5274684A 1992-12-04 1993-11-02 分散データ処理装置及び方法 Pending JPH06215031A (ja)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
GB9225424A GB2273182A (en) 1992-12-04 1992-12-04 Currency period of replicated data objects.
GB9225424/2 1992-12-04

Publications (1)

Publication Number Publication Date
JPH06215031A true JPH06215031A (ja) 1994-08-05

Family

ID=10726155

Family Applications (1)

Application Number Title Priority Date Filing Date
JP5274684A Pending JPH06215031A (ja) 1992-12-04 1993-11-02 分散データ処理装置及び方法

Country Status (4)

Country Link
US (1) US5627961A (ja)
EP (1) EP0600457A3 (ja)
JP (1) JPH06215031A (ja)
GB (1) GB2273182A (ja)

Cited By (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH0981429A (ja) * 1995-09-19 1997-03-28 Mitsubishi Electric Corp キャッシュ管理装置
JPH09307590A (ja) * 1996-05-03 1997-11-28 Mitsubishi Electric Res Lab Inc ネットワークにおけるデータ転送システム
WO2000054157A1 (fr) * 1999-03-08 2000-09-14 Athena Telecom Lab, Inc. Procede et appareil pour la gestion de la duree de validite de donnes dans un systeme de traitement repartie et un support d'enregistrement

Families Citing this family (47)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP3443938B2 (ja) * 1994-03-31 2003-09-08 ソニー株式会社 ディジタル信号処理装置
JP3526474B2 (ja) * 1994-07-06 2004-05-17 富士通株式会社 ネットワークにおける配布情報管理システム
GB2294132A (en) * 1994-10-10 1996-04-17 Marconi Gec Ltd Data communication network
GB2295035A (en) * 1994-10-18 1996-05-15 First Option Ltd Computer network distributed data storage.
EP0724223B1 (en) * 1995-01-24 2001-07-25 Compaq Computer Corporation Remote duplicate database facility with database replication support for online line DDL operations
US5745753A (en) * 1995-01-24 1998-04-28 Tandem Computers, Inc. Remote duplicate database facility with database replication support for online DDL operations
JPH0981491A (ja) * 1995-09-12 1997-03-28 Toshiba Corp ネットワークビデオサーバ、クライアント装置及びマルチメディア情報提供方法
US5815649A (en) * 1995-10-20 1998-09-29 Stratus Computer, Inc. Distributed fault tolerant digital data storage subsystem for fault tolerant computer system
US5893115A (en) * 1995-11-29 1999-04-06 Lucent Technologies, Inc. Isochronal updating of data records
US5802062A (en) * 1996-06-19 1998-09-01 At&T Corp Preventing conflicts in distributed systems
US5812793A (en) * 1996-06-26 1998-09-22 Microsoft Corporation System and method for asynchronous store and forward data replication
US5787262A (en) * 1996-06-26 1998-07-28 Microsoft Corporation System and method for distributed conflict resolution between data objects replicated across a computer network
US5819272A (en) * 1996-07-12 1998-10-06 Microsoft Corporation Record tracking in database replication
US6161145A (en) * 1997-05-08 2000-12-12 International Business Machines Corporation Updating server-related data at a client
US6122645A (en) * 1997-08-25 2000-09-19 Lucent Technologies, Inc. System and method for physically versioning data in a main memory database
US6029178A (en) * 1998-03-18 2000-02-22 Bmc Software Enterprise data movement system and method which maintains and compares edition levels for consistency of replicated data
US6016501A (en) * 1998-03-18 2000-01-18 Bmc Software Enterprise data movement system and method which performs data load and changed data propagation operations
US6341339B1 (en) * 1998-03-26 2002-01-22 Compaq Computer Corporation Apparatus and method for maintaining data coherence within a cluster of symmetric multiprocessors
US6035307A (en) * 1998-03-30 2000-03-07 Bmc Software Enterprise data movement system and method including opportunistic performance of utilities and data move operations for improved efficiency
US6952829B1 (en) * 1998-06-29 2005-10-04 International Business Machines Corporation Dynamically adapting between pessimistic and optimistic notifications to replicated objects
US6301643B1 (en) 1998-09-03 2001-10-09 International Business Machines Corporation Multi-environment data consistency
US6802022B1 (en) 2000-04-14 2004-10-05 Stratus Technologies Bermuda Ltd. Maintenance of consistent, redundant mass storage images
US6862689B2 (en) 2001-04-12 2005-03-01 Stratus Technologies Bermuda Ltd. Method and apparatus for managing session information
US6901481B2 (en) 2000-04-14 2005-05-31 Stratus Technologies Bermuda Ltd. Method and apparatus for storing transactional information in persistent memory
US6732193B1 (en) 2000-06-09 2004-05-04 International Business Machines Corporation Method, system, and program for determining a number of write operations to execute
US7404005B1 (en) 2000-06-09 2008-07-22 International Business Machines Corporation Method, system, and program for selecting one of multiple paths to communicate with a device
US6526419B1 (en) 2000-06-09 2003-02-25 International Business Machines Corporation Method, system, and program for remote copy in an open systems environment
US6948010B2 (en) 2000-12-20 2005-09-20 Stratus Technologies Bermuda Ltd. Method and apparatus for efficiently moving portions of a memory block
GB0100753D0 (en) * 2001-01-11 2001-02-21 Bate Matthew Data system
US7054887B2 (en) * 2001-01-30 2006-05-30 Ibm Corporation Method and system for object replication in a content management system
US6886171B2 (en) * 2001-02-20 2005-04-26 Stratus Technologies Bermuda Ltd. Caching for I/O virtual address translation and validation using device drivers
US6766413B2 (en) 2001-03-01 2004-07-20 Stratus Technologies Bermuda Ltd. Systems and methods for caching with file-level granularity
US6874102B2 (en) * 2001-03-05 2005-03-29 Stratus Technologies Bermuda Ltd. Coordinated recalibration of high bandwidth memories in a multiprocessor computer
US6996750B2 (en) * 2001-05-31 2006-02-07 Stratus Technologies Bermuda Ltd. Methods and apparatus for computer bus error termination
GB0202600D0 (en) * 2002-02-05 2002-03-20 Ibm Consolidation of replicated data
US7624158B2 (en) * 2003-01-14 2009-11-24 Eycast Inc. Method and apparatus for transmission and storage of digital medical data
JP4477370B2 (ja) * 2004-01-30 2010-06-09 株式会社日立製作所 データ処理システム
GB0921851D0 (en) * 2009-12-15 2010-01-27 Geniedb Record operation mode setting
US10311027B2 (en) * 2011-09-23 2019-06-04 Open Invention Network, Llc System for live-migration and automated recovery of applications in a distributed system
US10331801B2 (en) 2011-09-23 2019-06-25 Open Invention Network, Llc System for live-migration and automated recovery of applications in a distributed system
GB2495079A (en) 2011-09-23 2013-04-03 Hybrid Logic Ltd Live migration of applications and file systems in a distributed system
US9547705B2 (en) * 2011-09-23 2017-01-17 Hybrid Logic Ltd System for live-migration and automated recovery of applications in a distributed system
US9483542B2 (en) 2011-09-23 2016-11-01 Hybrid Logic Ltd System for live-migration and automated recovery of applications in a distributed system
US9501543B2 (en) 2011-09-23 2016-11-22 Hybrid Logic Ltd System for live-migration and automated recovery of applications in a distributed system
US9477739B2 (en) 2011-09-23 2016-10-25 Hybrid Logic Ltd System for live-migration and automated recovery of applications in a distributed system
US20140019573A1 (en) * 2012-07-16 2014-01-16 Compellent Technologies Source reference replication in a data storage subsystem
US20160218935A1 (en) 2015-01-27 2016-07-28 Bank Of America Corporation User interface and dashboard for holistic data transmission throughout an enterprise

Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH03113544A (ja) * 1989-09-28 1991-05-14 Nec Corp 分散型データ処理装置

Family Cites Families (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US4432057A (en) * 1981-11-27 1984-02-14 International Business Machines Corporation Method for the dynamic replication of data under distributed system control to control utilization of resources in a multiprocessing, distributed data base system
US4620276A (en) * 1983-06-02 1986-10-28 International Business Machines Corporation Method and apparatus for asynchronous processing of dynamic replication messages
US4718002A (en) * 1985-06-05 1988-01-05 Tandem Computers Incorporated Method for multiprocessor communications
US4714996A (en) * 1985-11-26 1987-12-22 International Business Machines Corporation Impact calculation for version management in a distributed information service
US4714992A (en) * 1985-11-26 1987-12-22 International Business Machines Corporation Communication for version management in a distributed information service
US4853843A (en) * 1987-12-18 1989-08-01 Tektronix, Inc. System for merging virtual partitions of a distributed database
US5107419A (en) * 1987-12-23 1992-04-21 International Business Machines Corporation Method of assigning retention and deletion criteria to electronic documents stored in an interactive information handling system
US4899299A (en) * 1987-12-23 1990-02-06 International Business Machines Corporation Method for managing the retention of electronic documents in an interactive information handling system
US5051891A (en) * 1987-12-23 1991-09-24 International Business Machines Corporation Method to manage transfer of ownership of electronic documents stored in an interactive information handling system
JPH0432940A (ja) * 1990-05-23 1992-02-04 Toshiba Corp 分散データベース・システム
US5280612A (en) * 1991-11-26 1994-01-18 International Business Machines Corporation Multiple version database concurrency control system

Patent Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH03113544A (ja) * 1989-09-28 1991-05-14 Nec Corp 分散型データ処理装置

Cited By (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH0981429A (ja) * 1995-09-19 1997-03-28 Mitsubishi Electric Corp キャッシュ管理装置
JPH09307590A (ja) * 1996-05-03 1997-11-28 Mitsubishi Electric Res Lab Inc ネットワークにおけるデータ転送システム
WO2000054157A1 (fr) * 1999-03-08 2000-09-14 Athena Telecom Lab, Inc. Procede et appareil pour la gestion de la duree de validite de donnes dans un systeme de traitement repartie et un support d'enregistrement

Also Published As

Publication number Publication date
GB2273182A (en) 1994-06-08
US5627961A (en) 1997-05-06
EP0600457A2 (en) 1994-06-08
GB9225424D0 (en) 1993-01-27
EP0600457A3 (en) 1995-11-02

Similar Documents

Publication Publication Date Title
JPH06215031A (ja) 分散データ処理装置及び方法
US5737738A (en) Distributed read/write replication with primary copy first write and primary copy transfer features
EP0226734B1 (en) Method and apparatus for managing obsolescence of data objects
US6269432B1 (en) Distributed transactional processing system having redundant data
US5452448A (en) Method of replicate file updating by monitoring file accesses and system therefor
US6944726B2 (en) Distributed background track processing
US4714996A (en) Impact calculation for version management in a distributed information service
US7293009B2 (en) System and method for flushing bean cache
US5640556A (en) Synchronous/asynchronous client server access based upon database file record attribute
US9652346B2 (en) Data consistency control method and software for a distributed replicated database system
US7836162B2 (en) Transaction processing system and transaction processing method
EP0864129A1 (en) Database access
US20060224639A1 (en) Backup system, program and backup method
US6718349B2 (en) Intelligent, optimistic concurrency database access scheme
Rahm Primary copy synchronization for DB-sharing
US8719313B2 (en) Distributed data store with a designated master to ensure consistency
CN113326146A (zh) 一种消息处理方法、装置、电子设备及存储介质
EP1430419B1 (en) Cluster caching with concurrency checking
EP0600458B1 (en) Distributed data processing system with replication of data across the system
JPH03113544A (ja) 分散型データ処理装置
JPH10512985A (ja) トランザクションの状態の追跡
US7136879B2 (en) System and method for read-only entity bean caching
JPH09171480A (ja) 情報記憶システムを備えるネットワークシステム、該システムの入力システムならびに自動運用システム、および該ネットワークシステムの自動運用方法
JPH04310146A (ja) 分散処理システムにおけるデータ一元管理方式