Computer-readable recording medium storing data processing program, server apparatus, and data processing method

• US 8,577,838 B2
• Filed: 08/26/2009
• Issued: 11/05/2013
• Est. Priority Date: 12/16/2008
• Status: Active Grant

• Current Assignee: Fujitsu Limited
• Original Assignee: Fujitsu Limited
• Inventors: Murata, Miho
• Primary Examiner(s): Pulliam, Christyann
• Assistant Examiner(s): Khoshnoodi, Fariborz
• Application Number:
  US12/547,805
• Publication Number:
  US 20100153337A1
• Time in Patent Office: 1,532 Days
• Field of Search: 707/609, 707/610
• 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 non-transitory computer-readable recording medium storing a data processing program that causes a computer of a group of computers, which are configured to communicate with each other, to execute:

a setting procedure configured, when a new write processing request for an arbitrary object data is inputted as a processing request, to set a preset value as a first number indicating a number of replicas of the arbitrary object data;

an acquisition procedure configured, when a processing request for the arbitrary object data is inputted, to acquire the first number that has been set for the arbitrary object data;

a selection procedure configured to select one or more computers that serve as arrangement destinations of the arbitrary object data and are as many as the first number, from the group of computers by using a predetermined algorithm that is performed based on the first number;

a number transmission procedure configured to transmit the first number to all the group of computers; and

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

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

a decision procedure to decide whether the first number is equal to a second number indicating the total number of the group of computers when the first number is set by the setting procedure,

wherein when the decision procedure decides that the first number is equal to the second number, the processing request transmission procedure transmits the new write processing request of the arbitrary object data to all the group of computers.

3. The non-transitory computer-readable recording medium according to claim 2,

wherein the decision procedure decides whether the first number is equal to the second number when a write processing request for the arbitrary object data arranged in any one of the group of computers is inputted as the processing request for the arbitrary object data,

wherein when the decision procedure decides that the first number is not equal to the second number, the selection procedure selects computers, in which the arbitrary object data is arranged and which are as many as the first number, from the group of computers by using the predetermined algorithm, and

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

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

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

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

7. The non-transitory 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 the processing request is inputted by the computer or received from another computer.

8. The non-transitory 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 the processing request is inputted by the computer or received from another computer.

9. The non-transitory 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 the processing request is inputted by the computer or received from another computer.

10. The non-transitory computer-readable recording medium according to claim 7, wherein, when a reference processing request for the arbitrary object data is received as the processing request, the execution procedure returns the result of the reference processing that was executed for the arbitrary object data according to the processing request, to a source computer that is a transmission source of the processing request.

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

a determination procedure to determine the first number for the arbitrary object data by referring to the processing request on which the processing has been executed by the execution procedure;

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

wherein the selection procedure, upon receiving the determined first number transmitted by the number transmission procedure, selects the one or more computers, in which the arbitrary object data is arranged and which are as many as the first number, from the group of computers, according to the predetermined algorithm that is performed based on the first number, and

wherein the execution procedure, when the computer is selected by the selection procedure as the computer in which the arbitrary object data is newly arranged, writes the arbitrary object data to the computer, while when the computer is no longer selected by the selection procedure as the computer in which the arbitrary object data is newly arranged, the execution procedure erases the data.

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

a determination procedure to determine the first number for the arbitrary object data by referring to the processing request on which the processing has been executed by the execution procedure;

wherein the number transmission procedure, when the currently set number of replicas is determined as the first number by the determination procedure, transmits the determined first number all the group of computers,

wherein the selection procedure, upon receiving the determined first number transmitted by the number transmission procedure, selects the one or more computers, in which the arbitrary object data is arranged and which are as many as the first number, from the group of computers, according to the predetermined algorithm that is performed based on the first number, and

wherein the execution procedure, when the computer is selected by the selection procedure as the computer in which the arbitrary object data is newly arranged, writes the arbitrary object data to the computer, while when the computer is no longer selected by the selection procedure as the computer in which the arbitrary object data is newly arranged, the execution procedure erases the data.

13. The non-transitory computer-readable recording medium according to claim 11, wherein the determination procedure determines the second number as the first number for the arbitrary object data, in the case in which an average value of the processing time for the arbitrary object data, when the first number is set at a value of the second number, is equal to or greater than a predetermined value.

14. The non-transitory computer-readable recording medium according to claim 12, wherein the determination procedure determines the second number as the first number for the arbitrary object data, in the case in which an average value of the processing time for the arbitrary object data, when the first number is set at a value of the second number, is equal to or greater than a predetermined value.

15. The non-transitory computer-readable recording medium according to claim 11, wherein the determination procedure determines a settable minimum value as the first number for the arbitrary object data, in the case in which when the first number for the arbitrary object data is set at a value of 1, an average value of the processing time for the arbitrary object data is less than a predetermined value.

16. A server apparatus that is a computer and constitutes a server apparatus group configured to communicate 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, wherein the number is 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 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.

17. A data processing method of a computer that constitutes a group of computers communicable with each other, wherein the data processing method is 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, wherein the number is 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.

18. A server apparatus that is a computer and constitutes a server apparatus group configured to communicate with each other, the server apparatus comprising:

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

a selection unit configured to select one or more server apparatuses that serve as arrangement destinations of the arbitrary object data and are as many as the first number, from the server apparatus group by using a predetermined algorithm that is performed based on the first number;

a number transmission unit configured to transmit the acquired first number for the arbitrary object data to all the selected one or more server apparatuses of the server apparatus group;

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

an execution unit configured, upon receiving the processing request that is inputted by the server apparatus or transmitted from another server apparatus, to execute processing corresponding to the processing request; and

a determination unit configured to determine at each arbitrary time the first number for the arbitrary object data by referring to the processing request on which the processing was executed by the execution unit for the arbitrary object data,

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

wherein the selection unit, upon receiving the determined first number transmitted by the number transmission unit, newly selects the one or more server apparatuses, in which the arbitrary object data is arranged and which are as many as the determined first number, from the server apparatus group, according to the predetermined algorithm that is performed based on the first number,

wherein, when the server apparatus is selected by the selection unit as the server apparatus in which the arbitrary object data is newly arranged, the execution unit performs writing of the arbitrary object data, and

wherein, when the server apparatus is no longer selected by the selection unit as the server apparatus in which the arbitrary object data is newly arranged, the execution unit erases the arbitrary object data.

19. A data processing method of a computer that constitutes a group of computers that are configured to communicate with each other, the data processing method executing:

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

a selection procedure configured to select one or more computers that serve as arrangement destinations of the arbitrary object data and are as many as the first number, from the group of computers by using a predetermined algorithm that is performed based on the first number;

a number transmission procedure, configured to transmit the first number of the arbitrary object data to all the one or more computers;

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

an execution procedure configured, when the processing request transmitted from the computer 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 first number for the arbitrary object data by referring to the processing request on which the processing has been executed by the execution unit for the arbitrary object data,

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

wherein, upon receiving the determined first number transmitted by the number transmission procedure, the selection procedure newly selects the one or more computers, in which the arbitrary object data is arranged and which are as many as the determined first number, from the group of computers according to a predetermined algorithm that is performed based on the first number,

wherein, when the computer is selected by the selection procedure as the computer in which the arbitrary object data is newly arranged, the execution procedure performs writing of the arbitrary object data, and

wherein, when the computer is no longer selected by the selection procedure as the computer in which the arbitrary object data is newly arranged, the execution procedure erases the arbitrary object data.