¿Qué es RabbitMQ?

RabbitMQ es un intermediario de mensajes que implementa el protocolo AMQP (Protocolo Avanzado de Colas de Mensajes). Permite a las aplicaciones interactuar de manera asíncrona, enviando y recibiendo mensajes a través de un sistema centralizado. RabbitMQ garantiza una entrega confiable, enrutamiento y almacenamiento de mensajes.

Componentes principales:

• Productor (Producer): Envía mensajes a RabbitMQ.
• Intercambiador (Exchange): Recibe mensajes de los productores y los dirige a una o varias colas según reglas de enrutamiento (binding).
• Cola (Queue): Almacena mensajes hasta que son recogidos por los consumidores.
• Consumidor (Consumer): Recibe mensajes de las colas para su procesamiento.

Tipos de intercambiadores:

• Direct: Enruta mensajes a las colas donde la clave de enrutamiento coincide exactamente con la clave de enlace de la cola.
• Fanout: Enruta mensajes a todas las colas enlazadas, ignorando la clave de enrutamiento.
• Topic: Enruta mensajes basándose en coincidencias parciales de la clave de enrutamiento con un patrón de clave de enlace (usando los símbolos * y #).
• Headers: Enruta mensajes basándose en los encabezados del mensaje, no en la clave de enrutamiento.

Aplicaciones en desarrollo PHP:

• Procesamiento diferido de tareas: Por ejemplo, envío de emails, generación de informes, procesamiento de imágenes.
• Arquitectura de microservicios: Interacción asíncrona entre servicios.
• Sistemas en tiempo real: Procesamiento de grandes flujos de eventos.
• Balanceo de carga: Distribución de tareas entre varios trabajadores.

Ejemplo de envío de mensaje usando la biblioteca 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] Enviado '" . $data . "'\n";

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

Ejemplo de recepción de mensajes:

<?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 " [*] Esperando mensajes. Para salir presione CTRL+C\n";

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

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

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

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

RabbitMQ proporciona resistencia a fallos, escalabilidad y flexibilidad en el diseño de sistemas distribuidos.