Консьюмеры не читают из очереди rabbitmq

halva

Новичок
Привет. Есть проблема, воспроизводится только на одной машине, на остальных нет.

У меня есть консьюмеры принцип которых строится по типу:
1. Запустили скрипт под супервизором
2. Скрипт подключился создав новый конекшен и канал
3. Скрипт подключился к определенной очереди
4. Принимает от очереди сообщение и выполняет непотребства
5. Умирает
6. Идет в пункт 1 (то есть супервизор, держит постоянное количество процессов)

Проблема в том: что на этапе 4, в какой-то момент новоиспеченные консьюмеры перестают получать сообщения из очереди, хотя формально ее слушают. Создается ощущение, что где-то стоит блок на одновременное количество подключение, каналов или прочей лабуды. На других машинах проблема не воспроизводится, deb пакеты одинаковые, окружение не факт.

Лимиты на файловые дескрипторы не достигнуты.

Куда смотреть, где рыть?

Использую эту библиотеку: https://github.com/php-amqplib/php-amqplib
Консьюмер принципиально не отличается от демки: https://github.com/php-amqplib/php-amqplib/blob/master/demo/amqp_consumer.php
 

halva

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

AnrDaemon

Продвинутый новичок
Т.е. подключения есть?
Тогда надо повышать уровень логирования, чтобы видеть, что именно во время этих подключений происходит.
 

halva

Новичок
Подключения есть, проблема именно когда он начинает читать из буфера

в логах

cat /var/log/rabbitmq/[email protected] | grep error

Channel error on connection <0.1844.0> ([::1]:57861 -> [::1]:5672, vhost: '/', user: 'guest'), channel 1:
Channel error on connection <0.1925.0> ([::1]:57927 -> [::1]:5672, vhost: '/', user: 'guest'), channel 1:
Channel error on connection <0.2072.0> ([::1]:58217 -> [::1]:5672, vhost: '/', user: 'guest'), channel 1:
Channel error on connection <0.2148.0> ([::1]:58277 -> [::1]:5672, vhost: '/', user: 'guest'), channel 1:
Channel error on connection <0.2191.0> ([::1]:58335 -> [::1]:5672, vhost: '/', user: 'guest'), channel 1:
webmachine error: path="/api/queues/%2F/Cron/get"
webmachine error: path="/api/queues/%2F/Cron/get"
webmachine error: path="/api/queues/%2F/Cron/get"
webmachine error: path="/api/queues/%2F/Cron/get"
webmachine error: path="/api/queues/%2F/Cron/get"

Проблемы кстати с очередью Cron
 

halva

Новичок
Поискал по логам что за webmachine

=ERROR REPORT==== 3-Oct-2018::14:31:40 ===
webmachine error: path="/api/queues/%2F/Cron/get"
"Bad Request"
 

halva

Новичок
Короче, вроде зафиксил, настройл heartbeat, и вроде консьюмеры начали разбирать очередь, но инфа не сотка
 
Сверху