JP5879159B2 - Synchronization method in multiple servers - Google Patents

Description

  The present invention relates to a technique for maintaining the consistency of data processing when performing synchronization processing with a plurality of information processing apparatuses (servers).

  Currently, a predetermined process is executed by a plurality of servers in accordance with an instruction from a client. If processing is performed by a plurality of servers in this way, inconsistencies may occur in the processing results. As a technique for solving this problem, there is Patent Literature 1. This patent document 1 includes “a preferred embodiment of the present invention comprising structured electronic storage means (SES) interconnected and shared by a plurality of central processing complexes (CPCs). (Refer to the means for solving the problem).

JP-A-6-83775

  Patent Document 1 describes an example of a technique for interconnecting a plurality of computers and preventing inconsistency with a structured electronic storage means shared by them. However, when the electronic storage means of Patent Document 1 does not function due to a failure or the like, data synchronization cannot be performed among a plurality of computers.

  In order to solve the above-mentioned problems, the present invention provides one electronic storage means by duplicating a structured electronic storage means shared by a plurality of computers and connecting the plurality of computers to each electronic storage means. Data can be synchronized among a plurality of computers even if the computer stops functioning due to a failure or the like. That is, in the present invention, when processing is executed in a plurality of servers, the same identification information (sequential number) for different requests (requests) for the processing of each of the plurality of servers in any of the corresponding synchronization servers Is given, it notifies the other synchronization server. At this time, it is more preferable to execute an arbitration process for giving priority to the processing result in which server in accordance with the notification.

Note that one embodiment of the present invention will be described below in more specific terms. An information processing apparatus (system) 1 having the following configuration,
A client terminal 100 including a control unit 102 that transmits a processing request to the calculation server and receives a response of the processing result;
A request duplication unit 202 that transmits the processing request from the client terminal 100 to the first calculation server 300 and one or more second calculation servers 400;
A response / discard determination unit 204 for transmitting processing result responses from the first calculation server 300 and the second calculation server 400 to the client terminal 100;
A request replication server 200 comprising:
When a processing request is received from the client terminal 100 and the first calculation server 300 and the second calculation server 400 require a synchronization, the first synchronization server 700 and one or more second synchronization servers 800 The first calculation server 300 including the first calculation unit 302 that executes the calculation process of the processing request and sends back the processing result after requesting the synchronization process;
When a processing request is received from the client terminal 100 and the first calculation server 300 and the second calculation server 400 require a synchronization, the first synchronization server 700 and one or more second synchronization servers 800 The one or more second calculation servers 400 including the second calculation unit 402 that executes the calculation process of the process request and sends back the processing result after requesting the synchronization process;
Have
The first synchronization server 700 processes the synchronization request from the first calculation server 300 and the second calculation server 400, and the comparison result of the one or more second synchronization processing servers 800 includes the processing result of the synchronization request. A comparison processing unit 708 that notifies the notification unit 808 is provided.

  According to the present invention, even when one electronic storage means shared by a plurality of computers ceases to function due to a failure or the like, the other electronic storage means functions so that Data synchronization is possible.

  Problems, configurations, and effects other than those described above will be clarified by the following description of embodiments.

It is a block diagram of the information processing apparatus of a present Example. 1 is a schematic diagram of a distributed processing system. It is a hardware block diagram of a client terminal. 6 is a flowchart for explaining processing of a comparison notification unit of the first synchronization server. It is a flowchart explaining the process of the comparison notification part of a 1st synchronous server. It is an example of queue data handled by a request queue processing unit and a replication queue processing unit. It is an example of queue data handled by a request queue processing unit and a replication queue processing unit. It is a flowchart explaining the process of the comparison notification part of a 2nd synchronization server.

  Hereinafter, an embodiment of the present invention will be described with reference to the drawings.

