Что такое маршрутизация сообщений в RabbitMQ?

# Маршрутизация сообщений в RabbitMQ

Маршрутизация сообщений — это механизм определения того, каким образом сообщение доставляется от издателя (publisher) к одному или нескольким потребителям (consumer) в RabbitMQ. Она основана на взаимодействии exchange (обменника), queues (очередей) и bindings (привязок) с использованием routing keys (ключей маршрутизации) или headers (заголовков).

Основные компоненты маршрутизации

Exchange

Exchange принимает сообщения от издателей и направляет их в очереди. Тип exchange определяет алгоритм маршрутизации.

Queue

Очередь хранит сообщения до их обработки потребителем.

Binding

Привязка — это связь между exchange и queue, которая определяет правила маршрутизации.

Типы Exchange и их стратегии маршрутизации

Direct Exchange

Сообщение отправляется в очереди, чья привязка имеет routing key, полностью совпадающий с routing key сообщения. Используется для точной адресации.

// Пример создания Direct Exchange в .NET (using RabbitMQ.Client)
var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

channel.ExchangeDeclare("direct_logs", ExchangeType.Direct);

// Публикация с routing key "error"
var body = Encoding.UTF8.GetBytes("Critical error occurred!");
channel.BasicPublish(exchange: "direct_logs",
                     routingKey: "error",
                     basicProperties: null,
                     body: body);

Fanout Exchange

Сообщение рассылается во все очереди, привязанные к этому exchange, игнорируя routing key. Используется для широковещательной передачи.

channel.ExchangeDeclare("fanout_notifications", ExchangeType.Fanout);
// Сообщение получит все очереди, привязанные к "fanout_notifications"
channel.BasicPublish(exchange: "fanout_notifications",
                     routingKey: "", // игнорируется
                     basicProperties: null,
                     body: body);

Topic Exchange

Сообщение направляется в очереди на основе pattern matching между routing key сообщения и pattern привязки. Pattern содержит слова разделенные точками и поддерживает wildcards:

• * — заменяет одно слово.
• # — заменяет zero или более слов.

channel.ExchangeDeclare("topic_orders", ExchangeType.Topic);
// Привязка queue с pattern "order.eu.*"
// Сообщение с routing key "order.eu.paid" попадет в эту очередь
channel.BasicPublish(exchange: "topic_orders",
                     routingKey: "order.eu.paid",
                     basicProperties: null,
                     body: body);

Headers Exchange

Маршрутизация основана на headers сообщения (атрибутах в basicProperties.Headers), а не на routing key. Привязка использует условия сопоставления (x-match аргумент: all или any).

var properties = channel.CreateBasicProperties();
properties.Headers = new Dictionary<string, object>
{
    { "format", "pdf" },
    { "priority", "high" }
};

channel.ExchangeDeclare("headers_docs", ExchangeType.Headers);
// Привязка queue с условием: "format" == "pdf" AND "priority" == "high" (x-match=all)
channel.BasicPublish(exchange: "headers_docs",
                     routingKey: "", // игнорируется
                     basicProperties: properties,
                     body: body);

Процесс маршрутизации

1. Издатель отправляет сообщение в exchange, указывая routing key (или заголовки).
2. Exchange оценивает сообщение согласно своему типу и правилам привязок.
3. Сообщение направляется в одну или несколько очереди, удовлетворяющих условиям.
4. Потребители получают сообщения из своих очередей.

Пример сложной маршрутизации с Topic Exchange

// Привязки нескольких очередей к Topic Exchange "events"
// Queue "security" с pattern "security.*"
// Queue "errors" с pattern "*.error"
// Queue "all_events" с pattern "#"

// Сообщение с routing key "security.login" попадет в "security" и "all_events"
// Сообщение с routing key "app.error" попадет в "errors" и "all_events"
// Сообщение с routing key "security.auth.error" попадет во все три очереди

Практические применения

• Direct: Точечные команды (например, обработка конкретного заказа по ID).
• Fanout: Рассылка уведомлений всем подписчикам системы.
• Topic: Сложные системы событий с категоризацией (например, логирование по уровням и компонентам).
• Headers: Маршрутизация по метаданным (тип файла, язык, регион), когда routing key недостаточно.

Ключевые особенности в .NET (RabbitMQ.Client)

• Используйте ExchangeDeclare для создания exchange с нужным типом.
• BasicPublish требует указания exchange и routing key.
• Для headers установка basicProperties.Headers и объявление exchange как Headers.
• Привязки (QueueBind) устанавливаются потребителями или административно.

Маршрутизация сообщений — это фундаментальная концепция RabbitMQ, обеспечивающая гибкость и мощность в распределении сообщений между компонентами системы. Выбор правильного типа exchange и грамотное использование routing key/headers позволяют строить эффективные и масштабируемые event-driven архитектуры.