Czym jest RabbitMQ?

RabbitMQ to broker wiadomości, implementujący protokół AMQP (Advanced Message Queuing Protocol). Umożliwia aplikacjom asynchroniczną interakcję, wysyłając i odbierając wiadomości za pomocą scentralizowanego systemu. RabbitMQ zapewnia niezawodne dostarczanie, routowanie i przechowywanie wiadomości.

Główne komponenty:

• Producent (Producer): Wysyła wiadomości do RabbitMQ.
• Wymiennik (Exchange): Odbiera wiadomości od producentów i kieruje je do jednej lub wielu kolejek na podstawie reguł routingu (binding).
• Kolejka (Queue): Przechowuje wiadomości do czasu ich pobrania przez konsumentów.
• Konsument (Consumer): Odbiera wiadomości z kolejek do przetwarzania.

Typy wymienników:

• Direct: Kieruje wiadomości do kolejek, gdzie klucz routingu dokładnie pasuje do klucza wiązania kolejki.
• Fanout: Kieruje wiadomości do wszystkich powiązanych kolejek, ignorując klucz routingu.
• Topic: Kieruje wiadomości na podstawie częściowych dopasowań klucza routingu z wzorcem klucza wiązania (używając symboli * i #).
• Headers: Kieruje wiadomości na podstawie nagłówków wiadomości, a nie klucza routingu.

Przykłady zastosowania w rozwoju PHP:

• Opóźnione przetwarzanie zadań: Na przykład wysyłanie emaili, generowanie raportów, przetwarzanie obrazów.
• Architektura mikroserwisów: Asynchroniczna interakcja między usługami.
• Systemy czasu rzeczywistego: Przetwarzanie dużych strumieni zdarzeń.
• Równoważenie obciążenia: Rozdzielanie zadań między wielu pracowników.

Przykład wysyłania wiadomości za pomocą biblioteki 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] Wysłano '" . $data . "'\n";

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

Przykład odbioru wiadomości:

<?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 " [*] Oczekiwanie na wiadomości. Naciśnij CTRL+C, aby wyjść\n";

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

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

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

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

RabbitMQ zapewnia odporność na awarie, skalowalność i elastyczność w projektowaniu systemów rozproszonych.