Как реализовать множество консьюмеров RabbitMQ?

Question

[Ivan Palamarchuk]

Допустим, у меня есть воркер (консьюмер):

$connection = new AMQPConnection($config['rabbitmq']);
$connection->connect();
$channel = new AMQPChannel($connection);

$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->setFlags(AMQP_AUTODELETE);
$exchange->declareExchange();

$queue = new AMQPQueue($channel);
$queue->setName('queue_name');
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());

while (true) {
    $envelope = $queue->get();

    if ($envelope) {
        var_dump($envelope->getBody());
        $queue->nack($envelope->getDeliveryTag());
    }
}

$connection->disconnect();

Каким путем лучше сделать поддержку 15 консьюмеров? Т.е. если я запускаю этот воркер, он будет кушать процесс, не хотелось бы запускать параллельно 15 php-cli процессов..

Answer 1

[Максим Федоров]

для управления процессами можно использовать например supervisord

Comments

[tkutru]

Максим Федоров тоже это пришло в голову, вот только он не умеет процессы динамически поднимать и бить как php-fpm например. https://github.com/Supervisor/supervisor/issues/177

[Ivan Palamarchuk]

supervisord.. когда еще с gearman работал, один процесс там висел, который уже внутри скрипта распределял задачи по воркерам.. а тут получается, чем больше проект, тем больше процессов у тебя, которые по каким-то причинам и падать могут, и за этим еще следить нужно. Если бы как-то 1-2 процессами ограничиться можно было..

[Ivan Palamarchuk]

Просто тут так получается.. делаешь деплой, и если у тебя какая-то новая сущность появилась - создаешь новый конфиг в supervisord.. как-то совсем не гибко

[parserpro]

Может горутины?

[Ivan Palamarchuk]

parserpro: нет, в итоге ограничился "типом" в payload (сообщении)