System and Method for Processing Information Via Networked Computers Including Request Handlers, Process Handlers, and Task Handlers

• US 20120246216A1
• Filed: 06/08/2012
• Published: 09/27/2012
• Est. Priority Date: 09/07/2002
• Status: Active Grant

• Current Assignee: Appistry Incorporated
• Original Assignee: Appistry Incorporated
• Inventors: Hinni, Aaron Louis, Semones, Guerry Anderson, Groner, Michael Scott, Lozano, Roberto Raul
• Granted Patent: US 8,341,209 B2
• Time in Patent Office: Days
• US Class Current: 709/202
• CPC Class Codes: H04L 41/00 Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
• CPC Class Codes: H04L 41/046 comprising network management agents or mobile agents therefor
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/51 Discovery or management thereof, e.g. service location protocol [SLP] or web services
• CPC Class Codes: H04L 69/16 Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
• CPC Class Codes: H04L 69/163 In-band adaptation of TCP data exchange; In-band control procedures

Abstract

Systems and methods for processing information via networked computers leverage request handlers, process handlers, and task handlers to provide efficient distributed processing of processing jobs, the processing jobs comprising a process flow, each process flow including (1) a plurality of processing tasks to be performed by task handlers and (2) state information associated with the processing tasks.

Claims

1. A system for processing information, the system comprising:

a plurality of networked computers for processing a processing job in a distributed manner, the plurality of networked computers comprising a request handler, a plurality of process handlers, and a plurality of task handlers, the processing job comprising a process flow, the process flow including (1) a plurality of processing tasks and (2) state information associated with the processing tasks;

the request handler configured to (1) receive a service request for the processing job, (2) select a process handler from among the process handlers for servicing the processing job, and (3) communicate data representative of the processing job to the selected process handler;

the selected process handler configured to (1) receive the communicated data, (2) analyze the state information for the processing job, (3) based on the analyzed state information, determine whether (i) there is a next processing task in the processing flow to be performed or (ii) the processing job has been completed, (4) in response to a determination that there is a next processing task within the processing flow to be performed, identify the processing task to be performed as the next processing task, (5) repeat the state information analysis operation, the determination operation based on the analyzed state information, and the identification operation until a determination is made based on the analyzed state information that the processing job has been completed, and (6) in response to a determination that the processing job has been completed, communicate a processing result for the processing job to the request handler; and

at least one of the task handlers configured to (1) receive an identified processing task, and (2) perform the received processing task to generate a task result, the task result including updated state information for the processing job.

2. The system of claim 1 wherein the plurality of networked computers are grouped into a plurality of territories such that each territory comprises at least one of the process handlers and a plurality of the task handlers, wherein each selected process handler is further configured to select a task handler from among a plurality of the task handlers for performing the identified processing task based on territory considerations.

3. The system of claim 2 wherein the plurality of networked computers further comprise a plurality of the request handlers, wherein each territory further comprises at least one of the request handlers, and a plurality of the process handlers.

4. The system of claim 3 wherein each request handler is configured to select a process handler for servicing a processing job based on territory considerations.

5. The system of claim 4 wherein a plurality of the networked computers have an associated physical location, and wherein the plurality of the networked computers having an associated physical location are grouped into the territories based on their associated physical locations such that each territory comprises a plurality of networked computers having an associated physical location within that territory.

6. The system of claim 5 wherein each request handler is further configured to select a process handler within its own territory for servicing a processing job, and wherein each selected process handler is configured to select a task handler within its own territory for performing an identified processing task.

7. The system of claim 4 wherein a plurality of the networked computers have an associated quality, and wherein the plurality of the networked computers having an associated quality are grouped into the territories based on their associated qualities.

8. The system of claim 2 wherein the request handler is further configured to receive the service request for the processing job from a client computer, and wherein the territory within which the selected process handler resides comprises a territory corresponding to a selection received from the client computer.

9. The system of claim 1 wherein the request handler is further configured to (1) receive the service request for the processing job from a client computer, and (2) communicate the processing result for the processing job to the client computer.

10. The system of claim 9 further comprising the client computer, the client computer in communication via a network with the networked computer on which the request handler is resident.

11. The system of claim 1 wherein the request handler is resident on a first of the networked computers, wherein at least one of the process handlers is resident on a second of the networked computers, and wherein at least one of the task handlers is resident on a third of the networked computers.

12. The system of claim 1 wherein the request handler and at least one of the process handlers are resident on the same one of the networked computers.

13. The system of claim 1 wherein the request handler is resident on a different one of the networked computers than the networked computers on which the process handlers and task handlers are resident.

