Šta je RabbitMQ?

RabbitMQ је брокер порука који имплементира протокол AMQP (Advanced Message Queuing Protocol). Он омогућава апликацијама да асинхроно комуницирају, шаљући и примајући поруке преко централизованог система. RabbitMQ обезбеђује поуздану доставу, рутирање и складиштење порука.

Основне компоненте:

• Произвођач (Producer): Шаље поруке у RabbitMQ.
• Разменик (Exchange): Прима поруке од произвођача и их усмерава у једну или више редова на основу правила рутирања.
• Ред (Queue): Чува поруке док их корисници не преузму.
• Корисник (Consumer): Прима поруке из редова за обраду.

Типови разменика:

• Direct: Усмерава поруке у редове где кључ рутирања тачно одговара кључу везе реда.
• Fanout: Усмерава поруке у све повезане редове, игноришући кључ рутирања.
• Topic: Усмерава поруке на основу делимичног поклапања кључа рутирања са шаблоном кључа везе (користећи симболе * и #).
• Headers: Усмерава поруке на основу заглавља поруке, а не кључа рутирања.

Примена у PHP:

• Одложена обрада задатака: нпр. слање емаилова, генерисање извештаја, обрада слика.
• Микросервисна архитектура: Асиметрична комуникација између сервиса.
• Системи у реалном времену: Обрада великог тока догађаја.
• Расподела оптерећења: Расподела задатака међу више радника.

Пример слања поруке помоћу библиотеке 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] Poslato '" . $data . "'\n";

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

Пример пријема поруке:

<?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 " [*] Чекање на поруке. За излаз натисните CTRL+C\n";

$callback = function ($msg) {
    echo " [x] Примљено '" . $msg->body . "'\n";
};

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

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

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

RabbitMQ обезбеђује отпорност на отказе, скалабилност и флексибилност у пројектовању распоређених система.