11.5. Message Dispatcher

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

图 11.4. Message Dispatcher Pattern

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

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

在 Apache Camel 中，您可以通过在 JMS 端点 URI 上设置 选择器 查询选项，在消费者端点上定义 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 属性。

如果要将 JMS 属性添加到 Apache Camel 应用程序内的消息中，您可以通过设置消息标头( 在 In message 或 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 Selectors 和 ActiveMQ Message Properties。

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

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