14. The system of claim 13 wherein the process handlers are resident on different ones of the networked computers than the networked computers on which the task handlers are resident.

15. The system of claim 1 wherein at least one of the process handlers and at least one of the task handlers are resident on the same one of the networked computers, the at least one task handler being on a different thread of the network computer than the at least one process handler.

16. The system of claim 1 wherein the request handler is further configured to (1) send a processing request to a plurality of the process handlers, (2) receive a plurality of processing request responses from a plurality of the process handlers, and (3) select the process handler for servicing the processing job based on the received processing request responses.

17. The system of claim 16 wherein the request handler is further configured to send the processing request to a multicast address associated with a plurality of the process handlers.

18. The system of claim 1 wherein the selected process handler is further configured to select a task handler from among the task handlers for performing the identified processing task, each selected task handler further configured to (1) receive the identified processing task selected for it, and (2) perform the received processing task to generate the task result.

19. The system of claim 18 wherein the selected process handler is further configured to (1) send a task request to a plurality of the task handlers, (2) receive a plurality of task request responses from a plurality of the task handlers, and (3) select the task handler for performing the identified processing task based on the received task request responses.

20. The system of claim 19 wherein the selected process handler is further configured to send the task request to a multicast address associated with a plurality of the task handlers.

21. The system of claim 18 wherein the selected process handler is further configured to communicate the identified processing task to the selected task handler.

22. The system of claim 18 wherein each selected task handler is further configured to communicate the generated task result to the selected process handler.

23. The system of claim 1 wherein the request handler, the selected process handlers, and each of the at least one task handlers are configured to process the processing job according to a process definition file corresponding to the processing job, the process definition file being configured to define the process flow for the processing job, the process flow comprising the plurality of processing tasks, a plurality of state variables before and after each processing task for storing the state information, and a definition of a sequence for the processing tasks.

24. The system of claim 23 wherein the process definition file further comprises a recovery procedure for a plurality of the processing tasks.

25. The system of claim 23 wherein the process definition file comprises an XML process definition file.

26. A method for processing information via a plurality of networked computers, the plurality of networked computers comprising a request handler, a plurality of process handlers, and a plurality of task handlers, the method comprising:

receiving a service request for the processing job, the processing job comprising a process flow, the process flow including (1) a plurality of processing tasks and (2) state information associated with the processing tasks;

selecting a process handler from among the process handlers for servicing the processing job;

communicating data representative of the processing job to the selected process handler;

the selected process handler (1) receiving the communicated data, (2) analyzing the state information for the processing job, (3) based on the analyzed state information, determining whether (i) there is a next processing task in the processing flow to be performed or (ii) the processing job has been completed, (4) in response to a determination that there is a next processing task within the processing flow to be performed, identifying the processing task to be performed as the next processing task, (5) repeating the analyzing step, the determining step based on the analyzed state information, and the identifying step until a determination is made based on the analyzed state information that the processing job has been completed, and (6) in response to a determination that the processing job has been completed, communicating a processing result for the processing job to the request handler; and

at least one of the task handlers (1) receiving the identified processing task, and (2) performing the received processing task to generate a task result, the task result including updated state information for the processing job; and

wherein the method steps are performed by the networked computers.

27. The method of claim 26 wherein the plurality of networked computers are grouped into a plurality of territories such that each territory comprises at least one of the process handlers and a plurality of the task handlers, and the method further comprising the selected process handler selecting a task handler from among a plurality of the task handlers for performing the identified processing task based on territory considerations.

28. The method of claim 27 wherein the plurality of networked computers further comprise a plurality of the request handlers, wherein each territory further comprises at least one of the request handlers, and a plurality of the process handlers.

29. The method of claim 28 wherein the process handler selecting step comprises a request handler selecting a process handler for servicing a processing job based on territory considerations.

30. The method of claim 29 wherein a plurality of the networked computers have an associated physical location, the method further comprising grouping the plurality of the networked computers having an associated physical location into the territories based on their associated physical locations such that each territory comprises a plurality of networked computers having an associated physical location within that territory.

31. The method of claim 30 wherein the process handler selecting step further comprises a request handler selecting a process handler within its own territory for servicing a processing job, and wherein the task handler selecting step comprises a selected process handler selecting a task handler within its own territory for performing an identified processing task.

32. The method of claim 29 wherein a plurality of the networked computers have an associated quality, the method further comprising grouping the plurality of the networked computers having an associated quality into the territories based on their associated qualities.

