关于“CORBA 节点”样本

“CORBA 节点”样本由一个消息流中的多个过程流组成。这些过程流中包括：

• 创建新的库存项，指定产品名称和库存量单位 (SKU) 产品号。 如果 SKU 产品号在范围之外或产品名称已存在，那么将抛出用户定义异常。
• 增加库存数量，指定 SKU 产品号和数量。 如果 SKU 产品号不存在，那么将抛出用户定义异常。
• 获取库存项详细信息，仅指定产品名称。如果产品名称不存在，那么将抛出用户定义异常。
• 减少库存数量，指定 SKU 产品名称和数量。如果 SKU 产品号不存在，或数量过大，那么将抛出用户定义异常。
• 删除库存项，指定 SKU 产品号。如果 SKU 产品号不存在，那么将抛出用户定义异常。

以下概述图显示了 IBM Integration Bus 上的消息流、命名服务和 CORBA 服务器 Java 应用程序之间的关系。

1. 将库存控制管理系统作为 CORBA 服务器 Java 应用程序来进行托管。该服务器应用程序将创建 CORBA 对象，将此对象绑定到引用，并将此对象引用放入命名服务。
2. 进行部署时，CORBARequest 节点将连接命名服务来获取对象引用。 命名服务是 CORBA 服务器应用程序用于放入它们的对象引用的机制。在特定的主机和端口号上启动命名服务。
3. StockWarehouseClient 消息流通过使用对象引用并调用 CORBA 服务器中的对象上的特定操作来驱动对 CORBA 服务器 Java 应用程序的请求。

路由初始消息请求

此过程流由以下节点组成：

• MQInput
• Compute (RouteOperation)
• RouteToLabel

Integration 节点从 WebSphere MQ 队列接收消息请求。

Compute 节点：

1. 通过指定在本地环境中要将正确的标签名称路由到哪个地方来设置消息路由。
2. 将消息复制到本地环境。

创建新的库存项过程

此过程流由以下节点组成：

• Label
• CORBARequest (createNewStockItem)
• Compute (SetPriceOperation)
• CORBARequest (setPrice)
• Compute (createStockItemResponse)
• MQOutput (MQOutput)
• MQOutput (MQError)

Label 节点接收路由的消息请求。CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 createNewStockItem 操作，并返回响应。

Compute 节点将响应数据复制到本地环境，并为下一个 CORBA 请求设置输入参数。下一个 CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 setPrice 操作，并返回响应。

最后的 Compute 节点会将响应数据复制到本地环境，然后将 CORBARequest 节点中所有累计的响应复制到将传播到 WebSphere MQ 队列的消息体。

从 CORBA 服务器 Java 应用程序抛出的用户定义异常将从 CORBARequest 节点的 Error 终端传播到另一个 WebSphere MQ 队列。

增加库存数量过程

此过程流由以下节点组成：

• Label
• CORBARequest (addStock)
• MQOutput (MQOutput1)
• MQOutput (MQError1)

Label 节点接收路由的消息请求。CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 addStock 操作，并返回要传播到 WebSphere MQ 的响应。

从 CORBA 服务器 Java 应用程序抛出的用户定义异常将从 CORBARequest 节点的 Error 终端传播到另一个 WebSphere MQ 队列。

获取库存项详细信息过程

此过程流由以下节点组成：

• Label
• CORBARequest (getSKU)
• Compute (GetPriceOperation)
• CORBARequest (getPrice)
• Compute (GetStockLevelOperation)
• CORBARequest (getStockLevel)
• Compute (getStockItemResponse)
• MQOutput (MQOutput2)
• MQOutput (MQError2)

Label 节点接收路由的消息请求。CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 getSKU 操作，并返回响应。

Compute 节点将响应数据复制到本地环境，并为下一个 CORBA 请求设置输入参数。下一个 CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 getPrice 操作，并返回响应。

另一个 Compute 节点将响应数据复制到本地环境，并为下一个 CORBA 请求设置输入参数。下一个 CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 getStockLevel 操作，并返回响应。

最后的 Compute 节点会将响应数据复制到本地环境，然后将 CORBARequest 节点中所有累计的响应复制到将传播到 WebSphere MQ 队列的消息体。

从 CORBA 服务器 Java 应用程序抛出的用户定义异常将从 CORBARequest 节点的 Error 终端传播到另一个 WebSphere MQ 队列。

减少库存数量过程

此过程流由以下节点组成：

• Label
• CORBARequest (reduceStock)
• MQOutput (MQOutput3)
• MQOutput (MQError3)

Label 节点接收路由的消息请求。CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 reduceStock 操作，并返回要传播到 WebSphere MQ 的响应。

从 CORBA 服务器 Java 应用程序抛出的用户定义异常将从 CORBARequest 节点的 Error 终端传播到另一个 WebSphere MQ 队列。

删除库存项过程

此过程流由以下节点组成：

• Label
• CORBARequest (deleteStockItem)
• MQOutput (MQOutput4)
• MQOutput (MQError4)

Label 节点接收路由的消息请求。CORBARequest 节点调用了要解析输入参数的 CORBA 服务器应用程序的 deleteStockItem 操作，并返回要传播到 WebSphere MQ 的响应。

从 CORBA 服务器 Java 应用程序抛出的用户定义异常将从 CORBARequest 节点的 Error 终端传播到另一个 WebSphere MQ 队列。

返回到样本主页