Dynamic service invocation and service adaptation in BPEL SOA process

• US 8,271,609 B2
• Filed: 09/15/2008
• Issued: 09/18/2012
• Est. Priority Date: 09/15/2008
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Addala, Raju, Singh, Alok, Nene, Shrikant, Butt, Zeeshan
• Primary Examiner(s): Follansbee, John
• Assistant Examiner(s): Mejia, Anthony
• Application Number:
  US12/210,657
• Publication Number:
  US 20100070553A1
• Time in Patent Office: 1,464 Days
• Field of Search: 709/200, 709/202, 709/218, 719/315, 706/47
• US Class Current: 709/218
• CPC Class Codes: G06F 2209/5015 Service provider selection
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals

Abstract

Techniques for dynamic service invocation and dynamic service adaptation in the context of a service oriented application. In one set of embodiments, a plurality of mediator services are introduced between the application and a plurality of actual services accessed by the application. The plurality of mediator services are configured to expose a common, abstract operation. At application runtime, the application determines, via a rules engine, a selection of a mediator service, and invokes the abstract operation by sending an invocation message to the selected mediator service. The selected mediator service transforms (i.e., adapts) the message into a format appropriate for invoking an actual operation exposed by an actual service associated with the selected mediator service. The selected mediator service then invokes the actual operation by sending the transformed message to the actual service.

Claims

1. A method for dynamic service invocation and dynamic service adaptation in the context of a service-oriented application of a business process execution language (BPEL), the method comprising:

initiating a plurality of mediator services, wherein each mediator service is associated with an actual service in a plurality of actual services, and wherein the plurality of mediator services are configured to expose a common, abstract operation;

determining, at runtime of the application, a selection of a mediator service in the plurality of mediator services for executing the abstract operation; and

invoking, at runtime of the application, the abstract operation by sending an invocation message to the selected mediator service, wherein the BPEL process is enabled to dynamically invoke any type of operation exposed by any of the plurality of mediator services, regardless of the abstract operation'"'"'s name and message schema, and wherein all transformation logic of the BPEL process is encapsulated in the plurality of mediator services such that when a new service is made available or when an interface of an existing service is changed, only the affected of the plurality of mediator services, rather than the BPEL process, is required to be modified, and wherein, in response to receiving the invocation message, the selected mediator service is configured to;

transform the invocation message into a format appropriate for invoking an actual operation exposed by an actual service associated with the selected mediator service; and

invoke the actual operation by sending the transformed invocation message to the actual service.

2. The method of claim 1, wherein transforming the invocation message comprises mapping a first message schema associated with the abstract operation to a second message schema associated with the actual operation.

3. The method of claim 2, wherein the first and second message schemas are expressed in Extensible Markup Language (XML).

4. The method of claim 2, wherein mapping the first message schema to the second message schema comprises mapping a name element in the first message schema identifying a name of the abstract operation to a name element in the second message schema identifying a name of the actual operation.

5. The method of claim 4, wherein mapping the first message schema to the second message schema further comprises mapping a parameter element in the first message schema identifying a parameter of the abstract operation to a parameter element in the second message schema identifying a parameter of the actual operation.

6. The method of claim 2, wherein transforming the invocation message further comprises transforming data values included in the invocation message into formats expected by the actual operation.

7. The method of claim 1, wherein the selected mediator service is further configured to:

receive, in response to invoking the actual operation, an output message from the actual service;

transform the output message into a format expected by the abstract operation; and

send the transformed output message to the application.

8. The method of claim 7, wherein transforming the output message comprises mapping a first message schema associated with the actual operation to a second message schema associated with the abstract operation.

9. The method of claim 7, wherein transforming the output message further comprises transforming data values included in the output message into formats expected by the abstract operation.

10. The method of claim 1, wherein determining a selection of a mediator service from the plurality of mediator services comprises:

receiving one or more business attributes;

invoking a decision service, wherein the decision service is configured to interoperate with a rules engine to select the mediator service based on the one or more business attributes; and

receiving, from the decision service, information pertaining to the selected mediator service.

11. The method of claim 10, wherein the rules engine is distinct from the service-oriented application, and wherein business rules used by the rules engine can be defined declaratively without any program code.

