根据文档,“没有中间件,Redux商店只支持同步数据流”。我不明白为什么会这样。为什么容器组件不能调用异步API,然后分派操作?

例如,想象一个简单的UI:一个字段和一个按钮。当用户按下按钮时,该字段将填充来自远程服务器的数据。

import * as React from 'react';
import * as Redux from 'redux';
import { Provider, connect } from 'react-redux';

const ActionTypes = {
    STARTED_UPDATING: 'STARTED_UPDATING',
    UPDATED: 'UPDATED'
};

class AsyncApi {
    static getFieldValue() {
        const promise = new Promise((resolve) => {
            setTimeout(() => {
                resolve(Math.floor(Math.random() * 100));
            }, 1000);
        });
        return promise;
    }
}

class App extends React.Component {
    render() {
        return (
            <div>
                <input value={this.props.field}/>
                <button disabled={this.props.isWaiting} onClick={this.props.update}>Fetch</button>
                {this.props.isWaiting && <div>Waiting...</div>}
            </div>
        );
    }
}
App.propTypes = {
    dispatch: React.PropTypes.func,
    field: React.PropTypes.any,
    isWaiting: React.PropTypes.bool
};

const reducer = (state = { field: 'No data', isWaiting: false }, action) => {
    switch (action.type) {
        case ActionTypes.STARTED_UPDATING:
            return { ...state, isWaiting: true };
        case ActionTypes.UPDATED:
            return { ...state, isWaiting: false, field: action.payload };
        default:
            return state;
    }
};
const store = Redux.createStore(reducer);
const ConnectedApp = connect(
    (state) => {
        return { ...state };
    },
    (dispatch) => {
        return {
            update: () => {
                dispatch({
                    type: ActionTypes.STARTED_UPDATING
                });
                AsyncApi.getFieldValue()
                    .then(result => dispatch({
                        type: ActionTypes.UPDATED,
                        payload: result
                    }));
            }
        };
    })(App);
export default class extends React.Component {
    render() {
        return <Provider store={store}><ConnectedApp/></Provider>;
    }
}

渲染导出的组件时,我可以单击该按钮,输入将正确更新。

注意connect调用中的update函数。它发送一个动作,告诉应用程序它正在更新,然后执行一个异步调用。调用完成后,所提供的值将作为另一个操作的有效负载进行调度。

这种方法有什么问题?为什么我要使用Redux Thunk或Redux Promise,如文档所示?

编辑:我在Redux repo中搜索线索,发现Action Creator在过去被要求是纯函数。例如,这里有一个用户试图为异步数据流提供更好的解释:

动作创建者本身仍然是一个纯函数,但它返回的thunk函数不需要是纯函数,它可以执行我们的异步调用

动作创作者不再需要纯粹。因此,thunk/promise中间件在过去肯定是必需的,但现在似乎不再是这样了?


当前回答

简短的回答:对我来说,这似乎是解决异步问题的一种完全合理的方法。

当我在一个新项目上工作时,我有一个非常相似的想法,我们刚刚开始我的工作。我是vanilla Redux优雅系统的忠实粉丝,该系统可以更新商店并以一种远离React组件树的方式重新渲染组件。在我看来,使用这种优雅的调度机制来处理异步似乎很奇怪。

我最终采用了一种非常类似的方法,就像我从项目中分解出来的一个库一样,我们称之为react redux控制器。

出于以下几个原因,我最终没有采用上述方法:

按照您编写的方式,这些调度功能无法访问商店。通过让UI组件传递调度函数所需的所有信息,您可以在某种程度上绕过这个问题。但我认为这将不必要地将这些UI组件耦合到调度逻辑。更有问题的是,调度函数没有明显的方法来访问异步延续中的更新状态。分派函数可以通过词法范围访问分派本身。一旦connect语句失控,这就限制了重构的选项——而且仅使用一个更新方法看起来非常笨拙。因此,如果您将这些分派器函数分解为单独的模块,您需要一些系统来组合它们。

总之,您必须装配一些系统,以便将调度和存储以及事件的参数注入到调度函数中。我知道三种合理的依赖注入方法:

