javascript - 以角度 6 重试 HTTP 请求
问题描述
我使用拦截器根据每个请求的 HTTP 响应在显示屏上显示错误消息。
intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
const customReq = request.clone({
//headers: request.headers.set('app-language', 'en')
});
return next
.handle(customReq).pipe(
tap((ev: HttpEvent<any>) => {
if (ev instanceof HttpResponse) {
// processing request
}
}),
catchError(response => {
if (response instanceof HttpErrorResponse) {
switch (response.status) {
case 0:
// server API connection error show
break;
case 403:
// error Token Invalid and Redirect to logout
break;
case 401:
// error Token Invalid and Redirect to logout
break;
case 502:
// Bad gateway error
break;
case 500:
// internal server error
break;
}
}
// return next.handle(request);
return observableThrowError(response);
})
);
}
在我的项目中,Web 服务器在某些情况下可能会一秒钟不可用并回复 500 错误代码。我不希望我的 Web 应用程序在收到错误后立即显示错误消息,并且我希望它以一秒钟的延迟重试请求几次。
我已经尝试过 rxjs 重试:
...
.handle(customReq).pipe(retry(5),
...
它没有用,因为它没有延迟。基于这个答案 How to create an RXjs RetryWhen with delay and limit on try
我试过 retryWhen 像:
.handle(customReq).pipe(
tap((ev: HttpEvent<any>) => {
if (ev instanceof HttpResponse) {
console.log('###processing response', ev, this.location);
}
}),
retryWhen(error => {
return error
.flatMap((error: any) => {
if (error.status == 400) {
return Observable.of(error.status).delay(1000);
}
if (error.status == 0) {
return observableThrowError(error).delay(1000);
}
return observableThrowError(error);
})
.take(5)
.concat(observableThrowError(error));
}),
但它没有按预期工作,也没有进入 if 条件。
解决方案
您的代码中有几个错误:
- 您正在隐藏
error
变量 - 首先它是一个错误流,然后是一个错误对象。 - 使用
observableThrowError
withdelay
没有效果。Error 将绕过除那些处理错误的操作员之外的所有操作员。 - 您正在混合“
pipe(operator())
”样式运算符和原型样式运算符.operator()
。
我提出了一些改变:
.handle(customReq).pipe(
tap((ev: HttpEvent<any>) => {
if (ev instanceof HttpResponse) {
console.log('###processing response', ev, this.location);
}
}),
retryWhen(errors => errors
.pipe(
concatMap((error, count) => {
if (count < 5 && (error.status == 400 || error.status == 0)) {
return Observable.of(error.status);
}
return observableThrowError(error);
}),
delay(1000)
)
),
主要变化是通过第二个参数跟踪错误计数,concatMap
而不是使用take
主要用于取消订阅 observable 的操作符,我认为你想抛出一个错误。
推荐阅读
- kubernetes - GitLab Kubernetes 集成错误;Helm Tiller 的配置已经存在
- ios - 为什么编译器不允许从 peek 方法返回的泛型不是可选的?
- javascript - JQuery 功能 keyup 不适用于我的项目,其他功能有效
- php - php邮件功能的输入数组
- javascript - 如何在 MathJax 中使用张量?
- ios - 通过 kind 切换 Collectionviews 页眉/页脚
- firebase - FCM 消息始终以 503 响应
- azure - 在 Azure Data Lake Analytics 中添加 SQL Server 作为数据源
- java - Spring requestMapping 将 requestParam 中的 %2f 作为斜杠 (/)
- laravel-5 - 重定向路由未重定向到正确的路由