现在我们把它们集中到一个地方,给这个地方起个名字叫做 store,然后构建一个函数 createStore,用来专门生产这种 statedispatch 的集合,这样别的 App 也可以用这种模式了:

  1. function createStore (state, stateChanger) {
  2. const getState = () => state
  3. return { getState, dispatch }
  4. }

createStore 接受两个参数,一个是表示应用程序状态的 state;另外一个是 stateChanger,它来描述应用程序状态会根据 action 发生什么变化,其实就是相当于本节开头的 dispatch 代码里面的内容。

createStore 会返回一个对象,这个对象包含两个方法 getStatedispatchgetState 用于获取 state 数据,其实就是简单地把 state 参数返回。

dispatch 用于修改数据,和以前一样会接受 action,然后它会把 stateaction 一并传给 stateChanger,那么 就可以根据 action 来修改 state 了。

针对每个不同的 App,我们可以给 createStore 传入初始的数据 appState,和一个描述数据变化的函数 stateChanger,然后生成一个 store。需要修改数据的时候通过 store.dispatch,需要获取数据的时候通过 store.getState

上面的代码有一个问题,我们每次通过 dispatch 修改数据的时候,其实只是数据发生了变化,如果我们不手动调用 renderApp,页面上的内容是不会发生变化的。但是我们总不能每次 dispatch 的时候都手动调用一下 renderApp,我们肯定希望数据变化的时候程序能够智能一点地自动重新渲染数据,而不是手动调用。

你说这好办,往 dispatch里面加 renderApp 就好了,但是这样 createStore 就不够通用了。我们希望用一种通用的方式“监听”数据变化,然后重新渲染页面,这里要用到观察者模式。修改 createStore

  1. function createStore (state, stateChanger) {
  2. const listeners = []
  3. const subscribe = (listener) => listeners.push(listener)
  4. const getState = () => state
  5. const dispatch = (action) => {
  6. listeners.forEach((listener) => listener())
  7. }
  8. }

我们在 createStore 里面定义了一个数组 listeners,还有一个新的方法 subscribe,可以通过 store.subscribe(listener) 的方式给 subscribe 传入一个监听函数,这个函数会被 push 到数组当中。

我们只需要 subscribe 一次,后面不管如何 dispatch 进行修改数据,renderApp 函数都会被重新调用,页面就会被重新渲染。这样的订阅模式还有好处就是,以后我们还可以拿同一块数据来渲染别的页面,这时 dispatch 导致的变化也会让每个页面都重新渲染:

  1. const store = createStore(appState, stateChanger)
  2. store.subscribe(() => renderApp(store.getState()))
  3. store.subscribe(() => renderApp2(store.getState()))
  4. ...

本节的完整代码:

现在我们有了一个比较通用的 createStore,它可以产生一种我们新定义的数据类型 store,通过 store.getState 我们获取共享状态,而且我们约定只能通过 store.dispatch 修改共享状态。 也允许我们通过 store.subscribe 监听数据数据状态被修改了,并且进行后续的例如重新渲染页面的操作。