在NestJS管道中使用Node.js AsyncLocalStorage的技术问题

获取Request和Response对象 #

NestJS管道的transform方法自带ExecutionContext参数，通过它可以直接拿到请求和响应对象：

const req = context.switchToHttp().getRequest();
const res = context.switchToHttp().getResponse();

关于Next函数的问题与解决方案 #

管道的核心职责是转换输入数据，本身并没有直接暴露next函数。如果要实现用AsyncLocalStorage.run包裹后续请求流程，推荐以下两种方式：

方案一：改用全局中间件（推荐）

中间件天然拥有req、res、next参数，是初始化请求上下文的最佳位置，完全符合NestJS的职责划分：

// 自定义请求上下文中间件
export class RequestContextMiddleware implements NestMiddleware {
  use(req: Request, res: Response, next: NextFunction) {
    const appContext = { /* 填充你的应用专属上下文数据 */ };
    MyRequestContext.cls.run(new MyRequestContext(req, res, appContext), next);
  }
}

// 在main.ts中注册全局中间件
async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  app.use(new RequestContextMiddleware());
  await app.listen(3000);
}
bootstrap();

这种方式下，后续所有的管道、守卫、控制器都能直接从AsyncLocalStorage中读取上下文，无需在管道中额外处理。

方案二：在管道中手动触发后续流程（不推荐）

如果必须在管道中处理，可通过ExecutionContext获取控制器和处理函数，手动用cls.run包裹执行逻辑：

@Injectable()
export class RequestContextPipe implements PipeTransform {
  async transform(value: any, context: ExecutionContext) {
    const req = context.switchToHttp().getRequest();
    const res = context.switchToHttp().getResponse();
    const appContext = { /* 填充你的应用专属上下文数据 */ };
    const handler = context.getHandler();
    const controllerInstance = context.getClass();

    // 用AsyncLocalStorage包裹后续处理流程
    return MyRequestContext.cls.run(new MyRequestContext(req, res, appContext), async () => {
      return handler.call(controllerInstance, ...context.getArgs());
    });
  }
}

注意：这种方式会打破管道的单一职责，仅在特殊场景下使用。

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