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
У меня есть консьюмеры принцип которых строится по типу:
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