Что такое RabbitMQ?

RabbitMQ — это брокер сообщений, имплементирующий протокол AMQP (Advanced Message Queuing Protocol). Он позволяет приложениям асинхронно взаимодействовать, отправляя и получая сообщения через централизованную систему. RabbitMQ обеспечивает надежную доставку, маршрутизацию и хранение сообщений.

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

• Производитель (Producer): Отправляет сообщения в RabbitMQ.
• Обменник (Exchange): Получает сообщения от произведетелей и направляет их в одну или несколько очередей на основе правил маршрутизации (binding).
• Очередь (Queue): Хранит сообщения до тех пор, пока их не заберут потребители.
• Потребитель (Consumer): Получает сообщения из очередей для обработки.

Типы обменников:

• Direct: Маршрутизирует сообщения в очереди, где ключ маршрутизации сообщения точно совпадает с ключом привязки очереди.
• Fanout: Маршрутизирует сообщения во все привязанные очереди, игнорируя ключ маршрутизации.
• Topic: Маршрутизирует сообщения на основе частичного совпадения ключа маршрутизации сообщения с шаблоном ключа привязки очереди (с использованием символов * и #).
• Headers: Маршрутизирует сообщения на основе заголовков сообщения, а не ключа маршрутизации.

Применение в PHP-разработке:

• Отложенная обработка задач: Например, отправка email, генерация отчетов, обработка изображений.
• Микросервисная архитектура: Асинхронное взаимодействие между сервисами.
• Системы реального времени: Обработка большого потока событий.
• Балансировка нагрузки: Распределение задач между несколькими работниками.

Пример отправки сообщения с помощью библиотеки 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] Отправлено '" . $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 обеспечивает отказоустойчивость, масштабируемость и гибкость в проектировании распределенных систем.