cqrs - 是否可以使用 CQRS 直接从 Axon 聚合的命令处理程序运行查询？

Question

这更像是一个与 CQRS 和 Axon 相关的理论问题。下面是一个不言自明的设置，代码是 伪代码 ，它并不意味着编译。
假设为了处理来自聚合“Foo”的命令，我们首先需要查询另一个聚合“Bar”的状态以进行验证(来自另一个有界上下文，所以这不是简单查找“Foo”的问题' s 成员聚合)。
我们在这里有两个选择，如伪代码所示。选择 (1)，我们只是使用查询网关从“Foo”聚合中的命令处理程序运行查询。
选择(2)，我们应用一个事件来请求一个专门的服务来处理查询而不是“Foo”。然后，该服务将在向系统查询“Bar”状态后将命令发送回“Foo”。
第一个选择( 从命令处理程序直接查询 )似乎违背了命令-查询分离的整个想法——毕竟，这样我们在命令处理期间执行查询，对吗？
第二种选择似乎更符合 CQRS 的精神:该命令只会导致一个事件(稍后将导致另一个命令等)。但显然，这是有代价的:涉及更多步骤，2a、2b、2c、2d ......
我想听听社区对此有何看法。对我来说，如果我们严格要求不将命令与查询处理混合，但允许在命令处理中执行查询，这似乎很奇怪。还是我错过了什么？

@Aggregate
class AggregateFoo {

    private QueryGateway queryGateway;

    @CommandHandler
    public void on(UpdateFooCommand command){

        /*
            Assume that in order to validate this command we first need
            to query the state of another aggregate, "Bar".
        */

        // 1. We can just issue the query directly from the command handler.

        queryGateway
            .query(new AskForStateOfBarQuery(command.getBarId()))
            .then(queryResponse -> {
                // Proceed with original command execution depending
                // the result of the query response.    
            });

        // 2a. Or we can issue an intermediate EVENT offloading the query handling
        //     to a dedicated service ("FooBarService", see below).

        AggregateLifecycle.apply(new FooUpdateValidationRequestedEvent(command.getBarId()));

    }

    // 2d. "Foo" aggregate will react to the validation command from the
    //     dedicated service effectively executing the original command.

    @CommandHandler
    public void on(ProceedWithFooUpdateCommand command){

        // Do other validations, issue events here. At this
        // point we know that UpdateFooCommand was validated.
    } 

}

@Service
class FooBarService {

    private QueryGateway queryGateway;
    private CommandGateway commandGateway;

    @EventHandler
    public void on(FooUpdateValidationRequestedEvent event){
        
        // 2b. The dedicated service will run the corresponding query,
        //     asking for the state of "Bar".
        
        queryGateway
            .query(new AskForStateOfBarQuery(command.getBarId()))
            .then(queryResponse -> {

                // 2c. And will issue a COMMAND to the "Foo" aggregate
                //     indicating that it shoud proceed with the original 
                //     command's (UpdateFooCommand) execution.

                commandGateway.send(new ProceedWithFooUpdateCommand(command.getFooId()));

            });

    }

}

更新:
这是讨论 91stefan 给出的信息性答案后的更新(见下文)。

class AggregateFoo {
    int f = 9;

    // reference to the related Bar aggregate
    UUID bar;

    on(UpdateFooCommand){
        // Assume we must execute ONLY IF f < 10 AND bar.b > 10.
        // So we apply event to Saga (with f = 9), 
        // Saga will ask Bar: (b = 15), so the condition holds
        // and Saga issues ConfirmValidBarStateCommand
    }

    // Meanwhile, when Saga is busy validating, we process another
    // command CHANGING the state of Foo
    on(AnotherCommand) { f++; }

    // or "ConfirmValidBarStateCommand" as in 91stefan's example
    on(ProceedWithFooUpdateCommand){
        // So when we get back here (from Saga), there is no guarantee
        // that the actual state of Foo (f < 10) still holds,
        // and that we can proceed with the execution of the
        // original UpdateFooCommand
    }

}

class AggregateBar {
    int b = 15;
}

所以看起来这个问题仍然存在:如果它的验证依赖于另一个有界上下文中的 Bar 状态，如何在 Foo 中一致地验证和执行命令？看起来我们在这里可能有几个选择:

从 Foo 的命令处理程序直接查询 Bar

的投影状态

事件到(无状态)服务，该服务向 Bar 查询投影状态

(91stefan 的建议)向 Saga 发送验证命令到 Bar

的事件

Answer 1

您可能会遇到问题，从命令处理程序查询不被认为是一种好的做法，因为由于最终的一致性，您的投影可能不是最新的。此外，来自同一聚合的命令处理程序按顺序/同步执行。您只想做一些快速的事情，调用外部服务将阻塞并阻止其他命令聚合执行，直到当前命令处理程序完成执行。
在这种情况下，您需要的是 Saga。
https://docs.axoniq.io/reference-guide/v/3.3/part-ii-domain-logic/sagas
简化流程将是:

commandHandler(UpdateFooCommand) -> applyEvent(AskedForStateOfBarEvent)

AskedForStateOfBarEvent 开始 Saga

在 saga 中，向 Bar 聚合发送命令 -> ConfirmYourStateBar(barAggregateId)

commandHandler(ConfirmYourStateBar) -> 验证状态 -> applyEvent(StateIsValidatedEvent)

Saga 对 StateIsValidatedEvent 使用react，将命令发送到 AggregateFoo -> (ConfirmValidBarStateCommand(aggreageFooId) & saga 已关闭(结束事件是 StateIsValidatedEvent)

在 commandHandler(ConfirmValidBarStateCommand) 中，您继续执行，因为您的状态 BAR 状态有效