对 Axon 事件溯源的理解

Question

我一直在学习轴突和事件溯源，我想我终于理解了其中的一部分，并且在我的头脑中它是有意义的，但我想确保我对它的理解是正确的并且我没有犯任何错误。该代码有效，我也可以在 DOMAIN_EVENT_ENTRY 表中看到事件。

我将在下面发布我的代码（文档中的简单礼品卡示例）并解释我的思考过程。如果我没有正确理解它，请您帮助我以正确的方式理解该部分。

我没有包含命令/事件，因为它们非常简单，包含 id、金额字段

首先是我的代码：

测试运行器.java

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();
    }   
}

据我所知：

1. 在我的TestRunner班级中，命令网关使用命令总线将其分派issueCardCommand给它CommandHandler，然后创建聚合的新实例GiftCard。在这里CommandHandler我们可以执行任何逻辑，然后我们使用这个apply方法。

2. 该apply(event)方法用于将 发布CardIssuedEvent为聚合EventMessage范围内的an GiftCard，并且它还EventSourcingHandler为该特定事件调用 ，因此在本例中为onCardIssuedEvent。它将 EventMessage 发布到 EventBus 并发送到 EventHandler。

3. 在 中@EventSourcingHandler onCardIssuedEvent，我们可以对聚合进行任何状态更改GiftCard，并且我们还使用 spring Jpa 将事件持久保存到表中DOMAIN_EVENT_ENTRY。

4. 一旦CommandHandler执行完成，聚合对象就不再存在。

5. 现在再次在我的TestRunner类中，命令网关将 分派RedeemCardCommand给它CommandHandler，并且由于第一个命令不再存在，因此使用空的无参数构造函数来创建对象。axon 框架从该DOMAIN_EVENT_ENTRY表中检索所有事件，并重播GiftCard聚合实例的所有事件 (EventSourcingHandlers)，以便获取其当前状态（这就是为什么它@AggregateIdentifier很重要）。

6. 然后执行该RedeemCardCommandHandler方法，它执行任何逻辑并应用事件，该事件在聚合内发布并调用它的EventSourcingHandler. 然后，这会将聚合/持久化EventSourcingHandler的状态更新到表中。GiftCardDOMAIN_EVENT_ENTRY

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

Answer 1

让我尝试引导您完成这段旅程！

\n

你的理解几乎完全正确。我只想将其分为事件源和 Axon，以便更好地理解。

\n

\n
• 事件溯源
\n

\n

简而言之，事件溯源是一种通过过去发生的事件历史来存储应用程序\xe2\x80\x99s状态的方法。请记住，您还有其他模式，例如状态存储聚合。\n在您的示例中，您正在使用事件源，因此需要@EventSourcingHandlers 。现在进入下一个主题。

\n

\n
• 轴突
\n

\n

我建议您阅读我们一位同事写的这篇很棒的博客，特别是其中包含的幻灯片，您将看到 Axon 框架内消息的旅程！

\n

现在就您的观点而言，我想预先澄清一些事情：

\n

\n
1. 正确，您分派了 a Command，并且由于注释的方法是构造函数，因此它将为您创建一个聚合。CommandHanlders 是业务逻辑和验证的正确位置。
\n
2. 在这里，他们apply将在内部发布消息（向此Aggregate，也向他们的Entities/ AggregateMembers），然后再发布到EventBus. 来自javadoc：
\n

\n

\n

该事件应立即应用于聚合并计划发布到其他事件处理程序。

\n

\n

\n

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

   \n
\n

4. 正确的。

   \n
\n

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

   \n
\n

6. 还纠正了第 3 点中关于事件何时发布/保存/保留的观察结果。

   \n
\n

\n\n

关于您的代码的另一个小注释：您正在您的@CommandHandler

\n

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

\n

此状态更改应在@EventSourcingHandler. @CommandHandler仅当该聚合有足够的“钱”可供兑换时，您才应该进行验证:)

\n