Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP7564438B2 - Information processing system, log transmission program, information processing device, and log transmission method - Google Patents
[go: Go Back, main page]

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 PDF

Info

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
Application number
JP2020206497A
Other languages
Japanese (ja)
Other versions
JP2022093812A (en
Inventor
勇太 飯塚
真二 山開
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Fujitsu Ltd
Original Assignee
Fujitsu Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Fujitsu Ltd filed Critical Fujitsu Ltd
Priority to JP2020206497A priority Critical patent/JP7564438B2/en
Publication of JP2022093812A publication Critical patent/JP2022093812A/en
Application granted granted Critical
Publication of JP7564438B2 publication Critical patent/JP7564438B2/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

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).

特表2010-527087号公報Special Publication No. 2010-527087

ここで、上記のようなスタンバイ装置や連携装置は、アクティブ装置からコミットログを受信した場合、コミットログの受信が正常に行われたことを示す通知(以下、応答通知)をアクティブ装置に送信する。これにより、アクティブ装置は、各コミットログの送信が正常に完了したか否かについて判断を行うことが可能になる。 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.

図1は、取引システム10の構成について説明する図である。FIG. 1 is a diagram illustrating the configuration of a trading system 10. As shown in FIG. 図2は、アクティブ装置1のハードウエア構成を説明する図である。FIG. 2 is a diagram for explaining the hardware configuration of the active device 1. As shown in FIG. 図3は、スタンバイ装置2のハードウエア構成を説明する図である。FIG. 3 is a diagram illustrating the hardware configuration of the standby device 2. As shown in FIG. 図4は、連携装置4のハードウエア構成を説明する図である。FIG. 4 is a diagram illustrating the hardware configuration of the linking device 4. As shown in FIG. 図5は、アクティブ装置1の機能のブロック図である。FIG. 5 is a functional block diagram of the active device 1. 図6は、スタンバイ装置2の機能のブロック図である。FIG. 6 is a block diagram of the functions of the standby device 2. 図7は、連携装置4の機能のブロック図である。FIG. 7 is a block diagram of the functions of the linked device 4. As shown in FIG. 図8は、第1の実施の形態におけるログ送信処理の概略を説明するフローチャート図である。FIG. 8 is a flow chart outlining the log transmission process according to the first embodiment. 図9は、第1の実施の形態におけるログ送信処理の概略を説明するフローチャート図である。FIG. 9 is a flow chart outlining the log transmission process according to the first embodiment. 図10は、第1の実施の形態におけるログ送信処理の概略を説明するフローチャート図である。FIG. 10 is a flow chart outlining the log transmission process according to the first embodiment. 図11は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 11 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図12は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 12 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図13は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 13 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図14は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 14 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図15は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 15 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図16は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 16 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図17は、第1の実施の形態におけるログ送信処理の詳細を説明するフローチャート図である。FIG. 17 is a flowchart illustrating details of the log transmission process according to the first embodiment. 図18は、コミットログCLの具体例を説明する図である。FIG. 18 is a diagram illustrating a specific example of the commit log CL. 図19は、対応情報131の具体例を説明する図である。FIG. 19 is a diagram for explaining a specific example of the correspondence information 131. As shown in FIG. 図20は、コミットログCLの具体例を説明する図である。FIG. 20 is a diagram illustrating a specific example of the commit log CL. 図21は、対応情報131の具体例を説明する図である。FIG. 21 is a diagram for explaining a specific example of the correspondence information 131. As shown in FIG. 図22は、第1応答通知RS1の具体例を説明する図である。FIG. 22 is a diagram illustrating a specific example of the first response notification RS1. 図23は、第1応答通知RS1の具体例を説明する図である。FIG. 23 is a diagram illustrating a specific example of the first response notification RS1. 図24は、第3応答通知RS3の具体例を説明する図である。FIG. 24 is a diagram illustrating a specific example of the third response notification RS3. 図25は、連携装置4に対するコミットログの再送が発生しない場合におけるログ送信処理の具体例について説明するシーケンスチャート図である。FIG. 25 is a sequence chart illustrating a specific example of the log transmission process in the case where the retransmission of the commit log to the collaboration apparatus 4 does not occur. 図26は、連携装置4に対するコミットログの再送が発生する場合におけるログ送信処理の具体例について説明するシーケンスチャート図である。FIG. 26 is a sequence chart illustrating a specific example of a log transmission process in a case where a commit log needs to be resent to the coordination apparatus 4. In FIG.

[情報処理システムの構成]
初めに、取引システム10の構成について説明を行う。図1は、取引システム10の構成について説明する図である。
[Configuration of Information Processing System]
First, a description will be given of the configuration of the trading system 10. FIG.

図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 active device 1, a standby device 2, a standby device 3, a cooperating device 4, and a reception device 5.

受付装置5は、例えば、証券会社が有する情報処理システム(図示せず)から送信された株の売買注文を受け付ける。そして、受付装置5は、例えば、受け付けた売買注文を成立させるための処理の実行を依頼する処理依頼(以下、単に処理依頼とも呼ぶ)をアクティブ装置1に送信する。 The reception device 5, for example, receives orders to buy and sell stocks sent from an information processing system (not shown) owned by a securities company. The reception device 5 then transmits to the active device 1, for example, a processing request (hereinafter also simply referred to as a processing request) requesting the execution of a process to execute the received buying and selling orders.

アクティブ装置1の処理部1aは、例えば、受付装置5から受信した処理依頼に対応する売買注文(受付装置5が受信した売買注文)を取り纏めて株の売買を成立させる。そして、処理部1aは、例えば、成立させた売買の内容をデータベース1b(以下、DB1bとも表記する)に反映する。さらに、処理部1aは、データベース1bにおける売買の反映結果を示すコミットログを生成する。その後、処理部1aは、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、生成したコミットログを送信する。 The processing unit 1a of the active device 1, for example, consolidates buy and sell orders (buy and sell orders received by the receiving device 5) corresponding to processing requests received from the receiving device 5, and completes the buying and selling of stocks. Then, the processing unit 1a, for example, reflects the content of the completed buying and selling in the database 1b (hereinafter also referred to as DB1b). Furthermore, the processing unit 1a generates a commit log that indicates the reflection result of the buying and selling in the database 1b. After that, the processing unit 1a transmits the generated commit log to each of the standby device 2, the standby device 3, and the cooperating device 4.

スタンバイ装置2の処理部2aは、アクティブ装置1から送信されたコミットログの内容をデータベース2b(以下、DB2bとも表記する)に反映することによって、データベース1bとデータベース2bとの間の同期処理を行う。同様に、スタンバイ装置3の処理部3aは、アクティブ装置1から送信されたコミットログの内容をデータベース3b(以下、DB3bとも表記する)に反映することによって、データベース1bとデータベース3bとの間の同期処理を行う。そして、例えば、アクティブ装置1において所定の異常が発生した場合、スタンバイ装置2またはスタンバイ装置3は、アクティブ装置1が実行していた処理を引き継いで実行する。 The processing unit 2a of the standby device 2 performs synchronization processing between database 1b and database 2b by reflecting the contents of the commit log sent from the active device 1 in database 2b (hereinafter also referred to as DB2b). Similarly, the processing unit 3a of the standby device 3 performs synchronization processing between database 1b and database 3b by reflecting the contents of the commit log sent from the active device 1 in database 3b (hereinafter also referred to as DB3b). Then, for example, if a specified abnormality occurs in the active device 1, the standby device 2 or standby device 3 takes over and executes the processing that was being executed by the active device 1.

なお、以下、取引システム10が2台のスタンバイ装置(スタンバイ装置2及びスタンバイ装置3)を有する場合について説明を行うが、取引システム10は、2台以外の台数のスタンバイ装置を有するものであってもよい。 Note that, although the following description will be given of a case where trading system 10 has two standby devices (standby device 2 and standby device 3), trading system 10 may have a number of standby devices other than two.

連携装置4は、アクティブ装置1から送信されたコミットログを外部システム20に送信する。具体的に、連携装置4は、アクティブ装置1から送信されたコミットログを、外部システム20がアクセス可能なメッセージキュー(図示せず)に順次格納する。 The coordinating device 4 transmits the commit log sent from the active device 1 to the external system 20. Specifically, the coordinating device 4 sequentially stores the commit log sent from the active device 1 in a message queue (not shown) that is accessible by the external system 20.

