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");
}
};
要评估更复杂的过滤器 predicates,您可以调用其中一个支持的脚本语言,如 XPath、XQuery 或 SQL (请参阅 第 II 部分 “路由表达式和 predicates 语言”)。以下示例定义了一个路由,它阻止所有消息,除了包含 name 属性等于 basic 的 person 项外的所有消息:
from("direct:start").
filter().xpath("/person[@name='James']").
to("mock:result");
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>
确保将要过滤的端点放在右 </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");
}
}
使用 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");
了解是否过滤 Exchange 还是未过滤 复制链接链接已复制到粘贴板!
从 Camel 2.5 开始提供
消息过滤器 EIP 将在 Exchange 中添加属性,如果其被过滤或未显示,则状态。
该属性具有主要 Exchange.FILTER_MATCHED,它具有 CamelFilterMatched 的 String 值。其值是一个布尔值,表示 true 或 false。如果值为 true,则在过滤器块中路由 Exchange。