5.5. Message Router
概述
图 5.7 “Message Router Pattern” 中 显示的消息路由器 是根据特定决策条件消耗来自单一消费者端点的消息的过滤器类型。邮件路由器仅关注重定向消息,它不会修改消息内容。
但是,默认情况下,当 Camel 将消息交换路由到接收者端点时,它发送是原始交换对象的相对副本。在虚构副本中,原始交换的元素(如消息正文、标头和附件)仅由引用进行复制。通过发送能够复制资源,Camel 可以优化性能。但是,由于这些应该副本都是链接的,因此当 Camel 将消息路由到多个端点时,折衷是,您失去应用自定义逻辑来将自定义逻辑复制到路由到不同接收方的功能。有关如何启用 Camel 将唯一消息版本路由到不同端点的信息,请参阅 "应用自定义处理到传出消息"。
图 5.7. Message Router Pattern
可以使用 choice()
处理器在 Apache Camel 中轻松实施消息路由器,其中每个替代目标端点都可以使用 when()
子clause(有关所选处理器的详细信息,请参阅 第 1.5 节 “处理器”)。
Java DSL 示例
以下 Java DSL 示例演示了如何根据 foo
标头的内容将消息路由到三个替代目的地( seda:a
、
、seda:b ):
seda:
b
from("seda:a").choice() .when(header("foo").isEqualTo("bar")).to("seda:b") .when(header("foo").isEqualTo("cheese")).to("seda:c") .otherwise().to("seda:d");
XML 配置示例
以下示例演示了如何在 XML 中配置相同的路由:
<camelContext id="buildSimpleRouteWithChoice" xmlns="http://camel.apache.org/schema/spring"> <route> <from uri="seda:a"/> <choice> <when> <xpath>$foo = 'bar'</xpath> <to uri="seda:b"/> </when> <when> <xpath>$foo = 'cheese'</xpath> <to uri="seda:c"/> </when> <otherwise> <to uri="seda:d"/> </otherwise> </choice> </route> </camelContext>
无其他选择
如果您使用没有 otherwise()
子句的 choice()
,则默认丢弃任何不匹配的交换。