8.18. 动态路由器

动态路由器 模式（如 图 8.12 “动态路由器模式” 所示）可让您连续通过一系列处理步骤（在设计时不了解步骤序列）来连续路由消息。在运行时动态计算消息应通过的端点列表。每次消息从端点返回时，对 bean 的动态路由器调用重新发现路由中的下一端点。

图 8.12. 动态路由器模式

在 Camel 2.5 中，我们引入了 DSL 中的 动态Router，它类似于一个动态 第 8.7 节 “路由 Slip”，它评估 slip on-fly。

从 Camel 2.5，第 8.18 节 “动态路由器” 更新交换属性 Exchange.SLIP_ENDPOINT，当前的端点通过 slip 推进。这可让您了解通过 slip 的交换过程。（它是一个 slip，因为 第 8.18 节 “动态路由器” 的实现基于 第 8.7 节 “路由 Slip”。

在 Java DSL 中，您可以使用 dynamicRouter，如下所示：

from("direct:start")
    // use a bean as the dynamic router
    .dynamicRouter(bean(DynamicRouterTest.class, "slip"));

这将利用 bean 集成计算 slip on-fly，它可按照如下所示实现：

// Java
/**
 * Use this method to compute dynamic where we should route next.
 *
 * @param body the message body
 * @return endpoints to go, or <tt>null</tt> to indicate the end
 */
public String slip(String body) {
    bodies.add(body);
    invoked++;

    if (invoked == 1) {
        return "mock:a";
    } else if (invoked == 2) {
        return "mock:b,mock:c";
    } else if (invoked == 3) {
        return "direct:foo";
    } else if (invoked == 4) {
        return "mock:result";
    }

    // no more so return null
    return null;
    }

Spring XML 中的相同示例如下：

<bean id="mySlip" class="org.apache.camel.processor.DynamicRouterTest"/>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="direct:start"/>
        <dynamicRouter>
            <!-- use a method call on a bean as dynamic router -->
            <method ref="mySlip" method="slip"/>
        </dynamicRouter>
    </route>

    <route>
        <from uri="direct:foo"/>
        <transform><constant>Bye World</constant></transform>
        <to uri="mock:foo"/>
    </route>

</camelContext>

dynamicRouter DSL 命令支持以下选项：

// Java
public class MyDynamicRouter {

    @Consume(uri = "activemq:foo")
    @DynamicRouter
    public String route(@XPath("/customer/id") String customerId, @Header("Location") String location, Document body) {
        // query a database to find the best match of the endpoint based on the input parameteres
        // return the next endpoint uri, where to go. Return null to indicate the end.
    }
}