Qu'est-ce que RabbitMQ ?

RabbitMQ est un courtier de messages qui implémente le protocole AMQP (Protocole Avancé de File d Attente de Messages). Il permet aux applications d interagir de manière asynchrone, en envoyant et recevant des messages via un système centralisé. RabbitMQ assure une livraison fiable, un routage et un stockage des messages.

Composants principaux:

• Producteur (Producer): Envoie des messages à RabbitMQ.
• Échangeur (Exchange): Reçoit des messages des producteurs et les dirige vers une ou plusieurs files selon des règles de routage (binding).
• File (Queue): Stocke les messages jusqu à ce qu ils soient récupérés par les consommateurs.
• Consommateur (Consumer): Reçoit des messages des files pour traitement.

Types d échangeurs:

• Direct: Routage des messages vers les files où la clé de routage correspond exactement à la clé de liaison de la file.
• Fanout: Routage des messages vers toutes les files liées, en ignorant la clé de routage.
• Topic: Routage basé sur des correspondances partielles de la clé de routage avec un motif de clé de liaison (utilisant les symboles * et #).
• Headers: Routage basé sur les en-têtes du message, pas sur la clé de routage.

Applications en développement PHP:

• Traitement différé des tâches: Par exemple, envoi d emails, génération de rapports, traitement d images.
• Architecture microservices: Interaction asynchrone entre services.
• Systèmes en temps réel: Traitement de grands flux d événements.
• Répartition de charge: Distribution des tâches entre plusieurs travailleurs.

Exemple d envoi de message avec la bibliothèque php-amqplib:

<?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] Envoyé '" . $data . "'\n";

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

Exemple de réception de 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 " [*] En attente de messages. Pour quitter, appuyez sur CTRL+C\n";

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

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

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

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

RabbitMQ offre une résilience aux pannes, une évolutivité et une flexibilité dans la conception de systèmes distribués.