Spring Integration DSL：向多个endpoint发送转换输出

Question

遗留的Spring集成项目使用XML定义工作流。基本流程如下：

null

<int:chain input-channel="inputChannel">
    <int:transformer ref="..." />
    <int:recipient-list-router apply-sequence="true">
        <int:recipient channel="outputChannel1" />
        <int:recipient channel="outputChannel2" />
        <int:recipient channel="outputChannel3" />
    </int:recipient-list-router>
</int:chain>

@Bean
public DirectChannel outputChannel() {
    return new DirectChannel();
}

@Bean
public org.springframework.integration.dsl.IntegrationFlow listenerFlow() {
    return IntegrationFlows
            .from(inputChannel)
            .transform(transformer)
            .channel(outputChannel())
            .get();
}

@Bean
public org.springframework.integration.dsl.IntegrationFlow outputFlow() {
    return IntegrationFlows
            .from(outputChannel())
            .handle(handler)
            .get();
}

每个endpoint都被表示为单独的IntegrationFlowbean。这是最佳实践吗？还是最好让一个integrationflow代表完整的工作流（如果可能的话）？

谢谢

Answer 1

您可以使用.routeToreCipients()，原因相同:https://docs.spring.io/spring-integration/docs/5.0.2.release/reference/html/java-dsl.html#java-dsl-routers

然后为每个收件人分别设置流。