【angular】Observable & RxJs

该知识点还未学习，先转载备份......

状态管理？
observables：观察者与订阅者模式
RxJs

本文转自知乎：Angular 真的需要状态管理么？

前端在过去很多年压根就没有听说过状态管理这东西，即使在 Angular.js 火热的那几年也很少有人谈前端的状态管理，直到 React 的出现，各种状态管理框架 Flux，Redux，Mobx, ... 层出不穷，让人眼花缭乱。如果你是一个 Angular 的开发者，貌似没有状态管理框架也可以正常的组件化开发，并没有发现缺什么东西。那么在 Angular 中如何优雅的管理前端状态呢？

首先前端组件化开发已经变成了标准，对于他的好处和概念网上有很多文章介绍，目前三大框架都是遵循组件化开发的思想，而且组件之间的通信基本都是单向数据流，就是说父组件通过属性绑定把数据传递给子组件，子组件想要修改传入的数据必须通过事件回调和父组件通信，React 中如果组件的层级比较深，同时父组件与很远的一个子组件之间需要共享数据，那就意味着数据会从父组件一层层往下传递，如果底层的组件需要修改数据，必须通过事件层层返回，这对于开发来说基本是灾难，代码变得难以维护，记得听说过一句很有哲学的话：任何解决不了的问题都可以引入一个第三方去解决，没错， 引入一个第三方存放维护这些状态，组件直接读取第三方把需要的状态展示在视图上，那么怎么样合理的设计这个第三方呢，那么 Flux，Redux，Mobx 这些状态管理类库基本都是所谓的第三方。

那么在 Angular 中为啥不是必须要状态管理框架呢？

首先在 Angular 中有个 Service的概念，虽然 Angular 对于 Service 基本上什么都没有做，连一个基类 BaseService 都没有提供，但是以下2个特性决定了在 Angular 中会很轻松的通过 Service 实现一个上述的第三方。

1. Angular 中定义了一个 Service 后可以通过依赖注入很轻松的把这个服务注入到组件中，这样组件就可以调用 Service 提供的各种方法；
2. 我们可以把组件需要的状态数据存储在 Service 中，然后把注入的 Service 设成 public，这样在模版中可以直接通过表达式绑定 Service 中的数据 。

基于以上 2 个特性，基本上在使用 Angular 开发应用时一旦遇到组件之间共享数据，都可以使用 Service 轻松应对（当然做一个 SPA 单页应用，即使组件之间没有共享数据，也建议 使用 Service 作为数据层，统一维护业务逻辑），官方提供的英雄编辑器示例 MessageService，就是直接公开服务在组件模版上绑定的，代码如下，所以 Angular 不像 React 那样必须完全依赖状态管理框架才可以做组件之间的数据共享。：

export class MessageService {
  messages: string[] = [];

  add(message: string) {
    this.messages.push(message);
  }

  clear() {
    this.messages = [];
  }
}

@Component({
  selector: 'app-messages',
  template: `
<div *ngIf="messageService.messages.length">
  <h2>Messages</h2>
  <button class="clear"
          (click)="messageService.clear()">clear</button>
  <div *ngFor='let message of messageService.messages'> {{message}} </div>

</div>
`
})
export class AppMessagesComponent implements OnInit {

  constructor(public messageService: MessageService) { }

  ngOnInit() {
  }
}

那么在 Angular 中使用 Service 做状态管理会遇到哪些问题呢，如果只是很简单的状态通过 Service 直接管理肯定没有任何问题，但是一旦 Service 存储的状态与每个组件需要展示的状态不一致就很难处理了。比如下图是我们经常遇到的场景，首先项目中会有很多自定义的视图，默认只展示 2 个视图，其余的视图在更多视图中。

image

我们可以很简单把所有的视图列表存放在 ViewService中, 针对视图的增删改逻辑都移动到 ViewService中, 伪代码如下，但是有个问题就是导航条组件和更多视图组件两个组件展示的视图数据不一样，需要把视图列表进行分割，导航条只展示 2 个视图，其余的在更多视图中。

class ViewService {
    views: ViewInfo[];

    addView(view: ViewInfo) {
        // 调用 API
        this.views.push(view);
    }

    updateView(view: ViewInfo) {
    }

    removeView(view: ViewInfo) {
    }
}

此时要想解决这个问题怎么办？我能想到快速解决的有两种方式

