spring - Spring Integration - 最大吞吐量消费者

Question

Spring Integration 元素的配置（如果有）将支持以下模型：

• 一个消息队列，代表传入的工作
• 从该队列读取的多个消费者（一条消息只需要发送给一个消费者）
• 每个消费者只有在无事可做时才进行轮询；如果它当前正在处理消息，则不要轮询。如果它没有工作，则每隔 X 秒轮询一次以查看是否有新工作到达。

Answer 1

假设您的意思是使用 JMS，

<jms:message-driven-channel-adapter/>

查看concurrent-consumers、max-concurrent-consumers、idle-consumer-limit、idle-task-execution-limit等属性。

消费者管理全部由底层核心 Spring DefaultMessageListenerContainer 完成。