Что делать, если события приходят не по порядку — например, сначала событие "Success/Paid/Done", а потом более старое "Pending"?

Проблема неупорядоченных событий

В распределённых системах события часто доставляются асинхронно, и порядок их получения может отличаться от порядка создания. Например, событие Success может прийти раньше, чем Pending, что нарушает логику обработки. Без специальных мер это приведёт к некорректному состоянию бизнес-процесса.

Основные подходы к решению

• Монотонные номера (sequence numbers): каждое событие получает уникальный возрастающий номер, и обработчик игнорирует события с номером меньше уже обработанного.
• Временные метки: если события содержат время создания, можно сортировать их перед обработкой или отклонять устаревшие.
• Идемпотентность: обработчик должен быть устойчив к повторной доставке, чтобы одно и то же событие не меняло состояние дважды.
• Хранение состояния и версионирование: вместо обработки каждого события изолированно, система хранит текущее состояние и применяет события в правильном порядке, используя версии.

Практический пример

Допустим, у нас есть заказ, и события Pending и Success приходят в обратном порядке. Используем sequence number:

let lastProcessedSeq = 0;
const state = { status: 'unknown' };

function handleEvent(event) {
  if (event.seq <= lastProcessedSeq) return; // игнорируем устаревшие
  if (event.type === 'Pending' && state.status !== 'Success') {
    state.status = 'Pending';
  } else if (event.type === 'Success') {
    state.status = 'Success';
  }
  lastProcessedSeq = event.seq;
}

handleEvent({ type: 'Success', seq: 2 }); // state.status = 'Success'
handleEvent({ type: 'Pending', seq: 1 }); // игнорируется, seq <= lastProcessedSeq

Здесь мы не даём более старому событию перезаписать новое состояние.

Где это применяется

Подходы используются в event-driven архитектурах, системах на основе event sourcing, очередях сообщений (Kafka, RabbitMQ), а также при интеграции микросервисов. Например, в платёжных системах важно, чтобы финальный статус не был перезаписан более ранним событием.

Вывод

Для корректной обработки неупорядоченных событий необходимо внедрять механизмы упорядочивания (sequence numbers, временные метки) и идемпотентность. Это гарантирует согласованность данных и предотвращает ошибки, связанные с поздней доставкой событий.