详细介绍RxJS在Angular中的应用

RxJS是一种针对异步数据流编程工具，或者叫响应式扩展编程；可不管如何解释RxJS其目标就是异步编程，Angular引入RxJS为了就是让异步可控、更简单。

而今就是要探讨什么是Observable、observer、operator、Submit、EventEmmit，以及如何去使用它们。

什么是Observable？

Observable只是一个普通函数，要想让他有所作为，就需要跟observer一起使用；前者是受后者是攻。而这个observer（后面我们会介绍）只是一个带有 next、error、complete 的简单对象而已。最后，还需要通过 subscribe 订阅来启动Observable；否则它是不会有任何反应；可以理解为陌*为了他们能在一起而提供的环境，而订阅也会返回一个可用于取消操作（在RxJS里叫 unsubscribe）。

当Observable设置观察者后，而连接并获取原始数据的这个过程叫生产者，可能是DOM中的 click 事件、input 事件、或者更加复杂的HTTP通信。

为了更好理解，先从一个简单的示例开始：

import { Component } from '@angular/core';import { Observable, Subscription } from 'rxjs';@Component({ selector: 'app-home', template: `<input type="text"> `})export class HomeComponent { ngOnInit() {  const node = document.querySelector('input[type=text]');  // 第二个参数 input 是事件名，对于input元素有一个 oninput 事件用于接受用户输入  const input$ = Observable.fromEvent(node, 'input');  input$.subscribe({   next: (event: any) => console.log(`You just typed ${event.target.value}!`),   error: (err) => console.log(`Oops... ${err}`),   complete: () => console.log(`Complete!`)  }); }}

示例中 Observable.fromEvent() 会返回一个Observable，并且监听 input 事件，当事件被触发后会发送一个 Event 给对应的observer观察者。

什么是observer？

observer非常简单，像上面示例中 subscribe 订阅就是接收一个 observer 方法。

一般在Angular我们 subscribe 会这么写：

input$.subscribe((event: any) => {});

从语法角度来讲和 subscribe({ next, error, complete }) 是一样的。

当Observable产生一个新值时，会通知 observer 的 next()，而当捕获失败可以调用 error()。

当Observable被订阅后，除非调用observer的 complete() 或 unsubscribe() 取消订阅两情况以外；会一直将值传递给 observer。

Observable的生产的值允许经过一序列格式化或操作，最终得到一个有价值的数据给观察者，而这一切是由一序列链式operator来完成的，每一个operator都会产生一个新的Observable。而我们也称这一序列过程为：流。

什么是operator？

正如前面说到的，Observable可以链式写法，这意味着我们可以这样：

Observable.fromEvent(node, 'input') .map((event: any) => event.target.value) .filter(value => value.length >= 2) .subscribe(value => { console.log(value); });