Axon Framework微服务间无法发布ModelCreatedEvent问题求助

我正在学习使用Axon Framework/Server实现微服务间的事件传递，构建Saga编排模式。目前已完成CreateModelCommand和ModelAggregate的实现，触发创建命令后能在Axon Dashboard看到命令执行记录，但未发现ModelCreatedEvent的发布痕迹。需要发布该事件，让另一个微服务接收并创建模型。

代码实现 #

CreateModelCommand #

@AllArgsConstructor
@Data
@NoArgsConstructor
public class CreateModelCommand {

    @TargetAggregateIdentifier
    private String sagaId;

    private String name;
}

ModelAggregate #

@AllArgsConstructor
@Aggregate
@Data
@NoArgsConstructor
public class ModelAggregate {

    @AggregateIdentifier
    private String sagaId;

    private String name;

    @CommandHandler
    public ModelAggregate(CreateModelCommand command) {
        ModelCreatedEvent event = new ModelCreatedEvent(
                command.getSagaId(),
                command.getName()
        );
        AggregateLifecycle.apply(event);
    }

    @EventSourcingHandler
    public void on(ModelCreatedEvent event) {
        this.sagaId = event.getSagaId();
        this.name = event.getName();
    }
}

共享事件ModelCreatedEvent #

@AllArgsConstructor
@Data
@NoArgsConstructor
public class ModelCreatedEvent {

    private String sagaId;

    private String name;
}

控制器 #

@RequestMapping("/api/v1")
@RequiredArgsConstructor
@RestController
public class Controller {

    private final CommandGateway commandGateway;

    @PostMapping
    public ResponseEntity<ResponseBody> createUser(@RequestBody RequestBody requestBody) {
        String sagaId = UUID.randomUUID().toString();
        CreateModelCommand command = new CreateModelCommand(
                sagaId,
                requestBody.name()
        );
        commandGateway.sendAndWait(command);
        return ResponseEntity.status(HttpStatus.CREATED).body(new ResponseBody(UUID.randomUUID()));
    }
}

Saga类 #

@Saga
public class ModelProcessingSaga {

    @SagaEventHandler(associationProperty = "sagaId")
    @StartSaga
    private void handle(ModelCreatedEvent event) {
        log.info("SAGA STARTED: %s".formatted(event.toString()));
    }
}

问题补充 #

第二个微服务中存在监听ModelCreatedEvent的EventHandler，该方法会根据事件属性调用模型创建方法。发送POST请求后，CreateModelCommand已触发，但始终看不到ModelCreatedEvent的发布。同时不确定这种微服务设计是否合理，只是希望集中编排创建命令，以便更轻松地处理关联模型。

排查与解决建议 #

1. 核心配置检查 #

• 确认所有微服务的Axon Server连接配置正确，确保事件能被Axon Server接收并跨服务转发。
• 检查ModelAggregate所在服务的启动类是否添加了@EnableAxon注解，启用Axon的核心功能。
• 验证ModelCreatedEvent的序列化配置：确保使用Axon默认Jackson序列化或自定义序列化器配置无错误，避免因序列化失败导致事件无法发布。

2. 日志与事件追踪 #

• 在ModelAggregate的CommandHandler中添加日志，确认AggregateLifecycle.apply(event)逻辑被执行：

  @CommandHandler
  public ModelAggregate(CreateModelCommand command) {
      log.info("Processing CreateModelCommand: {}", command);
      ModelCreatedEvent event = new ModelCreatedEvent(command.getSagaId(), command.getName());
      log.info("Applying ModelCreatedEvent: {}", event);
      AggregateLifecycle.apply(event);
  }
  

• 查看Axon Server的日志，搜索ModelCreatedEvent相关条目，确认事件是否被持久化或转发。
• 调整Axon Dashboard的Events面板过滤条件（如时间范围、事件名称），重新查找事件记录。

3. Saga与事件监听配置 #

• 确认ModelProcessingSaga所在服务已启用Saga支持，启动类添加@EnableAxon且Axon Server配置正确。
• 检查第二个微服务的事件监听方法是否使用@EventHandler注解，且方法参数严格匹配ModelCreatedEvent类型。
• 验证Saga的associationProperty配置：确保sagaId是ModelCreatedEvent中存在的属性，且名称拼写完全一致。

4. 设计合理性优化 #

• 当前用sagaId作为聚合根ID的设计可接受，但建议为聚合根设置独立ID（如modelId），将sagaId仅用于Saga生命周期关联，避免逻辑混淆。
• 集中编排创建命令的思路符合Saga核心思想，建议在Saga中明确后续命令调用逻辑（如调用第二个微服务的创建命令），而非仅监听事件。
• 确保Saga的生命周期与业务流程匹配，避免因聚合根状态变更导致Saga提前终止。

内容的提问来源于stack exchange，提问作者Oğuz Öztınaz