nodejs Async 使用方法(解決多層回調嵌套)

由於nodejs是異步處理的，有時我們想同步從mysql里取出數據，最后在處理邏輯 就需要用到此擴展；

此擴展可以避免多層回調；

安裝方法:

npm install async

使用方法：

1、parallel 多個函數並行執行 

 

var Async = require('async');

Async.parallel(
    [
        function(callback){
            // 此處查詢數據庫代碼
            DaoUser.getUserByID(userId, function(err, user) {
                callback(err, user);
            });
        },
        function(callback){
            // 此處查詢數據庫代碼
            DaoUser.getTotal(callback, function(err, count){
                callback(err, count);
            });
        }
        // 如果還需要查詢數據 繼續添加方法即可
    ],
    function(err, results){
        var user = results[0];
        var count = results[1];
    }
);

 

2、waterfall 多個方法依次執行，前一個函數的返回值可以傳遞給下一個函數

var Async = require('async');

Async.waterfall([
    function(callback) {
        DaoUser.getUserIdByName(uName, function(err, userId) {
            callback(null, userId);
        });
    },
    function(userId, callback) {
        DaoTask.getDateByUid(userId, function(err, tasks) {
            callback(null, tasks);
        });
    }
], function(err, result) {
    var tasks = result;
});

 3、map 遍歷數組的值，執行結果傳給最后的callback

var Async = require('async');


var array = [1,2,3,4];
Async.map(array,
    function(data, callback) {
        data ++;
        callback(null, data);
    },
    function(err, results) {
        console.log(results);
    }
);
// 結果 [ 2, 3, 4, 5 ]