章节 9 - middleware 中间件

优质

小牛编辑

134浏览

2023-12-01

在 dispatch-async-action-2.js 章节中我们抛出了“中间件”的概念。中间件似乎可以帮助我们处理异步 action。但中间件到底是什么呢？

通常来说中间件是在某个应用中 A 和 B 部分中间的那一块，中间件可以把 A 发送数据到 B 的形式从

A -----> B

变成:

A ---> middleware 1 ---> middleware 2 ---> middleware 3 --> ... ---> B

那么中间件在 Redux 中是如何工作的？

看上去 Redux 并不能自动处理 action creator 中返回的异步函数。

但如果在 action creator 和 reducer 之间增加一个中间件，就可以把这个函数转成适合 Redux 处理的内容：

action ---> dispatcher ---> middleware 1 ---> middleware 2 ---> reducers

每当一个 action（或者其他诸如异步 action creator 中的某个函数）被分发时，我们的中间件就会被调用并且在需要的时候协助 action creator 分发真正的 action（或者什么都不做，有时我们需要这么做）在 Redux 中，中间件是纯粹的函数，有明确的使用方法并且严格的遵循以下格式：

var anyMiddleware = function ({ dispatch, getState }) {
  return function(next) {
    return function (action) {
      // 你的中间件业务相关代码
    }
  }
}

如上所述，中间件由三个嵌套的函数构成（会依次调用）：

第一层向其余两层提供分发函数和 getState 函数（因为你的中间件或 action creator 可能需要从 state 中读取数据）
第二层提供 next 函数，它允许你显式的将处理过的输入传递给下一个中间件或 Redux（这样 Redux 才能调用所有 reducer)。
第三层提供从上一个中间件或从 dispatch 传递来的 action，这个 action 可以调用下一个中间件（让 action 继续流动) 或者以想要的方式处理 action。

学习过函数式编程的人可能会意识到给上述代码提供了一个机会来使用柯里化（如果你不理解也没关系，跳过接下去的 10 行，不会影响你对 redux 的理解）。

使用柯里化，你可以简化上述函数：

// "curry" may come any functional programming library (lodash, ramda, etc.)
var thunkMiddleware = curry(
  ({dispatch, getState}, next, action) => (
    // 你的中间件业务相关代码
  )
);

我们为异步 action creator 提供的中间件叫 thunk middleware
它的代码在：https://github.com/gaearon/redux-thunk.
它看上去是这样 (为了可读性使用 ES5 语法书写该函数）:

var thunkMiddleware = function ({ dispatch, getState }) {
  // console.log('Enter thunkMiddleware');
  return function(next) {
    // console.log('Function "next" provided:', next);
    return function (action) {
      // console.log('Handling action:', action);
      return typeof action === 'function' ?
        action(dispatch, getState) :
        next(action)
    }
  }
}

为了让 Redux 知道我们有一个或多个中间件，我们使用 Redux 的辅助函数：applyMiddleware.

applyMiddleware 接收所有中间件作为参数，返回一个供 Redux createStore 调用的函数，当最后这个函数被调用时，它会产生一个 Store 增强器，用来将所有中间件应用到 Store 的 dispatch 上。

来自 https://github.com/rackt/redux/blob/v1.0.0-rc/src/utils/applyMiddleware.js

下面就是如何将一个中间件应用到 Redux store：

import { createStore, combineReducers, applyMiddleware } from 'redux'

const finalCreateStore = applyMiddleware(thunkMiddleware)(createStore)

针对多个中间件，使用：applyMiddleware(middleware1, middleware2, ...)(createStore)

var reducer = combineReducers({
  speaker: function (state = {}, action) {
    console.log('speaker was called with state', state, 'and action', action)

    switch (action.type) {
      case 'SAY':
        return {
          ...state,
          message: action.message
        }
      default:
        return state
    }
  }
})

const store_0 = finalCreateStore(reducer)

输出:

speaker was called with state {} and action { type: '@@redux/INIT' }
speaker was called with state {} and action { type: '@@redux/PROBE_UNKNOWN_ACTION_s.b.4.z.a.x.a.j.o.r' }
speaker was called with state {} and action { type: '@@redux/INIT' }

现在 store 的 middleware 已经准备好了，再来尝试分发我们的异步 action：

var asyncSayActionCreator_1 = function (message) {
  return function (dispatch) {
    setTimeout(function () {
      console.log(new Date(), 'Dispatch action now:')
      dispatch({
        type: 'SAY',
        message
      })
    }, 2000)
  }
}

console.log("\n", new Date(), 'Running our async action creator:', "\n")

store_0.dispatch(asyncSayActionCreator_1('Hi'))

输出:

Mon Aug 03 2015 00:01:20 GMT+0200 (CEST) Running our async action creator:
Mon Aug 03 2015 00:01:22 GMT+0200 (CEST) 'Dispatch action now:'
speaker was called with state {} and action { type: 'SAY', message: 'Hi' }

当我们调用异步 action creator 两秒之后，action 成功被分发出去。

你可能会好奇，一个中间件如何 log 出所有已分发的 action ，是这样：

function logMiddleware ({ dispatch, getState }) {
  return function(next) {
    return function (action) {
      console.log('logMiddleware action received:', action)
      return next(action)
    }
  }
}

同样的，下面是一个中间件，它会丢弃所有经过的 action（不是很实用，但是如果加一些判断就能实现丢弃一些 action，放到一些 action 给下一个中间件）：

function discardMiddleware ({ dispatch, getState }) {
  return function(next) {
    return function (action) {
      console.log('discardMiddleware action received:', action)
    }
  }
}

通过使用 logMiddleware 或 discardMiddleware 试着修改上述的 finalCreateStore 调用看看会发生什么...

比如，这样用:

const finalCreateStore = applyMiddleware(discardMiddleware, thunkMiddleware)(createStore)

会让你的 action 永远无法到达 thunkMiddleware 和 reducer。

查看 http://rackt.org/redux/docs/introduction/Ecosystem.html 的中间件部分可以了解其他例子。

总结一下到目前为止我们所学的：

我们知道怎样写 action 和 action creator
我们知道怎样分发 action
我们知道怎样使用中间件处理自定义 action，比如异步 action

对于 Flux 体系的完整闭环，我们还剩下唯一的一块就是如何订阅 state 的更新并响应这些更新（比如重新渲染我们的组件)

所以我们怎么订阅 Redux store 的更新呢？