redux thunk通过将它们传递给你的thunk(根据dome定义,使它们完全不是thunk),以一种功能性的方式实现了这一点。我还没有使用过其他调度中间件方法,但我认为它们基本相同。react-redux控制器通过协程实现这一点。另外,它还允许您访问“选择器”,这些函数可能是您作为连接的第一个参数传入的,而不必直接使用原始的标准化存储。您还可以通过各种可能的机制将它们注入到这个上下文中,以面向对象的方式来实现这一点。

使现代化

我想到这个难题的一部分是react redux的限制。connect的第一个参数获取状态快照,但不获取分派。第二个参数得到分派,而不是状态。这两个参数都没有获得关闭当前状态的thunk,因为在继续/回调时能够看到更新的状态。

其他回答

Redux不能返回函数而不是操作。这只是事实。这就是人们使用Thunk的原因。阅读以下14行代码,了解它如何允许异步循环与一些附加的函数分层一起工作:

function createThunkMiddleware(extraArgument) {
  return ({ dispatch, getState }) => (next) => (action) => {
    if (typeof action === 'function') {
      return action(dispatch, getState, extraArgument);
    }

    return next(action);
  };
}

const thunk = createThunkMiddleware();
thunk.withExtraArgument = createThunkMiddleware;

export default thunk;

https://github.com/reduxjs/redux-thunk

这种方法有什么问题?为什么我要使用Redux Thunk或Redux Promise,如文档所示?

这种方法没有错。在大型应用程序中,这是不方便的,因为您将有不同的组件执行相同的操作,您可能希望取消某些操作,或保持某些本地状态,如自动递增ID靠近操作创建者等。因此,从维护的角度来看,将操作创建者提取到单独的函数中更容易。

您可以阅读我对“如何在超时情况下调度Redux操作”的回答,以了解更详细的演练。

像Redux Thunk或Redux Promise这样的中间件只是为你提供了发送Thunk或Promise的“语法糖”,但你不必使用它。

因此,如果没有任何中间件,您的动作创建者可能看起来像

// action creator
function loadData(dispatch, userId) { // needs to dispatch, so it is first argument
  return fetch(`http://data.com/${userId}`)
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'LOAD_DATA_SUCCESS', data }),
      err => dispatch({ type: 'LOAD_DATA_FAILURE', err })
    );
}

// component
componentWillMount() {
  loadData(this.props.dispatch, this.props.userId); // don't forget to pass dispatch
}

但使用Thunk中间件,您可以这样写:

// action creator
function loadData(userId) {
  return dispatch => fetch(`http://data.com/${userId}`) // Redux Thunk handles these
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'LOAD_DATA_SUCCESS', data }),
      err => dispatch({ type: 'LOAD_DATA_FAILURE', err })
    );
}

// component
componentWillMount() {
  this.props.dispatch(loadData(this.props.userId)); // dispatch like you usually do
}

所以没有什么大的区别。我喜欢后一种方法的一点是,组件不关心动作创建者是异步的。它只是正常调用dispatch,它还可以使用mapDispatchToProps以短语法等方式绑定此类动作创建者。组件不知道动作创建者是如何实现的,您可以在不同的异步方法(Redux Thunk、Redux Promise、Redux Saga)之间切换,而无需更改组件。另一方面,使用前一种显式方法,您的组件确切地知道特定调用是异步的,并且需要通过某种约定(例如,作为同步参数)传递分派。

还请考虑此代码将如何更改。假设我们希望有第二个数据加载函数,并将它们组合在一个动作创建器中。

对于第一种方法,我们需要注意我们所称的行动创造者:

// action creators
function loadSomeData(dispatch, userId) {
  return fetch(`http://data.com/${userId}`)
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'LOAD_SOME_DATA_SUCCESS', data }),
      err => dispatch({ type: 'LOAD_SOME_DATA_FAILURE', err })
    );
}
function loadOtherData(dispatch, userId) {
  return fetch(`http://data.com/${userId}`)
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'LOAD_OTHER_DATA_SUCCESS', data }),
      err => dispatch({ type: 'LOAD_OTHER_DATA_FAILURE', err })
    );
}
function loadAllData(dispatch, userId) {
  return Promise.all(
    loadSomeData(dispatch, userId), // pass dispatch first: it's async
    loadOtherData(dispatch, userId) // pass dispatch first: it's async
  );
}


