Как избавиться от ошибки "no free channel ids" в rabbitmq?

Question

[Newto]

Есть программа на php, которая отправляет сообщения в consumer rabbitmq. Consumer обрабатывает входящие сообщения, соответственно. При отправке 2к+ сообщений, за короткий промежуток времени, я получаю ответ от отправляющего скрипта "no free channel ids". Подскажите какой-то способ это исправить, минуя непосредственные настройки rabbitmq.

p.s. То что гуглится на stackoverflow -- не помогает.

Comments

[Дмитрий]

Добрый вечер.
У Вас получилось решить проблему?

Answer 1

[Сергей]

По PHP возможно не подскажу, но всё же в таких ситуациях желательно публиковать и пример кода. По всей видимости, открывается канал (channel) на каждую публикацию сообщения, чего делать не стоит. Каналы нужны для параллельной работы через одно TCP подключение, так как AMQP протокол по своей натуре синхронный (следующую команду нельзя послать, если ожидается ответ от предыдущей). Если через один канал скорость публикации сообщений с подтверждением не устраивает, то можно:

• открыть несколько параллельных каналов,
  
• или использовать пакетную отправку, когда подтверждение приходит на каждые N запросов.
  

Comments

[Дмитрий]

Добрый вечер.
Подскажите, пожалуйста, если вернулся ответ "no free channel ids", то так и будет он возвращаться до перезапуска всего rabbit-a?

У меня сейчас подобная проблема. Часть задач отваливается с подобной ошибкой, и больше никаких задач поставить нельзя в очередь. Ни сразу, ни через какое-то время.

Как можно выйти из ситуации без перезапуска rabbit-a?

[Дмитрий]

Я так понимаю, что надо в produce-ре проверять, доступен ли канал для публикации задачи?

Как это лучше сделать?

[Сергей]

Дмитрий, как я писал выше, канал открывается внутри TCP подключения, поэтому переподключение должно решить эту проблему. Но лучше что-то исправить, потому-что каждый канал занимает ресурсы со стороны RabbitMQ и если висит куча неиспользуемых каналов, то потребляется большое памяти и процессора.

Возможно стоит посмотреть официальный мануал на эту тему - https://www.rabbitmq.com/channels.html

[Дмитрий]

Сергей, проблема решилась.
Не отрабатывал код, который должен был закрывать канал по завершению работы скрипта, поэтому накапливалось очень много каналов.