##Flux与面向组件化开发首先要明确的是，Flux并不是一个前端框架，而是前端的一个设计模式，其把前端的一个交互流程简单的模拟成了一个单向数据流。在上图中，我们可以看到Flux的四个核心构成：####Action一个交互动作，来源于用户在页面组件上的某个行为，如点击，失焦，双击等等。其往往具有两个组成：*交互类型 ，例如创建、删除、更新等*交互体，或者说交互的携带信息， 例如创建的文本####Dispatcher分发器，从上图的数据流中，我们可以看到，用户产生的一个交互行为将被送入Dispatcher，分发器对Action进行简单的包裹之后分发该行为到所有__向其注册了的Store__中。>！注意，Dispatcher的这种广播行为有别于__Pub/Sub__模型，在__Pub/Sub__模型中，需要声明订阅的消息类型，然后发布者会像订阅者广播特定类型的消息。而在Dispatcher中，Store向其注册的任意回调接口都不要声明订阅的Action类型，当Dispatcher派发Action时，所有注册到Dispatcher的callback都会得到相应。回调可以通过简单工厂模式（通常是一个switch块）来针对不对类型的Action做出不同的行为。####Store数据存储仓，其保存了我们某个前端App的数据，并封装了对于数据的操作。Store会向其对应的Dispatcher注册一个回调函数，其参数为一个交互。当Action被派发到Store时，该回调函数被调用，借由Action中描述的__交互类型__，Store进行不同处理（一个简单工厂模式），这些处理都将被持久化到Store维护的数据对象上。Store完成数据的变更后，由于Flux并不是双向数据绑定的，所以此时，页面组件的数据并未得到更新，组件也不会重新渲染。所以，为了告知组件去更新数据，Store会emit一个变更事件，并且监听该事件。当监听到变更事件产生时，注册到这个事件上的回调（往往是我们App的状态维护器的状态更新函数）会被调用，从而更新各个组件的状态。####View显而易见，这就是用户所能看到的视图，有别于传统的MVC，在Flux中，View并不会和数据模型（Model）产生交互，其只会产生各种交互行为（Actions），这些行为将会被送到Dispatcher中，如下图所示：###TODO栗子下面我们分析一个用React+Flux实现的一个Flux栗子，其源码托管在[github](https://github.com/facebook/flux/tree/master/examples/flux-todomvc)上。在项目实践中，面向组件化开发的最佳场景我认为是__交互驱动型的开发__，可能描述不够准确，准确点说就是一旦一个完善的交互设计稿产生时，我们就可以去__分割__和__分析__组件了，我们现在来分析Todo的交互原型：>这是交互设计师的给我们的原稿，并且，原稿可能远不止这样一幅简单的图像，可能还包括更多的交互效果我们将会把这个应用拆分为如下组件：####TodoApp通常，在前端面向组件化的开发过程中，我们往往需要一个顶部容器包裹住我们的组件，一个页面可以存在若干个这样的顶部容器，这个容器类似一个集装箱或者盒子，封装了某个页面应用的所有组件和状态。例如，在某视频网站中，视频播放窗口可以作为一个顶部容器，其包裹了播放窗口，进度条，播放选项等各个组件，同时，评论部分也可以作为一个顶部容器，其包裹了评论列表，评论框等组件。在Todo例子中，TodoApp作为一个顶部容器，包裹了所有Todo应用需要的组件，这样，我们在应用入口只需要渲染TodoApp就完成了整个TodoApp的渲染。但更为重要的是，TodoApp将会封装其下各个组件需要用到的状态，通过数据流，各个组件将会收到状态，并且在状态改变时，重新渲染自己，最终更新页面内容。####Header这是一个头部组件，根据交互设计，他除了将保有静态的“todos”文字标题以外，还将会具有如下行为：*右侧输入框失焦或者相应回车键：创建新的任务####Footer这是一个底部组件，它将显示未完成任务数，并能删除所有已完成任务，故而，首先他需要获得如下__状态__:*所有任务：*通过遍历任务的完成情况，能获得未完成任务数*通过遍历任务的完成情况，统计已完成任务的信息*如果当前无任务，不现实Footer并且，他具有如下行为：*单击右侧按钮（Clear completed）: 清除所有已完成任务------------####MainSection该组件将会负责渲染所有的以创建任务，因而他需要维护的状态为：*所有任务其具有的行为：*点击顶部左侧图标按钮：完成/取消完成所有任务，具体根据__所有任务__是否都完成了决定----------------####TodoItem这是Todo项，其Todo对象来源于MainSection的迭代，并且该组件具有如下行为：*单击左侧按钮：完成/取消完成该任务*单击右侧按钮：删除该Todo*双击Todo文本：进入如下的编辑模式我们不难发现，“是否处于编辑模式”实际上可作为该组件的一个状态，该状态的切花直接影响了该组件的展示和行为，所以，组件应当维护一个状态：*是否编辑模式在编辑模式中，具有如下行为：*输入框失焦或者相应回车键：更新任务可以看到，在__Header__组件及__TodoItem__组件的输入框组件具有一致的交互行为，所以，我们可以将其提出来作为单独的组件，这也体现了，一份晚上的交互设计原型将预测到实现过程中的复用和抽象，避免了一些代码重构的时间。----------------####TodoTextInput现在，我们抽象出一个可复用的输入组件TodoTextInput，他具有如下行为：*输入框失焦或者相应回车键：调用存储过程（创建，更新等等）综上，我们以一个简单的示意图表示如上的划分：上图__蓝色__椭圆封装的属性，__黄色__椭圆封装的是状态。 在每个TodoItem中，还需要单独维护一个”是否可编辑状态”，该状态决定了TodoItem的行为和展示。注意到，因为__所有任务__这个状态会被多个组件共享（MainSection，Footer），所以，该状态被提到了顶部容器TodoApp中进行维护，这样，通过TodoApp的__SetState()__方法，所有绑定到TodoApp的组件都获得了状态更新，避免了组件间的相互引用，实现了组件解耦（唯一的耦合存在于组件与顶层容器），如下图所示：倘若我们在MainSection及Footer中分别维护这个状态，由于MainSection与Footer属于平级的组件，所以，当MainSection中的__所有任务__这一状态发生改变时，为使Footer中的状态也发生改变，为此，MainSection及Footer组件都要保存对方引用，二者将会是强耦合的，如下图所示：设想，如果以后还有更多的组件需要__所有任务__这一状态，这一设计模式将会是十分糟糕的，任何一个组件的脱离将可能导致整个引用网络的崩溃，如下图所示：###封装其中app.js为应用的入口文件，通常，单页面应用（SPA）都需要提供一个最初的文件，然后递归渲染DOM树。下面，开始实现我们的逻辑，顺着Flux的单向数据流，逐个分析Todo例子中的实现。####Dispatcher__js/AppDispatcher.js__```javascriptvar Dispatcher = require('flux').Dispatcher;module.exports = new Dispatcher();```可以看到，Dispatcher的实现主要依赖于官方的[flux](https://www.npmjs.com/package/flux)提供支持。我们可以看下flux中的Dispatcher源码，所有解说都放在代码注释中：首先看到__Dispatcher__的构造函数：```javascriptfunction Dispatcher() {_classCallCheck(this, Dispatcher);this._callbacks = {}; // 保存向Dispatcher注册回调函数this._isDispatching = false; // 是否正在分派Actionthis._isHandled = {}; // 已经完成执行的回调列表this._isPending = {}; // 正在执行中的回调列表this._lastID = 1; // 回调Id的起始标志}```再看注册方法__register(callback)__,每个向Dispatcher的注册的回调（callback）都拥有唯一Id进行标识：```javascript/*** 向Dispatcher注册回调函数,每个回调函数都有唯一id进行标识* @param callback* @returns {string} 注册回调的id*/Dispatcher.prototype.register = function register(callback) {var id = _prefix + this._lastID++;this._callbacks[id] = callback;return id;};/*** 根据id删除回调*/Dispatcher.prototype.unregister = function unregister(id) {!this._callbacks[id] ? process.env.NODE_ENV !== 'production' ? invariant(false, 'Dispatcher.unregister(...): `%s` does not map to a registered callback.', id) : invariant(false) : undefined;delete this._callbacks[id];};```执行一个注册了的回调函数将经历如下过程：1.标识当前正在执行的回调为进行中（Pending）状态2.将用户行为（payload）送回调执行3.执行完成,标识该回调已经完成（Handled）```javascript/*** 执行回调函数,该过程为:* 1. 标识当前正在执行的回调为Pending状态* 2. 将payload送入回调执行* 3. 执行完成,标识该回调已经完成* @internal*/Dispatcher.prototype._invokeCallback = function _invokeCallback(id) {this._isPending[id] = true;this._callbacks[id](this._pendingPayload);this._isHandled[id] = true;};```派发__dispatch(payload)__指定的用户行为payload到所有的callback将经历如下过程：首先，需要明确的是能够进行派发的前提是当前Dispatcher为空闲状态，接下来1.派发前的预处理___startDispatching()__1.初始化所有回调的状态2.设置当前正在分发的payload3.标识当前的Dispatcher状态为"正在进行派发"2.根据注册顺序依次执行回调___invokeCallback(id)__3.派发结束后的收尾工作___stopDispatching()__1.清除派发对象2.标识当前的Dispatcher状态为"结束派发"```javascript/*** 派发一个payload到所以已注册的callback中*/Dispatcher.prototype.dispatch = function dispatch(payload) {!!this._isDispatching ? process.env.NODE_ENV !== 'production' ? invariant(false, 'Dispatch.dispatch(...): Cannot dispatch in the middle of a dispatch.') : invariant(false) : undefined;this._startDispatching(payload);try {for (var id in this._callbacks) {if (this._isPending[id]) {continue;}this._invokeCallback(id);}} finally {this._stopDispatching();}};/*** 分发payload前的初始化:* 1. 初始化所有回调的状态* 2. 设置当前正在分发的payload* 3. 标识当前"正在进行派发"* @internal*/Dispatcher.prototype._startDispatching = function _startDispatching(payload) {for (var id in this._callbacks) {this._isPending[id] = false;this._isHandled[id] = false;}this._pendingPayload = payload;this._isDispatching = true;};/*** 结束派发时的收尾工作* 1. 清除派发对象* 2. 标识当前"结束派发"* @internal*/Dispatcher.prototype._stopDispatching = function _stopDispatching() {delete this._pendingPayload;this._isDispatching = false;};```#####waitFor再看Dispatcher中一个很重要的方法:__waitFor(ids)__, 顾名思义，该方法的作用是等待指定的回调的函数调用完成。因而，该方法主要保证了回调函数的执行的顺序性。例如，在一个航班订票系统中，我们首先要选择完国家（Country），才能选择城市（City），所以，当一个类型为“更新选择国家”的交互被送到CityStore所注册的回调时，为了保证能正确的选择更新后国家的城市```javascriptCityStore.dispatchToken = flightDispatcher.register(function(payload) {if (payload.actionType === 'country-update') {/** 如果不执行waitFor(),那么可同CityStore的回调先于ContryStore的回调执行* 此时的国家尚未更新，得到的默认城市是错误的，而并不是最新的* */flightDispatcher.waitFor([CountryStore.dispatchToken]);// waitFor()保证了ContryStore先响应了'country-update'，即保证了国家更新先于城市更新// 此时我们能正确的选择该国家的城市CityStore.city = getDefaultCityForCountry(CountryStore.country);}});```下面我们看__waitFor()__的源码实现：```javascript/*** 等待指定的回调完成*/Dispatcher.prototype.waitFor = function waitFor(ids) {!this._isDispatching ? process.env.NODE_ENV !== 'production' ? invariant(false, 'Dispatcher.waitFor(...): Must be invoked while dispatching.') : invariant(false) : undefined;for (var ii = 0; ii < ids.length; ii++) {var id = ids[ii];if (this._isPending[id]) {!this._isHandled[id] ? process.env.NODE_ENV !== 'production' ? invariant(false, 'Dispatcher.waitFor(...): Circular dependency detected while ' + 'waiting for `%s`.', id) : invariant(false) : undefined;continue;}!this._callbacks[id] ? process.env.NODE_ENV !== 'production' ? invariant(false, 'Dispatcher.waitFor(...): `%s` does not map to a registered callback.', id) : invariant(false) : undefined;this._invokeCallback(id);}};```####Store实现在__js/stores/TodoStore.js__中：首先，我们维护我们的数据对象，并提供若干对于该数据的操作：```javascript// 保存TODO列表var _todos = {};/*** 创建一个 Todo* @param text {string} Todo内容*/function create(text) {// ...}/*** 更新一个 TODO item* @param id {string}* @param updates {object} 待更新对象的属性*/function update(id, updates) {// ...}/*** 根据一个更新属性值对象更新所有 Todo* @param updates {object}*/function updateAll(updates) {// ...}/*** 删除 Todo* @param id {string}*/function destroy(id) {// ...}/*** 删除所有的已完成的 TODO items*/function destroyCompleted() {// ...}```然后导出一个全局单例，该单例提供了常用的外部访问接口，并且通过node提供的EventEmitter来实现事件的派发和监听：```javascriptvar TodoStore = assign({}, EventEmitter.prototype, {/*** 是否所有TODO 都已完成* @return {boolean}*/areAllComplete: function () {// ...},/*** 获得所有的TODO* @returns {object}*/getAll: function () {// ...},/*** 发送变更事件*/emitChange: function () {// ...},/*** 添加变更事件监听* @param callback*/addChangeListener: function (callback) {// 一旦受到变更事件, 触发回调/**  例如, 当我们创建一条todo时,*  TodoStore将会发出一条变更事件,*  上游的状态维护器将会调用callback进行状态更新*/this.on(CHANGE_EVENT, callback);},/*** 删除变更事件监听* @param callback*/removeChangeListener: function (callback) {this.removeListener(CHANGE_EVENT, callback);}});```最后，我们需要向__AppDispatcher__注册回调函数，以便在payload被分发到TodoStore时，TodoStore能做出相应：```javascriptAppDispatcher.register(function callback(action) {var text;// 根据不同的action类型(即不同的交互逻辑), 执行不同过程switch (action.actionType) {case TodoConstants.TODO_CREATE:text = action.text.trim();if( text!=='') {create(text);// 一旦变更,发出变更事件,TodoStore.emitChange();}break;case TodoConstants.TODO_TOGGLE_COMPLETE_ALL:// ...break;case TodoConstants.TODO_UNDO_COMPLETE:// ...break;case TodoConstants.TODO_COMPLETE:// ...break;case TodoConstants.TODO_UPDATE_TEXT:// ...break;case TodoConstants.TODO_DESTROY:// ...break;case TodoConstants.TODO_DESTROY_COMPLETED:// ...break;default:// no op}});```>!注意, 在回调执行过程中，如果发生状态的变动，需要发出变更事件，以便上游注册的回调函数能够获得相应并更新状态到下游。####Actions我们将TodoApp中常见的Action都封装到了__js/TodoActions.js__中, 通过其中的__AppDispatcher__单例，我们可以将Action派发出去:```javascriptvar TodoActions = {/*** 创建行为* @param text {string}*/create: function (text) {// 将创建行为送到Dispatcher, Dispatcher派发这个行为(action对象)到各个StoreAppDispatcher.dispatch({actionType: TodoConstants.TODO_CREATE,text: text});},/*** 更新行为* @param id {string}* @param text {string}*/updateText: function (id, text) {// ...},/*** 全部设置为完成* @param todo*/toggleComplete: function (todo) {// ...},/*** 标记所有的Todo为已完成*/toggleCompleteAll: function () {// ...},/**** @param id*/destroy: function (id) {// ...},/*** 删除所有已完成的Todo*/destroyCompleted: function() {// ...}};```####Components下面开始实现各个组件， 个人偏向的流程是先在组件目录下创建好各个组件文件，并以如下内容先导出，亦即，我们先创建空白组件，之后再依序进行装填```javascriptvar React = require('react');var Header = React.createClass({render: function () {// TODO::render},});module.exports = Header;```装填顺序我会选择先装填顶部容器（此例中即为__TodoApp__），之后按照DOM树自底向上的进行装填:__TodoApp.react.js__:```javascriptvar Footer = require('./Footer.react');var Header = require('./Header.react');var MainSection = require('./MainSection.react');var React = require('react');var TodoStore = require('../stores/TodoStore');// 在根DOM下维护状态,// 这样的状态往往是共享状态(会向下传递的状态)function getTodoState() {return {allTodos: TodoStore.getAll(),areAllComplete: TodoStore.areAllComplete()};}var TodoApp = React.createClass({getInitialState: function () {return getTodoState();},/*** 绑定生命期--挂载*/componentDidMount: function () {// 挂载时再为TodoStore添加监听器TodoStore.addChangeListener(this._onChange);},componentWillUnmount: function () {TodoStore.removeChangeListener(this._onChange);},render: function () {return (

todos