- React有props和state:
props意味着父级分发下来的属性
state意味着组件内部可以自行管理的状态,并且整个React没有数据向上回溯的能力,这就是react的单向数据流。这就意味着如果是一个数据状态非常复杂的应用,更多的时候发现React根本无法让两个组件互相交流,使用对方的数据,react的通过层级传递数据的这种方法是非常难受的,这个时候,迫切需要一个机制,把所有的state集中到组件顶部,能够灵活的将所有state各取所需的分发给所有的组件,这就是redux - Redux的诞生是为了给 React 应用提供「可预测化的状态管理」机制。
- Redux会将整个应用状态(其实也就是数据)存储到到一个地方,称为store(就是一个数据池,一个应用只有一个),这个store里面保存一棵状态树(state tree),组件改变state的唯一方法是通过调用store的dispatch方法,触发一个action,这个action被对应的reducer(reducer就是改变state的处理层,它接收action和state,通过处理action来返回新的state)处理,于是state完成更新
组件可以派发(dispatch)行为(action)给store,而不是直接通知其它组件,其它组件可以通过订阅store中的状态(state)来刷新自己的视图 -
使用步骤
1.创建reducer
可以使用单独的一个reducer,也可以将多个reducer合并为一个reducer,即:combineReducers()
action发出命令后将state放入reducer加工函数中,返回新的state,对state进行加工处理
2.创建action
用户是接触不到state的,只能由view触发,action可以理解为指令,需要发出多少动作就有多少指令,action是一个对象,其中的type属性是必须的,定义action类型,其他属性可以自由设置
3.创建store,使用createStore方法。store 可以理解为有多个加工机器的总工厂,提供subscribe,dispatch,getState这些方法。
- 如果把store直接集成到React应用的顶层props里面,只要各个子组件能访问到顶层props就可以了,比如这样:
<顶层组件 store={store}>
<App />
</顶层组件>
这就是 react-redux,是为了让redux更好的适用于react而生的一个库。react-redux将组件区分为容器组件 和 UI 组件,前者会处理逻辑,后者只负责显示和交互,内部不处理逻辑,状态完全由外部掌控。
- 两个核心
Provider
一般我们都将顶层组件包裹在Provider组件之中,这样,所有组件就都可以在react-redux的控制之下了,但是store必须作为参数放到Provider组件中。
<Provider store = {store}>
<App />
<Provider>
// 这样,所有组件都能够访问到Redux中的数据
connect
这个方法可以从UI组件生成容器组件,但容器组件的定位是处理数据、响应行为,因此,需要对UI组件添加额外的东西,即mapStateToProps和mapDispatchToProps,也就是在组件外加了一层state,用法如下:
connect(mapStateToProps, mapDispatchToProps)(MyComponent)
mapStateToProps
把Redux中的数据映射到React中的props中去,举例:
const mapStateToProps = (state) => {
return {
foo: state.bar
}
}
然后渲染的时候就可以使用this.props.foo
class Foo extends Component {
constructor(props){
super(props);
}
render(){
return(
<div>this.props.foo</div>
)
}
}
Foo = connect()(Foo);
export default Foo;
然后这样就可以完成渲染了
mapDispatchToProps
把各种dispatch也变成了可以直接使用的props,举例:
const mapDispatchToProps = (dispatch) => {
return {
onClick: () => {
dispatch({type: 'increatment'});
}
}
}
class Foo extends Component {
constructor(props){
super(props);
}
render(){
return(
<button onClick = {this.props.onClick}>click increase</button>
)
}
}
Foo = connect()(Foo);
export default Foo;
组件可以直接通过this.props.onClick来调用dispatch,就不需要在代码中来进行store.dispatch了
- 如果按照原始的redux工作流程,当组件中产生一个action后会直接触发reducer修改state,reducer又是一个纯函数,也就是不能在reducer中进行异步操作;而往往实际中,组件中发生的action在进入reducer之前需要完成一个异步任务(比如发送ajax请求),拿到数据后再进入reducer,这个时候就需要一个中间件来处理这种业务场景,目前最优雅的处理方式是redux-saga中间件,它通过 Generator 函数来创建,可以用同步的方式写异步的代码,目的是更好、更易地解决异步操作(把所有异步请求集中处理)。
redux-saga提供了一些辅助函数,用来在一些特定的action 被发起到Store时派生任务,我们先来看两个辅助函数:takeEvery 和 takeLatest
takeEvery
takeEvery,同一个action多次触发,每个都会执行
例如:每次点击按钮去Fetch数据时,我们发起一个 FETCH_REQUESTED 的 action,想通过启动一个任务从服务器获取一些数据,来处理这个action
首先创建一个将执行异步 action 的任务
// put:你就认为put就等于 dispatch就可以了
// call:可以理解为实行一个异步函数,是阻塞型的,只有运行完后面的函数,才会继续往下
import { call, put } from 'redux-saga/effects'
export function* fetchData(action) {
try {
const apiAjax = (params) => fetch(url, params);
const data = yield call(apiAjax);
yield put({type: "FETCH_SUCCEEDED", data});
} catch (error) {
yield put({type: "FETCH_FAILED", error});
}
}
然后在每次 FETCH_REQUESTED action 被发起时启动上面的任务,也就相当于每次触发一个名字为 FETCH_REQUESTED 的action就会执行上边的任务,代码如下
import { takeEvery } from 'redux-saga'
function* watchFetchData() {
yield* takeEvery("FETCH_REQUESTED", fetchData)
}
takeLatest
在上面的例子中,takeEvery 允许多个 fetchData 实例同时启动,在某个特定时刻,我们可以启动一个新的 fetchData 任务, 尽管之前还有一个或多个 fetchData 尚未结束,如果我们只想得到最新那个请求的响应(例如,始终显示最新版本的数据),我们可以使用 takeLatest
import { takeLatest } from 'redux-saga'
function* watchFetchData() {
yield* takeLatest('FETCH_REQUESTED', fetchData)
}
和takeEvery不同,在任何时刻 takeLatest 只允许执行一个 fetchData 任务,并且这个任务是最后被启动的那个,如果之前已经有一个任务在执行,那之前的这个任务会自动被取消
Effect Creators
redux-saga框架提供了很多创建effect的函数,下面我们就来简单的介绍下开发中最常用的几种
- take(pattern)
- put(action)
- call(fn, ...args)
- fork(fn, ...args)
- select(selector, ...args)
take(pattern)
take函数可以理解为监听未来的action,它创建了一个命令对象,告诉middleware等待一个特定的action,Generator会暂停,直到一个与pattern匹配的action被发起,才会继续执行下面的语句,也就是说,take是一个阻塞的 effect,用法:
function* watchFetchData() {
while(true) {
// 监听一个type为 'FETCH_REQUESTED' 的action的执行,直到等到这个Action被触发,才会接着执行下面的 yield fork(fetchData) 语句
yield take('FETCH_REQUESTED');
yield fork(fetchData);
}
}
put(action)
put函数是用来发送action的 effect,你可以简单的把它理解成为redux框架中的dispatch函数,当put一个action后,reducer中就会计算新的state并返回,put 也是阻塞 effect,用法:
export function* toggleItemFlow() {
let list = []
// 发送一个type为 'UPDATE_DATA' 的Action,用来更新数据,参数为 `data:list`
yield put({
type: actionTypes.UPDATE_DATA,
data: list
})
}
call(fn, ...args)
call函数简单的理解为可以调用其他函数的函数,它命令 middleware 来调用fn 函数,args为函数的参数,注意:fn 函数可以是一个 Generator 函数,也可以是一个返回 Promise 的普通函数,call 函数也是阻塞 effect,用法:
export const delay = ms => new Promise(resolve => setTimeout(resolve, ms))
export function* removeItem() {
try {
// 这里call 函数就调用了 delay 函数,delay 函数为一个返回promise 的函数
return yield call(delay, 500)
} catch (err) {
yield put({type: actionTypes.ERROR})
}
}
fork(fn, ...args)
fork 函数和 call 函数很像,都是用来调用其他函数的,但是fork函数是非阻塞函数,也就是说,程序执行完 yield fork(fn, args) 这一行代码后,会立即接着执行下一行代码语句,而不会等待fn函数返回结果后再执行下面的语句,用法:
import { fork } from 'redux-saga/effects'
export default function* rootSaga() {
// 下面的四个 Generator 函数会一次执行,不会阻塞执行
yield fork(addItemFlow)
yield fork(removeItemFlow)
yield fork(toggleItemFlow)
yield fork(modifyItem)
}
select(selector, ...args)
select 函数是用来指示 middleware调用提供的选择器获取Store上的state数据,可以简单的把它理解为redux框架中获取store上的 state数据一样的功能 :store.getState(),用法:
export function* toggleItemFlow() {
// 通过 select effect 来获取 全局 state上的 `getTodoList` 中的 list
let tempList = yield select(state => state.getTodoList.list)
}
一个具体的实例
- index.js
import React from 'react';
import ReactDOM from 'react-dom';
import {createStore, applyMiddleware} from 'redux'
import createSagaMiddleware from 'redux-saga'
import rootSaga from './sagas'
import Counter from './Counter'
import rootReducer from './reducers'
const sagaMiddleware = createSagaMiddleware() // 创建了一个saga中间件实例
// 下边这句话和下边的两行代码创建store的方式是一样的
// const store = createStore(reducers,applyMiddlecare(middlewares))
const createStoreWithMiddleware = applyMiddleware(middlewares)(createStore)
const store = createStoreWithMiddleware(rootReducer)
sagaMiddleware.run(rootSaga)
const action = type => store.dispatch({ type })
function render() {
ReactDOM.render(
<Counter
value={store.getState()}
onIncrement={() => action('INCREMENT')}
onDecrement={() => action('DECREMENT')}
onIncrementAsync={() => action('INCREMENT_ASYNC')} />,
document.getElementById('root')
)
}
render()
store.subscribe(render)
- sagas.js
import { put, call, take,fork } from 'redux-saga/effects';
import { takeEvery, takeLatest } from 'redux-saga'
export const delay = ms => new Promise(resolve => setTimeout(resolve, ms));
function* incrementAsync() {
// 延迟 1s 在执行 + 1操作
yield call(delay, 1000);
yield put({ type: 'INCREMENT' });
}
export default function* rootSaga() {
// while(true){
// yield take('INCREMENT_ASYNC');
// yield fork(incrementAsync);
// }
// 下面的写法与上面的写法上等效
yield* takeEvery("INCREMENT_ASYNC", incrementAsync)
}
- reducer.js
export default function counter(state = 0, action) {
switch (action.type) {
case 'INCREMENT':
return state + 1
case 'DECREMENT':
return state - 1
case 'INCREMENT_ASYNC':
return state
default:
return state
}
}
redux-saga基本用法总结:
- 使用 createSagaMiddleware 方法创建 saga 的 Middleware ,然后在创建的 redux 的 store 时,使用 applyMiddleware 函数将创建的 saga Middleware 实例绑定到 store 上,最后可以调用 saga Middleware 的 run 函数来执行某个或者某些 Middleware 。
- 在 saga 的 Middleware 中,可以使用 takeEvery 或者 takeLatest 等 API 来监听某个 action ,当某个 action 触发后, saga 可以使用 call 发起异步操作,操作完成后使用 put 函数触发 action ,同步更新 state ,从而完成整个 State 的更新。
- ui->action1(异步请求)->redux-saga->action2->reducer(更新state)