角度-7-拦截器-重试-请求-令牌刷新后

Question

我正在尝试在令牌过期的情况下为失败的请求实现拦截器。我已经尝试了多种方法，但仍然没有成功。

我在下面引用了URL并阅读了多个博客。 每个人都建议切换地图方法，但不与我合作。 令牌刷新后 Angular 4 拦截器重试请求

我尝试将所有请求收集到缓存请求中：数组> = []; 但不知道如何使用它来重新触发失败的请求。

this.next.handle(request( 在成功刷新令牌后未召回。不过，我可以看到更新的请求对象。

有人可以指出在 Angular 7
中引用"rxjs"的位置："~6.3.3"、"rxjs-compat"："^6.5.2"，以实现拦截器。

下面是对我有用的代码，但只得到令牌的响应

``````````
handleError(request: HttpRequest<any>, next: HttpHandler, err) {
if (err instanceof HttpErrorResponse) {
if (err.status === 401) {
this.service.getNewToken().pipe(filter(token => token != null),
take(1),
switchMap((token: any) => {
console.log('token', token);
if (token && token.access_token && token.refresh_token) {
sessionStorage.setItem('accessToken', token.access_token);
sessionStorage.setItem('refreshToken', token.refresh_token);
}
request = this.addHeader(request);
request.headers.getAll('Authorization');
return next.handle(request);
})).subscribe(results => this.subject.next(results));
}
}
}
`````````

更新2：尝试多种方法后，我发现

1. 返回 next.handle(request(; <-- 这根本不被调用
2. 返回 next.handle(request(.subscribe((; <-- 这被调用 但不更新对请求组件的响应。

感谢指针

Answer 1

回复晚了。 我就是这样做的。

也适用于并行请求。

import { HttpInterceptor, HttpRequest, HttpHandler, HttpErrorResponse, HttpEvent, HttpResponse } from '@angular/common/http';
import { Injectable } from '@angular/core';
import { environment } from 'src/environments/environment';
import { GlobalService } from './global.service';
import { tap, mergeMap, switchMap, filter, take, flatMap, catchError } from 'rxjs/operators';
import { Observable, Subject, throwError, of, BehaviorSubject } from 'rxjs';

@Injectable()
export class InterceptorService implements HttpInterceptor {
private isRefreshing = false;
private refreshTokenSubject: BehaviorSubject<any> = new BehaviorSubject<any>(null);
constructor(public globalService: GlobalService) {
}
intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
request = this.addHeader(request);
// console.log('request ', request);
return next.handle(request).pipe(catchError((error: any) => {
if (error instanceof HttpErrorResponse) {
if (error.status === 401) {
if (!this.isRefreshing) {
this.isRefreshing = true;
this.refreshTokenSubject.next(null);
request = this.addHeader(request);
console.log('Token request');
return this.globalService.getRefershToken().pipe(
switchMap((token: any) => {
console.log('inside token');
this.isRefreshing = false;
if (token && token.access_token && token.refresh_token) {
sessionStorage.setItem('accessToken', token.access_token);
sessionStorage.setItem('refreshToken', token.refresh_token);
}
// request = this.addHeader(request);
// console.log('request: ', request);
this.refreshTokenSubject.next(token);
return next.handle(this.addHeader(request));
}));
} else {
console.log('inside else call');
console.log('token : ', this.refreshTokenSubject.getValue());
return this.refreshTokenSubject.pipe(
filter(token => (token != null && token != undefined)),
take(1),
switchMap(() => {
console.log('adding header in else');
return next.handle(this.addHeader(request))
}));
}
}
}
}));
}
private addHeader(request: HttpRequest<any>) {
let getEndPoint = request.url.split('/')[request.url.split('/').length - 1];
if (getEndPoint !== 'refreshToken') {
const accessToken = sessionStorage.getItem('accessToken');
request = request.clone({
setHeaders: {
Authorization: `Bearer ${accessToken}`
}
});
} else if (getEndPoint === 'refreshToken') {
const refreshToken = sessionStorage.getItem('refreshToken');
request = request.clone({
setHeaders: {
applicationCode: environment.applicationCode,
'refresh-token': `${refreshToken}`,
}
});
}
return request;
}
}

Answer 2

在 api 失败并出现 HTTP 错误 401 后，令牌刷新 api 被调用，所有失败和缓存的请求都可以使用 http 拦截器重试。

if (this.isRefreshingToken && !req.url.endsWith(tokenURL)) {
// check if unique url to be added in cachedRequest
if (urlPresentIndex == -1) {
this.cachedRequests.push(req);
return this.tokenSubject.pipe(
switchMap(() => next.handle(req)),
tap((v) => {
// delete request from catchedRequest if api gets called
this.cachedRequests.splice(
this.cachedRequests.findIndex(
(httpRequest) => httpRequest.url == req.url
),
1
);
return EMPTY;
})
);
} else {
//already in cached request array
return EMPTY;
}
}

有关更多详细信息，您可以阅读我的中等文章令牌刷新拦截器重试失败请求

看看它，它是如何工作的堆栈闪电战