11.5. Message Dispatcher

消息分配程序 模式（如 图 11.4 “消息 Dispatcher Pattern” ）用于消耗来自某个频道的信息，然后在本地分发它们以执行它，该模式负责处理信息。在 Apache Camel 应用程序中，执行者通常由进程中的端点表示，这些端点用于将消息传送到路由的另一个部分。

图 11.4. 消息 Dispatcher Pattern

您可以使用以下方法之一在 Apache Camel 中实施消息分配模式：

如果您的应用程序消耗来自 JMS 队列的消息，您可以使用 JMS 选择器 实施消息分配模式。JMS 选择器是涉及 JMS 标头和 JMS 属性的 predicate 表达式。如果选择器评估为 true，则允许 JMS 消息访问使用者，如果选择器评估为 false，则 JMS 消息会被阻止。在很多方面，JMS 选择器类似于 第 8.2 节 “Message Filter”，但在 JMS 提供程序中实施过滤具有额外的优点。这意味着，JMS 选择器可以在将消息传输到 Apache Camel 应用程序前阻止消息。这带来了显著的效率优势。

在 Apache Camel 中，您可以通过在 JMS 端点上设置 选择器 查询选项，在消费者端点上定义 JMS 选择器。例如：

from("jms:dispatcher?selector=CountryCode='US'").to("cxf:bean:replica01");
from("jms:dispatcher?selector=CountryCode='IE'").to("cxf:bean:replica02");
from("jms:dispatcher?selector=CountryCode='DE'").to("cxf:bean:replica03");

在选择器字符串中显示的 predicates 是基于 SQL92 条件表达式语法的子集（用于完整详情，请参阅 JMS 规格）。选择器字符串中显示的标识符可以指代 JMS 标头或 JMS 属性。例如，在前面的路由中，发送者会设置名为 CountryCode 的 JMS 属性。

如果要向 Apache Camel 应用中的消息添加 JMS 属性，您可以通过设置消息标头或 Out 消息来完成此操作。在读取或写入 JMS 端点时，Apache Camel 会将 JMS 标头和 JMS 属性映射到其原生邮件标题。

从技术上讲，选择器字符串必须根据 application/x-www-form-url 编码的 MIME 格式进行 URL 编码（请参阅 HTML 规格）。在实践中，&amp;(ampersand)字符可能会造成困难，因为它用于限定 URI 中的每个查询选项。对于可能需要嵌入 & amp; 字符的复杂选择器字符串，您可以使用 java.net.URLEncoder 程序类对字符串进行编码。例如：

from("jms:dispatcher?selector=" + java.net.URLEncoder.encode("CountryCode='US'","UTF-8")).
    to("cxf:bean:replica01");

必须使用 UTF-8 编码的位置。

您还可以在 ActiveMQ 端点上定义 JMS 选择器。例如：

from("activemq:dispatcher?selector=CountryCode='US'").to("cxf:bean:replica01");
from("activemq:dispatcher?selector=CountryCode='IE'").to("cxf:bean:replica02");
from("activemq:dispatcher?selector=CountryCode='DE'").to("cxf:bean:replica03");

如需了解更多详细信息，请参阅 ActiveMQ: JMS Selector 和 ActiveMQ Message Properties。

基于内容的路由器模式和消息分配模式之间的基本区别在于，基于内容的路由器将消息分配给物理独立的目的地（远程端点），以及分配本地的、在同一进程空间中的消息分配消息。在 Apache Camel 中，这两种模式之间的区别由目标端点决定。相同的路由器逻辑同时用于实施基于内容的路由器和消息分配程序。当目标端点为远程端点时，路由会定义一个基于内容的路由器。当目标端点处于进程中时，路由定义了一个消息分配程序。

有关如何使用内容的路由器模式的详情和示例请查看 第 8.1 节 “基于内容的路由器”。