spring-boot - 轴突事件溯源的理解

Question

我一直在学习轴突和事件溯源，我想我终于理解了其中的一部分，这在我的脑海中是有道理的，但我想确保我对它的理解是正确的，并且我没有犯任何错误。代码有效，我也可以在 DOMAIN_EVENT_ENTRY 表中看到事件。
我将在下面发布我的代码(文档中的简单礼品卡示例)并解释我的思考过程。如果我没有正确理解它，请您帮助我以正确的方式理解该部分。
我没有包含命令/事件，因为它们非常简单，包含 id、amount 字段
首先我的代码:
测试运行程序

package com.example.demoaxon;

import java.util.UUID;

import org.axonframework.commandhandling.gateway.CommandGateway;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j
public class TestRunner implements CommandLineRunner {
    
    private final CommandGateway commandGateway;
    
    @Autowired
    public TestRunner(CommandGateway commandGateway) {
        this.commandGateway = commandGateway;
    }
    
    @Override
    public void run(String... args) throws Exception {
        log.info("send command");
        String id = UUID.randomUUID().toString();
        commandGateway.sendAndWait(new IssueCardCommand(id,100));
        commandGateway.sendAndWait(new RedeemCardCommand(id,90));
        
    }
}

礼品卡.java

package com.example.demoaxon;

import org.axonframework.commandhandling.CommandHandler;
import org.axonframework.eventsourcing.EventSourcingHandler;
import org.axonframework.modelling.command.AggregateIdentifier;
import static org.axonframework.modelling.command.AggregateLifecycle.apply;
import org.axonframework.spring.stereotype.Aggregate;

import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;

@NoArgsConstructor
@Aggregate
@Slf4j
public class GiftCard {
    
    @AggregateIdentifier
    private String giftCardId;
    private Integer amount;
    
    @CommandHandler
    public GiftCard(IssueCardCommand cmd) {
        log.info("handling {}",cmd);
        apply(new CardIssuedEvent(cmd.getCardId(),cmd.getAmount()));
    }
    
    @EventSourcingHandler
    public void onCardIssuedEvent(CardIssuedEvent evt) {
        log.info("applying {}",evt);
        this.giftCardId = evt.getCardId();
        this.amount = evt.getAmount();
    }
    
    @CommandHandler
    public void redeemCardCommandHandler(RedeemCardCommand cmd) {
        log.info("handling {}",cmd);
        this.amount -= cmd.getAmount();
        apply(new CardRedeemedEvent(cmd.getCardId(),cmd.getTransactionId(),this.amount));
    }
    
    @EventSourcingHandler
    public void onCardRedeemedEvent(CardRedeemedEvent evt) {
        log.info("applying {}",evt);
        this.amount = evt.getAmount();
    }   
}

据我了解:

在我的 TestRunner类，命令网关调度 issueCardCommand到它CommandHandler使用命令总线，然后创建 GiftCard 的新实例总计的。在此 CommandHandler我们可以执行任何逻辑，然后我们使用这个 apply方法。

apply(event)方法用于发布CardIssuedEvent作为 EventMessage在GiftCard范围内聚合，它还调用 EventSourcingHandler对于那个特定事件，所以在这种情况下 onCardIssuedEvent .它将 EventMessage 发布到 EventBus 并发送到 EventHandlers。

在 @EventSourcingHandler onCardIssuedEvent ，我们可以对 GiftCard 进行任何状态更改聚合，我们还将事件持久化到 DOMAIN_EVENT_ENTRY使用 spring Jpa 的表。

一旦这个CommandHandler执行完毕，聚合对象不再存在。

现在在我的 TestRunner再次上课，命令网关调度 RedeemCardCommand到其 CommandHandler并且由于第一个命令不再存在，因此使用空的 no args 构造函数来创建对象。轴突框架从此 DOMAIN_EVENT_ENTRY 中检索所有事件表并重放 GiftCard 的所有事件 (EventSourcingHandlers)聚合实例以获得它的当前状态(这就是 @AggregateIdentifier 很重要的原因)。

RedeemCardCommandHandler然后执行方法，它执行任何逻辑并应用事件，该事件在聚合中发布并调用它的 EventSourcingHandler .此 EventSourcingHandler然后更新 GiftCard 的状态聚合/持续到 DOMAIN_EVENT_ENTRY table 。

我对事件溯源如何工作的理解正确吗？

Answer 1

让我试着引导你完成这段旅程!
你的理解几乎完全正确。为了更好地理解，我只想将其拆分为 Event Sourcing 和 Axon。

事件采购

简而言之，事件溯源是一种通过过去发生的事件历史来存储应用程序状态的方式。请记住，您还有其他模式，例如状态存储聚合。
在您的示例中，您使用的是事件溯源，因此为什么 @EventSourcingHandler s 到位。现在进入下一个话题。

轴突

我建议您阅读本文 awesome blog通过我们的一位同事，特别是其中包含的幻灯片，您将看到 Axon 框架内的消息旅程!
现在谈到你的观点，我想事先澄清一些事情:

正确，您发送了 Command并且由于注释的方法是一个构造函数，它将为您创建一个聚合。 CommandHanlder s 是业务逻辑和验证的正确位置。

这里apply将在内部发布消息(到这个 Aggregate 也到他们的 Entities/AggregateMember s)然后再发布到 EventBus .来自 javadoc:

The event should be applied to the aggregate immediately and scheduled for publication to other event handlers.

由于我们在谈论事件溯源，所有 EventSourcingHandler s 将被调用，并且 Aggregate 的状态修改/更新。这很重要，因为如前所述，这是您在需要时重建聚合状态的方式。但是事件的持久化不会在这里发生，它已经被安排在这个过程完成时发生。

正确的。

也正确。这通常与事件溯源以及它如何重建您的 Aggregate 有关。 .

也更正第 3 点的观察，关于事件何时发布/保存/持久化。

代码中的另一个小注意事项:您在 @CommandHandler 上执行此操作

@CommandHandler
public void redeemCardCommandHandler(RedeemCardCommand cmd) {
    log.info("handling {}", cmd);
    this.amount -= cmd.getAmount(); // you should not do this here
    apply(new CardRedeemedEvent(cmd.getCardId(), cmd.getTransactionId(), this.amount));
}

此状态更改应在 @EventSourcingHandler 中进行。 .关于 @CommandHandler如果这个聚合有足够的“钱”可以赎回，你应该只做验证:)