JP7564438B2 - Information processing system, log transmission program, information processing device, and log transmission method - Google Patents
Information processing system, log transmission program, information processing device, and log transmission method Download PDFInfo
- Publication number
- JP7564438B2 JP7564438B2 JP2020206497A JP2020206497A JP7564438B2 JP 7564438 B2 JP7564438 B2 JP 7564438B2 JP 2020206497 A JP2020206497 A JP 2020206497A JP 2020206497 A JP2020206497 A JP 2020206497A JP 7564438 B2 JP7564438 B2 JP 7564438B2
- Authority
- JP
- Japan
- Prior art keywords
- information processing
- commit log
- processing device
- information
- log
- 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 an information processing system, a log transmission program, an information processing device, and a log transmission method.
例えば、金融商品等を扱う証券取引システム(以下、単に取引システムとも呼ぶ)では、取引参加者からの株の売買注文を受信した場合や株の売買が成立した場合、その株の売買状況についての情報(以下、取引情報とも呼ぶ)をデータベースに反映する。そして、取引システムは、例えば、証券会社や取引参加者等が有する外部の情報処理システム(以下、外部システムとも呼ぶ)に対して、各取引情報をデータベースに反映した際のコミットログを送信する。 For example, in a securities trading system (hereinafter simply referred to as a trading system) that handles financial products, when a stock buy/sell order is received from a trading participant or when a stock trade is concluded, information about the stock trading status (hereinafter also referred to as trading information) is reflected in a database. The trading system then transmits a commit log when each piece of trading information is reflected in the database to an external information processing system (hereinafter also referred to as an external system) owned by, for example, a securities company or a trading participant.
具体的に、上記のような取引システムは、例えば、株の売買に伴う処理を行う情報処理装置(以下、アクティブ装置とも呼ぶ)と、アクティブ装置において異常等が発生した場合に処理を引き継いで行う情報処理装置(以下、スタンバイ装置とも呼ぶ)と、外部システムに対してコミットログの送信を行う情報処理装置(以下、連携装置とも呼ぶ)とから構成される。そして、アクティブ装置は、例えば、スタンバイ装置及び連携装置のそれぞれに対してコミットログの送信を行う。これにより、アクティブ装置は、外部システムに対するコミットログの送信を行うとともに、アクティブ装置のデータベースとスタンバイ装置のデータベースとの間における同期を行うことが可能になる(例えば、特許文献1を参照)。 Specifically, the above-mentioned trading system is composed of, for example, an information processing device (hereinafter also referred to as an active device) that performs processing associated with buying and selling stocks, an information processing device (hereinafter also referred to as a standby device) that takes over processing if an abnormality or the like occurs in the active device, and an information processing device (hereinafter also referred to as a cooperating device) that transmits a commit log to an external system. The active device then transmits a commit log to, for example, both the standby device and the cooperating device. This enables the active device to transmit a commit log to the external system and to synchronize the database of the active device with the database of the standby device (for example, see Patent Document 1).
ここで、上記のようなスタンバイ装置や連携装置は、アクティブ装置からコミットログを受信した場合、コミットログの受信が正常に行われたことを示す通知(以下、応答通知)をアクティブ装置に送信する。これにより、アクティブ装置は、各コミットログの送信が正常に完了したか否かについて判断を行うことが可能になる。 When a standby device or a cooperating device such as the above receives a commit log from an active device, it sends a notification (hereinafter, a response notification) to the active device indicating that the commit log was received successfully. This enables the active device to determine whether the transmission of each commit log was completed successfully.
しかしながら、アクティブ装置は、この場合、スタンバイ装置から送信される応答通知だけでなく、連携装置から送信される応答通知についても待ち合わせる必要がある。そのため、アクティブ装置では、例えば、連携装置から送信される応答通知の待ち合わせに時間を要する場合、処理性能が低下する可能性がある。 However, in this case, the active device must wait not only for the response notification sent from the standby device, but also for the response notification sent from the cooperating device. Therefore, for example, if the active device needs time to wait for the response notification sent from the cooperating device, the processing performance may be degraded.
そこで、一つの側面では、本発明は、応答通知の待ち合わせに伴う処理性能の低下を防止することを可能とする情報処理システム、ログ送信プログラム、情報処理装置及びログ送信方法を提供することを目的とする。 In one aspect, the present invention aims to provide an information processing system, a log transmission program, an information processing device, and a log transmission method that can prevent a decrease in processing performance due to waiting for response notifications.
実施の形態の一態様では、データベースに対するトランザクションについてのコミットログを送信する第1情報処理装置と、前記コミットログを前記第1情報処理装置から受信する第2情報処理装置及び第3情報処理装置と、前記コミットログを前記第1情報処理装置から受信する送信先装置とを有する情報処理システムであって、前記第1情報処理装置は、前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う情報処理装置を、前記第2情報処理装置及び前記第3情報処理装置のうちのいずれかの情報処理装置を決定し、前記第1情報処理装置は、決定した前記いずれかの情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記いずれかの情報処理装置とにそれぞれ送信し、前記いずれかの情報処理装置は、前記コミットログを前記第1情報処理装置から受信したら、受信した前記コミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、前記いずれかの情報処理装置は、前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、前記送信先装置は、前記コミットログを前記第1情報処理装置から受信し、かつ、前記コミットログの前記受信確認の指示を前記いずれかの情報処理装置から受信したら、前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記いずれかの情報処理装置に送信し、前記いずれかの情報処理装置は、前記受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する。 In one aspect of the embodiment, an information processing system includes a first information processing device that transmits a commit log for a transaction to a database, a second information processing device and a third information processing device that receive the commit log from the first information processing device, and a destination device that receives the commit log from the first information processing device, in which when the transaction is committed, the first information processing device determines which of the second information processing device and the third information processing device is an information processing device that will confirm receipt of the commit log at the destination device, and the first information processing device transmits the commit log to which identification information of the determined one of the information processing devices is added to the destination device and one of the information processing devices, and one of the information processing devices transmits the commit log to the previous information processing device. When the commit log is received from the first information processing device, it is determined whether the identification information included in the received commit log indicates its own device, and when the information processing device determines that the identification information included in the commit log indicates its own device, it stores the commit log in a storage unit and transmits an instruction to the destination device to confirm receipt of the commit log, and when the destination device receives the commit log from the first information processing device and receives an instruction to confirm receipt of the commit log from the one of the information processing devices, it transmits a receipt confirmation result to the one of the information processing devices indicating that the reception of the commit log at the destination device has been completed successfully, and when the one of the information processing devices receives the receipt confirmation result from the destination device, it deletes the commit log from the storage unit.
一つの側面によれば、応答通知の待ち合わせに伴う処理性能の低下を防止することを可能とする。 According to one aspect, it is possible to prevent a decrease in processing performance due to waiting for response notifications.
[情報処理システムの構成]
初めに、取引システム10の構成について説明を行う。図1は、取引システム10の構成について説明する図である。
[Configuration of Information Processing System]
First, a description will be given of the configuration of the
図1に示す取引システム10(以下、情報処理システム10とも呼ぶ)は、例えば、アクティブ装置1と、スタンバイ装置2と、スタンバイ装置3と、連携装置4と、受付装置5とを有する。
The trading system 10 (hereinafter also referred to as information processing system 10) shown in FIG. 1 has, for example, an
受付装置5は、例えば、証券会社が有する情報処理システム(図示せず)から送信された株の売買注文を受け付ける。そして、受付装置5は、例えば、受け付けた売買注文を成立させるための処理の実行を依頼する処理依頼(以下、単に処理依頼とも呼ぶ)をアクティブ装置1に送信する。
The
アクティブ装置1の処理部1aは、例えば、受付装置5から受信した処理依頼に対応する売買注文(受付装置5が受信した売買注文)を取り纏めて株の売買を成立させる。そして、処理部1aは、例えば、成立させた売買の内容をデータベース1b(以下、DB1bとも表記する)に反映する。さらに、処理部1aは、データベース1bにおける売買の反映結果を示すコミットログを生成する。その後、処理部1aは、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、生成したコミットログを送信する。
The
スタンバイ装置2の処理部2aは、アクティブ装置1から送信されたコミットログの内容をデータベース2b(以下、DB2bとも表記する)に反映することによって、データベース1bとデータベース2bとの間の同期処理を行う。同様に、スタンバイ装置3の処理部3aは、アクティブ装置1から送信されたコミットログの内容をデータベース3b(以下、DB3bとも表記する)に反映することによって、データベース1bとデータベース3bとの間の同期処理を行う。そして、例えば、アクティブ装置1において所定の異常が発生した場合、スタンバイ装置2またはスタンバイ装置3は、アクティブ装置1が実行していた処理を引き継いで実行する。
The
なお、以下、取引システム10が2台のスタンバイ装置(スタンバイ装置2及びスタンバイ装置3)を有する場合について説明を行うが、取引システム10は、2台以外の台数のスタンバイ装置を有するものであってもよい。
Note that, although the following description will be given of a case where
連携装置4は、アクティブ装置1から送信されたコミットログを外部システム20に送信する。具体的に、連携装置4は、アクティブ装置1から送信されたコミットログを、外部システム20がアクセス可能なメッセージキュー(図示せず)に順次格納する。
The
ここで、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれは、アクティブ装置1からコミットログを受信した場合、コミットログの受信が正常に行われたことを示す応答通知をアクティブ装置1に送信する。これにより、アクティブ装置1は、各コミットログの送信が正常に完了したか否かについて判断を行うことが可能になる。
When each of the
しかしながら、アクティブ装置1は、この場合、スタンバイ装置2及びスタンバイ装置3から送信される応答通知だけでなく、連携装置4から送信される応答通知についても待ち合わせる必要がある。そのため、アクティブ装置1では、例えば、連携装置4から送信される応答通知の待ち合わせ時間が長時間に及ぶ場合、株の売買に伴う処理等の性能低下が発生する。
However, in this case, the
そこで、本実施の形態におけるアクティブ装置1は、データベース1bに対するトランザクションがコミットした場合、スタンバイ装置2及びスタンバイ装置3のうちのいずれかのスタンバイ装置を、連携装置4におけるコミットログの受信確認を行うスタンバイ装置(以下、特定のスタンバイ装置とも呼ぶ)として決定する。そして、アクティブ装置1は、決定した特定のスタンバイ装置の識別情報を付加したコミットログを連携装置4と特定のスタンバイ装置とにそれぞれ送信する。
In this embodiment, when a transaction to
その後、特定のスタンバイ装置は、コミットログをアクティブ装置1から受信した場合、受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する。その結果、受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、特定のスタンバイ装置は、受信したコミットログを記憶部に記憶するとともに、連携装置4に対してコミットログの受信確認の指示を送信する。
After that, when the specific standby device receives a commit log from the
そして、連携装置4は、コミットログをアクティブ装置1から受信し、かつ、コミットログの受信確認の指示を特定のスタンバイ装置から受信した場合、コミットログの受信が正常に完了したことを示す応答通知を特定のスタンバイ装置に送信する。
Then, when the coordinating
さらに、特定のスタンバイ装置は、コミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信した場合、アクティブ装置1から受信したコミットログを記憶部から削除する。
Furthermore, when a particular standby device receives a response notification from the cooperating
すなわち、本実施の形態における取引システム10では、連携装置4におけるコミットログの受信確認を特定のスタンバイ装置が行う。
In other words, in the
これにより、本実施の形態における取引システム10は、例えば、連携装置4から送信される応答通知の待ち合わせに時間を要する場合であっても、アクティブ装置1における処理性能の低下を防止することが可能になる。
As a result, the
[取引システムのハードウエア構成]
次に、取引システム10のハードウエア構成について説明する。図2は、アクティブ装置1のハードウエア構成を説明する図である。また、図3は、スタンバイ装置2のハードウエア構成を説明する図である。さらに、図4は、連携装置4のハードウエア構成を説明する図である。なお、スタンバイ装置3のハードウエア構成については、スタンバイ装置2のハードウエア構成と同じであるため説明を省略する。
[Hardware configuration of trading system]
Next, the hardware configuration of the
初めに、アクティブ装置1のハードウエア構成について説明を行う。
First, we will explain the hardware configuration of
アクティブ装置1は、図2に示すように、プロセッサであるCPU101と、メモリ102と、通信装置103と、記憶媒体104とを有する。各部は、バス105を介して互いに接続される。
As shown in FIG. 2, the
記憶媒体104は、例えば、連携装置4に対してコミットログを送信する処理(以下、ログ送信処理とも呼ぶ)を行うためのプログラム110を記憶するプログラム格納領域(図示せず)を有する。また、記憶媒体104は、例えば、ログ送信処理を行う際に用いられる情報を記憶する情報格納領域130を有する。なお、記憶媒体104は、例えば、HDD(Hard Disk Drive)やSSD(Solid State Drive)であってよい。
The
CPU101は、記憶媒体104からメモリ102にロードされたプログラム110を実行してログ送信処理を行う。
The
また、通信装置103は、例えば、ネットワークNWを介してスタンバイ装置2等との通信を行う。
The
次に、スタンバイ装置2のハードウエア構成について説明を行う。
Next, we will explain the hardware configuration of
スタンバイ装置2は、図3に示すように、プロセッサであるCPU201と、メモリ202と、通信装置203と、記憶媒体204とを有する。各部は、バス205を介して互いに接続される。
As shown in FIG. 3, the
記憶媒体204は、例えば、ログ送信処理を行うためのプログラム210を記憶するプログラム格納領域(図示せず)を有する。また、記憶媒体204は、例えば、ログ送信処理を行う際に用いられる情報を記憶する情報格納領域230を有する。なお、記憶媒体204は、例えば、HDDやSSDであってよい。
The
CPU201は、記憶媒体204からメモリ202にロードされたプログラム210を実行してログ送信処理を行う。
The
また、通信装置203は、例えば、ネットワークNWを介してアクティブ装置1等との通信を行う。
The
次に、連携装置4のハードウエア構成について説明を行う。
Next, we will explain the hardware configuration of linked
連携装置4は、図4に示すように、プロセッサであるCPU401と、メモリ402と、通信装置403と、記憶媒体404とを有する。各部は、バス405を介して互いに接続される。
As shown in FIG. 4, the linked
記憶媒体404は、例えば、ログ送信処理を行うためのプログラム410を記憶するプログラム格納領域(図示せず)を有する。また、記憶媒体404は、例えば、ログ送信処理を行う際に用いられる情報を記憶する情報格納領域430を有する。なお、記憶媒体404は、例えば、HDDやSSDであってよい。
The
CPU401は、記憶媒体404からメモリ402にロードされたプログラム410を実行してログ送信処理を行う。
The
また、通信装置403は、例えば、ネットワークNWを介してアクティブ装置1等との通信を行う。
The
[取引システムの機能]
次に、取引システム10の機能について説明を行う。図5は、アクティブ装置1の機能のブロック図である。また、図6は、スタンバイ装置2の機能のブロック図である。さらに、図7は、連携装置4の機能のブロック図である。なお、スタンバイ装置3の機能については、スタンバイ装置2の機能と同じであるため説明を省略する。
[Trading system functions]
Next, the functions of the
初めに、アクティブ装置1の機能について説明を行う。
First, we will explain the functions of the
アクティブ装置1は、図5に示すように、CPU101やメモリ102等のハードウエアとプログラム110とが有機的に協働することにより、例えば、情報受信部111と、取引処理部112と、情報管理部113と、情報生成部114と、装置決定部115と、情報送信部116とを含む各種機能を実現する。なお、図1で説明した処理部1aは、例えば、情報受信部111、取引処理部112、情報管理部113、情報生成部114、装置決定部115及び情報送信部116に対応する。
As shown in FIG. 5, the
また、アクティブ装置1は、図5に示すように、例えば、対応情報131を情報格納領域130に記憶する。
In addition, as shown in FIG. 5, the
情報受信部111は、受付装置5が送信した処理依頼を受信する。具体的に、情報受信部111は、例えば、受付装置5が受け付けた売買注文を成立させるための処理依頼を受信する。
The
取引処理部112は、例えば、情報受信部111が受信した処理依頼に対応する売買注文を取り纏めて株の売買を成立させる。そして、情報管理部113は、例えば、取引処理部112が株の売買を成立させた場合、取引処理部112が成立させた売買注文(情報受信部111が受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。また、情報管理部113は、例えば、取引処理部112が株の売買を成立させなかった場合、取引処理部112が成立させなかった売買注文(情報受信部111が受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。
The
情報生成部114は、データベース1bに対するトランザクション(情報受信部111が受信した処理依頼に対応するトランザクション)がコミットした場合、そのトランザクションについてのコミットログを生成する。
When a transaction for
装置決定部115は、情報生成部114が生成したコミットログの連携装置4における受信確認を行う特定のスタンバイ装置を決定する。そして、情報生成部114は、装置決定部115が決定した特定のスタンバイ装置の識別情報をコミットログに付加する。
The
情報送信部116は、特定のスタンバイ装置の識別情報を付加したコミットログを、連携装置4と特定のスタンバイ装置とにそれぞれ送信する。対応情報131についての説明は後述する。
The
次に、スタンバイ装置2の機能について説明を行う。
Next, we will explain the functions of
スタンバイ装置2は、図6に示すように、CPU201やメモリ202等のハードウエアとプログラム210とが有機的に協働することにより、例えば、情報受信部211と、情報管理部212と、情報判定部213と、再送制御部214と、情報送信部215とを含む各種機能を実現する。なお、図1で説明した処理部2aは、例えば、情報受信部211、情報管理部212、情報判定部213、再送制御部214及び情報送信部215に対応する。
As shown in FIG. 6, the
情報受信部211は、アクティブ装置1が送信したコミットログを受信する。そして、情報管理部212は、情報受信部211が受信したコミットログの内容をデータベース2bに書き込む。
The
情報判定部213は、情報受信部211が受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する。
The
再送制御部214は、情報受信部211が受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、情報受信部211が受信したコミットログを情報格納領域130に記憶する。
When the
情報送信部215は、情報受信部211が受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、情報受信部211が受信したコミットログの受信確認の指示を連携装置4に対して送信する。
When the
また、情報受信部211は、情報受信部211が受信したコミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信する。そして、再送制御部214は、情報受信部211が連携装置4から送信された応答通知を受信した場合、情報受信部211が受信したコミットログを情報格納領域130から削除する。
The
なお、以下、連携装置4に対するコミットログの再送を行う処理(再送制御部214が行う処理)を再送処理とも呼ぶ。 Note that, hereinafter, the process of resending the commit log to the collaboration device 4 (the process performed by the resend control unit 214) is also referred to as the resend process.
次に、連携装置4の機能について説明を行う。
Next, we will explain the functions of linked
連携装置4は、図7に示すように、CPU401やメモリ402等のハードウエアとプログラム410とが有機的に協働することにより、例えば、情報受信部411と、受信判定部412と、情報送信部413とを含む各種機能を実現する。
As shown in FIG. 7, the
情報受信部411は、アクティブ装置1が送信したコミットログを受信する。また、情報受信部411は、特定のスタンバイ装置が送信した受信確認の指示を受信する。
The
受信判定部412は、情報受信部411がコミットログと受信確認の指示とを受信しているか否かを判定する。具体的に、受信判定部412は、情報受信部411が受信確認の指示を受信した場合、その受信確認の指示に対応するコミットログを既に受信しているか否かを判定する。
The
情報送信部413は、情報受信部411がコミットログと受信確認の指示とを受信していると受信判定部412が判定した場合、情報受信部411が受信したコミットログの受信が正常に完了したことを示す応答通知を特定のスタンバイ装置に送信する。
When the
また、情報送信部413は、情報受信部411が受信したコミットログを外部システム20に送信する。
In addition, the
[第1の実施の形態の概略]
次に、第1の実施の形態の概略について説明する。図8から図10は、第1の実施の形態におけるログ送信処理の概略を説明するフローチャート図である。具体的に、図8は、アクティブ装置1におけるログ送信処理の概略を説明するフローチャート図である。また、図9は、スタンバイ装置2におけるログ送信処理の概略を説明するフローチャート図である。さらに、図10は、連携装置4におけるログ送信処理の概略を説明するフローチャート図である。なお、スタンバイ装置3における処理については、スタンバイ装置2における処理と同じであるため説明を省略する。
[Overview of the first embodiment]
Next, an outline of the first embodiment will be described. Figures 8 to 10 are flow charts outlining the log transmission process in the first embodiment. Specifically, Figure 8 is a flow chart outlining the log transmission process in the
初めに、アクティブ装置1におけるログ送信処理の概略について説明を行う。
First, we will provide an overview of the log transmission process in the
アクティブ装置1は、図8に示すように、データベース1bに対するトランザクションがコミットするまで待機する(S1のNO)。
As shown in FIG. 8, the
そして、データベース1bに対するトランザクションがコミットした場合(S1のYES)、アクティブ装置1は、コミットしたトランザクションについてのコミットログの連携装置4における受信確認を行う特定のスタンバイ装置を決定する(S2)。
Then, when the transaction for
具体的に、アクティブ装置1は、例えば、スタンバイ装置2及びスタンバイ装置3のいずれかを特定のスタンバイ装置として決定する。
Specifically,
その後、アクティブ装置1は、S2の処理において決定した特定のスタンバイ装置の識別情報を付加したコミットログを、S2の処理において決定した特定のスタンバイ装置と連携装置4とにそれぞれ送信する(S3)。
Then, the
次に、スタンバイ装置2におけるログ送信処理の概略について説明を行う。
Next, we will provide an overview of the log transmission process on the
スタンバイ装置2は、図9に示すように、アクティブ装置1から送信されたコミットログを受信するまで待機する(S11のNO)。
As shown in FIG. 9, the
そして、アクティブ装置1から送信されたコミットログを受信した場合(S11のYES)、スタンバイ装置2は、S11の処理において受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する(S12)。
Then, when a commit log sent from the
その結果、S11の処理において受信したコミットログに含まれる識別情報が自装置を示していると判定した場合(S13のYES)、スタンバイ装置2は、S11の処理において受信したコミットログを情報格納領域230に記憶するとともに、S11の処理において受信したコミットログの受信確認の指示を連携装置4に対して行う(S14)。
As a result, if it is determined that the identification information included in the commit log received in processing S11 indicates the standby device 2 (YES in S13), the
その後、コミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信した場合(S15のYES)、スタンバイ装置2は、S11の処理において受信したコミットログ(S14の処理において記憶したコミットログ)を情報格納領域230から削除する(S16)。
Thereafter, if a response notification is received from the
一方、コミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信しなかった場合(S15のNO)、スタンバイ装置2は、S16の処理を行わない。
On the other hand, if a response notification indicating that the receipt of the commit log has been completed successfully is not received from the collaboration device 4 (NO in S15), the
また、S11の処理において受信したコミットログに含まれる識別情報が自装置を示していないと判定した場合(S13のNO)、スタンバイ装置2は、S14以降の処理を行わない。
Furthermore, if it is determined in the processing of S11 that the identification information contained in the received commit log does not indicate the standby device 2 (NO in S13), the
次に、連携装置4におけるログ送信処理の概略について説明を行う。
Next, we will provide an overview of the log transmission process in the linked
連携装置4は、図10に示すように、アクティブ装置1からコミットログを受信し、かつ、特定のスタンバイ装置から受信確認の指示を受信するまで待機する(S21のNO)。
As shown in FIG. 10, the coordinating
そして、コミットログ及び受信確認の指示を受信した場合(S21のYES)、連携装置4は、受信した受信確認の指示に対する応答通知(コミットログの受信が正常に完了したことを示す応答通知)を特定のスタンバイ装置に送信する(S22)。
Then, if a commit log and a receipt confirmation instruction are received (YES in S21), the coordinating
すなわち、本実施の形態における取引システム10では、連携装置4におけるコミットログの受信確認を特定のスタンバイ装置が行う。
In other words, in the
これにより、本実施の形態における取引システム10は、例えば、連携装置4から送信される応答通知の待ち合わせに時間を要する場合であっても、アクティブ装置1における処理性能の低下を防止することが可能になる。
As a result, the
[第1の実施の形態の詳細]
次に、第1の実施の形態の詳細について説明する。図11から図17は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。また、図18から図26は、第1の実施の形態におけるログ送信処理の詳細を説明する図である。なお、スタンバイ装置3における処理については、スタンバイ装置2における処理と同じであるため説明を省略する。
[Details of the First Embodiment]
Next, the details of the first embodiment will be described. Figures 11 to 17 are flow charts for explaining the details of the log transmission process in the first embodiment. Figures 18 to 26 are diagrams for explaining the details of the log transmission process in the first embodiment. Note that the process in the
[アクティブ装置におけるログ送信処理の詳細]
初めに、アクティブ装置1におけるログ送信処理の詳細について説明を行う。図11から図13は、アクティブ装置1におけるログ送信処理の詳細について説明するフローチャート図である。
[Details of log transmission process in active device]
First, a detailed description will be given of the log transmission process in the
情報受信部111は、図11に示すように、例えば、受付装置5が送信した処理依頼を受信するまで待機する(S31のNO)。
As shown in FIG. 11, the
そして、受付装置5が送信した処理依頼を受信した場合(S31のYES)、情報管理部113は、受信した処理依頼に対応する内容をデータベース1bに反映する(S32)。
Then, when a processing request sent by the
具体的に、情報管理部113は、例えば、取引処理部112が株の売買を成立させた場合、取引処理部112が成立させた売買注文(S31の処理において受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。また、情報管理部113は、例えば、取引処理部112が株の売買を成立させなかった場合、取引処理部112が成立させなかった売買注文(S31の処理において受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。
Specifically, for example, if the
続いて、情報生成部114は、S31の処理において受信した処理依頼に対応するトランザクションについてのコミットログを生成する(S33)。以下、S33の処理において生成されたコミットログの具体例について説明を行う。
Next, the
[コミットログの具体例]
図18及び図20は、コミットログCLの具体例を説明する図である。
[Example of a commit log]
18 and 20 are diagrams for explaining specific examples of the commit log CL.
図18等に示すコミットログCLは、コミットログCLを示す電文種別が設定される「電文種別」と、各コミットログCLに対応するトランザクションの識別番号であるシーケンス番号が設定される「シーケンス番号」と、各コミットログCLの再送制御を行うスタンバイ装置の識別情報が設定される「識別情報」とを項目として有する。また、図18等に示すコミットログCLは、各コミットログCLに対応するレコードの格納位置(データベース1bにおける格納位置)が設定される「レコード番号」と、各コミットログCLに対応するレコードの内容が設定される「レコード情報」とを項目として有する。
The commit log CL shown in FIG. 18 etc. has as its items "message type" in which the message type indicating the commit log CL is set, "sequence number" in which the sequence number that is the identification number of the transaction corresponding to each commit log CL is set, and "identification information" in which the identification information of the standby device that controls the retransmission of each commit log CL is set. In addition, the commit log CL shown in FIG. 18 etc. has as its items "record number" in which the storage location (storage location in
具体的に、図18に示すコミットログCLは、「電文種別」として「コミットログ」が設定され、「シーケンス番号」として「0013」が設定され、「識別情報」として情報が設定されていないことを示す「-」が設定され、「レコード番号」として「0003」が設定されている。なお、以下、レコード番号を特定の項目とも呼ぶ。 Specifically, in the commit log CL shown in FIG. 18, "commit log" is set as the "message type," "0013" is set as the "sequence number," "-" is set as the "identification information" indicating that no information is set, and "0003" is set as the "record number." Note that hereinafter, the record number will also be referred to as a specific item.
図11に戻り、装置決定部115は、S33の処理において生成したコミットログの連携装置4における受信確認を行う特定のスタンバイ装置を決定する(S34)。以下、S34の処理の詳細について説明を行う。
Returning to FIG. 11, the
[S34の処理の詳細]
図13は、S34の処理の詳細について説明するフローチャート図である。
[Details of the process of S34]
FIG. 13 is a flow chart illustrating the details of the process of S34.
装置決定部115は、S33の処理において生成したコミットログに含まれるレコード番号を含む対応情報131が情報格納領域130に記憶されているか否かを判定する(S51)。以下、対応情報131の具体例について説明を行う。
The
[対応情報の具体例]
図19及び図21は、対応情報131の具体例を説明する図である。
[Examples of correspondence information]
19 and 21 are diagrams for explaining specific examples of the
図19等に示す対応情報131は、各スタンバイ装置の識別情報が設定される「識別情報」と、各スタンバイ装置が再送制御を行うコミットログに対応するレコードの格納位置が設定される「レコード番号」とを項目として有する。「識別情報」には、例えば、スタンバイ装置2を示す「Standby1」、または、スタンバイ装置3を示す「Standby2」が設定される。
The
具体的に、図19に示す対応情報131において、例えば、1行目の情報には、「識別情報」として「Standby2」が設定され、「レコード番号」として「0001」が設定されている。
Specifically, in the
また、図19に示す対応情報131において、例えば、2行目の情報には、「識別情報」として「Standby1」が設定され、「レコード番号」として「0002」が設定されている。図19に含まれる他の情報についての説明は省略する。
In addition, in the
図13に戻り、S33の処理において生成したコミットログに含まれるレコード番号を含む対応情報131が情報格納領域130に記憶されていると判定した場合(S52のYES)、装置決定部115は、情報格納領域130に記憶した対応情報131を参照し、S33の処理において生成したコミットログに含まれるレコード番号に対応するスタンバイ装置を、S33の処理において生成したコミットログの受信確認を行う特定のスタンバイ装置として決定する(S53)。
Returning to FIG. 13, if it is determined that
具体的に、図19で説明した対応情報131において、「レコード番号」に「0003」が設定された情報(3行目の情報)の「識別情報」には、「Standby1」が設定されている。そのため、例えば、S33の処理において生成したコミットログに含まれるレコード番号が「0003」である場合、装置決定部115は、スタンバイ装置2を特定のスタンバイ装置として決定する。
Specifically, in the
すなわち、対応情報131には、各レコード番号に対応するコミットログの送信(再送)を行っているスタンバイ装置の情報が含まれている。そのため、装置決定部115は、特定のスタンバイ装置を対応情報131に従って決定することによって、同一のレコード番号を有するコミットログの送信を同一のスタンバイ装置に行わせることが可能になる。
In other words, the
これにより、アクティブ装置1は、同一のレコード番号を有するコミットログの送信が複数のスタンバイ装置において行われることを防止することが可能になる。そのため、アクティブ装置1は、例えば、ネットワークの状況等に起因して各スタンバイ装置から送信されたコミットログの順序が入れ替わる可能性がある場合であっても、同一レコード番号を有するコミットログの送信順序が入れ替わることを防止することが可能になる。
This enables the
一方、S33の処理において生成したコミットログに含まれるレコード番号を含む対応情報131が情報格納領域130に記憶されていないと判定した場合(S52のNO)、装置決定部115は、例えば、情報格納領域130に記憶した対応情報131に含まれる数(割合)が最小である識別情報に対応するスタンバイ装置を、S33の処理において生成したコミットログの受信確認を行う特定のスタンバイ装置として決定する(S54)。
On the other hand, if it is determined that the
具体的に、図19で説明した対応情報131において、例えば、「識別情報」に「Standby1」が設定された情報(行)の数が、「識別情報」に「Standby2」が設定された情報の数よりも少ない場合、装置決定部115は、スタンバイ装置2を特定のスタンバイ装置として決定する。
Specifically, in the
これにより、アクティブ装置1は、各スタンバイ装置における処理負荷を均等化することが可能になる。
This allows the
その後、装置決定部115は、S33の処理において生成したコミットログに含まれるレコード番号と、S54の処理において決定したスタンバイ装置の識別情報とを対応付けた情報を対応情報131の少なくとも一部として情報格納領域130に記憶する(S55)。
Then, the
図11に戻り、情報生成部114は、S34の処理において決定した特定のスタンバイ装置の識別情報を、S33の処理において生成したコミットログに付加する(S35)。
Returning to FIG. 11, the
具体的に、S34の処理において決定した特定のスタンバイ装置がスタンバイ装置2である場合、情報生成部114は、図20に示すように、例えば、図18で説明したコミットログの「識別情報」に「Standby1」を設定する。
Specifically, if the specific standby device determined in the processing of S34 is
そして、情報送信部116は、S35の処理において識別情報を付加したコミットログを、全てのスタンバイ装置(スタンバイ装置2及びスタンバイ装置3)と連携装置4とにそれぞれ送信する(S36)。
Then, the
その後、情報受信部111は、図12に示すように、各スタンバイ装置におけるコミットログの受信が正常に行われたことを示す応答通知(以下、第1応答通知)を全てのスタンバイ装置から受信するまで待機する(S41のNO)。第1応答通知の具体例については後述する。
Then, as shown in FIG. 12, the
そして、第1応答通知を全てのスタンバイ装置から受信した場合(S41のYES)、情報生成部114は、S41の処理において受信した第1応答通知の内容に従って、情報格納領域130に記憶した対応情報131を更新する(S42)。
Then, if the first response notification has been received from all standby devices (YES in S41), the
具体的に、例えば、「レコード番号」が「0002」であるコミットログの連携装置4に対する送信が正常に行われたことを示す第1応答通知を特定のスタンバイ装置から受信した場合、情報生成部114は、図21に示すように、図19で説明した対応情報131のうち、「レコード番号」が「0002」である情報(2行目の情報)を削除する。
Specifically, for example, when a first response notification is received from a specific standby device indicating that a commit log with a "record number" of "0002" has been successfully sent to the
すなわち、情報生成部114は、各スタンバイ装置において記憶されているコミットログに対応するレコード番号のみが含まれるように、対応情報131の更新を行う。
In other words, the
これにより、アクティブ装置1は、情報格納領域130に記憶した対応情報131を参照することで、各スタンバイ装置において記憶されているコミットログに対応するレコード番号を特定することが可能になる。
This allows the
なお、情報生成部114は、例えば、第1応答通知を特定のスタンバイ装置から受信したことに応じて、S42の処理を行うものであってもよい。
In addition, the
その後、情報送信部116は、S31の処理において受信した処理依頼に対応するトランザクションがデータベース1bにおいてコミットしたことを示す応答通知(以下、第2応答通知とも呼ぶ)を受付装置5に送信する(S43)。
Then, the
[スタンバイ装置におけるログ送信処理の詳細]
次に、スタンバイ装置2におけるログ送信処理の詳細について説明を行う。図14から図16は、スタンバイ装置2におけるログ送信処理の詳細について説明するフローチャート図である。
[Details of log transmission process on standby device]
Next, a detailed description will be given of the log transmission process in the
情報受信部211は、図14に示すように、アクティブ装置1が送信したコミットログを受信するまで待機する(S61のNO)。
As shown in FIG. 14, the
そして、コミットログが受信した場合(S61のYES)、情報判定部213は、S61で受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する(S62)。
If a commit log is received (YES in S61), the
その結果、S61で受信したコミットログに含まれる識別情報が自装置を示していないと判定した場合(S63のNO)、再送制御部214は、直前に行ったS84の処理において削除したコミットログのレコード番号を付加した第1応答通知を生成する(S64)。以下、S64の処理において生成された第1応答通知の具体例について説明を行う。
As a result, if it is determined that the identification information included in the commit log received in S61 does not indicate the device itself (NO in S63), the
[第1応答通知の具体例(1)]
図22及び図23は、第1応答通知RS1の具体例を説明する図である。具体的に、図22は、S64の処理において生成された第1応答通知RS1の具体例を説明する図である。
[Specific example (1) of first response notice]
22 and 23 are diagrams illustrating a specific example of the first response notification RS1. Specifically, Fig. 22 is a diagram illustrating a specific example of the first response notification RS1 generated in the process of S64.
図22等に示す第1応答通知RS1は、第1応答通知RS1を示す電文種別が設定される「電文種別」と、各コミットログに対応するトランザクションの識別番号であるシーケンス番号が設定される「シーケンス番号」とを項目として有する。また、図22等に示す第1応答通知RS1は、各コミットログに対応するレコードの格納位置(データベース1bにおける格納位置)が設定される「レコード番号」と、各コミットログに対応する操作種別が設定される「操作種別」と、各コミットログのそのものが設定される「再送コミットログ」とを項目として有する。
The first response notification RS1 shown in FIG. 22 etc. has as its items "Message type" in which the message type indicating the first response notification RS1 is set, and "Sequence number" in which the sequence number that is the identification number of the transaction corresponding to each commit log is set. The first response notification RS1 shown in FIG. 22 etc. also has as its items "Record number" in which the storage location of the record corresponding to each commit log (storage location in
具体的に、図22に示す第1応答通知RS1には、「電文種別」として「応答通知1」が設定され、「シーケンス番号」として「0013」が設定され、「レコード番号(1)」として「0002」が設定され、「操作種別(1)」として「削除」が設定され、「再送コミットログ」として情報(コミットログ)が設定されていないことを示す「-」が設定されている。
Specifically, in the first response notification RS1 shown in FIG. 22, "
すなわち、図22に示す第1応答通知RS1は、直前に行ったS84の処理において削除したコミットログのレコード番号が「0002」であった場合に送信される応答通知である。 In other words, the first response notification RS1 shown in FIG. 22 is a response notification that is sent when the record number of the commit log deleted in the immediately preceding processing of S84 is "0002."
図14に戻り、情報送信部215は、S64の処理において生成した第1応答通知をアクティブ装置1に送信する(S65)。
Returning to FIG. 14, the
一方、S63の処理において、S61で受信したコミットログに含まれる識別情報が自装置を示していると判定した場合(S63のYES)、再送制御部214は、図15に示すように、S61の処理において受信したコミットログを情報格納領域230に記憶する(S71)。
On the other hand, in the process of S63, if it is determined that the identification information included in the commit log received in S61 indicates the own device (YES in S63), the
続いて、再送制御部214は、S61の処理において受信したコミットログのレコード番号と、直前に行ったS84で削除したコミットログのレコード番号とを付加した第1応答通知を生成する(S72)。
Next, the
[第1応答通知の具体例(2)]
図23は、S72の処理において生成された第1応答通知RS1の具体例を説明する図である。
[Specific example (2) of first response notice]
FIG. 23 is a diagram illustrating a specific example of the first response notification RS1 generated in the process of S72.
具体的に、図23に示す第1応答通知RS1には、「電文種別」として「応答通知1」が設定され、「シーケンス番号」として「0013」が設定され、「レコード番号(1)」として「0002」が設定され、「操作種別(1)」として「削除」が設定されている。また、図23に示す第1応答通知RS1には、「電文種別」として「応答通知1」が設定され、「レコード番号(2)」として「0003」が設定され、「操作種別(2)」として「追加」が設定され、「再送コミットログ」として「-」が設定されている。
Specifically, in the first response notification RS1 shown in FIG. 23, "
すなわち、図23に示す第1応答通知RS1は、直前に行ったS84の処理において削除したコミットログのレコード番号が「0002」であり、かつ、S61の処理において受信したコミットログのレコード番号が「0003」であった場合に送信される応答通知である。 In other words, the first response notification RS1 shown in FIG. 23 is a response notification that is sent when the record number of the commit log deleted in the immediately preceding processing of S84 is "0002" and the record number of the commit log received in processing of S61 is "0003."
図15に戻り、再送制御部214は、S61の処理において受信したコミットログ以外のコミットログが情報格納領域230に記憶されているか否かを判定する(S73)。
Returning to FIG. 15, the
その結果、S61の処理において受信したコミットログ以外のコミットログが情報格納領域230に記憶されていないと判定した場合(S74のNO)、情報送信部215は、S72の処理において生成した第1応答通知をアクティブ装置1と連携装置4とにそれぞれ送信する(S75)。
As a result, if it is determined that no commit logs other than the commit log received in the processing of S61 are stored in the information storage area 230 (NO in S74), the
一方、S61の処理において受信したコミットログ以外のコミットログが情報格納領域230に記憶されていると判定した場合(S74のYES)、再送制御部214は、図16に示すように、S61の処理において受信したコミットログ以外のコミットログを、S72の処理において生成した第1応答通知に付加する(S81)。
On the other hand, if it is determined that a commit log other than the commit log received in the processing of S61 is stored in the information storage area 230 (YES in S74), the
具体的に、再送制御部214は、例えば、図23で説明した第1応答通知における「再送コミットログ」に、情報格納領域230に記憶したコミットログのうち、S61の処理において受信したコミットログ以外のコミットログの内容を設定する。
Specifically, the
そして、情報送信部215は、S81の処理においてコミットログを付加した第1応答通知をアクティブ装置1と連携装置4とにそれぞれ送信する(S82)。
Then, the
さらに、S75の処理またはS82の処理の後、所定時間が経過するまでの間に、S36の処理においてアクティブ装置1が送信したコミットログを正常に受信したことを示す応答通知(以下、第3応答通知とも呼ぶ)を連携装置4から受信した場合(S83のYES)、再送制御部214は、S83の処理において受信した第3応答通知の内容に従って、情報格納領域230からコミットログを削除する(S84)。
Furthermore, after processing of S75 or processing of S82, if a response notification (hereinafter also referred to as a third response notification) indicating that the commit log sent by the
一方、S75の処理またはS82の処理の後、所定時間が経過するまでの間に、第3応答通知を連携装置4から受信しなかった場合(S83のNO)、再送制御部214は、S84の処理を実行しない。以下、第3応答通知の具体例について説明を行う。
On the other hand, if the third response notification is not received from the linked
[第3応答通知の具体例]
図24は、第3応答通知RS3の具体例を説明する図である。
[Specific example of third response notice]
FIG. 24 is a diagram illustrating a specific example of the third response notification RS3.
図24に示す第3応答通知RS3は、第3応答通知RS3を示す電文種別が設定される「電文種別」と、各コミットログに対応するトランザクションの識別番号であるシーケンス番号が設定される「シーケンス番号」とを項目として有する。 The third response notification RS3 shown in FIG. 24 has the following fields: "Message type," in which the message type indicating the third response notification RS3 is set, and "Sequence number," in which the sequence number that is the identification number of the transaction corresponding to each commit log is set.
具体的に、図24に示す第3応答通知RS3には、「電文種別」として「応答通知3」が設定され、「シーケンス番号」として「0013」が設定されている。
Specifically, in the third response notification RS3 shown in FIG. 24, "
すなわち、再送制御部214は、アクティブ装置1から連携装置4に対して送信されたコミットログのうち、連携装置4から受信が正常に完了したことを示す第3応答通知を受信していないコミットログが情報格納領域230に記憶されるように制御を行う。
In other words, the
これにより、スタンバイ装置2は、情報格納領域230に記憶されているコミットログを参照することで、連携装置4に対して再送を行う必要があるコミットログを容易に特定することが可能になる。
This allows the
[連携装置におけるログ送信処理の詳細]
次に、連携装置4におけるログ送信処理の詳細について説明を行う。図17は、連携装置4におけるログ送信処理の詳細について説明するフローチャート図である。
[Details of the log transmission process in the linked device]
Next, the details of the log transmission process in the linking
情報受信部411は、図17に示すように、アクティブ装置1からコミットログを受信し、かつ、特定のスタンバイ装置から第1応答通知を受信するまで待機する(S91のNO)。
As shown in FIG. 17, the
そして、アクティブ装置1からコミットログを受信し、かつ、特定のスタンバイ装置から第1応答通知を受信した場合(S91のYES)、情報送信部413は、受信したコミットログを外部システム20に送信する(S92)。
Then, when a commit log is received from the
続いて、受信判定部412は、S91の処理において受信した第1応答通知にコミットログが含まれているか否かを判定する(S93)。
Then, the
その結果、S91の処理において受信した第1応答通知にコミットログが含まれていると判定した場合(S94のYES)、情報送信部413は、S91の処理において受信した第1応答通知に含まれているコミットログを外部システム20に送信する(S95)。
As a result, if it is determined that the first response notification received in the processing of S91 includes a commit log (YES in S94), the
一方、S91の処理において受信した第1応答通知にコミットログが含まれていないと判定した場合(S94のNO)、情報送信部413は、S95の処理を実行しない。
On the other hand, if it is determined in the process of S91 that the first response notification received does not include a commit log (NO in S94), the
その後、情報送信部413は、S91の処理において受信したコミットログに含まれる識別情報が示す特定のスタンバイ装置に対して第3応答通知を送信する(S96)。
Then, the
これにより、連携装置4は、受信に成功したコミットログに対応する第3応答通知を特定のスタンバイ装置に対して送信することが可能になる。
This enables the coordinating
このように、本実施の形態におけるアクティブ装置1は、データベース1bに対するトランザクションがコミットした場合、連携装置4におけるコミットログの受信確認を行う特定のスタンバイ装置を決定する。そして、アクティブ装置1は、決定した特定のスタンバイ装置の識別情報を付加したコミットログを連携装置4と特定のスタンバイ装置とにそれぞれ送信する。
In this way, in this embodiment, when a transaction to
その後、特定のスタンバイ装置は、コミットログをアクティブ装置1から受信した場合、受信したコミットログに含まれる識別情報が自装置(特定のスタンバイ装置)を示しているか否かを判定する。その結果、受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、特定のスタンバイ装置は、コミットログを記憶部に記憶するとともに、連携装置4に対してコミットログの受信確認の指示を送信する。
After that, when the specific standby device receives a commit log from the
そして、連携装置4は、コミットログをアクティブ装置1から受信し、かつ、コミットログの受信確認の指示を特定のスタンバイ装置から受信した場合、コミットログの受信確認が正常に完了したことを示す応答通知を特定のスタンバイ装置に送信する。
Then, when the coordinating
さらに、特定のスタンバイ装置は、コミットログの受信確認が正常に完了したことを示す応答通知を連携装置4から受信した場合、アクティブ装置1から受信したコミットログを記憶部から削除する。
Furthermore, when a particular standby device receives a response notification from the cooperating
すなわち、本実施の形態における取引システム10では、連携装置4におけるコミットログの受信確認を特定のスタンバイ装置が行う。
In other words, in the
これにより、本実施の形態における取引システム10は、例えば、連携装置4から送信される応答通知の待ち合わせに時間を要する場合であっても、アクティブ装置1における処理性能の低下を防止することが可能になる。
As a result, the
[ログ送信処理の具体例(1)]
次に、連携装置4に対するコミットログの再送が発生しない場合におけるログ送信処理の具体例について説明を行う。図25は、連携装置4に対するコミットログの再送が発生しない場合におけるログ送信処理の具体例について説明するシーケンスチャート図である。なお、以下、スタンバイ装置3が特定のスタンバイ装置である場合について説明を行う。
[Specific example of log transmission process (1)]
Next, a specific example of the log transmission process in the case where the retransmission of the commit log to the
具体的に、受付装置5は、例えば、証券会社の情報処理システム(図示せず)から送信された処理依頼(1)をアクティブ装置1に送信する。
Specifically, the
そして、アクティブ装置1は、受付装置5から送信された処理依頼(1)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(1)に対応するトランザクションについてのコミットログ(1)を送信する。
When the
その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、第1応答通知(1)をアクティブ装置1に送信する。
Then, in response to receiving the commit log (1) sent by the
また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、受信したコミットログ(1)を情報格納領域130に記憶し、第1応答通知(2)をアクティブ装置1に送信し、さらに、第1応答通知(3)を連携装置4に送信する。
In addition, upon receiving the commit log (1) sent by the
そして、アクティブ装置1は、スタンバイ装置3が送信した第1応答通知(2)を受信したことに応じて、第2応答通知(1)を受付装置5に送信する。なお、アクティブ装置1は、この場合、コミットログ(1)とスタンバイ装置3の識別情報とを対応付けた対応情報131を生成して情報格納領域130に記憶する。
Then, in response to receiving the first response notification (2) sent by the
また、連携装置4は、スタンバイ装置3が送信した第1応答通知(3)を受信したことに応じて、アクティブ装置1が送信したコミットログ(1)を外部システム20に送信し、さらに、第3応答通知(1)をスタンバイ装置3に送信する。その後、スタンバイ装置3は、連携装置4が送信した第3応答通知(1)を受信したことに応じて、情報格納領域330に記憶したコミットログ(1)を削除する。
In addition, in response to receiving the first response notification (3) sent by the
続いて、受付装置5は、例えば、アクティブ装置1が送信した第2応答通知(1)を受信した後、処理依頼(2)をアクティブ装置1に送信する。
Then, for example, after receiving the second response notification (1) sent by the
そして、アクティブ装置1は、受付装置5から送信された処理依頼(2)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(2)に対応するトランザクションについてのコミットログ(2)を送信する。
Then, when the
その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、第1応答通知(4)をアクティブ装置1に送信する。
Then, in response to receiving the commit log (2) sent by the
また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、受信したコミットログ(2)を情報格納領域330に記憶し、第1応答通知(5)をアクティブ装置1に送信し、さらに、第1応答通知(6)を連携装置4に送信する。
In addition, upon receiving the commit log (2) sent by the
そして、アクティブ装置1は、スタンバイ装置3が送信した第1応答通知(5)を受信したことに応じて、第2応答通知(2)を受付装置5に送信する。なお、アクティブ装置1は、この場合、コミットログ(1)とスタンバイ装置3の識別情報とを対応付けた対応情報131を情報格納領域130から削除するとともに、コミットログ(2)とスタンバイ装置3の識別情報とを対応付けた対応情報131を生成して情報格納領域130に記憶する。
Then, in response to receiving the first response notification (5) sent by the
また、連携装置4は、スタンバイ装置3が送信した第1応答通知(6)を受信したことに応じて、アクティブ装置1が送信したコミットログ(2)を外部システム20に送信し、さらに、第3応答通知(2)をスタンバイ装置3に送信する。その後、スタンバイ装置3は、連携装置4が送信した第3応答通知(2)を受信したことに応じて、情報格納領域330に記憶したコミットログ(2)を削除する。
In addition, in response to receiving the first response notification (6) sent by the
[ログ送信処理の具体例(2)]
次に、連携装置4に対するコミットログの再送が発生する場合におけるログ送信処理の具体例について説明を行う。図26は、連携装置4に対するコミットログの再送が発生する場合におけるログ送信処理の具体例について説明するシーケンスチャート図である。
[Specific example of log transmission process (2)]
Next, a specific example of the log transmission process will be described in the case where a retransmission of a commit log occurs to the
具体的に、受付装置5は、例えば、証券会社の情報処理システム(図示せず)から送信された処理依頼(1)をアクティブ装置1に送信する。
Specifically, the
そして、アクティブ装置1は、受付装置5から送信された処理依頼(1)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(1)に対応するトランザクションについてのコミットログ(1)を送信する。
When the
その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、第1応答通知(1)をアクティブ装置1に送信する。
Then, in response to receiving the commit log (1) sent by the
また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、受信したコミットログ(1)を情報格納領域130に記憶し、第1応答通知(2)をアクティブ装置1に送信し、さらに、第1応答通知(3)を連携装置4に送信する。
In addition, upon receiving the commit log (1) sent by the
そして、アクティブ装置1は、スタンバイ装置3が送信した第1応答通知(2)を受信したことに応じて、第2応答通知(1)を受付装置5に送信する。なお、アクティブ装置1は、この場合、コミットログ(1)とスタンバイ装置3の識別情報とを対応付けた対応情報131を生成して情報格納領域130に記憶する。
Then, in response to receiving the first response notification (2) sent by the
ここで、アクティブ装置1から連携装置4に対するコミットログ(1)の送信が失敗した場合、連携装置4は、図25で説明した場合と異なり、スタンバイ装置3が送信した第1応答通知(3)を受信した場合であっても、スタンバイ装置3に対して第3応答通知(1)の送信を行わない。そのため、スタンバイ装置3では、この場合、コミットログ(1)の削除が行われない。
Here, if the transmission of commit log (1) from
続いて、受付装置5は、例えば、アクティブ装置1が送信した第2応答通知(1)を受信した後、処理依頼(2)をアクティブ装置1に送信する。
Then, for example, after receiving the second response notification (1) sent by the
そして、アクティブ装置1は、受付装置5から送信された処理依頼(2)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(2)に対応するトランザクションについてのコミットログ(2)を送信する。
Then, when the
その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、第1応答通知(4)をアクティブ装置1に送信する。
Then, in response to receiving the commit log (2) sent by the
また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、受信したコミットログ(2)を情報格納領域330に記憶し、第1応答通知(5)をアクティブ装置1に送信する。ここで、情報格納領域330には、コミットログ(1)とコミットログ(2)との両方が記憶されている。そのため、スタンバイ装置3は、図25で説明した場合と異なり、第1応答通知(6)だけでなく、コミットログ(1)についても連携装置4に送信する。
In addition, in response to receiving the commit log (2) sent by the
そして、アクティブ装置1は、スタンバイ装置3が送信した第1応答通知(5)を受信したことに応じて、第2応答通知(2)を受付装置5に送信する。なお、アクティブ装置1は、この場合、コミットログ(2)とスタンバイ装置3の識別情報とを対応付けた対応情報131を生成して情報格納領域130に記憶する。
Then, in response to receiving the first response notification (5) sent by the
また、連携装置4は、スタンバイ装置3が送信した第1応答通知(6)及びコミットログ(1)を受信したことに応じて、スタンバイ装置3が送信(再送)したコミットログ(1)とアクティブ装置1が送信したコミットログ(2)とを外部システム20に送信し、さらに、第3応答通知(2)をスタンバイ装置3に送信する。その後、スタンバイ装置3は、連携装置4が送信した第3応答通知(2)を受信したことに応じて、情報格納領域330に記憶したコミットログ(1)とコミットログ(2)とを削除する。
In addition, in response to receiving the first response notification (6) and commit log (1) sent by the
これにより、スタンバイ装置3(特定のスタンバイ装置)は、連携装置4に対するコミットログの再送処理をアクティブ装置1に代わって行うことが可能になる。そのため、スタンバイ装置3は、アクティブ装置1の処理負担を軽減させることが可能になる。
This enables the standby device 3 (a specific standby device) to resend the commit log to the cooperating
以上の実施の形態をまとめると、以下の付記のとおりである。 The above embodiments can be summarized as follows:
(付記1)
データベースに対するトランザクションについてのコミットログを送信する第1情報処理装置と、前記コミットログを前記第1情報処理装置から受信する第2情報処理装置及び第3情報処理装置と、前記コミットログを前記第1情報処理装置から受信する送信先装置とを有する情報処理システムであって、
前記第1情報処理装置は、前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う情報処理装置を、前記第2情報処理装置及び前記第3情報処理装置のうちのいずれかの情報処理装置に決定し、
前記第1情報処理装置は、決定した前記いずれかの情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記いずれかの情報処理装置とにそれぞれ送信し、
前記いずれかの情報処理装置は、前記コミットログを前記第1情報処理装置から受信したら、受信した前記コミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、
前記いずれかの情報処理装置は、前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、
前記送信先装置は、前記コミットログを前記第1情報処理装置から受信し、かつ、前記コミットログの前記受信確認の指示を前記いずれかの情報処理装置から受信したら、前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記いずれかの情報処理装置に送信し、
前記いずれかの情報処理装置は、前記受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する、
ことを特徴とする情報処理システム。
(Appendix 1)
An information processing system including a first information processing device that transmits a commit log for a transaction on a database, a second information processing device and a third information processing device that receive the commit log from the first information processing device, and a transmission destination device that receives the commit log from the first information processing device,
When the transaction is committed, the first information processing device determines that an information processing device that will perform a reception confirmation of the commit log at the destination device is one of the second information processing device and the third information processing device;
the first information processing device transmits the commit log to which identification information of the determined one of the information processing devices has been added, to the destination device and the one of the information processing devices, respectively;
When the information processing device receives the commit log from the first information processing device, the information processing device determines whether the identification information included in the received commit log indicates the information processing device itself;
When the information processing device determines that the identification information included in the commit log indicates the information processing device itself, the information processing device stores the commit log in a storage unit and transmits an instruction to the transmission destination device to confirm receipt of the commit log;
the destination device receives the commit log from the first information processing device and, upon receiving an instruction to confirm the receipt of the commit log from any one of the information processing devices, transmits a receipt confirmation result indicating that the receipt of the commit log at the destination device has been successfully completed to any one of the information processing devices;
When any of the information processing devices receives the receipt confirmation result from the destination device, the information processing device deletes the commit log from the storage unit.
An information processing system comprising:
(付記2)
付記1において、
前記第1情報処理装置は、
前記コミットログに含まれる特定の項目に対応する情報と前記識別情報とを対応付ける対応情報を記憶部に記憶し、
前記データベースに対する新たなトランザクションがコミットしたら、前記記憶部を参照し、前記新たなトランザクションについての新たなコミットログに含まれる前記特定の項目に対応する情報を含む前記対応情報が前記記憶部に記憶されているか否かを判定し、
前記対応情報が前記記憶部に記憶されていると判定した場合、前記記憶部を参照し、前記新たなコミットログに含まれる前記特定の項目に対応する情報と対応付けられた前記識別情報を特定し、
特定した前記識別情報が示す情報処理装置を、前記送信先装置における前記新たなコミットログの受信確認を行う情報処理装置として決定する、
ことを特徴とする情報処理システム。
(Appendix 2)
In
The first information processing device,
storing, in a storage unit, correspondence information that associates information corresponding to a specific item included in the commit log with the identification information;
When a new transaction is committed to the database, refer to the storage unit and determine whether or not the corresponding information including information corresponding to the specific item included in a new commit log for the new transaction is stored in the storage unit;
When it is determined that the corresponding information is stored in the storage unit, referring to the storage unit, the identification information associated with the information corresponding to the specific item included in the new commit log is identified;
determining the information processing device indicated by the specified identification information as an information processing device that will perform reception confirmation of the new commit log at the destination device;
An information processing system comprising:
(付記3)
付記2において、
前記第1情報処理装置は、前記対応情報が前記記憶部に記憶されていないと判定した場合、前記記憶部を参照し、前記対応情報に含まれる前記識別情報の割合が最も少ない情報処理装置を、前記送信先装置における前記新たなコミットログの受信確認を行う情報処理装置として特定する、
ことを特徴とする情報処理システム。
(Appendix 3)
In Appendix 2:
When the first information processing device determines that the correspondence information is not stored in the storage unit, the first information processing device refers to the storage unit, and identifies an information processing device that includes the smallest ratio of the identification information in the correspondence information as an information processing device that will perform reception confirmation of the new commit log at the transmission destination device.
An information processing system comprising:
(付記4)
付記2において、
前記第1情報処理装置は、前記コミットログを前記記憶部から削除したことを示す通知を前記いずれかの情報処理装置から受信したら、前記対応情報を前記記憶部から削除する、
ことを特徴とする情報処理システム。
(Appendix 4)
In Appendix 2:
when the first information processing device receives a notification from any one of the information processing devices indicating that the commit log has been deleted from the storage unit, the first information processing device deletes the correspondence information from the storage unit.
An information processing system comprising:
(付記5)
付記1において、
前記いずれかの情報処理装置は、
新たなコミットログを前記第1情報処理装置から受信したら、受信した前記新たなコミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、
前記新たなコミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記新たなコミットログを前記記憶部に記憶するとともに、前記コミットログが前記記憶部に記憶されている時は、前記送信先装置に対して前記新たなコミットログの受信確認の指示及び前記コミットログを送信し、
前記送信先装置における前記新たなコミットログの受信が正常に完了したことを示す受信確認結果を前記送信先装置から受信したら、前記コミットログと前記新たなコミットログとを前記記憶部から削除する、
ことを特徴とする情報処理システム。
(Appendix 5)
In
Any one of the information processing devices,
When a new commit log is received from the first information processing device, it is determined whether or not the identification information included in the received new commit log indicates the first information processing device;
When it is determined that the identification information included in the new commit log indicates the own device, the new commit log is stored in the storage unit, and when the commit log is stored in the storage unit, an instruction to confirm receipt of the new commit log and the commit log are transmitted to the transmission destination device;
when receiving, from the destination device, a reception confirmation result indicating that the reception of the new commit log at the destination device has been completed normally, the commit log and the new commit log are deleted from the storage unit;
An information processing system comprising:
(付記6)
データベースに対するトランザクションについてのコミットログを送信先装置に送信する処理をコンピュータに実行させるログ送信プログラムであって、
前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う他の情報処理装置を決定し、
決定した前記他の情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記他の情報処理装置とにそれぞれ送信する、
ことを特徴とするログ送信プログラム。
(Appendix 6)
A log transmission program that causes a computer to execute a process of transmitting a commit log about a transaction for a database to a destination device,
determining another information processing device that will acknowledge receipt of the commit log in the destination device when the transaction is committed;
transmitting the commit log to which the identification information of the determined other information processing device has been added, to the destination device and the other information processing device, respectively;
A log transmission program comprising:
(付記7)
データベースに対するトランザクションについてのコミットログを送信先装置に送信する処理をコンピュータに実行させるログ送信プログラムであって、
前記コミットログを他の情報処理装置から受信したら、受信した前記コミットログに含まれる識別情報が自装置を示しているか否かを判定し、
前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、
前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する、
ことを特徴とするログ送信プログラム。
(Appendix 7)
A log transmission program that causes a computer to execute a process of transmitting a commit log about a transaction for a database to a destination device,
When the commit log is received from the other information processing device, it is determined whether or not identification information included in the received commit log indicates the own device;
When it is determined that the identification information included in the commit log indicates the own device, the commit log is stored in a storage unit, and an instruction to the transmission destination device to confirm receipt of the commit log is transmitted;
when receiving, from the destination device, a reception confirmation result indicating that reception of the commit log at the destination device has been completed normally, the commit log is deleted from the storage unit;
A log transmission program comprising:
(付記8)
データベースに対するトランザクションについてのコミットログを送信先装置に送信する情報処理装置であって、
前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う他の情報処理装置を決定する装置決定部と、
決定した前記他の情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記他の情報処理装置とにそれぞれ送信する情報送信部と、を有する、
ことを特徴とする情報処理装置。
(Appendix 8)
An information processing device that transmits a commit log regarding a transaction for a database to a destination device,
a device determination unit that determines another information processing device that will acknowledge receipt of the commit log in the destination device when the transaction is committed;
an information transmission unit that transmits the commit log to which the identification information of the determined other information processing device is added, to the destination device and the other information processing device,
23. An information processing apparatus comprising:
(付記9)
データベースに対するトランザクションについてのコミットログを送信先装置に送信する情報処理装置であって、
前記コミットログを他の情報処理装置から受信したら、受信した前記コミットログに含まれる識別情報が自装置を示しているか否かを判定する情報判定部と、
前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信する情報送信部と、
前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する再送制御部と、を有する、
ことを特徴とする情報処理装置。
(Appendix 9)
An information processing device that transmits a commit log regarding a transaction for a database to a destination device,
an information determination unit that, when receiving the commit log from another information processing device, determines whether or not identification information included in the received commit log indicates the information processing device itself;
an information transmission unit that stores the commit log in a storage unit and transmits an instruction to the destination device to confirm receipt of the commit log when it is determined that the identification information included in the commit log indicates the destination device;
a retransmission control unit that deletes the commit log from the storage unit when a reception confirmation result indicating that the reception of the commit log at the transmission destination device has been completed normally is received from the transmission destination device.
23. An information processing apparatus comprising:
(付記10)
データベースに対するトランザクションについてのコミットログを送信する第1情報処理装置と、前記コミットログを前記第1情報処理装置から受信する第2情報処理装置及び第3情報処理装置と、前記コミットログを前記第1情報処理装置から受信する送信先装置とを有する情報処理システムにおけるログ送信方法であって、
前記第1情報処理装置は、前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う情報処理装置を、前記第2情報処理装置及び前記第3情報処理装置のうちのいずれかの情報処理装置に決定し、
前記第1情報処理装置は、決定した前記いずれかの情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記いずれかの情報処理装置とにそれぞれ送信し、
前記いずれかの情報処理装置は、前記コミットログを前記第1情報処理装置から受信したら、受信した前記コミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、
前記いずれかの情報処理装置は、前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、
前記送信先装置は、前記コミットログを前記第1情報処理装置から受信し、かつ、前記コミットログの前記受信確認の指示を前記いずれかの情報処理装置から受信したら、前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記いずれかの情報処理装置に送信し、
前記いずれかの情報処理装置は、前記受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する、
ことを特徴とするログ送信方法。
(Appendix 10)
A log transmission method in an information processing system having a first information processing device that transmits a commit log for a transaction on a database, a second information processing device and a third information processing device that receive the commit log from the first information processing device, and a destination device that receives the commit log from the first information processing device, comprising:
When the transaction is committed, the first information processing device determines that an information processing device that will perform a reception confirmation of the commit log at the destination device is one of the second information processing device and the third information processing device;
the first information processing device transmits the commit log to which identification information of the determined one of the information processing devices has been added, to the destination device and the one of the information processing devices, respectively;
When the information processing device receives the commit log from the first information processing device, the information processing device determines whether the identification information included in the received commit log indicates the information processing device itself;
When the information processing device determines that the identification information included in the commit log indicates the information processing device itself, the information processing device stores the commit log in a storage unit and transmits an instruction to the transmission destination device to confirm receipt of the commit log;
the destination device receives the commit log from the first information processing device and, upon receiving an instruction to confirm the receipt of the commit log from any one of the information processing devices, transmits a receipt confirmation result indicating that the receipt of the commit log at the destination device has been successfully completed to any one of the information processing devices;
When any of the information processing devices receives the receipt confirmation result from the destination device, the information processing device deletes the commit log from the storage unit.
A log transmission method comprising:
1:アクティブ装置 1a:処理部
1b:データベース 2:スタンバイ装置
2a:処理部 2b:データベース
3:スタンバイ装置 3a:処理部
3b:データベース 4:連携装置
5:受付装置 10:情報処理システム
20:外部システム
1:
Claims (8)
前記第1情報処理装置は、前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う情報処理装置を、前記第2情報処理装置及び前記第3情報処理装置のうちのいずれかの情報処理装置に決定し、
前記第1情報処理装置は、決定した前記いずれかの情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記いずれかの情報処理装置とにそれぞれ送信し、
前記いずれかの情報処理装置は、前記コミットログを前記第1情報処理装置から受信したら、受信した前記コミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、
前記いずれかの情報処理装置は、前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、
前記送信先装置は、前記コミットログを前記第1情報処理装置から受信し、かつ、前記コミットログの前記受信確認の指示を前記いずれかの情報処理装置から受信したら、前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記いずれかの情報処理装置に送信し、
前記いずれかの情報処理装置は、前記受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する、
ことを特徴とする情報処理システム。 An information processing system including a first information processing device that transmits a commit log for a transaction on a database, a second information processing device and a third information processing device that receive the commit log from the first information processing device, and a transmission destination device that receives the commit log from the first information processing device,
When the transaction is committed, the first information processing device determines that an information processing device that will perform a reception confirmation of the commit log at the destination device is one of the second information processing device and the third information processing device;
the first information processing device transmits the commit log to which identification information of the determined one of the information processing devices has been added, to the destination device and the one of the information processing devices, respectively;
When the information processing device receives the commit log from the first information processing device, the information processing device determines whether the identification information included in the received commit log indicates the information processing device itself;
When the information processing device determines that the identification information included in the commit log indicates the information processing device itself, the information processing device stores the commit log in a storage unit and transmits an instruction to the transmission destination device to confirm receipt of the commit log;
the destination device receives the commit log from the first information processing device and, upon receiving an instruction to confirm the receipt of the commit log from any one of the information processing devices, transmits a receipt confirmation result indicating that the receipt of the commit log at the destination device has been successfully completed to any one of the information processing devices;
When any of the information processing devices receives the receipt confirmation result from the destination device, the information processing device deletes the commit log from the storage unit.
An information processing system comprising:
前記第1情報処理装置は、
前記コミットログに含まれる特定の項目に対応する情報と前記識別情報とを対応付ける対応情報を記憶部に記憶し、
前記データベースに対する新たなトランザクションがコミットしたら、前記記憶部を参照し、前記新たなトランザクションについての新たなコミットログに含まれる前記特定の項目に対応する情報を含む前記対応情報が前記記憶部に記憶されているか否かを判定し、
前記対応情報が前記記憶部に記憶されていると判定した場合、前記記憶部を参照し、前記新たなコミットログに含まれる前記特定の項目に対応する情報と対応付けられた前記識別情報を特定し、
特定した前記識別情報が示す情報処理装置を、前記送信先装置における前記新たなコミットログの受信確認を行う情報処理装置として決定する、
ことを特徴とする情報処理システム。 In claim 1,
The first information processing device,
storing, in a storage unit, correspondence information that associates information corresponding to a specific item included in the commit log with the identification information;
When a new transaction is committed to the database, refer to the storage unit and determine whether or not the corresponding information including information corresponding to the specific item included in a new commit log for the new transaction is stored in the storage unit;
When it is determined that the corresponding information is stored in the storage unit, referring to the storage unit, the identification information associated with the information corresponding to the specific item included in the new commit log is identified;
determining the information processing device indicated by the specified identification information as an information processing device that will perform reception confirmation of the new commit log at the destination device;
An information processing system comprising:
前記第1情報処理装置は、前記対応情報が前記記憶部に記憶されていないと判定した場合、前記記憶部を参照し、前記対応情報に含まれる前記識別情報の割合が最も少ない情報処理装置を、前記送信先装置における前記新たなコミットログの受信確認を行う情報処理装置として特定する、
ことを特徴とする情報処理システム。 In claim 2,
When the first information processing device determines that the correspondence information is not stored in the storage unit, the first information processing device refers to the storage unit, and identifies an information processing device that includes the smallest ratio of the identification information in the correspondence information as an information processing device that will perform reception confirmation of the new commit log at the transmission destination device.
An information processing system comprising:
前記第1情報処理装置は、前記コミットログを前記記憶部から削除したことを示す通知を前記いずれかの情報処理装置から受信したら、前記対応情報を前記記憶部から削除する、
ことを特徴とする情報処理システム。 In claim 2,
when the first information processing device receives a notification from any one of the information processing devices indicating that the commit log has been deleted from the storage unit, the first information processing device deletes the correspondence information from the storage unit.
An information processing system comprising:
前記いずれかの情報処理装置は、
新たなコミットログを前記第1情報処理装置から受信したら、受信した前記新たなコミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、
前記新たなコミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記新たなコミットログを前記記憶部に記憶するとともに、前記コミットログが前記記憶部に記憶されている時は、前記送信先装置に対して前記新たなコミットログの受信確認の指示及び前記コミットログを送信し、
前記送信先装置における前記新たなコミットログの受信が正常に完了したことを示す受信確認結果を前記送信先装置から受信したら、前記コミットログと前記新たなコミットログとを前記記憶部から削除する、
ことを特徴とする情報処理システム。 In claim 1,
Any one of the information processing devices,
When a new commit log is received from the first information processing device, it is determined whether or not the identification information included in the received new commit log indicates the first information processing device;
When it is determined that the identification information included in the new commit log indicates the own device, the new commit log is stored in the storage unit, and when the commit log is stored in the storage unit, an instruction to confirm receipt of the new commit log and the commit log are transmitted to the transmission destination device;
when receiving, from the destination device, a reception confirmation result indicating that the reception of the new commit log at the destination device has been completed normally, the commit log and the new commit log are deleted from the storage unit;
An information processing system comprising:
前記コミットログを他の情報処理装置から受信したら、受信した前記コミットログに含まれる識別情報が自装置を示しているか否かを判定し、
前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、
前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する、
ことを特徴とするログ送信プログラム。 A log transmission program that causes a computer to execute a process of transmitting a commit log about a transaction for a database to a destination device,
When the commit log is received from the other information processing device, it is determined whether or not identification information included in the received commit log indicates the own device;
When it is determined that the identification information included in the commit log indicates the own device, the commit log is stored in a storage unit, and an instruction to the transmission destination device to confirm receipt of the commit log is transmitted;
when receiving, from the destination device, a reception confirmation result indicating that reception of the commit log at the destination device has been completed normally, the commit log is deleted from the storage unit;
A log transmission program comprising:
前記コミットログを他の情報処理装置から受信したら、受信した前記コミットログに含まれる識別情報が自装置を示しているか否かを判定する情報判定部と、
前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信する情報送信部と、
前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する再送制御部と、を有する、
ことを特徴とする情報処理装置。 An information processing device that transmits a commit log regarding a transaction for a database to a destination device,
an information determination unit that, when receiving the commit log from another information processing device, determines whether or not identification information included in the received commit log indicates the information processing device itself;
an information transmission unit that stores the commit log in a storage unit and transmits an instruction to the destination device to confirm receipt of the commit log when it is determined that the identification information included in the commit log indicates the destination device;
a retransmission control unit that deletes the commit log from the storage unit when a reception confirmation result indicating that the reception of the commit log at the transmission destination device has been completed normally is received from the transmission destination device.
23. An information processing apparatus comprising:
前記第1情報処理装置は、前記トランザクションがコミットしたら、前記送信先装置における前記コミットログの受信確認を行う情報処理装置を、前記第2情報処理装置及び前記第3情報処理装置のうちのいずれかの情報処理装置に決定し、
前記第1情報処理装置は、決定した前記いずれかの情報処理装置の識別情報を付加した前記コミットログを前記送信先装置と前記いずれかの情報処理装置とにそれぞれ送信し、
前記いずれかの情報処理装置は、前記コミットログを前記第1情報処理装置から受信したら、受信した前記コミットログに含まれる前記識別情報が自装置を示しているか否かを判定し、
前記いずれかの情報処理装置は、前記コミットログに含まれる前記識別情報が自装置を示していると判定した場合、前記コミットログを記憶部に記憶するとともに、前記送信先装置に対して前記コミットログの受信確認の指示を送信し、
前記送信先装置は、前記コミットログを前記第1情報処理装置から受信し、かつ、前記コミットログの前記受信確認の指示を前記いずれかの情報処理装置から受信したら、前記送信先装置における前記コミットログの受信が正常に完了したことを示す受信確認結果を前記いずれかの情報処理装置に送信し、
前記いずれかの情報処理装置は、前記受信確認結果を前記送信先装置から受信したら、前記コミットログを前記記憶部から削除する、
ことを特徴とするログ送信方法。 A log transmission method in an information processing system having a first information processing device that transmits a commit log for a transaction on a database, a second information processing device and a third information processing device that receive the commit log from the first information processing device, and a destination device that receives the commit log from the first information processing device, comprising:
When the transaction is committed, the first information processing device determines that an information processing device that will perform a reception confirmation of the commit log at the destination device is one of the second information processing device and the third information processing device;
the first information processing device transmits the commit log to which identification information of the determined one of the information processing devices has been added, to the destination device and the one of the information processing devices, respectively;
When the information processing device receives the commit log from the first information processing device, the information processing device determines whether the identification information included in the received commit log indicates the information processing device itself;
When the information processing device determines that the identification information included in the commit log indicates the information processing device itself, the information processing device stores the commit log in a storage unit and transmits an instruction to the transmission destination device to confirm receipt of the commit log;
the destination device receives the commit log from the first information processing device and, upon receiving an instruction to confirm the receipt of the commit log from any one of the information processing devices, transmits a receipt confirmation result indicating that the receipt of the commit log at the destination device has been successfully completed to any one of the information processing devices;
When any of the information processing devices receives the receipt confirmation result from the destination device, the information processing device deletes the commit log from the storage unit.
A log transmission method comprising:
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2020206497A JP7564438B2 (en) | 2020-12-14 | 2020-12-14 | Information processing system, log transmission program, information processing device, and log transmission method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2020206497A JP7564438B2 (en) | 2020-12-14 | 2020-12-14 | Information processing system, log transmission program, information processing device, and log transmission method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2022093812A JP2022093812A (en) | 2022-06-24 |
| JP7564438B2 true JP7564438B2 (en) | 2024-10-09 |
Family
ID=82081238
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2020206497A Active JP7564438B2 (en) | 2020-12-14 | 2020-12-14 | Information processing system, log transmission program, information processing device, and log transmission method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP7564438B2 (en) |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2003507791A (en) | 1999-08-17 | 2003-02-25 | イーエムシー コーポレーション | Remote mirroring system, apparatus and method |
| JP2004342041A (en) | 2003-05-19 | 2004-12-02 | Fujitsu Ltd | Traffic reduction device |
| JP2009282790A (en) | 2008-05-22 | 2009-12-03 | Fujitsu Ltd | Method for solving in-doubt state of two-phase commit protocol of distributed transaction |
| JP2010527087A (en) | 2007-05-21 | 2010-08-05 | エヌエイチエヌ コーポレーション | Data replication method and system in database management system (DBMS) |
-
2020
- 2020-12-14 JP JP2020206497A patent/JP7564438B2/en active Active
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2003507791A (en) | 1999-08-17 | 2003-02-25 | イーエムシー コーポレーション | Remote mirroring system, apparatus and method |
| JP2004342041A (en) | 2003-05-19 | 2004-12-02 | Fujitsu Ltd | Traffic reduction device |
| JP2010527087A (en) | 2007-05-21 | 2010-08-05 | エヌエイチエヌ コーポレーション | Data replication method and system in database management system (DBMS) |
| JP2009282790A (en) | 2008-05-22 | 2009-12-03 | Fujitsu Ltd | Method for solving in-doubt state of two-phase commit protocol of distributed transaction |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2022093812A (en) | 2022-06-24 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US7676616B2 (en) | Method, apparatus and program storage device for providing asynchronous status messaging in a data storage system | |
| US8726079B2 (en) | Handling of messages in a message system | |
| HK1222746A1 (en) | Failover system and method | |
| JP4495977B2 (en) | Retry technology for multi-layer network communication system | |
| US20020069121A1 (en) | Supply assurance | |
| CN111651284B (en) | Method, device, system and storage medium for processing business data | |
| US20130282666A1 (en) | Method and system for implementing a redo repeater | |
| JP2011510414A (en) | Method and system for improving replica server performance | |
| US20050044193A1 (en) | Method, system, and program for dual agent processes and dual active server processes | |
| JP7564438B2 (en) | Information processing system, log transmission program, information processing device, and log transmission method | |
| CN101364997A (en) | Network-based distributed transaction processing method and system | |
| US8234338B1 (en) | System and method for reliable message delivery | |
| JP4722864B2 (en) | Data processing system, format conversion apparatus, received data processing apparatus, data processing method, and computer program | |
| JPH0213158A (en) | Message transmission method | |
| CN113783666B (en) | Method and device for processing business | |
| JP5200658B2 (en) | Server system | |
| CN116775226A (en) | Database transaction processing method, device and system | |
| JPH09319634A (en) | Transaction executing state management system, management method and medium for storing management program | |
| JP2007164535A (en) | Business integration method, business integration device, business integration system, and business integration program | |
| JP2023057210A (en) | Information processing device, information processing method, and information processing program | |
| US10685040B1 (en) | Storage-based replication of E-commerce transactions in real time | |
| KR102890142B1 (en) | Method of operating a business system, and business system | |
| JP3006469B2 (en) | Message double feed check system | |
| JP2006260400A (en) | Computer device status monitoring method | |
| JP5928976B2 (en) | Survival monitoring system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20230804 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20240717 |
|
| 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: 20240827 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20240909 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 7564438 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |