如何从NestJS CQRS中失败的后续命令引发HTTP异常？

Question

我使用NestJS CQRS配方来管理两个实体之间的交互：User和UserProfile。该架构是一个API网关NestJS服务器+每个微服务(User、UserProfile等）的NestJS服务器。

我已经通过API Gateway上的User和UserProfile模块用它们自己的saga/events/命令建立了基本的交互：

null

如果后者失败，则引发UserProfileFailedToCreate事件并由UserProfile saga拦截，该事件将触发DeleteUser命令（来自用户模块）。

一切都很好。

如果CreateUser命令失败，I解析（promise.reject（new HttpException（error,error.status）），它向最终用户指示在用户创建过程中出了问题。

UserController.ts

@Post('createUser')
async createUser(@Body() createUserDto: CreateUserDto): Promise<{user: IAuthUser, token: string}> {
  const { authUser } = await this.authService.createAuthUser(createUserDto);
  // this is executed after resolve() in CreateUserCommand
  return {user: authUser, token: this.authService.createAccessTokenFromUser(authUser)};
}

userService.ts

async createAuthUser(createUserDto: CreateUserDto): Promise<{authUser: IAuthUser}> {
  return await this.commandBus
    .execute(new CreateAuthUserCommand(createUserDto))
    .catch(error => { throw new HttpException(error, error.status); });
}

CreateUserCommand.ts

async execute(command: CreateAuthUserCommand, resolve: (value?) => void) {
    const { createUserDto } = command;
    const createAuthUserDto: CreateAuthUserDto = {
      email: createUserDto.email,
      password: createUserDto.password,
      phoneNumber: createUserDto.phoneNumber,
    };

    try {
      const user = this.publisher.mergeObjectContext(
        await this.client
          .send<IAuthUser>({ cmd: 'createAuthUser' }, createAuthUserDto)
          .toPromise()
          .then((dbUser: IAuthUser) => {
            const {password, passwordConfirm, ...publicUser} = Object.assign(dbUser, createUserDto);
            return new AuthUser(publicUser);
          }),
      );
      user.notifyCreated();
      user.commit();
      resolve(user); // <== This makes the HTTP request return its reponse
    } catch (error) {
      resolve(Promise.reject(error));
    }
  }

authUserCreated = (event$: EventObservable<any>): Observable<ICommand> => {
    return event$
      .ofType(AuthUserCreatedEvent)
      .pipe(
        map(event => {
          const createUserProfileDto: CreateUserProfileDto = {
            avatarUrl: '',
            firstName: event.authUser.firstName,
            lastName: event.authUser.lastName,
            nationality: '',
            userId: event.authUser.id,
            username: event.authUser.username,
          };
          return new CreateUserProfileCommand(createUserProfileDto);
        }),
      );
  }

async execute(command: CreateUserProfileCommand, resolve: (value?) => void) {
    const { createUserProfileDto } = command;

    try {
      const userProfile = this.publisher.mergeObjectContext(
        await this.client
          .send<IUserProfile>({ cmd: 'createUserProfile' }, createUserProfileDto)
          .toPromise()
          .then((dbUserProfile: IUserProfile) => new UserProfile(dbUserProfile)),
      );
      userProfile.notifyCreated();
      userProfile.commit();
      resolve(userProfile);
    } catch (error) {
      const userProfile = this.publisher.mergeObjectContext(new UserProfile({id: createUserProfileDto.userId} as IUserProfile));
      userProfile.notifyFailedToCreate();
      userProfile.commit();
      resolve(Promise.reject(new HttpException(error, 500)).catch(() => {}));
    }
  }

userProfilesagas.ts

userProfileFailedToCreate = (event$: EventObservable<any>): Observable<ICommand> => {
    return event$
      .ofType(UserProfileFailedToCreateEvent)
      .pipe(
        map(event => {
          return new DeleteAuthUserCommand(event.userProfile);
        }),
      );
  }

DeleteUserCommand.ts

async execute(command: DeleteAuthUserCommand, resolve: (value?) => void) {
    const { deleteAuthUserDto } = command;

    try {
      const user = this.publisher.mergeObjectContext(
        await this.client
          .send<IAuthUser>({ cmd: 'deleteAuthUser' }, deleteAuthUserDto)
          .toPromise()
          .then(() => new AuthUser({} as IAuthUser)),
      );
      user.notifyDeleted();
      user.commit();
      resolve(user);
    } catch (error) {
      resolve(Promise.reject(new HttpException(error, error.status)).catch(() => {}));
    }
  }

Answer 1

用DDD术语来说，您对user和userprofile的创建构成了一个跨多个微服务的业务事务--一组必须一致的业务操作/规则。

在这种情况下，在创建userprofile之前返回数据库user意味着您返回的数据状态不一致。这不一定是错误的，但如果您这样做，您应该在客户机中适当地处理这一点。

我看到了三种可能的方法来处理这种情况：

>

您让SAGA运行，直到它们执行指示业务事务已结束的命令，然后才为客户机解析指示成功或失败的结果（例如，在错误详细信息中，您可以报告哪些步骤成功了，哪些步骤没有成功）。因此，您还没有在CreateAuthUserCommand中进行解析。

如果创建UserProfile可能需要很长时间（甚至需要由主持人手动验证），那么您可能需要在CreateAuthUserCommand中解析UserProfile中的UserProfile，然后让客户机订阅与UserProfile相关的事件。您需要一种机制来实现这一点，但它将客户机与正在运行的事务解耦，并且可以执行其他操作。

或者，您可以将业务事务分成两个部分，客户机为其发送单独的请求：一个创建/返回经过身份验证的User，另一个返回创建的UserProfile。虽然User+UserProfile似乎属于相同的有界上下文，但它们驻留在两个不同的微服务中的事实可能表明它们不是（在这种情况下，我认为第一个微服务实际上是用于身份验证的，另一个用于用户配置文件，它对我来说指示了不同的有界上下文）。最佳实践是让微服务实现它们自己的封装的有界上下文。

（注：回答了一个老问题，希望对其他人有所帮助）