关于集成流程设计的建议

Question

我计划实施以下整合流程：

IntegrationFlows.from(httpInboundGateway)
    .transform(transformer-rest-api-1)
    .transform(transformer-rest-api-2)
    .handle(jdbc-outbound)
    .handle(http-outbound-gateway-1)
    .get(); 

我想要满足的要求是：

1. ，以尽可能多地在并行线程中运行。
2. 在每个端点保持消息。
3. 将非常端点设置为rest(使流可伸缩)

做流动反应有什么意义吗？如果是这样的话，怎么做呢？我如何在每一步登录？(窃听对此有帮助吗？)最后，请您提供一个具体的示例，说明在java dsl中实现上述功能的简单方法吗？

Answer 1

1. 要使其并行，需要考虑在端点之间使用ExecutorChannel： IntegrationFlows.from(httpInboundGateway) .channel(c -> c.executor(myTaskExecutor().transform(变压器-rest-api-1)

诸若此类。

1. 但是，由于您希望具有持久性选项，因此需要考虑使用QueueChannel和持久的MessageStore：https://docs.spring.io/spring-integration/docs/current/reference/html/system-management-chapter.html#message-store。然后，必须为每个端点提供轮询器选项，包括并行处理的tasExecutor： p.fixedDelay(100).taskExecutor(myTaskExecutor()))) .channel(c -> c.queue(jdbcMessageStore()，"queue1Channel")) .transform(变压器-rest-api-1，e -> e.poller(p -> e.poller)
2. 要将端点作为REST，只需使用Http.outboundGateway()即可。或者是反应性变体-- WebFlux.outboundGateway()在.handle()中而不是transform()中。或者在流中的现有.handle(http-outbound-gateway-1)中继续前进
3. 要使流反应，你需要使用一个.channel(c -> c.flux()))，但你失去了坚持的事情。
4. 要记录每个步骤，需要在端点之间放置一个.log()操作符。
5. 你的要求还不清楚要分享一些样本..。