使用Axon的EventGateway发布事件后聚合@EventHandler不触发问题

核心问题原因 #

• 注解使用错误
  Axon聚合内用于响应事件、更新聚合状态的注解为@EventSourcingHandler，而非通用@EventHandler。通用@EventHandler仅会被注册为全局事件监听器，不会绑定到聚合生命周期，也无法关联到具体的聚合实例触发执行。
• 事件未关联对应聚合标识符
  你发布的OtherEvent类中，需要存在被@AggregateIdentifier注解修饰的字段，且该字段的值必须和你期望响应事件的SessionAggregate实例的ID完全一致。Axon需要通过该字段匹配到对应的聚合实例，才能执行对应的处理逻辑。
• 未开启事件溯源配置
  如果你的聚合没有启用事件溯源模式，聚合内部的事件处理逻辑本身就不会被触发，非事件溯源的聚合仅能通过命令触发状态变更。

修正代码示例 #

1. 调整OtherEvent，增加聚合标识字段

public class OtherEvent {
    @AggregateIdentifier
    private String sessionId; // 对应目标SessionAggregate的ID值

    public OtherEvent(String sessionId) {
        this.sessionId = sessionId;
    }
    // 其他getter、setter逻辑
}

2. 修正聚合类的事件处理注解

@Aggregate
public class SessionAggregate {
    @AggregateIdentifier
    private String sessionId; // 聚合唯一标识

    // 原有聚合逻辑

    @EventSourcingHandler // 替换原有的@EventHandler
    public void on(OtherEvent event){
        // 此时即可正常触发执行
    }
}

3. 外部发布事件时携带目标聚合ID

public class ExternalLogic {
    private final EventGateway eventGateway;

    public void execute(String targetSessionId) {
        // 其他逻辑
        eventGateway.publish(new OtherEvent(targetSessionId));
    }
}

注意：聚合是DDD中的命令模型，核心职责是接收命令、校验业务规则、生成领域事件。如果你的逻辑是要通过外部事件触发聚合的业务操作，更符合规范的实现方式是先注册一个全局的@EventHandler监听OtherEvent，再在该监听器中通过CommandGateway向目标聚合发送对应的命令，由命令触发聚合的状态变更，而非直接让聚合监听外部事件。

内容的提问来源于stack exchange，提问作者Kumi