What is RabbitMQ?

RabbitMQ is a message broker implementing the AMQP (Advanced Message Queuing Protocol). It allows applications to interact asynchronously by sending and receiving messages through a centralized system. RabbitMQ provides reliable delivery, routing, and message storage.

Main components:

• Producer: Sends messages to RabbitMQ.
• Exchange: Receives messages from producers and routes them to one or more queues based on routing rules (binding).
• Queue: Stores messages until they are retrieved by consumers.
• Consumer: Receives messages from queues for processing.

Types of exchanges:

• Direct: Routes messages to queues where the routing key exactly matches the binding key.
• Fanout: Routes messages to all bound queues, ignoring the routing key.
• Topic: Routes messages based on partial matching of the routing key with the binding key pattern (using * and # symbols).
• Headers: Routes messages based on message headers rather than the routing key.

Application in PHP development:

• Deferred task processing: For example, sending emails, generating reports, image processing.
• Microservice architecture: Asynchronous interaction between services.
• Real-time systems: Processing a large stream of events.
• Load balancing: Distributing tasks among multiple workers.

Example of sending a message using the php-amqplib library:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->exchange_declare('my_exchange', 'direct', false, false, false);
$channel->queue_declare('my_queue', false, false, false, false);
$channel->queue_bind('my_queue', 'my_exchange', 'my_routing_key');

$data = 'Hello, RabbitMQ!';
$msg = new AMQPMessage($data);

$channel->basic_publish($msg, 'my_exchange', 'my_routing_key');

echo " [x] Sent '" . $data . "'\n";

$channel->close();
$connection->close();

Example of receiving a message:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->queue_declare('my_queue', false, false, false, false);

echo " [*] Waiting for messages. To exit press CTRL+C\n";

$callback = function ($msg) {
    echo " [x] Received '" . $msg->body . "'\n";
};

$channel->basic_consume('my_queue', '', false, true, false, false, $callback);

while ($channel->is_consuming()) {
    $channel->wait();
}

$channel->close();
$connection->close();

RabbitMQ ensures fault tolerance, scalability, and flexibility in designing distributed systems.