配置通用路由器
Spring 集成提供了一个通用路由器。 你可以将它用于通用路由（与 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注解（稍后显示），或者您可以将ref替换为显式方法名称。
指定方法将应用@Routerannotation 部分。
以下示例定义了一个路由器，该路由器在其ref属性：
<int:router input-channel="input" ref="somePojo" method="someMethod"/>我们通常建议使用ref属性（如果自定义路由器实现在其他<router>定义。
但是，如果自定义路由器实现的范围应限定为<router>，您可以提供内部 Bean 定义，如下例所示：
<int:router method="someMethod" input-channel="input3"
default-output-channel="defaultOutput3">
<beans:bean class="org.foo.MyCustomRouter"/>
</int:router>同时使用refattribute 和内部处理程序定义位于同一<router>不允许配置。
这样做会产生不明确的条件并引发异常。 |
如果ref属性引用一个扩展AbstractMessageProducingHandler（例如框架本身提供的路由器），则配置会优化为直接引用路由器。
在这种情况下，每个ref属性必须引用单独的 bean 实例（或prototype-scoped 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();
}