Лимит потребительских тарифов? - PullRequest
1 голос
/ 23 октября 2019

Я написал продюсера, который отправляет более 12 000 сообщений примерно за 23 секунды, но мой потребитель, похоже, получает только 6 тыс. Сообщений в минуту.

Я добавил плагин метрик, чтобы следить за количествомсообщения, подтвержденные в этой очереди, но они увеличиваются со скоростью 6 000 сообщений в минуту

2019-10-23 11:09:46,815 INFO  [io.micrometer.core.instrument.logging.LoggingMeterRegistry] artemis.messages.acknowledged{address=my.controller.queue,broker=0.0.0.0,queue=my.controller.queue} value=40156
2019-10-23 11:10:46,818 INFO  [io.micrometer.core.instrument.logging.LoggingMeterRegistry] artemis.messages.acknowledged{address=my.controller.queue,broker=0.0.0.0,queue=my.controller.queue} value=46157

message.count для указанных выше журналов выглядит следующим образом

2019-10-23 11:09:46,818 INFO  [io.micrometer.core.instrument.logging.LoggingMeterRegistry] artemis.unrouted.message.count{address=my.controller.queue,broker=0.0.0.0} value=2
2019-10-23 11:10:46,815 INFO  [io.micrometer.core.instrument.logging.LoggingMeterRegistry] artemis.delivering.durable.message.count{address=my.controller.queue,broker=0.0.0.0,queue=my.controller.queue} value=0

У меня есть следующие параметры URL-адреса соединения:

?minLargeMessageSize=10485760;compressLargeMessages=true;producerWindowSize=-1;reconnectAttempts=-1;confirmationWindowSize=1048576&consumerWindowSize=-1&throttleRate=-1&consumerMaxRate=-1

1 Ответ

0 голосов
/ 24 октября 2019

Мне удалось выяснить причину удушения. В нашем фреймворковом коде мы устанавливали

com.google.common.util.concurrent.RateLimite outboundRateLimiter на 100

, поэтому только 100*60=6000 в минуту, сообщения отправляются каждую минуту.

...