消息路由与处理组件详解

# 消息路由与处理组件详解 ## 1. 固定路由器（Fixed Router） 固定路由器是消息路由器中最简单的形式，它只有一个消息源通道和一个目标通道。通常，我们通过配置连接映射的源和目标来设置固定路由器。不过，如果目标是 JMS 目标，也可以通过 Java 协作或业务流程来明确选择目标。 ### 1.1 示例分析 以下是几个示例情况： - **基于连接映射的预期**：给定如图 6 - 2 所示的连接映射，我们可能期望 Java 协作将消息发布到 JMS 目标（队列）qDummyDestination。 - **实际目标的硬编码**：但检查协作源（如图 6 - 3）会发现，实际的消息目标是 JMS 目标（队列）qNewQueue，这个目标在固定路由器中是硬编码的。 - **另一种硬编码方式**：也可以在发送消息之前显式分配目标队列名称来达到相同效果，如图 6 - 4 所示。 - **业务流程中的显式分配**：如图 6 - 5 所示的连接映射，我们可能再次期望队列 qDummyDestination 是消息的目标，但检查 eInsight 业务流程中嵌入的业务规则（如图 6 - 6），会发现并非如此，这里显式地将 JMS 目标名称分配给 JMS OTD 的目标节点，从而将消息路由到 JMS 目标（队列）qNewJMSDestination。 ### 1.2 命名提示 在上述示例中，JMS 目标名称包含“Dummy”字样，这是给检查连接映射的开发者的一个提示，即实际目标可能不同，并且是在发布到“虚拟”目标的组件中进行配置的。这是一个很好的实践建议，因为 Java CAPS 本身并不强制命名约定。 ### 1.3 固定路由器操作步骤 1. 确定消息源通道和目标通道。 2. 配置连接映射的源和目标。 3. 若目标为 JMS 目标，可通过 Java 协作或业务流程明确选择目标。 4. 可在发送消息前显式分配目标队列名称。 ## 2. 基于内容的路由器（Content - Based Router） 基于内容的路由器会根据消息内容来决定消息的目标。它会检查接收到的消息，并根据内容将其发送到相应的目标。 ### 2.1 简单实现方式 在简单情况下，Java 协作或业务流程会在 switch 或 if - then - else 结构中硬编码一组目标，这些结构会对消息的全部或部分内容进行操作。例如图 6 - 7 展示了一个简单的 Java 协作，用于动态选择 JMS 目标；图 6 - 8 展示了基于 eInsight 业务流程的动态路由器，其中决策门检查消息以确定要遵循的分支，业务规则活动将字符串字面量分配给 JMS 目标的目标属性，然后 JMS.send 活动将消息发送到设置好的目标。 ### 2.2 局限性 这种实现方式存在一定局限性。如果需要增加额外的目标，就必须修改协作或流程，并重新部署包含它的应用程序，以将更改传播到运行时环境。因此，如果目标频繁变化，这种基于内容的路由器实现可能需要较高的维护成本。 ### 2.3 特殊实现方式 在特殊情况下，我们可以使用消息或消息组件作为目标名称的全部或部分，而无需使用条件或硬编码目标名称。例如图 6 - 9 中的 JCD，它将输入消息的前 10 个字符追加到字面量 qDest 上，形成目标名称，然后将消息写入该目标。如果消息的前 10 个字符是 PRIMARY??? 和 SECONDARY?（? 表示空格字符），则生成的目标名称分别为 qDestPRIMARY 和 qDestSECONDARY。使用 Sun SeeBeyond JMS 实现时，它无需提前预配置 JMS 目标，而是在首次引用时创建不存在的 JMS 目标，这样可以实现完全动态的基于内容的路由器。 ### 2.4 消息结构与路由决策 在之前的示例中，使用的是非常简单的文本消息，并从文本中提取一些前导或尾随字符用于条件判断或作为目标名称的一部分。但在实际的消息系统中，消息通常是结构化的，会使用消息中一个或多个字段的内容来进行路由决策或推导目标名称。 ### 2.5 基于内容的路由器操作步骤 1. 使用 Java 协作或业务流程在 switch 或 if - then - else 结构中硬编码一组目标。 2. 决策门检查消息内容，业务规则活动分配目标属性。 3. JMS.send 活动将消息发送到目标。 4. 特殊情况下，使用消息或消息组件生成目标名称。 ## 3. 消息过滤器（Message Filter） 消息过滤器是集成解决方案中的一个组件，用于选择性地处理消息。Java CAPS 提供了两种方式让消息过滤器决定是否处理消息。 ### 3.1 基于 JMS 选择器的静态过滤 如果消息源是 JMS 目标（如队列或主题），可以通过连接映射配置消息过滤器，使其仅接受属性与类似 SQL 的选择表达式匹配的消息。这种方法利用了 JMS 选择器机制，它可以防止不匹配选择表达式的消息被传递到过滤接收器，而不是接收消息后再丢弃不感兴趣的消息。不过，这种机制是静态的，因为选择表达式是通过连接映射配置的，若要更改则需要重新部署企业应用程序。 ### 3.2 基于 Java 协作的动态过滤 Java CAPS 还提供了使用 Java 协作实现动态选择解决方案的方法，这种技术可以在运行时更改选择表达式，从而实现动态路由解决方案。 ### 3.3 消息过滤器操作步骤 #### 静态过滤 1. 确定消息源为 JMS 目标。 2. 通过连接映射配置消息过滤器，设置类似 SQL 的选择表达式。 3. 利用 JMS 选择器机制防止不匹配的消息传递。 #### 动态过滤 1. 使用 Java 协作实现动态选择解决方案。 2. 在运行时更改选择表达式。 ## 4. 接收者列表（Recipient List） 在很多情况下，需要将消息选择性地发送给多个接收者。接收者可以根据消息内容动态确定，也可以根据外部业务规则静态确定。 ### 4.1 与基于内容的路由器的区别 接收者列表处理器与基于内容的路由器类似，但不同的是，基于内容的路由器根据消息内容将消息路由到特定目标，而接收者列表处理器将消息发送给一个或多个指定的接收者。接收者列表可以是静态的（在实现中硬编码），也可以是动态的（从外部维护的源提供），动态方式具有更大的灵活性，因为它允许动态配置接收者列表。 ### 4.2 Java CAPS 中的实现 在 Java CAPS 中，可以使用 JCD 或业务流程来实现接收者列表。以图 6 - 10 为例，Java 协作接收到金额大于 300 美元的费用报告消息后，根据业务规则查找需要批准该费用报告的其他审批人，并将消息副本发送给这些审批人以