CQRS - Как обрабатывать запросы, которые меняют состояние системы

Question

У меня есть ситуация в проекте CQRS, где я должен регистрировать запрос пользователя для информации (запроса), а затем, при необходимости, запускать рабочий процесс на основе ответа из хранилища данных. Пользователь делает запрос на получение информации, которая требует немедленной обратной связи. В то же время система дополнительно запускает рабочий процесс для анализа запроса. Как это реализовать в CQRS, поскольку запрос не является «чистым» запросом или «чистой» командой?

Edit: Чтобы добавить некоторый контекст к этому: Приложение как приложения поиска, где пользователь вводит запрос и возвращает приложение с результатом. Но приложение также регистрирует запрос и может запускать рабочий процесс в зависимости от ответа с сервера. Приложение также «запоминает» последние несколько запросов пользователя и использует его для предоставления контекста новому запросу.

Кроме того, ответ запроса может быть несинхронным. Фоновый работник может нести ответственность за доставку результата клиенту.

Answer 1

Хотя вы дали нам немного работать с Я думаю, что этот вопрос имеет простой ответ:

Я не согласен с вами, что запрос не является ни «чистый» запрос, ни команда «чистой». Запрос является чистым запросом, потому что запрос не является запросом для анализа, а запросом информации. Анализ, который по желанию запускается запросом, представляет собой команду, но команду в контексте события запроса. Таким образом, система, или, более конкретно, обработчик событий, является актером в контексте команды, а не пользователем, который является актером в контексте запроса.

Никакого запроса никогда не бывает побочным эффектом. Это намерение делает запрос.

Answer 2

Такой запрос command.

В простом ООП я часто моделировал такое сообщение как метод void с параметрами out.

Например, в финансовой модели, у меня был консультативный контракт (сущность и совокупный корень) принуждая правила строить финансовые рекомендации (сущность, неизменная). Pubblication дефинитивной recommentation был смоделирован с помощью команды, как это:

public interface IAdvisoryContract 
{ 
    ContractNumber Number { get; } 

    // lot of well documented commands and queries here... 

    /// 90 lines of documentation here... 
    void PublishRecommendation(
       IUser advisor, IAssetClassBreakdownAnalysis assetClassAnalysis, 
       IVolatilityAnalysis tevAnalysis, Time time, 
       out IRecommendation newRecommendation); 

    event EventHandler<EventArgs<RecommendationNumber>> RecommendationPublished; 
} 

В CQRS это зависит от инфраструктуры: например, в аналогичной ситуации по HTTP, я использовал POST возвращая соответствующую информацию клиента ,

Answer 3

Как насчет после выполнения запроса отправить сообщение для уведомления? Я, вероятно, буду использовать декоратор, такой как:

public QueryRs query(QueryRq rq) { 
    final QueryRs rs = target.query(rq); 
    notifier.notifyQueryDone(rs); 
} 

И сделайте рабочий процесс подписанием и употреблением сообщения. Я не уверен, что этот запрос считается изменением состояния в этом решении?