Nest.js微服务RabbitMQ环境下，服务异常无法传递至客户端问题求助

问题核心 #

你当前的问题在于：网关是HTTP服务，而你配置的MicroserviceExceptionFilter是针对RPC上下文的过滤器，它在HTTP请求处理流程中无法正确解析微服务返回的RPC异常，导致网关直接返回默认500错误。

解决方案步骤 #

1. 确保微服务端（users Service）的异常配置正确 #

首先确认用户服务已经正确注册RPC异常过滤器，并且抛出的是RpcException：

• 在用户服务的main.ts中注册全局RPC过滤器：

async function bootstrap() {
  const app = await NestFactory.createMicroservice<UserServiceModule>(UserServiceModule, {
    transport: Transport.RMQ,
    options: {
      urls: ['amqp://localhost:5672'],
      queue: 'users_queue',
    },
  });
  // 注册RPC异常过滤器
  app.useGlobalFilters(new MicroserviceExceptionFilter());
  await app.listen();
}
bootstrap();

• 在用户服务的业务逻辑中抛出带详细信息的RpcException：

import { RpcException } from '@nestjs/microservices';

// 示例：在用户服务的方法中抛出异常
async getUser(id: string) {
  const user = await this.userRepository.findOne(id);
  if (!user) {
    throw new RpcException({
      status: 404,
      message: '用户不存在',
    });
  }
  return user;
}

2. 网关端配置HTTP异常过滤器处理RPC返回的异常 #

网关是HTTP服务，需要创建一个HTTP全局异常过滤器，专门处理从微服务返回的异常信息，将其转换为标准HTTP响应：

创建http-rpc-exception.filter.ts：

import { Catch, ExceptionFilter, ArgumentsHost, HttpException } from '@nestjs/common';
import { Response } from 'express';

@Catch()
export class HttpRpcExceptionFilter implements ExceptionFilter {
  catch(exception: any, host: ArgumentsHost) {
    const ctx = host.switchToHttp();
    const response = ctx.getResponse<Response>();
    
    // 判断是否是微服务返回的RPC异常
    if (exception.status && exception.message) {
      return response.status(exception.status).json({
        statusCode: exception.status,
        message: exception.message,
      });
    }
    
    // 处理其他未知异常
    return response.status(500).json({
      statusCode: 500,
      message: '服务器内部错误',
    });
  }
}

然后在网关的main.ts中注册这个HTTP过滤器：

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  const environmentService = app.get(EnvironmentService);
  // 替换原RPC过滤器为HTTP专用的异常过滤器
  app.useGlobalFilters(new HttpRpcExceptionFilter());
  await app.listen(environmentService.getAppPort());
}
bootstrap();

3. 可选：在网关的ClientProxy调用处直接捕获异常 #

如果不想用全局HTTP过滤器，也可以在网关调用微服务的地方，通过RxJS的catchError捕获异常并抛出HttpException：

import { Injectable } from '@nestjs/common';
import { ClientProxy, ClientProxyFactory, Transport } from '@nestjs/microservices';
import { catchError } from 'rxjs';
import { HttpException } from '@nestjs/common';

@Injectable()
export class UserGatewayService {
  private client: ClientProxy;

  constructor() {
    this.client = ClientProxyFactory.create({
      transport: Transport.RMQ,
      options: {
        urls: ['amqp://localhost:5672'],
        queue: 'users_queue',
      },
    });
  }

  async getUser(id: string) {
    return this.client.send({ cmd: 'get-user' }, { id }).pipe(
      catchError((error) => {
        throw new HttpException(error.message, error.status);
      }),
    );
  }
}

关键说明 #

• RPC异常过滤器仅在微服务的RPC上下文生效，网关作为HTTP服务需要单独处理异常转换。
• 确保微服务抛出的RpcException包含status（HTTP状态码）和message（错误信息）字段，这样网关才能正确解析并返回给客户端。

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