是Spring集成聚合器单线程执行

Question

我在应用程序中使用拆分器聚合器模式。我有以下配置-

<int:splitter inputChannel="CH1" outputChannel="CH2" ref="foo" method="bar"/>
<int:aggregator inputChannel="CH2" outputChannel="CH3" ref="oof" method="rab" ---other required configurations/>
<task:scheduler --with threadpool of size 30 />
<!--there are other channels as well. Some are queue and some are direct channels-->

我的所有通道（CH1、CH2、CH3）都是QueueChannel。Splitter输入通道CH1的源代码是一个文件。

在我的测试中，我观察到即使在CH1通道中添加两个文件，在给定时间也只有一个文件被处理。所以我在我的CH1通道中添加了一个轮询器，现在正在同时处理CH1通道上的多个输入消息。

在聚合器方面，我也注意到执行总是单线程的，即直到第一个线程完成执行，第二个线程才开始执行。

到目前为止，我试图解决这个问题-

1. 将轮询器添加到<代码>

有人能帮我把聚合器处理成多线程的吗。

Update1我想做什么：

我接收包含库存数据的文件。我为每个文件创建消息并将其放入CH1通道。CH1通道有一个拆分器，可以将其拆分为单个记录并将其发送到CH2通道。CH2通道有一个与之关联的聚合器，它将尝试根据文件名聚合记录，并“oof.rab”将记录写入数据库。我的期望是看到同一文件的多批次同时写入数据库。

Update2：这里进行聚合以批处理行，以便我们可以以批处理模式将其写入数据库，而不是单独写入行

Answer 1

聚合器是多线程的，但仅适用于不同的消息组（相关性）。每个组都必须是单线程的，因为对于每个消息到达，我们都必须咨询ReleaseStrategy。