关注核心实现请直接跳至 第四小节:执行流程。javascript
本文中的命令仅适用于支持shell的系统,如Mac、乌班图及其余linux发行版。不适用于windows,若是想在windows下执行文章中的命令请使用git命令窗口(需安装git)或linux子系统(win10如下不支持)。
一、初始化工程目录html
cd ~ && mkdir my-single-spa && cd "$_"
二、初始化npm环境前端
# 初始化package.json文件 npm init -y # 安装dev依赖 npm install @babel/core @babel/plugin-syntax-dynamic-import @babel/preset-env rollup rollup-plugin-babel rollup-plugin-commonjs rollup-plugin-node-resolve rollup-plugin-serve -D
模块名称 | 说明 |
---|---|
@babel/core | babel编译器的核心库,负责全部babel预设和插件的加载及执行 |
@babel/plugin-syntax-dynamic-import | 支持使用import() 进行动态导入,当前在Stage 4: finished 的阶段 |
@babel/preset-env | 预设:为方便开发提供的经常使用的插件集合 |
rollup | javascript打包工具,在打包方面比webpack更加的纯粹 |
rollup-plugin-babel | 让rollup支持babel,开发者可使用高级js语法 |
rollup-plugin-commonjs | 将commonjs模块转换为ES6 |
rollup-plugin-node-resolve | 让rollup支持nodejs的模块解析机制 |
rollup-plugin-serve | 支持dev serve,方便调试和开发 |
三、配置babel和rollupjava
建立babel.config.jsnode
# 建立babel.config.js touch babel.config.js
添加内容:linux
module.export = function (api) { // 缓存babel的配置 api.cache(true); // 等同于api.cache.forever() return { presets: [ ['@babel/preset-env', {module: false}] ], plugins: ['@babel/plugin-syntax-dynamic-import'] }; };
建立rollup.config.jswebpack
# 建立rollup.config.js touch rollup.config.js
添加内容:git
import resolve from 'rollup-plugin-node-resolve'; import babel from 'rollup-plugin-babel'; import commonjs from 'rollup-plugin-commonjs'; import serve from 'rollup-plugin-serve'; export default { input: './src/my-single-spa.js', output: { file: './lib/umd/my-single-spa.js', format: 'umd', name: 'mySingleSpa', sourcemap: true }, plugins: [ resolve(), commonjs(), babel({exclude: 'node_modules/**'}), // 见下方的package.json文件script字段中的serve命令 // 目的是只有执行serve命令时才启动这个插件 process.env.SERVE ? serve({ open: true, contentBase: '', openPage: '/toutrial/index.html', host: 'localhost', port: '10001' }) : null ] }
四、在package.json中添加script和browserslist字段github
{ "script": { "build:dev": "rollup -c", "serve": "SERVE=true rollup -c -w" }, "browserslist": [ "ie >=11", "last 4 Safari major versions", "last 10 Chrome major versions", "last 10 Firefox major versions", "last 4 Edge major versions" ] }
四、添加项目文件夹web
mkdir -p src/applications src/lifecycles src/navigation src/services toutrial && touch src/my-single-spa.js && touch toutrial/index.html
到目前为止,整个项目的文件夹结构应该是:
. ├── babel.config.js ├── package-lock.json ├── package.json ├── rollup.config.js ├── node_modules ├── toutrial | └── index.html └── src ├── applications ├── lifecycles ├── my-single-spa.js ├── navigation └── services
到此,项目就已经初始化完毕了,接下来开始核心的内容,微前端框架的编写。
微前端的核心为app,微前端的场景主要是:将应用拆分为多个app加载,或将多个不一样的应用当成app组合在一块儿加载。
为了更好的约束app和行为,要求每一个app必须向外export完整的生命周期函数,使微前端框架能够更好地跟踪和控制它们。
// app1 export default { // app启动 bootstrap: [() => Promise.resolve()], // app挂载 mount: [() => Promise.resolve()], // app卸载 unmount: [() => Promise.resolve()], // service更新,只有service才可用 update: [() => Promise.resolve()] }
生命周期函数共有4个:bootstrap
、mount
、unmount
、update
。
生命周期能够传入 返回Promise的函数也能够传入 返回Promise函数的数组。
为了更好的管理app,特意给app增长了状态,每一个app共存在11个状态,其中每一个状态的流转图以下:
状态说明(app和service在下表统称为app):
状态 | 说明 | 下一个状态 |
---|---|---|
NOT_LOADED | app还未加载,默认状态 | LOAD_SOURCE_CODE |
LOAD_SOURCE_CODE | 加载app模块中 | NOT_BOOTSTRAPPED、SKIP_BECAUSE_BROKEN、LOAD_ERROR |
NOT_BOOTSTRAPPED | app模块加载完成,可是还未启动(未执行app的bootstrap 生命周期函数) |
BOOTSTRAPPING |
BOOTSTRAPPING | 执行app的bootstrap 生命周期函数中(只执行一次) |
SKIP_BECAUSE_BROKEN |
NOT_MOUNTED | app的bootstrap 或unmount 生命周期函数执行成功,等待执行mount 生命周期函数(可屡次执行) |
MOUNTING |
MOUNTING | 执行app的mount 生命周期函数中 |
SKIP_BECAUSE_BROKEN |
MOUNTED | app的mount 或update(service独有) 生命周期函数执行成功,意味着此app已挂载成功,可执行Vue的$mount()或ReactDOM的render() |
UNMOUNTING、UPDATEING |
UNMOUNTING | app的unmount 生命周期函数执行中,意味着此app正在卸载中,可执行Vue的$destory()或ReactDOM的unmountComponentAtNode() |
SKIP_BECAUSE_BROKEN、NOT_MOUNTED |
UPDATEING | service更新中,只有service才会有此状态,app则没有 |
SKIP_BECAUSE_BROKEN、MOUNTED |
SKIP_BECAUSE_BROKEN | app变动状态时碰见错误,若是app的状态变为了SKIP_BECAUSE_BROKEN ,那么app就会blocking ,不会往下个状态变动 |
无 |
LOAD_ERROR | 加载错误,意味着app将没法被使用 | 无 |
load、mount、unmount条件
判断须要被加载(load)的App:
判断须要被挂载(mount)的App:
判断须要被卸载(unmount)的App:
app的生命周期函数何以传入数组或函数,可是它们都必须返回一个Promise,为了方便处理,因此咱们会判断:若是传入的不是Array,就会用数组将传入的函数包裹起来。
export function smellLikeAPromise(promise) { if (promise instanceof Promise) { return true; } return typeof promise === 'object' && promise.then === 'function' && promise.catch === 'function'; } export function flattenLifecyclesArray(lifecycles, description) { if (Array.isArray(lifecycles)) { lifecycles = [lifecycles] } if (lifecycles.length === 0) { lifecycles = [() => Promise.resolve()]; } // 处理lifecycles return props => new Promise((resolve, reject) => { waitForPromise(0); function waitForPromise(index) { let fn = lifecycles[index](props); if (!smellLikeAPromise(fn)) { reject(`${description} at index ${index} did not return a promise`); return; } fn.then(() => { if (index >= lifecycles.length - 1) { resolve(); } else { waitForPromise(++index); } }).catch(reject); } }); } // 示例 app.bootstrap = [ () => Promise.resolve(), () => Promise.resolve(), () => Promise.resolve() ]; app.bootstrap = flattenLifecyclesArray(app.bootstrap);
具体的流程以下图所示:
思考:若是用reduce的话怎么写?有什么须要注意的问题么?
为了app的可用性,咱们还讲给每一个app的生命周期函数增长超时的处理。
// flattenedLifecyclesPromise为通过上一步flatten处理过的生命周期函数 export function reasonableTime(flattenedLifecyclesPromise, description, timeout) { return new Promise((resolve, reject) => { let finished = false; flattenedLifecyclesPromise.then((data) => { finished = true; resolve(data) }).catch(e => { finished = true; reject(e); }); setTimeout(() => { if (finished) { return; } let error = `${description} did not resolve or reject for ${timeout.milliseconds} milliseconds`; if (timeout.rejectWhenTimeout) { reject(new Error(error)); } else { console.log(`${error} but still waiting for fulfilled or unfulfilled`); } }, timeout.milliseconds); }); } // 示例 reasonableTime(app.bootstrap(props), 'app bootstraping', {rejectWhenTimeout: false, milliseconds: 3000}) .then(() => { console.log('app 启动成功了'); console.log(app.status === 'NOT_MOUNTED'); // => true }) .catch(e => { console.error(e); console.log('app启动失败'); console.log(app.status === 'SKIP_BECAUSE_BROKEN'); // => true });
微前端中app分为两种:一种是根据Location进行变化的,称之为app。另外一种是纯功能(Feature)级别的,称之为service。
若是要实现随Location的变化动态进行mount和unmount那些符合条件的app,咱们就须要对浏览器的Location相关操做作统一的拦截。另外,为了在使用Vue、React等视图框架时下降冲突,咱们须要保证微前端必须是第一个处理Location的相关事件,而后才是Vue或React等框架的Router处理。
为何Location改变时,微前端框架必定要第一个执行相关操做哪?如何保证"第一个"?由于微前端框架要根据Location来对app进行mount或unmount操做。而后app内部使用的Vue或React才开始真正进行后续工做,这样能够最大程度减小app内部Vue或React的无用(冗余)操做。
对原生的Location相关事件进行拦截(hijack),统一由微前端框架进行控制,这样就能够保证老是第一个执行。
const HIJACK_EVENTS_NAME = /^(hashchange|popstate)$/i; const EVENTS_POOL = { hashchange: [], popstate: [] }; function reroute() { // invoke主要用来load、mount、unmout知足条件的app // 具体条件请看文章上方app状态小节中的"load、mount、unmount条件" invoke([], arguments) } window.addEventListener('hashchange', reroute); window.addEventListener('popstate', reroute); const originalAddEventListener = window.addEventListener; const originalRemoveEventListener = window.removeEventListener; window.addEventListener = function (eventName, handler) { if (eventName && HIJACK_EVENTS_NAME.test(eventName) && typeof handler === 'function') { EVENTS_POOL[eventName].indexOf(handler) === -1 && EVENTS_POOL[eventName].push(handler); } return originalAddEventListener.apply(this, arguments); }; window.removeEventListener = function (eventName, handler) { if (eventName && HIJACK_EVENTS_NAME.test(eventName)) { let eventsList = EVENTS_POOL[eventName]; eventsList.indexOf(handler) > -1 && (EVENTS_POOL[eventName] = eventsList.filter(fn => fn !== handler)); } return originalRemoveEventListener.apply(this, arguments); }; function mockPopStateEvent(state) { return new PopStateEvent('popstate', {state}); } // 拦截history的方法,由于pushState和replaceState方法并不会触发onpopstate事件,因此咱们即使在onpopstate时执行了reroute方法,也要在这里执行下reroute方法。 const originalPushState = window.history.pushState; const originalReplaceState = window.history.replaceState; window.history.pushState = function (state, title, url) { let result = originalPushState.apply(this, arguments); reroute(mockPopStateEvent(state)); return result; }; window.history.replaceState = function (state, title, url) { let result = originalReplaceState.apply(this, arguments); reroute(mockPopStateEvent(state)); return result; }; // 再执行完load、mount、unmout操做后,执行此函数,就能够保证微前端的逻辑老是第一个执行。而后App中的Vue或React相关Router就能够收到Location的事件了。 export function callCapturedEvents(eventArgs) { if (!eventArgs) { return; } if (!Array.isArray(eventArgs)) { eventArgs = [eventArgs]; } let name = eventArgs[0].type; if (!HIJACK_EVENTS_NAME.test(name)) { return; } EVENTS_POOL[name].forEach(handler => handler.apply(window, eventArgs)); }
整个微前端框架的执行顺序和js事件循环类似,大致执行流程以下:
整个系统的触发时机分为两类:
registerApplication()
或start()
方法。每经过触发时机进行一次触发操做,都会被存放到changesQueue队列中,它就像事件循环的事件队列同样,静静地等待被处理。若是changesQueue为空,则中止循环直至下一次触发时机到来。
和js事件循环队列不一样的是,
changesQueue
是当前循环内的全部修改(changes)会绑成一批(batch)同时执行,而js事件循环是一个一个地执行。
在每一次循环的开始阶段,会先判断整个微前端的框架是否已经启动。
未启动:
根据规则(见上文的『判断须要被加载(load)的App』)加载须要被加载的app,加载完成以后调用内部的finish方法。
已启动:
根据规则获取当前由于不知足条件而须要被卸载(unmount)的app、须要被加载(load)的app以及须要被挂载(mount)的app,将load和mount的app先合并在一块儿进行去重,等unmout完成以后再统一进行mount。而后再等到mount执行完成以后就会调用内部的finish方法。
能够经过调用
mySingleSpa.start()
来启动微前端框架。
经过上文咱们能够发现不论是当前的微前端框架的状态是未启动
或已启动
,最终都会调用内部的finish方法。其实,finish方法的内部很简单,判断当前的changesQueue
是否为空,若是不为空则从新启动下一次循环,若是为空则终止终止循环,退出整个流程。
function finish() { // 获取成功mount的app let resolveValue = getMountedApps(); // pendings是上一次循环进行时存储的一批changesQueue的别名 // 其实就是下方调用invoke方法的backup变量 if (pendings) { pendings.forEach(item => item.success(resolveValue)); } // 标记循环已结束 loadAppsUnderway = false; // 发现changesQueue的长度不为0 if (pendingPromises.length) { const backup = pendingPromises; pendingPromises = []; // 将『修改队列』传入invoke方法,并开启下一次循环 return invoke(backup); } // changesQueue为空,终止循环,返回已mount的app return resolveValue; }
另外在每次循环终止时都会将已拦截的location事件进行触发,这样就能够保证上文说的微前端框架的location触发时机老是首先被执行,而Vue或React的Router老是在后面执行。
微前端框架仓库地址:https://github.com/YataoZhang...