JP5469573B2 - Information synchronization system, information synchronization program, and information synchronization method - Google Patents
Information synchronization system, information synchronization program, and information synchronization method Download PDFInfo
- Publication number
- JP5469573B2 JP5469573B2 JP2010209000A JP2010209000A JP5469573B2 JP 5469573 B2 JP5469573 B2 JP 5469573B2 JP 2010209000 A JP2010209000 A JP 2010209000A JP 2010209000 A JP2010209000 A JP 2010209000A JP 5469573 B2 JP5469573 B2 JP 5469573B2
- Authority
- JP
- Japan
- Prior art keywords
- update
- time stamp
- update history
- master information
- information
- 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.)
- Active
Links
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Description
本発明は、情報を同期する処理において、装置の処理負荷を軽減することができる情報同期システム等の技術に関する。 The present invention relates to a technology such as an information synchronization system that can reduce a processing load on an apparatus in a process of synchronizing information.
従来の一般的な情報配信または情報同期方式においては、図１２に示すように、情報サーバシステム１０１における更新処理部１１２がマスタ情報１１１を更新する時に、ネットワーク１０３を介して、マスタ情報１１１を利用する複数の情報クライアントシステム１０２の情報１２２に対し同様の更新を行う。
In the conventional general information distribution or information synchronization method, as shown in FIG. 12, when the update processing unit 112 in the
また、図１３に示すように、情報クライアントシステム１０２そのものがさらに情報サーバシステム２０１と情報クライアントシステム２０２（２０２Ａ、２０２Ｂ、…）とネットワーク２０３によって階層的に構成されることもある。このような場合にも、更新処理部１１２がマスタ情報１１１を更新する時に、ネットワーク１０３を介して、情報１２２Ａに対し同様の更新を行い、情報１２２Ａの更新がされた時に、ネットワーク２０３を介して、情報２２２（２２２Ａ、２２２Ｂ、…）に対し同様の更新が階層的に行われる。
As shown in FIG. 13, the
また、特許文献１に開示された技術では、情報サーバシステムは、マスタ情報の情報ごとに更新時刻を保持し、情報クライアントシステムへの手動コピー開始時刻とマスタ情報の情報ごとの更新時刻を比較することにより、マスタ情報の当該情報の更新時刻の方が新しい場合には、マスタ情報の当該情報を更新した時に、情報クライアントシステムへコピーを行うことが提案されている。
In the technology disclosed in
しかし、上述した方法では、情報サーバシステムにおけるマスタ情報が更新される時に、情報クライアントシステムの情報に対しても更新を行うと、例えば、情報クライアントシステムがその情報同期処理よりも優先度の高い処理を実行している場合、情報サーバシステムの更新同期要求がその優先度の高い処理を妨げるおそれがあるなどの問題がある。すなわち、上述した方法では、いずれも更新が発生した側の装置から更新要求をしていることが問題となっている。 However, in the above-described method, when the master information in the information server system is updated, if the information in the information client system is also updated, for example, the information client system has a higher priority than the information synchronization processing. When the process is executed, there is a problem that an update synchronization request of the information server system may interfere with a process having a high priority. That is, the above-described methods have a problem in that an update request is issued from the device on which the update has occurred.
また、階層的な構成の場合、従来の方法では、図１３に示すように、複数の情報クライアントシステム１０２（１０２Ａ、１０２Ｂ、…）の情報１２２（１２２Ａ、１２２Ｂ、…）は同期可能であるが、階層的な情報クライアントシステム２０２（２０２Ａ、２０２Ｂ、…）の情報２２２（２２２Ａ、２２２Ｂ、…）については、ネットワーク１０３とネットワーク２０３が同時に接続されていなければ情報同期することができないという問題がある。
In the case of a hierarchical configuration, the conventional method can synchronize information 122 (122A, 122B,...) Of a plurality of information client systems 102 (102A, 102B,...) As shown in FIG. The information 222 (222A, 222B,...) Of the hierarchical information client system 202 (202A, 202B,...) Cannot be synchronized unless the
そこで、本発明は、前記問題に鑑みてなされたものであり、情報を同期する処理において、装置の処理負荷を軽減することができる情報同期システム、情報同期プログラムおよび情報同期方法を提供することを課題とする。 Therefore, the present invention has been made in view of the above problems, and provides an information synchronization system, an information synchronization program, and an information synchronization method that can reduce the processing load of the apparatus in the process of synchronizing information. Let it be an issue.
前記課題を解決するために、本発明の情報同期システムは、マスタ情報を保持する第１の装置と、前記マスタ情報を利用する第２の装置と、を備える情報同期システムであって、前記第１の装置は、前記マスタ情報を記憶する第１マスタ情報記憶部と、前記マスタ情報の更新処理を行う更新処理部と、前記マスタ情報の更新履歴を時系列で記憶する第１更新履歴記憶部と、前記第２の装置からの次回の更新の起点を示す起点時刻スタンプの時刻からの前記更新履歴を要求する更新履歴要求に対し、前記第１更新履歴記憶部に記憶された更新履歴を前記第２の装置に返す処理をする第１更新要求応答部と、前記マスタ情報の更新履歴において、互いに関連のある情報である意味的に不可分な一連の更新履歴を分解しないように、前記マスタ情報に登録されている更新履歴の時刻スタンプを終点時刻スタンプとして記憶する終点時刻スタンプ記憶部とを備え、前記第２の装置は、前記マスタ情報と同期したデータである第２マスタ情報を記憶する第２マスタ情報記憶部と、前記起点時刻スタンプを記憶する起点時刻スタンプ記憶部と、第１の装置に対し前記起点時刻スタンプの時刻からの更新履歴を要求する更新履歴要求部と、前記更新履歴要求部が受信した更新履歴に基づいて、同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを前記起点時刻スタンプとして前記起点時刻スタンプ記憶部に記憶させる同期更新処理部と、を備え、前記第１の装置の前記第１更新要求応答部は、前記第２の装置からの更新履歴要求に対し、前記起点時刻スタンプおよび前記終点時刻スタンプに基づいて、前記第１更新履歴記憶部に記憶された更新履歴を前記第２の装置に返す処理をし、前記第２の装置の前記同期更新処理部は、前記終点時刻スタンプで前記起点時刻スタンプを更新することを特徴とする。 In order to solve the above problem, an information synchronization system of the present invention is an information synchronization system comprising a first device that holds master information and a second device that uses the master information, 1 apparatus includes a first master information storage unit that stores the master information, an update processing unit that performs an update process of the master information, and a first update history storage unit that stores an update history of the master information in time series When, the relative update history requesting update history request, the update history of previous SL stored in the first update history storage unit from the time of start time stamp indicating a start point of the next update from the second device In the update history of the first update request response unit that performs processing to be returned to the second device and the master information, the master information so as not to decompose a semantically inseparable series of update histories that are mutually related information information And a end point time stamp storage unit that stores as the end point time stamp the time stamp of the update history that is registered, the second device, the second storing a second master information is data synchronized with the master information A master information storage unit; an origin time stamp storage unit that stores the origin time stamp; an update history request unit that requests an update history from the time of the origin time stamp to the first device; and the update history request unit A synchronization update processing unit that performs update processing for synchronization based on the received update history and stores the time stamp of the latest update history that has been synchronized in the start time stamp storage unit as the start time stamp; , wherein the first update request response unit of the first device to update history request from the second device, the start time stamp Contact And the process of returning the update history stored in the first update history storage unit to the second device based on the end point time stamp, and the synchronous update processing unit of the second device includes the end point time The starting time stamp is updated with a stamp .
本発明によれば、情報を同期する処理において、装置の処理負荷を軽減することができる。 ADVANTAGE OF THE INVENTION According to this invention, in the process which synchronizes information, the processing load of an apparatus can be reduced.
＜第１実施形態＞
以下、本発明の第１実施形態について、図１〜図６を参照して説明する。
[情報同期システム１の構成]
図１に示すように、情報同期システム１は、マスタ情報を保持する第１の装置１０と、そのマスタ情報を利用する第２の装置２０とを備えている。第１の装置は、例えば、情報サーバシステムであり、第２の装置は、例えば、情報クライアントシステムである。第２の装置２０は、ネットワーク３０を介して、第１の装置１０に接続されている。
<First Embodiment>
Hereinafter, a first embodiment of the present invention will be described with reference to FIGS.
[Configuration of information synchronization system 1]
As shown in FIG. 1, the
[第１の装置１０の構成]
第１の装置１０は、第１マスタ情報記憶部１１と、更新処理部１２と、第１更新履歴記憶部１３と、第１更新要求応答部１４とを備えている。
[Configuration of the first apparatus 10]
The
第１マスタ情報記憶部１１は、マスタ情報を記憶するものである。マスタ情報とは、基本的な情報を集約したファイルやデータベースにおけるテーブル等のことである。
更新処理部１２は、マスタ情報の更新履歴を、後記する第１更新履歴記憶部１３に記憶させるとともに、第１マスタ情報記憶部１１に記憶されたマスタ情報を更新するものである。
The first master
The
第１更新履歴記憶部１３は、マスタ情報のすべての更新履歴を記憶するものである。
ここで、更新履歴について図２を参照して説明する。
図２に示すように、更新履歴４０は、例えば、更新種別４１と、情報種別４２と、更新履歴の時刻スタンプ４３と、更新内容４４とを含んでいる。
更新種別４１には、新規、変更および削除の種別がある。
情報種別４２には、典型的には１つのテーブルで管理される区分ごとの情報の種別がある。ここでは例えば、グループ情報、ユーザ情報、ＩＣカード情報およびＩＤ・パスワードである。
The first update
Here, the update history will be described with reference to FIG.
As illustrated in FIG. 2, the
The
The
更新履歴の時刻スタンプ４３は、シーケンス番号で管理している。なお、更新履歴の時刻スタンプ４３は、日付時刻やシステム起点からの経過時間等、システム内における時間的な前後（新旧）を判定することができるものであれば任意の形式でよい。
更新内容４４は、マスタ情報を更新する内容であり、情報ラベルおよび更新内容等がある。なお、更新内容４４は、更新をする情報を特定するものと、その情報を更新する内容が記述されていれば、他の形式でもよい。
The
The
また、この更新履歴４０には、意味的に不可分な一連の更新履歴が入ってくることがある。意味的に不可分な一連の更新履歴とは、一斉に処理されるべき更新履歴である。
例えば、カードのユーザ名、そのユーザのカード情報およびそのカードのパスワードのデータがデータベースに保存されている場合に、ユーザ名だけが削除され、カード情報およびパスワードのデータが残っていると、第三者にカードを使われるなどの不都合が生じる。そのため、ユーザ名が削除されたときには、カード情報およびパスワードも同時に削除される必要がある。
シーケンス番号８から１０が示す更新履歴は、ユーザ情報、ＩＣカード情報およびＩＤ・パスワードの削除であるが、これらの削除処理は互いに関連のある情報を削除する処理であり、意味的にこれらの更新履歴は不可分であることがある。この場合、シーケンス番号８のみを処理した段階で、マスタ情報が他から参照されることがあってはならない。
The
For example, when the card user name, the card information of the user, and the password data of the card are stored in the database, if only the user name is deleted and the card information and password data remain, the third Inconveniences such as use of a card by a person occur. Therefore, when the user name is deleted, it is necessary to delete the card information and the password at the same time.
The update history indicated by the
図１に戻り、第１の装置１０の構成の続きを説明する。
第１更新要求応答部１４は、後記する第２の装置２０からの更新履歴要求に対し第１更新履歴記憶部１３に記憶された更新履歴のうち、第２の装置２０から指定された更新の起点を示す起点時刻スタンプより新しい更新履歴の時刻スタンプを持つ更新履歴を第２の装置２０に返すものである。
Returning to FIG. 1, the continuation of the configuration of the
In response to an update history request from the
[第２の装置２０の構成]
第２の装置２０は、第２マスタ情報記憶部２１と、起点時刻スタンプ記憶部２２と、更新履歴要求部２３と、同期更新処理部２４とを備えている。
[Configuration of Second Device 20]
The
第２マスタ情報記憶部２１は、第１の装置１０のマスタ情報と同期したデータである第２マスタ情報を記憶するものである。
起点時刻スタンプ記憶部２２は、次回の更新の起点を示す起点時刻スタンプを記憶するものである。
更新履歴要求部２３は、第１の装置１０に対し起点時刻スタンプからの更新履歴を要求するものである。
同期更新処理部２４は、更新履歴要求部２３が取得した更新履歴に基づいて、第２マスタ情報記憶部２１に対し同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを、起点時刻スタンプとして起点時刻スタンプ記憶部２２に記憶させるものである。
The second master
The start time
The update
The synchronous
また、第２の装置２０そのものが、情報サーバシステム２０１と、情報クライアントシステム（第３の装置）２０２（２０２Ａ、２０２Ｂ、…）と、ネットワーク２０３とを階層的に備える場合もある。この場合には、第２の装置２０は、第２更新履歴記憶部２５と、第２更新要求応答部２６とをさらに備える。
第２更新履歴記憶部２５は、第２マスタ情報の更新履歴を第２更新履歴として記憶するものである。
第２更新要求応答部２６は、第３の装置２０２（２０２Ａ、２０２Ｂ、…）からの更新履歴要求に対し第２更新履歴記憶部２５に記憶された更新履歴のうち、第３の装置２０２（２０２Ａ、２０２Ｂ、…）から指定された更新の起点を示す起点時刻スタンプより新しい更新履歴の時刻スタンプを持つ更新履歴を第３の装置２０２（２０２Ａ、２０２Ｂ、…）に返すものである。
The
The second update
The second update
[第３の装置２０２（２０２Ａ、２０２Ｂ、…）の構成]
第３の装置２０２（２０２Ａ、２０２Ｂ、…）の構成は、図示を省略したが、第２マスタ情報記憶部２１に相当する第３マスタ情報記憶部と、起点時刻スタンプ記憶部２２に相当する第２起点時刻スタンプ記憶部と、更新履歴要求部２３に相当する第２更新履歴要求部と、同期更新処理部２４に相当する第２同期更新処理部とを備える。
[Configuration of Third Device 202 (202A, 202B, ...)]
The configuration of the third device 202 (202A, 202B,...) Is omitted from illustration, but a third master information storage unit corresponding to the second master
[情報同期システム１の動作]
次に、情報同期システム１の動作について図３〜図６を参照して説明する。
[第１の装置１０の更新処理動作]
まず、第１の装置１０の更新処理動作について図３を参照して説明する。
図３のフローチャートに示すように、ステップＳ１１において、更新処理部１２は、第１マスタ情報記憶部１１の排他ロックを要求する。なお、排他ロックとは、他からのアクセスを禁止するものである。
[Operation of information synchronization system 1]
Next, the operation of the
[Update processing operation of first device 10]
First, the update processing operation of the
As shown in the flowchart of FIG. 3, in step S <b> 11, the
ステップＳ１２において、更新処理部１２は、第１マスタ情報記憶部１１の排他ロックを取得したか否かを判定する。排他ロックを取得していない場合は（ステップＳ１２・Ｎｏ）、更新処理部１２は、第１マスタ情報記憶部１１の排他ロックの取得を待つ（ステップＳ１３）。次にステップＳ１１に戻る。
一方、排他ロックを取得した場合は（ステップＳ１２・Ｙｅｓ）、ステップＳ１４において、更新処理部１２は、マスタ情報の更新履歴を時系列で第１更新履歴記憶部１３に記憶させる。
In step S <b> 12, the
On the other hand, when the exclusive lock is acquired (step S12 / Yes), in step S14, the
ステップＳ１５において、更新処理部１２は、マスタ情報を更新する。
ステップＳ１６において、更新処理部１２は、第１マスタ情報記憶部１１の排他ロックを解放する。
In step S15, the
In step S <b> 16, the
なお、意味的に不可分な一連の更新履歴については、１回の排他ロック取得の中で、それらのマスタ情報を更新する必要がある。この場合、ステップＳ１４およびステップＳ１５を繰り返すこととなる。
また、図示していないが、ステップＳ１５において、更新処理部１２がマスタ情報の更新を失敗した場合は、更新処理部１２はステップＳ１４において記憶した更新履歴を破棄し、更新処理は終了する。
It should be noted that for a series of update histories that are semantically inseparable, it is necessary to update their master information in one exclusive lock acquisition. In this case, step S14 and step S15 are repeated.
Although not shown, when the
[情報同期システム１の同期処理動作]
次に、情報同期システム１の同期処理動作について図４を参照して説明する。
この同期処理は、第２の装置（情報クライアントシステム）２０の更新履歴要求部２３が自らの要件により定めたタイミングで開始する。例えば、第２の装置２０の処理負荷が高い時間帯は先延ばしにする等、周期的あるいは動的に、更新履歴要求部２３は、この同期処理を開始する。
[Synchronization processing operation of information synchronization system 1]
Next, the synchronization processing operation of the
This synchronization processing starts at a timing determined by the update
図４のフローチャートに示すように、ステップＳ１において、更新履歴要求部２３は、起点時刻スタンプ記憶部２２に起点時刻スタンプが記憶されているか否かを判定する。起点時刻スタンプが記憶されていない場合には（ステップＳ１・Ｎｏ）、更新履歴要求部２３は、同期更新処理部２４を介して、起点時刻スタンプを、システム起点時刻、システム起点からの経過時間０またはシーケンス番号０で更新して起点時刻スタンプ記憶部２２に記憶する（ステップＳ２）。次にステップＳ３へ進む。
As shown in the flowchart of FIG. 4, in step S <b> 1, the update
一方、起点時刻スタンプが記憶されている場合には（ステップＳ１・Ｙｅｓ）、ステップＳ３において、更新履歴要求部２３は、当該起点時刻スタンプからの更新履歴を第１の装置（情報サーバシステム）１０に対して要求する。ここで、更新履歴要求部２３は、第２の装置にとって必要な情報種別を指定して、その情報種別の更新履歴のみを要求してもよい。
ステップＳ４において、第１の装置１０の第１更新要求応答部１４は、第２の装置２０の更新履歴要求部２３からの更新履歴要求に対し、当該起点時刻スタンプに基づいて、第１更新履歴記憶部１３に記憶された更新履歴を第２の装置２０に返す。なお、このステップにおける処理は後に詳述する。
On the other hand, when the starting time stamp is stored (step S1 / Yes), in step S3, the update
In step S4, the first update
ステップＳ５において、更新履歴要求部２３は、第１更新要求応答部１４からの更新履歴を受信する。
ステップＳ６において、更新履歴要求部２３は、起点時刻スタンプ記憶部２２に起点時刻スタンプが記憶されているか否かを判定する。起点時刻スタンプが記憶されていない場合には（ステップＳ６・Ｎｏ）、更新履歴要求部２３は、同期更新処理部２４を介して、第２マスタ情報記憶部２１に記憶された第２マスタ情報と第２更新履歴記憶部２５に記憶された第２更新履歴をすべて破棄する（ステップＳ７）。次にステップＳ８へ進む。
In step S <b> 5, the update
In step S <b> 6, the update
一方、起点時刻スタンプが記憶されている場合には（ステップＳ６・Ｙｅｓ）、ステップＳ８において、同期更新処理部２４は、同期更新処理を行う。なお、このステップにおける処理は後に詳述する。
On the other hand, when the starting time stamp is stored (step S6 / Yes), in step S8, the synchronous
なお、図示していないが、ステップＳ５において、第１の装置１０またはネットワーク３０のいずれかの障害により、更新履歴要求部２３が更新履歴を受信できなかった場合は、同期処理は終了し、次の同期処理は、再度、ステップＳ１から行う。
Although not shown, in step S5, if the update
ここで、起点時刻スタンプが記憶されていない場合（ステップＳ１・Ｎｏ、ステップＳ６・Ｎｏ）について補足説明する。なお、ステップＳ１でＮｏと判定されたときは、必ず、ステップＳ６でＮｏと判定される。
同期処理がこの流れに従って行われるのは、例えば、情報同期システムの電源を入れた直後であり、初めて同期処理を行う場合がある。あるいは、同期更新処理部２４が、第１の装置１０の第１マスタ情報記憶部１１に記憶されたマスタ情報と、第２の装置２０の第２マスタ情報記憶部２１に記憶された第２マスタ情報とが不整合であることを検出した場合がある。図示していないが、同期更新処理部２４は、不整合を検出したときは、起点時刻スタンプ記憶部２２に記憶された起点時刻スタンプを破棄する。これにより、同期処理がこの流れに従って行われるようになる。
Here, a supplementary explanation will be given for the case where the starting time stamp is not stored (
The synchronization process is performed according to this flow, for example, immediately after the information synchronization system is turned on, and the synchronization process may be performed for the first time. Alternatively, the synchronous
ステップＳ２において、起点時刻スタンプを、システム起点時刻、システム起点からの経過時間０またはシーケンス番号０で更新しているのは、第１の装置１０の第１マスタ情報記憶部１１に記憶されたマスタ情報に対するすべての更新履歴の時刻スタンプより前の起点時刻スタンプとするためである。そうすると、ステップＳ５において、更新履歴要求部２３は、第１マスタ情報記憶部１１に記憶されたマスタ情報に対するすべての更新履歴を受信する。
ステップＳ７において、同期更新処理部２４は、第２マスタ情報記憶部２１に記憶された第２マスタ情報と、第２更新履歴記憶部２５に記憶された第２更新履歴とを破棄した上で、ステップＳ８において、同期更新処理を行うため、第２マスタ情報と第２更新履歴とを自動的に構築しなおすことができる。
In step S2, the start time stamp is updated with the system start time, the elapsed time from the system start time 0, or the sequence number 0. The master stored in the first master
In step S7, the synchronous
[第１の装置１０における第１更新要求応答部１４の更新要求応答処理動作]
次に、第１の装置１０における第１更新要求応答部１４の更新要求応答処理（図４、ステップＳ４参照）動作について図５を参照して説明する。
図５のフローチャートに示すように、ステップＳ４１において、第１更新要求応答部１４は、更新処理部１２の排他ロックを要求する。
[Update request response processing operation of the first update
Next, the update request response processing (see FIG. 4, step S4) operation of the first update
As shown in the flowchart of FIG. 5, in step S <b> 41, the first update
ステップＳ４２において、第１更新要求応答部１４は、更新処理部１２の排他ロックを取得したか否かを判定する。排他ロックを取得していない場合は（ステップＳ４２・Ｎｏ）、第１更新要求応答部１４は、更新処理部１２の排他ロックの取得を待つ（ステップＳ４３）。次にステップＳ４１に戻る。
一方、排他ロックを取得した場合は（ステップＳ４２・Ｙｅｓ）、ステップＳ４４において、第１更新要求応答部１４は、第１更新履歴記憶部１３に記憶されたすべての更新履歴のうち、第２の装置２０から指定された起点時刻スタンプより新しい時刻スタンプを持つ更新履歴を時系列に取得する。
In step S <b> 42, the first update
On the other hand, when the exclusive lock has been acquired (step S42 / Yes), in step S44, the first update
ステップＳ４５において、第１更新要求応答部１４は、更新処理部１２の排他ロックを解放する。
ステップＳ４６において、第１更新要求応答部１４は、取得した更新履歴を第２の装置２０へ返す。
In step S45, the first update
In step S <b> 46, the first update
[第２の装置２０における同期更新処理部２４の同期更新処理動作]
次に、第２の装置２０における同期更新処理部２４の同期更新処理（図４、ステップＳ８参照）動作について図６を参照して説明する。なお、この同期更新処理の前のステップにおいて、第２の装置２０の更新履歴要求部２３は、自ら指定した起点時刻スタンプからの更新履歴を受信している（図４参照、ステップＳ５）。
[Synchronous Update Processing Operation of Synchronous
Next, the synchronous update processing (see FIG. 4, step S8) operation of the synchronous
図６のフローチャートに示すように、ステップＳ８１において、同期更新処理部２４は、更新履歴要求部２３が受信した更新履歴のうち、時刻スタンプが最も古いものから順に処理するために、受信した更新履歴の時刻スタンプを順次探索していく。同期更新処理部２４は、次の（未だ更新処理を行っていない）更新履歴が存在するか否かを判定する。
次の更新履歴が存在しない場合には（ステップＳ８１・Ｎｏ）、同期更新処理部２４は、同期更新処理を終了する。
As shown in the flowchart of FIG. 6, in step S <b> 81, the synchronous
When the next update history does not exist (step S81 / No), the synchronous
一方、次の更新履歴が存在する場合には（ステップＳ８１・Ｙｅｓ）、ステップＳ８２において、同期更新処理部２４は、未だ更新処理を行っていない最も古い時刻スタンプを持つ更新履歴に基づいて、同期のための更新処理を第２マスタ情報記憶部２１に対して行う。
なお、ここで、同期が必要な情報種別の更新履歴のみについて更新処理を行ってもよい。
ステップＳ８３において、同期更新処理部２４は、起点時刻スタンプ記憶部２２に記憶されている起点時刻スタンプを、更新処理を行った更新履歴の時刻スタンプで更新する。
On the other hand, when the next update history exists (step S81 / Yes), in step S82, the synchronous
Here, the update process may be performed only for the update history of the information type that needs to be synchronized.
In step S83, the synchronous
ステップＳ８４において、同期更新処理部２４は、自らを情報サーバシステムとして同期する情報クライアントシステムが階層的に存在するか否かを判定する。情報クライアントシステムが階層的に存在しない場合には（ステップＳ８４・Ｎｏ）、同期更新処理部２４は、ステップＳ８１に戻る。
一方、情報クライアントシステムが階層的に存在する場合には（ステップＳ８４・Ｙｅｓ）、同期更新処理部２４は、当該情報クライアントシステム（第３の装置２０２Ａ）に対する更新要求応答処理において更新履歴を取得できるように、更新履歴を時系列で第２更新履歴記憶部２５に記憶させる。次にステップＳ８１に戻る。
In step S84, the synchronization
On the other hand, when the information client system exists hierarchically (step S84, Yes), the synchronous
以上の動作によって、第２の装置２０の更新履歴要求部２３が自らの要件により定めたタイミングで同期処理を開始できるため、第２の装置２０が同期処理よりも優先度の高い処理を実行している場合は、第１の装置１０への更新履歴の要求を先延ばしにして、第２の装置２０の処理負荷を平準化することができる。
With the above operation, the update
また、複数の第２の装置２０（２０Ａ、２０Ｂ、…）ごとに、情報の保持方法が異なる場合、例えば、データベース管理システム・リレーショナルデータベースあるいは階層型データベース等によって保持する場合、テキストファイル・バイナリファイルあるいは表計算ソフトウェア等の専用ファイルとして保持する場合、不揮発メモリや揮発メモリ上に独自の構造で保持する場合等、様々な保持方法がある。
このような場合、第１の装置１０と複数の第２の装置２０（２０Ａ、２０Ｂ、…）で構成された全システムがすでに稼働中に、新たな第２の装置２０Ｘ（図示せず）を情報同期対象として追加しようとすると、その追加する第２の装置２０Ｘの情報保持方法によっては、第１の装置１０の更新処理部１２の処理内容を変更する必要がある。更新処理部１２の変更を行っている時間は、マスタ情報の更新がすべての第２の装置２０へ同期されない。
よって、更新処理部１２の処理内容変更後に手動でコピーするか、またはその時間帯のマスタ情報の更新を禁止する必要がある。いずれの場合でもサービス停止期間が発生するという問題がある。
しかし、本発明によれば、実際に情報の同期を行うのは第２の装置２０であるため、第１の装置１０と複数の第２の装置２０で構成された全システムが稼働中でも、新たな第２の装置２０を情報同期対象に追加することができる。
In addition, when the information holding method is different for each of the plurality of second devices 20 (20A, 20B,...), For example, when they are held by a database management system, a relational database, a hierarchical database, etc. Alternatively, there are various holding methods such as holding as a dedicated file such as spreadsheet software or holding it in a non-volatile memory or volatile memory with a unique structure.
In such a case, a new second device 20X (not shown) is installed while the entire system composed of the
Therefore, it is necessary to manually copy after changing the processing contents of the
However, according to the present invention, since it is the
また、第２の装置２０は、必要な情報種別の更新履歴のみについて同期を行うことにより、冗長な同期処理を防ぐことができる。
Further, the
また、階層的な構成の場合、各段階における情報クライアントシステムは自らの情報同期先に対してのみ更新履歴の要求を行うため、マスタ情報を持つ情報サーバシステムが段階的な階層を構成するすべての情報クライアントシステムを管理する必要がない。それぞれの情報クライアントシステムが、自らの情報同期先のみを管理することで十分である。 In addition, in the case of a hierarchical configuration, the information client system at each stage requests an update history only to its own information synchronization destination, so all the information server systems having master information constitute a hierarchical hierarchy. There is no need to manage the information client system. It is sufficient for each information client system to manage only its own information synchronization destination.
さらに、従来の方法では、第１の装置１０は、複数あるすべての第２の装置２０（２０Ａ、２０Ｂ、…）の稼働状況を監視し、ある第２の装置２０Ｘ（図示せず）が不稼動状態の間のマスタ情報に対する更新については別途保存しておく必要がある。そして、第２の装置２０Ｘの再稼動後に第１の装置１０の更新処理部１２は、保存していた情報を第２の装置２０Ｘに対して更新する、あるいは、第１の装置のサービスを停止して手動でマスタ情報を第２の装置２０Ｘにコピーする等のリカバリーが必要である。
しかし、本発明によれば、第１の装置１０は、第２の装置２０からの要求により更新履歴を返すため、すべての第２の装置２０（２０Ａ、２０Ｂ、…）の稼働状況を監視する必要がない。すなわち、既存の第１の装置と既存の第２の装置は稼動させたまま新たな第２の装置２０Ｙ（図示せず）を同期対象に追加することも、既存の第２の装置を一時停止させることも、稼働中の第１の装置１０と稼働中の他の第２の装置２０に影響を与えることなく行うことができる。
Further, in the conventional method, the
However, according to the present invention, since the
＜第２実施形態＞
次に、本発明の第２実施形態について、図７〜図１１を参照して説明する。なお、同一の構成には同一の符号を付して、重複する説明は省略する。
[情報同期システム１ａの構成]
図７に示すように、第１の装置１０ａは、更新処理部１２ａと、第１更新要求応答部１４ａと、終点時刻スタンプ記憶部１５とを備えている。
第２の装置２０ａは、起点・終点時刻スタンプ記憶部２２ａを備えている。なお、階層的な構成は第１実施形態と同様である。
Second Embodiment
Next, a second embodiment of the present invention will be described with reference to FIGS. In addition, the same code | symbol is attached | subjected to the same structure and the overlapping description is abbreviate | omitted.
[Configuration of
As shown in FIG. 7, the
The
更新処理部１２ａは、第１実施形態における更新処理部１２の機能に加え、さらに意味的に不可分な一連の更新履歴を分解しない最新の更新履歴の時刻スタンプを終点時刻スタンプとして、後記する終点時刻スタンプ記憶部１５に記憶させるものである。
第１更新要求応答部１４ａは、第２の装置２０ａからの更新履歴要求に対し、起点時刻スタンプより新しく、かつ、終点時刻スタンプ以前の時刻スタンプを持つ、第１更新履歴記憶部１３に記憶された更新履歴を第２の装置２０ａに返すものである。
終点時刻スタンプ記憶部１５は、終点時刻スタンプを記憶するものである。
起点・終点時刻スタンプ記憶部２２ａは、起点時刻スタンプおよび終点時刻スタンプを記憶するものである。
In addition to the functions of the
The first update
The end point time
The start / end time
[情報同期システム１ａの動作]
次に、情報同期システム１ａの動作について図８〜図１１を参照して説明する。
図８のフローチャートに示すように、ステップＳ１０１において、更新履歴要求部２３は、第１の装置１０ａの第１更新要求応答部１４ａに対し、終点時刻スタンプを要求する。
ステップＳ１０２において、第１更新要求応答部１４ａは、終点時刻スタンプ返信処理を行う。なお、このステップにおける処理は後に詳述する。
[Operation of
Next, the operation of the
As shown in the flowchart of FIG. 8, in step S101, the update
In step S102, the first update
ステップＳ１０３において、更新履歴要求部２３は、終点時刻スタンプを受信し、起点・終点時刻スタンプ記憶部２２ａに終点時刻スタンプを記憶させる。
ステップＳ１０４において、更新履歴要求部２３は、起点・終点時刻スタンプ記憶部２２ａに起点時刻スタンプが記憶されているか否かを判定する。起点時刻スタンプが記憶されていない場合には（ステップＳ１０４・Ｎｏ）、更新履歴要求部２３は、同期更新処理部２４を介して、第２マスタ情報記憶部２１に記憶された第２マスタ情報と第２更新履歴記憶部２５に記憶された第２更新履歴をすべて破棄し、起点時刻スタンプを、システム起点時刻、システム起点からの経過時間０またはシーケンス番号０で更新して起点・終点時刻スタンプ記憶部２２ａに記憶する（ステップＳ１０５）。次にステップＳ１０６へ進む。
In step S103, the update
In step S104, the update
一方、起点時刻スタンプが記憶されている場合には（ステップＳ１０４・Ｙｅｓ）、ステップＳ１０６において、更新履歴要求部２３は、起点・終点時刻スタンプ記憶部２２ａに記憶された起点時刻スタンプ、終点時刻スタンプおよび情報種別を指定して、更新履歴を第１の装置１０ａに対して要求する。
ステップＳ１０７において、第１更新要求応答部１４ａは、更新要求応答処理を行う。なお、このステップにおける処理は後に詳述する。
On the other hand, when the starting time stamp is stored (step S104 / Yes), in step S106, the update
In step S107, the first update
ステップＳ１０８において、更新履歴要求部２３は、第１更新要求応答部１４ａからの更新履歴を受信する。
ステップＳ１０９において、同期更新処理部２４は、同期更新処理を行う。なお、このステップにおける処理は後に詳述する。
In step S108, the update
In step S109, the synchronous
ステップＳ１１０において、更新履歴要求部２３は、他に更新が必要な情報種別が存在するか否かを判定する。他に更新が必要な情報種別が存在する場合には（ステップＳ１１０・Ｙｅｓ）、ステップＳ１０６に戻って、更新履歴要求部２３は、その情報種別を指定して更新履歴を要求する。
一方、他に更新が必要な情報種別が存在しない場合には（ステップＳ１１０・Ｎｏ）、ステップＳ１１１において、同期更新処理部２４は、起点時刻スタンプを終点時刻スタンプで更新する。
In step S110, the update
On the other hand, if there is no other information type that needs to be updated (No at Step S110), in Step S111, the synchronous
[第１の装置１０ａにおける第１更新要求応答部１４ａの終点時刻スタンプ返信処理動作]
次に、第１の装置１０ａにおける第１更新要求応答部１４ａの終点時刻スタンプ返信処理（図８、ステップＳ１０２参照）動作について図９を参照して説明する。
図９のフローチャートに示すように、ステップＳ１２１において、第１更新要求応答部１４ａは、更新処理部１２ａの排他ロックを要求する。
[End point time stamp reply processing operation of the first update
Next, the operation of returning the end point time stamp (see FIG. 8, step S102) of the first update
As shown in the flowchart of FIG. 9, in step S121, the first update
ステップＳ１２２において、第１更新要求応答部１４ａは、更新処理部１２ａの排他ロックを取得したか否かを判定する。排他ロックを取得していない場合は（ステップＳ１２２・Ｎｏ）、第１更新要求応答部１４ａは、更新処理部１２ａの排他ロックの取得を待つ（ステップＳ１２３）。次にステップＳ１２１に戻る。
一方、排他ロックを取得した場合は（ステップＳ１２２・Ｙｅｓ）、ステップＳ１２４において、第１更新要求応答部１４ａは、終点時刻スタンプ記憶部１５に記憶された終点時刻スタンプを取得する。
In step S122, the first update
On the other hand, when the exclusive lock has been acquired (step S122: Yes), in step S124, the first update
ステップＳ１２５において、第１更新要求応答部１４ａは、更新処理部１２ａの排他ロックを解放する。
ステップＳ１２６において、第１更新要求応答部１４ａは、取得した終点時刻スタンプを第２の装置２０ａへ返す。
In step S125, the first update
In step S126, the first update
[第１の装置１０ａにおける第１更新要求応答部１４ａの更新要求応答処理動作]
次に、第１の装置１０ａにおける第１更新要求応答部１４ａの更新要求応答処理（図８、ステップＳ１０７参照）動作について図１０を参照して説明する。
図１０のフローチャートに示すように、ステップＳ１７１において、第１更新要求応答部１４ａは、第１更新履歴記憶部１３に記憶されたすべての更新履歴のうち、第２の装置２０ａから指定された起点時刻スタンプより新しく、かつ、終点時刻スタンプ以前の時刻スタンプを持ち、かつ、指定された情報種別の更新履歴を時系列で取得する。
[Update request response processing operation of the first update
Next, the update request response processing (see FIG. 8, step S107) operation of the first update
As shown in the flowchart of FIG. 10, in step S171, the first update
ステップＳ１７２において、第１更新要求応答部１４ａは、取得した更新履歴を第２の装置２０ａへ返す。
なお、第１実施形態と異なり、第１更新要求応答部１４ａが更新処理部１２ａの排他ロックを取得する必要がないのは、更新履歴を取得する際に終点時刻スタンプを範囲指定に使用しているからである。
In step S172, the first update
Unlike the first embodiment, the first update
[第２の装置２０ａにおける同期更新処理部２４の同期更新処理動作]
次に、第２の装置２０ａにおける同期更新処理部２４の同期更新処理（図８、ステップＳ１０９参照）動作について図１１を参照して説明する。なお、この同期更新処理の前のステップにおいて、第２の装置２０ａの更新履歴要求部２３は、第１の装置１０ａからの更新履歴を受信している（図８参照、ステップＳ１０８）。また、ここでは、第１実施形態における同期更新処理との違いについてのみ説明する。
[Synchronous Update Processing Operation of Synchronous
Next, the synchronous update processing (see FIG. 8, step S109) operation of the synchronous
第１実施形態における同期更新処理との違いは、ステップＳ１９２において同期のための更新処理を行った後、起点時刻スタンプを更新履歴の時刻スタンプで更新しないことである。
これは、第２実施形態では、更新処理ごとに起点時刻スタンプを更新するのではなく、意味的に不可分な一連の更新履歴を分解しない最新の更新履歴の時刻スタンプである終点時刻スタンプで、起点時刻スタンプを更新するためである（図８参照、ステップＳ１１１）。
The difference from the synchronous update process in the first embodiment is that, after performing the update process for synchronization in step S192, the starting time stamp is not updated with the time stamp of the update history.
This is because, in the second embodiment, the starting time stamp is not updated for each update process, but is an end time stamp that is a time stamp of the latest update history that does not decompose a semantically inseparable series of update history. This is to update the time stamp (see FIG. 8, step S111).
以上の動作によって、第１実施形態と同様の効果の他、意味的に不可分な一連の更新履歴を分解するような更新要求を防ぐことができる。 With the above operation, in addition to the same effect as in the first embodiment, it is possible to prevent an update request that decomposes a series of semantically inseparable update histories.
なお、終点時刻スタンプを第２の装置２０ａにおいて記憶することを前提としたが、第１の装置１０ａにおいてのみ記憶し、第２の装置２０ａからの更新要求ごとに第１の装置１０ａに記憶された終点時刻スタンプを参照することにしてもよい。
Although it is assumed that the end time stamp is stored in the
また、ステップＳ１０５において、第２マスタ情報と第２更新履歴を破棄しているが、ステップＳ１０８の後で、更新履歴要求部２３は、第２マスタ情報と第２更新履歴を、受信した更新履歴の情報種別ごとに破棄してもよい。
In step S105, the second master information and the second update history are discarded. After step S108, the update
以上、本発明の実施形態について説明したが、本発明はこれに限定されず、本発明の趣旨を逸脱しない範囲で、例えば次のように変更することができる。
第２の装置２０，２０ａは、複数接続されていてもよい。
また、第２の装置２０，２０ａそのものがさらに情報サーバシステム２０１と情報クライアントシステム２０２（２０２Ａ、２０２Ｂ、…）とネットワーク２０３によって構成される場合について、およびそれ以降も階層的に同様に構成される場合についても、各段階において、上述した処理を再帰的に行うことになる。
As mentioned above, although embodiment of this invention was described, this invention is not limited to this, For example, it can change as follows in the range which does not deviate from the meaning of this invention.
A plurality of
Further, the case where the
１ 情報同期システム
１０ 第１の装置
１１ 第１マスタ情報記憶部
１２ 更新処理部
１３ 第１更新履歴記憶部
１４ 第１更新要求応答部
１５ 終点時刻スタンプ記憶部
２０ 第２の装置
２１ 第２マスタ情報記憶部
２２ 起点時刻スタンプ記憶部
２３ 更新履歴要求部
２４ 同期更新処理部
２５ 第２更新履歴記憶部
２６ 第２更新要求応答部
DESCRIPTION OF
Claims (10)
前記第１の装置は、前記マスタ情報を記憶する第１マスタ情報記憶部と、前記マスタ情報の更新処理を行う更新処理部と、前記マスタ情報の更新履歴を時系列で記憶する第１更新履歴記憶部と、前記第２の装置からの次回の更新の起点を示す起点時刻スタンプの時刻からの前記更新履歴を要求する更新履歴要求に対し、前記第１更新履歴記憶部に記憶された更新履歴を前記第２の装置に返す処理をする第１更新要求応答部と、前記マスタ情報の更新履歴において、互いに関連のある情報である意味的に不可分な一連の更新履歴を分解しないように、前記マスタ情報に登録されている更新履歴の時刻スタンプを終点時刻スタンプとして記憶する終点時刻スタンプ記憶部とを備え、
前記第２の装置は、前記マスタ情報と同期したデータである第２マスタ情報を記憶する第２マスタ情報記憶部と、前記起点時刻スタンプを記憶する起点時刻スタンプ記憶部と、第１の装置に対し前記起点時刻スタンプの時刻からの更新履歴を要求する更新履歴要求部と、前記更新履歴要求部が受信した更新履歴に基づいて、同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを前記起点時刻スタンプとして前記起点時刻スタンプ記憶部に記憶させる同期更新処理部と、を備え、
前記第１の装置の前記第１更新要求応答部は、前記第２の装置からの更新履歴要求に対し、前記起点時刻スタンプおよび前記終点時刻スタンプに基づいて、前記第１更新履歴記憶部に記憶された更新履歴を前記第２の装置に返す処理をし、
前記第２の装置の前記同期更新処理部は、前記終点時刻スタンプで前記起点時刻スタンプを更新する
ことを特徴とする情報同期システム。 An information synchronization system comprising: a first device that holds master information; and a second device that uses the master information,
The first device includes a first master information storage unit that stores the master information, an update processing unit that performs an update process of the master information, and a first update history that stores an update history of the master information in time series a storage unit, with respect to the update history requesting an update history request from the time of the next start time stamp indicating a start point of the update from the second apparatus, previously stored SL in the first update history storage unit updates In the update history of the master information , the first update request response unit that performs processing to return the history to the second device, so as not to decompose a semantically inseparable series of update histories that are mutually related information, An end point time stamp storage unit that stores a time stamp of the update history registered in the master information as an end point time stamp ,
The second device includes a second master information storage unit that stores second master information that is data synchronized with the master information, a start time stamp storage unit that stores the start time stamp, and a first device. On the other hand, an update history request unit that requests an update history from the time of the starting time stamp , and an update process for synchronization based on the update history received by the update history request unit, and the latest comprising a synchronous update unit for storing the time stamp of the update history on the start time stamp storage unit as the start time stamp, and
The first update request response unit of the first device stores the update history request from the second device in the first update history storage unit based on the start time stamp and the end time stamp. Processing the returned update history to the second device,
The synchronous update processing unit of the second device updates the start time stamp with the end time stamp.
An information synchronization system characterized by that.
ことを特徴とする請求項１に記載の情報同期システム。 The information synchronization system according to claim 1, wherein the update history request unit of the second device requests an update history at a predetermined timing from the first device.
ことを特徴とする請求項１に記載の情報同期システム。 The information synchronization system according to claim 1, wherein the update history request unit of the second device requests an update history for information of a predetermined information type from the first device.
前記第２の装置は、前記第２マスタ情報の更新履歴を時系列で記憶する第２更新履歴記憶部と、前記第３の装置からの更新履歴要求に対し、前記第３の装置から指定された起点時刻スタンプに基づいて、前記第２更新履歴記憶部に記憶された更新履歴を前記第３の装置に返す処理をする第２更新要求応答部と、をさらに備え、
前記第３の装置は、前記第２マスタ情報と同期したデータである第３マスタ情報を記憶する第３マスタ情報記憶部と、起点時刻スタンプを記憶する第２起点時刻スタンプ記憶部と、第２の装置に対し前記起点時刻スタンプからの更新履歴を要求する第２更新履歴要求部と、前記第２更新履歴要求部が受信した更新履歴に基づいて、同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを前記第２起点時刻スタンプ記憶部に記憶された起点時刻スタンプである第２起点時刻スタンプとして前記起点時刻スタンプ記憶部に記憶させる第２同期更新処理部と、
を備えることを特徴とする情報同期システム。 The information synchronization system according to claim 1, further comprising a third device that uses the second master information.
The second device is designated by the third device in response to an update history request from the third device and a second update history storage unit that stores the update history of the second master information in time series. A second update request response unit that performs processing to return the update history stored in the second update history storage unit to the third device based on the starting time stamp.
The third device includes a third master information storage unit that stores third master information that is data synchronized with the second master information, a second start time stamp storage unit that stores a start time stamp, and a second master information storage unit. A second update history requesting unit for requesting an update history from the starting time stamp to the device, and an update process for synchronization based on the update history received by the second update history requesting unit, and synchronization A second synchronous update processing unit that stores a time stamp of the latest update history that has been completed in the starting time stamp storage unit as a second starting time stamp that is a starting time stamp stored in the second starting time stamp storage unit; ,
An information synchronization system comprising:
前記第２の装置は、前記第２マスタ情報の更新履歴を時系列で記憶する第２更新履歴記憶部と、前記第３の装置からの更新履歴要求に対し、前記第３の装置から指定された起点時刻スタンプに基づいて、前記第２更新履歴記憶部に記憶された更新履歴を前記第３の装置に返す処理をする第２更新要求応答部と、前記マスタ情報の更新履歴において意味的に不可分な一連の更新履歴を分解しないように、更新履歴の時刻スタンプを第２終点時刻スタンプとして記憶する終点時刻スタンプ記憶部と、をさらに備え、
前記第３の装置は、前記第２マスタ情報と同期したデータである第３マスタ情報を記憶する第３マスタ情報記憶部と、起点時刻スタンプを記憶する第２起点時刻スタンプ記憶部と、第２の装置に対し前記起点時刻スタンプからの更新履歴を要求する第２更新履歴要求部と、前記第２更新履歴要求部が受信した更新履歴に基づいて、同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを前記第２起点時刻スタンプ記憶部に記憶された起点時刻スタンプである第２起点時刻スタンプとして前記起点時刻スタンプ記憶部に記憶させる第２同期更新処理部と、を備え、
前記第２の装置の前記第２更新要求応答部は、前記第３の装置からの更新履歴要求に対し前記第２更新履歴記憶部に記憶された更新履歴のうち、前記第２起点時刻スタンプおよび前記第２終点時刻スタンプに基づいて更新履歴を前記第３の装置に返す処理をし、
前記第３の装置の前記第２同期更新処理部は、前記第２終点時刻スタンプで前記第２起点時刻スタンプを更新する
ことを特徴とする情報同期システム。 The information synchronization system according to claim 1 , further comprising a third device that uses the second master information.
The second device is designated by the third device in response to an update history request from the third device and a second update history storage unit that stores the update history of the second master information in time series. In the update history of the master information, the second update request response unit for processing to return the update history stored in the second update history storage unit to the third device based on the starting time stamp. An end point time stamp storage unit that stores a time stamp of the update history as a second end time stamp so as not to disassemble the inseparable series of update history,
The third device includes a third master information storage unit that stores third master information that is data synchronized with the second master information, a second start time stamp storage unit that stores a start time stamp, and a second master information storage unit. A second update history requesting unit for requesting an update history from the starting time stamp to the device, and an update process for synchronization based on the update history received by the second update history requesting unit, and synchronization A second synchronous update processing unit that stores a time stamp of the latest update history that has been completed in the starting time stamp storage unit as a second starting time stamp that is a starting time stamp stored in the second starting time stamp storage unit; With
The second update request response unit of the second device includes the second origin time stamp and the update history stored in the second update history storage unit in response to the update history request from the third device. Processing to return an update history to the third device based on the second end time stamp,
The second synchronization update processing unit of the third device updates the second start time stamp with the second end time stamp.
前記第１の装置の前記第１更新要求応答部は、前記第２の装置からの更新履歴要求に対し、前記第２の装置から指定された起点時刻スタンプに基づいて、前記第１更新履歴記憶部に記憶された更新履歴を取得する処理の間に排他制御を行う
ことを特徴とする請求項１に記載の情報同期システム。 The update processing unit of the first device performs exclusive control during the update process of the master information,
In response to an update history request from the second device, the first update request response unit of the first device is configured to store the first update history based on a starting time stamp designated by the second device. The information synchronization system according to claim 1, wherein exclusive control is performed during a process of acquiring an update history stored in the unit.
前記第１の装置の前記第１更新要求応答部は、前記終点時刻スタンプを取得する処理の間に排他制御を行う
ことを特徴とする請求項１に記載の情報同期システム。 The update processing unit of the first device performs exclusive control during the update process of the master information,
The information synchronization system according to claim 1 , wherein the first update request response unit of the first device performs exclusive control during a process of acquiring the end point time stamp.
ことを特徴とする請求項１に記載の情報同期システム。 The information synchronization system according to claim 1, wherein information capable of determining before and after time is used as a time stamp of the update history.
前記第１の装置において、前記マスタ情報を記憶する第１マスタ情報記憶部、前記マスタ情報の更新処理を行う更新処理部、前記マスタ情報の更新履歴を時系列で記憶する第１更新履歴記憶部、前記第２の装置からの次回の更新の起点を示す起点時刻スタンプの時刻からの前記更新履歴を要求する更新履歴要求に対し、前記第１更新履歴記憶部に記憶された更新履歴を前記第２の装置に返す処理をする第１更新要求応答部、前記マスタ情報の更新履歴において、互いに関連のある情報である意味的に不可分な一連の更新履歴を分解しないように、前記マスタ情報に登録されている更新履歴の時刻スタンプを終点時刻スタンプとして記憶する終点時刻スタンプ記憶部として機能させ、
前記第２の装置において、前記マスタ情報と同期したデータである第２マスタ情報を記憶する第２マスタ情報記憶部、前記起点時刻スタンプを記憶する起点時刻スタンプ記憶部、第１の装置に対し前記起点時刻スタンプの時刻からの更新履歴を要求する更新履歴要求部、前記更新履歴要求部が受信した更新履歴に基づいて、同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを前記起点時刻スタンプとして前記起点時刻スタンプ記憶部に記憶させる同期更新処理部として機能させ、
前記第１の装置の前記第１更新要求応答部は、前記第２の装置からの更新履歴要求に対し、前記起点時刻スタンプおよび前記終点時刻スタンプに基づいて、前記第１更新履歴記憶部に記憶された更新履歴を前記第２の装置に返す処理をし、
前記第２の装置の前記同期更新処理部は、前記終点時刻スタンプで前記起点時刻スタンプを更新する
ための情報同期プログラム。 A computer in an information synchronization system comprising: a first device that holds master information; and a second device that uses the master information.
In the first device, a first master information storage unit that stores the master information, an update processing unit that performs an update process of the master information, and a first update history storage unit that stores an update history of the master information in time series the said to update history requesting update history request, the update history of previous SL stored in the first update history storage unit from the time of start time stamp indicating a start point of the next update from the second device A first update request responding unit that performs processing to be returned to the second device; in the update history of the master information, in order to avoid disassembling a series of semantically inseparable update histories that are mutually related information, Function as an end point time stamp storage unit for storing a time stamp of the registered update history as an end point time stamp ,
In the second device, a second master information storage unit that stores second master information that is data synchronized with the master information, a start time stamp storage unit that stores the start time stamp, and the first device An update history request unit for requesting an update history from the time of the starting time stamp , an update process for synchronization is performed based on the update history received by the update history request unit, and the latest update history for which synchronization has been completed time stamp the start time stamp storage unit synchronization is stored in the updating unit and to thereby function as the start time stamp,
The first update request response unit of the first device stores the update history request from the second device in the first update history storage unit based on the start time stamp and the end time stamp. Processing the returned update history to the second device,
The synchronous update processing unit of the second device updates the start time stamp with the end time stamp.
Information synchronization program for.
前記第１の装置において、前記マスタ情報を記憶する第１マスタ情報記憶ステップと、前記マスタ情報の更新処理を行う更新処理ステップと、前記マスタ情報の更新履歴を時系列で記憶する第１更新履歴記憶ステップと、前記第２の装置からの次回の更新の起点を示す起点時刻スタンプの時刻からの前記更新履歴を要求する更新履歴要求に対し、前記第１更新履歴記憶ステップで記憶された更新履歴を前記第２の装置に返す処理をする第１更新要求応答ステップと、前記マスタ情報の更新履歴において、互いに関連のある情報である意味的に不可分な一連の更新履歴を分解しないように、前記マスタ情報に登録されている更新履歴の時刻スタンプを終点時刻スタンプとして記憶する終点時刻スタンプ記憶ステップとを含み、
前記第２の装置において、前記マスタ情報と同期したデータである第２マスタ情報を記憶する第２マスタ情報記憶ステップと、前記起点時刻スタンプを記憶する起点時刻スタンプ記憶ステップと、第１の装置に対し前記起点時刻スタンプの時刻からの更新履歴を要求する更新履歴要求ステップと、前記更新履歴要求ステップで受信した更新履歴に基づいて、同期のための更新処理を行うとともに、同期が完了した最新の更新履歴の時刻スタンプを前記起点時刻スタンプとして記憶する同期更新処理ステップとを含み、
前記第１の装置の前記第１更新要求応答ステップは、前記第２の装置からの更新履歴要求に対し、前記起点時刻スタンプおよび前記終点時刻スタンプに基づいて、前記第１更新履歴記憶ステップで記憶された更新履歴を前記第２の装置に返す処理をし、
前記第２の装置の前記同期更新処理ステップは、前記終点時刻スタンプで前記起点時刻スタンプを更新する
ことを特徴とする情報同期方法。 An information synchronization method in an information synchronization system comprising: a first device that holds master information; and a second device that uses the master information,
In the first device, a first master information storing step for storing the master information, an update processing step for performing an update process of the master information, and a first update history for storing an update history of the master information in time series a storage step, to said requesting an update history update history request from the time of start time stamp indicating a start point of the next update from the second device, stored in the previous SL first update history storing step updates In the first update request response step for performing processing to return the history to the second device, and in the update history of the master information, a series of semantically inseparable update histories that are mutually related information are not decomposed. An end point time stamp storing step of storing an update history time stamp registered in the master information as an end point time stamp ,
In the second device, a second master information storing step for storing second master information which is data synchronized with the master information, a starting time stamp storing step for storing the starting time stamp, and a first device On the other hand, an update history request step for requesting an update history from the time of the starting time stamp , and an update process for synchronization based on the update history received at the update history request step, and the latest A synchronous update processing step of storing a time stamp of an update history as the starting time stamp ,
The first update request response step of the first device stores the update history request from the second device in the first update history storage step based on the start time stamp and the end time stamp. Processing the returned update history to the second device,
The synchronous update processing step of the second device updates the start time stamp with the end time stamp.
An information synchronization method characterized by the above.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010209000A JP5469573B2 (en) | 2010-09-17 | 2010-09-17 | Information synchronization system, information synchronization program, and information synchronization method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010209000A JP5469573B2 (en) | 2010-09-17 | 2010-09-17 | Information synchronization system, information synchronization program, and information synchronization method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2012064089A JP2012064089A (en) | 2012-03-29 |
| JP5469573B2 true JP5469573B2 (en) | 2014-04-16 |
Family
ID=46059713
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2010209000A Active JP5469573B2 (en) | 2010-09-17 | 2010-09-17 | Information synchronization system, information synchronization program, and information synchronization method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP5469573B2 (en) |
Family Cites Families (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH04310146A (en) * | 1991-04-09 | 1992-11-02 | Nec Corp | Data unitary control system for decentralized processing system |
| JPH0528021A (en) * | 1991-07-19 | 1993-02-05 | Fujitsu Ltd | Management method of two-way arrangement data |
| JPH10222409A (en) * | 1997-01-31 | 1998-08-21 | Mitsubishi Electric Corp | Distributed data managing system |
| JP2004280210A (en) * | 2003-03-13 | 2004-10-07 | Hitachi Ltd | Database information communication controller |
| JP4624829B2 (en) * | 2004-05-28 | 2011-02-02 | 富士通株式会社 | Data backup system and method |
-
2010
- 2010-09-17 JP JP2010209000A patent/JP5469573B2/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| JP2012064089A (en) | 2012-03-29 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109739935B (en) | Data reading method and device, electronic equipment and storage medium | |
| US7240114B2 (en) | Namespace management in a distributed file system | |
| CN110196885B (en) | Cloud distributed real-time database system | |
| US9740582B2 (en) | System and method of failover recovery | |
| EP1661000B1 (en) | Recovery from failures within data processing systems | |
| US6687701B2 (en) | Namespace management in a distributed file system | |
| US6298425B1 (en) | Computer disk management system using doublet A-B logging | |
| EP2535815B1 (en) | Consistent backup of a distributed database system | |
| EP3391244B1 (en) | Replication control among redundant data centers | |
| CN107710203B (en) | Transaction database layer above distributed key/value store | |
| US20050028026A1 (en) | Method and system for backing up and restoring data of a node in a distributed system | |
| US7099889B2 (en) | System and method for decoupling object identification for the purpose of object switching in database systems | |
| EP3391249B1 (en) | Replication of structured data records among partitioned data storage spaces | |
| US10013424B2 (en) | Efficient building of restore list | |
| CN109753511B (en) | Cross-region real-time synchronization method and system for big data platform | |
| US8600933B2 (en) | Multi-master attribute uniqueness | |
| EP3391243A1 (en) | Promoted properties in relational structured data | |
| US5745674A (en) | Management of units of work on a computer system log | |
| JP2006018796A (en) | Data processing method and apparatus, storage apparatus and processing program therefor | |
| WO2000070465A1 (en) | Distributed computer system and method of application of maintenance data | |
| WO2022026787A1 (en) | Using multiple blockchains for applying transactions to a set of persistent data objects in persistent storage systems | |
| US9201685B2 (en) | Transactional cache versioning and storage in a distributed data grid | |
| US20080195615A1 (en) | Recursive lock-and-propagate operation | |
| JP5469573B2 (en) | Information synchronization system, information synchronization program, and information synchronization method | |
| EP3377970B1 (en) | Multi-version removal manager |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20120809 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20131016 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20131029 |
|
| A521 | Written amendment |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20131225 |
|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20140121 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20140131 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 5469573 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 Free format text: JAPANESE INTERMEDIATE CODE: R150 |