COMPUTER-READABLE RECORDING MEDIUM STORING DATA PROCESSING PROGRAM, SERVER APPARATUS, AND DATA PROCESSING METHOD

• US 20100153337A1
• Filed: 08/26/2009
• Published: 06/17/2010
• Est. Priority Date: 12/16/2008
• Status: Active Grant

• Current Assignee: Fujitsu Limited
• Original Assignee: Fujitsu Limited
• Inventors: MURATA, Miho
• Granted Patent: US 8,577,838 B2
• Time in Patent Office: Days
• US Class Current: 707/610
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 9/505 considering the load

Abstract

A computer-readable recording medium storing a data processing program that causes a computer of a group of mutually communicable computers to execute, an acquisition procedure configured, when a processing request for an arbitrary data is inputted, to acquire the number of replicas set in the arbitrary data, a selection procedure configured to select computers, which serve as arrangement destinations of the arbitrary data and are as many as the number of replicas, from the computers of the computer group by using a predetermined algorithm, a transmission procedure of the number of replicas, configured to transmit the number of replicas of the arbitrary data, which number is acquired by the acquisition procedure, to all the computers of the computer group, and a processing request transmission procedure configured to transmit the processing request to each the computers that are selected by the selection procedure and as many as the number of replicas.

Claims

1. A computer-readable recording medium storing a data processing program that causes a computer of a group of mutually communicable computers to execute:

an acquisition procedure configured, when a processing request for an arbitrary data is inputted, to acquire a number of replicas set in the arbitrary data;

a selection procedure configured to select computers, which serve as arrangement destinations of the arbitrary data and are as many as the number of replicas, from the computers of the computer group by using a predetermined algorithm;

a transmission procedure of the number of replicas, configured to transmit the number of replicas of the arbitrary data, the number being acquired by the acquisition procedure, to all the computers of the computer group; and

a processing request transmission procedure configured to transmit the processing request to each of the computers that are selected by the selection procedure and as many as the number of replicas.

2. The computer-readable recording medium according to claim 1, the program further causing the computer to execute:

a setting procedure configured to set a preset value as the number of replicas of the arbitrary data when a new write processing request of the arbitrary data is inputted as the processing request of the arbitrary data,

wherein the selection procedure selects computers, which serve as the arrangement destinations of the arbitrary data and are as many as the number of replicas, from the computers in the computer group by using a predetermined algorithm, when the number of replicas of the arbitrary data is set by the setting procedure,

wherein the transmission procedure of the number of replicas transmits, to the computer group, the number of replicas of the arbitrary data, the number being set by the setting procedure, and

wherein the processing request transmission procedure transmits the new write processing request of the arbitrary data to each of the computers that are selected by the selection procedure and as many as the number of replicas.

3. The computer-readable recording medium according to claim 2, the program further causing the computer to execute:

a decision procedure to decide whether or not the number of replicas is equal to the total number of computers of the computer group when the number of replicas of the arbitrary data is set by the setting procedure,

wherein when it is decided by the decision procedure that the number of replicas is equal to the total number of computers of the computer group, the processing request transmission procedure transmits the new write processing request of the arbitrary data to all the computers of the computer group.

4. The computer-readable recording medium according to claim 3,

wherein the decision procedure decides whether or not the number of replicas is equal to the total number of computers of the computer group when a write processing request for the arbitrary data arranged in any of the computers of the computer group is inputted as the processing request for the arbitrary data,

wherein when it is decided by the decision procedure that the number of replicas is not equal to the total number of computers of the computer group, the selection procedure selects computers, in which the arbitrary data is arranged and which are as many as the number of replicas, from the computers of the computer group by using the predetermined algorithm, and

wherein the processing request transmission procedure transmits the write processing request for the arbitrary data to each of the computers that are selected by the selection procedure and as many as the number of replicas.

5. The computer-readable recording medium according to claim 1, wherein the processing request transmission procedure transmits the reference processing request for the arbitrary data to one of the computers that is selected by the selection procedure and as many as the number of replicas when a reference processing request for the arbitrary data arranged in any of the computers of the computer group is inputted as the processing request for the arbitrary data.

