RxJS 中的异常处理：retry 和 retryWhen

在前端开发中，我们经常会遇到一些网络请求失败或者其他异常情况。这时候，我们需要对异常进行处理，以避免程序出现崩溃或者无法正常运行的情况。在 RxJS 中，我们可以使用 retry 和 retryWhen 这两个操作符来处理异常情况。

retry 操作符

retry 操作符可以在发生异常的情况下，自动重新发起请求，直到请求成功或者达到最大重试次数为止。retry 操作符的语法如下：

observable.retry(count)

其中，count 表示最大重试次数。如果不传入 count 参数，则会一直重试，直到请求成功为止。

下面是一个使用 retry 操作符的示例代码：

import { Observable } from 'rxjs';

const observable = Observable.create(observer => {
  observer.next('Hello');
  observer.next('World');
  observer.error('Something went wrong');
});

const result = observable.retry(3);
result.subscribe({
  next: value => console.log(value),
  error: error => console.log(error),
  complete: () => console.log('Complete')
});

在上面的代码中，我们创建了一个 observable 对象，并且在第三个 next 方法中模拟了一个异常情况。然后，我们使用 retry 操作符来进行重试，最多重试 3 次。运行代码后，我们可以看到程序会在发生异常后自动重试，直到达到最大重试次数为止。

retryWhen 操作符

retryWhen 操作符可以在发生异常的情况下，根据指定的条件，自动重新发起请求，直到请求成功或者达到最大重试次数为止。retryWhen 操作符的语法如下：

observable.retryWhen(notifier)

其中，notifier 是一个函数，用来判断是否需要进行重试。如果 notifier 返回一个 observable 对象，则会在 observable 对象发出值的时候进行重试。如果 notifier 返回一个错误，则会立即停止重试，并抛出该错误。

下面是一个使用 retryWhen 操作符的示例代码：

import { Observable } from 'rxjs';

const observable = Observable.create(observer => {
  observer.next('Hello');
  observer.next('World');
  observer.error('Something went wrong');
});

const result = observable.retryWhen(errors => errors
  .do(val => console.log(`Value ${val} was too high!`))
  .delayWhen(val => Observable.timer(val * 1000))
);

result.subscribe({
  next: value => console.log(value),
  error: error => console.log(error),
  complete: () => console.log('Complete')
});

在上面的代码中，我们创建了一个 observable 对象，并且在第三个 next 方法中模拟了一个异常情况。然后，我们使用 retryWhen 操作符来进行重试。在 retryWhen 的参数中，我们使用了 do 和 delayWhen 操作符，来判断是否需要进行重试以及重试的时间间隔。运行代码后，我们可以看到程序会在发生异常后自动重试，直到达到最大重试次数为止。

总结

在 RxJS 中，我们可以使用 retry 和 retryWhen 这两个操作符来处理异常情况。使用这两个操作符可以让我们的程序更加健壮，避免出现崩溃或者无法正常运行的情况。在实际开发中，我们可以根据具体情况选择使用哪个操作符来进行异常处理。

来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/658d66cbeb4cecbf2d35b7ab