javascript - 无法取消拦截器中的请求

标签 javascript rxjs nestjs

我正在尝试取消对超过 n 秒的请求的请求处理。例如,在此示例中 https://github.com/nestjs/nest/tree/master/sample/01-cats-app

cats.controller.ts代替

@UseInterceptors(LoggingInterceptor, TransformInterceptor)



@UseInterceptors(TimeoutInterceptor, LoggingInterceptor, TransformInterceptor)

cats.controller.ts代替

  @Get()
  async findAll(): Promise<Cat[]> {
    return this.catsService.findAll();
  }



  @Get()
  async findAll(): Promise<Cat[]> {
    for (let i = 0; i < 100000000; i++) {
      if (i === 99999999) {
        return this.catsService.findAll();
      }
    }
  }

添加拦截器源:

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

@Injectable()
export class TimeoutInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    return next.handle().pipe(timeout(1));
  }
}

即使在 1 毫秒后请求处理并返回数据。日志:
Before...
After... 134ms

拦截器的代码来自这里:https://docs.nestjs.com/interceptors

我做错了什么?

最佳答案

好的,弄清楚发生了什么。以您的方式使用 for 循环时,从技术上讲,您并没有进入执行上下文的下一部分,因此超时管道还没有开始生效。要启动超时运算符,AppService的方法必须被调用以允许调用堆栈继续前进。您可以返回一个异步函数,并根据异步函数的工作时间让可观察的工作超时,但是 for 循环通常是同步的,这是错误功能的来源。如果需要,请尝试添加

function asyncTimeout(time: number) {
  return new Promise((resolve, reject) => {
    setTimeout(() => resolve(), time);
  });
}

这个函数到你的服务器然后调用await asyncTimeout(5000) .

您可以将其用于您的 AppService
import { Injectable } from '@nestjs/common';

function asyncTimeout(time: number) {
  return new Promise((resolve, reject) => {
    setTimeout(() => resolve(), time);
  });
}

@Injectable()
export class AppService {
  async getHello(): Promise<string> {
    console.log('In service');
    await asyncTimeout(5000);
    console.log('Returning after waiting');
    return 'Hello World!';
  }
}

这是给你的AppController
import { Controller, Get, UseInterceptors } from '@nestjs/common';
import { AppService } from './app.service';
import { TimeoutInterceptor } from './timeout.interceptor';

@Controller()
@UseInterceptors(TimeoutInterceptor)
export class AppController {
  constructor(private readonly appService: AppService) {}

  @Get()
  getHello(): Promise<string> {
    console.log('In controller');
    return this.appService.getHello();
  }
}

这是你的TimeoutInterceptor
import { CallHandler, ExecutionContext, Injectable, NestInterceptor } from '@nestjs/common';
import { Observable } from 'rxjs';
import { tap, timeout } from 'rxjs/operators';

@Injectable()
export class TimeoutInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    console.log('In interceptor');
    return next.handle().pipe(tap(() => console.log('In tap of return interceptor')), timeout(1));
  }
}

如果您调用http://localhost:3000你会看到超时几乎是瞬间发生的,你会看到日志:

[Nest] 10529   - 12/23/2019, 8:07:40 AM   [NestFactory] Starting Nest application...
[Nest] 10529   - 12/23/2019, 8:07:40 AM   [InstanceLoader] AppModule dependencies initialized +11ms
[Nest] 10529   - 12/23/2019, 8:07:40 AM   [RoutesResolver] AppController {/}: +4ms
[Nest] 10529   - 12/23/2019, 8:07:40 AM   [RouterExplorer] Mapped {/, GET} route +2ms
[Nest] 10529   - 12/23/2019, 8:07:40 AM   [NestApplication] Nest application successfully started +2ms
In interceptor
In controller
In service
[Nest] 10529   - 12/23/2019, 8:07:48 AM   [ExceptionsHandler] Timeout has occurred +7955ms
Returning after waiting

但是在 HTTP 响应中你会发现

▶ curl http://localhost:3000
{"statusCode":500,"message":"Internal server error"}% 

这是因为你不能取消 promise ,所以它仍然必须完成它的执行。但是,您可以忽略 promise 的返回,因为您已经向客户端发送了响应,说请求花费了太长时间。

Here's a link to the repository

关于javascript - 无法取消拦截器中的请求,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59450028/

相关文章:

javascript - JavaScript全局变量值在函数中丢失

javascript - 每次路由更改都不会调用 Router.match

javascript - RxJS 5.5错误:接受不是一个函数。链式功能出现问题

javascript - 如何在 RxJS 中停止 Observable 的间隔

header - 如何用 nestjs 写标题

javascript - 隔离表单中的download()函数调用的特定按钮

javascript - Nodejs - 将基于 Promise 的架构与事件混合是错误的

javascript - 使用flatMap链接可观察对象

javascript - 是否可以在 nestjs 中的一种方法上使用多个装饰器?

typescript - 如何在 Docker 容器内的 NestJs 应用程序中观察文件更改