1. 在 ViewService 除了存储所有的 views 外单独存储导航条的 2 个视图 toolbarShowViews 和更多视图 moreViews，这么做的缺点就是每次增删改视图后都需要重新计算这2个数组，Service 中的状态会增多，如果有一天需求变了，所有的视图直接显示，显示不下换行，那还得回过头来修改 ViewSevice 中的代码，这本来是应该是导航条和更多视图组件的状态，现在必须和全局的视图状态放在了一起，虽然可以解决问题，但是不完美；
2. 还有一种更恶心的做法就是在导航条组件模版上循环所有视图，根据 index 只取前 2 个展示，更多组件模版循环所有视图只展示后面的视图，这种做法缺点是把逻辑代码放到了视图中，如果有更复杂的场景通过模版表达式未必可以做到，其二是循环了一些不需要的数据或许在某些场景下有性能损耗，至于示例中的那几个视图肯定没有性能问题。

那么除了上述 2 中解决方式外还有更优雅更好的方式么？答案就是 Observable( 可被订阅的对象) ，当然 Angular 框架本身就是依赖 RxJS 的，官方提供的 HttpClient Router 提供的 API 返回的都是 Observable对象。

回到这个例子上来，我们可以把 ViewService 中的 views 改成 BehaviorSubject<ViewInfo[]>，BehaviorSubject 对象既可以被订阅，又可以广播，同时还可以存储最后一次的数据, 操作数据后通过 views$.next(newViews) 广播出去，然后在导航条组件中订阅 views$ 流只取前 2 个视图，更多视图菜单组件订阅取后面的视图，如果还有其他组件显示所有的视图可以直接订阅视图列表流 viewService.views$ | async 显示所有视图。

class ViewService {
    views$ = new BehaviorSubject<ViewInfo[]>([]);

    addView(view: ViewInfo) {
        // 调用 API
        const views = this.views$.getValue();
        this.views$.next([...views, view]);
    }

    updateView(view: ViewInfo) {
    }

    removeView(view: ViewInfo) {
    }
}

// component.ts
this.showViews$ = this.viewService.views$.pipe(
      map((views) => {
        return views.filter((view, index) => {
          return index < 2;
        });
      })
    );

所以在 Angular 中把状态通过 BehaviorSubject保存在服务中，其他组件通过订阅服务中的数据流可以处理各种复杂的场景，这样的状态流非常的清晰，简单易维护，基本上不需要复杂的状态管理框架。

其实前端状态管理本质上处理无外乎只有 2 种方式；

1. 不可变数据（类 Redux），函数式编程的一个特点；
2. 响应式编程 Observable 。

通过 Service 去管理前端的状态，需要共享的数据使用 Observable 足够应付大部分应用场景。但是通过我们这么长时间的实践，我认为会有以下几个问题：

1. Service 比较灵活，可以存放普通的数据，也可以存放 Observable 对象, 一般建议 Service 做数据层，所有修改操作都要通过 Service 封装的方法，但是数据是公开出去的，难免会不轻易间就在组件中直接操作 Service 中的数据了;
2. 什么时候使用 Observable对象，什么时候用普通的数据对象，对开发人员来说不好把控，而且可能需求本来是不需要订阅的，后来变了，就需要订阅了，那就需要改很多地方。

上述的 2 个问题可能不是 Angular 的问题，但是怎么样通过引入一个简单的状态管理框架统一管理起来呢，同时让开发人员更容易写出一致的代码，而且不容易出错。

最近比较火的 mobx 它是通过装饰器设置某个属性是否是 Observable 的，这样之后修改只需要加 @observable 就可以了，同时它提供了 @computed 计算属性实现上面的更多视图的问题，mobx 解决状态管理的思路走的是 Observable，和在 Angular 中写的那个 Service 解决思路类似，但是在 Angular 中我建议不要使用 mobox，原因如下 ：

1. mobox 还是有点复杂，概念比较多；
2. 自己实现的 Observable，对于 Angular 应用来说有点多余，和 Angular 配合总有点别扭;
3. 处理同步和异步的 Action 比较繁琐。

其实和 Angular 匹配的状态库不多，你搜索下可能只能看到下面 2 个（虽然 Redux ，mobox 和框架无关，但是总感觉他们就是为 React 而生的）：

1. ngrx/platform 这个基本上是把 Redux 强行搬到 Angular 中，本来 Redux 就被吐槽不好用，看到各种 Switch 就高兴不起来，并且繁琐，写起来费劲；
2. ngxs/store 这个框架其实就是使用 RxJS 管理状态，感觉比 ngrx 好用，使用装饰器定义 State 和 Action，组件通过 store.dispatch(new AddTodo('title'))调用对应的 Action 方法 , 充分利用了 Angular 和 TypeScript 的特质，推荐使用。

