aggregateidentifier的分布式使用

Question

一般来说，这似乎是有效的，因为当我在第二个服务中发送命令时，它会被接收并更新状态。由于我可以使用EventSourcingHandler还可以使用在另一个服务中创建的事件来操作它的状态，所以我从第一个服务聚合应用的源中获取状态信息。

我担心快照机制会对我不利，但显然它足够聪明，只要我确保聚合的“类型”名称不相同，就可以单独存储快照。

到目前为止，一切都很好，唯一让我感觉到的是，第二个聚合没有（需要）初始构造函数CommandHandler，因为创建是在第一个聚合中完成的。

@Aggregate
@Getter
@NoArgsConstructor
public class Foo {

  @AggregateIdentifier
  private String fooIdentifier;

  @CommandHandler
  public Foo(CreateFooCommand command) {
    apply(FooCreatedEvent.builder()
      .fooIdentifier(command.getFooIdentifier())
      .build());
  }

  @EventSourcingHandler
  public void on(FooCreatedEvent event) {
    this.fooIdentifier = event.getFooIdentifier();
  }

}


@Aggregate
@Getter
@NoArgsConstructor
public class Bar {

  @AggregateIdentifier
  private String fooIdentifier;

  private String barProperty;

  @CommandHandler
  public void on(UpdateBarCommand command) {

    apply(BarUpdatedEvent.builder()
      .fooIdentifier(this.fooIdentifier)
      .barProperty(command.getBarProperty())
      .build());
  }

  @EventSourcingHandler
  public void on(FooCreatedEvent event) {
    this.fooIdentifier = event.getFooIdentifier();
  }

  @EventSourcingHandler
  public void on(BarUpdatedEvent event) {
    this.barProperty = event.getBarProperty();
  }

}

因此，我现在唯一的选择就是上面提到的，或者使用创建第二个聚合来设置不同的aggregateId，但也可以在内部添加第一个聚合的aggregateId，以允许将第一个聚合的aggregateId信息作为引用ID发布事件。为了实现这一功能，我必须保留一个投影来在两个标识符之间来回映射，这看起来也不太好。

提前谢谢，拉斯·卡尔森

Answer 1

你想出了一个很有趣的解决方案。我不能说我曾经在这样一个庄园中拆分聚合逻辑，即一个服务创建它，另一个服务加载相同的事件，以它自己的形式重新创建该状态。

那么，我是否违背了axon框架打算使用聚合的方式，或者这是一个可行的用例？

老实说，我不认为这会是预期的用法。与其说是因为Axon，不如说是因为您所使用的术语Bounded Context。在上下文之间，您应该非常有意识地共享，因为每个上下文的术语（普遍存在的语言）都是不同的。您的事件本质上是该语言的一部分，因此我通常不会建议与另一个服务共享聚合流的全部。

由于我不能为相同的聚合标识符但不同的聚合类型发布两次创建事件（构造函数中的CommandHandler，序列0)，所以我不能完全分离这两个状态。

这行提示您希望在不同的聚合之间重用聚合标识符，这也在问题的标题中出现。正如您所注意到的，[聚合标识符，序列号]对需要是唯一的。因此，不能为不同类型的聚合重用聚合标识符。但是，要知道Axon将使用聚合标识符类的toString方法来填充聚合标识符字段。因此，如果将toString()方法调整为包含聚合类型，则可以保持唯一性要求，并仍然重用聚合标识符。

例如，包含UUID的VehicleID类的ToString方法通常会输出以下内容：

null

• vehhleid[684EC9F4-B9F8-11EA-B3DE-0242AC130004]

最后，我想分享以下三点：

1. Axon框架无意重用聚合流来重新创建不同的聚合类型。
2. 聚类聚合可能是解决此方案的一种方法。
3. [aggregateId,seqNo]唯一性要求可以重用aggregateId，只要toString方法将聚合类型追加/前置到结果。