事件溯源和 cqrs 与 eventstore db

如何解决事件溯源和 cqrs 与 eventstore db

store db 和 event-sourcing，但我对预测和 cqrs 有疑问。 到目前为止，这是我调用我的突击队和我的命令处理程序的方式：

创建用户命令

export class CreateUserCommand implements ICommand {
  constructor(
    public readonly userDto: UserStruct,) {}
}

命令处理程序：

export class CreateUserHandler implements ICommandHandler<CreateUserCommand> {
  constructor(private readonly publisher: EventPublisher) {}

  async execute(command: CreateUserCommand) {
    const { userDto } = command;
    const user = User.create(userDto);
        console.log(user.value)
    if (user.isLeft()) throw user.value;
    const userPublisher = this.publisher.mergeObjectContext(user.value);
        userPublisher.commit()
  }
}

事件：

export class UserCreatedEvent implements IEvent {
  static readonly NAME = "UniFtcIdade/user-registered";
  readonly $name = UserCreatedEvent.NAME;
  readonly $version = 0;
  constructor(
    public readonly aggregateId: string,public readonly state: { email: string; name: string },public readonly date: Date
  ) {
  }
}

域：

export class User extends AggregateRoot {
  public readonly name: string;
  public readonly email: string;

  private constructor (guid: string,name: string,email: string) {
    super()
    this.apply(new UserCreatedEvent(guid,{email,name},new Date()));
  }
  static create(
    dto: UserStruct
  ): Either<InvalidNameError | InvalidEmailError,User> {
    const name: Either<InvalidNameError,Name> = Name.create(dto.name);
    const email: Either<InvalidEmailError,Email> = Email.create(dto.email);
    if (name.isLeft()) return left(name.value);
    if (email.isLeft()) return left(email.value);
    const user = new User(v4(),name.value.value,email.value.value);
    return right(user);
  }
}

但我对预测如何进入这种情况表示怀疑。 投影用于获取聚合的当前状态 ??? 我应该有一个 db 作为 mongodb 来保存当前状态，也就是说，每次我调用我的命令处理程序并更改 mongodb 中的当前状态时？？？ 这是 eventstoredb 的投影吗？保存聚合的当前状态 ??

解决方法

在 CQRS 中，当使用 EventStoreDb 时，您的聚合必须设计为从事件恢复到状态。事件存储在具有唯一名称和标识符 (guid) 的流中。修改聚合时，您必须读取此流，并按顺序应用每个事件以恢复当前状态，然后再对聚合执行任何更改（这会生成更多事件）。为了保持完整性并处理乐观并发，您应该在聚合中进行简单的版本检查，以计算旧事件 + 新事件，以确定要持久化的最新版本号。

我在上面看到的问题如下。 您的聚合有一个构造函数和一个静态方法，该方法生成事件而不对当前状态进行任何验证，即：如果我使用相同的 guid 调用 create 两次会发生什么？

this.apply(new UserCreatedEvent(guid,{email,name},new Date()));

您在此处直接应用状态。相反，您应该在 Create 方法中引发事件。

this.raiseEvent(new UserCreatedEvent(guid,new Date()));

这应该被实现以执行以下操作。

• 添加到未提交事件列表
• this.apply 被调用

然后，您应该将事件保存到命令处理程序中的 EventStoreDb。

async execute(command: CreateUserCommand) {
    const { userDto } = command;
    const user = eventRepository.Get<User>(command.Id);
    user.Create(userDto); // Can now check current state and fail if required.
    eventRepository.Save(user)
  }

这里的存储库很简单。它可以创建一个空的 User 并在返回用户之前按顺序应用所有事件。 保存应该只是读取未提交的事件列表并将它们保存到用户流中。

命令端就这样完成了， 对于读取端，您可以使用所有用户的开箱即用类别投影，并将它们写入 mongo 以供不同的 API（而不是您的命令处理程序）读取。