配置通用路由器

DeepSeek V3 中英对照 Configuring a Generic Router

Spring Integration 提供了一个通用的路由器。您可以将它用于通用路由（与 Spring Integration 提供的其他路由器不同，每个其他路由器都有某种形式的专门化）。

以下部分解释了使用 XML 组件的路由器配置。

router 元素提供了一种将路由器连接到输入通道的方式，并接受可选的 default-output-channel 属性。ref 属性引用自定义路由器实现的 bean 名称（该实现必须扩展 AbstractMessageRouter）。以下示例展示了三种通用路由器：

<int:router ref="payloadTypeRouter" input-channel="input1"
            default-output-channel="defaultOutput1"/>

<int:router ref="recipientListRouter" input-channel="input2"
            default-output-channel="defaultOutput2"/>

<int:router ref="customRouter" input-channel="input3"
            default-output-channel="defaultOutput3"/>

<beans:bean id="customRouterBean" class="org.foo.MyCustomRouter"/>

或者，ref 可以指向一个包含 @Router 注解的 POJO（稍后展示），或者你可以将 ref 与一个显式的方法名结合使用。指定方法会应用与本文档稍后 @Router 注解部分描述的相同行为。以下示例定义了一个在其 ref 属性中指向 POJO 的路由器：

<int:router input-channel="input" ref="somePojo" method="someMethod"/>

我们通常建议，如果自定义路由器实现在其他 <router> 定义中被引用，则使用 ref 属性。但是，如果自定义路由器实现应限定在单个 <router> 定义范围内，则可以提供一个内部 bean 定义，如下例所示：

<int:router method="someMethod" input-channel="input3"
            default-output-channel="defaultOutput3">
    <beans:bean class="org.foo.MyCustomRouter"/>
</int:router>

备注

不允许在同一个 <router> 配置中同时使用 ref 属性和内部处理器定义。这样做会产生歧义条件并抛出异常。

important

如果 ref 属性引用的 bean 继承自 AbstractMessageProducingHandler（例如框架本身提供的路由器），配置会被优化为直接引用该路由器。在这种情况下，每个 ref 属性必须引用一个独立的 bean 实例（或一个 prototype 作用域的 bean），或者使用内部的 <bean/> 配置类型。然而，此优化仅适用于您在路由器的 XML 定义中未提供任何路由器特定属性的情况。如果您无意中从多个 bean 引用了相同的消息处理器，将会引发配置异常。

以下示例展示了在 Java 中配置的等效路由器：

@Bean
@Router(inputChannel = "routingChannel")
public AbstractMessageRouter myCustomRouter() {
    return new AbstractMessageRouter() {

        @Override
        protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {
            return // determine channel(s) for message
        }

    };
}

以下示例展示了使用 Java DSL 配置的等效路由器：

@Bean
public IntegrationFlow routerFlow() {
    return IntegrationFlow.from("routingChannel")
            .route(myCustomRouter())
            .get();
}

public AbstractMessageRouter myCustomRouter() {
    return new AbstractMessageRouter() {

        @Override
        protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {
            return // determine channel(s) for message
        }

    };
}

或者，您也可以根据消息负载中的数据来路由，如下例所示：

@Bean
public IntegrationFlow routerFlow() {
    return IntegrationFlow.from("routingChannel")
            .route(String.class, p -> p.contains("foo") ? "fooChannel" : "barChannel")
            .get();
}