关于“涂抹”样本

“涂抹”样本使用发布/预订类型的消息传递来传输数据。有关更多信息,请参阅 IBM Integration Bus 文档中的发布/预订

ScribblePublisher 和 ScribbleSubscriber 通过使用 JMS 以 WebSphere MQ 为底层传输层传输发布消息。

“涂抹”样本执行以下操作:

  1. 启动 ScribbleSubscriber 应用程序时,它将预定主题 scribble/coordsscribble/clear
  2. 在 ScribblePublisher 窗口中启动绘图时,ScribblePublisher 将主题 scribble/coords 上的绘图的坐标发布到 ScribblePublish 消息流。
  3. 该消息流检查是否已将消息发布到 scribble/coords 主题上并变换发布消息中的坐标。
  4. ScribbleSubscriber 应用程序接收包含已变换坐标的消息,因为已将其预定到 scribble/coords 主题上的发布。
  5. 当您在 ScribblePublisher 应用程序中单击“清除”时,ScribblePublisher 应用程序将把 scribble/clear 主题上的消息发布到 ScribblePublish 消息流。
  6. 该消息流不变换消息数据,因为该消息未在 scribble/coords 主题上发布。
  7. ScribbleSubscriber 应用程序接收该消息,因为已将其预定到 scribble/clear 主题上的发布。

以下各部分更详细地描述了样本的资源:

消息

“涂抹”样本使用 WebSphere MQ JMS 消息。

所有消息都具有标准的消息模板,其中包含以下部分:

消息流中的 Publication 节点将 WebSphere MQ 消息发布到 ScribbleSubscriber 应用程序。

有关更多信息,请参阅 IBM Integration Bus 文档中的 WebSphere Broker JMS 传输

消息流

下图显示了 ScribblePublish 消息流,该消息流处理“涂抹”样本中的发布消息。

ScribblePublish 消息流的截屏。

下表列出了 ScribblePublish 消息流中使用的节点的类型。

节点类型 节点名
MQInput SCRIBBLE_PUBLICATION
Filter Filter On Topic
Compute Invert Coordinates
Publication Publication

有关 ScribblePublish 消息流中使用的节点的更多信息,请参阅 IBM Integration Bus 文档中的内置节点

ScribblePublish 消息流变换 ScribblePublisher 应用程序发布的坐标,然后将新坐标发布到 ScribbleSubscriber 应用程序。有关更多信息,请参阅 IBM Integration Bus 文档中的消息流概述

ScribblePublish 消息流将执行以下操作:

  1. SCRIBBLE_PUBLICATION 节点从 SCRIBBLE_PUBLICATION 队列中获取发布消息。
  2. 根据主题过滤发布消息:
  3. 变换在 scribble/coords 主题上发布的坐标,从而使这些坐标在 ScribbleSubscriber 应用程序中显示为反向。
  4. 输出该消息。消息流将消息中的坐标发布到 SYSTEM.JMS.ND.SUBSCRIBER.QUEUE 队列中。

ESQL

要在工作台中查看 ScribblePublish 消息流中使用的 ESQL,请在 IBM Integration Toolkit 的“应用程序开发”视图中双击 ScribblePublish.esql,以便在 ESQL 编辑器中将其打开。

Filter On Topic 节点的 ESQL 包含在 ScribblePublish_Filter 模块中,而 Invert Coordinates 节点的 ESQL 包含在 ScribblePublish_Compute 模块中。有关更多信息,请参阅 IBM Integration Bus 文档中的 ESQL 概述

消息传输

ScribblePublisher 和 ScribbleSubscriber 应用程序发布 JMS 消息中的信息。 两个应用程序均使用 WebSphere MQ 传输。

WebSphere MQ 传输

“涂抹”应用程序与下表中显示的 WebSphere MQ 本地队列进行交互。

队列 消息流如何使用队列
SCRIBBLE_PUBLICATION 消息流获取已由 ScribblePublisher 应用程序发布到队列的事件发布。
SYSTEM.JMS.ND.SUBSCRIBER.QUEUE 消息流将发布放到队列上,以供 ScribbleSubscriber 应用程序获取并将其发布到 Integration 节点。

有关 WebSphere MQ 的更多信息,请参阅 WebSphere MQ 产品文档。

返回到样本主页