8.18. 动态路由器

动态路由器
复制链接

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

图 8.12. 动态路由器模式

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

beware

您必须确保用于 dynamicRouter （如 bean）的表达式返回 null 以指示最终。否则，dynamicRouter 继续在无限循环中。

Camel 2.5 中的动态路由器以后
复制链接

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

Java DSL
复制链接

在 Java DSL 中，您可以按照以下方法使用 dynamicRouter ：

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

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

Copy to Clipboard

Toggle word wrap

这将利用 bean 集成来计算 slip on-the-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;
    }

// 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;
    }

Copy to Clipboard

Toggle word wrap

注意

前面的示例不是线程安全。您需要在 Exchange 上存储状态以确保线程安全。

Spring XML
复制链接

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>

<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>

Copy to Clipboard

Toggle word wrap

选项
复制链接

dynamicRouter DSL 命令支持以下选项：

Expand

Name	默认值	描述
`uriDelimiter`	`,`	如果第 II 部分 “路由表达式和 predicates 语言” 返回多个端点，则使用分隔符。
`ignoreInvalidEndpoints`	`false`	如果端点 uri 无法解析，则应忽略它。否则 Camel 将抛出一个异常，表示 endpoint uri 无效。

@DynamicRouter 注释
复制链接

您还可以使用 @DynamicRouter 注释。例如：

// 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.
    }
}

// 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.
    }
}

Copy to Clipboard

Toggle word wrap

当消息进度通过 slipes 时，会重复调用 路由 方法。其理念是返回下一个目的地的端点 URI。返回 null 以指示最终。如果您就像第 8.7 节 “路由 Slip” 一样，您可以返回多个端点，其中每个端点用分隔符分开。

动态路由器
复制链接

Camel 2.5 中的动态路由器以后
复制链接

Java DSL
复制链接

Spring XML
复制链接

选项
复制链接

@DynamicRouter 注释
复制链接

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

8.18. 动态路由器

动态路由器复制链接链接已复制到粘贴板!

Camel 2.5 中的动态路由器以后复制链接链接已复制到粘贴板!

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

Spring XML复制链接链接已复制到粘贴板!

选项复制链接链接已复制到粘贴板!

@DynamicRouter 注释复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

动态路由器
复制链接

Camel 2.5 中的动态路由器以后
复制链接

Java DSL
复制链接

Spring XML
复制链接

选项
复制链接

@DynamicRouter 注释
复制链接