Method, system, and program for distributing application transactions among work servers

• US 20060031242A1
• Filed: 08/03/2004
• Published: 02/09/2006
• Est. Priority Date: 08/03/2004
• Status: Active Grant

• Current Assignee: Twitter Inc (X Holdings Corp.)
• Original Assignee: International Business Machines Corporation
• Inventors: Hsiung, Lawrence Shun-mok, Ostdiek, Luis Javier, Wadia, Noshir Cavas, Ye, Peng, Hall, Harold Hershey Jr.
• Granted Patent: US 7,660,897 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 9/505 considering the load

Abstract

Provided are a method, system, and program for distributing application transactions among work servers. Application transaction rates are determined for a plurality of applications supplying transactions to process. For each application, available partitions in at least one server are assigned to process the application transactions based on partition transaction rates of partitions in the servers. For each application, a determination is made of weights for each server including partitions assigned to the application based on a number of partitions in the server assigned to the application. The determined weights for each application are used to distribute application transactions among the servers including partitions assigned to the application.

Claims

1. A method, comprising:

determining application transaction rates for a plurality of applications supplying transactions to process;

for each application, assigning available partitions in at least one server to process the application transactions based on partition transaction rates of partitions in the servers;

for each application, determining weights for each server including partitions assigned to the application based on a number of partitions in the server assigned to the application; and

using the determined weights for each application to distribute application transactions among the servers including partitions assigned to the application.

2. The method of claim 1, wherein applications are capable of having different application transaction rates and partitions in different servers are capable of having different partition transaction rates for one application.

3. The method of claim 1, wherein assigning available partitions in at least one server to process the application transactions comprises:

selecting all available partitions in one server to assign to the application before assigning partitions in another server.

4. The method of claim 1, wherein assigning available partitions in at least one server to process the application transactions comprises:

assigning available partitions in different servers to the application before assigning all available partitions in one server to the application.

5. The method of claim 1, wherein assigning available partitions in at least one server to process the application transactions further comprises:

selecting available partitions in one at least one server to assign to the application until a total of the partition transaction rates of the assigned partitions is greater than or equal to the application transaction rate.

6. The method of claim 1, wherein the weight for each server comprises the number of partitions in the server assigned to the application.

7. The method of claim 6, wherein using the determined weights for each application to distribute transactions for the application to the servers assigned to the application comprises:

determining an application ratio comprising a ratio of the weights to one another indicating how many transactions of the application are sent to the work servers.

8. The method of claim 1, further comprising:

periodically determining current application transaction rates for the applications after determining the weights for each server;

for each application, assigning additional available partitions in at least one server to process the application transactions in response to determining that the current application transaction rate for the application has increased by a threshold.

9. The method of claim 8, wherein the threshold comprises a first threshold, further comprising:

for each application, removing the assignment of at least one partition in at least one server to process the application transactions in response to determining that the current application transaction rate for the application has decreased by a second threshold.

10. The method of claim 1, further comprising:

receiving indication of a new application generating transactions after determining the weights for each server;

assigning available partitions in at least one server to process the new application transactions based on partition transaction rates of partitions in the servers;

determining weights for each server including partitions assigned to the new application based a number of partitions in the server assigned to the application; and

using the determined weights for the new application to determine a number of transactions for the application to forward to the servers including partitions assigned to the application.

11. The method of claim 1, further comprising:

determining partitions assigned to at least one application to reassign to one application having an application transaction rate that is greater than a total of the partition transaction rates assigned to the application;

removing the assignment of the determined partitions from the at least one application to which they are assigned; and

reassigning the determined partitions to the application.

12. A system in communication with applications and work servers, wherein the system includes circuitry enabled to perform:

determining application transaction rates for the applications supplying transactions to process;

for each application, assigning available partitions in at least one server to process the application transactions based on partition transaction rates of partitions in the servers;

for each application, determining weights for each server including partitions assigned to the application based on a number of partitions in the server assigned to the application; and

using the determined weights for each application to distribute application transactions among the servers including partitions assigned to the application.

13. The system of claim 12, wherein applications are capable of having different application transaction rates and partitions in different servers are capable of having different partition transaction rates for one application.

14. The system of claim 12, wherein assigning available partitions in at least one server to process the application transactions comprises:

selecting all available partitions in one server to assign to the application before assigning partitions in another server.

15. The system of claim 12, wherein assigning available partitions in at least one server to process the application transactions comprises:

assigning available partitions in different servers to the application before assigning all available partitions in one server to the application.

16. The system of claim 12, wherein assigning available partitions in at least one server to process the application transactions further comprises:

