8.2. Message Filter

概述
复制链接

消息过滤器 是一个处理器，它根据特定标准消除不必要的消息。在 Apache Camel 中，消息过滤器模式（如图 8.2 “Message Filter Pattern” 所示）由 filter （） Java DSL 命令实现。filter （） 命令使用一个 predicate 参数来控制过滤器。当 predicate 为 true 时，允许传入的消息继续，当 predicate 为 false 时，传入的信息会被阻断。

图 8.2. Message Filter Pattern

Java DSL 示例
复制链接

以下示例演示了如何创建从端点 seda:a、到端点 seda:b 的路由，它会阻止除 foo 标头具有值 bar 之外的所有消息：

RouteBuilder builder = new RouteBuilder() {
    public void configure() {
        from("seda:a").filter(header("foo").isEqualTo("bar")).to("seda:b");
    }
};

RouteBuilder builder = new RouteBuilder() {
    public void configure() {
        from("seda:a").filter(header("foo").isEqualTo("bar")).to("seda:b");
    }
};

Copy to Clipboard

Toggle word wrap

要评估更复杂的过滤器 predicates，您可以调用其中一个支持的脚本语言，如 XPath、XQuery 或 SQL （请参阅第 II 部分 “路由表达式和 predicates 语言”）。以下示例定义了一个路由，它阻止所有消息，除了包含 name 属性等于 basic 的 person 项外的所有消息：

from("direct:start").
        filter().xpath("/person[@name='James']").
        to("mock:result");

from("direct:start").
        filter().xpath("/person[@name='James']").
        to("mock:result");

Copy to Clipboard

Toggle word wrap

XML 配置示例
复制链接

以下示例演示了如何在 XML 中使用 XPath predicate 配置路由（请参阅第 II 部分 “路由表达式和 predicates 语言”）：

<camelContext id="simpleFilterRoute" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="seda:a"/>
    <filter>
      <xpath>$foo = 'bar'</xpath>
      <to uri="seda:b"/>
    </filter>
  </route>
  </camelContext>

<camelContext id="simpleFilterRoute" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="seda:a"/>
    <filter>
      <xpath>$foo = 'bar'</xpath>
      <to uri="seda:b"/>
    </filter>
  </route>
  </camelContext>

Copy to Clipboard

Toggle word wrap

在 </filter> tag 中过滤所需的端点

确保将要过滤的端点放在右 </filter> 标签前（例如 & lt;to uri="seda:b"/> ），否则不会应用过滤器（在 2.8+ 中省略此操作会导致错误）。

使用 Bean 过滤
复制链接

以下是使用 bean 定义过滤器行为的示例：

from("direct:start")
     .filter().method(MyBean.class, "isGoldCustomer").to("mock:result").end()
     .to("mock:end");

public static class MyBean {
    public boolean isGoldCustomer(@Header("level") String level) {
        return level.equals("gold");
    }
}

from("direct:start")
     .filter().method(MyBean.class, "isGoldCustomer").to("mock:result").end()
     .to("mock:end");

public static class MyBean {
    public boolean isGoldCustomer(@Header("level") String level) {
        return level.equals("gold");
    }
}

Copy to Clipboard

Toggle word wrap

使用 stop （）
复制链接

从 Camel 2.0 开始提供

stop 是过滤掉 所有消息的 特殊类型的过滤器。当您需要在其中一个 predicates 中停止进一步处理时，停止在基于内容的路由器中使用。

在以下示例中，我们不希望消息正文中带有单词 Bye 的消息在路由中传播任何进一步。我们使用 .stop （） 在 when （） predicate 中阻止这种情况。

from("direct:start")
    .choice()
        .when(bodyAs(String.class).contains("Hello")).to("mock:hello")
        .when(bodyAs(String.class).contains("Bye")).to("mock:bye").stop()
        .otherwise().to("mock:other")
    .end()
    .to("mock:result");

from("direct:start")
    .choice()
        .when(bodyAs(String.class).contains("Hello")).to("mock:hello")
        .when(bodyAs(String.class).contains("Bye")).to("mock:bye").stop()
        .otherwise().to("mock:other")
    .end()
    .to("mock:result");

Copy to Clipboard

Toggle word wrap

了解是否过滤 Exchange 还是未过滤
复制链接

从 Camel 2.5 开始提供

消息过滤器 EIP 将在 Exchange 中添加属性，如果其被过滤或未显示，则状态。

该属性具有主要 Exchange.FILTER_MATCHED，它具有 CamelFilterMatched 的 String 值。其值是一个布尔值，表示 true 或 false。如果值为 true，则在过滤器块中路由 Exchange。

概述
复制链接

Java DSL 示例
复制链接

XML 配置示例
复制链接

使用 Bean 过滤
复制链接

使用 stop （）
复制链接

了解是否过滤 Exchange 还是未过滤
复制链接

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

8.2. Message Filter

概述复制链接链接已复制到粘贴板!

Java DSL 示例复制链接链接已复制到粘贴板!

XML 配置示例复制链接链接已复制到粘贴板!

使用 Bean 过滤复制链接链接已复制到粘贴板!

使用 stop （）复制链接链接已复制到粘贴板!

了解是否过滤 Exchange 还是未过滤复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

概述
复制链接

Java DSL 示例
复制链接

XML 配置示例
复制链接

使用 Bean 过滤
复制链接

使用 stop （）
复制链接

了解是否过滤 Exchange 还是未过滤
复制链接