常规管道 和微服务管道之间没有根本区别。唯一的区别是,您不应抛出 HttpException
,而应使用 RpcException
。
RpcException
类从 @nestjs/microservices
包中公开。
绑定管道
以下示例使用手动实例化的方法范围管道。与基于 HTTP 的应用程序一样,您也可以使用控制器范围的管道(即,在控制器类前添加 @UsePipes()
装饰器)。
ts
TS
ts
@UsePipes(new ValidationPipe())
@MessagePattern({ cmd: 'sum' })
accumulate(data: number[]): number {
return (data || []).reduce((a, b) => a + b);
}