如何继续致电后端API，直到我在回复中收到200个好的

Question

我正在开发一个Angular项目，我需要致电后端API，如果它不是返回200，那么我需要每30秒钟调用此API，直到我获得200个AP。

我使用的是Angular，我通常称为后端API的格式是：

this.productServices.onProductBuy(product_id).subscribe(response => {
    console.log(response)
});

这只是一个get请求。

OnProductBuy（）包含一些调用API代码，如果未收到此onProdCutBuy API，则仅收到http 200， 我需要再一次称此API，直到获得200。

Answer 1

这应该解决问题：

this.productServices.onProductBuy(product_id).pipe(
  retry({
    delay: 30 * 1000
  } as any)
).subscribe(response => {
  console.log(response)
});

这重试了无限的次数，也增加了30秒的延迟。 重试的类型定义似乎与我使用的版本打破了。这就是为什么我必须将用作任何。

但是 source code> source Code 表明，该<显示了<代码>重试接受具有延迟属性的对象：

export interface RetryConfig {
  /**
   * The maximum number of times to retry. If `count` is omitted, `retry` will try to
   * resubscribe on errors infinite number of times.
   */
  count?: number;
  /**
   * The number of milliseconds to delay before retrying, OR a function to
   * return a notifier for delaying. If a function is given, that function should
   * return a notifier that, when it emits will retry the source. If the notifier
   * completes _without_ emitting, the resulting observable will complete without error,
   * if the notifier errors, the error will be pushed to the result.
   */
  delay?: number | ((error: any, retryCount: number) => ObservableInput<any>);
  /**
   * Whether or not to reset the retry counter when the retried subscription
   * emits its first value.
   */
  resetOnSuccess?: boolean;
}

export function retry<T>(count?: number): MonoTypeOperatorFunction<T>;
export function retry<T>(config: RetryConfig): MonoTypeOperatorFunction<T>;

Answer 2

您可以使用 rxjs retry ：

this.productServices.onProductBuy(product_id)
  .pipe(retry(2)) // <-- Here
  .subscribe(response => {
    console.log(response)
  });

随着上述内容，它将重试两次。如果您想永远重试，请不要添加一个数字，它将不断重试直到获得成功为止：

this.productServices.onProductBuy(product_id)
  .pipe(retry()) // <-- Here
  .subscribe(response => {
    console.log(response)
  });

不要忘记避免内存泄漏陷阱带有订阅。

Answer 3

好吧！

因此，就我个人而言，我相信这应该由后端框架来处理。但是，如果您真的想在应用程序的角度上实现这一目标，这是我对问题的解决方案（显然不使用重试，因为有时可能会像其他提到的那样有问题）：

1. 将产品服务类中的主题定义为下图：

   public onproductBysubject = new object（）;

2. 在component.ts文件中定义一种方法（如果还没有定义），以执行服务类中所需方法的调用：

   public justanexample（）{
   this.productservices.onproductbuy（product_id）.subscribe（response =＆gt; {

   if（wendesp.code！= 200）{
   settimeout（this.productservices.onproductbysubject.next（true），30000）;
   }
   console.log（响应）
   }）;
   }

3. 在ngoninit（）生命周期钩功能中，进行订阅：

   this.mysubscription = this.productservices.onproductbysubject.subscribe（value =＆gt; {{
   if（value）this.justanexample（）;
   }）;

4. 在ngdestroy（）生命周期钩功能中，退订“ mySubscription”。

让我知道这是否会有所帮助并为我的答案提供帮助，以便对他人有所帮助。