NestJS混合应用全局拦截器无法捕获微服务RPC异常如何解决

通过APP_INTERCEPTOR令牌在根模块注册的全局拦截器，默认仅作用于HTTP主应用上下文，不会自动挂载到通过connectMicroservice()接入的微服务实例上。
NestJS混合应用模式下，HTTP主应用与每个连接的微服务是相互独立的运行实例，各自维护独立的全局增强器（拦截器、过滤器、管道、守卫）注册表，因此给HTTP应用注册的全局拦截器不会自动透传到微服务侧。
单独在控制器方法上用@UseInterceptors()绑定拦截器可以生效，是因为装饰器直接将拦截器绑定到了对应路由处理函数的执行链上，不依赖全局增强器注册表，无论请求来自HTTP还是微服务上下文，命中路由时都会执行。

有两种可落地的实现方案，按需选择即可：

方案1：手动给微服务实例注册全局拦截器 #

这是最直接的适配方式，在bootstrap启动函数中，拿到connectMicroservice()返回的微服务实例，手动调用全局拦截器注册方法即可。
如果拦截器不需要依赖注入，可以直接传入新实例：

async function bootstrap() {
  const app = await NestFactory.create<NestExpressApplication>(AppModule, {
    logger: WinstonModule.createLogger(winstonTransports),
  });

  // 接收connectMicroservice返回的微服务实例
  const kafkaMicroservice = app.connectMicroservice<MicroserviceOptions>(kafkaConfig);
  // 给微服务实例注册全局拦截器
  kafkaMicroservice.useGlobalInterceptors(new ErrorsInterceptor());

  const logger = app.get<winston.Logger>(WINSTON_MODULE_NEST_PROVIDER);
  app.useLogger(logger);
  app.enableCors(corsConfig);

  await app.startAllMicroservices();
  await app.listen(env.PORT);
}

如果拦截器内部依赖其他Nest容器管理的服务（比如配置服务、日志服务），不要手动new实例，从应用容器中取出已经完成依赖注入的拦截器实例再传入：

// 从DI容器中取出拦截器实例，自动解析所有依赖
const errorsInterceptor = app.get(ErrorsInterceptor);
kafkaMicroservice.useGlobalInterceptors(errorsInterceptor);

如果项目中连接了多个微服务实例，每个connectMicroservice()返回的实例都需要单独执行一次注册操作，才能覆盖所有RPC请求场景。

方案2：拦截器内适配多上下文逻辑（可选优化） #

全局拦截器同时作用于HTTP和RPC场景后，建议在拦截逻辑中增加上下文判断，针对不同请求类型返回符合对应协议规范的错误格式，避免统一返回格式导致RPC消费端解析失败：

@Injectable()
export class ErrorsInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    return next
      .handle()
      .pipe(
        catchError(err => {
          // 区分上下文类型做不同封装
          const contextType = context.getType();
          if (contextType === 'rpc') {
            // RPC场景的错误封装逻辑
            return throwError(() => new ApplicationException(err.message));
          }
          // HTTP场景的错误封装逻辑
          return throwError(() => new ApplicationException(err.message, err.status));
        }),
      );
  }
}

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