ここで、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれは、アクティブ装置1からコミットログを受信した場合、コミットログの受信が正常に行われたことを示す応答通知をアクティブ装置1に送信する。これにより、アクティブ装置1は、各コミットログの送信が正常に完了したか否かについて判断を行うことが可能になる。 When each of the standby device 2, standby device 3, and cooperating device 4 receives a commit log from the active device 1, it sends a response notification to the active device 1 indicating that the commit log was received successfully. This enables the active device 1 to determine whether the transmission of each commit log was completed successfully.

しかしながら、アクティブ装置1は、この場合、スタンバイ装置2及びスタンバイ装置3から送信される応答通知だけでなく、連携装置4から送信される応答通知についても待ち合わせる必要がある。そのため、アクティブ装置1では、例えば、連携装置4から送信される応答通知の待ち合わせ時間が長時間に及ぶ場合、株の売買に伴う処理等の性能低下が発生する。 However, in this case, the active device 1 needs to wait not only for the response notification sent from the standby device 2 and the standby device 3, but also for the response notification sent from the coordinating device 4. Therefore, in the active device 1, for example, if the waiting time for the response notification sent from the coordinating device 4 is long, a decrease in performance occurs in the processing associated with buying and selling stocks.

そこで、本実施の形態におけるアクティブ装置1は、データベース1bに対するトランザクションがコミットした場合、スタンバイ装置2及びスタンバイ装置3のうちのいずれかのスタンバイ装置を、連携装置4におけるコミットログの受信確認を行うスタンバイ装置(以下、特定のスタンバイ装置とも呼ぶ)として決定する。そして、アクティブ装置1は、決定した特定のスタンバイ装置の識別情報を付加したコミットログを連携装置4と特定のスタンバイ装置とにそれぞれ送信する。 In this embodiment, when a transaction to database 1b is committed, active device 1 determines one of standby devices 2 and standby device 3 as the standby device that will confirm receipt of the commit log in collaboration device 4 (hereinafter also referred to as a specific standby device). Then, active device 1 transmits the commit log, to which the identification information of the determined specific standby device has been added, to each of collaboration device 4 and the specific standby device.

その後、特定のスタンバイ装置は、コミットログをアクティブ装置1から受信した場合、受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する。その結果、受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、特定のスタンバイ装置は、受信したコミットログを記憶部に記憶するとともに、連携装置4に対してコミットログの受信確認の指示を送信する。 After that, when the specific standby device receives a commit log from the active device 1, it determines whether the identification information included in the received commit log indicates its own device. As a result, if it determines that the identification information included in the received commit log indicates its own device, the specific standby device stores the received commit log in a memory unit and sends an instruction to the cooperating device 4 to confirm receipt of the commit log.

そして、連携装置4は、コミットログをアクティブ装置1から受信し、かつ、コミットログの受信確認の指示を特定のスタンバイ装置から受信した場合、コミットログの受信が正常に完了したことを示す応答通知を特定のスタンバイ装置に送信する。 Then, when the coordinating device 4 receives the commit log from the active device 1 and also receives an instruction from a specific standby device to confirm receipt of the commit log, it sends a response notification to the specific standby device indicating that receipt of the commit log has been completed successfully.

さらに、特定のスタンバイ装置は、コミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信した場合、アクティブ装置1から受信したコミットログを記憶部から削除する。 Furthermore, when a particular standby device receives a response notification from the cooperating device 4 indicating that reception of the commit log has been completed successfully, the particular standby device deletes the commit log received from the active device 1 from the memory unit.

すなわち、本実施の形態における取引システム10では、連携装置4におけるコミットログの受信確認を特定のスタンバイ装置が行う。 In other words, in the trading system 10 of this embodiment, a specific standby device confirms receipt of the commit log in the linked device 4.

これにより、本実施の形態における取引システム10は、例えば、連携装置4から送信される応答通知の待ち合わせに時間を要する場合であっても、アクティブ装置1における処理性能の低下を防止することが可能になる。 As a result, the trading system 10 in this embodiment can prevent a decrease in processing performance in the active device 1, even if it takes time to wait for a response notification sent from the linked device 4, for example.

[取引システムのハードウエア構成]
次に、取引システム10のハードウエア構成について説明する。図2は、アクティブ装置1のハードウエア構成を説明する図である。また、図3は、スタンバイ装置2のハードウエア構成を説明する図である。さらに、図4は、連携装置4のハードウエア構成を説明する図である。なお、スタンバイ装置3のハードウエア構成については、スタンバイ装置2のハードウエア構成と同じであるため説明を省略する。
[Hardware configuration of trading system]
Next, the hardware configuration of the trading system 10 will be described. Fig. 2 is a diagram for explaining the hardware configuration of the active device 1. Fig. 3 is a diagram for explaining the hardware configuration of the standby device 2. Fig. 4 is a diagram for explaining the hardware configuration of the cooperating device 4. Note that the hardware configuration of the standby device 3 is the same as that of the standby device 2, so a description thereof will be omitted.

初めに、アクティブ装置1のハードウエア構成について説明を行う。 First, we will explain the hardware configuration of active device 1.

アクティブ装置1は、図2に示すように、プロセッサであるCPU101と、メモリ102と、通信装置103と、記憶媒体104とを有する。各部は、バス105を介して互いに接続される。 As shown in FIG. 2, the active device 1 has a processor, a CPU 101, a memory 102, a communication device 103, and a storage medium 104. Each part is connected to each other via a bus 105.

記憶媒体104は、例えば、連携装置4に対してコミットログを送信する処理(以下、ログ送信処理とも呼ぶ)を行うためのプログラム110を記憶するプログラム格納領域(図示せず)を有する。また、記憶媒体104は、例えば、ログ送信処理を行う際に用いられる情報を記憶する情報格納領域130を有する。なお、記憶媒体104は、例えば、HDD(Hard Disk Drive)やSSD(Solid State Drive)であってよい。 The storage medium 104 has, for example, a program storage area (not shown) that stores a program 110 for performing a process of transmitting a commit log to the linkage device 4 (hereinafter also referred to as a log transmission process). The storage medium 104 also has, for example, an information storage area 130 that stores information used when performing the log transmission process. Note that the storage medium 104 may be, for example, a HDD (Hard Disk Drive) or an SSD (Solid State Drive).

CPU101は、記憶媒体104からメモリ102にロードされたプログラム110を実行してログ送信処理を行う。 The CPU 101 executes the program 110 loaded from the storage medium 104 to the memory 102 to perform the log transmission process.

また、通信装置103は、例えば、ネットワークNWを介してスタンバイ装置2等との通信を行う。 The communication device 103 also communicates with the standby device 2, etc., via the network NW, for example.

次に、スタンバイ装置2のハードウエア構成について説明を行う。 Next, we will explain the hardware configuration of standby device 2.

スタンバイ装置2は、図3に示すように、プロセッサであるCPU201と、メモリ202と、通信装置203と、記憶媒体204とを有する。各部は、バス205を介して互いに接続される。 As shown in FIG. 3, the standby device 2 has a processor, a CPU 201, a memory 202, a communication device 203, and a storage medium 204. Each part is connected to each other via a bus 205.

記憶媒体204は、例えば、ログ送信処理を行うためのプログラム210を記憶するプログラム格納領域(図示せず)を有する。また、記憶媒体204は、例えば、ログ送信処理を行う際に用いられる情報を記憶する情報格納領域230を有する。なお、記憶媒体204は、例えば、HDDやSSDであってよい。 The storage medium 204 has, for example, a program storage area (not shown) that stores a program 210 for performing the log transmission process. The storage medium 204 also has, for example, an information storage area 230 that stores information used when performing the log transmission process. Note that the storage medium 204 may be, for example, an HDD or SSD.

CPU201は、記憶媒体204からメモリ202にロードされたプログラム210を実行してログ送信処理を行う。 The CPU 201 executes the program 210 loaded from the storage medium 204 to the memory 202 to perform the log transmission process.

