由于nodejs是异步处理的,有时我们想同步从mysql里取出数据,最后在处理逻辑 就需要用到此扩展;
此扩展可以避免多层回调;
安装方法:
npm install async
使用方法:
1、parallel 多个函数并行执行
1 var Async = require(‘async‘); 2 3 Async.parallel( 4 [ 5 function(callback){ 6 // 此处查询数据库代码 7 DaoUser.getUserByID(userId, function(err, user) { 8 callback(err, user); 9 }); 10 }, 11 function(callback){ 12 // 此处查询数据库代码 13 DaoUser.getTotal(callback, function(err, count){ 14 callback(err, count); 15 }); 16 } 17 // 如果还需要查询数据 继续添加方法即可 18 ], 19 function(err, results){ 20 var user = results[0]; 21 var count = results[1]; 22 } 23 );
2、waterfall 多个方法依次执行,前一个函数的返回值可以传递给下一个函数
1 var Async = require(‘async‘); 2 3 Async.waterfall([ 4 function(callback) { 5 DaoUser.getUserIdByName(uName, function(err, userId) { 6 callback(null, userId); 7 }); 8 }, 9 function(userId, callback) { 10 DaoTask.getDateByUid(userId, function(err, tasks) { 11 callback(null, tasks); 12 }); 13 } 14 ], function(err, result) { 15 var tasks = result; 16 });
时间: 2024-10-26 14:01:07