💬 События публикуются дважды

Сервис сохраняет заказ в БД и сразу публикует событие OrderCreated. Выглядит логично, но БД и очередь это две отдельные системы.

Что может произойти: БД коммитилась, но публикация упала. Заказ есть, события нет. Клиент повторяет запрос из за таймаута. Событие публикуется еще раз. Нижестоящий сервис видит два события и создает два заказа вместо одного.

➡️ Решение: Outbox паттерн

Сохраняем заказ и событие в одной БД транзакции. Отдельный диспетчер читает неотправленные события и публикует их позже. Если диспетчер упадет или повторится, событие уже в БД и не потеряется.

// В одной транзакции
BEGIN
  INSERT INTO orders ...
  INSERT INTO outbox ...
COMMIT

// Отдельно
func dispatchOutbox() {
  events := store.GetUnsent()
  for _, e := range events {
    publisher.Send(e)
    store.MarkSent(e.ID)
  }
}

➡️ Ключевые моменты

Каждое событие должно иметь уникальный ID. Потребители должны быть идемпотентные (игнорировать дубликаты). Outbox паттерн гарантирует, что событие не потеряется, но не гарантирует ровно одну доставку. Это нормально, если потребители правильно обрабатывают дубликаты.

➡️ Что делать

Добавьте таблицу outbox. Вставляйте заказ и событие одной транзакцией. Запустите диспетчер, который периодически отправляет события из outbox. Добавьте уникальный event_id потребителям для фильтрации дубликатов.

Граница между микросервисами это самое опасное место. Outbox паттерн это простой способ сделать ее безопаснее.

📍 Навигация: Вакансии • Задачи • Собесы

🐸 Библиотека Go-разработчика

#GoToProduction