また、通信装置203は、例えば、ネットワークNWを介してアクティブ装置1等との通信を行う。 The communication device 203 also communicates with the active device 1, etc., via the network NW.

次に、連携装置4のハードウエア構成について説明を行う。 Next, we will explain the hardware configuration of linked device 4.

連携装置4は、図4に示すように、プロセッサであるCPU401と、メモリ402と、通信装置403と、記憶媒体404とを有する。各部は、バス405を介して互いに接続される。 As shown in FIG. 4, the linked device 4 has a processor, a CPU 401, a memory 402, a communication device 403, and a storage medium 404. Each part is connected to each other via a bus 405.

記憶媒体404は、例えば、ログ送信処理を行うためのプログラム410を記憶するプログラム格納領域(図示せず)を有する。また、記憶媒体404は、例えば、ログ送信処理を行う際に用いられる情報を記憶する情報格納領域430を有する。なお、記憶媒体404は、例えば、HDDやSSDであってよい。 The storage medium 404 has, for example, a program storage area (not shown) that stores a program 410 for performing the log transmission process. The storage medium 404 also has, for example, an information storage area 430 that stores information used when performing the log transmission process. The storage medium 404 may be, for example, an HDD or SSD.

CPU401は、記憶媒体404からメモリ402にロードされたプログラム410を実行してログ送信処理を行う。 The CPU 401 executes the program 410 loaded from the storage medium 404 to the memory 402 to perform the log transmission process.

また、通信装置403は、例えば、ネットワークNWを介してアクティブ装置1等との通信を行う。 The communication device 403 also communicates with the active device 1, etc., via the network NW.

[取引システムの機能]
次に、取引システム10の機能について説明を行う。図5は、アクティブ装置1の機能のブロック図である。また、図6は、スタンバイ装置2の機能のブロック図である。さらに、図7は、連携装置4の機能のブロック図である。なお、スタンバイ装置3の機能については、スタンバイ装置2の機能と同じであるため説明を省略する。
[Trading system functions]
Next, the functions of the trading system 10 will be described. Fig. 5 is a block diagram of the functions of the active device 1. Fig. 6 is a block diagram of the functions of the standby device 2. Fig. 7 is a block diagram of the functions of the cooperating device 4. Note that the functions of the standby device 3 are the same as those of the standby device 2, so a description thereof will be omitted.

初めに、アクティブ装置1の機能について説明を行う。 First, we will explain the functions of the active device 1.

アクティブ装置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 active device 1 realizes various functions including, for example, an information receiving unit 111, a transaction processing unit 112, an information management unit 113, an information generating unit 114, a device determination unit 115, and an information transmission unit 116, by organic cooperation between hardware such as a CPU 101 and a memory 102 and a program 110. Note that the processing unit 1a described in FIG. 1 corresponds to, for example, the information receiving unit 111, the transaction processing unit 112, the information management unit 113, the information generating unit 114, the device determination unit 115, and the information transmission unit 116.

また、アクティブ装置1は、図5に示すように、例えば、対応情報131を情報格納領域130に記憶する。 In addition, as shown in FIG. 5, the active device 1 stores, for example, correspondence information 131 in the information storage area 130.

情報受信部111は、受付装置5が送信した処理依頼を受信する。具体的に、情報受信部111は、例えば、受付装置5が受け付けた売買注文を成立させるための処理依頼を受信する。 The information receiving unit 111 receives a processing request sent by the reception device 5. Specifically, the information receiving unit 111 receives, for example, a processing request to complete a buy or sell order accepted by the reception device 5.

