带有 axon-spring-boot-starter 的 NoHandlerForCommandException

Question

我正在使用 Axon + Spring Boot 创建一个简单的应用程序，只是为了确保我在实际项目中使用它之前了解 Axon 框架中的基本组件。在 class TaskAggregate 中有一个用 @CommandHandler 注释的方法，当我通过 CommandGateway 发送命令时应该调用它，但是在运行应用程序之后我得到异常：

Exception in thread "main" org.axonframework.commandhandling.NoHandlerForCommandException: No handler was subscribed to command [com.xxx.axontest.task.CreateTaskCommand]

根据文档，@CommandHandler 注释应该足以将命令处理程序订阅到命令总线。我想我一定是错过了什么。你能看看下面的代码并指出正确的方向吗？

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.xxx</groupId>
    <artifactId>axon-test</artifactId>
    <version>0.0.1-SNAPSHOT</version>

    <properties>
        <axon.version>3.0.6</axon.version>
    </properties>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.7.RELEASE</version>
    </parent>

    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
                <groupId>org.axonframework</groupId>
                <artifactId>axon-spring-boot-starter</artifactId>
                <version>${axon.version}</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

App.java

package com.xxx.axontest;

import org.axonframework.commandhandling.gateway.CommandGateway;
import org.axonframework.eventsourcing.eventstore.EventStorageEngine;
import org.axonframework.eventsourcing.eventstore.inmemory.InMemoryEventStorageEngine;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;

import com.xxx.axontest.task.CreateTaskCommand;

@SpringBootApplication
public class App {

    public static void main(String[] args) {
        ConfigurableApplicationContext configurableApplicationContext = SpringApplication.run(App.class, args);
        CommandGateway commandGateway = configurableApplicationContext.getBean(CommandGateway.class);
        commandGateway.send(new CreateTaskCommand(123, "asd"));
    }

    @Bean
    public EventStorageEngine eventStorageEngine() {
        return new InMemoryEventStorageEngine();
    }

    @Bean
    public AnnotationCommandHandlerBeanPostProcessor 
 annotationCommandHandlerBeanPostProcessor() {
    return new AnnotationCommandHandlerBeanPostProcessor();
    }
}

CreateTaskCommand.java

package com.xxx.axontest.task;

import org.axonframework.commandhandling.TargetAggregateIdentifier;

public class CreateTaskCommand {

    @TargetAggregateIdentifier
    private int taskId;
    private String name;

    public CreateTaskCommand(int taskId, String name) {
        this.taskId = taskId;
        this.name = name;
    }

    public int getTaskId() {
        return taskId;
    }

    public String getName() {
        return name;
    }   
}

TaskCreatedEvent.java

package com.xxx.axontest.task;

import org.axonframework.commandhandling.TargetAggregateIdentifier;

public class TaskCreatedEvent {

    @TargetAggregateIdentifier
    private int taskId;
    private String name;

    public int getTaskId() {
        return taskId;
    }

    public String getName() {
        return name;
    }

}

TaskAggregate.java

package com.xxx.axontest.task;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.axonframework.commandhandling.CommandHandler;
import org.axonframework.commandhandling.model.AggregateIdentifier;
import org.axonframework.commandhandling.model.AggregateLifecycle;
import org.axonframework.eventsourcing.EventSourcingHandler;
import org.axonframework.spring.stereotype.Aggregate;

@AggregateRoot
public class TaskAggregate {

    private Logger logger = LogManager.getLogger(TaskCreatedEvent.class);

    @AggregateIdentifier
    private int taskId;
    private String name;

    @CommandHandler
    public void handleCommand(CreateTaskCommand createTaskCommand) {
        logger.info("Command received");
        AggregateLifecycle.apply(new TaskCreatedEvent());
    }

    @EventSourcingHandler
    public void onTaskCreatedEvent(TaskCreatedEvent taskCreatedEvent) {
        logger.info("Event received");
    }

    public int getTaskId() {
        return taskId;
    }

    public void setTaskId(int taskId) {
        this.taskId = taskId;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

}

提前致谢。

Answer 1

您还需要将处理程序注册到命令总线。我发现 this tutorial 应该对你有帮助。从那里快速突出显示：

@Configuration 
public class AppConfiguration { 

    @Bean  
    public SimpleCommandBus commandBus() { 
        SimpleCommandBus simpleCommandBus = new SimpleCommandBus(); 
        // This manually subscribes the command handler: 
        // DebitAccountHandler to the commandbus.  
        simpleCommandBus.subscribe(DebitAccount.class.getName(), new DebitAccountHandler()); 
        return simpleCommandBus;  
    }
}

P.S。一件重要的事情：事件和命令应该是不可变的（没有设置器）

Answer 2

我认为您需要使用@Aggregate 而不是@AggregateRoot 来注释聚合。 @Aggregate 作为注释既是 @AggregateRoot 注释，但也被 Spring Boot Axon Starter 模块用来表示 class 聚合工厂和 Repository 必须创建。此外，这意味着您聚合上的 @CommandHandler 注释函数也将被发现并注册到 CommandBus，可能会解决您捕获的异常。

否则，Allard 在 YouTube 上关于在版本 3 中启动 Axon 应用程序的 webinars 可能会给您一些见解。

但是，简而言之，尝试将 @AggregateRoot 注释切换为 @Aggregate :-)

此外，您应该将 CreateTaskCommand 的 @CommandHandler 注释函数调整为 TaskAggregate 的构造函数。最后，Axon 要求您有一个用于聚合的无参数构造函数，因此还要在其中添加一个 public TaskAggregate() { } 构造函数。

Answer 3

基于以上代码，几点说明：

您不需要提供 AnnotationCommandHandlerBeanPostProcessor。事实上，指定一个可能会干扰 Axon/Spring 引导自动配置
创建新聚合实例的命令应放在构造函数中。目前还没有调用方法的实例。请注意，您将（也）必须指定一个无参数构造函数。
taskId 应该由@EventSourcingHandler 设置。 Getters 和 Setters 不属于（事件来源的）聚合
在事件中，您不需要指定@TargetAggregateIdentifier。它们只是命令的手段。

鉴于您提供的代码，我无法解释此异常，但有可能是显式定义的 AnnotationCommandHandlerBeanPostProcessor 造成了阻碍。

[已编辑] Steven 正确地注意到了 @AggregateRoot 注释。它应该是@Aggregate。以上评论仍然有效，但与异常没有直接关系[/Edited]

Answer 4

Bases on the comments

我会分享修改后的实际代码。

@Aggregate
public class TaskAggregate {

    private Logger logger = LogManager.getLogger(TaskCreatedEvent.class);

    @AggregateIdentifier
    private int taskId;

    private String name;

    TaskAggregate(){ // default constructor needed for axon
    }

    @CommandHandler
    public void TaskAggregate(CreateTaskCommand createTaskCommand) {
        logger.info("Command received");
        AggregateLifecycle.apply(new TaskCreatedEvent());
    }

    @EventSourcingHandler
    public void onTaskCreatedEvent(TaskCreatedEvent taskCreatedEvent) {
        logger.info("Event received");
        this.name = taskCreatedEvent; // use this to set the aggregate meber than get and setter.
    }

}

@CommandHandler CreateTaskCommand 的注释函数是 TaskAggregate 的构造函数。最后，Axon 要求您有一个 no-arg constructor 用于聚合，因此还要添加一个 public TaskAggregate() { }那里的构造函数。

带有 axon-spring-boot-starter 的 NoHandlerForCommandException

NoHandlerForCommandException with axon-spring-boot-starter

spring

spring-boot

cqrs

axon

spring-boot-starter