6. The computer-readable recording medium according to claim 2, wherein the processing request transmission procedure transmits the reference processing request for the arbitrary data to one of the computers that is selected by the selection procedure and as many as the number of replicas when a reference processing request for the arbitrary data arranged in any of the computers of the computer group is inputted as the processing request for the arbitrary data.

7. The computer-readable recording medium according to claim 3, wherein the processing request transmission procedure transmits the reference processing request for the arbitrary data to one of the computers that is selected by the selection procedure and as many as the number of replicas when a reference processing request for the arbitrary data arranged in any of the computers of the computer group is inputted as the processing request for the arbitrary data.

8. The computer-readable recording medium according to claim 4, wherein the processing request transmission procedure transmits the reference processing request for the arbitrary data to one of the computers that is selected by the selection procedure and as many as the number of replicas when a reference processing request for the arbitrary data arranged in any of the computers of the computer group is inputted as the processing request for the arbitrary data.

9. The computer-readable recording medium according to claim 1, the program further causing the computer to execute:

an execution procedure to execute processing corresponding to the processing request when a processing request is received from the computer itself or from another computer.

10. The computer-readable recording medium according to claim 2, the program further causing the computer to execute:

an execution procedure to execute processing corresponding to the processing request when a processing request is received from the computer itself or from another computer.

11. The computer-readable recording medium according to claim 3, the program further causing the computer to execute:

an execution procedure to execute processing corresponding to the processing request when a processing request is received from the computer itself or from another computer.

12. The computer-readable recording medium according to claim 4, the program further causing the computer to execute:

an execution procedure to execute processing corresponding to the processing request when a processing request is received from the computer itself or from another computer.

13. The computer-readable recording medium according to claim 9, wherein the execution procedure returns the result of the reference processing executed to the arbitrary data according to the processing request to the computer as the transmission source of the processing request, when a reference processing request for the arbitrary data is received as the processing request.

14. The computer-readable recording medium according to claim 9, the program further causing the computer to execute:

a determination procedure to determine the number of replicas of the arbitrary data by referring to the processing request for the arbitrary data, which processing request is executed by the execution procedure;

wherein when the number of replicas different from the currently set number of replicas is determined by the determination procedure, the transmission procedure of the number of replicas transmits the determined number of replicas to all the computers of the computer group,

wherein, when the determined number of replicas is transmitted by the transmission procedure of the number of replicas, the selection procedure selects the computers, in which the arbitrary data is to be arranged and which are as many as the number of replicas, from the computers of the computer group according to a predetermined algorithm, and

wherein, when the computer itself is selected by the selection procedure as the computer with the arbitrary data to be newly arranged therein, the execution procedure writes the arbitrary data to the computer itself, while when the computer itself is no longer selected by the selection procedure as the computer with the arbitrary data to be newly arranged therein, the execution procedure erases the data.

15. The computer-readable recording medium according to claim 13, the program further causing the computer to execute:

a determination procedure to determine the number of replicas of the arbitrary data by referring to the processing request for the arbitrary data, which processing request is executed by the execution procedure;

wherein, when the number of replicas different from the currently set number of replicas is determined by the determination procedure, the transmission procedure of the number of replicas transmits the determined number of replicas to all the computers of the computer group,

wherein, when the determined number of replicas is transmitted by the transmission procedure of the number of replicas, the selection procedure selects the computers, in which the arbitrary data is to be arranged and which are as many as the number of replicas, from the computers of the computer group according to a predetermined algorithm, and

wherein, when the computer itself is selected by the selection procedure as the computer with the arbitrary data to be newly arranged therein, the execution procedure writes the arbitrary data to the computer itself, while when the computer itself is no longer selected by the selection procedure as the computer with the arbitrary data to be newly arranged therein, the execution procedure erases the data.

16. The computer-readable recording medium according to claim 14, wherein the determination procedure determines the total number of computers of the computer group to be the number of replicas of the arbitrary data, in the case in which an average value of the processing time for the arbitrary data, when the number of replicas is set to the total number of computers of the computer group, is equal to or greater than an average value of the processing time for the arbitrary data which is processed by the number of replicas.