取引処理部112は、例えば、情報受信部111が受信した処理依頼に対応する売買注文を取り纏めて株の売買を成立させる。そして、情報管理部113は、例えば、取引処理部112が株の売買を成立させた場合、取引処理部112が成立させた売買注文(情報受信部111が受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。また、情報管理部113は、例えば、取引処理部112が株の売買を成立させなかった場合、取引処理部112が成立させなかった売買注文(情報受信部111が受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。 The transaction processing unit 112, for example, consolidates buy and sell orders corresponding to processing requests received by the information receiving unit 111 and completes the buying and selling of stocks. Then, for example, when the transaction processing unit 112 completes the buying and selling of stocks, the information management unit 113 writes the contents of the buying and selling orders completed by the transaction processing unit 112 (buy and sell orders corresponding to processing requests received by the information receiving unit 111) in database 1b. Also, for example, when the transaction processing unit 112 does not complete the buying and selling of stocks, the information management unit 113 writes the contents of the buying and selling orders not completed by the transaction processing unit 112 (buy and sell orders corresponding to processing requests received by the information receiving unit 111) in database 1b.

情報生成部114は、データベース1bに対するトランザクション(情報受信部111が受信した処理依頼に対応するトランザクション)がコミットした場合、そのトランザクションについてのコミットログを生成する。 When a transaction for database 1b (a transaction corresponding to a processing request received by the information receiving unit 111) is committed, the information generating unit 114 generates a commit log for that transaction.

装置決定部115は、情報生成部114が生成したコミットログの連携装置4における受信確認を行う特定のスタンバイ装置を決定する。そして、情報生成部114は、装置決定部115が決定した特定のスタンバイ装置の識別情報をコミットログに付加する。 The device determination unit 115 determines a specific standby device that will confirm receipt of the commit log generated by the information generation unit 114 in the cooperating device 4. The information generation unit 114 then adds identification information of the specific standby device determined by the device determination unit 115 to the commit log.

情報送信部116は、特定のスタンバイ装置の識別情報を付加したコミットログを、連携装置4と特定のスタンバイ装置とにそれぞれ送信する。対応情報131についての説明は後述する。 The information transmission unit 116 transmits the commit log, to which the identification information of the specific standby device is added, to the cooperating device 4 and the specific standby device, respectively. The correspondence information 131 will be explained later.

次に、スタンバイ装置2の機能について説明を行う。 Next, we will explain the functions of standby device 2.

スタンバイ装置2は、図6に示すように、CPU201やメモリ202等のハードウエアとプログラム210とが有機的に協働することにより、例えば、情報受信部211と、情報管理部212と、情報判定部213と、再送制御部214と、情報送信部215とを含む各種機能を実現する。なお、図1で説明した処理部2aは、例えば、情報受信部211、情報管理部212、情報判定部213、再送制御部214及び情報送信部215に対応する。 As shown in FIG. 6, the standby device 2 realizes various functions including, for example, an information receiving unit 211, an information managing unit 212, an information determining unit 213, a retransmission control unit 214, and an information transmitting unit 215, by organic cooperation between hardware such as a CPU 201 and a memory 202 and a program 210. Note that the processing unit 2a described in FIG. 1 corresponds to, for example, the information receiving unit 211, the information managing unit 212, the information determining unit 213, the retransmission control unit 214, and the information transmitting unit 215.

情報受信部211は、アクティブ装置1が送信したコミットログを受信する。そして、情報管理部212は、情報受信部211が受信したコミットログの内容をデータベース2bに書き込む。 The information receiving unit 211 receives the commit log sent by the active device 1. Then, the information management unit 212 writes the contents of the commit log received by the information receiving unit 211 to the database 2b.

情報判定部213は、情報受信部211が受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する。 The information determination unit 213 determines whether the identification information included in the commit log received by the information receiving unit 211 indicates the device itself.

再送制御部214は、情報受信部211が受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、情報受信部211が受信したコミットログを情報格納領域130に記憶する。 When the retransmission control unit 214 determines that the identification information included in the commit log received by the information receiving unit 211 indicates the device itself, the retransmission control unit 214 stores the commit log received by the information receiving unit 211 in the information storage area 130.

情報送信部215は、情報受信部211が受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、情報受信部211が受信したコミットログの受信確認の指示を連携装置4に対して送信する。 When the information sending unit 215 determines that the identification information included in the commit log received by the information receiving unit 211 indicates its own device, the information sending unit 215 sends an instruction to the cooperating device 4 to confirm receipt of the commit log received by the information receiving unit 211.

また、情報受信部211は、情報受信部211が受信したコミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信する。そして、再送制御部214は、情報受信部211が連携装置4から送信された応答通知を受信した場合、情報受信部211が受信したコミットログを情報格納領域130から削除する。 The information receiving unit 211 also receives a response notification from the coordinating device 4 indicating that reception of the commit log received by the information receiving unit 211 has been completed successfully. Then, when the information receiving unit 211 receives the response notification sent from the coordinating device 4, the retransmission control unit 214 deletes the commit log received by the information receiving unit 211 from the information storage area 130.

なお、以下、連携装置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 device 4.

連携装置4は、図7に示すように、CPU401やメモリ402等のハードウエアとプログラム410とが有機的に協働することにより、例えば、情報受信部411と、受信判定部412と、情報送信部413とを含む各種機能を実現する。 As shown in FIG. 7, the linkage device 4 realizes various functions including, for example, an information receiving unit 411, a reception determining unit 412, and an information transmitting unit 413, by organic cooperation between hardware such as a CPU 401 and a memory 402 and a program 410.

情報受信部411は、アクティブ装置1が送信したコミットログを受信する。また、情報受信部411は、特定のスタンバイ装置が送信した受信確認の指示を受信する。 The information receiving unit 411 receives the commit log sent by the active device 1. The information receiving unit 411 also receives a receipt confirmation instruction sent by a specific standby device.

受信判定部412は、情報受信部411がコミットログと受信確認の指示とを受信しているか否かを判定する。具体的に、受信判定部412は、情報受信部411が受信確認の指示を受信した場合、その受信確認の指示に対応するコミットログを既に受信しているか否かを判定する。 The reception determination unit 412 determines whether the information receiving unit 411 has received a commit log and an instruction to confirm receipt. Specifically, when the information receiving unit 411 receives an instruction to confirm receipt, the reception determination unit 412 determines whether the commit log corresponding to the instruction to confirm receipt has already been received.

情報送信部413は、情報受信部411がコミットログと受信確認の指示とを受信していると受信判定部412が判定した場合、情報受信部411が受信したコミットログの受信が正常に完了したことを示す応答通知を特定のスタンバイ装置に送信する。 When the reception determination unit 412 determines that the information receiving unit 411 has received the commit log and an instruction to confirm reception, the information transmitting unit 413 transmits a response notification to a specific standby device indicating that reception of the commit log received by the information receiving unit 411 has been completed successfully.

また、情報送信部413は、情報受信部411が受信したコミットログを外部システム20に送信する。 In addition, the information sending unit 413 sends the commit log received by the information receiving unit 411 to the external system 20.

[第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 active device 1. Also, Figure 9 is a flow chart outlining the log transmission process in the standby device 2. Furthermore, Figure 10 is a flow chart outlining the log transmission process in the cooperating device 4. Note that the process in the standby device 3 is the same as the process in the standby device 2, so a description thereof will be omitted.

初めに、アクティブ装置1におけるログ送信処理の概略について説明を行う。 First, we will provide an overview of the log transmission process in the active device 1.

アクティブ装置1は、図8に示すように、データベース1bに対するトランザクションがコミットするまで待機する(S1のNO)。 As shown in FIG. 8, the active device 1 waits until the transaction for database 1b is committed (NO in S1).

そして、データベース1bに対するトランザクションがコミットした場合(S1のYES)、アクティブ装置1は、コミットしたトランザクションについてのコミットログの連携装置4における受信確認を行う特定のスタンバイ装置を決定する(S2)。 Then, when the transaction for database 1b is committed (YES in S1), active device 1 determines a specific standby device that will confirm receipt of the commit log for the committed transaction in collaboration device 4 (S2).

具体的に、アクティブ装置1は、例えば、スタンバイ装置2及びスタンバイ装置3のいずれかを特定のスタンバイ装置として決定する。 Specifically, active device 1 determines, for example, either standby device 2 or standby device 3 as the specific standby device.

その後、アクティブ装置1は、S2の処理において決定した特定のスタンバイ装置の識別情報を付加したコミットログを、S2の処理において決定した特定のスタンバイ装置と連携装置4とにそれぞれ送信する(S3)。 Then, the active device 1 transmits the commit log, to which the identification information of the specific standby device determined in the process of S2 has been added, to the specific standby device determined in the process of S2 and to the cooperating device 4 (S3).

次に、スタンバイ装置2におけるログ送信処理の概略について説明を行う。 Next, we will provide an overview of the log transmission process on the standby device 2.

スタンバイ装置2は、図9に示すように、アクティブ装置1から送信されたコミットログを受信するまで待機する(S11のNO)。 As shown in FIG. 9, the standby device 2 waits until it receives the commit log sent from the active device 1 (NO in S11).

そして、アクティブ装置1から送信されたコミットログを受信した場合(S11のYES)、スタンバイ装置2は、S11の処理において受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する(S12)。 Then, when a commit log sent from the active device 1 is received (YES in S11), the standby device 2 determines whether the identification information included in the commit log received in the processing of S11 indicates its own device (S12).

その結果、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 standby device 2 stores the commit log received in processing S11 in the information storage area 230 and instructs the cooperating device 4 to confirm receipt of the commit log received in processing S11 (S14).

その後、コミットログの受信が正常に完了したことを示す応答通知を連携装置4から受信した場合(S15のYES)、スタンバイ装置2は、S11の処理において受信したコミットログ(S14の処理において記憶したコミットログ)を情報格納領域230から削除する(S16)。 Thereafter, if a response notification is received from the collaboration device 4 indicating that reception of the commit log has been completed successfully (YES in S15), the standby device 2 deletes the commit log received in the processing of S11 (the commit log stored in the processing of S14) from the information storage area 230 (S16).

一方、コミットログの受信が正常に完了したことを示す応答通知を連携装置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 standby device 2 does not perform the process of S16.

また、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 standby device 2 does not perform processing from S14 onwards.

次に、連携装置4におけるログ送信処理の概略について説明を行う。 Next, we will provide an overview of the log transmission process in the linked device 4.

連携装置4は、図10に示すように、アクティブ装置1からコミットログを受信し、かつ、特定のスタンバイ装置から受信確認の指示を受信するまで待機する(S21のNO)。 As shown in FIG. 10, the coordinating device 4 receives the commit log from the active device 1 and waits until it receives a receipt confirmation instruction from a specific standby device (NO in S21).

そして、コミットログ及び受信確認の指示を受信した場合(S21のYES)、連携装置4は、受信した受信確認の指示に対する応答通知(コミットログの受信が正常に完了したことを示す応答通知)を特定のスタンバイ装置に送信する(S22)。 Then, if a commit log and a receipt confirmation instruction are received (YES in S21), the coordinating device 4 sends a response notification to the received receipt confirmation instruction (a response notification indicating that reception of the commit log has been completed successfully) to a specific standby device (S22).

すなわち、本実施の形態における取引システム10では、連携装置4におけるコミットログの受信確認を特定のスタンバイ装置が行う。 In other words, in the trading system 10 of this embodiment, a specific standby device confirms receipt of the commit log in the linked device 4.

これにより、本実施の形態における取引システム10は、例えば、連携装置4から送信される応答通知の待ち合わせに時間を要する場合であっても、アクティブ装置1における処理性能の低下を防止することが可能になる。 As a result, the trading system 10 in this embodiment can prevent a decrease in processing performance in the active device 1, even if it takes time to wait for a response notification sent from the linked device 4, for example.

[第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 standby device 3 is the same as the process in the standby device 2, so a description thereof will be omitted.

[アクティブ装置におけるログ送信処理の詳細]
初めに、アクティブ装置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 active unit 1. Fig. 11 to Fig. 13 are flow charts for explaining the details of the log transmission process in the active unit 1.

情報受信部111は、図11に示すように、例えば、受付装置5が送信した処理依頼を受信するまで待機する(S31のNO)。 As shown in FIG. 11, the information receiving unit 111 waits, for example, until it receives a processing request sent by the reception device 5 (NO in S31).

そして、受付装置5が送信した処理依頼を受信した場合(S31のYES)、情報管理部113は、受信した処理依頼に対応する内容をデータベース1bに反映する(S32)。 Then, when a processing request sent by the reception device 5 is received (YES in S31), the information management unit 113 reflects the contents corresponding to the received processing request in the database 1b (S32).

具体的に、情報管理部113は、例えば、取引処理部112が株の売買を成立させた場合、取引処理部112が成立させた売買注文(S31の処理において受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。また、情報管理部113は、例えば、取引処理部112が株の売買を成立させなかった場合、取引処理部112が成立させなかった売買注文(S31の処理において受信した処理依頼に対応する売買注文)の内容をデータベース1bに書き込む。 Specifically, for example, if the trading processing unit 112 completes a stock trade, the information management unit 113 writes the contents of the trade order completed by the trading processing unit 112 (the trade order corresponding to the processing request received in the processing of S31) into database 1b. Also, for example, if the trading processing unit 112 does not complete a stock trade, the information management unit 113 writes the contents of the trade order not completed by the trading processing unit 112 (the trade order corresponding to the processing request received in the processing of S31) into database 1b.

続いて、情報生成部114は、S31の処理において受信した処理依頼に対応するトランザクションについてのコミットログを生成する(S33)。以下、S33の処理において生成されたコミットログの具体例について説明を行う。 Next, the information generation unit 114 generates a commit log for the transaction corresponding to the processing request received in the processing of S31 (S33). Below, a specific example of the commit log generated in the processing of S33 is described.

[コミットログの具体例]
図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 database 1b) of the record corresponding to each commit log CL is set, and "record information" in which the contents of the record corresponding to each commit log CL is set.

具体的に、図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 device determination unit 115 determines a specific standby device that will confirm receipt of the commit log generated in the processing of S33 in the collaboration device 4 (S34). Details of the processing of S34 will be described below.

[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 device determination unit 115 determines whether or not correspondence information 131 including the record number included in the commit log generated in the process of S33 is stored in the information storage area 130 (S51). A specific example of the correspondence information 131 will be described below.

[対応情報の具体例]
図19及び図21は、対応情報131の具体例を説明する図である。
[Examples of correspondence information]
19 and 21 are diagrams for explaining specific examples of the correspondence information 131. FIG.

図19等に示す対応情報131は、各スタンバイ装置の識別情報が設定される「識別情報」と、各スタンバイ装置が再送制御を行うコミットログに対応するレコードの格納位置が設定される「レコード番号」とを項目として有する。「識別情報」には、例えば、スタンバイ装置2を示す「Standby1」、または、スタンバイ装置3を示す「Standby2」が設定される。 The correspondence information 131 shown in FIG. 19 etc. has the following items: "identification information," in which the identification information of each standby device is set, and "record number," in which the storage location of the record corresponding to the commit log for which each standby device performs retransmission control is set. For example, "Standby1," which indicates standby device 2, or "Standby2," which indicates standby device 3, is set as the "identification information."

具体的に、図19に示す対応情報131において、例えば、1行目の情報には、「識別情報」として「Standby2」が設定され、「レコード番号」として「0001」が設定されている。 Specifically, in the correspondence information 131 shown in FIG. 19, for example, in the information in the first line, "Standby2" is set as the "identification information" and "0001" is set as the "record number."

また、図19に示す対応情報131において、例えば、2行目の情報には、「識別情報」として「Standby1」が設定され、「レコード番号」として「0002」が設定されている。図19に含まれる他の情報についての説明は省略する。 In addition, in the correspondence information 131 shown in FIG. 19, for example, in the information on the second line, "Standby1" is set as the "identification information" and "0002" is set as the "record number." Explanation of the other information included in FIG. 19 is omitted.

図13に戻り、S33の処理において生成したコミットログに含まれるレコード番号を含む対応情報131が情報格納領域130に記憶されていると判定した場合(S52のYES)、装置決定部115は、情報格納領域130に記憶した対応情報131を参照し、S33の処理において生成したコミットログに含まれるレコード番号に対応するスタンバイ装置を、S33の処理において生成したコミットログの受信確認を行う特定のスタンバイ装置として決定する(S53)。 Returning to FIG. 13, if it is determined that correspondence information 131 including the record number included in the commit log generated in the processing of S33 is stored in the information storage area 130 (YES in S52), the device determination unit 115 refers to the correspondence information 131 stored in the information storage area 130 and determines the standby device corresponding to the record number included in the commit log generated in the processing of S33 as the specific standby device that will confirm receipt of the commit log generated in the processing of S33 (S53).

具体的に、図19で説明した対応情報131において、「レコード番号」に「0003」が設定された情報(3行目の情報)の「識別情報」には、「Standby1」が設定されている。そのため、例えば、S33の処理において生成したコミットログに含まれるレコード番号が「0003」である場合、装置決定部115は、スタンバイ装置2を特定のスタンバイ装置として決定する。 Specifically, in the correspondence information 131 described in FIG. 19, the "identification information" of the information (the information in the third line) in which "record number" is set to "0003" is set to "Standby1." Therefore, for example, if the record number included in the commit log generated in the processing of S33 is "0003," the device determination unit 115 determines standby device 2 as the specific standby device.

すなわち、対応情報131には、各レコード番号に対応するコミットログの送信(再送)を行っているスタンバイ装置の情報が含まれている。そのため、装置決定部115は、特定のスタンバイ装置を対応情報131に従って決定することによって、同一のレコード番号を有するコミットログの送信を同一のスタンバイ装置に行わせることが可能になる。 In other words, the correspondence information 131 includes information about the standby device that is sending (re-sending) the commit log that corresponds to each record number. Therefore, the device determination unit 115 can determine a specific standby device according to the correspondence information 131, thereby making it possible to have the same standby device send commit logs having the same record number.

これにより、アクティブ装置1は、同一のレコード番号を有するコミットログの送信が複数のスタンバイ装置において行われることを防止することが可能になる。そのため、アクティブ装置1は、例えば、ネットワークの状況等に起因して各スタンバイ装置から送信されたコミットログの順序が入れ替わる可能性がある場合であっても、同一レコード番号を有するコミットログの送信順序が入れ替わることを防止することが可能になる。 This enables the active device 1 to prevent the transmission of commit logs having the same record number from being performed on multiple standby devices. Therefore, even if there is a possibility that the order of commit logs transmitted from each standby device may be changed due to network conditions, etc., the active device 1 can prevent the transmission order of commit logs having the same record number from being changed.

一方、S33の処理において生成したコミットログに含まれるレコード番号を含む対応情報131が情報格納領域130に記憶されていないと判定した場合(S52のNO)、装置決定部115は、例えば、情報格納領域130に記憶した対応情報131に含まれる数(割合)が最小である識別情報に対応するスタンバイ装置を、S33の処理において生成したコミットログの受信確認を行う特定のスタンバイ装置として決定する(S54)。 On the other hand, if it is determined that the correspondence information 131 including the record number included in the commit log generated in the processing of S33 is not stored in the information storage area 130 (NO in S52), the device determination unit 115 determines, for example, the standby device corresponding to the identification information with the smallest number (proportion) included in the correspondence information 131 stored in the information storage area 130 as the specific standby device that will confirm the reception of the commit log generated in the processing of S33 (S54).

具体的に、図19で説明した対応情報131において、例えば、「識別情報」に「Standby1」が設定された情報(行)の数が、「識別情報」に「Standby2」が設定された情報の数よりも少ない場合、装置決定部115は、スタンバイ装置2を特定のスタンバイ装置として決定する。 Specifically, in the correspondence information 131 described in FIG. 19, for example, if the number of pieces of information (rows) in which "Identification Information" is set to "Standby1" is less than the number of pieces of information in which "Identification Information" is set to "Standby2", the device determination unit 115 determines standby device 2 as the specific standby device.

これにより、アクティブ装置1は、各スタンバイ装置における処理負荷を均等化することが可能になる。 This allows the active device 1 to equalize the processing load on each standby device.

その後、装置決定部115は、S33の処理において生成したコミットログに含まれるレコード番号と、S54の処理において決定したスタンバイ装置の識別情報とを対応付けた情報を対応情報131の少なくとも一部として情報格納領域130に記憶する(S55)。 Then, the device determination unit 115 stores information associating the record number included in the commit log generated in the process of S33 with the identification information of the standby device determined in the process of S54 in the information storage area 130 as at least part of the correspondence information 131 (S55).

図11に戻り、情報生成部114は、S34の処理において決定した特定のスタンバイ装置の識別情報を、S33の処理において生成したコミットログに付加する(S35)。 Returning to FIG. 11, the information generation unit 114 adds the identification information of the specific standby device determined in the processing of S34 to the commit log generated in the processing of S33 (S35).

具体的に、S34の処理において決定した特定のスタンバイ装置がスタンバイ装置2である場合、情報生成部114は、図20に示すように、例えば、図18で説明したコミットログの「識別情報」に「Standby1」を設定する。 Specifically, if the specific standby device determined in the processing of S34 is standby device 2, the information generation unit 114 sets, for example, "Standby1" to the "identification information" of the commit log described in FIG. 18, as shown in FIG. 20.

そして、情報送信部116は、S35の処理において識別情報を付加したコミットログを、全てのスタンバイ装置(スタンバイ装置2及びスタンバイ装置3)と連携装置4とにそれぞれ送信する(S36)。 Then, the information sending unit 116 sends the commit log to which the identification information was added in the processing of S35 to all standby devices (standby device 2 and standby device 3) and the cooperating device 4 (S36).

その後、情報受信部111は、図12に示すように、各スタンバイ装置におけるコミットログの受信が正常に行われたことを示す応答通知(以下、第1応答通知)を全てのスタンバイ装置から受信するまで待機する(S41のNO)。第1応答通知の具体例については後述する。 Then, as shown in FIG. 12, the information receiving unit 111 waits until it receives a response notification (hereinafter, a first response notification) from all standby devices indicating that the commit log has been received successfully at each standby device (NO in S41). A specific example of the first response notification will be described later.

そして、第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 information generation unit 114 updates the correspondence information 131 stored in the information storage area 130 according to the contents of the first response notification received in the processing of S41 (S42).

具体的に、例えば、「レコード番号」が「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 collaboration device 4, the information generation unit 114 deletes the information with a "record number" of "0002" (the information in the second row) from the correspondence information 131 described in FIG. 19, as shown in FIG. 21.

すなわち、情報生成部114は、各スタンバイ装置において記憶されているコミットログに対応するレコード番号のみが含まれるように、対応情報131の更新を行う。 In other words, the information generation unit 114 updates the correspondence information 131 so that it contains only the record numbers that correspond to the commit logs stored in each standby device.

これにより、アクティブ装置1は、情報格納領域130に記憶した対応情報131を参照することで、各スタンバイ装置において記憶されているコミットログに対応するレコード番号を特定することが可能になる。 This allows the active device 1 to identify the record number corresponding to the commit log stored in each standby device by referring to the correspondence information 131 stored in the information storage area 130.

なお、情報生成部114は、例えば、第1応答通知を特定のスタンバイ装置から受信したことに応じて、S42の処理を行うものであってもよい。 In addition, the information generating unit 114 may perform the process of S42, for example, in response to receiving a first response notification from a specific standby device.

その後、情報送信部116は、S31の処理において受信した処理依頼に対応するトランザクションがデータベース1bにおいてコミットしたことを示す応答通知(以下、第2応答通知とも呼ぶ)を受付装置5に送信する(S43)。 Then, the information sending unit 116 sends a response notification (hereinafter also referred to as a second response notification) to the receiving device 5 indicating that the transaction corresponding to the processing request received in the processing of S31 has been committed in the database 1b (S43).

[スタンバイ装置におけるログ送信処理の詳細]
次に、スタンバイ装置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 standby device 2. Figures 14 to 16 are flow charts illustrating the details of the log transmission process in the standby device 2.

情報受信部211は、図14に示すように、アクティブ装置1が送信したコミットログを受信するまで待機する(S61のNO)。 As shown in FIG. 14, the information receiving unit 211 waits until it receives the commit log sent by the active device 1 (NO in S61).

そして、コミットログが受信した場合(S61のYES)、情報判定部213は、S61で受信したコミットログに含まれる識別情報が自装置を示しているか否かを判定する(S62)。 If a commit log is received (YES in S61), the information determination unit 213 determines whether the identification information included in the commit log received in S61 indicates the device itself (S62).

その結果、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 retransmission control unit 214 generates a first response notification to which the record number of the commit log deleted in the immediately preceding process of S84 is added (S64). A specific example of the first response notification generated in the process of S64 will be described below.

[第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 database 1b) is set, "Operation type" in which the operation type corresponding to each commit log is set, and "Resent commit log" in which each commit log itself is set.

具体的に、図22に示す第1応答通知RS1には、「電文種別」として「応答通知1」が設定され、「シーケンス番号」として「0013」が設定され、「レコード番号(1)」として「0002」が設定され、「操作種別(1)」として「削除」が設定され、「再送コミットログ」として情報(コミットログ)が設定されていないことを示す「-」が設定されている。 Specifically, in the first response notification RS1 shown in FIG. 22, "Response notification 1" is set as the "Message type," "0013" is set as the "Sequence number," "0002" is set as the "Record number (1)," "Delete" is set as the "Operation type (1)," and "-" is set as the "Resend commit log," indicating that no information (commit log) is set.

すなわち、図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 information transmission unit 215 transmits the first response notification generated in the processing of S64 to the active device 1 (S65).

一方、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 retransmission control unit 214 stores the commit log received in the process of S61 in the information storage area 230 (S71), as shown in FIG. 15.

続いて、再送制御部214は、S61の処理において受信したコミットログのレコード番号と、直前に行ったS84で削除したコミットログのレコード番号とを付加した第1応答通知を生成する(S72)。 Next, the retransmission control unit 214 generates a first response notification to which the record number of the commit log received in the processing of S61 and the record number of the commit log deleted immediately before in S84 are added (S72).

[第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, "response notification 1" is set as the "message type", "0013" is set as the "sequence number", "0002" is set as the "record number (1)", and "delete" is set as the "operation type (1)". Also, in the first response notification RS1 shown in FIG. 23, "response notification 1" is set as the "message type", "0003" is set as the "record number (2)", "add" is set as the "operation type (2)", and "-" is set as the "re-sent commit log".

すなわち、図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 retransmission control unit 214 determines whether any commit logs other than the commit log received in the processing of S61 are stored in the information storage area 230 (S73).

その結果、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 information sending unit 215 sends the first response notification generated in the processing of S72 to each of the active device 1 and the cooperating device 4 (S75).

一方、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 retransmission control unit 214 adds the commit log other than the commit log received in the processing of S61 to the first response notification generated in the processing of S72 (S81), as shown in FIG. 16.

具体的に、再送制御部214は、例えば、図23で説明した第1応答通知における「再送コミットログ」に、情報格納領域230に記憶したコミットログのうち、S61の処理において受信したコミットログ以外のコミットログの内容を設定する。 Specifically, the retransmission control unit 214 sets, for example, the contents of the commit logs stored in the information storage area 230 other than the commit log received in the processing of S61 to the "retransmitted commit log" in the first response notification described in FIG. 23.

そして、情報送信部215は、S81の処理においてコミットログを付加した第1応答通知をアクティブ装置1と連携装置4とにそれぞれ送信する(S82)。 Then, the information sending unit 215 sends the first response notification to which the commit log was added in the processing of S81 to the active device 1 and the cooperating device 4 (S82).

さらに、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 active device 1 in processing of S36 has been successfully received is received from the linked device 4 within a predetermined time period (YES in S83), the retransmission control unit 214 deletes the commit log from the information storage area 230 in accordance with the contents of the third response notification received in processing of S83 (S84).

一方、S75の処理またはS82の処理の後、所定時間が経過するまでの間に、第3応答通知を連携装置4から受信しなかった場合(S83のNO)、再送制御部214は、S84の処理を実行しない。以下、第3応答通知の具体例について説明を行う。 On the other hand, if the third response notification is not received from the linked device 4 within the predetermined time period after the process of S75 or S82 (NO in S83), the retransmission control unit 214 does not execute the process of S84. Specific examples of the third response notification are described below.

[第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, "Response notification 3" is set as the "Message type" and "0013" is set as the "Sequence number."

すなわち、再送制御部214は、アクティブ装置1から連携装置4に対して送信されたコミットログのうち、連携装置4から受信が正常に完了したことを示す第3応答通知を受信していないコミットログが情報格納領域230に記憶されるように制御を行う。 In other words, the retransmission control unit 214 performs control so that, among the commit logs sent from the active device 1 to the coordinating device 4, those commit logs for which a third response notification indicating that reception has been successfully completed has not been received from the coordinating device 4 are stored in the information storage area 230.

これにより、スタンバイ装置2は、情報格納領域230に記憶されているコミットログを参照することで、連携装置4に対して再送を行う必要があるコミットログを容易に特定することが可能になる。 This allows the standby device 2 to easily identify the commit logs that need to be resent to the collaboration device 4 by referring to the commit logs stored in the information storage area 230.

[連携装置におけるログ送信処理の詳細]
次に、連携装置4におけるログ送信処理の詳細について説明を行う。図17は、連携装置4におけるログ送信処理の詳細について説明するフローチャート図である。
[Details of the log transmission process in the linked device]
Next, the details of the log transmission process in the linking device 4 will be described. FIG. 17 is a flow chart illustrating the details of the log transmission process in the linking device 4.

情報受信部411は、図17に示すように、アクティブ装置1からコミットログを受信し、かつ、特定のスタンバイ装置から第1応答通知を受信するまで待機する(S91のNO)。 As shown in FIG. 17, the information receiving unit 411 receives a commit log from the active device 1 and waits until it receives a first response notification from a specific standby device (NO in S91).

そして、アクティブ装置1からコミットログを受信し、かつ、特定のスタンバイ装置から第1応答通知を受信した場合(S91のYES)、情報送信部413は、受信したコミットログを外部システム20に送信する(S92)。 Then, when a commit log is received from the active device 1 and a first response notification is received from a specific standby device (YES in S91), the information sending unit 413 sends the received commit log to the external system 20 (S92).

続いて、受信判定部412は、S91の処理において受信した第1応答通知にコミットログが含まれているか否かを判定する(S93)。 Then, the reception determination unit 412 determines whether the first response notification received in the processing of S91 includes a commit log (S93).

その結果、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 information sending unit 413 sends the commit log included in the first response notification received in the processing of S91 to the external system 20 (S95).

一方、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 information sending unit 413 does not execute the process of S95.

その後、情報送信部413は、S91の処理において受信したコミットログに含まれる識別情報が示す特定のスタンバイ装置に対して第3応答通知を送信する(S96)。 Then, the information transmission unit 413 transmits a third response notification to the specific standby device indicated by the identification information included in the commit log received in the processing of S91 (S96).

これにより、連携装置4は、受信に成功したコミットログに対応する第3応答通知を特定のスタンバイ装置に対して送信することが可能になる。 This enables the coordinating device 4 to send a third response notification corresponding to the successfully received commit log to a specific standby device.

このように、本実施の形態におけるアクティブ装置1は、データベース1bに対するトランザクションがコミットした場合、連携装置4におけるコミットログの受信確認を行う特定のスタンバイ装置を決定する。そして、アクティブ装置1は、決定した特定のスタンバイ装置の識別情報を付加したコミットログを連携装置4と特定のスタンバイ装置とにそれぞれ送信する。 In this way, in this embodiment, when a transaction to database 1b is committed, active device 1 determines a specific standby device that will confirm receipt of the commit log in collaboration device 4. Then, active device 1 transmits the commit log, to which the identification information of the determined specific standby device has been added, to each of collaboration device 4 and the specific standby device.

その後、特定のスタンバイ装置は、コミットログをアクティブ装置1から受信した場合、受信したコミットログに含まれる識別情報が自装置(特定のスタンバイ装置)を示しているか否かを判定する。その結果、受信したコミットログに含まれる識別情報が自装置を示していると判定した場合、特定のスタンバイ装置は、コミットログを記憶部に記憶するとともに、連携装置4に対してコミットログの受信確認の指示を送信する。 After that, when the specific standby device receives a commit log from the active device 1, it determines whether the identification information included in the received commit log indicates its own device (the specific standby device). As a result, if it determines that the identification information included in the received commit log indicates its own device, the specific standby device stores the commit log in the memory unit and sends an instruction to the cooperating device 4 to confirm receipt of the commit log.

そして、連携装置4は、コミットログをアクティブ装置1から受信し、かつ、コミットログの受信確認の指示を特定のスタンバイ装置から受信した場合、コミットログの受信確認が正常に完了したことを示す応答通知を特定のスタンバイ装置に送信する。 Then, when the coordinating device 4 receives the commit log from the active device 1 and receives an instruction to confirm receipt of the commit log from a specific standby device, it sends a response notification to the specific standby device indicating that confirmation of receipt of the commit log has been completed successfully.

さらに、特定のスタンバイ装置は、コミットログの受信確認が正常に完了したことを示す応答通知を連携装置4から受信した場合、アクティブ装置1から受信したコミットログを記憶部から削除する。 Furthermore, when a particular standby device receives a response notification from the cooperating device 4 indicating that confirmation of receipt of the commit log has been successfully completed, the particular standby device deletes the commit log received from the active device 1 from the memory unit.

すなわち、本実施の形態における取引システム10では、連携装置4におけるコミットログの受信確認を特定のスタンバイ装置が行う。 In other words, in the trading system 10 of this embodiment, a specific standby device confirms receipt of the commit log in the linked device 4.

これにより、本実施の形態における取引システム10は、例えば、連携装置4から送信される応答通知の待ち合わせに時間を要する場合であっても、アクティブ装置1における処理性能の低下を防止することが可能になる。 As a result, the trading system 10 in this embodiment can prevent a decrease in processing performance in the active device 1, even if it takes time to wait for a response notification sent from the linked device 4, for example.

[ログ送信処理の具体例(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 collaboration device 4 does not occur will be described. Fig. 25 is a sequence chart diagram illustrating a specific example of the log transmission process in the case where the retransmission of the commit log to the collaboration device 4 does not occur. Note that the following description will be given for the case where the standby device 3 is a specific standby device.

具体的に、受付装置5は、例えば、証券会社の情報処理システム(図示せず)から送信された処理依頼(1)をアクティブ装置1に送信する。 Specifically, the reception device 5 transmits a processing request (1) sent from, for example, an information processing system (not shown) of a securities company to the active device 1.

そして、アクティブ装置1は、受付装置5から送信された処理依頼(1)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(1)に対応するトランザクションについてのコミットログ(1)を送信する。 When the active device 1 receives a processing request (1) sent from the receiving device 5, it sends a commit log (1) for the transaction corresponding to the processing request (1) to each of the standby device 2, the standby device 3, and the cooperating device 4.

その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、第1応答通知(1)をアクティブ装置1に送信する。 Then, in response to receiving the commit log (1) sent by the active device 1, the standby device 2 sends a first response notification (1) to the active device 1.

また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、受信したコミットログ(1)を情報格納領域130に記憶し、第1応答通知(2)をアクティブ装置1に送信し、さらに、第1応答通知(3)を連携装置4に送信する。 In addition, upon receiving the commit log (1) sent by the active device 1, the standby device 3 stores the received commit log (1) in the information storage area 130, sends a first response notification (2) to the active device 1, and further sends a first response notification (3) to the cooperating device 4.

そして、アクティブ装置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 standby device 3, the active device 1 sends a second response notification (1) to the receiving device 5. In this case, the active device 1 generates correspondence information 131 that associates the commit log (1) with the identification information of the standby device 3 and stores it in the information storage area 130.

また、連携装置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 standby device 3, the cooperating device 4 sends the commit log (1) sent by the active device 1 to the external system 20, and further sends a third response notification (1) to the standby device 3. After that, in response to receiving the third response notification (1) sent by the cooperating device 4, the standby device 3 deletes the commit log (1) stored in the information storage area 330.

続いて、受付装置5は、例えば、アクティブ装置1が送信した第2応答通知(1)を受信した後、処理依頼(2)をアクティブ装置1に送信する。 Then, for example, after receiving the second response notification (1) sent by the active device 1, the reception device 5 sends a processing request (2) to the active device 1.

そして、アクティブ装置1は、受付装置5から送信された処理依頼(2)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(2)に対応するトランザクションについてのコミットログ(2)を送信する。 Then, when the active device 1 receives the processing request (2) sent from the receiving device 5, it sends a commit log (2) for the transaction corresponding to the processing request (2) to each of the standby device 2, the standby device 3, and the cooperating device 4.

その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、第1応答通知(4)をアクティブ装置1に送信する。 Then, in response to receiving the commit log (2) sent by the active device 1, the standby device 2 sends a first response notification (4) to the active device 1.

また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、受信したコミットログ(2)を情報格納領域330に記憶し、第1応答通知(5)をアクティブ装置1に送信し、さらに、第1応答通知(6)を連携装置4に送信する。 In addition, upon receiving the commit log (2) sent by the active device 1, the standby device 3 stores the received commit log (2) in the information storage area 330, sends a first response notification (5) to the active device 1, and further sends a first response notification (6) to the cooperating device 4.

そして、アクティブ装置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 standby device 3, the active device 1 sends a second response notification (2) to the receiving device 5. In this case, the active device 1 deletes the correspondence information 131 that associates the commit log (1) with the identification information of the standby device 3 from the information storage area 130, and generates correspondence information 131 that associates the commit log (2) with the identification information of the standby device 3 and stores it in the information storage area 130.

また、連携装置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 standby device 3, the cooperating device 4 sends the commit log (2) sent by the active device 1 to the external system 20, and further sends a third response notification (2) to the standby device 3. After that, in response to receiving the third response notification (2) sent by the cooperating device 4, the standby device 3 deletes the commit log (2) stored in the information storage area 330.

[ログ送信処理の具体例(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 coordination device 4. Fig. 26 is a sequence chart diagram illustrating a specific example of the log transmission process in the case where a retransmission of a commit log occurs to the coordination device 4.

具体的に、受付装置5は、例えば、証券会社の情報処理システム(図示せず)から送信された処理依頼(1)をアクティブ装置1に送信する。 Specifically, the reception device 5 transmits a processing request (1) sent from, for example, an information processing system (not shown) of a securities company to the active device 1.

そして、アクティブ装置1は、受付装置5から送信された処理依頼(1)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(1)に対応するトランザクションについてのコミットログ(1)を送信する。 When the active device 1 receives a processing request (1) sent from the receiving device 5, it sends a commit log (1) for the transaction corresponding to the processing request (1) to each of the standby device 2, the standby device 3, and the cooperating device 4.

その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、第1応答通知(1)をアクティブ装置1に送信する。 Then, in response to receiving the commit log (1) sent by the active device 1, the standby device 2 sends a first response notification (1) to the active device 1.

また、スタンバイ装置3は、アクティブ装置1が送信したコミットログ(1)を受信したことに応じて、受信したコミットログ(1)を情報格納領域130に記憶し、第1応答通知(2)をアクティブ装置1に送信し、さらに、第1応答通知(3)を連携装置4に送信する。 In addition, upon receiving the commit log (1) sent by the active device 1, the standby device 3 stores the received commit log (1) in the information storage area 130, sends a first response notification (2) to the active device 1, and further sends a first response notification (3) to the cooperating device 4.

そして、アクティブ装置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 standby device 3, the active device 1 sends a second response notification (1) to the receiving device 5. In this case, the active device 1 generates correspondence information 131 that associates the commit log (1) with the identification information of the standby device 3 and stores it in the information storage area 130.

ここで、アクティブ装置1から連携装置4に対するコミットログ(1)の送信が失敗した場合、連携装置4は、図25で説明した場合と異なり、スタンバイ装置3が送信した第1応答通知(3)を受信した場合であっても、スタンバイ装置3に対して第3応答通知(1)の送信を行わない。そのため、スタンバイ装置3では、この場合、コミットログ(1)の削除が行われない。 Here, if the transmission of commit log (1) from active device 1 to coordinating device 4 fails, unlike the case described in FIG. 25, coordinating device 4 does not transmit third response notification (1) to standby device 3 even if it receives first response notification (3) sent by standby device 3. Therefore, in this case, the standby device 3 does not delete commit log (1).

続いて、受付装置5は、例えば、アクティブ装置1が送信した第2応答通知(1)を受信した後、処理依頼(2)をアクティブ装置1に送信する。 Then, for example, after receiving the second response notification (1) sent by the active device 1, the reception device 5 sends a processing request (2) to the active device 1.

そして、アクティブ装置1は、受付装置5から送信された処理依頼(2)を受信した場合、スタンバイ装置2、スタンバイ装置3及び連携装置4のそれぞれに対して、処理依頼(2)に対応するトランザクションについてのコミットログ(2)を送信する。 Then, when the active device 1 receives the processing request (2) sent from the receiving device 5, it sends a commit log (2) for the transaction corresponding to the processing request (2) to each of the standby device 2, the standby device 3, and the cooperating device 4.

その後、スタンバイ装置2は、アクティブ装置1が送信したコミットログ(2)を受信したことに応じて、第1応答通知(4)をアクティブ装置1に送信する。 Then, in response to receiving the commit log (2) sent by the active device 1, the standby device 2 sends a first response notification (4) to the active device 1.

また、スタンバイ装置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 active device 1, the standby device 3 stores the received commit log (2) in the information storage area 330 and sends a first response notification (5) to the active device 1. Here, both the commit log (1) and the commit log (2) are stored in the information storage area 330. Therefore, unlike the case described in FIG. 25, the standby device 3 sends not only the first response notification (6) but also the commit log (1) to the cooperating device 4.

そして、アクティブ装置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 standby device 3, the active device 1 sends a second response notification (2) to the receiving device 5. In this case, the active device 1 generates correspondence information 131 that associates the commit log (2) with the identification information of the standby device 3 and stores it in the information storage area 130.

また、連携装置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 standby device 3, the coordinating device 4 transmits the commit log (1) sent (retransmitted) by the standby device 3 and the commit log (2) sent by the active device 1 to the external system 20, and further transmits a third response notification (2) to the standby device 3. After that, in response to receiving the third response notification (2) sent by the coordinating device 4, the standby device 3 deletes the commit log (1) and the commit log (2) stored in the information storage area 330.

これにより、スタンバイ装置3(特定のスタンバイ装置)は、連携装置4に対するコミットログの再送処理をアクティブ装置1に代わって行うことが可能になる。そのため、スタンバイ装置3は、アクティブ装置1の処理負担を軽減させることが可能になる。 This enables the standby device 3 (a specific standby device) to resend the commit log to the cooperating device 4 on behalf of the active device 1. Therefore, the standby device 3 can reduce the processing load on the active device 1.

以上の実施の形態をまとめると、以下の付記のとおりである。 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 Appendix 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:

(付記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 Appendix 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:

(付記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: Active device 1a: Processing unit 1b: Database 2: Standby device 2a: Processing unit 2b: Database 3: Standby device 3a: Processing unit 3b: Database 4: Cooperative device 5: Reception device 10: Information processing system 20: External system

Claims (8)

データベースに対するトランザクションについてのコミットログを送信する第1情報処理装置と、前記コミットログを前記第1情報処理装置から受信する第2情報処理装置及び第3情報処理装置と、前記コミットログを前記第1情報処理装置から受信する送信先装置とを有する情報処理システムであって、
前記第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において、
前記第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:
請求項2において、
前記第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:
請求項2において、
前記第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において、
前記いずれかの情報処理装置は、
新たなコミットログを前記第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情報処理装置と、前記コミットログを前記第1情報処理装置から受信する第2情報処理装置及び第3情報処理装置と、前記コミットログを前記第1情報処理装置から受信する送信先装置とを有する情報処理システムにおけるログ送信方法であって、
前記第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:
JP2020206497A 2020-12-14 2020-12-14 Information processing system, log transmission program, information processing device, and log transmission method Active JP7564438B2 (en)

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)

* Cited by examiner, † Cited by third party
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)

Patent Citations (4)

* Cited by examiner, † Cited by third party
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