时间戳

首页 > 解决方案 > Axon 框架：在命令处理程序期间仅应用第一个事件

axon - Axon 框架：在命令处理程序期间仅应用第一个事件

问题描述

我正在尝试创建一个将命令视为多个子命令的命令处理程序。每个子命令将生成一个事件（然后应该更新聚合的状态）。每个子命令的处理依赖于聚合的最新状态（来自上一个子命令）。

例如，考虑以下聚合：

package axon.poc

import org.axonframework.commandhandling.CommandHandler
import org.axonframework.eventsourcing.EventSourcingHandler
import org.axonframework.modelling.command.AggregateIdentifier
import org.axonframework.modelling.command.AggregateLifecycle
import org.axonframework.spring.stereotype.Aggregate
import org.slf4j.LoggerFactory
import java.util.UUID

@Aggregate
class Aggregate() {

    companion object {
        private val logger = LoggerFactory.getLogger(Aggregate::class.java)
    }

    @AggregateIdentifier
    internal var aggregateId: UUID? = null

    private var value: Int = 0

    @CommandHandler
    constructor(command: Command): this() {
        logger.info("generating create event")
        var applyMore = AggregateLifecycle.apply(CreatedEvent(command.aggregateId))
        for (i in 0 until command.value) {
            applyMore = applyMore.andThenApply {
                logger.info("generating update event: ${value+1}")
                UpdatedEvent(command.aggregateId, value+1)
            }
        }
        logger.info("completed command handler")
    }

    @EventSourcingHandler
    fun on(event: CreatedEvent) {
        logger.info("event sourcing handler: $event")
        this.aggregateId = event.aggregateId
        this.value = 0
    }

    @EventSourcingHandler
    fun on(event: UpdatedEvent) {
        logger.info("event sourcing handler: $event")
        this.value = event.value
    }

}

什么时候Command(value = 2)由此代码处理时，它会生成

[main] INFO org.axonframework.spring.stereotype.Aggregate - generating create event
[main] INFO org.axonframework.spring.stereotype.Aggregate - completed command handler
[main] INFO org.axonframework.spring.stereotype.Aggregate - event sourcing handler: CreatedEvent(aggregateId=65a7a461-61bb-451f-b2d9-8460994eeb1a)
[main] INFO org.axonframework.spring.stereotype.Aggregate - generating update event: 1
[main] INFO org.axonframework.spring.stereotype.Aggregate - generating update event: 1
[main] INFO org.axonframework.spring.stereotype.Aggregate - event sourcing handler: UpdatedEvent(aggregateId=65a7a461-61bb-451f-b2d9-8460994eeb1a, value=1)
[main] INFO org.axonframework.spring.stereotype.Aggregate - event sourcing handler: UpdatedEvent(aggregateId=65a7a461-61bb-451f-b2d9-8460994eeb1a, value=1)

第一个事件（CreatedEvent）在applyMore执行之前被处理。然而，即使applyMore被链接，UpdatedEvent事件源处理程序也不会处理 '，直到两者都已生成。

我期待（并希望）：

[main] INFO org.axonframework.spring.stereotype.Aggregate - generating create event
[main] INFO org.axonframework.spring.stereotype.Aggregate - completed command handler
[main] INFO org.axonframework.spring.stereotype.Aggregate - event sourcing handler: CreatedEvent(aggregateId=65a7a461-61bb-451f-b2d9-8460994eeb1a)
[main] INFO org.axonframework.spring.stereotype.Aggregate - generating update event: 1
[main] INFO org.axonframework.spring.stereotype.Aggregate - event sourcing handler: UpdatedEvent(aggregateId=65a7a461-61bb-451f-b2d9-8460994eeb1a, value=1)
[main] INFO org.axonframework.spring.stereotype.Aggregate - generating update event: 2
[main] INFO org.axonframework.spring.stereotype.Aggregate - event sourcing handler: UpdatedEvent(aggregateId=65a7a461-61bb-451f-b2d9-8460994eeb1a, value=2)

这是 Axon 的错误吗？还是我误解了应该如何使用它？如何以原子方式处理多个“命令”？IE。全部通过或全部失败。

标签： axon

解决方案

TLDR；这是一个错误。

您遇到了仅在构造函数中发生的非常特殊的情况。从 Axon 的角度来看，挑战在于您需要一个实例来应用事件。但是，该实例仅在构造函数完成后才可用。

该andThenApply功能正是为此目的而提供的（并且您正在正确使用它）。但是，在您的情况下，代码被（错误地）评估得太早了。我必须在本地运行您的代码并进行调试以找出究竟发生了什么。

根本原因是andThenApply执行AnnotatedAggregate调用apply，而不是publish。前者将看到它当前正在执行延迟任务，并在这些任务结束时安排实际发布。下一个任务也是如此。因此，这两个事件最终都首先被创建，然后在它们都被创建后发布。

您是否有兴趣将此作为问题提交到Axon 问题跟踪器中？这样，学分就会流向它们所属的地方。

推荐阅读