Как определяется маршрутизация сообщений в RabbitMQ (куда отправляется сообщение)?

Давай разберём эту вашу маршрутизацию в RabbitMQ, а то как её обычно объясняют — глаза на лоб лезут. Представь себе почтовое отделение, только для данных, и все там слегка ебнутые.

Вот смотри, есть три главных героя в этой пьесе: Издатель (Publisher), Обменник (Exchange) и Очередь (Queue). Так вот, издатель — он вообще палец о палец не ударит, чтобы напрямую в очередь что-то сунуть. Нет, блядь. Он как барский сынок: принёс посылку (сообщение), швырнул её в окошко обменника и сказал: «Вот тебе ключ маршрутизации (Routing Key), разбирайся, куда это, я пошёл». И всё. А обменник уже, бедолага, с этой хуйней разбирается.

Обменник (Exchange) — это такой диспетчер-шизофреник. У него несколько личностей, в зависимости от типа. Он получает сообщение, смотрит на ключ и решает, в какие очереди его пихнуть. А связывает его с очередью волшебная ниточка под названием Binding (Привязка), в которой иногда прописан ключ привязки (Binding Key). Вот их он и сравнивает с ключом маршрутизации.

Очередь (Queue) — это просто ящик. Тупо хранилище, где сообщения лежат и ждут, пока их заберёт потребитель (Consumer). Всё гениальное просто.

А теперь самое интересное — типы обменников. От этого зависит, как они эту всю хуйню маршрутизируют.

Типы обменников: кто во что горазд

Примеры из жизни, то есть из кода

Вот смотри, как это выглядит, когда ты это пишешь (используем библиотеку RabbitMQ.Client).

1. Издатель шлёт заказ через Direct Exchange Представь, ты сервис заказов. Нужно отправить заказ из ЕС на обработку.

using var channel = connection.CreateModel();

// Объявляем Direct Exchange. Название "order.direct", тип — Direct, durable: true чтобы пережил перезагрузку.
channel.ExchangeDeclare(exchange: "order.direct", type: ExchangeType.Direct, durable: true);

// Само сообщение
var message = "Order data...";
var body = Encoding.UTF8.GetBytes(message);
// Ключ маршрутизации. Как адрес на конверте.
var routingKey = "orders.eu";

// Публикуем! Швыряем в обменник "order.direct" с ключом "orders.eu".
// Сообщение найдёт очередь, которая привязана к этому обменнику с ТОЧНО ТАКИМ ЖЕ Binding Key.
channel.BasicPublish(exchange: "order.direct",
                     routingKey: routingKey,
                     basicProperties: null,
                     body: body);

2. Потребитель слушает логи ошибок через Topic Exchange А вот сервис для сбора логов. Хочет получать только ошибки от любых приложений.

using var channel = connection.CreateModel();

// Объявляем Topic Exchange для логов.
channel.ExchangeDeclare(exchange: "logs.topic", type: ExchangeType.Topic);

// Создаём временную, уникальную очередь для этого экземпляра сервиса.
var queueName = channel.QueueDeclare().QueueName;

// ВЯЖЕМ! Это самое главное. Привязываем нашу очередь к обменнику "logs.topic"
// с Binding Key "*.error". Звёздочка (*) — любое одно слово, "error" — обязательно.
// Значит, очередь получит ВСЕ сообщения, где Routing Key: "payment.error", "auth.error", "gateway.error" и т.д.
channel.QueueBind(queue: queueName,
                  exchange: "logs.topic",
                  routingKey: "*.error");

// Вешаем потребителя
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
    var body = ea.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    // В ea.RoutingKey будет полный ключ, например "payment.error"
    Console.WriteLine($"[ERROR from {ea.RoutingKey}] {message}");
};
channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);

Краткие итоги, чтобы не облажаться

• Имена — всему голова. Называй обменники понятно: notifications.fanout, commands.direct, events.user.topic. Не exchange1, блядь.
• Topic — твой лучший друг для событийной архитектуры. Гибко, мощно, можно делать сложные подписки.
• Fanout — это «на всех». Идеален, когда одно событие должно триггернуть кучу независимых действий у разных сервисов.
• Не забывай про durable. Если очередь или обменник должны пережить перезапуск брокера — ставь durable: true. Иначе после ребута всё накроется медным тазом, и ты будешь искать, куда делись твои сообщения.