我们一开始是想选择 ngxs/store 的，但是后来放弃了，放弃的原因如下：

1. 它是单 Store 的，关于单 Store 和 多 Store 到底哪个好，仁者见仁智者见智，我觉得多 Store 更符合前端的场景，首先，单一 Store，意味着所有的操作都通过 Store.dispatch 触发 Action，然后就会通过其他的方式分模块处理不同的状态，Redux 通过 Reducer 函数去处理不同的状态，ngxs/store 通过定多个 State 类处理各种 Action，如果是多 Store，那就意味着 Store 的划分就是按照业务模块来的，小项目你可以把所有的状态和操作 Action 都放入一个 Store，多余复杂项目可以放在更多的 Store 去管理，完全交给用户自己控制，另外一个就是我觉得状态存在哪里，操作状态的 Action 应该和存储的状态放在一起，否则我要去多个地方去找，因为 Action 的操作就是操作状态的；
2. 既然是单 Store ，所有的操作都通过 Store.dispatch 触发 Action，那么这个 dispatch 函数方法就没有类型检查，你写错了也只能运行时通过调试得知，无法利用 TypeScript 的静态类型检查发现低级错误，当然 ngxs/store 比 Redux 会先进一点，它把 Action 的 type 和 payload 定义在一起，然后调用 dispatch 的时候示例化 Action 类做到类型检查，但是定义 Action 的时候还是需要指定这个 Action 和 payload 参数一致，比如：

export class AddTodo {
  static type = 'AddTodo';

  constructor(public readonly payload: string) {}
}

@State<string[]>({
  name: 'todo',
  defaults: []
})
export class TodoState {
  @Selector()
  static pandas(state: string[]) {
    return state.filter(s => s.indexOf('panda') > -1);
  }

  @Action(AddTodo)
  addTodo({ getState, setState }: StateContext<string[]>, { payload }: AddTodo) {
    setState([...getState(), payload]);
  }
}

单 Store 还会带来另外一个问题就是还需要统一管理所有的 Action，Action 类型不能重复，大型项目很多模块还需要统一规划 Actions。当然单 Store 也有它的优势，可以循环调用其他 State 的 Action，统一使用 dispacth(action) 等等。

那么在 Angular 中我们需要的东西其实和 ngxs/store 类似的理念，去除单 Store，换成多 Store 即可，所以我们内部自己封装了一个超级简单的状态管理类库。

image

1. 每个 Store 对应一个状态对象，状态以 BehaviorSubject 的形式存在 Store 中；
2. 每个 Store除了定义对应的状态外还会定义各种 Action, Action 就是 Store 中的一个普通方法，通过装饰器 @Action包装一下即可，对于同步和异步没有区分，异步的返回一个 Observable即可 ；
3. 组件注入对应的 Store, 通过 Store 封装的 select 方法订阅当前组件需要的状态，当然可以通过 store.snapshot获取当前的状态快照；
4. 组件直接调用 Store 对应的 Action 进行状态的增删改。

上周末从我们的组件库中提取出来，独立成一个简单的 Angular 状态管理类库 ngx-mini-store ，当然还有很多需要完善的地方。

// counter-store
import { Store, Action } from 'ngx-mini-store';

interface CounterStoreState {
    count: number;
}

export class CounterStore extends Store<CounterStoreState> {

    constructor() {
        super({
            count: 0
        });
    }

    @Action()
    increase() {
       this.snapshot.count++;
       this.next(this.snapshot);
    }

    @Action()
    decrement() {
        this.snapshot.count--;
        this.next(this.snapshot);
    }
}

// counter-component.ts
import { CounterStore } from '../counter-store';

@Component({
  selector: 'app-tasks',
  templateUrl: './counter.component.html'
})
export class CounterComponent implements OnInit, OnDestroy {

  count$: Observable<number>;

  constructor(public store: TaskListStore) {
    this.count$ = this.store.select((state) => {
       return state.count;
    });
  }

  ngOnInit(): void {

  }

  increase() {
    this.store.increase();
  }
}

最后总结一下，在 Angular 中推荐使用 Service（或者 Store，本质上也是个服务）来做数据层的管理，那么全局状态或者组件之间共享的状态存储在 Service 中，使用 Observable 存储数据是个推荐的方式，基于这个基础上，你可以按照自己的喜欢封装这一层实现状态管理。我们按照这种方式做了之后，偶然发现 github 上也有一个项目 https://github.com/SebastianM/tinystate 和我们解决的思路一致，希望这篇文章可以给你带来 Angular 状态管理的一些思考。