NestJS中如何在Service中使用Interceptor？

NestJS的@UseInterceptors装饰器仅针对Controller层的路由处理器设计，无法直接在Service方法上生效——因为原生拦截器机制绑定的是HTTP请求/响应生命周期，不会自动拦截Service内部的方法调用。以下是两种可行的实现方式：

方法一：手动调用拦截器的intercept方法 #

拦截器本质是实现NestInterceptor接口的类，你可以在Service中手动实例化拦截器，将业务逻辑包裹后传入intercept方法执行。

步骤1：确保拦截器实现标准接口 #

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';

@Injectable()
export class MyInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    // 前置拦截逻辑
    console.log('Service方法执行前');
    
    return next.handle().pipe(
      map(data => {
        // 后置拦截逻辑
        console.log('Service方法执行后');
        return data;
      }),
    );
  }
}

步骤2：在Service中手动调用拦截器 #

import { Injectable } from '@nestjs/common';
import { MyInterceptor } from './my.interceptor';
import { ExecutionContext, CallHandler, Observable } from '@nestjs/common';

@Injectable()
export class DemoService {
  constructor(private readonly myInterceptor: MyInterceptor) {}

  public anyFunc(): Observable<string> {
    // 模拟ExecutionContext（若不需要上下文信息可简化）
    const mockContext = {} as ExecutionContext;
    
    // 包裹业务逻辑为CallHandler
    const callHandler: CallHandler = {
      handle: () => {
        // 原业务逻辑
        console.log('执行Service核心逻辑');
        return new Observable(observer => {
          observer.next('Service返回结果');
          observer.complete();
        });
      },
    };

    // 调用拦截器处理业务逻辑
    return this.myInterceptor.intercept(mockContext, callHandler);
  }
}

方法二：自定义装饰器+反射实现AOP #

通过自定义装饰器标记需要拦截的Service方法，结合Nest的Reflector获取元数据，手动触发拦截器逻辑。

步骤1：创建自定义装饰器 #

import { SetMetadata } from '@nestjs/common';

// 自定义装饰器，标记需要使用的拦截器
export const UseServiceInterceptor = (interceptor: new () => any) => 
  SetMetadata('service_interceptor', interceptor);

步骤2：在Service中使用装饰器并执行拦截 #

import { Injectable, Reflector } from '@nestjs/common';
import { MyInterceptor } from './my.interceptor';
import { UseServiceInterceptor } from './use-service-interceptor.decorator';

@Injectable()
export class DemoService {
  constructor(private readonly reflector: Reflector) {}

  @UseServiceInterceptor(MyInterceptor)
  public async anyFunc(): Promise<string> {
    // 通过反射获取装饰器标记的拦截器
    const InterceptorClass = this.reflector.get(
      'service_interceptor', 
      this.anyFunc
    );
    const interceptor = new InterceptorClass();

    // 模拟上下文与调用处理器
    const mockContext = {} as any;
    const callHandler = {
      handle: () => Promise.resolve('Service返回结果'),
    };

    // 执行拦截器逻辑
    return interceptor.intercept(mockContext, callHandler).toPromise();
  }
}

关键说明 #

• 原生拦截器的设计目标是处理HTTP请求流程，因此无法直接复用在Service层。
• 上述两种方式本质都是手动触发拦截器逻辑，而非依赖Nest的自动生命周期绑定。

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