在前端开发中，RxJS 是一种非常流行的函数式编程库。Retry 操作符则是 RxJS 中非常重要的一种操作符，它可以帮助我们在请求失败后进行重试。本文将详细讲解 RxJS 中的 Retry 操作符，并提供示例代码以便读者学习和练习。
什么是 Retry 操作符？
Retry 操作符是 RxJS 中的一种操作符，用于在 Observable 发生错误时重试，以便尝试多次，直到符合条件为止。使用 Retry 操作符可以使我们更好地对错误进行处理，并确保请求成功。
Retry 的使用
Retry 操作符具有很多选项，可以根据实际需求灵活使用。常见的选项包括 retry() 和 retryWhen()。
retry()
retry() 可以用于无条件地重试 Observable，直到它发出完成（Complete）信号、发出错误（Error）信号后重试，或达到你给定的最大尝试次数。
以一个简单的例子来说明：
-- -------------------- ---- -------
------ - -- - ---- -------
------ - ---- --- - ---- -----------------
------- --
------
----- -- -----------------
----- -- --------------------- -------
-
---------
------------
------- - -------------------- ------- --
---------- - ------------------- --------- -
---代码解释：
- 导入 RxJS 中的 of、map 和 tap 操作符，of 操作符构造一个 Observable，发出每个参数然后发出完成信号。
- 该 Observable 中尝试了两个元素，其中一个是字符串（'a'），另一个是数字（1）。
- map 操作符将每个元素转换成大写字母，tap 操作符在此时记日志。
- retry(3) 操作符告诉 Observable 在错误的情况下尝试重试三次。
- 最后，subscribe() 将输出 Observable 中的所有元素。
retryWhen()
如果我们希望在错误出现时自定义重试行为，那么可以使用 retryWhen() 操作符。它采用一个工厂方法作为参数，该方法返回一个 Observable，会根据其发出的信号（或者由其结束）来控制重试行为。
看下方示例：
-- -------------------- ---- -------
------ - --- ----- - ---- -------
------ - --------- ----------- --------- - ---- -----------------
--- ------- - --
----- ------ - ---------
----- ------- - ------------
----------- -- -
-- -------- --- -- -
------ -------- ------- ------ ----- - -------------
-
----------
------ ---------------- ------- ------- ---- ------- ----- - - ------- - - ----- ------ ------ -----
---
---------------- --
------------
-------------- -- ------ --- ----- ------- ------- ---- ------- ----- - ----- ------ ------ ----
- --------------- ---------
- -----------
-------------- -- ------
-
-
--
----- --------- - --------------------- -- ------------------代码解释：
- 设置 retries 的值为 3
- 构造一个只有一个 null 元素的 Observable。
- 通过使用 mergeMap 操作符，尝试递减 retries 的值，直到值为 0。处理完每个元素，发出错误。
- 使用 retryWhen 操作符在出现错误时进行重试。它返回一个 Observable，该 Observable 决定着“何时”将 Observable 重试。尝试将错误消息映射到 Observable，根据错误消息进行相应的决策（这里是决定是重试还是结束 Observable），最后在错误处理结束后返回相应的 Observable。如果不想进行重试，则会返回“空”Observable。
- subscribe 最终将返回一个错误消息或较少并且没有错误的输出。
重试的应用
重试是前端开发中非常常见的需求。比如，当请求超时或者服务端繁忙时，我们可以使用 Retry 操作符进行重试，使我们更快地获得我们需要的结果。并且，执行重试操作对于移动端或者弱网络的情况下，更是一种有用的处理方式。
总结
在本文中，我们学习了 RxJS 中的 Retry 操作符。重试操作符可以在 Observable 中出现错误时进行重试，以便重新尝试多次请求。
根据实际需求，我们可以使用 retry() 或 retryWhen()，并设置一些条件，以便更好地控制重试行为。希望本文可以帮助大家更好地理解和运用 RxJS 中的 Retry 操作符。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64579316968c7c53b0a39e92