NestJS微服务集成RabbitMQ时服务抛HttpException网关返回500问题咨询

根本原因 #

NestJS 中HttpException属于HTTP服务专属异常类，RabbitMQ 属于RPC通信模式，微服务默认的异常序列化器无法识别该类异常的状态码与错误信息，只会统一将未捕获的业务侧异常标记为内部错误，因此网关侧会收到 500 错误。

排查步骤 #

• 确认B服务的RabbitMQ微服务是否配置了全局异常过滤器，检查HttpException是否被正确捕获，未被其他中间件或过滤器提前包装为未知错误
• 检查网关侧调用B服务的逻辑中，是否对RPC返回的异常做了统一拦截，是否存在将非RPC异常直接转成500的兜底逻辑

修复方案 #

方案1：业务侧改用RPC异常抛出（推荐） #

B服务的业务逻辑中不再直接抛出HttpException，改为使用NestJS提供的RpcException，自定义结构携带状态码与错误信息：

// B服务异常抛出示例
import { RpcException } from '@nestjs/microservices';

throw new RpcException({
  message: 'something',
  statusCode: 403
});

网关侧增加RPC调用异常拦截逻辑，将捕获到的RpcException转为对应HTTP异常返回：

// 网关侧调用逻辑示例
import { HttpException } from '@nestjs/common';
import { firstValueFrom } from 'rxjs';

try {
  return await firstValueFrom(this.authService.send('auth_check', payload));
} catch (err) {
  throw new HttpException(err.message, err.statusCode);
}

方案2：业务侧增加全局异常过滤器适配 #

如果不想修改现有业务的异常抛出逻辑，可以在B服务新增全局微服务异常过滤器，自动将HttpException转换为RpcException返回：

// B服务全局异常过滤器实现
import { ExceptionFilter, Catch, ArgumentsHost, HttpException } from '@nestjs/common';
import { RpcException } from '@nestjs/microservices';

@Catch(HttpException)
export class HttpToRpcExceptionFilter implements ExceptionFilter {
  catch(exception: HttpException, host: ArgumentsHost) {
    const statusCode = exception.getStatus();
    const message = exception.getResponse();
    throw new RpcException({ statusCode, message });
  }
}

将过滤器绑定到B服务的微服务实例上：

// B服务main.ts配置示例
import { NestFactory } from '@nestjs/core';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';
import { AppModule } from './app.module';
import { HttpToRpcExceptionFilter } from './http-to-rpc-exception.filter';

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  const microservice = app.connectMicroservice<MicroserviceOptions>({
    transport: Transport.RMQ,
    options: {
      // 此处保留你原有RabbitMQ配置
      urls: ['amqp://localhost:5672'],
      queue: 'auth_queue',
      queueOptions: {
        durable: false
      },
    },
  });
  microservice.useGlobalFilters(new HttpToRpcExceptionFilter());
  await app.startAllMicroservices();
  await app.listen(3001);
}
bootstrap();

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