在 Angular http 拦截器中刷新令牌后重试请求

Question

我有 401 拦截器，当access_token过期时，有一个请求的成功案例。拦截器重新加载令牌并返回 next.handle（customReq）。但是当同时发出 2 个或更多请求并且两个请求的令牌都已过期时，我遇到了问题，因为第二个请求尝试再次刷新，但现在刷新令牌无效。所以。。。。我尝试设置一个标志只执行一次，并使用自定义可观察量返回。问题是组件现在永远不会成功，我无法删除加载器。

HTTP 拦截器：

    return next
        .handle(customReq).pipe(
        tap((ev: HttpEvent < any > ) => {
            if (ev instanceof HttpResponse) {
                this.setApiStatus(ApiStatusCode.ACTIVE);
                this.interceptorIgnore.removeIgnore(request.url);
            }
        }),
        catchError(resp => {
            if (resp instanceof HttpErrorResponse) {
                switch (true) {
                    // Unauthorized
                    case resp.status === 401:
                        return this.attemptToRefreshToken(apiRequest, customReq, next);
                    // More code unnecessary ....
                }
            }

            return throwError(resp);
        })
    );

尝试ToRefreshToken方法:

attemptToRefreshToken(apiRequest: ApiRequest, customReq: HttpRequest<any>, next: HttpHandler) {


        const retryRequest = () => {
            this.updatingToken = false;
            customReq = customReq.clone({
                headers: apiRequest.buildHeader()
            });
            return next.handle(customReq);
        };

        if (!this.updatingToken) {
            this.updatingToken = true;
            const tokenRequestData = this.apiAuth.refreshTokenData();
            return this.http.request(tokenRequestData.opts.method, tokenRequestData.url, tokenRequestData.opts)
            .pipe(flatMap((token: ResponseTokenFormat) => {
                ApiAuth.storedToken = token;
                this.usersService.queryUsersUsename(ApiAuth.storedUser).then(([user]) => {
                    if (user && !user.isAdmin) {
                        this.sessionService.setUserPermissions(user);
                    }
                });
                this.tokenUpdated.next();
                return retryRequest();
            }));
        }

        return this.tokenUpdated$.pipe(
            flatMap(() => retryRequest())
        );       

}

当下一个（）被调用并正常工作时，重试请求会执行，但它永远不会通知服务女巫调用这个超文本传输协议请求。当我刷新令牌时，返回重试请求（）；服务可以订阅。

我做错了什么？也许是Observable？

Answer 1

我认为你可能不得不使用exhaustMap而不是flatMap，试图刷新令牌。

它们是如何工作的？

• 平面图：立即为任何源项目创建一个可观察对象，所有以前的可观察对象都保持活动
• 耗尽地图：源项被忽略，而上一个可观察项未完成。