命令处理程序只是从总线接收命令并发布事件吗？

Question

我实际上是CQRS和事件来源的新手。

当我看到以下代码时，我被命令处理程序弄得一头雾水：

@AllArgsConstructor
@NoArgsConstructor
@Getter
@Aggregate
public class BankAccountAggregate {

    @AggregateIdentifier
    private UUID id;
    private BigDecimal balance;
    private String owner;

    @CommandHandler
    public BankAccountAggregate(CreateAccountCommand command){
        AggregateLifecycle.apply(
                new AccountCreatedEvent(
                        command.getAccountId(),
                        command.getInitialBalance(),
                        command.getOwner()
                )
        );
    }

@Slf4j
@RequiredArgsConstructor
@Component
public class BankAccountProjection {

    private final BankAccountRepository repository;
    private final QueryUpdateEmitter updateEmitter;


    @EventHandler
    public void on(AccountCreatedEvent event) throws Exception {
        log.debug("Handling a Bank Account creation command {}", event.getId());
        BankAccount bankAccount = new BankAccount(
                event.getId(),
                event.getOwner(),
                event.getInitialBalance()
        );
        this.repository.save(bankAccount);
        Boolean isActive =  AggregateLifecycle.isLive();

    }
}

null

那么我们为什么不把帐户创建的逻辑放在命令处理程序中呢？这样做的目的是什么？

完整的源代码在这个链接。

Answer 1

你在混合一些概念。让我们把它们弄清楚。

如果你实现了事件来源，这意味着你的真相来源是事件本身。您存储的是事件，而不是具体的“状态”（实体）。让我们看看一些伪代码：

创建新帐户：

function createAccount(data) {
  event = new AccountCreatedEvent(data)
  eventStore.save(event)
}

  function withdraw(data) {
    events = eventStore.getEvents(data.accountId)
    account = new Account()
    account.apply(events)
    account.withdraw(data)
    newEvents = account.newEvents
    eventStore.save(newEvents)
  }

class Account {

  amount = 0
  newEvents = []

  function apply(events) {
    events.forEach(event => {
      if event == AccountCreatedEvent {
        this.amount = event.initialAmount
      } else if (event == WithdrawalApplied) {
        this.amount = this.amount - event.amount
      } // more event types
    })
  }

  function withdraw(data) {
    // here is where you ensure aggregate invariants (business rules)
    if this.amount == 0 {
      throw Error("no money")
    }
    this.amount = this.amount - data.amount
    newEvents.add(new WithdrawalApplied(data))
  }

}

 

该命令处理程序只是发布一个事件。正如您所看到的，对象的命名是AccountCreatedEvent，但这并不意味着帐户已经创建，对吗？

答案是您应该将事件存储在命令处理程序中。这恰恰意味着账户被创建了。然后，如果需要，您可以在正在进行的过程中发布事件。继续读。

使用CQRS，您只需分离查询和命令，但这种技术可以在根本不需要事件源的情况下应用。

下图说明了三种技术(CQRS、事件来源和预测）是如何协同工作的。