轴突状态存储聚集在测试中的异常

Question

环境设置:Axon4.4，H2Database（作为CI的一部分，我们正在进行组件测试）代码如下所示。

    @Aggregate(repository = "ARepository")
    @Entity
    @DynamicUpdate
    @Table(name = "A")
    @Getter
    @Setter
    @NoArgsConstructor
    @EqualsAndHashCode(onlyExplicitlyIncluded = true, callSuper = false)
    @Log4j2
    Class A implements Serializable {
    
    
      @CommandHandler
      public void handle(final Command1 c1) {
        apply(EventBuilder.buildEvent(c1));
      }
    
      @EventSourcingHandler
      public void on(final Event1 e1) {
      //some updates to the modela
        apply(new Event2());
      }
    
      @Id
      @AggregateIdentifier
      @EntityId
      @Column(name = "id", length = 40, nullable = false)
      private String id;
    
       @OneToMany(
          cascade = CascadeType.ALL,
          fetch = FetchType.LAZY,
          orphanRemoval = true,
          targetEntity = B.class,
          mappedBy = "id")
      @AggregateMember(eventForwardingMode = ForwardMatchingInstances.class)
      @JsonIgnoreProperties("id")
      private List<C> transactions = new ArrayList<>();
    }
    
    @Entity
    @Table(name = "B")
    @DynamicUpdate
    @Getter
    @Setter
    @NoArgsConstructor
    @EqualsAndHashCode(onlyExplicitlyIncluded = true, callSuper = false)
    @Log4j2
    Class B implements Serializable {
    
      @Id
      @EntityId
      @Column(name = "id", nullable = false)
      @AggregateIdentifier
      private String id;
    
      @ManyToOne(fetch = FetchType.LAZY)
      @JoinColumns({@JoinColumn(name = "id", referencedColumnName = "id")})
      @JsonIgnoreProperties("transactions")
      private A a;
    
      @EventSourcingHandler
      public void on(final Event2 e2) {
       //some updates to the model
      }
    }

我使用的是一个状态存储聚合，但在Spring测试中使用嵌入式H2时，我总是随机地得到错误。在非嵌入式模式下，PGSQL DB不会出现同样的问题，但我们无法在流水线中运行它。

    protected <P> EventMessage<P> createMessage(P payload, MetaData metaData) {
            if (lastKnownSequence != null) {
                String type = inspector.declaredType(rootType())
                                       .orElse(rootType().getSimpleName());
                long seq = lastKnownSequence + 1;
                String id = identifierAsString();
                if (id == null) {
                    Assert.state(seq == 0,
                                 () -> "The aggregate identifier has not been set. It must be set at the latest when applying the creation event");
                    return new LazyIdentifierDomainEventMessage<>(type, seq, payload, metaData);
                }
                return new GenericDomainEventMessage<>(type, identifierAsString(), seq, payload, metaData);
            }
            return new GenericEventMessage<>(payload, metaData);
        }

这有什么解决办法？我是否遗漏了一些配置或需要修复Axon代码？

Answer 1

我相信您得到的异常是指向您缺少的@Rohitdev的指针。在Axon中创建聚合时，它至少假设您将设置聚合标识符。因此，您将填写聚合中存在的@aggregateIdentifier注释字段。

这是一个强制验证，因为如果没有聚合标识符，您基本上就缺少了对聚合的外部引用。因此，您只需将以下命令分派到该集合，因为没有路由它们的方法。

从您共享的代码片段中，没有任何东西表明在聚合A或B中设置了@aggregateIdentifier注释的字符串ID字段。如果不结合使用Axon的测试夹具来执行此操作，将导致您得到异常。

最后，您的示例仍然使用@EventSourcingHandler注释函数，当您有事件源聚合时应该使用这些函数。听起来您有意识地做出了反对事件源的决定，因此我也不会在您的模型中使用这些注释。现在，开发人员可能只会迷惑于使用状态存储聚合逻辑和事件源聚合逻辑的混合。