用户登录

下面我们去执行一个查询,先打开 UserController 控制器,在这个控制器里定义一个接口,添加一个方法,名字叫 getUsers,这个方法的上面,可以使用 @Get 装饰器装饰一下。这样在客户端使用 Http 的 GET 方法请求 users 地址的时候,就会执行这个控制器里的 getUsers 方法。

在这个方法里可以执行一个查询,执行查询用的是 QueryBus,先把这个东西注入到这个类里面,在类的构造方法里,再添加一个参数属性,private readonly queryBus,类型设置成 QueryBus,这个 QueryBus 来自 @nestjs/cqrs,所以我们要在这个控制器所属的 UserModule 模块里,导入 CqrsModule 模块,这样才能在这个控制器里注入需要的这个 QueryBus。

在 getUsers 方法里, return 的是,用一下 this.queryBus 上的 execute 方法,新建一个 GetUserQuery 查询。

测试

在 Http 客户端,配置一个请求,方法使用 GET,请求的地址是 users,请求里不带数据,因为这是一个查询请求。 发送一下这个请求。

返回了一组用户数据,用 Http 的 GET 方法请求 users 这个地址,会执行一个 GetUsersQuery 查询,这个查询的处理器要做的事情就是返回这组用户数据。

Queries:执行查询(QueryBus)《 企业应用架构:事件驱动 》

统计

11686
分钟
0
你学会了
0%
完成

社会化网络

关于

微信订阅号

扫描微信二维码关注宁皓网,每天进步一点