Когда нужно использовать брокер сообщений (Message Broker)?

Брокер сообщений — это промежуточное ПО для асинхронного обмена сообщениями между компонентами системы. Его внедрение целесообразно в следующих архитектурных сценариях:

Основные use-cases:

1. Развязка сервисов (Decoupling): Когда микросервисы или модули приложения не должны знать о существовании друг друга и общаться напрямую. Брокер выступает посредником.

   • Плюс: Повышает отказоустойчивость — падение потребителя не влияет на отправителя.

2. Асинхронная обработка задач (Background Jobs / Task Queues): Для выполнения длительных операций (отправка email, обработка видео, генерация PDF) вне контекста HTTP-запроса.

   // Producer (Web Controller)
   public async Task<IActionResult> GenerateReport() {
       var reportId = Guid.NewGuid();
       await _bus.Publish(new GenerateReportCommand { ReportId = reportId });
       return Accepted(reportId); // Возвращаем 202 Accepted сразу.
   }
   // Consumer (Фоновый worker-сервис) обрабатывает команду.

3. Балансировка нагрузки (Load Balancing): Очередь сообщений позволяет иметь несколько экземпляров потребителя (Consumer), которые параллельно обрабатывают задачи, распределяя нагрузку.

4. Гарантированная доставка (Guaranteed Delivery): Когда критически важно не потерять сообщение даже при сбоях. Брокеры сохраняют сообщения на диск и подтверждают получение потребителем (acknowledgment).

5. Шаблон «Издатель-Подписчик» (Pub/Sub): Когда одно событие должно быть обработано несколькими независимыми системами.

   • Пример: Событие OrderPlaced может обрабатываться сервисом уведомлений, сервисом аналитики и сервисом рекомендаций одновременно.

Популярные технологии и их выбор:

• RabbitMQ (AMQP): Классический брокер для очередей задач и сложной маршрутизации. Отлично подходит для RPC и рабочих очередей.
• Apache Kafka: Скорее распределенный лог commit-ов. Идеален для потоковой обработки данных, событийного мостинга и аналитики в реальном времени, где важна пропускная способность и порядок сообщений.
• Azure Service Bus / AWS SQS: Управляемые облачные сервисы, которые снимают с разработчика операционную нагрузку.

Когда НЕ нужен брокер: Для простых монолитных приложений с синхронными вызовами, где нет проблем с производительностью и связностью. Добавление брокера добавляет сложность (операционную и в коде).