How to implement multiple RabbitMQ consumers?

Question

PHP

Let's say I have a worker (consumer):

$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();

Which way is better to support 15 consumers? Those. if I run this worker, it will eat the process, I would not like to run 15 php-cli processes in parallel..

Answer 1

to manage processes, you can use for example supervisord