// component
componentWillMount() {
  loadAllData(this.props.dispatch, this.props.userId); // pass dispatch first
}

使用Redux Thunk,动作创建者可以调度其他动作创建者的结果,甚至不考虑这些结果是同步的还是异步的:

// action creators
function loadSomeData(userId) {
  return dispatch => fetch(`http://data.com/${userId}`)
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'LOAD_SOME_DATA_SUCCESS', data }),
      err => dispatch({ type: 'LOAD_SOME_DATA_FAILURE', err })
    );
}
function loadOtherData(userId) {
  return dispatch => fetch(`http://data.com/${userId}`)
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'LOAD_OTHER_DATA_SUCCESS', data }),
      err => dispatch({ type: 'LOAD_OTHER_DATA_FAILURE', err })
    );
}
function loadAllData(userId) {
  return dispatch => Promise.all(
    dispatch(loadSomeData(userId)), // just dispatch normally!
    dispatch(loadOtherData(userId)) // just dispatch normally!
  );
}


// component
componentWillMount() {
  this.props.dispatch(loadAllData(this.props.userId)); // just dispatch normally!
}

使用这种方法,如果您希望动作创建者查看当前的Redux状态,您可以只使用传递给thunks的第二个getState参数,而不必修改调用代码:

function loadSomeData(userId) {
  // Thanks to Redux Thunk I can use getState() here without changing callers
  return (dispatch, getState) => {
    if (getState().data[userId].isLoaded) {
      return Promise.resolve();
    }

    fetch(`http://data.com/${userId}`)
      .then(res => res.json())
      .then(
        data => dispatch({ type: 'LOAD_SOME_DATA_SUCCESS', data }),
        err => dispatch({ type: 'LOAD_SOME_DATA_FAILURE', err })
      );
  }
}

如果需要将其更改为同步,也可以在不更改任何调用代码的情况下执行此操作:

// I can change it to be a regular action creator without touching callers
function loadSomeData(userId) {
  return {
    type: 'LOAD_SOME_DATA_SUCCESS',
    data: localStorage.getItem('my-data')
  }
}

因此,使用Redux Thunk或Redux Promise等中间件的好处是,组件不知道动作创建者是如何实现的,也不知道它们是否关心Redux状态,它们是同步还是异步,以及它们是否调用其他动作创建者。缺点是有点间接,但我们认为这在实际应用中是值得的。

最后,Redux Thunk和朋友只是Redux应用程序中异步请求的一种可能方法。另一种有趣的方法是Redux Saga,它允许您定义长时间运行的守护进程(“sagas”),这些守护进程在执行操作时执行操作,并在输出操作之前转换或执行请求。这将逻辑从动作创作者转变为传奇。你可能想看看,然后选择最适合你的。

我在Redux repo中搜索线索,发现Action Creator在过去被要求是纯函数。

这是不正确的。医生们这么说,但医生们错了。动作创建者从未被要求是纯函数。我们修改了文档以反映这一点。

你没有。

但是你应该使用redux saga:)

丹·阿布拉莫夫的回答是正确的,关于redux thunk,但我将更多地谈论redux传奇,它非常相似,但更强大。

命令性VS声明性

DOM:jQuery是命令性的/React是声明性的Monads:IO是命令性的/Free是声明性的Redux效果:Redux thunk是命令性的/Redux saga是声明性的

当你手中有一个暴徒,比如一个IO monad或一个承诺,你很难知道一旦你执行了它会做什么。测试thunk的唯一方法是执行它,并模拟调度程序(如果它与更多的东西交互,则模拟整个外部世界…)。

如果您使用的是模拟,那么您不是在进行函数式编程。

