Oracle Service Bus简介

我们正在为电信提供商设计一个新系统，在该系统中，我们研究了用作企业服务总线的Oracle服务总线（OSB）。对我来说，第一个优点是它提供了惊人的工具支持。通过将其捆绑为Oracle SOA套件，Oracle已将其所有企业集成软件堆栈集成为一个有凝聚力的整体。在本文中，重点将放在作为Oracle SOA Suite 11g一部分的Oracle OSB 11g上。新的Oracle SOA Suite 12c已进行了相当多的更改，我们将不在本文中介绍。但是，我喜欢新的Oracle SOA Suite 12c的一个功能是，开发人员可以使用JDeveloper在一个IDE（集成开发环境）中开发BPEL（业务流程执行语言）和OSB代码。

OSB需要了解的几个主要组件如下：

代理服务

顾名思义，代理服务是托管于外部方的服务，充当内部服务的基础。通过使用代理服务，您可以更好地控制内部服务中的更改，因为如果内部服务发生更改，则代理服务可以执行所需的转换。

商业服务

就OSB而言，业务服务代表内部应用程序服务。它可以是WebService，JMS队列/主题，REST服务，FTP服务等等。商业服务将包含调用实际服务的功能。

因此，我们将重点关注本文的场景如下：

我们有一项内部服务，如果用户输入了MSISDN或SIM卡号，它就会返回订户信息，并且根据输入，将提取并返回数据。
必须通过使用代理服务以更有意义的方式向外部用户公开此服务。

示例项目可以在此处下载。

首先，我们创建业务服务，它将作为我们内部服务的基础。在您的OSB项目中，创建以下四个文件夹；

代理
商业
转型
wsdl

然后，我们需要将内部服务WSDL和为此示例创建的代理服务WSDL复制到“ wsdl”文件夹中。

配置业务服务

右键单击“业务”文件夹，然后选择“新建”->“业务服务”。创建业务服务后，将首先为您提供“常规”选项卡。为此，我们执行以下操作；

选择“ WSDL Web服务”，然后单击浏览器。然后选择“浏览”，选择WSDL文件，您将看到两个选项。选择一个以“（端口）结尾的”。

然后转到“传输”选项卡，并将URI更改为http：// localhost：8088 / mockInstalledBaseSubscriberClassificationQueryWSServiceSoapBinding。这是因为我们将使用SOAPUI模拟服务功能进行测试，并且URI代表WSDL表示的服务的SOAPUI模拟服务端点。

可以从此处下载该示例的SOAPUI项目。

这就是我们配置业务服务所需要做的。然后，我们进入代理服务，在该服务上执行所有操作。

配置代理服务

右键单击创建的“ proxy”文件夹，选择“新建”->“代理服务”并提供有效名称。
在“常规”选项卡中，选择“ WSDL Web服务”，然后单击浏览。
现在，在代理服务中，您需要选择我们创建的代理WSDL文件，该文件将向外部客户端公开。

转到“消息流”选项卡。在该选项卡中，首先从右侧的“设计面板”中拖动“路线”元素。
然后，将“路由”元素拖到“路由”元素中。
单击“路由”元素，然后在底部窗格中，进入“属性”选项卡，您将在其中提供此代理服务将访问的业务服务和操作名称。

结果如下：

然后将“替换”动作拖到“请求动作”组件中。

在我们为“替换”操作提供“属性”选项卡上的信息之前，我们需要创建XQuery转换文件，该文件将代理服务请求映射到业务服务请求，然后将业务服务响应映射回代理服务响应。
右键单击“ transformation”文件夹，然后选择“新建”->“ XQuery转换”。输入一个有效的名称。对于请求和响应转换文件都应该这样做。
使用的请求转换文件如下：

