В CQRS как работать с NServiceBus для обновления хранилища команд и запросов

Question

В CQRS, как вы убедитесь, что обработчик команд обновляет хранилище записи и читает хранилище транзакционно?

Я не уверен, что эти два шага являются сделками? Или вы полагаетесь на возможную последовательность здесь? Что означает, что магазин чтения будет обновлен в конце концов?

Каков (или) общий способ сделать это с помощью NServiceBus 5 или 6?

В нашем приложении у нас есть IRepository<T> (Добавить, Обновить) для командной строки для обновления базы данных Sql Server. Запрос прост. База данных и фасад поверх структуры Entity Framework DbContext.

шагов на стороне команды будут:

1. MVC контроллер получает данные от View
2. действия контроллера создает объект Command/сообщение и отправляет его на шину.
3. Правильный обработчик команд создает соответствующий объект домена и выполняет проверку на нем.
4. Если это действительно так, использует IRepository для вставки или обновления базы данных.
5. Теперь что?

Это должно быть сага в NServiceBus, где шаги 1 и 2 обновляют хранилище команд и читают хранилище?

спасибо.

Answer 1

Поток я вижу следующее:

• контроллер принимает действие и выдает команду в командной шине
• правильный обработчик команд увольняют и модели записи обновляются
• в обработчик команды, событие вызывается
• правильный обработчик событий увольняют и модель чтения обновляется

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

Надеюсь, что это поможет! Удачи!