Consuming RabbitMQ Messages in PHP

RabbitMQ consumers receive broker deliveries and acknowledge messages after durable processing.

What It Does

RabbitMQ consumers receive broker deliveries and acknowledge messages after durable processing. The following examples distinguish a normal use case, a boundary case and a practical application.

Requirements and Compatibility

A RabbitMQ broker plus php-amqp (or a separate supported AMQP library), secure connection settings and an idempotent handler.

The code focuses on the core concept. Production implementation may also need routes, validation, persistence, authorization or deployment tooling.

Example 1: Basic Behavior

Install the AMQP client library if the PECL amqp extension is not used.

composer require php-amqplib/php-amqplib

This is a command-line example; use it in its appropriate file or shell, not in the PHP source editor.

Example 2: Another Case

Use an AMQPQueue consumer with manual acknowledgement; make handlers idempotent and route failures to a dead-letter policy.

<?php
// Requires PECL amqp and a configured, secured RabbitMQ broker.
$conn = new AMQPConnection(['host' => '127.0.0.1', 'login' => getenv('AMQP_USER'), 'password' => getenv('AMQP_PASSWORD'), 'vhost' => '/']);
$conn->connect();
$channel = new AMQPChannel($conn);
$queue = new AMQPQueue($channel);
$queue->setName('orders');
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->consume(function (AMQPEnvelope $msg, AMQPQueue $queue): void {
    try {
        $payload = json_decode($msg->getBody(), true, 512, JSON_THROW_ON_ERROR);
        // Commit the business action durably before acknowledging.
        $queue->ack($msg->getDeliveryTag());
    } catch (Throwable $e) {
        $queue->nack($msg->getDeliveryTag(), AMQP_NOPARAM, false);
    }
});
$conn->disconnect();

This example depends on an installed extension, third-party library or configured service and is not a standalone local test.

Practical Example: Putting It to Use

A test-only in-memory example of idempotency; use a durable database uniqueness constraint in a real worker.

<?php
$seen = [];
foreach (["job-1", "job-1", "job-2"] as $id) { if (isset($seen[$id])) continue; $seen[$id] = true; }
echo count($seen);

Important Behavior and Edge Cases

Expect redelivery and make handlers idempotent; manual acknowledgement and dead-letter policy matter.

Comparison with Related Functions or Approaches

Common Beginner Mistakes

Key Takeaways

• RabbitMQ consumers receive broker deliveries and acknowledge messages after durable processing.
• Expect redelivery and make handlers idempotent; manual acknowledgement and dead-letter policy matter.
• The php-amqp extension or php-amqplib can speak AMQP to RabbitMQ.

Before adapting these examples, verify the return values, test the failure paths and confirm that your application meets its security and environment requirements.