弹簧集成:并行处理

Question

我有一个春季消息监听器，它接收股票的价格( S1，S2，S3 .)。同一种股票的价格需要按顺序处理，因为不同股票的价格应该并行处理。

例如，如果价格顺序是S1-1，S1-2，S2-1，S1-3，S3-1，S2-2，S1-3，S3-2。然后应该有三个并行的处理流。

S1-1，S1-2，S1-3

S2-1，S2-1

S3-1，S3-2

目前，我正在并行处理所有内容，消息侦听器在消息到达时以soos的形式向priceInChannel发送消息。

<int:channel id="priceInChannel">
    <int:dispatcher task-executor="threadPoolExecutor"/>
</int:channel>

我需要哪些改变才能达到所需的行为？

谢谢Murali

Answer 1

看来你应该这么做：

1. 每只股票的总价格有S1，S2，S3 .
2. 把那些袋子重新整理一下。这里需要做一些关于sequenceDatails的技巧
3. 将每只股票分成一个executor-channel。

当然，这个解决方案取决于您有多少传入数据，以及它们都会持续多长时间。

更新

我相信我不能把它归为一个连续的价格

好的。合乎道理。

那么，如何为每个系列设置一个router和队列通道。

股票将被并行处理，但是股票中的每一个价格都是顺序的，因为队列通道将阻塞底层处理程序直到消息结束。当然，如果队列通道的poller是：

<poller max-messages-per-poll="1" fixed-delay="100"/>