&emsp;&emsp;Redux的中间件（Middleware）遵循了即插即用的设计思想，出现在Action到达Reducer之前（如图10所示）的位置。中间件是一个固定模式的独立函数，当把多个中间件像管道那样串联在一起时，前一个中间件不但能将其输出传给下一个中间件作为输入，还能中断整条管道。在引入中间件后，既能扩展Redux的功能，也能增强dispatch()函数，适应不同的业务需求，例如通过中间件记录日志、报告奔溃或处理异步请求等。 :-:  图10 中间件管道 ## 一、开发模式 &emsp;&emsp;在设计中间件函数时，会遵循一个固定的模式，如下代码所示，使用了柯里化、高阶函数等函数式编程中的概念。 ~~~js function middleware(store) { return function(next) { return function(action) { return next(action); }; }; } ~~~ &emsp;&emsp;middleware()函数接收一个Store实例，返回值是一个接收next参数的函数。其中next也是一个函数，用来将控制权转移给下一个中间件，从而实现了中间件之间的串联，它会返回一个处理Action对象的函数。由于闭包的作用，在这最内层的函数中，依然能调用外层的对象和函数，例如访问action所携带的数据、执行store中的dispatch()或getState()方法等。示例中的middleware()函数只是单纯的将接收到的action对象转交给后面的中间件，没有对其做额外的处理。 &emsp;&emsp;之所以将中间件函数写成层层嵌套的模式，有以下几个原因。 &emsp;&emsp;（1）扩展Redux需要遵循函数式编程的设计思想。 &emsp;&emsp;（2）柯里化让中间件更容易处理数据流，即便于形成数据处理管道。 &emsp;&emsp;（3）每个中间件的职责单一（即函数代码尽量少），通过嵌套组合完成复杂功能。 &emsp;&emsp;利用ES6中的箭头函数能将middleware()函数改写得更加简洁，如下所示。 ~~~js const middleware = store => next => action => { return next(action); }; ~~~ ## 二、applyMiddleware() &emsp;&emsp;Redux提供了组织中间件的applyMiddleware()函数，在阅读过此函数的源码（如下所示）之后，才能更好的理解中间件的开发模式。 ~~~js function applyMiddleware(...middlewares) { return createStore => (...args) => { const store = createStore(...args); let dispatch = () => { throw new Error( "Dispatching while constructing your middleware is not allowed. " + "Other middleware would not be applied to this dispatch." ); }; const middlewareAPI = { getState: store.getState, dispatch: (...args) => dispatch(...args) }; const chain = middlewares.map(middleware => middleware(middlewareAPI)); dispatch = compose(...chain)(store.dispatch); return { ...store, dispatch }; }; } ~~~ **1）源码分析** &emsp;&emsp;接下来会分析函数中的代码，为了便于理解，在说明中还会给出相应的语句。 &emsp;&emsp;（1）利用剩余参数（...middlewares）的方式，applyMiddleware()函数可以接收任意多个中间件。 &emsp;&emsp;（2）返回一个接收createStore参数的函数，在函数体中调用Redux的createStore()函数，得到一个store实例。 ~~~js const store = createStore(...args); ~~~ &emsp;&emsp;（3）middlewareAPI变量包含了中间件需要的参数，即store.getState()和dispatch()方法。 ~~~js const middlewareAPI = { getState: store.getState, dispatch: (...args) => dispatch(...args) }; ~~~ &emsp;&emsp;（4）将middlewareAPI变量传递给每个中间件并调用一次，再将返回的函数组成一个新数组。 ~~~js const chain = middlewares.map(middleware => middleware(middlewareAPI)); ~~~ &emsp;&emsp;（5）通过compose()增强dispatch()方法，compose()是Redux内置的函数，可从右向左合成多个函数，例如compose(f1, f2, f3)(arg)相当于f1(f2(f3(arg)))。 ~~~js dispatch = compose(...chain)(store.dispatch); ~~~ &emsp;&emsp;（6）最终得到一个对象，包含store实例的方法和增强后的dispatch()方法。 ~~~js return { ...store, dispatch }; ~~~ **2）使用方式** &emsp;&emsp;applyMiddleware()函数有两种使用方式，下面用一个例子来演示，先定义两个中间件：m1和m2，以及一个Reducer函数：caculate()。 ~~~js const m1 = store => next => action => { console.log("m1"); return next(action); }; const m2 = store => next => action => { console.log("m2"); return next(action); }; function caculate(previousState = {digit:0}, action) { let state = Object.assign({}, previousState); switch (action.type) { case "ADD": state.digit += 1; break; case "MINUS": state.digit -= 1; } return state; } ~~~ &emsp;&emsp;（1）applyMiddleware()是一个三级柯里化的函数，如果要使用，那么可以像下面这样调用，先传两个中间件，再传createStore()函数，最后传caculate()函数。 ~~~js let store = applyMiddleware(m1, m2)(createStore)(caculate); ~~~ &emsp;&emsp;（2）applyMiddleware()函数还可以作为createStore()的最后一个参数，如下代码所示，第一个参数是caculate()函数，第二个参数是applyMiddleware()函数的结果。 ~~~js let store = createStore(caculate, applyMiddleware(m1, m2)); ~~~ &emsp;&emsp;在applyMiddleware()函数的内部，chain数组的值是\[m1(next), m2(next)\]，由m1和m2返回的包含next参数的函数组成。增强后的dispatch()方法通过m1(m2(store.dispatch))得到，具体如下所示。 ~~~js dispatch = action => { console.log("m1"); return next(action); }; ~~~ &emsp;&emsp;当调用store实例的dispatch()方法（如下代码所示）时，会先输出“m1”；然后调用next()函数，也就是m2(next)，输出“m2”；最后调用m2中的next()函数，也就是dispatch()方法。注意，不能在中间件中直接调用dispatch()方法，以免造成死循环。 ~~~js store.dispatch({ type: "ADD" }); ~~~ ## 三、redux-thunk &emsp;&emsp;如果要在Redux中处理异步请求，那么可以借助中间件实现，目前市面上已有很多封装好的中间件可供使用，例如redux-thunk、redux-promise或redux-saga等。本节将着重讲解redux-thunk中间件，其核心代码如下所示。 ~~~js function createThunkMiddleware(extraArgument) { return ({ dispatch, getState }) => next => action => { if (typeof action === "function") { return action(dispatch, getState, extraArgument); } return next(action); }; } ~~~ &emsp;&emsp;首先检测action的类型，如果是函数，那么就直接调用并将dispatch、getState和extraArgument作为参数传入；否则就调用next参数，转移控制权。redux-thunk其实扩展了dispatch()方法，使其参数既可以是JavaScript对象，也可以是函数。 &emsp;&emsp;接下来用一个简单的例子演示redux-thunk的用法，如下代码所示，首先通过import引入redux-thunk，并定义一个异步Action。 ~~~js import thunk from "redux-thunk"; function asynAction() { return dispatch => { fetch("server.php").then( response => response.json(), error => console.log(error) ).then(data => { dispatch(data); //{type: "ADD"} }); }; } ~~~ &emsp;&emsp;然后让asynAction()函数返回一个接收dispatch参数的函数，在函数体内通过fetch()函数请求服务端的资源，再利用得到的Promise处理获取到的数据。在第二个then()方法中，data参数被赋为{type: "ADD"}，也就是server.php响应的数据，其代码如下所示。 ~~~php <?php $json = [ 'type' => 'ADD' ]; echo json_encode($json); ~~~ &emsp;&emsp;再接入redux-thunk中间件，即将thunk传给applyMiddleware()函数，最后发送一个异步Action，如下所示。 ~~~js let store = createStore(caculate, applyMiddleware(thunk)); store.dispatch(asynAction()); ~~~ ***** > 原文出处： [博客园-React躬行记](https://www.cnblogs.com/strick/category/1455720.html) [知乎专栏-React躬行记](https://zhuanlan.zhihu.com/pwreact) 已建立一个微信前端交流群，如要进群，请先加微信号freedom20180706或扫描下面的二维码，请求中需注明“看云加群”，在通过请求后就会把你拉进来。还搜集整理了一套[面试资料](https://github.com/pwstrick/daily)，欢迎浏览。  推荐一款前端监控脚本：[shin-monitor](https://github.com/pwstrick/shin-monitor)，不仅能监控前端的错误、通信、打印等行为，还能计算各类性能参数，包括 FMP、LCP、FP 等。