In this embodiment, an example of a dual system in which synchronization servers are duplicated will be described.
FIG. 2 is a diagram illustrating the information processing apparatus 1 according to the present embodiment.

  The information processing apparatus 1 includes a client terminal 100, a request replication server 200, a plurality of calculation servers 300 and 400, a plurality of queue servers 500 and 600, and a plurality of synchronization servers 700 and 800. Each terminal and server can communicate with each other via the network 150.

  The network 150 is a communication network managed by a user organization such as a LAN (Local Area Network). However, the network 150 is not limited thereto, and may be a public communication network such as the Internet, or a communication network partially using a general public line such as a WAN (Wide Area Network) or a VPN (Virtual Private Network).

  FIG. 1 is a diagram illustrating that the information processing apparatus 1 has a dual system configuration in which synchronization servers are duplicated.

  The client terminal 100 includes a control unit 102. The control unit 102 transmits a processing request to the calculation server and receives a response as a processing result.

  Since the process request transmitted by the control unit 102 of the client terminal 100 is transmitted to each of the dual computation server groups, the request replication unit 202 of the request replication server 200 first receives it. The request duplication unit 202 registers the processing request as “processing” in the request state data 206 and transmits the request to the first calculation server and the second calculation server.

  The calculation server has a dual configuration, and includes a first calculation server 300 and a second calculation server 400 each including a plurality of servers.

  The processing request transmitted from the request duplication unit 202 to the first calculation server 300 is received by the first calculation processing unit 302 of any one of the servers constituting the first calculation server 300, and the requested processing is executed. Similarly, the processing request is also received by the second calculation processing unit 402 of any of the servers constituting the second calculation server 400, and the requested processing is executed.

  When the processing according to the above-described processing request does not require the synchronization processing, the first calculation unit 302 and the second calculation unit 402 transmit the processing results to the response / discard determination unit 204 of the request replication server 200, respectively.

  The response / discard determination unit 204 checks the status of the processing request corresponding to the received processing result with reference to the request status data 206, and if it is “processing”, changes the status to “response completed” The result is transmitted to the client terminal 100. If the response has already been made, the processing result is discarded without being transmitted.

  As described above, the dual system according to the present embodiment improves the availability by multiplexing the calculation server group, and transmits a response that has been processed first to the client terminal 100, thereby providing a high-speed response. Realize.

  Next, processing when synchronization processing is necessary in this embodiment will be described.

  The case where the synchronization processing is necessary is, for example, the following case. In this embodiment, since each calculation server is a distributed system including a plurality of servers, the processing order of processing requests may be different between the first calculation server 300 and the second calculation server 400. When the processing order affects the final result, it is necessary to synchronize the processing order of the processing requests between the first calculation server 300 and the second calculation server 400.

  In this embodiment, the synchronization server performs the above-described synchronization processing. Further, by duplicating the synchronization server into the first synchronization server 700 and the second synchronization server, the synchronization server is prevented from becoming a single point of failure.

  The first calculation unit 302 that has received the processing request transmits the processing request to the first sorting queue processing unit 502 of the first queue server 500 before performing the processing when the processing request requires synchronization processing. The first sorting queue processing unit 502 sequentially transmits processing requests to the first request queue processing unit 702 of the first synchronization server 700 and the second replication queue processing unit 804 of the second synchronization server 800 in the order received.

  Similarly, the second calculation unit 402 that has received the processing request transmits the processing request to the second aligned queue processing unit 602 of the second queue server 600 before performing the processing when the processing request requires synchronization processing. The second sorting queue processing unit 602 sequentially transmits processing requests to the first replication queue processing unit 704 of the first synchronization server 700 and the second request queue processing unit 802 of the second synchronization server 800 in the order received.

  Here, the order of the processing requests received by the first request queue processing unit 702 and the order of the processing requests received by the second replication queue processing unit 804 are the same by the processing of each sorting queue processing unit. is there. The order of processing requests received by the first replication queue processing unit 704 and the order of processing requests received by the second request queue processing unit 802 are the same.

  However, the arrival timing of the processing request to each request queue and each replication queue may differ depending on the processing load of the queue server, the network load, and the like.

  The comparison notification unit 708 takes out the first processing request from the first request queue processing unit 702 and the first replication queue 704 and compares them. In the case of the same processing request, the numbering processing unit 706 is requested to assign a number to the request, and the response number is added to the processing request and transmitted to the first calculation server 300. Further, the numbering result is notified to the comparison processing unit 808 of the second synchronization server 800.

  The comparison processing unit 808 of the second synchronization server 800 adds a number to the processing request according to the notified numbering result, and transmits it to the second calculation server 400.

  The first calculation server 300 and the second calculation server 400 perform processing in the order according to the number added to the processing request, and return the calculation result.

  When the processing requests fetched from the first request queue processing unit 702 and the first replication queue 704 are different, the comparison notification unit 708 selects one of the processing requests as a numbering target by a given method, and returns to the request. Is assigned to the numbering processing unit 706, and the response number is added to the processing request and transmitted to the first calculation server 300. Further, the numbering result is notified to the comparison processing unit 808 of the second synchronization server 800. Furthermore, the processing request that has not been selected is held, and is set as a comparison target in the next comparison notification processing.

  The processing after the notification is received at the second synchronization server is the same, and the processing request that has not been selected is held and used as a comparison target in the next comparison notification processing.

