聊一聊KOA的洋葱模型(koa洋葱模型原理)
ccwgpt 2024-09-21 13:37 21 浏览 0 评论
我们知道,在前端发展初期,html网页只是静态的,任何小的改动意味着一个新的页面;之后出现了iframe和XMLHttpRequest,实现了异步的局部加载,极大的提升了用户体验;再到后面的jQuery,利用 命令式 的编程管理dom的状态,但应用一旦复杂的话也难以维护;直到近些年从Angular的诞生,到后来的React,Vue陆续推出,各类前端技术框架层出不穷,除了Vue用户熟悉的Vuex,React与Redux,还出现了Mobx,Rxjs等其他优秀的数据存储和管理的方案,这才真正有了前端状态管理的概念。
不得不说,SPA的出现进一步带动了前后端分离,前端再也不需要通过请求URL返回的HTML来显示页面,而是通过加载解析JS代码生成DOM,独立地实现了内容的渲染,在这过程中, 数据驱动 的思想也深入人心。
所谓数据驱动,是指视图是由数据驱动生成的,我们可以通过修改数据来处理DOM,这也是典型的 声明式 编程。以React为例,我们可以轻松的通过改变state更新UI,但是有一个问题,React并不会对数据层有任何的限制,即任何组件都可以改变数据层的代码,那就带来了一个问题,一旦数据层出现特殊状况,很难快速定位和解决问题,那么如何在视图组件中管理公共的状态呢?
这个时候Facebook团队提出了Flux思想,旨在从架构层面来解决MVC的在复杂场景下越来越复杂内部逻辑繁重等问题。那到底啥才是Flux架构呢?
Flux思想及其实现
Vuex官方文档里一句话很有意思:"Flux 架构就像眼镜:您自会知道什么时候需要它。"
好吧,还是不清楚,那我们先了解一下Flux的一些基本概念。(以Facebook官方实现为例)
Flux将一个应用分成四个部分,其中: 视图层 View、视图层发出的消息 Action、用来接收Actions并执行回调函数 Dispatcher、以及用来存放应用的状态的 Store 。
从上图可以很明显看到,这是一个 单向流动 的过程:用户只能触发Action来修改状态,应用的状态也必须放在Store里统一管理,通过监听Action进行一些具体的操作。任何状态的变更都离不开Action的发起以及Dispatcher的派发,这样一来,我们可以很容易的记录每一次的状态变化。这也是Flux基本的设计理念,之后在此基础上也出现了越来越多的Flux实践,接下来,我们以React的状态管理发展历程为例,看看Redux是怎么管理状态的。
(对Flux感兴趣的话可以继续看阮一峰这篇 Flux架构入门教程 。)
Redux
React刚出现的时候还没有Redux,我们只能通过state来管理组件的状态,这在多数情况下已经足够了,但是应用一旦复杂起来,状态还是会变得难以维护。之后又受到Flux的影响,在这种环境下,Redux应运而生。
首先,Redux有三大原则: 单一数据源,state只读,使用纯函数来执行修改 。前两条很好理解,至于第三条,要知道React遵循的是数据的不可变性,即永远不在原对象上修改属性,并且在源码中,Redux只通过比较新旧两个对象的存储位置来比较新旧两个对象是否相同,这就意味着不能直接修改state的属性,每次只能返回新的 state。于是我们可以把Redux当作是 Reduce + Flux,而Reduce就是上面说的纯函数。
不仅如此,Redux中还有一个重要的概念 Middleware。
Redux中的中间件提供的是位于 Action 被发起之后,到达 Reducer 之前的扩展点,一图概括:
可以看到,使用中间件时,中间件会将发起的Actions做相应的处理,最后交给Reducer执行。假设我们需要在每次触发Action前打印log,那我们就可以将Dispatch方法拿出来重写,大概像这样:
let next = store.dispatch
store.dispatch = function dispatchLog(action) {
console.log('log', action)
next(action)
}
这样以后发出Action时,就不需要做额外的工作了。
那为什么要将中间件设计成这种 middleware =(store) => (next) => (action) => { [return next(action)]} 多层柯里化的写法呢,源码中有applyMiddleware方法用来添加中间件,其核心代码大概是这样:
let store = createStore(reducers);
let dispatch;
// 这里第一次执行返回了一个存放可以修改dispatch函数的数组chain [f(next)=>acticon=>next(action)]
// 这个函数接收next参数 就是在中间件间传递的diapatch方法
let chain = middlewares.map(middleware => middleware({
getState: store.getState, // 因为闭包 执行中间件的时候store不会更新
dispatch: action => dispatch(action)
}));
// 调用原生的dispatch重写dispatch逻辑 只有最后一个中间件会接受真实的dispatch方法
dispatch = compose(...chain)(store.dispatch);
return {
...store,
dispatch
}
这里可以看到中间件的设计确实十分巧妙,利用柯里化的结构 可以方便的访问相同的store,还能够配合compose方法,积累参数达到延迟执行的效果 ,关于compose方法的说明就不列出来了,主要是通过reduce方法从右到左整合中间件。
其实Redux源码的内容还有其他值得细细品味的地方,以后有机会再写吧,接下来我们看一个新鲜的面孔。
下一代React状态管理器
自从React16以来,大家都纷纷用起了Hooks,毫无疑问,Hooks的出现在一定程度上解决了组件间功能复用的问题,这种逻辑的封装和复用确实很香,但还存在某些问题,比如说数据的共享。hox,被称为下一代React状态管理器,就是为了解决这类问题。
进入项目的Github,这里的Features很有意思: 只有一个API;使用 custom Hooks 来定义 model;完美拥抱TypeScript;支持多数据源 。不得不说这个one API很吸引人,我们先看看官方示例:
// 定义Model
import { createModel } from 'hox';
/* 任意一个 custom Hook */
function useCounter() {
const [count, setCount] = useState(0);
const decrement = () => setCount(count - 1);
const increment = () => setCount(count + 1);
return {
count,
decrement,
increment
};
}
export default createModel(useCounter)
--------------------------------------------------------------------------------------------
// 使用Model
import { useCounterModel } from "../models/useCounterModel";
function App(props) {
const counter = useCounterModel();
return (
<div>
<p>{counter.count}</p>
<button onClick={counter.increment}>Increment</button>
</div>
);
}
// 这个时候useCounterModel 是一个真正的 Hook,会订阅数据的更新。也就是说,当点击 “Increment” 按钮时,会触发 counter model 的更新,并且最终通知所有使用 useCounterModel 的组件或 Hook。
这里的createModel类似HOC的使用,其作用就是实现数据的共享,原理大概就是其内部实现了个发布订阅器,每当Model进行重渲染时,会通知其订阅者重新进行渲染。有兴趣的童鞋们不妨直接去看源码,其核心内容并不多。
相关推荐
- 迈向群体智能 | 智源发布首个跨本体具身大小脑协作框架
-
允中发自凹非寺量子位|公众号QbitAI3月29日,智源研究院在2025中关村论坛“未来人工智能先锋论坛”上发布首个跨本体具身大小脑协作框架RoboOS与开源具身大脑RoboBrain,可实...
- 大模型对接微信个人号,极空间部署AstrBot机器人,万事不求百度
-
「亲爱的粉丝朋友们好啊!今天熊猫又来介绍好玩有趣的Docker项目了,喜欢的记得点个关注哦!」引言前两天熊猫发过一篇关于如何在极空间部署AstrBot并对接QQ消息平台的文章,不过其实QQ现在已经很少...
- Seata,让分布式事务不再是难题!实战分享带你领略Seata的魅力!
-
终身学习、乐于分享、共同成长!前言Seata是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务。Seata将为用户提供了AT、TCC、SAGA和XA事务模式,为用户打造一站式的...
- 常见分布式事务解决方案(分布式事务解决的问题)
-
1.两阶段提交(2PC)原理:分为准备阶段(协调者询问参与者是否可提交)和提交阶段(协调者根据参与者反馈决定提交或回滚)。优点:强一致性,适用于数据库层(如XA协议)。缺点:同步阻塞:所有参与者阻塞...
- 分布式事务:从崩溃到高可用,程序员必须掌握的实战方案!
-
“支付成功,但订单状态未更新!”、“库存扣减后,交易却回滚了!”——如果你在分布式系统中踩过这些“天坑”,这篇文章就是你的救命稻草!本文将手把手拆解分布式事务的核心痛点和6大主流解决方案,用代码实战+...
- 谈谈对分布式事务的一点理解和解决方案
-
分布式事务首先,做系统拆分的时候几乎都会遇到分布式事务的问题,一个仿真的案例如下:项目初期,由于用户体量不大,订单模块和钱包模块共库共应用(大war包时代),模块调用可以简化为本地事务操作,这样做只要...
- 一篇教你通过Seata解决分布式事务问题
-
1 Seata介绍Seata是由阿里中间件团队发起的开源分布式事务框架项目,依赖支持本地ACID事务的关系型数据库,可以高效并且对业务0侵入的方式解决微服务场景下面临的分布式事务问题,目前提供AT...
- Seata分布式事务详解(原理流程及4种模式)
-
Seata分布式事务是SpringCloudAlibaba的核心组件,也是构建分布式的基石,下面我就全面来详解Seata@mikechen本篇已收于mikechen原创超30万字《阿里架构师进阶专题合...
- 分布式事务最终一致性解决方案有哪些?MQ、TCC、saga如何实现?
-
JTA方案适用于单体架构多数据源时实现分布式事务,但对于微服务间的分布式事务就无能为力了,我们需要使用其他的方案实现分布式事务。1、本地消息表本地消息表的核心思想是将分布式事务拆分成本地事务进行处理...
- 彻底掌握分布式事务2PC、3PC模型(分布式事务视频教程)
-
原文:https://mp.weixin.qq.com/s/_zhntxv07GEz9ktAKuj70Q作者:马龙台工作中使用最多的是本地事务,但是在对单一项目拆分为SOA、微服务之后,就会牵扯出分...
- Seata分布式事务框架关于Annotation的SAGA模式分析
-
SAGAAnnotation是ApacheSeata版本2.3.0中引入的功能,它提供了一种使用Java注解而不是传统的JSON配置或编程API来实现SAGA事务模式的声明...
- 分布式事务,原理简单,写起来全是坑
-
今天我们就一起来看下另一种模式,XA模式!其实我觉得seata中的四种不同的分布式事务模式,学完AT、TCC以及XA就够了,Saga不好玩,而且长事务本身就有很多问题,也不推荐使用。S...
- 内存空间节约利器redis的bitmap(位图)应用场景有哪些你知道吗
-
在前面我们分享过一次Redis常用数据结构和使用场景,文章对Redis基本使用做了一个简单的API说明,但是对于其中String类型中的bitmap(位图)我们需要重点说明一下,因为他的作用真的不容忽...
- 分布式事务原理详解(图文全面总结)
-
分布式事务是非常核心的分布式系统,也是大厂经常考察对象,下面我就重点详解分布式事务及原理实现@mikechen本文作者:陈睿|mikechen文章来源:mikechen.cc分布式事务分布式事务指的是...
- 大家平时天天说的分布式系统到底是什么东西?
-
目录从单块系统说起团队越来越大,业务越来越复杂分布式出现:庞大系统分而治之分布式系统所带来的技术问题一句话总结:什么是分布式系统设计和开发经验补充说明:中间件系统及大数据系统前言现在有很多Java技术...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- MVC框架 (46)
- spring框架 (46)
- 框架图 (58)
- bootstrap框架 (43)
- flask框架 (53)
- quartz框架 (51)
- abp框架 (47)
- jpa框架 (47)
- laravel框架 (46)
- express框架 (43)
- springmvc框架 (49)
- 分布式事务框架 (65)
- scrapy框架 (52)
- java框架spring (43)
- grpc框架 (55)
- orm框架有哪些 (43)
- ppt框架 (48)
- 内联框架 (52)
- winform框架 (46)
- gui框架 (44)
- cad怎么画框架 (58)
- ps怎么画框架 (47)
- ssm框架实现登录注册 (49)
- oracle字符串长度 (48)
- oracle提交事务 (47)