Rxjs 01-认识Rxjs

2023-11-06 18:22:35





## Rxjs 概述

Rxjs 是一个基于观察者模式和迭代器模式以函数式编程思维来实现的响应式编程库。它可以帮助我们轻松处理数据流，并使用函数式编程思维来编写代码。Rxjs 具有强大的功能，可以帮助我们解决各种复杂的问题，例如处理异步操作、管理并发、处理事件流等。

Rxjs 的核心思想是观察者模式。在观察者模式中，有一个被观察者对象和一个或多个观察者对象。被观察者对象负责发出事件，观察者对象负责监听这些事件并做出相应的反应。Rxjs 中的被观察者对象称为可观察对象，观察者对象称为订阅者。

## Rxjs 的基本概念

Rxjs 的基本概念包括可观察对象、订阅者、事件和操作符。

* 可观察对象：可观察对象是 Rxjs 中的核心概念。它是一个可以发出事件的对象。可观察对象可以是任何对象，例如一个函数、一个类或一个数组。
* 订阅者：订阅者是监听可观察对象事件的对象。订阅者可以是任何对象，例如一个函数、一个类或一个数组。
* 事件：事件是可观察对象发出的通知。事件可以是任何值，例如一个字符串、一个数字或一个对象。
* 操作符：操作符是 Rxjs 中用于处理可观察对象事件的函数。操作符可以对事件进行各种操作，例如过滤、映射、合并等。

## Rxjs 的使用

Rxjs 的使用非常简单。首先，我们需要创建一个可观察对象。然后，我们可以使用订阅方法来订阅这个可观察对象。当可观察对象发出事件时，订阅者就会收到这些事件并做出相应的反应。

以下是一个简单的 Rxjs 示例：

```javascript
// 创建一个可观察对象
const observable = Rx.Observable.from([1, 2, 3, 4, 5]);

// 订阅这个可观察对象
observable.subscribe(
  (value) => {
    console.log(value);
  },
  (error) => {
    console.log(error);
  },
  () => {
    console.log('Completed');
  }
);