【问题标题】：Spring Cloud Data Flow: complex parallel processors senarioSpring Cloud Data Flow：复杂的并行处理器场景
【发布时间】：2021-11-09 00:27:54
【问题描述】：
我想知道是否可以使用预设模块在spring cloud数据流中实现这样的流程。处理器 1、2、3 都是预设模块（httpclient 等）。处理器 1 和 3 将同时从源获得相同的消息，然后处理器 1 将输出通过管道传输到处理器 2。在处理器 2 和 3 完成后，它们同时将输出通过管道传输到处理器 4。我并不真正关心处理器 2 的输出。处理器 4 只从 3 获取输出是可以的，但是处理器 3 应该只在处理器 2 完成时才向 4 发送消息。
【问题讨论】：
标签：
spring-cloud-stream
spring-cloud-dataflow
【解决方案1】：
使用水龙头和命名的目的地，您可以到达那里的大部分路。
DSL 看起来像：
main-stream=source: http | processor1: script | processor2: script > :destination
second-stream=:main-stream.source > processor3: script > :destination
sink-stream=:destination > sink: log
处理器 2 和处理器 3 之间的同步听起来像是一种反模式。这听起来更像是您需要处理器 3 从处理器 2 接收，而不是并行工作（它还需要消息的原始副本）。