我使用spring集成通过tcp获取记录。有一个客户端id集合,将其拆分为单独的客户端id消息,以获取相应的记录。到目前为止效果良好。现在,为了提高性能,我需要将集合分解为子集合,并使用子集合中的客户端ID来获取记录。我已经实现了拆分器来破坏集合,但它只适用于一个线程。程序在仅服务于第一请求(即客户端的第一集合)之后结束。
如何使用多线程实现该场景?
只需将拆分器的输出通道作为Executor通道即可:
<int:channel id="executorChannel">
<int:dispatcher task-executor="someExecutor"/>
</int:channel>