使用RxJ在Angular中按顺序执行一个后端调用并重试
在Angular中使用RxJS按顺序执行一个后端调用并重试的方法如下：
- 首先，确保你已经安装了RxJS库。可以通过以下命令来安装：
npm install rxjs- 在你的Angular组件中，导入所需的RxJS操作符和Observable：
import { Observable, of, throwError } from 'rxjs';
import { concatMap, retryWhen, delay, take } from 'rxjs/operators';- 创建一个后端调用的函数，并返回一个Observable对象。例如：
function backendCall(): Observable<any> {
// 这里是你的后端调用逻辑
// 可以使用HttpClient来发送HTTP请求
// 返回一个Observable对象
return this.http.get('https://api.example.com/backend');
}- 在你的组件中，使用RxJS操作符来按顺序执行后端调用并重试。例如：
backendCall()
.pipe(
retryWhen(errors => errors.pipe(
// 设置重试次数
take(3),
// 设置重试延迟时间
delay(1000)
))
)
.subscribe(
response => {
// 处理成功的响应
},
error => {
// 处理错误
}
);在上面的代码中，retryWhen操作符用于在发生错误时进行重试。take操作符用于设置重试次数，这里设置为3次。delay操作符用于设置重试延迟时间，这里设置为1秒。
这样，当后端调用失败时，它将按顺序重试3次，每次间隔1秒。如果重试3次后仍然失败，将会触发错误处理逻辑。
请注意，以上代码只是一个示例，你需要根据你的实际情况进行调整和扩展。另外，如果你想了解更多关于RxJS的内容，可以参考腾讯云的RxJS产品文档：RxJS产品介绍。
相关·内容
2回答
只是想将我的一些遗留代码迁移到较新版本的RxJ。该代码用于轮询：
Observable
.interval(5000)
.startWith(0)
.switchMap(() => this.apiService.getData())
.subscribe(data => /* ... */)
这在RxJs 5.2.0中运行得很好。
在RxJs 6.0.0中，这是由于多种原因而不能工作的(Observable唯一的方法是create，interval似乎是静态的，没有方法链接，.)。
如何在最新的RxJ中做到这一点？
浏览 0提问于2018-05-21得票数 0
回答已采纳
3回答
我正在使用ngrx测试一个Angular 2原型应用程序。在几乎所有的情况下，操作必须在更新状态之前异步地从后端API获取数据。我使用标准方法在ngrx/effects中完成此操作，方法是获取数据，然后使用获取的数据创建另一个操作来处理状态(当然是使用reducer )。
我注意到的是，第二个操作是按照从后端检索数据的顺序处理的，而不是按操作启动的顺序处理的。这可能会产生一些不幸的影响。
在ngrx中，有没有一种标准的方法来确保操作，包括依赖操作，按照它们被调度的顺序进行处理？
浏览 25提问于2018-02-21得票数 1
我在用：
"webpack": "4.12.0",
"rxjs": "5.5.9",
"@angular" : "5.2.11"
用DDL插件捆绑库。
{
entry:
{"rxjs_5_5_9": [
"rxjs
],
"angular_5_2_11": [
"@angular/common",
"@angular/compiler",
浏览 0提问于2018-06-22得票数 1
回答已采纳
2回答
我有两个对象流，帐户和余额。
我需要根据id和account_id合并(加入)这两个流
var accounts = Rx.Observable.from([
{ id: 1, name: 'account 1' },
{ id: 2, name: 'account 2' },
{ id: 3, name: 'account 3' },
]);
var balances = Rx.Observable.from([
{ account_id: 1, balance: 100 },
{ account_id
浏览 0提问于2017-04-25得票数 7
我正在使用RxJ处理RxJ，目前我发现解决这个问题很有挑战性。
我有一个数组，其中包含一些ids。
ids = [1,2,3,4]
然后，我有一个API，可以用id param调用它，它从数据库中删除带有给定id的项：
this.controller.deleteItem(id)
我想在数组中的每个id上调用这个API。
这些API调用应该严格按照顺序模式一个接一个地进行，如
this.controller.deleteItem(1) -> this.controller.deleteItem(2)等。
在所有api调用完成后，我想用以下方法获取数据：
this.controller.g
浏览 14提问于2022-10-14得票数 1
回答已采纳
我正在尝试理解当事件中心有重试策略时，分区是如何执行事件的，并且我找不到当一个人在事件中心的相同分区中遇到错误并重试时，新事件会发生什么的答案？ 我猜得到错误的事件不应该阻止新的事件执行，当它恢复时，它应该放在分区的末尾，所以在该事件发生错误后进入分区的任何其他事件都应该按顺序执行，而不会发生任何阻塞。 有人能解释一下在这种情况下到底发生了什么吗？谢谢。
浏览 31提问于2021-11-12得票数 0
回答已采纳
在过去，我们使用了几个angular2 websocket驱动程序，但是我们对它们并不满意，使用它们存在一些问题。所以我们决定用RxJ来尝试自己的运气。
这是我们第一次尝试：
@Injectable()
export class WebSocketService{
public createWebsocket(url: string): Subject<MessageEvent> {
let socket = new WebSocket(url);
let observable = Observable.create(
浏览 2提问于2017-05-26得票数 1
我在努力学习RxJ。我有这个工作代码，但是在一个AJAX错误之后，所有东西都停止工作了。
(function($, _) {
var alertBox = $('.alert-box');
alertBox.hide();
var fetchRepoButton = $('.fetch-repo');
var organization = $('#organization');
var repositories = $('.repositories');
var fetchRepoClickStream
浏览 1提问于2016-03-18得票数 0
回答已采纳
1回答
DOM悬浮时的规则可观测发射
、、、、
问题:寻找一种方法来获得有规律的事件发射(每200 to )，而用户在角度5上使用RxJ在DOM元素上徘徊。
实际上，通过简单的JS、RxJ或RxJ使用mouseover并不会产生规则的事件，而且这种行为与浏览器不同。使用debounce无助于事件的发布。
因此，我认为应该使用mouseenter和mouseleave事件以及它们之间的计时器。但我不知道如何从事件中启动和阻止计时器。
有点像，但有可观察的。
一个(坏的)代码比1000个单词好：
// RxJs syntax in typescript for angular
const enter = fromEvent(nativeElem
浏览 0提问于2018-07-27得票数 2
回答已采纳
1回答
特定观察者的可观察.next()
、、、、
在我的Angular 2应用程序中，我有一个通信服务，用于在其他angular组件上广播消息。
@Injectable()
export class CommunicationService {
private _broadcast = new Subject<EventParam>();
broadcast$ = this._broadcast.asObservable();
public sendEvent(eventParameters: EventParam): void {
this._broadcast.next(eventP
浏览 7提问于2016-07-21得票数 0
如何导入所有东西(如操作符、可观测值、.、.)在angular2(ts)中从Rxjs单次导入？
如何在angular2中使用单个导入来使用RxJ的所有内容？
浏览 6提问于2017-07-05得票数 0
回答已采纳
下面的代码是针对Angular的，我希望在角14中实现相同的功能/行为。
var getData = $timeout(function () {
return $q(function (resolve, reject) {
if (someCondition) {
resolve('data received!');
} else {
reject('something went wrong!');
}
});
}, 2000);
和取消行为
浏览 9提问于2022-11-23得票数 0
我正在使用AngularJS 2开发2种应用程序，我选择angular2是因为它速度快，而且与angular1相比还有许多其他优点。但我面临的问题，初步加载速度的应用。它加载大量的javascript文件，主要与RxJ相关。有什么方法来优化它吗？
浏览 2提问于2016-03-16得票数 2
我使用解析器从服务器获取数据 import {Resolve, ActivatedRoute} from "@angular/router";
import {Observable} from "rxjs";
import {RouterStateSnapshot} from "@angular/router";
import {ActivatedRouteSnapshot} from "@angular/router";
import {Injectable} from "@angular/core";
i
浏览 6提问于2019-06-03得票数 0
对不起，我有一个草率的问题，我真的希望在这里能找到一些帮助。
我将Angular 6用于前端，将.NET核心应用程序接口用于后端逻辑。API会调用一些外部API。有一种情况是我需要定期调用API来检查事件的状态。我每隔3秒打一次电话，可能的响应是“等待”、"ok“、”取消“、”错误“等等。在某些情况下，第一个调用在执行下一个调用之前没有响应，因此我不必要地对一个API进行了两次调用。
我尝试过使用.pipe(share().subscribe())，它解决了延迟响应在客户端做出不需要的操作的问题，但其他调用仍然会执行。
角度：
this.subscription = interval(
浏览 0提问于2019-07-24得票数 0
我们有一个应用程序，它使用Gmail访问Gmail中的电子邮件。
随机得到以下错误消息
Google.Apis.Requests.RequestError利率限制超过429错误[ MessageRate限制超过位置- ReasonrateLimitExceeded DomainusageLimits ]
然后，我们在错误事件上重新尝试代码，并得到
Google.Apis.Requests.RequestError后端错误500错误[ MessageBackend错误定位- ReasonbackendError领域全局]
然后，我们在错误事件的代码中重新尝试(我们尝试了3次)，它
浏览 16提问于2014-09-18得票数 7
我有一个角度解析器，从后端获取数据。我有以下调用要执行： GetProject(projectId): Observable<IProject>
GetSites(projectId): Observable<ISites[]>
GetPersons(siteId): Observable<IPerson[]> 我正在尝试使用combineLatest，但不确定如何在我的场景中使用RxJ。我希望在解析之前完成所有请求，但是GetPersons()应该将GetSites()结果中第一项的id作为输入。这是怎么做的？
浏览 35提问于2019-10-01得票数 3
回答已采纳
5回答
我需要构建一个流，它在调用后立即发出api请求，如果页面没有刷新，则每小时(下午1:00，下午2:00 )。我用setTimeout()构建它，但是我想用RxJ实现它。你能帮帮我吗？
isUpdated() {
return new Observable<Object>(function update(obs) {
this.http.get(`/update`).subscribe(data => {
obs.next(data);
});
const timer = (60 - new Dat
浏览 6提问于2020-12-03得票数 1
回答已采纳
2回答
环境: windows SFTP服务器上的iib9代理在windows上。
我们要求按顺序处理后端系统生成的一批文件(即FIFO)。一个批处理可以有多个文件。所有文件都放在FileInputNode使用move命令轮询的IIB源目录中。
我想知道FileInputNode是否能够按照后端系统创建的顺序拾取文件。
谢谢,
浏览 0提问于2015-12-14得票数 1
我正在用RxJ在Angular2中开发一个组件。这是我使用RxJ的第一步，我正在讨论如何使用RxJ的专业人员和const。
组件基于文本框。当文本框是被动的，没有焦点时，文本框将显示信息。当用户单击它时，焦点放在textbox上，它下面有一个工具提示，在用户编辑文本时显示信息。
在每个KeyUp上，处理textbox的值并验证多个业务规则，然后更新弹出以向用户提供反馈。
验证处理为debounceTime和distinctUntilChanged上可观察到的密钥的订阅。
有两个可用的事件：“开始编辑”(当用户单击textbox时)和“结束编辑”(当用户按回车、转义、TAB或单击出控件时)。
考
浏览 4提问于2016-11-25得票数 2
回答已采纳
我找到了很多关于如何绑定Angular 的资源：
@HostListener('document:click', ['$event'])
handleClick(event: Event) {
// etc
}
但是，我如何使用RxJ来流式传输它呢？
documentClickedStream = Observable.fromEvent(/* how to bind this? */)
不确定如何使用Angular文档中建议的装饰器模式来绑定以创建“单击任意位置”流。
浏览 3提问于2018-07-21得票数 4
我在angular中使用RxJ编写了以下代码：
private loadData(id) {
const inputData = .....
this.backendservice.getData(inputData).pipe(take(1)).subscribe(data => {
// do stuff
});
}
目前，代码只处理单个id。现在我想让它为多个I工作，并有一个可能的代码结构，如下所示：
private loadData(ids) {
const M
浏览 1提问于2020-11-20得票数 0
这主要是RxJ的最佳实践/方法问题，因为我的POC代码可以工作，但我对RxJ非常陌生。
这个问题归结为.subscribe()和.publish().connect()，因为两者似乎都在做同样的事情。
在我的angular2应用程序中，我有一个按钮，该按钮调用一个函数来将用户注销，该按钮调用我的服务中的一个函数，该函数执行一些服务器端操作，并返回一个URL来重定向用户。为了启动请求，我调用.subscribe()使可观察到的值开始产生值。我读了一篇关于“冷与热观察”的文章，另一种方法是调用.publish().connect()而不是.subscribe()。这两种方法都有什么好处吗。
<
浏览 3提问于2016-10-20得票数 21
回答已采纳
如何使用MySQL数据库和php集成Angular 2以实现数据库连接?？作为angular 2和使用不同端口的XAMPP。
因此，请帮助我给出的方法与后端和角度2 (前端).I是新的角度2。
浏览 0提问于2016-06-01得票数 1
我有一个角形6应用程序，被配置为重试http请求3次失败。我想从策略中排除某些urls : /login (例如)。
有办法吗？
我在RxJ文档中找不到任何答案。
谢谢你的帮助
这是我的密码：
@Injectable()
export class RetryInterceptor implements HttpInterceptor {
constructor( public spinnerService: NgxSpinnerService ) { }
timer: any;
intercept(req: HttpRequest<any>,
浏览 1提问于2022-06-01得票数 2
回答已采纳
1回答
我有两个项目。第一个项目是使用spring boot、hibernate和angular.js。另一个是后端服务，它接收数据并将其插入到表中。
当后端服务插入一些数据时，我想在spring hibernate项目中执行一个操作。
后端服务是一个Java程序。
浏览 0提问于2016-12-12得票数 0
我有一个angular2 Navbar组件，它包括一个注销按钮：
import { Component, OnInit } from '@angular/core';
import { LoginService } from '../login.service';
import { Router } from '@angular/router';
@Component({
selector: 'app-navbar',
templateUrl: './navbar.component.html',
s
浏览 1提问于2017-09-11得票数 0
回答已采纳
1回答
我有以下政策：
var sharedBulkhead = Policy.BulkheadAsync(
maxParallelization: maxParallelizations,
maxQueuingActions: maxQueuingActions,
onBulkheadRejectedAsync: (context) =>
{
Log.Info($"Bulk head rejected => Policy Wrap: {context.
浏览 0提问于2018-12-25得票数 0
回答已采纳
我想设置一个不断从后端接收值的页面，这样渲染的数据集就会随着时间的推移而增长，直到后端声明它已经完成(这可能永远不会发生)。类似于this article，但后端基于.NET核心。 因此，Angular服务最初看起来是这样的。 @Injectable()
export class TheService {
constructor(private httpClient: HttpClient) {}
getStuff(): Observable<Thing[]> {
return this.httpClient.get<Thing[]>('htt
浏览 13提问于2021-04-03得票数 0
回答已采纳
我是angular的新手，正在尝试建立一个健康检查连接来检查我的后端im背景的可用性。该检查将每隔5秒定期运行一次，以检查是否收到200 OK状态：
这是我的服务：
healthCheck() {
return this.http.get<any>(this.healthCheckAPI, { observe: 'response' })
.pipe(
map((resp: any) => {
if(resp.status !== 200){
throw resp;
浏览 0提问于2020-09-02得票数 0
我使用ng build --prod构建angular。
输出放到金字塔后端的静态文件夹中
在登录表单上，单击一个按钮，然后angular将http post发送到金字塔后端。金字塔后端接收用户名和pw。生成jwt令牌并发送响应。
Angular没有等待响应。
Angular使用subscribe和map() w/ observable实现http post。
创建一个jwt大约需要3秒钟。如果我不选择不创建jwt并从后端返回json超级快速，angular会立即捕捉到它。
如果金字塔后台的响应速度不够快，订阅的就不会捕获数据或错误。在订阅的回调函数中似乎没有执行任何东西，因为它就像是立即取消
浏览 0提问于2019-11-03得票数 2
我有一个Angular JS应用程序(前端)，可以与Laravel应用程序(后端)通信。
我被困在这个问题中，并不总是发生，但当它发生的时候，就在我验证了一些随机请求之后，得到了401 (未经授权)。但是如果我使用postman访问相同的url，它就能完美地工作。
我不确定显示为代码的是什么，所以这里有一些可能是有效的细节：
在Angular JS中，我的后端有25个不同的uri (xhr)。
我使用$httpProvider.interceptors来添加头文件：
'Accept': 'application/json',
'Authorization
浏览 0提问于2016-05-02得票数 0
4回答
我的服务是DService，我是服务链中的第四个环节，即呼叫流程是在线用户-> AService -> BService -> CService -> DService -> EService。
当我从EService调用DService时，它可以抛出可检索的异常，比如HttpTimeoutException。我通常会三次重试2-3次，如果它在2-3次重试后失败，我会抛出一个异常。
我的问题是，我向CService抛出的例外，是可检索的还是不可检索的？请在下面找到我对两种选择的Pros & Cons的评估
Cons从DService抛出可检索异常--如果D
浏览 4提问于2016-03-11得票数 3
我有一个大型的应用程序构建在Angular 7上。我想实现一些东西，如果开发人员忘记在ngOnDestroy中取消订阅，就会取消订阅RxJ订阅者。这是为了确保应用程序中没有内存泄漏。
有没有可能有卫兵？当路由改变时，卫士将检查最后加载的组件并取消订阅其订阅者？
浏览 3提问于2020-11-13得票数 0
嗨，对不起，我的可怜的英语
为什么摇尾搜索返回搜索后的PostgresSearchResult？
我要PageQuerySet
像Django postgres一样搜索后端，因为我在搜索后不能使用values_list
我想获得页面路径列表(因为我想按路径查找页面父母(类别页))
而且我不能在搜索前使用values_list，因为它不起作用
我知道，我可以使用Forloop，但是每次运行大约需要5秒。
我的代码非常简单：
Django方法：#Work
ProductPage.objects.filter(title__search="phone").values_list(&#
浏览 1提问于2017-11-11得票数 0
1回答
当前堆栈: Stripe V3集成+ Angular 8，带有用于我的SPA的nodeJS/AWS后端。
我注意到，在升级到Angular 8之后，我经常失去与Stripe的连接，这损害了各种组件上的一些功能，因为我在组件初始化时调用Stripe来获取帐户余额信息。这是我在浏览器控制台中经常看到的：
刷新页面解决了这个问题，但这个问题会带来糟糕的用户体验。我甚至在每个组件文件的HTML文件的底部添加了script标记，以便在渲染新组件时重新加载Stripe，但没有成功。我很好奇是否有其他人遇到了同样的问题，或者遇到了这个问题并设法解决了它。
提前感谢！
浏览 5提问于2020-05-26得票数 0
我使用nodejs + mongodb作为一个大型分布式web应用程序的后端。我有一系列的事件，需要按照特定的顺序。有多个服务生成这些事件，我的应用程序应该在它们传入时处理和存储它们，并且在任何给定的时间，我都希望它们按正确的顺序排列。
我不能依赖时间戳，因为javascript只提供以毫秒为单位的时间戳，这对我的情况来说不够准确。
我的数据库中有两个集合。一个存储事件，另一个存储索引，表示我的事件顺序。我尝试过使用findOneAndUpdate来自动增加我的索引。然而，这似乎不起作用。
console.log('Adding');
console.log(event.typ
浏览 0提问于2019-01-04得票数 0
我使用了ActiveMQ 5.10.0，并配置了相同的接收器和代理: tcp://localhost:61666?jms.prefetchPolicy.queuePrefetch=0&jms.redeliveryPolicy.maximumRedeliveries=5&jms.redeliveryPolicy.initialRedeliveryDelay=5000&jms.redeliveryPolicy.useExponentialBackOff=true&jms.redeliveryPolicy.backOffMultiplier=2.0&jms.n
浏览 0提问于2015-01-06得票数 0
我对RxJ很陌生。我试图在没有运气的情况下递归运行可观察的函数。我想按这个顺序打印。
表单文本框图标文本框区域
这是我目前尝试过的。任何帮助都将不胜感激。
const args = {
name: 'form',
children: [{
name: 'textbox',
children: [{
name: 'icon',
children: []
}]
}, {
name: 'textarea',
children: []
}]
};
i
浏览 0提问于2019-02-07得票数 1
回答已采纳
1回答
我的package.json中有以下依赖项：
"dependencies": {
"@angular/animations": "~12.1.0",
"@angular/common": "~12.1.0",
"@angular/compiler": "~12.1.0",
"@angular/core": "~12.1.0",
"angulartics2": "^11.0.0",
"rxjs"
浏览 17提问于2022-06-21得票数 1
回答已采纳
我正在本地实验一个非常基本的角度页。我可以通过运行http-服务器在我的Windows上完成这个任务。然而，这一点今天已经停止了。我回过头去，把我的页面压缩到非常基本的、hello-world级别的代码，但是我仍然无法获得任何角度的功能来工作。
有人知道为什么下面的页面不会输出基本的数学问题，而不是花括号吗？正如我提到的，这件事昨天做得很好。
app.js：
var app = angular.module('store', []);
index.html：
<!DOCTYPE html>
<html ng-app="store">
浏览 1提问于2017-05-12得票数 0
回答已采纳
我对RxJ和Angular2并不熟悉，我正在尝试正确地处理错误。我看到了一些带有onNext、onError和onCompleted事件的可观测实例(例如，，但我看到的所有Angular2 http示例似乎都只是使用.catch和.map方法，我不知道这与OnNext/OnError/OnCompleted模型有什么关系。我正在处理来自的代码)：
let stream = this.http.request(options.url, options)
.catch(error: any) => {
this.errorsSubject.next(error);
浏览 1提问于2016-08-03得票数 2
回答已采纳
在Angular 9中，只要满足后端条件，我就会强制显示页面(例如，直到填充了一些强制信息)。这样，用户将不能访问网站的任何其他页面。你知道怎么做吗？
谢谢
浏览 0提问于2020-07-14得票数 0
我已经在Azure API Management中创建了一个API来从后端API获取数据。 来自后端API的结果被分页，在响应中包括必须用于下一个请求的' next‘url。 如何处理这个“下一个”url，以便通过Azure APIM连接所有分页响应并将所有分页响应的总和作为一个响应返回？
浏览 9提问于2019-03-18得票数 1
1回答
我有一个角度应用程序，在这个应用程序中，我使用RxJ库从后端API服务器获取数据。电话看起来是这样的：
allPowerPlants(onlyActive: boolean = false, page: number = 1): PowerPlant[] {
const self = this;
const path = `/powerPlants?onlyActive=${onlyActive}&page=${page}`;
this.apiService.get(path).subscribe(
powerplants => {
浏览 4提问于2017-08-29得票数 0
回答已采纳
因此，Firestore文档/集合引用上的onSnapshot处理程序基本上是：
ref.onSnapshot(query => {}, error => {}, complete => {})
我不明白它是怎么挂在AF2上的。Firestore文档强调必须处理在回调中发生的各种错误。
它是不是简单地翻译成RxJS中的等价物：
this.afDb.collection('my_collection')
.valueChanges()
.retry();
考虑到我的Angular 5服务是单例的，我更希望他们的活动数据侦听器(观察值)不会因为测试版中
浏览 0提问于2017-11-22得票数 0
在我的Angular6应用程序中，我使用HttpClient将头注入到htpp调用中，以便从后端服务器获取数据：
我的服务:
@Injectable()
export class LoadUserInfosService {
public _headers = new HttpHeaders().set('Content-Type', 'application/json');
constructor(private httpClient: HttpClient) {}
getUserPnsInfos(cuid): Observable<o
浏览 0提问于2018-07-13得票数 6
我在周末遇到了一个问题，网站上的angularjs代码突然停止工作。在它工作和停止工作期间，没有对任何文件进行更新。
控制台提供的错误为" error：$injector:nomod模块不可用“。
$注入器/nomod?p0=bkApp
下面是现在断开的页面，错误为-
以下是头部代码：
<script async src="//ajax.googleapis.com/ajax/libs/angularjs/1.4.9/angular.min.js"></script>
<script async src="//ajax.googl
浏览 2提问于2016-08-30得票数 0
场景我已经在WSO2中配置了API，它连接到我的后端HTTP服务。
在调用后端服务之前，我想调用另一个HTTP端点(XML )来执行一些验证。如果验证响应成功，则可以调用API网关中配置的后端点，否则API需要返回错误。请告诉我如何做到这一点。
谢谢你，卡西
浏览 2提问于2019-12-24得票数 0
2回答
标题几乎是自我解释的。我找不到关于它的任何信息。RxJ的角度使用RxJ，遮罩下的可观测值在React和MobX中也是一样的吗？
浏览 0提问于2018-12-10得票数 13
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
