NestJS微服务Class Validator错误仅在Docker容器显示，API无返回

问题原因 #

你通过RpcException抛出校验错误，但NestJS的HTTP网关默认不会将RpcException转换为友好的客户端响应，而是直接返回500内部服务器错误。容器日志能看到错误是因为校验逻辑已执行，但异常未被正确处理并传递给客户端。

解决方案 #

1. 调整ValidationPipe的异常格式化逻辑 #

先将校验错误整理成结构化格式，再用RpcException包裹，确保异常信息包含明确的状态码和错误详情。修改main.ts中的ValidationPipe配置：

app.useGlobalPipes(new ValidationPipe({
  transform: true,
  validationError: { target: false, value: false },
  exceptionFactory: (validationErrors = []) => {
    // 格式化校验错误为易读结构
    const formattedErrors = validationErrors.map(error => ({
      field: error.property,
      messages: Object.values(error.constraints || {})
    }));
    // 用RpcException包裹结构化错误，指定400状态码
    return new RpcException({
      statusCode: 400,
      message: '参数校验失败',
      errors: formattedErrors
    });
  },
}));

2. 新增全局RPC异常过滤器 #

创建过滤器捕获RpcException，将其转换为标准HTTP响应返回给客户端。

创建rpc-exception.filter.js文件：

const { ExceptionFilter, Catch, ArgumentsHost } = require('@nestjs/common');
const { RpcException } = require('@nestjs/microservices');

@Catch(RpcException)
class RpcExceptionFilter implements ExceptionFilter {
  catch(exception, host) {
    const ctx = host.switchToHttp();
    const response = ctx.getResponse();
    const error = exception.getError();

    // 提取状态码，默认400
    const statusCode = typeof error === 'object' && 'statusCode' in error 
      ? error.statusCode 
      : 400;
    
    response.status(statusCode).json({
      statusCode,
      message: typeof error === 'object' && 'message' in error 
        ? error.message 
        : '请求参数错误',
      errors: typeof error === 'object' && 'errors' in error 
        ? error.errors 
        : error
    });
  }
}

module.exports = RpcExceptionFilter;

在网关的main.js中注册该过滤器：

const { NestFactory } = require('@nestjs/core');
const { AppModule } = require('./app.module');
const { RpcExceptionFilter } = require('./filters/rpc-exception.filter');

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  // 注册全局异常过滤器
  app.useGlobalFilters(new RpcExceptionFilter());
  await app.listen(3000);
}
bootstrap();

3. 确保微服务与网关通信协议一致 #

如果微服务使用TCP等非HTTP协议，网关需正确配置客户端以接收微服务的异常信息。例如网关模块中的客户端配置：

const { Module } = require('@nestjs/common');
const { ClientsModule, Transport } = require('@nestjs/microservices');
const { AppController } = require('./app.controller');
const { AppService } = require('./app.service');

@Module({
  imports: [
    ClientsModule.register([
      {
        name: 'USER_SERVICE',
        transport: Transport.TCP,
        options: {
          host: 'user-service', // Docker容器名称
          port: 3001,
        },
      },
    ]),
  ],
  controllers: [AppController],
  providers: [AppService],
})
class AppModule {}

module.exports = AppModule;

验证效果 #

发送测试请求：

{
    "email" : "4",
    "password" : "pass"
}

将收到如下响应：

{
  "statusCode": 400,
  "message": "参数校验失败",
  "errors": [
    {
      "field": "email",
      "messages": ["email must be an email"]
    },
    {
      "field": "password",
      "messages": ["password must be longer than or equal to 6 characters"]
    }
  ]
}

内容的提问来源于stack exchange，提问作者Theohrd