CQRS и уведомление по электронной почте

Question

Чтение на CQRS есть много разговоров об уведомлении по электронной почте - мне интересно, откуда получить данные. Представьте себе senario, где один пользователь приглашает других пользователей к событию. Чтобы сообщить пользователю, что он был приглашен на мероприятие, ему отправлено электронное письмо.

Конкретные шаги могут пойти как это:

1. CreateEvent команда с соответствующей коллекцией пользователей Invite, принимается сервером.
2. Создается новый агрегат Meeting и вызывается метод InviteUser для каждого пользователя, который должен быть приглашен.
3. Каждый раз, когда пользователь приглашен на мероприятие, возникает событие домена UserWasInvitedToEvent.
4. Отправитель уведомления электронной почты принимает событие домена и отправляет уведомление по электронной почте.

Теперь, мой вопрос заключается в следующем: куда мне обратиться за информацией для включения в электронную почту?

Скажите, что я хочу включить описание события, а также имя пользователя. Поскольку это CQRS, я не могу получить его через мою модель домена; Все свойства объектов домена являются частными! Должен ли я затем запрашивать чтение? Или, возможно, переадресовать уведомление по электронной почте на другую услугу?

Answer 1

В CQRS вы отделяете команду от запроса. Вы всегда захотите перейти на страницу запроса, чтобы получить данные для данного обработчика событий. База данных записи будет представлять собой отдельную базу данных, содержащую данные, необходимые для создания объектов домена и не будет оптимизирована для чтения, но для записи.

1. Домен должен регистрироваться и отправлять событие EventCreated обработчикам событий/процессорам. Это может быть поднято из конструктора агрегата Meeting.
2. Компонент обработки событий получит событие EventCreated и обновит базу данных запроса данными, содержащимися в событии (т. Е. Идентификатором события и его именем).
3. Этот объект может зарегистрироваться и отправлена ​​информация о событиях UserWasInvitedToEvent.
4. Процессоры событий собирают UserWasInvitedToEvent и обновляют хранилище запросов с необходимыми данными отчетности.
5. Другой компонент обработки событий также получит событие UserWasInvitedToEvent. Этот процесс может иметь доступ к базе данных запросов и отбрасывать все данные, необходимые для отправки электронной почты.

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

Для того чтобы организовать несколько разных событий в одном обработчике (при условии, что события могут быть обработаны в другом порядке в разное время), вы можете использовать концепцию Saga в своей шине обмена сообщениями. NServiceBus является примером шины обмена сообщениями, которая supports Saga's. См. Также этот вопрос StackOverflow: NServiceBus Delayed Message Processing.