Что такое RabbitMQ?

Так, слушай, про RabbitMQ, да? Это ж, блядь, такая штука, которая как почтальон Печкин между твоими программами, только не тупой, а с гарантией доставки. Суть в чём: одна программа плюёт сообщением, а другая его ловит, и им вообще похуй друг на друга, они даже не в курсе, кто где живёт. Красота же!

Основная фишка — он решает проблемы, от которых обычный код просто обосрётся. Например, когда один сервис отвалился, а второй продолжает слать ему запросы. Тут RabbitMQ встаёт как буфер: принимает всё это добро, складывает в очередь и ждёт, пока получатель очухается. Ничего не теряется, все довольны. Гарантированная доставка, ёпта! Сообщения можно и на диск скинуть, чтобы даже если кролик (брокер) внезапно сдох — после перезагрузки всё продолжилось.

Архитектура у него, внатуре, простая, как три копейки. Представь себе почтовое отделение:

1. Producer (Отправитель) — это ты с посылкой. Принёс.
2. Exchange (Сортировочный узел) — это тётка за стеклом. Ты ей говоришь: «На деревню дедушке». Это routing key. Она смотрит на правила (bindings) и решает, в какую именно корзину (queue) твою посылку закинуть.
3. Queue (Очередь, корзина) — вот она, корзина с надписью «Для дедушки». Там твоё сообщение и лежит, ждёт.
4. Consumer (Получатель) — это собственно дедушка. Приходит, заглядывает в свою корзину, забирает посылку и говорит «Получил!» (ack). Только тогда посылку из корзины выкидывают.

А типов этих самых «сортировочных узлов» (exchanges) несколько, и от этого вся магия:

• direct — «Отнеси конкретно Васе». Ключ маршрутизации должен совпасть точь-в-точь.
• fanout — «Разошли копию всем, кто подписан». Похуй на ключ, просто разослал всем.
• topic — «Отнеси всем, кто живёт в доме №5, на любом этаже». Ключ — это шаблон типа house.5.*.
• headers — Вообще поехавший тип, там смотрится не ключ, а заголовки сообщения. На любителя.

Держи пример на C#, чтобы вообще всё встало на свои места. Вот один сервис кричит в лог об ошибке:

// Продюсер. Тот, кто паникует и шлёт сообщение.
using RabbitMQ.Client;

// Подключаемся к кролику на локалхосте
var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

// Объявляем тот самый сортировочный узел (exchange) типа 'direct' и зовём его 'logs'
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Direct);

// Готовим сообщение. Ключ маршрутизации - 'error', само сообщение - текст ошибки
var severity = "error";
var message = $"[{DateTime.UtcNow}] Критическая хуйня в модуле X!";
var body = Encoding.UTF8.GetBytes(message);

// Публикуем! Кидаем в exchange 'logs' с ключом 'error'
channel.BasicPublish(exchange: "logs",
                     routingKey: severity,
                     basicProperties: null,
                     body: body);
Console.WriteLine($" [x] Отправил '{severity}':'{message}'");

А вот где-то в другом месте, может, даже на другом сервере, сидит потребитель и слушает только ошибки:

// Консьюмер. Тот, кто слушает и паникует уже осознанно.
// ... подключение и канал создаются так же ...

// Важно! Объявляем ТОТ ЖЕ exchange. Он должен существовать.
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Direct);

// Создаём временную очередь. Её имя RabbitMQ придумает сам (типа 'amq.gen-J4tZ...')
var queueName = channel.QueueDeclare().QueueName;

// ПРИВЯЗЫВАЕМ эту очередь к exchange 'logs' с КОНКРЕТНЫМ ключом 'error'.
// Теперь в эту очередь будут лететь ТОЛЬКО сообщения с ключом 'error'.
channel.QueueBind(queue: queueName,
                  exchange: "logs",
                  routingKey: "error");

// Подписываемся на получение сообщений
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
    var body = ea.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    // Вот она, наша ошибка!
    Console.WriteLine($" [x] Получил '{ea.RoutingKey}':'{message}'");

    // РУЧНОЕ подтверждение! Говорим кролику: «Всё, брат, обработал, можешь удалять из очереди».
    // Если autoAck=true и твой код упадёт ДО обработки — сообщение потеряется нахуй. Вот поэтому false.
    channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
};

// Начинаем слушать очередь. autoAck: false — это ОЧЕНЬ важно для надёжности!
channel.BasicConsume(queue: queueName,
                     autoAck: false,
                     consumer: consumer);

Console.WriteLine("Жду ошибок... Нажми Enter чтобы выйти.");
Console.ReadLine();

Короче, RabbitMQ — это, блядь, фундамент для всяких микросервисных и событийных архитектур, где всё бегает, падает и перезапускается. Он всех мирит и обеспечивает порядок. Без него — пиздец и ручное управление, а с ним — хоть какая-то надежда на стабильность.