消息路由器

Spring 集成原生提供了专门的路由器类型，包括：spring-doc.cn

HeaderValueRouterspring-doc.cn
PayloadTypeRouterspring-doc.cn
ExceptionTypeRouterspring-doc.cn
RecipientListRouterspring-doc.cn
XPathRouterspring-doc.cn

与许多其他 DSL EIP 方法一样，该方法可以应用任何实现，或者为方便起见，可以应用作为 SPEL 表达式或 - 对。此外，您还可以使用 lambda 进行配置，并将 lambda 用于 . Fluent API 还提供 pairs 等选项，如下例所示：IntegrationFlowBuilderroute()AbstractMessageRouterStringrefmethodroute()Consumer<RouterSpec<MethodInvokingRouter>>AbstractMappingMessageRouterchannelMapping(String key, String channelName)spring-doc.cn

@Bean
public IntegrationFlow routeFlowByLambda() {
    return IntegrationFlow.from("routerInput")
            .<Integer, Boolean>route(p -> p % 2 == 0,
                    m -> m.suffix("Channel")
                            .channelMapping(true, "even")
                            .channelMapping(false, "odd")
            )
            .get();
}

以下示例显示了一个简单的基于表达式的路由器：spring-doc.cn

@Bean
public IntegrationFlow routeFlowByExpression() {
    return IntegrationFlow.from("routerInput")
            .route("headers['destChannel']")
            .get();
}

该方法采用，如下例所示：routeToRecipients()Consumer<RecipientListRouterSpec>spring-doc.cn

@Bean
public IntegrationFlow recipientListFlow() {
    return IntegrationFlow.from("recipientListInput")
            .<String, String>transform(p -> p.replaceFirst("Payload", ""))
            .routeToRecipients(r -> r
                    .recipient("thing1-channel", "'thing1' == payload")
                    .recipientMessageSelector("thing2-channel", m ->
                            m.getHeaders().containsKey("recipient")
                                    && (boolean) m.getHeaders().get("recipient"))
                    .recipientFlow("'thing1' == payload or 'thing2' == payload or 'thing3' == payload",
                            f -> f.<String, String>transform(String::toUpperCase)
                                    .channel(c -> c.queue("recipientListSubFlow1Result")))
                    .recipientFlow((String p) -> p.startsWith("thing3"),
                            f -> f.transform("Hello "::concat)
                                    .channel(c -> c.queue("recipientListSubFlow2Result")))
                    .recipientFlow(new FunctionExpression<Message<?>>(m ->
                                    "thing3".equals(m.getPayload())),
                            f -> f.channel(c -> c.queue("recipientListSubFlow3Result")))
                    .defaultOutputToParentFlow())
            .get();
}

的定义允许您将路由器设置为网关，以继续处理主流中不匹配的消息。.defaultOutputToParentFlow().routeToRecipients()defaultOutputspring-doc.cn

另请参阅 Lambda 和 Message<？> 参数。spring-doc.cn