DefaultJmsListenerContainerFactory - Concurrency - В какой момент число потоков в очереди начинает увеличиваться? - PullRequest
0 голосов
/ 06 мая 2018

DefaultMessageListenerContainer документация состояния:

Динамическое масштабирование числа одновременных инициаторов можно активировать, указав значение maxConcurrentConsumers, которое больше значения "concurrentConsumers". Поскольку по умолчанию последний равен 1, вы также можете просто указать «maxConcurrentConsumers», например, 5, что приведет к динамическому масштабированию до 5 одновременных потребителей в случае увеличения нагрузки на сообщение , а также к динамическому сокращению до стандартного числа потребителей при уменьшении нагрузки .

Непонятно в документации, что на самом деле увеличивает нагрузку? 100 / 1k / 1m сообщений в очереди? В какой момент количество потоков в очереди начинает увеличиваться? Когда должен быть достигнут maxConcurrentConsumers?

1 Ответ

0 голосов
/ 06 мая 2018

Ничего особенного, в основном, "как только все потоки заняты обработкой сообщения" и сообщение ставится в очередь.

Если вы можете выделить еще одну для обработки сообщения в очереди (т. Е. maxConcurrentConsumers не было достигнуто), то для его обработки будет выделен дополнительный поток. Следовательно, это определяет максимальное количество одновременных потоков, обрабатывающих сообщения.

...