(:: pragma bea:global-element-parameter parameter="$fetchSubscriber1" element="ns2:FetchSubscriber" location="../wsdl/SubscriberProxyService.wsdl" ::)
(:: pragma bea:local-element-return type="ns1:InstalledBaseSubscriberClassificationQuery/ns0:InstalledBaseSubscriberClassificationQuery" location="../wsdl/subscriber_classfication.wsdl" ::)declare namespace ns2 = "http://www.example.org/SubscriberProxyService/";
declare namespace ns1 = "http://www.openuri.org/";
declare namespace ns0 = "http://mtnsa.co.za/si/IB/IBSubscriberClassificationQuery";
declare namespace xf = "http://tempuri.org/OSB%20training%201/transformation/subscriberrequest/";declare function xf:subscriberrequest($fetchSubscriber1 as element(ns2:FetchSubscriber))as element() {<ns1:InstalledBaseSubscriberClassificationQuery><ns0:InstalledBaseSubscriberClassificationQuery><ns0:Request>{if (data($fetchSubscriber1/EquipmentType) = "MSISDN") then<ns0:MSISDN>  { (data($fetchSubscriber1/EquipmentValue))}</ns0:MSISDN>else <ns0:SIMCard> { data($fetchSubscriber1/EquipmentValue)}</ns0:SIMCard>}</ns0:Request></ns0:InstalledBaseSubscriberClassificationQuery></ns1:InstalledBaseSubscriberClassificationQuery>
};declare variable $fetchSubscriber1 as element(ns2:FetchSubscriber) external;xf:subscriberrequest($fetchSubscriber1)

如您所见，在这里，我们检查设备类型是否等于“ MSISDN”，然后在业务服务上设置适当的元素。

使用的响应转换文件如下：

(:: pragma bea:global-element-parameter parameter="$installedBaseSubscriberClassificationQueryResponse1" element="ns1:InstalledBaseSubscriberClassificationQueryResponse" location="../wsdl/subscriber_classfication.wsdl" ::)
(:: pragma bea:global-element-return element="ns2:FetchSubscriberResponse" location="../wsdl/SubscriberProxyService.wsdl" ::)declare namespace ns2 = "http://www.example.org/SubscriberProxyService/";
declare namespace ns1 = "http://www.openuri.org/";
declare namespace ns0 = "http://mtnsa.co.za/si/IB/IBSubscriberClassificationQuery";
declare namespace xf = "http://tempuri.org/OSB%20training%201/transformation/subscriberresponse/";declare function xf:subscriberresponse($installedBaseSubscriberClassificationQueryResponse1 as element(ns1:InstalledBaseSubscriberClassificationQueryResponse))as element(ns2:FetchSubscriberResponse) {<ns2:FetchSubscriberResponse><TradeCustomerCode>{ data($installedBaseSubscriberClassificationQueryResponse1/ns0:InstalledBaseSubscriberClassificationQuery/ns0:Response/ns0:Subscriber/@ServiceProviderCode) }</TradeCustomerCode><PackageCode>{ data($installedBaseSubscriberClassificationQueryResponse1/ns0:InstalledBaseSubscriberClassificationQuery/ns0:Response/ns0:Subscriber/ns0:Package/@ProductCode) }</PackageCode><PaymentOption>{ data($installedBaseSubscriberClassificationQueryResponse1/ns0:InstalledBaseSubscriberClassificationQuery/ns0:Response/ns0:Subscriber/@PaymentOption) }</PaymentOption></ns2:FetchSubscriberResponse>
};declare variable $installedBaseSubscriberClassificationQueryResponse1 as element(ns1:InstalledBaseSubscriberClassificationQueryResponse) external;xf:subscriberresponse($installedBaseSubscriberClassificationQueryResponse1)

这是一个简单的转换，其中我们根据需要将响应元素映射到代理响应元素。

现在我们回到代理服务，单击“替换”操作，转到“属性”选项卡。

在“ In Variable”中，输入值“ body”。
单击“表达”链接。转到“ XQuery资源”选项卡，单击“浏览”，然后选择请求转换文件。
在右侧的“可变结构”组件中，展开“ body”元素，然后选择request元素并将其拖放到“ Binding”文本框中，如下所示；

然后选择“确定”，这将带您返回“属性”选项卡。
选择“替换节点内容”单选按钮。最终结果如下所示；

现在，让我们将“替换”动作拖放到“响应动作”组件中。
与之前相同，选择响应转换“ $ body / ins：InstalledBaseSubscriberClassificationQueryResponse”。
现在，您将收到一条错误消息，指出无法识别“ ins”名称空间。
为了解决该问题，请在相同的“属性”选项卡中，选择“名称空间”选项卡，然后单击“添加”。输入前缀“ ins”和URI作为“ http://www.openuri.org/”。