当请求抛出错误时总是执行重复请求

如何解决当请求抛出错误时总是执行重复请求

我有一个奇怪的问题。

我有一个服务，它从后端获取数据和一个像这样的函数：

  validateChangEmailTokenAndChangeEmail(token: string): Observable<User>
  {
    const callUrl = environment.apiUrl + `users/validate-change-email-token-and-change-email`;
    return this.http.post<User>(callUrl,token,environment.httpOptions)
      .pipe(shareReplay(),retry(0));
  }

我的问题是，当我订阅这个 observable（它只在组件初始化时订阅一次）并且 BE 抛出错误时，请求将再执行一次。我曾尝试添加 shareReplay()、retry(0) 和 take(1)。但还是没有成功。

这是我的订阅：

this.userService.validateChangEmailTokenAndChangeEmail(this.token)
      .subscribe(user => {
       // my logic

      },error =>
      {
        // handling of error
        this.handleError(error);
      });

函数 this.handleError() 将只调用一次。这意味着重复的请求并没有真正被接受和处理。

检查下面的屏幕截图。请求错误记录了 2 次，WTF（来自 handleError()）只记录一次。

可能是什么？

我还注意到，订阅将始终接受第二个请求。

解决方法

有点像在黑暗中拍摄，但即使他们取消订阅，shareReplay 通常也会保持连接。

尝试使用

    return this.http.post<User>(callUrl,token,environment.httpOptions)
      .pipe(publishReplay(1),refCount(),retry(0));

,

您不止一次订阅该 http 调用。 它没有共享它的发射，因为每次调用 validateChangEmailTokenAndChangeEmail() 都会返回一个不同的 observable。

为了实现您的目标，您实际上需要将该方法的结果分配给一个局部变量，然后您可以通过 n 次重新订阅该局部变量。

validate$ = this.myService.validateChangEmailTokenAndChangeEmail(this.token);

ngOnInit() {
    this.validate$.subscribe(console.log);
    this.validate$.subscribe(console.log);
}

,

我发现了我遇到的问题。

基本上我已经实现了一个名为 HttpErrorInterceptor 的类，它有一个带有 retry(1) 的管道。这就是为什么每个导致错误的请求都被重复的原因。