弹簧集成的多线程拆分器



我使用spring集成通过tcp获取记录。有一个客户端id集合,将其拆分为单独的客户端id消息,以获取相应的记录。到目前为止效果良好。现在,为了提高性能,我需要将集合分解为子集合,并使用子集合中的客户端ID来获取记录。我已经实现了拆分器来破坏集合,但它只适用于一个线程。程序在仅服务于第一请求(即客户端的第一集合)之后结束。

如何使用多线程实现该场景?

只需将拆分器的输出通道作为Executor通道即可:

<int:channel id="executorChannel">
    <int:dispatcher task-executor="someExecutor"/>
</int:channel>

最新更新