FIG. 3 is a hardware configuration diagram of the synchronization server.
In this embodiment, the client terminal 100 is a computer such as a PC (personal computer), a workstation, a server device, various mobile phone terminals, and a PDA (Personal Digital Assistant).

  The client terminal 100 includes an input device 111, an output device 112, an arithmetic device 113, a main storage device 114, an external storage device 115, a communication device 116, and a bus 117 that connects these devices to each other. .

The input device 111 is a device that accepts input from, for example, a keyboard, mouse, touch pen, or other pointing device.
The output device 112 is a device that performs display, such as a display.

The arithmetic device 113 is an arithmetic device such as a CPU (Central Processing Unit).
The main storage device 114 is a memory device such as a RAM (Random Access Memory).
The external storage device 115 is a nonvolatile storage device such as a hard disk device or a flash memory.
The communication device 116 is a wireless communication device that performs wireless communication via an antenna, or a wired communication device that performs wired communication via a network cable.

The control unit 102 of the client terminal 100 is realized by a program that causes the arithmetic device 113 of the client terminal 100 to perform processing.
This program is stored in the main storage device 114 or the external storage device 115, loaded onto the main storage device 114 for execution, and executed by the arithmetic device 113.

  Although not shown, the request replication server 200, the first calculation server 300, the second calculation server 400, the first queue server 500, the second queue server 600, the first synchronization server 700, and the second synchronization server 800 are also clients. A hardware configuration similar to that of the terminal 100 is provided. However, for the request replication server 200, the first calculation server 300, the second calculation server 400, the first queue server 500, the second queue server 600, the first synchronization server 700, and the second synchronization server 800, the input of the client terminal 100 A device corresponding to the device 111 and the output device 112, that is, a device that does not have a hardware device responsible for an input / output function with a user may be used.

  Further, the request replication unit 202 and the response / discard determination unit 204 of the request replication server 200 are realized by a program that causes the arithmetic device 113 of the request replication server 200 to perform processing.

  This program is stored in the main storage device 114 or the external storage device 115, loaded onto the main storage device 114 for execution, and executed by the arithmetic device 113. The request status data 206 is stored in the main storage device 114 or the external storage device 115.

  The first calculation unit 302 of the first calculation server 300, the second calculation unit 402 of the second calculation server 400, the first queue alignment unit 502 of the first queue server 500, and the second queue alignment unit of the second queue server 600. 602 is realized by a program that causes the arithmetic device 113 of each server to perform processing.

  This program is stored in the main storage device 114 or the external storage device 115, loaded onto the main storage device 114 for execution, and executed by the arithmetic device 113.

  Further, the processing units of the first synchronization server 700 and the processing units of the second synchronization server 800 are the same as described above.

  In the dual system described above, the synchronization server is multiplexed, so that the synchronization server can be prevented from becoming a single point of failure and the availability can be improved.

  In the first embodiment, when the processing requests extracted from the first request queue processing unit 702 and the first replication queue 704 are different, the comparison notification unit 708 needs to select one of the processing requests as a numbering target.

  In this embodiment, an example of synchronization processing in which a priority queue is determined in advance in selection of a processing request in processing in the comparison notification unit in a dual system in which synchronization servers are duplicated will be described.

  FIG. 6 shows an example of queue data handled by the request queue processing unit and the replication queue processing unit. The figure shows an example of the first synchronization server 700.

  In the first request queue 6010, processing requests from the first queue server 500 are stored in the order of processing request A 6011, processing request B 6012, and processing request C 6013 from the top right. In the first replication queue 6020, processing requests from the second queue server 600 are stored in the order of processing request A6021, processing request C6022, and processing request B6023 from the top right side.

  As described above, the processing requests are stored in the second replication queue and the second request queue in the same order as the first request queue 6010 and the first replication queue 6020 shown in FIG. However, the arrival timing of the processing request to each request queue and each replication queue may differ depending on the processing load of the queue server, the network load, and the like.

  FIG. 7 shows another example of queue data handled by the request queue processing unit and the replication queue processing unit. The figure shows an example of the first synchronization server 700.

  In this example, processing requests from the first queue server 500 are stored in the first request queue 6010 in the order of processing request B 6012, processing request C 6013, processing request 6014 from the top right. . In the first replication queue 6020, processing requests from the second queue server 600 are stored in the order of processing request C6022, processing request B6023, and processing request D6024 from the top right side.

  Also in this example, processing requests are stored in the second replication queue and the second request queue in the same order as the first request queue 6010 and the first replication queue 6020 shown in FIG. However, the arrival timing of the processing request to each request queue and each replication queue may differ depending on the processing load of the queue server, the network load, and the like.

  FIG. 4 is a flowchart showing the processing of the comparison notification unit 708 of the first synchronization server in the method of determining the priority queue in advance. The flow of processing performed by the comparison notification unit 708 will be described using the example of the queue data in FIGS. 4, 6, and 7.

  When the process starts, first, the comparison notification unit 708 requests the first request queue processing unit 702 and the first duplication queue processing unit 704 to take out the head data of each queue (step S001).

  The comparison notification unit 708 determines whether or not there is a processing request from the first request queue processing unit 702 serving as a priority queue (step S002). If there is no processing request ("NO" in step S002), the comparison notification unit 708 proceeds to step S003. move on.

  When there is a processing request from the first request queue processing unit 702 (“Yes” in step S002), the processing request held in the processing of the comparison notification unit 708 up to the previous time and the first request queue processing unit 702 If the processing requests are the same, the comparison notification unit 708 discards the held processing request (step S004).

  When the processing request from the first replication queue processing unit 704 is different from the processing request from the first request queue processing unit 702, the comparison notification unit 708 holds the processing request from the first replication queue processing unit 704 (step S005). ).

  In the case of the queue data state as shown in FIG. 7, since the extracted processing request B 6012 and processing request C 6022 are different, the processing request C 6022 is held. In the next processing of the comparison notification unit 708, the processing request C6013 is extracted from the first request queue, and this processing request and the processing request C held here match, so in step S004, the processing request C held is Discarded.

  If the processing request from the first request queue processing unit 702 has not been numbered, the comparison notification unit 708 requests the numbering processing unit 706 for numbering and receives a response (step S006).

  The comparison notification unit 708 adds the number received from the numbering processing unit 706 to the processing request from the first request queue processing unit 702, and transmits it to the first calculation server 300 (step S007).

  Further, the comparison notification unit 708 records the numbering result, notifies the comparison notification unit 808 of the second synchronization server 800 of the numbering result (step S008), and ends the process.

  If “NO” in step S002, it is determined whether the elapsed time from the start of the current process of the comparison notification unit is within a given time (step S003).

  If it is within the given time (“YES” in step S003), the process returns to step S001, and the processing request from the first request queue processing unit 702 is taken out.

  If “NO” in step S003, if the processing request from the first replication queue has not been numbered, the comparison notification unit 708 requests the numbering processing unit 706 for numbering and receives a response (step S009). The process proceeds to step S007.

  According to the processing of the comparison notification unit 708 that previously determines the priority queue in the first synchronization server 700 described above, when a processing request arrives at high speed without stagnation in each queue, it is taken from the processing request from each queue. The processing load for selecting the target is small and a high-speed response is possible.

  In the method according to the second embodiment, when the transmission to the first request queue processing unit 702 serving as the priority queue is constantly slower than the first replication queue processing unit 704 due to a delay due to a lack of network bandwidth or the like, the processing request is processed. Will also be delayed.

  In this embodiment, an example of a synchronization process that selects a processing request based on an arrival time in a queue in a process in the comparison notification unit in a dual system in which synchronization servers are duplicated will be described.

  FIG. 5 is a flowchart showing the processing of the comparison notification unit 708 of the first synchronization server in the method of selecting a processing request based on the arrival time at the queue.

  When the processing starts, first, the comparison notification unit 708 requests the first request queue processing unit 702 and the first duplication queue processing unit 704 to take out the head data of each queue (step S101).

  The comparison notification unit 708 determines whether there are both processing requests from the first request queue processing unit 702 and the first replication queue processing unit 704 (step S102), and when both processing requests are not present (in step S102, “ NO ”), the process proceeds to step S105, and if there are both processing requests (“ YES ”in step S102), the process proceeds to step S103.

  In step S103, the comparison notification unit 708 determines whether both processing requests are the same, and if they are the same ("YES" in step S103), the process proceeds to step S105, and if not, the process proceeds to step S104.

  In step S104, the comparison notification unit 708 compares the arrival times of both processing requests to the first request queue processing unit 702 and the first replication queue processing unit 704, and selects a processing request with an earlier arrival time as a numbering target. And hold the other processing request.

  Subsequently, if the processing request has not been numbered, the comparison notification unit 708 requests the numbering processing unit 706 for numbering and receives a response (step S105).

  The comparison notification unit 708 adds the number received from the numbering processing unit 706 to the processing request, and transmits it to the first calculation server 300 (step S106).

  Further, the comparison notification unit 708 records the numbering result, notifies the comparison notification unit 808 of the second synchronization server 800 of the numbering result (step S107), and ends the process.

  According to the processing of the comparison notification unit 708 that selects the processing request based on the arrival time at the queue in the first synchronization server 700 described above, the irregularity is relatively high in the arrival of the processing request in each queue, Even when processing requests to the queue set as priority are delayed, the numbering processing can be performed when the processing request arrives at one of the queues, and a high-speed response is possible.

  In the first to third embodiments described above, the numbering result of the first synchronization server 700 is notified to the second synchronization server 800 to synchronize both numbering results. For this reason, when a failure occurs in the first synchronization server, the response to the processing request may be delayed.

  In the present embodiment, an example of a synchronization process in which a response to a processing request can be continued even if a failure occurs in the first synchronization server in a dual system in which the synchronization server is duplicated will be described.

  FIG. 8 is a flowchart showing the process of the comparison notification process 808 of the second synchronization server 800 that can continue the process even when the failure of the first synchronization server 700 occurs.

  When the processing starts, the comparison notification processing 808 suspends the continuation processing when the processing requests fetched from the second request queue processing unit 802 and the second replication queue processing unit 804 are different, and the first synchronization server 700 Waiting for notification of the numbering result from the comparison notification unit 708 (step S201).

  The comparison notification unit 808 determines whether there is a notification from the comparison notification unit 708 (step S202), and if not notified (“NO” in step S202), the process proceeds to step S203.

  In step S203, the comparison notification unit 808 determines whether the elapsed time from the start of processing of the comparison notification unit 808 is within a given time, and if within the time (“YES” in step S203), returns to step S202. , Wait for notification.

  If there is a notification in step S202 (“YES” in step S202), the comparison notification unit 808 requests the numbering processing unit 806 to assign a number to the notified processing request for numbering, and sends a number response. Receive (step S204).

  The comparison notification unit 808 holds a processing request that has not been assigned (step S205).

  Further, the comparison notification unit 808 adds the number received from the numbering processing unit 806 to the target processing request and transmits it to the second calculation server 400 (step S206). Then, the numbering result is recorded (step S207), and the process is terminated.