17. The computer-readable recording medium according to claim 15, wherein the determination procedure determines the total number of computers of the computer group to be the number of replicas of the arbitrary data, in the case in which an average value of the processing time for the arbitrary data, when the number of replicas is set to the total number of computers of the computer group, is equal to or greater than an average value of the processing time for the arbitrary data which is processed by the number of replicas.

18. The computer-readable recording medium according to claim 14, wherein the determination procedure determines a settable minimum value to be the number of replicas of the arbitrary data, in the case in which when the number of replicas of the arbitrary data is set to 1, an average value of the processing time for the arbitrary data is less than a predetermined value.

19. A server apparatus that is a computer and constitutes a server apparatus group capable of communicating with each other, the server apparatus comprising:

an acquisition unit configured, when a processing request for an arbitrary data is inputted, to acquire a number of replicas set in the arbitrary data;

a selection unit configured to select server apparatuses, which serve as arrangement destinations of the arbitrary data and are as many as the number of replicas, from the server apparatuses of the server apparatus group by using a predetermined algorithm;

a transmission unit of the number of replicas, configured to transmit the number of replicas of the arbitrary data, the number being acquired by the acquisition unit, to all the server apparatuses of the server apparatus group;

a processing request transmission unit configured to transmit the processing request to each of the server apparatuses that are selected by the selection unit and as many as the number of replicas;

an execution unit configured, when the processing request transmitted from the server apparatus itself or another server apparatus is received, to execute processing corresponding to the processing request; and

a determination unit configured to determine at each arbitrary time the number of replicas of the arbitrary data by referring to the processing request for the arbitrary data, which processing request is executed by the execution unit,

wherein, when the number of replicas different from the currently set number of replicas is determined by the determination unit, the transmission unit of the number of replicas transmits the determined number of replicas to all the server apparatuses of the server apparatus group,

wherein, when the determined number of replicas is transmitted by the transmission unit of the number of replicas, the selection unit newly selects the server apparatuses, in which the arbitrary data is to be arranged and which are as many as the determined number of replicas, from the server apparatuses of the server apparatus group according to a predetermined algorithm,

wherein, when the server apparatus itself is selected by the selection unit as the server apparatus with the arbitrary data to be newly arranged therein, the execution unit performs the writing of the arbitrary data, and

wherein, when the server apparatus itself is no longer selected by the selection unit as the server apparatus with the arbitrary data to be newly arranged therein, the execution unit erases the data.

20. A data processing method of a computer that constitutes a group of computers communicable with each other, the data processing method being configured to execute:

an acquisition procedure configured, when a processing request for an arbitrary data is inputted, to acquire a number of replicas set in the arbitrary data;

a selection procedure configured to select computers, which serve as arrangement destinations of the arbitrary data and are as many as the number of replicas, from the computers of the computer group by using a predetermined algorithm;

a transmission procedure of the number of replicas, configured to transmit the number of replicas of the arbitrary data, the number being acquired by the acquisition procedure, to all the computers of the computer group;

a processing request transmission procedure configured to transmit the processing request to each of the computers which are selected by the selection procedure and as many as the number of replicas;

an execution procedure configured, when the processing request transmitted from the computer itself or another computer is received, to execute processing corresponding to the processing request; and

a determination procedure configured to determine at each arbitrary time the number of replicas of the arbitrary data by referring to the processing request for the arbitrary data, which processing request is executed by the execution procedure,

wherein, when the number of replicas different from the currently set number of replicas is determined by the determination procedure, the transmission procedure of the number of replicas transmits the determined number of replicas to all the computers of the computer group,

wherein, when the determined number of replicas is transmitted by the transmission procedure of the number of replicas, the selection procedure newly selects computers, in which the arbitrary data is to be arranged and which are as many as the determined number of replicas, from the computers of the computer group according to a predetermined algorithm,

wherein, when the computer itself is selected by the selection procedure as the computer with the arbitrary data to be newly arranged therein, the execution procedure performs the writing of the arbitrary data, and

wherein, when the computer itself is no longer selected by the selection procedure as the computer with the arbitrary data to be newly arranged therein, the execution procedure erases the data.