11.6. selective Consumer

图 11.5 “selective Consumer Pattern” 中显示的 选择性消费者 模式描述了将过滤器应用到传入消息的消费者，以便只处理满足特定选择条件的消息。

图 11.5. selective Consumer Pattern

您可以使用以下方法之一在 Apache Camel 中实施选择性消费者模式：

JMS 选择器是涉及 JMS 标头和 JMS 属性的 predicate 表达式。如果选择器评估为 true，则允许 JMS 消息到达消费者，如果选择器评估为 false，则 JMS 消息将被阻止。例如，要使用来自队列的消息，选择ive，仅选择其国家代码属性等于 US 的消息，您可以使用以下 Java DSL 路由：

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

如果选择器字符串( CountryCode='US' )必须是 URL 编码（使用 UTF-8 字符），以避免解析查询选项。本例假定 JMS 属性 CountryCode 是由发件人设置的。有关 JMS 选择器的详情，请参阅 “JMS 选择器”一节。

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

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

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

如果无法在消费者端点上设置选择器，您可以将过滤器处理器插入路由中。例如，您可以定义仅使用 Java DSL 处理具有美国国家代码消息的选择消费者，如下所示：

from("seda:a").filter(header("CountryCode").isEqualTo("US")).process(myProcessor);

相同的路由可以使用 XML 配置来定义，如下所示：

<camelContext id="buildCustomProcessorWithFilter" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="seda:a"/>
    <filter>
      <xpath>$CountryCode = 'US'</xpath>
      <process ref="#myProcessor"/>
    </filter>
  </route>
</camelContext>

有关 Apache Camel 过滤器处理器的详情，请参考 第 8.2 节 “消息过滤器”。