1、导言
在 javascript 的世界里,异步(由于javascript的单线程运行,所以javascript中的异步是可以阻塞的)无处不在。
express 是 node 环境中非常流行的web服务端框架,有很大比例的 node web应用 采用了 express。
当使用 javascript 编写服务端代码时,我们无可避免的会大量使用到异步。随着 javascript、node 的进化,我们的异步处理方式,也就随之进化。
接下来,我们就来看看 express 中异步处理的进化过程。
2、javascript的异步处理
在异步的世界里,我们需要想办法获取的异步方法完毕的通知,那在 javascript 中,会有哪些方式呢?
2.1、回调
回调是 js 中最原始,也是最古老的异步通知机制。
function asyncfn(callback) { // 利用settimeout模拟异步 settimeout(function () { console.log('执行完毕'); callback(); // 发通知 }, 2000); } asyncfn(function () { console.log('我会在2s后输出'); });
2.2、事件监听
要获取结果的函数,监听某个时间。在异步方法完成后,触发该事件,达到通知的效果。
2.3、发布/订阅
通过观察者模式,在异步完成时,修改发布者。这个时候,发布者会把变更通知到订阅者。
2.4、promise
promise 是回调函数的改进。使用它, 我们可以将异步平行化,避免回调地狱。
function asyncfn() { return new promise((resolve, reject) => { // 利用settimeout模拟异步 settimeout(function () { console.log('执行完毕'); resolve(); // 发通知(是否有感觉到回调的影子?) }, 2000); }); } asyncfn() .then(function () { console.log('我会在2s后输出'); });
2.5、生成器(generator)
generator 函数是 es6 提供的一种异步编程解决方案。
以下代码只是简单演示,实际上 generator 的使用过程,相对是比较复杂的,这是另外一个话题,本文暂且不表。
function asyncfn() { return new promise((resolve, reject) => { // 利用settimeout模拟异步 settimeout(function () { console.log('执行完毕'); resolve(); // 发通知(是否有感觉到回调的影子?) }, 2000); }); } function* generatorsync() { var result = yield asyncfn(); } var g = generatorsync(); g.next().value.then(()=>{ console.log('我会在2s后输出'); });
2.6、async...await
可以说是当前 javascript 中,处理异步的最佳方案。
function asyncfn() { return new promise((resolve, reject) => { // 利用settimeout模拟异步 settimeout(function () { console.log('执行完毕'); resolve(); // 发通知(是否有感觉到回调的影子?) }, 2000); }); } async function run(){ await asyncfn(); console.log('我会在2s后输出'); } run();
3、express中的异步处理
在express中,我们一般常用的是方案是:回调函数、promise、以及async...await。
为了搭建演示环境,通过 express-generator 初始化一个express项目。一般的服务端项目,都是路由调用业务逻辑。所以,我们也遵循这个原则:
打开 routs/index.js,我们会看到如下内容,以下demo就以此文件来做演示。
var express = require('express'); var router = express.router(); /* get home page. */ router.get('/', function(req, res, next) { res.render('index', { title: 'express' }); }); module.exports = router;
3.1、回调函数处理express异步逻辑
在 express 中,路由可以加载多个中间件,所以我们可以把业务逻辑按照中间件的写法进行编写。这样通过一层层的next,就能非常方便的拆分异步逻辑。
var express = require('express'); var router = express.router(); function asyncfn(req, res, next) { settimeout(() => { req.user = {}; // 设置当前请求的用户 next(); }, 2000); } function asyncfn2(req, res, next) { settimeout(() => { req.auth = {}; // 设置用户权限 next(); }, 2000); } function asyncfn3(req, res, next) { settimeout(() => { res.locals = { title: 'express async test' }; // 设置数据 res.render('index'); // 响应 }, 2000); } /* get home page. */ router.get('/', asyncfn, asyncfn2, asyncfn3); // 一步步执行中间件 module.exports = router;
3.2、promise 处理express异步逻辑
该方案中,将多个业务逻辑,包装为返回 promise 的函数。通过业务方法进行组合调用,以达到一进一出的效果。
var express = require('express'); var router = express.router(); function asyncfn(req, res) { return new promise((resolve, reject) => { settimeout(() => { req.user = {}; // 设置当前请求的用户 resolve(req); }, 2000); }); } function asyncfn2(req) { return new promise((resolve, reject) => { settimeout(() => { req.auth = {}; // 设置用户权限 resolve(); }, 2000); }); } function asyncfn3(res) { return new promise((resolve, reject) => { settimeout(() => { res.locals = { title: 'express async test' }; // 设置数据 res.render('index'); // 响应 }, 2000); }); } function dobizasync(req, res, next) { asyncfn(req) .then(() => asyncfn2(req)) .then(() => asyncfn3(res)) .catch(next); // 统一异常处理 }; /* get home page. */ router.get('/', dobizasync); module.exports = router;
3.3、async...await 处理express异步逻辑
实际上,该方案也是需要 promise 的支持,只是写法上,更直观,错误处理也更直接。
需要注意的是,express是早期的方案,没有对async...await进行全局错误处理,所以可以采用包装方式,进行处理。
var express = require('express'); var router = express.router(); function asyncfn(req) { return new promise((resolve, reject) => { settimeout(() => { req.user = {}; // 设置当前请求的用户 resolve(req); }, 2000); }); } function asyncfn2(req) { return new promise((resolve, reject) => { settimeout(() => { req.auth = {}; // 设置用户权限 resolve(); }, 2000); }); } function asyncfn3(res) { return new promise((resolve, reject) => { settimeout(() => { }, 2000); }); } async function dobizasync(req, res, next) { var result = await asyncfn(req); var result2 = await asyncfn2(req); res.locals = { title: 'express async test' }; // 设置数据 res.render('index'); // 响应 }; const tools = { asyncwrap(fn) { return (req, res, next) => { fn(req, res, next).catch(next); // async...await在express中的错误处理 } } }; /* get home page. */ router.get('/', tools.asyncwrap(dobizasync)); // 需要用工具方法包裹一下 module.exports = router;
4、总结
虽然 koa 对更新、更好的用法(koa是generator,koa2原生async)支持的更好。但作为从 node 0.x 开始跟的我,对 express 还是有特殊的好感。
以上的一些方案,已经与 koa 中使用无异,配合 express 庞大的生态圈,无异于如虎添翼。
本文github地址
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持移动技术网。
如对本文有疑问, 点击进行留言回复!!
egg项目npm/cnpm出错Connect timeout
网友评论