Всем привет! Подскажите, пожалуйста. У меня 100 очередей в Реббите.

В них паблишат сообщения разные сервисы и с разной скоростью. Для сбалансированного консьюминга в рамках каждого соединения устанавливается разное количество каналов при prefetch count =1.

Вопрос 1: сколько таких каналов в одном реббите максимум можно сделать? Из разряда: 100 очередей по 5 каналов на соединение = 500 каналов.
Вопрос 2: правильный ли подход с увеличением количества каналов? Или стоит использовать 1 канал - одно соединение, а для балансировки изменять только префетч. Вычитал из курса Алексея следующее: "Создаёт соединение (connection) по протоколу AMQP, в рамках соединения создает канал (channel). В рамках одного соединения можно создать несколько каналов, но это не рекомендуется даже официальной документацией RabbitMQ"...

1 ответов

11 просмотров

в самом деле балансировать каналами эт конечно весьма странная затея. prefetch count=1 нужен в основном для гарантий последовательности обработки, если у вас в этом нет потребности и вы знаете что обрабатываете сообщения в мультитреде - то можно увеличить prefetch_count, но не думаю что это можно использовать как механизм балансировки нагрузки

Похожие вопросы

Обсуждают сегодня

Всем привет. Подскажите. Следующая ошибка при выполнении команды werf ci-env github --as-file - "unable to get synchronization client id: unable to get repo ghcr.io/*** tags: ...
2
pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...
Sergey
9
WERF_COMMIT_HASH если я правильно понимаю только внутри стапель сборки работает?
citius
2
Еще одну панику поймал: $ werf helm repo add --username gitlab --password ${CI_JOB_TOKEN} helm-werf ${HELM_REPO_V2_URL} "helm-werf" has been added to your repositories $wer...
citius
1
Всем привет 👋 может кто подсказать? Как мне добавить файлик без коммита в сборку stapel? С докерфайлом понятно Там allowContextAddFiles А как тоже самое сделать со stapel?
Sergeevich
5
Всем привет! Прохожу этот самоучитель. Дошел до # Настроим подключение к MinIO. mc alias set minio http://minio:9000 minioadmin minioadmin # Получим содержимое сохранённого...
Aleksandr
7
Вот такая неприятность на stable и ea версиях: werf helm --namespace s4c upgrade --install --atomic --timeout 5m --set s4c.version=839185f3 --set s4c.deployEnv=staging -f d...
citius
6
Всем доброго времени суток! Перестал запускаться сервер RabbitMQ, вижу по логам, что ругается на плагин, но по какой причине не могу понять. Можете помочь разобраться, куда ко...
Александр Семенов
2
https://habr.com/ru/companies/domclick/articles/500978/ Добрый день, подскажите, пожалуйста, насколько хорошая практика сделать вот такую структуру эксчейнджей и очередей для...
Sergey
5
Доброго дня чат, можно ли использовать для werf build локально podman?
Andrey🏔
2
Карта сайта