12. The method of claim 10, wherein the information pertaining to the selected mediator service includes a name and address of the selected mediator service.

13. The method of claim 12, wherein invoking the abstract operation comprises:

instantiating a dynamic partner link for invoking the abstract operation;

instantiating a WS-Addressing EndpointReference variable;

initializing a first field of the WS-Addressing EndpointReference variable to the name of the selected mediator service;

initializing a second field of the WS-Addressing EndpointReference variable to the address of the selected mediator service;

assigning the WS-Addressing EndpointReference variable to the dynamic partner link; and

invoking the abstract operation via the dynamic partner link.

14. The method of claim 1 further comprising:

determining, at runtime of the application, a selection of another mediator service in the plurality of mediator services for executing the abstract operation, wherein said another mediator service is associated with another actual service, and wherein said another actual service exposes another actual operation that is distinct from the actual operation exposed by the actual service; and

invoking, at runtime of the application, the abstract operation by sending another invocation message to said another mediator service, wherein, in response to receiving said another invocation message, said another mediator service is configured to;

transform said another invocation message into a format appropriate for invoking said another actual operation exposed by an said actual service; and

invoke said another actual operation by sending the transformed version of said another invocation message to said another actual service.

15. The method of claim 14, wherein transforming said another invocation message comprises mapping a first message schema associated with the abstract operation to a second message schema associated with said another actual operation.

16. The method of claim 14, wherein transforming said another invocation message further comprises transforming data values included in said another invocation message into formats expected by said another actual operation.

17. The method of claim 1, wherein the plurality of mediator services and the plurality of actual services are web services.

18. A system for performing dynamic service invocation and dynamic service adaptation in the context of a service-oriented application of a business process execution language (BPEL), the system comprising:

one or more first computer systems configured to run a plurality of mediator services, wherein each mediator service is associated with an actual service in a plurality of actual services, and wherein the plurality of mediator services are configured to expose a common, abstract operation; and

a second computer system configured to run the service-oriented application, wherein the application is configured to, at runtime;

determine a selection of a mediator service in the plurality of mediator services for executing the abstract operation; and

invoke the abstract operation by sending an invocation message to the selected mediator service, wherein the BPEL process is enabled to dynamically invoke any type of operation exposed by any of the plurality of mediator services, regardless of the abstract operation'"'"'s name and message schema, and wherein all transformation logic of the BPEL process is encapsulated in the plurality of mediator services such that when a new service is made available or when an interface of an existing service is changed, only the affected of the plurality of mediator services, rather than the BPEL process, is required to be modified, and wherein, in response to receiving the invocation message, the selected mediator service is configured to;

transform the invocation message into a format appropriate for invoking an actual operation exposed by an actual service associated with the selected mediator service; and

invoke the actual operation by sending the transformed invocation message to the actual service.

19. The system of claim 18 further comprising:

a third computer system configured to run a decision service, wherein the decision service is configured to;

receive, from the application, one or more business attributes;

interoperate with a rules engine to select the mediator service based on the one or more business attributes; and

send information pertaining to the selected mediator service to the application.

20. A non-transitory machine-readable medium having stored thereon program code for performing dynamic service invocation and dynamic service adaptation in the context of a service-oriented application of a business process execution language (BPEL), the program code comprising:

code for a plurality of mediator services, wherein each mediator service is associated with an actual service in a plurality of actual services, and wherein the plurality of mediator services are configured to expose a common, abstract operation; and

code for the service-oriented application, wherein the application is configured to, at runtime;

determine a selection of a mediator service in the plurality of mediator services for executing the abstract operation; and

invoke the abstract operation by sending an invocation message to the selected mediator service, wherein the BPEL process is enabled to dynamically invoke any type of operation exposed by any of the plurality of mediator services, regardless of the abstract operation'"'"'s name and message schema, and wherein all transformation logic of the BPEL process is encapsulated in the plurality of mediator services such that when a new service is made available or when an interface of an existing service is changed, only the affected of the plurality of mediator services, rather than the BPEL process, is required to be modified, and wherein, in response to receiving the invocation message, the selected mediator service is configured to;

transform the invocation message into a format appropriate for invoking an actual operation exposed by an actual service associated with the selected mediator service; and

invoke the actual operation by sending the transformed invocation message to the actual service.