Spring Cloud数据流:复杂并行处理器senario

Question

我想知道是否有可能使用预设模块在spring cloud数据流中实现这样的流。处理器1、2、3都是预置模块(httpclient等)。处理器1和3将同时从源获得相同的消息，然后处理器1通过管道将输出传递给处理器2。当处理器2和3完成时，它们同时将输出通过管道传递给处理器4。我真的不关心处理器2的输出，处理器4只从3获得输出是很好的，但是处理器3应该只在处理器2完成时才向4发送消息。

​

​

Answer 1

使用分路器和指定的目的地，您可以获得大部分路径。

​

​

DSL看起来像这样：

main-stream=source: http | processor1: script | processor2: script > :destination
second-stream=:main-stream.source > processor3: script > :destination
sink-stream=:destination > sink: log

在processor2和processor3之间同步听起来像是一种反模式。这听起来更像是您需要processor3从processor2接收，而不是并行工作(它只需要消息的原始副本)。