弹簧积分分布式并行散射模式

Question

我需要实现以下架构：

我有大量订单，必须拆分成较小的顺序(并行)，并发送到下游异步rest端点。

在使用相关ids完成订单(失败或成功)之后，向下流排序API将消息发布到应答队列( kafka/rabbitmq)。

需要有聚合侦听器来收集所有的响应，并将最终输出发送给调用者。

我正在考虑使用spring集成、散射聚集模式和其他有用的Spring特性。

你能帮我举个例子，说明如何在Spring集成的帮助下实现这样的架构吗？

Answer 1

大订单，必须拆分成较小的顺序(并行)

这不是分散收集设计的目的。它的目的是做许多相同的输入请求，例如要求经销商提供汽车报价，然后为你选择最好的。

您所要求的更像是一个拆分器-聚合器。

因此，您只需对order对象执行拆分函数，并在其输出通道中生成所需的多少项。这个必须是一个ExecutorChannel才能并行地处理那些分裂的项目。

由于您谈论的是对原始客户机的答复，所以不能使您的聚合器分布(同一应用程序的几个实例)，但是您仍然可以通过该ExecutorChannel获得异步并行处理的好处。不要忘记在整个流程中执行一个replyChannel头，这样聚合器最终会知道在哪里生成答复。