Processing of Service-Oriented Tasks within a Grid Computing Environment

• US 20100077068A1
• Filed: 02/18/2009
• Published: 03/25/2010
• Est. Priority Date: 09/19/2008
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Saha, Rakesh, Patel, Ashwin
• Granted Patent: US 8,037,122 B2
• Time in Patent Office: Days
• US Class Current: 709/223
• CPC Class Codes: G06F 9/5055 considering software capabilities, i.e. software resources associated or available to the machine

Abstract

Embodiments of the present invention enable processing of tasks within a service-oriented architecture (SOA). In embodiments, an echo mediator is a mediator SOA component that acts as a service provider by processing a service request associated with a service requester and returning the result to the service requester. In embodiments, an echo mediator handles a received sequential service request by synchronously processing it. In embodiments, an echo mediator handles a received parallel service request by storing it in a persistent store, and an echo mediator with processing capacity retrieves the stored parallel service request and asynchronously processes it. In embodiments, a group of echo mediators may be distributed among the nodes of a grid, forming an echo mediator grid in which each of the echo mediators interfaces with a common data store deployed within the grid. In embodiments, the grid of echo mediators balances the processing of stored service requests.

Claims

1. A computer program product comprising at least one computer-readable medium storing one or more sequences of instructions, wherein execution of the one or more sequences of instructions by one or more processors causes the one or more processors to handle a plurality of service requests within a service-oriented computing grid environment by performing the steps comprising:

providing a plurality of service-oriented architecture (SOA) components, the plurality of SOA components for distribution among processing nodes within the service-oriented computing grid environment, wherein each SOA component of the plurality of SOA components is of the same type and interfaces with a common persistent store;

receiving a first service request at a first SOA component from the plurality of SOA components, wherein the first service request is associated with a first service requester component;

responsive to the first service request being a parallel service request, the first SOA component storing the first service request in the common persistent store; and

retrieving the stored first service request from the common persistent store by a second SOA component within the plurality of SOA components, wherein the second SOA component processes the retrieved first service request asynchronously and returns a result to the first service requester via a callback.

2. The computer program product of claim 1 wherein the steps further comprise:

responsive to the first service request being a sequential service request, the first SOA component processing the first service request synchronously and returning a result to the first service requester via a reply.

3. The computer program product of claim 1 wherein the first SOA component and the second SOA component are the same SOA component.

4. The computer program product of claim 3 wherein each of the plurality of SOA components is a mediator.

5. The computer program product of claim 4 wherein the first service request is an atomic task.

6. The computer program product of claim 2 wherein a plurality of service requests are received by the plurality of SOA components and processing of the plurality of service requests is load balanced among the plurality of SOA components.

7. The computer program product of claim 6 wherein the second SOA component within the plurality of SOA components retrieves the stored first service request responsive to having capacity to process a service request.

8. The computer program product of claim 2 wherein handling of the first service request is specified in a service request configuration associated with the first service request.

9. A computer program product comprising at least one computer-readable medium storing one or more sequences of instructions, wherein execution of the one or more sequences of instructions by one or more processors causes the one or more processors to provide a mediator service-oriented architecture (SOA) component within a service-oriented computing environment by performing the steps comprising:

providing an echo mediator SOA component; and

responsive to the echo mediator SOA component receiving a service request associated with a service requester, the echo mediator SOA component performs the steps of;

processing the service request without invoking another service to obtain a result; and

returning the result to the service requester associated with the service request.

10. The computer program product of claim 9 wherein the echo mediator SOA component supports both synchronous and asynchronous service requests.

11. The computer program product of claim 10 wherein the service request associated with the service requester is a synchronous service request received from the service requester.

12. The computer program product of claim 10 wherein the service request associated with the service requester is an asynchronous service request received from a persistent store.

13. The computer program product of claim 12 wherein the step of responsive to the echo mediator SOA component receiving a service request associated with a service requester, the echo mediator SOA component performs the steps of:

processing the service request without invoking another service to obtain a result; and

returning the result to the service requester comprises the step of;

responsive to the service request being received from the service requester by the echo mediator SOA component being a sequential service request, processing the service request without invoking another service to obtain the result, and returning the result to the service requester; and

responsive to the service request being received from the service requester by the echo mediator SOA component being a parallel service request, storing the service request in the persistent store.

14. The computer program product of claim 13 wherein the steps further comprise:

responsive to the echo mediator SOA component having capacity to process a service request, receiving from the persistent store a stored service request associated with a service requester.

15. The computer program product of claim 14 further comprising a plurality of echo mediator SOA components that are configured to be deployed among nodes within a grid environment and wherein each echo mediator SOA component interfaces with the persistent store.

16. The computer program product of claim 14 wherein a plurality of service requests are stored in the persistent store, and wherein the echo mediator SOA component performs multi-threaded processing by retrieving at least some of the plurality of service requests.

17. The computer program product of claim 16 wherein a maximum number of service requests from the plurality of service requests to be processed by the echo mediator SOA component is configurable.

18. The computer program product of claim 9 wherein the service request is an atomic service request.

19. A system for handling service requests within a service-oriented computing environment, the system comprising:

a service-oriented architecture (SOA) component comprising;

a request dispatcher, coupled to receive one or more service requests from one or more requesting SOA components, wherein the request dispatcher identifies a type of a received service request and dispatches the received service request based upon the identified type;

at least one asynchronous task dispatcher, coupled to receive a stored service request from a persistent store, wherein the at least one asynchronous task dispatcher dispatches the stored service request for processing to a task processor within the SOA component; and

the task processor, coupled to receive service requests from the request dispatcher and from the at least one asynchronous task dispatcher, wherein a service request received and processed by the task processor to obtain a result and the result is returned to a requesting SOA component associated with the processed service request.

20. The system of claim 19 wherein service requests received by the request dispatcher are atomic tasks.

21. The system of claim 19 wherein the request dispatcher identifies a type of a received service request and dispatches the received service request based upon the identified type by performing the steps comprising:

determining whether a received service request is a sequential service request or a parallel service request; and

responsive to the received service request being a sequential service request, dispatching the received service request to the task processor within the SOA component for processing; and

responsive to the received service request being a parallel service request, dispatching the received service request to the persistent store for storing.

22. The system of claim 21 further comprising a plurality of SOA components that are deployed among nodes within a grid environment and wherein each SOA component is configured to interface with the persistent store.

23. The system of claim 22 wherein each of SOA components of the plurality of SOA components is a mediator.