Обязательная механика: снапшоты (не проигрывать миллион событий), оптимистичная блокировка по версии потока (конкурентные команды), версионирование и апкастинг событий. Записанные события не редактируют.
А ещё Персональные данные: крипто-шреддинг — шифровать ключом пользователя и удалить ключ
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Снапшоты. Состояние агрегата получается применением всех его событий. Для длинных потоков это дорого, поэтому периодически (каждые N событий) сохраняют снапшот и при загрузке применяют только события после него. Снапшот — оптимизация: его можно удалить и пересобрать.
Конкурентность. Две команды к одному агрегату читают его на версии 41 и обе хотят записать событие 42. Хранилище событий принимает добавление с ожидаемой версией: второе получит конфликт, перечитает агрегат и повторит команду или откажет. Это оптимистичная блокировка на уровне потока.
Версионирование — самая недооценённая часть. События записаны навсегда, а код меняется: поле переименовали, добавили обязательное. Подходы:
Неизменяемость. Ошибочное событие не исправляют, а компенсируют новым (СписаниеОтменено). Отсюда проблема права на удаление данных: решают крипто-шреддингом — персональные данные шифруются ключом пользователя, а для «удаления» уничтожается ключ.
Ещё: глобальный порядок событий обычно не нужен и дорог — порядок гарантируется внутри потока агрегата; публикация событий для проекций — через подписки хранилища или outbox.
Несколько верных вариантов. Подумайте, потом откройте ответ.
Разделение моделей чтения и записи, цена рассинхронизации, событие как источник истины, снапшоты и версионирование событий, и честный ответ на вопрос «когда это не нужно».
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto