如何从客户端终止运行中的NestJS服务端gRPC处理进程

问题本质是HTTP请求的中断信号没有从接入层透传到gRPC调用层：服务端仅感知到和客户端的连接断开，但内部gRPC调用没有收到终止指令，会继续执行直到超时或返回结果。要实现请求中断时同步终止服务端所有执行逻辑，只需要把中断信号从请求入口一路绑定到所有IO操作（包括gRPC调用）即可。

具体实现步骤 #

• 第一步：在请求入口获取中断信号
  不管NestJS用的是Express还是Fastify适配器，请求对象原生携带req.signal（AbortSignal实例），当客户端主动abort请求、关闭浏览器/页面导致连接断开时，这个信号会立刻触发abort事件，不需要额外封装事件监听逻辑。
  如果用Next.js的Server Action/Route Handler作为请求中转层，同样可以从NextRequest对象上拿到自带的signal属性，用户路由跳转、关闭页面时这个信号会自动触发，需要把这个信号一并透传给下游NestJS接口。

• 第二步：将中断信号透传给gRPC调用
  gRPC官方JS实现（@grpc/grpc-js）从1.8.0版本开始原生支持传入AbortSignal作为调用选项，信号触发时会自动取消正在进行的gRPC请求，不需要手动处理连接销毁逻辑。
  如果用@nestjs/microservices封装的gRPC客户端，调用方法时直接在第二个参数的选项里传入abortSignal即可；如果是旧版本不支持传signal的gRPC客户端，可以拿到gRPC调用返回的call实例，监听signal的abort事件手动调用call.cancel()终止调用。

• 第三步：全链路绑定信号避免遗漏
  如果请求处理流程中还有其他IO操作（比如数据库查询、第三方HTTP调用、文件读写），都可以绑定同一个AbortSignal，确保请求中断时所有占用资源的操作都能及时终止，避免无效的资源消耗。

代码示例 #

NestJS Controller层信号获取 #

import { Controller, Get, Req, Res, HttpStatus } from '@nestjs/common';
import { Request, Response } from 'express';
import { DataService } from './data.service';

@Controller('fetch')
export class FetchController {
  constructor(private readonly dataService: DataService) {}

  @Get()
  async fetchData(@Req() req: Request, @Res() res: Response) {
    const { signal } = req;

    try {
      // 把信号透传给业务服务层
      const data = await this.dataService.getGrpcData(signal);
      return res.status(HttpStatus.OK).send(data);
    } catch (err) {
      // 捕获中断错误，返回客户端断开的标准状态码
      if (err.name === 'AbortError') {
        return res.status(499).send('Request aborted by client');
      }
      throw err;
    }
  }
}

Service层gRPC调用绑定信号 #

import { Injectable, OnModuleInit } from '@nestjs/common';
import { ClientGrpc } from '@nestjs/microservices';
import { Inject } from '@nestjs/common';

@Injectable()
export class DataService implements OnModuleInit {
  private grpcService: any;

  constructor(@Inject('GRPC_DATA_PACKAGE') private readonly client: ClientGrpc) {}

  onModuleInit() {
    this.grpcService = this.client.getService('GrpcDataService');
  }

  async getGrpcData(signal: AbortSignal) {
    // 新版gRPC客户端直接传入abortSignal即可自动取消
    return this.grpcService.queryData(
      { page: 1, pageSize: 100 },
      { abortSignal: signal }
    ).toPromise();
  }
}

旧版gRPC手动取消兼容写法 #

如果gRPC客户端版本过低不支持abortSignal参数，可以手动监听信号取消调用：

async getGrpcDataLegacy(signal: AbortSignal) {
  return new Promise((resolve, reject) => {
    // 发起原生gRPC调用
    const call = this.nativeGrpcClient.queryData({ page:1, pageSize:100 }, (err, res) => {
      if (err) return reject(err);
      resolve(res);
    });

    const onAbort = () => {
      call.cancel();
      reject(new DOMException('Request aborted', 'AbortError'));
    };

    // 信号已经触发则直接取消
    if (signal.aborted) return onAbort();
    signal.addEventListener('abort', onAbort, { once: true });
  });
}

注意事项 #

• 客户端调用接口时必须把AbortController生成的signal传入fetch/axios请求配置，否则前端触发abort只是本地停止接收响应，不会通知服务端中断连接。
• 如果用了NestJS的守卫、拦截器、中间件做逻辑处理，不要缓存请求后异步执行，要确保中断信号能正常透传到业务逻辑层。
• 对于gRPC流式调用（服务端流、双向流），取消调用后记得移除相关事件监听，避免内存泄漏。
• 直接关闭浏览器窗口的中断通知在HTTP/1.1协议下可能存在几秒的延迟，主动调用AbortController.abort()的中断实时性更好。

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