前言
在 RxJS 中，错误处理是一个很重要的话题。由于 RxJS 的特殊性质，错误是非常常见的。一旦出现了一个错误，我们需要对其进行处理，否则整个应用程序可能会崩溃。
在本文中，我们将介绍 RxJS 中经常用到的错误处理算子。我们将讨论不同类型的错误，以及如何处理这些错误。我们还将详细介绍每个操作符的使用方法并提供示例代码。
catchError
catchError 操作符是 RxJS 中最常用的错误处理操作符之一。它用于捕获 Observable 序列中的错误，并且返回一个备用的 Observable。当原始的 Observable 发生错误时，备用的 Observable 将被发射，允许我们在错误处理器中进行适当的逻辑处理。
示例代码：
-- -------------------- ---- -------
------ - ----------- -- - ---- -------
------ - ---------- - ---- -----------------
--- ---------- - ----------------- ------------
----------------
---------------- -- -
------------------- -- ------ -----------
------ ------
--
-
------------
----- ----- -- ------------------ -----------
------ ----- -- --------------------- -----------
--------- -- -- ------------------------
---在以上示例中，当原始的 Observable 发生错误时，catchError 操作符返回另外一个 Observable（使用了 of 操作符，返回一个包含单个数字 0 的 Observable）。这个新的 Observable 将发送到订阅者，并且我们可以在 catchError 的回调函数中对错误进行适当的处理。
retry
retry 操作符用于在 Observable 发生错误时重新尝试操作。它可以尝试无限次数，也可以根据自定义规则来决定尝试的次数。 retry 操作符始终返回一个 Observable，该 Observable 要么是原始 Observable 发生错误后的一个新 Observable，或者仅是原始 Observable 的一个代理，其中包含由 retry 操作符发出的错误。
示例代码：
-- -------------------- ---- -------
------ - -- - ---- -------
------ - ---- ---- ----- - ---- -----------------
--- ------- - --
--- ------- - ------------
------
------ -- -
----------
-- -------- - -- -
----- --- ------------ ------------
-
--
--
-------------
--------
-------------------------
在以上示例中，我们可以看到，我们在执行 Observable 时，它会抛出一个错误（Error occurred!）。由于我们使用 retry 操作符并将重试次数设置为 2，因此我们会尝试 2 次，但是由于在第 2 次之后 Observable 此时正确执行，所以我们最终得到了一个发射了单个字符串的 Observable。
throwIfEmpty
throwIfEmpty 操作符可用于检查 Observable 是否为空，如果为空，则抛出异常。当我们知道 Observable 应该包含元素时，这种操作变得特别有用，因为我们可以确保 Observable 中始终有值。
示例代码：
-- -------------------- ---- -------
------ - -- - ---- -------
------ - ------------ - ---- -----------------
--- ------ - ----------
--------------- -- --- ----------------- -- --------
--
--- --------- - ------------------
--------------- -- --- ----------------- -- --------
--
------------------
------ ----- -- --------------------- ------------------
---
---------------------------------在以上示例中，empty$ 是一个空的 Observable，而对它进行订阅时，我们在 throwIfEmpty 内回调传递一个错误。因为它是一个空的 Observable，所以会抛出错误。而对于 hasValue$ 中，由于 Observable 有一个值而不是空，所以不会抛出错误。
timeoutWith
timeoutWith 操作符用于设置 Observable 操作的超时时间。如果在超时时间内 Observable 操作没有返回值，则我们可以选择返回一个备用的 Observable。
示例代码：
import { interval, of } from 'rxjs';
import { timeoutWith } from 'rxjs/operators';
interval(1000).pipe(
timeoutWith(3000, of('Observable timed out'))
).subscribe(console.log);在以上示例中，我们使用 interval 创建了一个每隔 1 秒发出一个数字的 Observable。由于我们将 timeoutWith 操作符的超时时间设置为 3000 毫秒，因此我们最终得到 Observable timed out 值。
Conclusion
以上是 RxJS 中常用的错误处理 Operators。除了这些，还有其他的错误处理 Operator 也很有用。学习和理解这些操作，可以帮助开发人员更好地维护应用程序，避免不必要的错误和崩溃。在日常应用中，这些操作符的使用也十分必要。希望在您的工作中能够有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/67bc274aa231b2b7edd94276
