JP2010067115A - Data storage system and data storage method - Google Patents
Data storage system and data storage method Download PDFInfo
- Publication number
- JP2010067115A JP2010067115A JP2008234279A JP2008234279A JP2010067115A JP 2010067115 A JP2010067115 A JP 2010067115A JP 2008234279 A JP2008234279 A JP 2008234279A JP 2008234279 A JP2008234279 A JP 2008234279A JP 2010067115 A JP2010067115 A JP 2010067115A
- Authority
- JP
- Japan
- Prior art keywords
- server
- data
- update
- storage
- storage device
- 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.)
- Granted
Links
- 238000013500 data storage Methods 0.000 title claims abstract description 45
- 238000000034 method Methods 0.000 title claims description 50
- 238000012546 transfer Methods 0.000 claims abstract description 10
- 238000012544 monitoring process Methods 0.000 claims description 24
- 230000005856 abnormality Effects 0.000 claims description 12
- 230000005540 biological transmission Effects 0.000 claims description 12
- 238000012806 monitoring device Methods 0.000 claims description 10
- 238000011084 recovery Methods 0.000 claims description 8
- 238000001514 detection method Methods 0.000 claims 1
- 238000004519 manufacturing process Methods 0.000 abstract description 18
- 230000008569 process Effects 0.000 description 43
- 238000012545 processing Methods 0.000 description 18
- 238000004891 communication Methods 0.000 description 13
- 230000006870 function Effects 0.000 description 7
- 238000011156 evaluation Methods 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 230000004048 modification Effects 0.000 description 4
- 230000001360 synchronised effect Effects 0.000 description 4
- 238000012360 testing method Methods 0.000 description 3
- 230000004913 activation Effects 0.000 description 2
- 238000010586 diagram Methods 0.000 description 2
- 230000004044 response Effects 0.000 description 2
- 230000002159 abnormal effect Effects 0.000 description 1
- 238000012790 confirmation Methods 0.000 description 1
- 230000010365 information processing Effects 0.000 description 1
- 230000008439 repair process Effects 0.000 description 1
- 230000009466 transformation Effects 0.000 description 1
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
Description
本発明は、データ記憶システム、データ記憶方法に関する。 The present invention relates to a data storage system and a data storage method.
ネットワークを介して接続された接続先のサーバに所定のデータを蓄積して記憶するシステムなどにおいて、サーバを二重化して、システムの信頼性を高めること(ホットスタンバイ)が知られている(例えば特許文献1)。 In a system in which predetermined data is accumulated and stored in a connection destination server connected via a network, it is known to increase the reliability of the system (hot standby) by duplicating the server (for example, patent) Reference 1).
しかし、サーバを二重化した場合であっても、双方のサーバに障害が発生する可能性があり、より信頼性の高いデータ記憶システムが求められている。 However, even if the servers are duplicated, a failure may occur in both servers, and a more reliable data storage system is required.
本発明は、上記実情に鑑みてなされたものであって、データ記憶システムの信頼性を向上させることを目的とする。 The present invention has been made in view of the above circumstances, and an object thereof is to improve the reliability of a data storage system.
上記目的を達成するため、本発明の第1の観点に係るデータ記憶システムは、
各々がデータを記憶する記憶装置を備える第1のサーバ、第2のサーバ、及び第3のサーバと、それらのサーバを監視するための監視装置と、から構成され、それぞれがネットワークを介して接続されるデータ記憶システムであって、
前記第1から第3のサーバのうち予め定められた1のサーバであるプライマリサーバは、
ネットワークを介して前記記憶装置に記憶されるデータを更新するための更新データを受信する受信手段と、
前記更新データに基づいて前記記憶装置に記憶されるデータを更新する第1の更新手段と、
前記更新データを他のサーバに転送する転送手段と、を備え、
前記第1から第3のサーバのうち前記プライマリサーバ以外のセカンダリサーバは、
前記プライマリサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新する第2の更新手段を備え、
前記監視装置は、前記プライマリサーバの動作が停止した場合に、前記セカンダリサーバのいずれかをプライマリサーバに切り換える切換手段を備える
ことを特徴とする。
In order to achieve the above object, a data storage system according to the first aspect of the present invention provides:
Each of the first server, the second server, and the third server each having a storage device for storing data, and a monitoring device for monitoring these servers, each connected via a network A data storage system,
A primary server that is a predetermined one of the first to third servers is:
Receiving means for receiving update data for updating data stored in the storage device via a network;
First update means for updating data stored in the storage device based on the update data;
Transfer means for transferring the update data to another server,
Secondary servers other than the primary server among the first to third servers are
Second update means for updating data stored in the storage device based on update data transferred from the primary server;
The monitoring device includes switching means for switching one of the secondary servers to the primary server when the operation of the primary server is stopped.
本発明の第2の観点に係るデータ記憶システムは、
各々がデータを記憶する記憶装置を備える第1のサーバ、第2のサーバ、及び第3のサーバと、データを記憶する記憶装置を備え前記第1から第3のサーバとは異なるバージョンの第4のサーバと、から構成され、それぞれがネットワークを介して接続されるデータ記憶システムであって、
前記第1のサーバは、
ネットワークを介して前記記憶装置に記憶されるデータを更新するための更新データを受信する手段と、
前記更新データに基づいて前記記憶装置に記憶されるデータを更新する手段と、
前記更新データを前記第2のサーバと前記第3のサーバとに転送する手段と、を備え、
前記第2のサーバは、
前記第1のサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新する手段を備え、
前記第3のサーバは、
前記第1のサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新する手段と、
前記更新データを前記第4のサーバに転送する手段と、を備え、
前記第4のサーバは、
前記第3のサーバから転送される更新データに基づいて前記記憶装置に記憶されるデータを更新する手段を備える
ことを特徴とする。
A data storage system according to the second aspect of the present invention provides:
A first server, a second server, and a third server each having a storage device for storing data, and a fourth version of the fourth server having a storage device for storing data and different from the first to third servers. A data storage system connected to each other via a network,
The first server is
Means for receiving update data for updating data stored in the storage device via a network;
Means for updating data stored in the storage device based on the update data;
Means for transferring the update data to the second server and the third server,
The second server is
Means for updating data stored in the storage device based on update data transferred from the first server;
The third server is
Means for updating data stored in the storage device based on update data transferred from the first server;
Means for transferring the update data to the fourth server,
The fourth server is
The information processing apparatus further comprises means for updating data stored in the storage device based on update data transferred from the third server.
本発明の第3の観点に係るデータ記憶方法は、
各々がデータを記憶する記憶装置を備える第1のサーバ、第2のサーバ、及び第3のサーバと、それらのサーバを監視するための監視装置と、から構成され、それぞれがネットワークを介して接続されるデータ記憶システムにおけるデータ記憶方法であって、
前記第1から第3のサーバのうち予め定められた1のサーバであるプライマリサーバは、
ネットワークを介して前記記憶装置に記憶されるデータを更新するための更新データを受信し、
前記更新データに基づいて前記記憶装置に記憶されるデータを更新し、
前記更新データを他のサーバに転送し、
前記第1から第3のサーバのうち前記プライマリサーバ以外のセカンダリサーバは、
前記プライマリサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新し、
前記監視装置は、前記プライマリサーバの動作が停止した場合に、前記セカンダリサーバのいずれかをプライマリサーバに切り換える
ことを特徴とする。
A data storage method according to a third aspect of the present invention includes:
Each of the first server, the second server, and the third server each having a storage device for storing data, and a monitoring device for monitoring these servers, each connected via a network A data storage method in a data storage system, comprising:
A primary server that is a predetermined one of the first to third servers is:
Receiving update data for updating data stored in the storage device via a network;
Updating the data stored in the storage device based on the update data;
Transferring the update data to another server;
Secondary servers other than the primary server among the first to third servers are
Update the data stored in the storage device based on the update data transferred from the primary server,
When the operation of the primary server is stopped, the monitoring device switches one of the secondary servers to the primary server.
本発明によれば、データ記憶システムの信頼性を向上することができる。 According to the present invention, the reliability of the data storage system can be improved.
本発明の実施の形態にかかるデータ記憶システム100について図面を参照しながら説明する。図1に示すように、データ記憶システム100は、複数の記憶サーバ10A〜Cと、監視サーバ20と、オンラインコントローラ30と、生産装置40と、から構成され、複数の記憶サーバ10A〜Cと、監視サーバ20と、オンラインコントローラ30と、はネットワーク50を介して接続される。データ記憶システム100は、生産装置40の稼働状況を記憶サーバ10A〜10Cにおいて、多重化して記憶するシステムである。このように記憶サーバ10を多重化することで、システムの信頼性を高めている。
A
図2に示すように、記憶サーバ10A〜10C(図中では記憶サーバ10)は、CPU(Central Processing Unit)11、ROM(Read Only Memory)12、RAM(Random Access Memory)13、通信部14、データベース15などから構成される。記憶サーバ10A〜10Cは専用のサーバである必要はなく、通常のコンピュータであってもよい。
As shown in FIG. 2, the
CPU11は、記憶サーバ10(10A〜10C)の動作を制御する。ROM12には、コンピュータを記憶サーバ10として機能させるためのプログラムが格納され、CPU11が当該プログラムを読み込むことで、記憶サーバ10の機能を実現する。具体的には、オンラインコントローラ30を介して生産装置40から送信される更新データに基づいて、データベース15を更新する処理などが実行される。詳しい動作については後述する。RAM13は、CPU11のワークエリアとして機能する。通信部14は、ネットワーク50に接続するためのインターフェースであって、記憶サーバ10は通信部14を介してネットワーク50に接続される。通信部14は、受信したデータを一時的に蓄積する受信キューと、送信するデータを一時的に蓄積する送信キューとを備える。データベース15は、ハードディスクドライブなどから構成される記憶装置である。データベース15は、制裁装置の稼働履歴を蓄積して記憶する。なお、図2では、記憶サーバ10の一般的な構成を示しているが、それぞれの記憶サーバ10A〜10C個別の構成を示す場合は、各構成に記憶サーバ10と同じアルファベットが付されるものとする。例えば、記憶サーバ10BのCPU10は、CPU10Bと表記する。
The
監視サーバ20は、記憶サーバ10の稼働状況を監視するサーバであり、記憶サーバ10と同様のCPU、ROM、RAM、通信部などを備える(図示せず)。監視サーバ20は専用のサーバである必要はなく、通常のコンピュータであってもよい。監視サーバ20のROMには、コンピュータを監視サーバ20として機能させるためのプログラムが格納され、監視サーバ20のCPUが当該プログラムを読み込むことで、監視サーバ20の機能を実現する。例えば、記憶サーバ10A〜10Cをネットワーク50を介して監視(モニタリング)し、記憶サーバ10A〜10Cに障害が発生しているか否かを判別する処理などを実行する。具体的には、記憶サーバ10A〜10Cに応答するように要求をする信号を送出し、応答があれば正常であると判別し、応答が無ければ異常であると判別する。
The
生産装置40は、所定の製品を生産する装置であって、例えば1日の稼働状況(生産した製品の数量など)を示す情報を、所定周期で(例えば24時間ごとで)オンラインコントローラ30に送信する。生産装置40は単独の装置であってもよいし、複数の装置であってもよい。
The
オンラインコントローラ30は、生産装置40から送信された情報を集計して記憶サーバに送信する。オンラインコントローラ30は、記憶サーバ10と同様のCPU、ROM、RAM、通信部などを備える(図示せず)。オンラインコントローラ30は専用のサーバである必要はなく、通常のコンピュータであってもよい。オンラインコントローラ30のROMには、コンピュータをオンラインコントローラ30として機能させるためのプログラムが格納され、オンラインコントローラ30のCPUが当該プログラムを読み込むことで、オンラインコントローラ30の機能を実現する。具体的には、生産装置40から受信した情報を集計し、記憶サーバ10のデータベース15を更新するための更新データを生成して、その更新データを記憶サーバ10(10A〜10Cのいずれか)に送信する。
The
ネットワーク50には、インターネットが使用される。また、ネットワーク50は、LAN(Local Area Network)やWAN(Wide Area Network)など、データ記憶システム100専用の専用線であってもよい。また、図1に示した接続構成は一例であって、例えば、監視サーバ20がネットワーク50とは異なるネットワークにより記憶サーバ10A〜10Cに接続されていてもよい。
The
続いて、データ記憶システム100の具体的な動作について説明する。図3は、本発明の実施の形態にかかるデータ記憶システム100の全体的な動作を示す図である。
Next, a specific operation of the
先ず、生産装置40が所定のタイミングで生産装置40の稼働状況を示す生産情報をオンラインコントローラ30に送信する(ステップS11)。そして、オンラインコントローラ30が受信した生産情報を集計し、記憶サーバ10のデータベースを更新するための更新データを生成し、生成した更新データを記憶サーバ10A(プライマリサーバ)に送信する(ステップS12)。
First, the
ここでプライマリサーバとは、記憶サーバ10A〜10Cのうちの予め定められた1台のサーバであり、ここでは記憶サーバ10Aがプライマリサーバとなっている。なお、プライマリサーバ以外の記憶サーバ10をセカンダリサーバと称する。プライマリサーバは、ネットワークにおける論理アドレスが予め定められており、オンラインコントローラ30は、そのアドレスに更新データを送信するようになっている。即ち、オンラインコントローラ30は、どの記憶サーバ10がプライマリサーバであるかを意識せずに更新データをプライマリサーバに送信することができる。
Here, the primary server is a predetermined one of the
記憶サーバ10Aが更新データを受信すると、データベース更新処理を開始する(ステップS13)。このデータベース更新処理では、更新データに基づいてデータベース15Aを更新する処理が実行される。また、プライマリサーバのデータベース更新処理においては、受信した更新データを各セカンダリサーバに転送する処理が実行される(ステップS14)。さらに、プライマリサーバのデータベース更新処理においては、データベース15Aの更新が完了すると、更新が完了したことを示す更新完了通知をオンラインコントローラ30に送信する(ステップS15)。なお、セカンダリサーバのデータベース更新処理においては、更新データに基づいてデータベース15B、15Cを更新する処理のみが実行される(S13)。以上のようにして、生産装置40の稼働状況を、記憶サーバ10A〜10Cにおいて多重化して記憶することができる。
When the
次に、プライマリサーバである記憶サーバ10Aに異常が発生した際に、プライマリサーバを切り換える動作と、そのときの生産装置40の稼働状況を、記憶サーバ10B、10Cにおいて多重化して記憶する動作について図4を用いて説明する。なお、図4において図3の処理と同様の処理については同じステップ番号を付して説明は省略する。
Next, when an abnormality occurs in the
図4に示すように、記憶サーバ10Aに異常が発生した場合、監視サーバ20がその異常を検出する。プライマリサーバに異常が発生したので、監視サーバ20はセカンダリサーバである記憶サーバ10Bをプライマリサーバに切り換えるため、プライマリ切換指示を記憶サーバ10Bに送信する(ステップT11)。このプライマリ切換指示の送信は、監視サーバ20が異常を検出したことに基づいて自動で送信するようにしてもよいし、監視サーバ20を使用するユーザが手動で送信してもよい。
As shown in FIG. 4, when an abnormality occurs in the
プライマリ切換指示を受信した記憶サーバ10Bはプライマリサーバに切り換えるためのプライマリ切換処理を開始する(ステップT12)。この処理により、記憶サーバ10Bがプライマリサーバとなる。
The
記憶サーバ10Aに異常発生中に、オンラインコントローラ30が、更新データを記憶サーバ10A(プライマリサーバ)に送信すると(ステップS12)、通信エラーとなる。このとき、更新データの送信に失敗したことを検出して通信エラーであることを判別してもよいし、更新データ送信から所定時間経過するまでに更新完了通知を受信しなかった場合に通信エラーであると判別するようにしてもよい。
If the
このように、通信エラーとなった場合、オンラインコントローラ30は更新データを再送する(ステップS21)。この再送の時点で記憶サーバ10Bのアドレスが、プライマリサーバのアドレスに切り換わっていれば、更新データは記憶サーバ10Bに送信される。記憶サーバ10Bが更新データを受信するとデータベース更新処理を開始する(ステップS13)。
Thus, when a communication error occurs, the
このときに、更新データを記憶サーバ10Aに転送する処理が実行されるが(ステップS14)、送信エラーとなる。そこで、その更新データを後に再送できるように、その更新データを記憶サーバ10Bの通信部14Bが備える送信キューに蓄積する。記憶サーバ10Bがデータベース15Bの更新を完了すると、更新が完了したことを示す更新完了通知をオンラインコントローラ30に送信する(ステップS15)。
At this time, the process of transferring the update data to the
このように、記憶サーバ10Aに異常が発生した場合にも、生産装置40やオンラインコントローラ30の動作を止めることなく、生産装置40の稼働状況を記憶サーバ10B、10Cにおいて多重化して記憶することができる。
Thus, even when an abnormality occurs in the
ここで、図3、図4におけるデータベース更新処理(ステップS13)、プライマリ切換処理(ステップT12)の詳細な動作について説明する。 Here, detailed operations of the database update process (step S13) and the primary switching process (step T12) in FIGS. 3 and 4 will be described.
図5は、データベース更新処理の動作を示すフローチャートである。各記憶サーバ10のCPU11は、所定周期でデータベース更新処理を実行する。そして、更新データの受信を検出すると(ステップS101;Yes)、当該更新データに基づいてデータベース15を更新する(ステップS102)。そして、RAM13の所定領域などに設けられたプライマリフラグがオンになっているか否かを判別する(ステップS103)。この処理により、CPU11は記憶サーバ10がプライマリサーバであるか否かを判別する。プライマリフラグがオフであれば(ステップS103;No)、処理を終える。プラマリフラグがオンであれば(ステップS103;Yes)、プライマリサーバ特有の処理を実行する。まず、CPU11は、更新データをセカンダリサーバに転送する(ステップS104)。そして、更新データのセカンダリサーバへの転送が成功したか否かを判別する(ステップS105)。転送が成功しなかった場合(ステップS105;No)、通信部14が備える送信キューに更新データを蓄積する(ステップS106)。更新データの転送が成功した場合や、送信キューに更新データを蓄積した後、オンラインコントローラ30に更新完了通知を送信して処理を終える。
FIG. 5 is a flowchart showing the operation of the database update process. The
図6は、プライマリ切換処理の動作を示すフローチャートである。各記憶サーバ10のCPU11は、所定周期でプライマリ切換処理を実行する。そして、プライマリ切換指示の受信を検出すると(ステップS201;Yes)、CPU11は、RAM13の所定領域に設けられるプライマリフラグをオンにセットする(ステップS202)。そして、ネットワーク50における論理アドレスをプライマリサーバのアドレスに変更して(ステップS203)、処理を終える。
FIG. 6 is a flowchart showing the operation of the primary switching process. The
次に、異常が発生した記憶サーバ10Aを復旧させるときの動作について図7、図8を用いて説明する。なお、図7、図8において図4において図3の処理と同様の処理については同じステップ番号を付して説明は省略する。
Next, an operation for recovering the
異常が発生して停止している記憶サーバ10Aの修理が完了し、ネットワーク50への接続が完了すると、ユーザが監視サーバ20を操作して、セカンダリサーバである記憶サーバ10Cに停止指示を送信する(ステップT13)。なお、記憶サーバ10Aのネットワーク50上でのアドレスはセカンダリサーバのものとして予め定められたアドレスとなる。また、記憶サーバ10Aのプライマリフラグはオフとなる。
When the repair of the
記憶サーバ10Cが監視サーバから停止指示を受信すると、更新停止時処理を開始する(ステップT14)。図9は、更新停止時処理の動作を示すフローチャートである。CPU11Cは、所定周期でデータベース更新処理を実行する。そして、停止指示の受信を検出すると(ステップS301;Yes)、データベース更新処理を停止する(ステップS302)。即ち、所定周期で実行していた図5に示したデータベース更新処理の実行を停止する。そして、データベース更新処理の停止中に受信する更新データを受信キューに蓄積する準備をする(ステップS303)。これにより、この間に更新データを受信した場合、受信キューに蓄積されることとなる。その後、データベース15Cの記憶内容を修理が完了した記憶サーバ10Aのデータベース15Aにコピーする(ステップS304)。例えば、記憶サーバ10Aのアドレスにデータベース15Cの記憶内容を送信するようにすればよい。そして、記憶サーバ10Aの側では、その内容を受信した場合、データベース15Aにコピーする用に設定すればよい。ステップS304の後、更新停止時処理を終える。
When the storage server 10C receives a stop instruction from the monitoring server, the update stop process is started (step T14). FIG. 9 is a flowchart showing the operation of the update stop process. The CPU 11C executes database update processing at a predetermined cycle. When the reception of the stop instruction is detected (step S301; Yes), the database update process is stopped (step S302). That is, the execution of the database update process shown in FIG. Then, it prepares to accumulate update data received while the database update process is stopped in the reception queue (step S303). Thus, if update data is received during this time, it is stored in the reception queue. Thereafter, the stored contents of the database 15C are copied to the database 15A of the
記憶サーバ10Cのデータベース15Cから記憶サーバ10Aのデータベース15Aへのコピーが終了すると、ユーザが監視サーバ20を操作して、記憶サーバ10A及び10Cに起動指示を送信する(図8のステップT15)。記憶サーバ10A及び10Cは、起動指示を受信すると、図3に示したデータベース更新処理の実行を再開する。これにより、記憶サーバ10A及び10Cはセカンダリサーバとしての復旧することになる。異常から復旧した記憶サーバ10Aはプライマリサーバである記憶サーバ10Bに再開通知を送信する(ステップS31)。プライマリサーバが再開通知を受信すると、当該サーバの送信キューに蓄積された更新データを記憶サーバ10Aに送信する(ステップS32)。記憶サーバ10Aでは、その更新データに基づいてデータベース更新処理が開始される(ステップS13)。なお、この更新データにはすでに更新済みのデータも含まれるが、更新データの日付情報などにより特定可能である。このデータベース更新処理により、データベース15Aの記憶内容がプライマリサーバのデータベース15Bと同期することとなる。
When copying from the database 15C of the storage server 10C to the database 15A of the
一方、更新停止時処理(ステップT14)を実行した記憶サーバ10Cがセカンダリサーバとして復帰すると、受信キューに蓄積された更新データに基づいてデータベース更新処理を開始する(ステップS13)。このデータベース更新処理により、データベース15Cの記憶内容がプライマリサーバのデータベース15Bと同期することとなる。なお、図7、図8に示した記憶サーバ10Aを、記憶サーバ10C(稼働中のセカンダリサーバ)を使用して復旧させる処理を下記では復旧処理ともいう。
On the other hand, when the storage server 10C that executed the update stop process (step T14) returns as the secondary server, the database update process starts based on the update data accumulated in the reception queue (step S13). By this database update process, the stored contents of the database 15C are synchronized with the database 15B of the primary server. Note that the process of restoring the
このように、記憶サーバ10A及び10Cをセカンダリサーバに復旧させることができる。また、復旧後に記憶サーバ10Bの送信キューや記憶サーバ10Cの受信キューに蓄積された更新データに基づいてデータベース更新処理が実行されることで、記憶サーバ10A〜10Cのデータベース15A〜15Cの記憶内容が自律的に同期する。さらに、記憶サーバ10A及び10Cをセカンダリサーバに復旧させるときにも、プライマリサーバは起動しているので、継続して生産装置40の稼働状況を記憶することができる。
Thus, the
次に、記憶サーバ10Dを追加したデータ記憶システム100の変形例について図10を参照しながら説明する。記憶サーバ10Dはネットワーク50を介して記憶サーバ10A〜10Cや、監視サーバ20(図10においては省略)、オンラインコントローラ30などと接続される。この記憶サーバ10Dは、基本的な構成は図2に示した記憶サーバ10A〜10Cと同様であるが、OS(Operating System)やソフトウェアの一部などがバージョンアップされた記憶サーバである。この変形例では、新バージョンの記憶サーバ10Dがデータ記憶システム100上で正常に動作するか否かを評価する。なお、記憶サーバ10Dのような新バージョンの記憶サーバを評価サーバとも称する。
Next, a modification of the
まず、図7、図8に示した復旧処理と同一の動作により、セカンダリサーバ(記憶サーバ)10Cのデータベース15Cの記憶内容を、記憶サーバ10Dのデータベース15Dにコピーするなどの一連の処理を実行する(ステップS41)。データベース15C、15Dの記憶内容が他のデータベースと同期したら、記憶サーバ10Cにおいて、更新データ転送プロセスを起動する(ステップS42)。この転送プロセスは、更新データを受信したときに、その更新データを記憶サーバ10Dに転送する処理を実行するプロセスである。このプロセスにより、更新データが記憶サーバ10Dに転送される(ステップS43)。記憶サーバ10Dでは、転送された更新データに基づいてデータベース更新処理の実行が開始される(ステップS13)。 First, a series of processing such as copying the storage contents of the database 15C of the secondary server (storage server) 10C to the database 15D of the storage server 10D is performed by the same operation as the recovery processing shown in FIGS. (Step S41). When the storage contents of the databases 15C and 15D are synchronized with other databases, the update data transfer process is started in the storage server 10C (step S42). This transfer process is a process for executing a process of transferring the update data to the storage server 10D when the update data is received. Through this process, the update data is transferred to the storage server 10D (step S43). In the storage server 10D, execution of the database update process is started based on the transferred update data (step S13).
このような、記憶サーバ10Dの稼働状況を確認することで、新バージョンの記憶サーバ10Dがデータ記憶システム100で正常に動作するか否かをテストすることができる。一般に、システムにおいて新たなバージョンのOSなどを導入する場合には、システム全体を新たなバージョンのOSなどで構築してテストする必要があり非常に手間がかかる。しかし、この変形例によれば、既存のシステムに評価サーバ10Dを導入することで、実際の環境下でのテストが可能になる。また、実際の環境(データ記憶システム100)の動作を停止する必要もない。また、評価サーバ10Dが実際の環境下で正常に動作することが確認できたときには、既存の記憶サーバ10A〜10Cを順次評価サーバと入れ換える(例えば、プライマリサーバ10Aから直接記憶サーバ10Dに更新データを転送するようにして記憶サーバ10Dをセカンダリサーバとする。その後、セカンダリサーバの全てが新バージョンとなったら、図4と同様の動作によりプライマリサーバを記憶サーバ10Aから新バージョンの記憶サーバに切り換える。)ことで、システムを停止することなく、容易にシステム全体のバージョンアップをすることができる。
By checking the operation status of the storage server 10D, it is possible to test whether or not the new version of the storage server 10D operates normally in the
なお、この発明は上記実施形態に限定されず、種々の変形及び応用が可能である。例えば、監視サーバ20により、記憶サーバ10A〜10Cのデータベース15A〜15Cの記憶内容が同期しているか否かを確認するようにしてもよい。この確認は、例えば、各記憶サーバ10A〜10Cのデータ更新処理の処理履歴を比較し、処理結果が同一であるか否かを確認することによって行う。仮に、処理結果が異なる記憶サーバがあった場合は、図7、図8で示した復旧処理と同一の動作により、処理結果が異なる記憶サーバをリカバリするようにすればよい。
In addition, this invention is not limited to the said embodiment, A various deformation | transformation and application are possible. For example, the monitoring
上記実施形態では、CPU11が実行するプログラムは、予めROM12に格納されているものとして説明したが、外部記憶媒体や通信網を介してデータ記憶サーバ10の所定領域に格納されるものであってもよい。
In the above embodiment, the program executed by the
10(10A、10B、10C) 記憶サーバ
20 監視サーバ
30 オンラインコントローラ
40 生産装置
100 データ記憶システム
10 (10A, 10B, 10C)
Claims (9)
前記第1から第3のサーバのうち予め定められた1のサーバであるプライマリサーバは、
ネットワークを介して前記記憶装置に記憶されるデータを更新するための更新データを受信する受信手段と、
前記更新データに基づいて前記記憶装置に記憶されるデータを更新する第1の更新手段と、
前記更新データを他のサーバに転送する転送手段と、を備え、
前記第1から第3のサーバのうち前記プライマリサーバ以外のセカンダリサーバは、
前記プライマリサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新する第2の更新手段を備え、
前記監視装置は、前記プライマリサーバの動作が停止した場合に、前記セカンダリサーバのいずれかをプライマリサーバに切り換える切換手段を備える
ことを特徴とするデータ記憶システム。 Each of the first server, the second server, and the third server each having a storage device for storing data, and a monitoring device for monitoring these servers, each connected via a network A data storage system,
A primary server that is a predetermined one of the first to third servers is:
Receiving means for receiving update data for updating data stored in the storage device via a network;
First update means for updating data stored in the storage device based on the update data;
Transfer means for transferring the update data to another server,
Secondary servers other than the primary server among the first to third servers are
Second update means for updating data stored in the storage device based on update data transferred from the primary server;
The data storage system, wherein the monitoring device includes switching means for switching one of the secondary servers to the primary server when the operation of the primary server stops.
前記停止したサーバが動作を開始した場合、当該サーバの記憶装置に記憶されるデータを、前記送信蓄積手段に蓄積される更新データと、前記セカンダリサーバのうち前記動作を停止したサーバではないセカンダリサーバの記憶装置に記憶されるデータと、に基づいて更新する復旧手段を備える
ことを特徴とする請求項1に記載のデータ記憶システム。 The primary server switched by the switching means of the monitoring device further comprises transmission storage means for storing update data that should be transferred to the server whose operation is stopped by the transfer means,
When the stopped server starts operation, the data stored in the storage device of the server is updated data stored in the transmission storage means, and the secondary server that is not the server that has stopped the operation among the secondary servers The data storage system according to claim 1, further comprising recovery means for updating based on data stored in the storage device.
前記復旧手段により前記記憶装置に記憶されるデータを更新する間に受信する更新データを蓄積する受信蓄積手段と、
前記復旧手段によるデータの更新が終了した後に、前記受信蓄積手段が蓄積する更新データに基づいて前記記憶装置に記憶されるデータを更新する第3の更新手段と、を更に備える
ことを特徴とする請求項2に記載のデータ記憶システム。 A secondary server that is not the server that stopped the operation among the secondary servers,
Receiving and accumulating means for accumulating update data received while updating data stored in the storage device by the recovery means;
And further comprising third update means for updating data stored in the storage device based on update data stored in the reception storage means after the data update by the recovery means is completed. The data storage system according to claim 2.
ことを特徴とする請求項1乃至3のいずれか1項に記載のデータ記憶システム。 The primary server transmits an update completion notification indicating that the update of the data has been completed to the transmission source of the update data when the update of the data stored in the storage device is completed by the first update unit The data storage system according to claim 1, further comprising a notification transmission unit.
ことを特徴とする請求項1乃至4のいずれか1項に記載のデータ記憶システム。 The data storage system according to any one of claims 1 to 4, wherein the monitoring server further includes abnormality detection means for detecting an abnormality in the first to third servers.
前記第1のサーバは、
ネットワークを介して前記記憶装置に記憶されるデータを更新するための更新データを受信する手段と、
前記更新データに基づいて前記記憶装置に記憶されるデータを更新する手段と、
前記更新データを前記第2のサーバと前記第3のサーバとに転送する手段と、を備え、
前記第2のサーバは、
前記第1のサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新する手段を備え、
前記第3のサーバは、
前記第1のサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新する手段と、
前記更新データを前記第4のサーバに転送する手段と、を備え、
前記第4のサーバは、
前記第3のサーバから転送される更新データに基づいて前記記憶装置に記憶されるデータを更新する手段を備える
ことを特徴とするデータ記憶システム。 A first server, a second server, and a third server each having a storage device for storing data, and a fourth version of the fourth server having a storage device for storing data and different from the first to third servers A data storage system connected to each other via a network,
The first server is
Means for receiving update data for updating data stored in the storage device via a network;
Means for updating data stored in the storage device based on the update data;
Means for transferring the update data to the second server and the third server,
The second server is
Means for updating data stored in the storage device based on update data transferred from the first server;
The third server is
Means for updating data stored in the storage device based on update data transferred from the first server;
Means for transferring the update data to the fourth server,
The fourth server is
A data storage system comprising means for updating data stored in the storage device based on update data transferred from the third server.
前記第1から第3のサーバのうち予め定められた1のサーバであるプライマリサーバは、
ネットワークを介して前記記憶装置に記憶されるデータを更新するための更新データを受信し、
前記更新データに基づいて前記記憶装置に記憶されるデータを更新し、
前記更新データを他のサーバに転送し、
前記第1から第3のサーバのうち前記プライマリサーバ以外のセカンダリサーバは、
前記プライマリサーバから転送された更新データに基づいて前記記憶装置に記憶されるデータを更新し、
前記監視装置は、前記プライマリサーバの動作が停止した場合に、前記セカンダリサーバのいずれかをプライマリサーバに切り換える
ことを特徴とするデータ記憶方法。 Each of the first server, the second server, and the third server each having a storage device for storing data, and a monitoring device for monitoring these servers, each connected via a network A data storage method in a data storage system, comprising:
A primary server that is a predetermined one of the first to third servers is:
Receiving update data for updating data stored in the storage device via a network;
Updating the data stored in the storage device based on the update data;
Transferring the update data to another server;
Secondary servers other than the primary server among the first to third servers are
Update the data stored in the storage device based on the update data transferred from the primary server,
The monitoring device switches one of the secondary servers to a primary server when the operation of the primary server stops.
前記停止したサーバが動作を開始した場合、当該サーバの記憶装置に記憶されるデータを、前記蓄積される更新データと、前記セカンダリサーバのうち前記動作を停止したサーバではないセカンダリサーバの記憶装置に記憶されるデータと、に基づいて更新する
ことを特徴とする請求項7に記載のデータ記憶方法。 The primary server switched by the switching unit of the monitoring device accumulates update data that should be transferred to the server whose operation is stopped by the transfer unit,
When the stopped server starts operation, the data stored in the storage device of the server is transferred to the stored update data and the storage device of the secondary server that is not the stopped server among the secondary servers. The data storage method according to claim 7, wherein updating is performed based on the stored data.
前記動作を停止したサーバの記憶装置に記憶されるデータを更新する間に、受信する更新データを蓄積し、
そのデータの更新が終了した後に、前記蓄積する更新データに基づいて前記記憶装置に記憶されるデータを更新する
ことを特徴とする請求項7に記載のデータ記憶方法。 A secondary server that is not the server that stopped the operation among the secondary servers,
While updating the data stored in the storage device of the server that has stopped the operation, accumulate update data to be received,
The data storage method according to claim 7, wherein the data stored in the storage device is updated based on the accumulated update data after the update of the data is completed.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2008234279A JP5366184B2 (en) | 2008-09-12 | 2008-09-12 | Data storage system and data storage method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2008234279A JP5366184B2 (en) | 2008-09-12 | 2008-09-12 | Data storage system and data storage method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2010067115A true JP2010067115A (en) | 2010-03-25 |
| JP5366184B2 JP5366184B2 (en) | 2013-12-11 |
Family
ID=42192633
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2008234279A Expired - Fee Related JP5366184B2 (en) | 2008-09-12 | 2008-09-12 | Data storage system and data storage method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP5366184B2 (en) |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2012208578A (en) * | 2011-03-29 | 2012-10-25 | Shimadzu Corp | Analyzer control system |
| JP2014026587A (en) * | 2012-07-30 | 2014-02-06 | Nippon Telegr & Teleph Corp <Ntt> | Distributed database system, first database device of distributed database system, second database device of distributed database system and computer program |
| EP2937786A2 (en) | 2014-03-31 | 2015-10-28 | Fujitsu Limited | Storage system, storage device, and monitoring server |
| US9712380B2 (en) | 2013-08-30 | 2017-07-18 | Shimadzu Corporation | Analytical device control system |
| JP2018181038A (en) * | 2017-04-17 | 2018-11-15 | 富士通株式会社 | Management program, management apparatus and management method |
| JP2020035163A (en) * | 2018-08-29 | 2020-03-05 | アイコム株式会社 | Data setting system and data setting method |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2000207375A (en) * | 1999-01-12 | 2000-07-28 | Meidensha Corp | Method for duplicating data of decentralized control system |
| JP2004348174A (en) * | 2002-07-30 | 2004-12-09 | Hitachi Ltd | Storage system |
| JP2005339411A (en) * | 2004-05-28 | 2005-12-08 | Toshiba Corp | Distributed data equivalence method and system, and program |
| JP2006338145A (en) * | 2005-05-31 | 2006-12-14 | Nippon Telegr & Teleph Corp <Ntt> | Multiplexed database system, synchronization method thereof, mediation apparatus, and mediation program |
| JP2007241324A (en) * | 2004-08-17 | 2007-09-20 | Nippon Telegr & Teleph Corp <Ntt> | Multiplexed database system, synchronization method thereof, mediation apparatus, and mediation program |
-
2008
- 2008-09-12 JP JP2008234279A patent/JP5366184B2/en not_active Expired - Fee Related
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2000207375A (en) * | 1999-01-12 | 2000-07-28 | Meidensha Corp | Method for duplicating data of decentralized control system |
| JP2004348174A (en) * | 2002-07-30 | 2004-12-09 | Hitachi Ltd | Storage system |
| JP2005339411A (en) * | 2004-05-28 | 2005-12-08 | Toshiba Corp | Distributed data equivalence method and system, and program |
| JP2007241324A (en) * | 2004-08-17 | 2007-09-20 | Nippon Telegr & Teleph Corp <Ntt> | Multiplexed database system, synchronization method thereof, mediation apparatus, and mediation program |
| JP2006338145A (en) * | 2005-05-31 | 2006-12-14 | Nippon Telegr & Teleph Corp <Ntt> | Multiplexed database system, synchronization method thereof, mediation apparatus, and mediation program |
Cited By (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2012208578A (en) * | 2011-03-29 | 2012-10-25 | Shimadzu Corp | Analyzer control system |
| JP2014026587A (en) * | 2012-07-30 | 2014-02-06 | Nippon Telegr & Teleph Corp <Ntt> | Distributed database system, first database device of distributed database system, second database device of distributed database system and computer program |
| US9712380B2 (en) | 2013-08-30 | 2017-07-18 | Shimadzu Corporation | Analytical device control system |
| EP2937786A2 (en) | 2014-03-31 | 2015-10-28 | Fujitsu Limited | Storage system, storage device, and monitoring server |
| JP2015197742A (en) * | 2014-03-31 | 2015-11-09 | 富士通株式会社 | Storage system, storage device and monitoring server |
| EP2937786A3 (en) * | 2014-03-31 | 2015-12-16 | Fujitsu Limited | Storage system, storage device, and monitoring server |
| US9760460B2 (en) | 2014-03-31 | 2017-09-12 | Fujitsu Limited | Storage system, storage device, and monitoring server |
| JP2018181038A (en) * | 2017-04-17 | 2018-11-15 | 富士通株式会社 | Management program, management apparatus and management method |
| JP2020035163A (en) * | 2018-08-29 | 2020-03-05 | アイコム株式会社 | Data setting system and data setting method |
| JP7157315B2 (en) | 2018-08-29 | 2022-10-20 | アイコム株式会社 | Data setting system and data setting method |
Also Published As
| Publication number | Publication date |
|---|---|
| JP5366184B2 (en) | 2013-12-11 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US7197634B2 (en) | System and method for updating device firmware | |
| US7793060B2 (en) | System method and circuit for differential mirroring of data | |
| JP4940967B2 (en) | Storage system, storage device, firmware hot replacement method, firmware hot swap program | |
| JP5366184B2 (en) | Data storage system and data storage method | |
| US20150317175A1 (en) | Virtual machine synchronization system | |
| JP2007164769A (en) | Methods, systems, and programs for managing failures in a mirrored system (managing failures in a mirrored system) | |
| JP2009015476A (en) | Journal management method in CDP remote configuration | |
| US8880552B2 (en) | Database system and database control method | |
| JP6124644B2 (en) | Information processing apparatus and information processing system | |
| TW200426571A (en) | Policy-based response to system errors occurring during os runtime | |
| US20090249010A1 (en) | Apparatus and method for controlling copying | |
| JP5104479B2 (en) | Information processing device | |
| EP1672501A2 (en) | Fault tolerant duplex computer system and its control method | |
| JP2019079263A (en) | Redundant-system storage system and failure recovery method for redundant-system storage system | |
| CN111917576A (en) | Control method and device for storage cluster | |
| JP5342395B2 (en) | Computer system and method | |
| JP2006235992A (en) | Printer firmware rewriting system, firmware rewriting method, and printer | |
| JP2009098715A (en) | Redundant system device, job execution method in redundant system device, and execution program | |
| JPWO2012070102A1 (en) | Computer apparatus and program | |
| JP5939053B2 (en) | Remote backup device, remote backup system, method and program | |
| WO2007094041A1 (en) | Server managing device and server managing program | |
| JP5509651B2 (en) | Log collection device, log collection method, program | |
| JP4459185B2 (en) | Computer system | |
| JP2003256399A (en) | Control method for switching in hot standby system | |
| CN117785568B (en) | Dual-host dual-machine hot standby method and device |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20110810 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20130218 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20130226 |
|
| A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20130426 |
|
| 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: 20130813 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20130905 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 5366184 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| S111 | Request for change of ownership or part of ownership |
Free format text: JAPANESE INTERMEDIATE CODE: R313111 |
|
| R350 | Written notification of registration of transfer |
Free format text: JAPANESE INTERMEDIATE CODE: R350 |
|
| LAPS | Cancellation because of no payment of annual fees |