33. The method of claim 27 wherein the service request receiving step comprises the request handler receiving the service request for the processing job from a client computer, and wherein the territory within which the selected process handler resides comprises a territory corresponding to a selection received from the client computer.

34. The method of claim 26 wherein the service request receiving step comprises the request handler receiving the service request for the processing job from a client computer, and the method further comprising the request handler communicating the processing result for the processing job to the client computer.

35. The method of claim 26 wherein the request handler is resident on a first of the networked computers, wherein at least one of the process handlers is resident on a second of the networked computers, and wherein at least one of the task handlers is resident on a third of the networked computers.

36. The method of claim 26 wherein the request handler and at least one of the process handlers are resident on the same one of the networked computers.

37. The method of claim 26 wherein the request handler is resident on a different one of the networked computers than the networked computers on which the process handlers and task handlers are resident.

38. The method of claim 37 wherein the process handlers are resident on different ones of the networked computers than the networked computers on which the task handlers are resident.

39. The method of claim 26 wherein at least one of the process handlers and at least one of the task handlers are resident on the same one of the networked computers, the at least one task handler running on a different thread of the network computer than the at least one process handler.

40. The method of claim 26 further comprising the request handler (1) sending a processing request to a plurality of the process handlers, and (2) receiving a plurality of processing request responses from a plurality of the process handlers, and wherein the process handler selecting step comprises the request handler selecting the process handler for servicing the processing job based on the received processing request responses.

41. The method of claim 40 wherein the sending step comprises the request handler sending the processing request to a multicast address associated with a plurality of the process handlers.

42. The method of claim 26 further comprising the selected process handler selecting a task handler from among the task handlers for performing the identified processing task, each selected task handler (1) receiving the identified processing task selected for it, and (2) performing the received processing task to generate the task result.

43. The method of claim 42 further comprising the selected process handler (1) sending a task request to a plurality of the task handlers, and (2) receiving a plurality of task request responses from a plurality of the task handlers, and wherein the task handler selecting step comprises the selected process handler selecting the task handler for performing the identified processing task based on the received task request responses.

44. The method of claim 43 wherein the sending step comprises the selected process handler sending the task request to a multicast address associated with a plurality of the task handlers.

45. The method of claim 42 further comprising the selected process handler communicating the identified processing task to the selected task handler.

46. The method of claim 42 further comprising each selected task handler communicating the generated task result to the selected process handler.

47. The method of claim 26 wherein the request handler, the selected process handlers, and each of the at least one task handlers process the processing job according to a process definition file corresponding to the processing job, the process definition file defining the process flow for the processing job, the process flow comprising the plurality of processing tasks, a plurality of state variables before and after each processing task for storing the state information, and a definition of a sequence for the processing tasks.

48. The method of claim 47 wherein the process definition file further comprises a recovery procedure for a plurality of the processing tasks.

49. The method of claim 47 wherein the process definition file comprises an XML process definition file.

50. A method for processing information via a plurality of networked computers, the plurality of networked computers comprising a request handler, a plurality of process handlers, and a plurality of task handlers, the method comprising:

the request handler receiving a service request for the processing job, the processing job comprising a process flow, the process flow including (1) a plurality of processing tasks and (2) state information associated with the processing tasks;

selecting a process handler from among the process handlers for servicing the processing job;

communicating data representative of the processing job to the selected process handler;

the selected process handler (1) receiving the communicated data, (2) analyzing the state information for the processing job, and (3) based on the analyzed state information, identifying the processing task to be performed;

selecting a task handler from among a plurality of the task handlers for performing the identified processing task;

the selected task handler (1) receiving the identified processing task, and (2) performing the received processing task to generate a task result, the task result including updated state information for the processing job;

the selected process handler further (1) analyzing the updated state information for the processing job, (2) based on the analyzed updated state information, determining whether (i) there is a next processing task in the processing flow to be performed or (ii) the processing job has been completed, and (3) in response to a determination that there is a next processing task within the processing flow to be performed, repeating the identifying step to identify a next processing task to be performed, and (4) in response to a determination that the processing job has been completed, communicating a processing result for the processing job to the request handler; and

wherein the method steps are performed by the networked computers.

51. The method of claim 50 wherein the plurality of networked computers are grouped into a plurality of territories such that each territory comprises at least one of the process handlers and a plurality of the task handlers, and wherein the networked computers that perform the method steps reside in the same territory.

52. The method of claim 51 wherein a plurality of the networked computers have an associated physical location, the method further comprising grouping the plurality of the networked computers having an associated physical location into the territories based on their associated physical locations such that each territory comprises a plurality of networked computers having an associated physical location within that territory.