RxJS 是一款基于响应式编程（Reactive Programming）思想的 JavaScript 库。它可以帮助我们更简洁、高效地管理异步数据流，并大幅度提升前端应用的响应性能。在 Angular 中，RxJS 是不可或缺的一部分，通过它我们可以更好地管理组件和服务之间的数据流动。本篇文章将为大家介绍 Angular 中 RxJS 的使用教程，包括基本概念、操作符和示例代码。
基本概念
在 Angular 中使用 RxJS，我们需要掌握几个基本概念：
Observable
Observable（可观察对象）代表一个可观察的数据源，它可以是一个 AJAX 请求、Websocket 数据流或者一个侦听 DOM 事件的对象等。Observable 可以发出三种类型的值，即 next（下一个值）、error（发生错误）和 complete（完成）。
下面是创建一个简单的 Observable 的示例代码：
import { Observable } from 'rxjs';
const observable$ = new Observable(observer => {
observer.next(1);
observer.next(2);
observer.next(3);
observer.complete();
});Subscription
Subscription（订阅）代表 Observable 的执行，并负责清理资源（取消订阅）。
下面是使用 Subscription 订阅一个 Observable 的示例代码：
-- -------------------- ---- ------- ------ - ---------- - ---- ------- ----- ----------- - --- ------------------- -- - ----------------- ----------------- ----------------- -------------------- --- ----- ------------ - ---------------------- ----- -- ------------------- ----- -- --------------------- -- -- ------------------------ -- --------------------------- -- ----
Operator
Operator（操作符）是一种用于处理 Observable 数据流的方法，常见的操作符有 map、filter、switchMap 等。操作符可以将输入的 Observable 转换为另一个 Observable。
下面是一个使用 map 操作符将 Observable 中的值加一的示例代码：
-- -------------------- ---- ------- ------ - -- - ---- ------- ------ - --- - ---- ----------------- ----- ----------- - ----- -- --- ----------------- ------- -- --- - -- ------------ ----- -- ------------------- ----- -- --------------------- -- -- ------------------------ --
操作符
在 Angular 中，RxJS 有大量的操作符可以使用。操作符以管道（pipe）的方式串联在一起，将 Observable 的数据流进行转换。下面介绍几个常见的操作符：
map
map 操作符用于对 Observable 中发出的每一个值进行映射，返回一个新的 Observable。
使用 map 操作符将 Observable 中的每个值加一：
-- -------------------- ---- ------- ------ - -- - ---- ------- ------ - --- - ---- ----------------- ----- ----------- - ----- -- --- ----------------- ------- -- --- - -- ------------ ----- -- ------------------- ----- -- --------------------- -- -- ------------------------ --
filter
filter 操作符用于过滤 Observable 中的值，返回一个仅包含符合条件的值的新的 Observable。
使用 filter 操作符提取大于 2 的值：
-- -------------------- ---- ------- ------ - -- - ---- ------- ------ - ------ - ---- ----------------- ----- ----------- - ----- -- --- ----------------- ---------- -- --- - -- ------------ ----- -- ------------------- ----- -- --------------------- -- -- ------------------------ --
tap
tap 操作符用于数据转换时不改变值本身，而是对值进行操作。可以用于执行调试代码或者日志记录。
使用 tap 操作符打印 Observable 中的每个值：
-- -------------------- ---- ------- ------ - -- - ---- ------- ------ - --- - ---- ----------------- ----- ----------- - ----- -- --- ----------------- ------- -- ----------------- -------- ----- ------------ ----- -- ------------------- ----- -- --------------------- -- -- ------------------------ --
switchMap
switchMap 操作符用于嵌套 Observable，返回一个新的 Observable，可以用它实现异步请求等操作。
使用 switchMap 操作符将一个 Observable 中的值映射到一个异步请求：
-- -------------------- ---- -------
------ - -- - ---- -------
------ - --------- - ---- -----------------
----- ----------- - ----- -- ---
-----------------
------------- -- -----------------
------------
----- -- -------------------
----- -- ---------------------
-- -- ------------------------
--
-------- ---------------- -
------ --- ------------------- -- -
------------- -- -
---------------------- ------ ---------
--------------------
-- ------
---
-示例代码
下面是一个使用 RxJS 实现的自动搜索输入框的示例代码：
search.component.ts
-- -------------------- ---- -------
------ - ---------- ------ - ---- ----------------
------ - ------- - ---- -------
------ - ---------- --- - ---- -----------------
------ - ---------- - ---- -----------------
------------
--------- -------------
--------- -
------ ----------- -------------------- -------------------------------------------
----
--- ----------- ---- -- --------- --------- -------
-----
--
--
------ ----- --------------- ---------- ------ -
------- --------------- - --- ------------------
------ ------
------------------- ---- ----------- --
---------- -
-----------
------
-------------------- -- -----------------------------
-------------- ---- -- ----------------
-
---------------- -- ----------- - --------
-
-api.service.ts
-- -------------------- ---- -------
------ - ---------- - ---- ----------------
------ - ---------- - ---- -----------------------
------ - ---------- - ---- -------
-------------
----------- -------
--
------ ----- ---------- -
------ - ---------------------------------------------
------------------- ----- ----------- --
------------------ -------- --------------- -
----- --- - ---------------------------------
------ -------------------
-
-结论
RxJS 是一个强大的数据流处理工具，可以提高前端应用的响应速度和性能。在 Angular 中，RxJS 是不可或缺的一部分，通过它我们可以更好地管理组件和服务之间的数据流动。掌握基本概念和操作符，并学会使用示例代码，在 Angular 中编写响应式代码将变得更加容易。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/672065212e7021665e02096e