NestJS微服务中@Res()装饰器返回的Response对象为null问题排查

你遇到的@Res()注入为null是NestJS微服务RPC通信和HTTP请求上下文隔离导致的，核心问题有两个：

• @Res()、@Body()都是HTTP控制器专属装饰器，仅能在标注了@Controller()的普通HTTP路由方法中注入，基于@MessagePattern的微服务RPC handler运行在独立的RPC上下文，不存在HTTP请求/响应对象，自然无法注入@Res()
• 微服务RPC调用的核心是返回可序列化的业务数据，不应该直接操作HTTP响应，所有和HTTP响应相关的逻辑（设置头、返回流）都需要在作为HTTP入口的API网关层完成

1. 存储服务（StorageService）修改 #

替换HTTP专属装饰器，直接返回文件流和响应元数据即可：

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

@MessagePattern('get_file')
public async getFile(@Payload() request: GetFileRequest) {
  const fileStream = await this.fileService.getFile(request);

  if (!fileStream)
    throw new RpcException('Failed to retrieve file');

  // 返回流和响应需要的元数据，不要操作任何HTTP相关对象
  return {
    fileStream,
    contentType: 'text/csv',
    fileName: 'export.csv'
  };
}

2. API网关修改 #

网关是HTTP服务，在网关层注入@Res()对象，拿到存储服务返回的流后直接pipe到HTTP响应：

import { firstValueFrom } from 'rxjs';
import { Response } from 'express';

@Post('/storage/file')
public async getLog(
  @Body() request: GetFileRequest,
  @Res() res: Response
): Promise<void> {
  // ClientProxy.send返回Observable，用firstValueFrom转为Promise获取返回结果
  const { fileStream, contentType, fileName } = await firstValueFrom(
    this.storageClient.send('get_file', request)
  );

  // 在网关层设置响应头
  res.set({
    'Content-Type': contentType,
    'Content-Disposition': `attachment; filename="${fileName}"`
  });

  // 将存储服务返回的文件流直接pipe到HTTP响应
  fileStream.pipe(res);
}

• 如果你的文件体积较大，可以根据需要添加Content-Length响应头，提升客户端下载体验
• 注意处理流传输过程中的异常，可以给fileStream添加error事件监听，避免请求挂起
• 常规TCP、Redis传输层默认支持流的序列化传输，如果使用gRPC作为微服务传输层，需要额外定义流类型的message结构

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