5

我有一个身份验证HttpInterceptor：

import {HttpErrorResponse, HttpEvent, HttpHandler, HttpInterceptor, 
HttpRequest} from '@angular/common/http';
import {AuthService} from '../service/auth.service';
import {Observable} from 'rxjs/Observable';
import {Injectable} from '@angular/core';
import {Router} from '@angular/router';

@Injectable()
export class AuthInterceptor implements HttpInterceptor {
  constructor(private authService: AuthService,
              private router: Router) {
  }

  intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
    const authHeader = this.authService.getToken();
    const clone = req.clone({headers: req.headers.set('Authorization',authHeader)});
    return next.handle(clone).do(() => {
}, err => {
  console.log(err);
  if (err instanceof HttpErrorResponse && err.status === 401) {
    this.authService.clearToken();
    this.router.navigate(['/auth/signin']);
    return Observable.empty();
      }
    });
  }
}

这个拦截器工作正常，但是当我收到 401 时，我将用户重定向到登录页面，但错误仍然出现在服务中，并且在该服务中我显示错误消息，并且此消息显示在登录页面。所以我想改变响应或做一些事情，if (err instanceof HttpErrorResponse && err.status === 401) {在这种情况下不返回错误。

return Observable.empty();

不管用

4

1 回答 1

8

next.handle(clone).do()- 这就是导致这种行为的原因。do()运算符仅旨在提供副作用，但它实际上并不影响可观察管道中的数据流和错误处理。本质上它是在说“当这种情况发生时，请执行此操作然后继续，就好像根本没有 do() 部分一样”。如果要抑制错误，则需要使用catch()运算符。

代码几乎相同：

@Injectable()
export class AuthInterceptor implements HttpInterceptor {
    constructor(private authService: AuthService,
                private router: Router) {
    }

    intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
        const authHeader = this.authService.getToken();
        const clone = req.clone({headers: req.headers.set('Authorization',authHeader)});
        return next.handle(clone).catch(err => { // <-- here
            console.log(err);
            if (err instanceof HttpErrorResponse && err.status === 401) {
                this.authService.clearToken();
                this.router.navigate(['/auth/signin']);
                return Observable.empty();
            }
            // we must tell Rx what to do in this case too
            return Observable.throw(err);
        });
    }
}
于 2017-09-20T19:12:37.040 回答