Брокеры

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

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

Синхронное: Клиент ждет ответ сразу. Пример — HTTP API. Асинхронное: Сервис отправляет сообщение и не ждет ответа. Пример — через брокер. Пример: Создание заказа → HTTP. Отправка уведомления → брокер.

Очередь — это структура, в которой сообщения обрабатываются по порядку. Producer — отправляет сообщение. Consumer — получает сообщение. Пример: Очередь заказов: Сообщения обрабатываются по одному.

Kafka — это распределенный брокер сообщений, ориентированный на потоковую обработку данных. Особенности: Высокая производительность. Работа с потоками данных. Хранение сообщений. Используется для: Логов. Аналитики. Событийных систем.

RabbitMQ — это брокер сообщений с очередями. Особенности: Гарантированная доставка. Гибкая маршрутизация сообщений. Используется для: Очередей задач. Интеграций между сервисами.

Producer — отправляет сообщение. Consumer — получает и обрабатывает сообщение. Пример: Сервис заказов — producer. Сервис уведомлений — consumer.

Kafka: Топик — это поток сообщений. RabbitMQ: Очередь — место хранения сообщений. Пример: Топик "orders" содержит события заказов.

Offset — это позиция сообщения в топике. Consumer читает сообщения по offset. Пример: Consumer прочитал до offset 100 → дальше читает с 101.

Сообщение не отправилось. Сообщение не обработалось. Дубли сообщений. Нарушение порядка. Потеря данных. Пример: Заказ создан, но уведомление не пришло.

Проверять: Отправку сообщения. Получение сообщения. Обработку сообщения. Данные внутри сообщения. Ошибки обработки. Пример: Создаем заказ → проверяем, появилось ли сообщение в брокере.

Проверить: Логи. Kafka UI / RabbitMQ UI. Консьюмер. Пример: После создания заказа проверяем топик orders.

Проверить: Действие после обработки. Логи consumer. Изменения в БД. Пример: После события → запись появилась в таблице notifications.

Нужно проверить: Сервис-отправитель. Брокер. Consumer. Логи. Данные. Пример: Сообщение есть в брокере → значит проблема в consumer.

Брокер сообщений — это промежуточный слой между сервисами, который позволяет им обмениваться данными асинхронно. Например, при создании заказа сервис отправляет событие в брокер, а другие сервисы (уведомления, аналитика) обрабатывают его независимо.

Логика проверки: 1. Проверить, создался ли заказ (БД). 2. Проверить, отправилось ли сообщение в брокер. 3. Проверить, есть ли сообщение в топике/очереди. 4. Проверить, обработал ли consumer сообщение. 5. Проверить логи. Вывод: Если сообщение есть в брокере, но нет уведомления → проблема в consumer.

Проверить: Количество отправленных сообщений. Количество обработанных сообщений. Сравнить данные. Пример: 10 заказов → должно быть 10 событий. Если меньше → потеря сообщений.

Проверить: Повторные записи в БД. Повторные события. Пример: Один заказ → два уведомления → проблема с повторной обработкой.