DefaultMessageListenerContainer documentation州:
可以通过指定高于“concurrentConsumers”值的“maxConcurrentConsumers”值来激活并发调度器数量的动态缩放 . 由于后者的默认值为1,因此您也可以简单地指定例如“maxConcurrentConsumers” . 如图5所示,在消息负载增加的情况下,这将导致动态扩展到5个并发消费者,并且一旦负载减少,动态缩减回标准数量的消费者 .
文档中不清楚实际上是什么增加了负载? 100 / 1k / 1m排队的消息?此时每个队列的线程数开始增加?什么时候应该达到“maxConcurrentConsumers”?
1 回答
没什么好看的,基本上“只要所有线程都忙于处理消息”并且消息排队 .
如果您可以再分配一个来处理排队的消息(即尚未到达
maxConcurrentConsumers
),则会分配一个额外的线程来处理它 . 因此,这定义了处理消息的最大并发线程数 .