从副作用的角度来看,模拟是一个标志,表明你的代码是不纯洁的,在功能程序员的眼里,它是错误的证据。我们应该绕过冰山,而不是下载一个图书馆来帮助我们检查冰山是否完好无损。一个铁杆TDD/Java的家伙曾经问我,你如何在Clojure中进行嘲笑。答案是,我们通常不会。我们通常将其视为需要重构代码的信号。

来源

saga(在redux saga中实现的)是声明性的,与Free monad或React组件一样,它们在没有任何模拟的情况下更容易测试。

另请参阅本文:

在现代FP中,我们不应该编写程序——我们应该编写程序的描述,然后我们可以随意反思、转换和解释。

(实际上,Redux传奇就像一个混合体:流程是强制性的,但效果是声明性的)

困惑:动作/事件/命令。。。

在前端世界中,对于一些后端概念(如CQRS/EventSourcing和Flux/Redux)可能是如何关联的,存在很多困惑,主要是因为在Flux中,我们使用了术语“action”,它有时可以同时表示命令式代码(LOAD_USER)和事件(USER_LOADED)。我认为,与事件源一样,您应该只发送事件。

在实践中使用西米

想象一个带有用户配置文件链接的应用程序。处理每个中间件的惯用方法是:

重复敲击声

<div onClick={e => dispatch(actions.loadUserProfile(123)}>Robert</div>

function loadUserProfile(userId) {
  return dispatch => fetch(`http://data.com/${userId}`)
    .then(res => res.json())
    .then(
      data => dispatch({ type: 'USER_PROFILE_LOADED', data }),
      err => dispatch({ type: 'USER_PROFILE_LOAD_FAILED', err })
    );
}

冗余传奇

<div onClick={e => dispatch({ type: 'USER_NAME_CLICKED', payload: 123 })}>Robert</div>


function* loadUserProfileOnNameClick() {
  yield* takeLatest("USER_NAME_CLICKED", fetchUser);
}

function* fetchUser(action) {
  try {
    const userProfile = yield fetch(`http://data.com/${action.payload.userId }`)
    yield put({ type: 'USER_PROFILE_LOADED', userProfile })
  } 
  catch(err) {
    yield put({ type: 'USER_PROFILE_LOAD_FAILED', err })
  }
}

这段传奇可以翻译为:

每次单击用户名时,获取用户配置文件,然后使用加载的配置文件发送事件。

正如你所看到的,redux saga有一些优点。

takeLatest的使用表明,您只对获取上次单击的用户名的数据感兴趣(在用户快速单击大量用户名时处理并发问题)。这种东西很难对付暴徒。如果你不想要这种行为,你可以使用takeEvery。

你让动作创作者保持纯洁。注意,保留actionCreator(在sagas put和组件分派中)仍然很有用,因为它可能会帮助您在将来添加动作验证(断言/流/类型脚本)。

由于效果是声明性的,所以代码变得更加可测试

你不需要再触发类似rpc的调用,比如actions.loadUser()。你的UI只需要调度已经发生的事情。我们只发射事件(总是用过去时!),不再发射动作。这意味着您可以创建解耦的“鸭子”或有边界的上下文,并且saga可以充当这些模块化组件之间的耦合点。

这意味着您的视图更易于管理,因为它们不再需要包含已发生和应发生的效果之间的转换层

例如,想象一个无限的滚动视图。CONTAINER_SSCROLLED可以导致NEXT_PAGE_LOADED,但可滚动容器是否真的有责任决定我们是否应该加载另一个页面?然后,他必须意识到更复杂的事情,比如最后一个页面是否成功加载,是否已经有一个页面试图加载,或者是否没有更多的项目可以加载?我不这么认为:为了实现最大的可重用性,可滚动容器应该只描述它已经被滚动了。加载页面是该滚动条的“业务效果”

有些人可能会认为生成器可以用本地变量内在地隐藏redux存储之外的状态,但如果您开始通过启动计时器等在thunk内部协调复杂的事情,那么无论如何都会遇到同样的问题。还有一个选择效果,现在可以从你的Redux商店获得一些状态。

佐贺可以是耗时的,也可以实现目前正在开发的复杂的流日志记录和开发工具。下面是一些已经实现的简单异步流日志记录:

解耦

传奇不仅取代了重复的thunks。它们来自后端/分布式系统/事件源。

这是一个非常普遍的误解,即sagas只是为了用更好的可测试性来替换你的redux thunks。实际上,这只是redux saga的一个实现细节。对于可测试性,使用声明性效果比thunks更好,但saga模式可以在命令性或声明性代码之上实现。

首先,传奇是一个软件,它允许协调长期运行的事务(最终一致性),以及跨不同边界环境的事务(领域驱动的设计术语)。

为了简化前端世界,假设有小部件1和小部件2。当单击小部件1上的某个按钮时,它应该会对小部件2产生影响。与其将两个小部件耦合在一起(即,小部件1调度一个以小部件2为目标的操作),小部件2只调度其按钮被单击。然后,saga监听此按钮,然后通过发送小部件2知道的新事件来更新小部件2。

这增加了简单应用程序不需要的间接级别,但可以更容易地扩展复杂应用程序。现在,您可以将小部件1和小部件2发布到不同的npm存储库,这样它们就不必知道彼此,而无需共享全局操作注册表。这两个小部件现在是可以单独使用的有界上下文。它们不需要彼此保持一致,也可以在其他应用程序中重复使用。传奇故事是两个小部件之间的耦合点,它们以有意义的方式对您的业务进行协调。

关于如何构建Redux应用程序的一些好文章,出于脱钩的原因,您可以在上面使用Redux saga:

http://jaysoo.ca/2016/02/28/organizing-redux-application/http://marmelab.com/blog/2015/12/17/react-directory-structure.htmlhttps://github.com/slorber/scalable-frontend-with-elm-or-redux

一个具体的用例:通知系统

我希望我的组件能够触发应用内通知的显示。但我不希望我的组件与具有自己业务规则的通知系统高度耦合(最多同时显示3个通知、通知排队、4秒显示时间等)。

我不希望JSX组件决定何时显示/隐藏通知。我只是赋予它请求通知的能力,并将复杂的规则留在传奇中。这种东西很难用恶棍或承诺来实现。

我已经在这里描述了如何用saga实现这一点

为什么叫佐贺?

传奇这个词来自后端世界。我最初在一次长时间的讨论中介绍了亚辛(《红色传奇》的作者)这个词。

最初,这一术语是在一篇论文中引入的,saga模式本应用于处理分布式事务中的最终一致性,但后端开发人员已将其用法扩展到更广泛的定义,因此它现在也涵盖了“流程管理器”模式(不知何故,最初的saga模式是流程管理器的一种特殊形式)。

今天,“传奇”一词令人困惑,因为它可以描述两种不同的事情。正如redux saga中使用的那样,它没有描述处理分布式事务的方法,而是描述在应用程序中协调操作的方法。redux saga也可以被称为redux过程管理器。

另请参见:

采访亚辛,讲述Redux传奇的历史凯拉·拜特:讲述传奇模式微软CQRS之旅:传奇故事亚辛的中等反应

选择

如果您不喜欢使用生成器的想法,但对saga模式及其解耦财产感兴趣,那么也可以使用redux-observable实现同样的目的,它使用名称epic来描述完全相同的模式,但使用RxJS。如果你已经熟悉Rx,你会感到宾至如归。

const loadUserProfileOnNameClickEpic = action$ =>
  action$.ofType('USER_NAME_CLICKED')
    .switchMap(action =>
      Observable.ajax(`http://data.com/${action.payload.userId}`)
        .map(userProfile => ({
          type: 'USER_PROFILE_LOADED',
          userProfile
        }))
        .catch(err => Observable.of({
          type: 'USER_PROFILE_LOAD_FAILED',
          err
        }))
    );

一些redux saga有用的资源

Redux saga vs Redux thunk与异步/等待Redux Saga的流程管理从动作创作者到传奇用Redux saga实现的Snake游戏

2017年建议

不要为了使用它而过度使用Redux传奇。只调用可测试的API是不值得的。对于大多数简单的情况,不要从项目中删除thunk。如果有意义的话,不要犹豫在yield put(someActionThunk)中发送thunk。

如果您害怕使用Redux saga(或Redux observable),但只需要解耦模式,请检查Redux分派订阅:它允许侦听分派并在侦听器中触发新分派。

const unsubscribe = store.addDispatchListener(action => {
  if (action.type === 'ping') {
    store.dispatch({ type: 'pong' });
  }
});

有同步动作创建器,然后有异步动作创建器。

同步动作创建器是一个当我们调用它时,它会立即返回一个action对象,其中包含附加到该对象的所有相关数据,并准备好由我们的还原器处理。

异步动作创建器需要一点时间才能最终调度动作。

根据定义,每当您有一个动作创建者发出网络请求时,它总是符合异步动作创建者的资格。

如果您想在Redux应用程序中使用异步动作创建器,则必须安装一种叫做中间件的东西,该中间件将允许您处理这些异步动作创建。

您可以在错误消息中验证这一点,该错误消息告诉我们使用自定义中间件执行异步操作。

那么什么是中间件,为什么我们需要它来实现Redux中的异步流呢?

在redux中间件(如redux thunk)的上下文中,中间件帮助我们处理异步动作创建者,因为这是redux无法开箱即用的。

随着中间件集成到Redux循环中,我们仍在调用动作创建者,这将返回一个将被调度的动作,但现在,当我们调度一个动作时,而不是直接将其发送给所有的reducer,我们将说一个动作将通过应用程序中的所有不同中间件发送。

在一个Redux应用程序中,我们可以拥有任意数量的中间件。在大多数情况下,在我们工作的项目中,我们将有一两个中间件连接到我们的Redux商店。

中间件是一个普通的JavaScript函数,我们分派的每个动作都会调用它。在该功能内部,中间件有机会阻止某个动作被分派到任何一个reducer,它可以修改某个动作或以任何方式处理某个动作,例如,我们可以创建一个中间件,控制台记录您分派的每一个动作,只是为了您的观看乐趣。

有大量的开源中间件可以作为依赖项安装到项目中。

您不限于仅使用开源中间件或将其作为依赖项安装。您可以编写自己的定制中间件,并在Redux商店中使用它。

中间件的一个更流行的用途(并得到您的答案)是处理异步动作创建者,可能最流行的中间件是redux thunk,它是帮助您处理异步动作创作者。

还有许多其他类型的中间件也可以帮助您处理异步动作创建者。

要回答开头提出的问题:

为什么容器组件不能调用异步API,然后分派操作?

请记住,这些文档适用于Redux,而不是Redux+React。连接到React组件的Redux商店可以做到您所说的一切,但没有中间件的Plain Jane Redux商店不接受除普通对象之外的参数来分派。

如果没有中间件,你当然还可以

const store = createStore(reducer);
MyAPI.doThing().then(resp => store.dispatch(...));

但这是一个类似的情况,异步是围绕着Redux而不是由Redux处理的。因此,中间件通过修改可以直接传递给调度的内容来允许异步。


也就是说,我认为你的建议的精神是有效的。在Redux+Rreact应用程序中,当然还有其他方法可以处理异步。

使用中间件的一个好处是,您可以继续正常使用动作创建者,而不必担心它们是如何连接的。例如,使用redux thunk,您编写的代码看起来很像

function updateThing() {
  return dispatch => {
    dispatch({
      type: ActionTypes.STARTED_UPDATING
    });
    AsyncApi.getFieldValue()
      .then(result => dispatch({
        type: ActionTypes.UPDATED,
        payload: result
      }));
  }
}

const ConnectedApp = connect(
  (state) => { ...state },
  { update: updateThing }
)(App);

它看起来与原始版本没有太大区别-只是有点混乱-connect不知道updateThing是(或需要)异步的。

如果您还想支持承诺、可观测性、传奇或疯狂的自定义和高度声明性的动作创建者,那么Redux可以通过更改传递给分派的内容(也就是从动作创建者返回的内容)来实现。无需干扰React组件(或连接调用)。