In step S203, when the elapsed time exceeds the given time (“NO” in step S203), the comparison notification unit 808 restarts the first synchronization server 700 and switches the role to the second synchronization server. An instruction is given (step S208).
Furthermore, the comparison notification unit 808 switches the processing method so as to play the role of the comparison notification unit 708 of the first synchronization server 700 (step S209).

  By the processing shown in FIG. 4 or 5, the comparison notification unit 808 selects the numbering processing request, requests the numbering processing unit 806 to receive the numbering, receives a number response (step), and goes to step 205. move on.

  In the migration, the second synchronization server 800 plays the role of the previous first synchronization server and continues the process. After the first synchronization server restarts, the first synchronization server takes the role of the previous second synchronization server. Thus, the duplication of the synchronization server can be continued.

  When a failure occurs in the first synchronization server as described above, the process is continued and synchronized even if a failure occurs in the first synchronization server by the process of switching the roles of the first synchronization server and the second synchronization server. It is possible to recover the dual server configuration.

  In each of the above-described embodiments, the calculation server, the queue server, and the synchronization server are each duplexed. However, the present invention is not limited to this embodiment, and a multiplicity of three or more is provided. It may have a configuration.

  Furthermore, the present invention is not limited to the illustrated application examples, and includes various modifications. For example, the above-described embodiments have been described in detail for easy understanding of the present invention, and are not necessarily limited to those having all the configurations described. Further, a part of the configuration of one embodiment can be replaced with the configuration of another embodiment, and the configuration of another embodiment can be added to the configuration of one embodiment. Further, it is possible to add, delete, and replace other configurations for a part of the configuration of each embodiment.

  Each of the above-described configurations, functions, processing units, processing means, and the like may be realized by hardware by designing a part or all of them with, for example, an integrated circuit. Each of the above-described configurations, functions, and the like may be realized by software by interpreting and executing a program that realizes each function by the processor. Information such as programs, tables, and files for realizing each function is stored in a recording device such as a memory, a hard disk, an SSD (Solid State Drive), or a recording medium such as an IC card, a flash memory (for example, an SD card), or a DVD. Can be put.

DESCRIPTION OF SYMBOLS 1 Information processing apparatus 100 Client terminal 200 Request replication server 300 1st calculation server 400 2nd calculation server 700 1st synchronization server 800 2nd synchronization server

Claims (2)

In a synchronization method in a plurality of calculation servers, each executing a process according to a process request,
Each of the plurality of calculation servers executes processing according to a processing request from a client device,
A synchronization server corresponding to each of the plurality of servers,
The result of the executed process is received from the first queue server connected to the corresponding calculation server and the second queue server connected to the other calculation server ,
Compare the result of the process received from the first queue server and the result of the process received from the second queue server, determine whether synchronization is necessary due to the different processing order, and synchronization process is required In this case, the synchronization in the plurality of calculation servers is characterized in that information indicating that the same identification number is given to another synchronization server that is connected to the second queue server. Method. The synchronization method for a plurality of calculation servers according to claim 1,
The synchronization method in a plurality of calculation servers, wherein the other information processing apparatus executes an arbitration process as to which of the plurality of servers gives priority to a processing result.

Images