java - Spring用单线程池并发处理多个队列

Question

我有一个应该处理和存储套接字传入数据的 Spring 应用程序，因为瓶颈问题应该使用多线程来完成。

传入数据属于 许多实体和 每个实体任务都应该串行处理 ，但我认为为每个实体分配一个线程并不是一个好的解决方案(数千个单线程来处理每个实体的队列)

那么如何定义公共(public)ThreadPool用票价算法处理所有实体的队列？

Answer 1

您已经描述了一个使用消息驱动架构解决的完美问题。

Spring Integration 是为您提供此功能的模块。

您可以使用 @ServiceActivator 构建您的任务服务和注释，并使用 Channels 创建您的链。

channel 可以选择在不同的线程池上执行，并且可以通过 channel 上的队列设置来克服峰值负载造成的瓶颈。

绝对值得一试查看 Spring Integration 的文档。