selecting available partitions in one at least one server to assign to the application until a total of the partition transaction rates of the assigned partitions is greater than or equal to the application transaction rate.

17. The system of claim 12, wherein the weight for each server comprises the number of partitions in the server assigned to the application.

18. The system of claim 17, wherein using the determined weights for each application to distribute transactions for the application to the servers assigned to the application comprises:

determining an application ratio comprising a ratio of the weights to one another indicating how many transactions of the application are sent to the work servers.

19. The system of claim 12, wherein the circuitry is further enabled to:

periodically determining current application transaction rates for the applications after determining the weights for each server;

for each application, assigning additional available partitions in at least one server to process the application transactions in response to determining that the current application transaction rate for the application has increased by a threshold.

20. The system of claim 19, wherein the threshold comprises a first threshold, wherein the circuitry is further enabled to:

for each application, removing the assignment of at least one partition in at least one server to process the application transactions in response to determining that the current application transaction rate for the application has decreased by a second threshold.

21. The system of claim 12, wherein the circuitry is further enabled to:

receiving indication of a new application generating transactions after determining the weights for each server;

assigning available partitions in at least one server to process the new application transactions based on partition transaction rates of partitions in the servers;

determining weights for each server including partitions assigned to the new application based a number of partitions in the server assigned to the application; and

using the determined weights for the new application to determine a number of transactions for the application to forward to the servers including partitions assigned to the application.

22. The system of claim 12, wherein the circuitry is further enabled to:

determining partitions assigned to at least one application to reassign to one application having an application transaction rate that is greater than a total of the partition transaction rates assigned to the application;

removing the assignment of the determined partitions from the at least one application to which they are assigned; and

reassigning the determined partitions to the application.

23. An article of manufacture in communication with applications and work servers, wherein the article of manufacture is enabled to cause operations to be performed, the operations comprising:

determining application transaction rates for a plurality of applications supplying transactions to process;

for each application, assigning available partitions in at least one server to process the application transactions based on partition transaction rates of partitions in the servers;

for each application, determining weights for each server including partitions assigned to the application based on a number of partitions in the server assigned to the application; and

using the determined weights for each application to distribute application transactions among the servers including partitions assigned to the application.

24. The article of manufacture of claim 23, wherein applications are capable of having different application transaction rates and partitions in different servers are capable of having different partition transaction rates for one application.

25. The article of manufacture of claim 23, wherein assigning available partitions in at least one server to process the application transactions comprises:

selecting all available partitions in one server to assign to the application before assigning partitions in another server.

26. The article of manufacture of claim 23, wherein assigning available partitions in at least one server to process the application transactions comprises:

assigning available partitions in different servers to the application before assigning all available partitions in one server to the application.

27. The article of manufacture of claim 23, wherein assigning available partitions in at least one server to process the application transactions further comprises:

selecting available partitions in one at least one server to assign to the application until a total of the partition transaction rates of the assigned partitions is greater than or equal to the application transaction rate.

28. The article of manufacture of claim 23, wherein the weight for each server comprises the number of partitions in the server assigned to the application.

29. The article of manufacture of claim 28, wherein using the determined weights for each application to distribute transactions for the application to the servers assigned to the application comprises:

determining an application ratio comprising a ratio of the weights to one another indicating how many transactions of the application are sent to the work servers.

30. The article of manufacture of claim 23, wherein the operations further comprise:

periodically determining current application transaction rates for the applications after determining the weights for each server;

for each application, assigning additional available partitions in at least one server to process the application transactions in response to determining that the current application transaction rate for the application has increased by a threshold.

31. The article of manufacture of claim 30, wherein the threshold comprises a first threshold, and wherein the operations further comprise:

for each application, removing the assignment of at least one partition in at least one server to process the application transactions in response to determining that the current application transaction rate for the application has decreased by a second threshold.

32. The article of manufacture of claim 23, wherein the operations further comprise:

receiving indication of a new application generating transactions after determining the weights for each server;

assigning available partitions in at least one server to process the new application transactions based on partition transaction rates of partitions in the servers;

determining weights for each server including partitions assigned to the new application based a number of partitions in the server assigned to the application; and

using the determined weights for the new application to determine a number of transactions for the application to forward to the servers including partitions assigned to the application.

33. The article of manufacture of claim 23, wherein the operations further comprise:

determining partitions assigned to at least one application to reassign to one application having an application transaction rate that is greater than a total of the partition transaction rates assigned to the application;

removing the assignment of the determined partitions from the at least one application to which they are assigned; and

reassigning the determined partitions to the application.