Nodejs Nestjs CQRS模块cqrs的使用

NestJS 是一个用于构建高效、可扩展的 Node.js 服务器端应用程序的框架。CQRS（命令查询职责分离）是一种架构设计模式，它将系统中的操作分为命令（改变系统状态）和查询（获取系统状态）。在 NestJS 中，可以使用 nest-command-query 这样的库来实现 CQRS。

下面是如何在 NestJS 中设置和使用 CQRS 的基本步骤：

1. 安装依赖

首先，你需要安装必要的库。这里我们以 cqrs-module 为例：

npm install @nestjs/cqrs

2. 创建命令和查询

命令通常用于执行某个动作或更改数据，而查询用于从数据库中检索数据。

命令

创建一个命令接口：

// src/commands/create-user.command.ts
export class CreateUserCommand {
  constructor(public readonly name: string, public readonly email: string) {}
}

查询

创建一个查询接口：

// src/queries/get-user.query.ts
export class GetUserQuery {
  constructor(public readonly id: string) {}
}

3. 创建处理程序

对于每个命令和查询，都需要创建一个处理程序。

命令处理程序

// src/commands/create-user.command.handler.ts
import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
import { CreateUserCommand } from './create-user.command';
import { UserService } from './user.service';

@CommandHandler(CreateUserCommand)
export class CreateUserCommandHandler implements ICommandHandler<CreateUserCommand> {
  constructor(private userService: UserService) {}

  async execute(command: CreateUserCommand) {
    return this.userService.createUser(command.name, command.email);
  }
}

查询处理程序

// src/queries/get-user.query.handler.ts
import { QueryHandler, IQueryHandler } from '@nestjs/cqrs';
import { GetUserQuery } from './get-user.query';
import { UserService } from './user.service';

@QueryHandler(GetUserQuery)
export class GetUserQueryHandler implements IQueryHandler<GetUserQuery> {
  constructor(private userService: UserService) {}

  async execute(query: GetUserQuery) {
    return this.userService.getUserById(query.id);
  }
}

4. 配置 CQRS 模块

在你的模块中注册这些命令和查询：

// src/user.module.ts
import { Module } from '@nestjs/common';
import { CQRSModule } from '@nestjs/cqrs';
import { CreateUserCommandHandler } from './commands/create-user.command.handler';
import { GetUserQueryHandler } from './queries/get-user.query.handler';

@Module({
  imports: [CQRSModule],
  providers: [
    { provide: 'IUserService', useClass: UserService },
    CreateUserCommandHandler,
    GetUserQueryHandler,
  ],
})
export class UserModule {}

5. 使用

现在你可以通过注入 ICommandBus 和 IQueryBus 来发送命令和查询：

// src/user.controller.ts
import { Controller, Post, Get, Param } from '@nestjs/common';
import { ICommandBus, IQueryBus } from '@nestjs/cqrs';
import { CreateUserCommand } from './commands/create-user.command';
import { GetUserQuery } from './queries/get-user.query';

@Controller('users')
export class UserController {
  constructor(
    private readonly commandBus: ICommandBus,
    private readonly queryBus: IQueryBus,
  ) {}

  @Post()
  async createUser(@Body() body: { name: string; email: string }) {
    const command = new CreateUserCommand(body.name, body.email);
    return await this.commandBus.execute(command);
  }

  @Get(':id')
  async getUser(@Param('id') id: string) {
    const query = new GetUserQuery(id);
    return await this.queryBus.execute(query);
  }
}

以上就是如何在 NestJS 中使用 CQRS 的基本流程。这只是一个简单的示例，实际应用中可能需要更复杂的错误处理、验证等逻辑。