多個POST請求的異步問題

Question

我使用功能_getLogFileUrls，它執行POST請求並將數據返回給回調函數。返回的數據正被添加到數組中。

函數_getLogFileUrls在一個循環中被調用。

如何在所有請求完成後返回結果數組？

我明白setTimeout是這種方法的錯誤方式，我寫代碼的方式是創建一個回調地獄。我如何擺脫setTimeout函數而不涉及各種異步問題。

// app.post('/api/getLogs', auth, loggingAPI.getLogs); // Make API request 

function getLogs(req, res) { 
    if (! req.body.id) { 
     return res.status(500).send('Please check the params!'); 
    } 

    var date; 

    if (req.body.date) { 
     date = req.body.date; 
    } else { 
     date = new Date().toISOString().slice(0,10); 
    } 

    var sqlQuery = "SELECT `LogFileID` FROM `logs_data` WHERE `EmpID` = '" + req.body.id + "' AND DATE(`Timestamp`) = '" + date + "'", 
     resArray= []; 

    hitThisQueryForMe(sqlQuery, res, function(rows) { 
     if (! rows.length) res.json(rows); 

     _.each(rows, function(item) { 
      console.log('item: ' + item.LogFileID); 
      _getLogFileUrls(item.LogFileID, function(response) { 
       resArray.push(response); 
      }); 
     }); 

     setTimeout(function() { 
      console.log('final urls: ' + JSON.stringify(resArray)); 
      res.send(resArray); 
      resArray = []; 
     }, 4000); 

    }); 
} 

function _getLogFileUrls(logFileId, callback) { 
    var request = require('request'), 
    config = require('../../config.js');  

    var fileParams = { 
     fileName: 'LogFiles/' + logFileId  
    }; 

    request.post({ 
     url: config.filesServiceUrl + 'get-logfile-urls', 
     json: fileParams 
    }, function(error, response, body) { 
     if (!error && response.statusCode === 200) { 
      callback(body); 
     } else { 
      console.log('err requesting logs: ' + JSON.stringify(error)); 
      res.status(400).send('Err requesting logs:'); 
     } 
    }).on('error', function(err) { 
     console.log('File service error for Logs: ' + err); 
    }); 
} 

Answer 1

使用async.eachOf遍歷陣列，並且每個元素上應用的異步功能：

async.eachOf(myArray, function(myElementInArray, it, callback){ 

    // call async function on element 
    myAsyncFunction(myElementInArray, function(err){ 
     if(err) 
     return callback(err); // abort async flow 
     else 
     return callback(); 
    }); 

}, function(err){ 
    // final callback called when the flow is finished 

}); 

////編輯

異步模塊文檔：https://caolan.github.io/async/docs.html

換一個代碼：

 _.each(rows, function(item){    
      console.log('item: ' + item.LogFileID); 
      _getLogFileUrls(item.LogFileID, function(response){ 
       resArray.push(response);    
      });   
     }); 

     setTimeout(function(){ 
      console.log('final urls: ' + JSON.stringify(resArray)); 
      res.send(resArray); 
      resArray = []; 
     }, 4000); 

隨着

var async = require("async"); 
var resArray = []; 
async.eachOf(rows, function(item, it, callback){ 

    console.log('item: ' + item.LogFileID); 
    // call async function on element 
    _getLogFileUrls(item.LogFileID, function(response){ 
     resArray.push(response); 
     return callback(); 
    }); 

}, function(err){ 
    // final callback called when the flow is finished 
    console.log('final urls: ' + JSON.stringify(resArray)); 
    res.send(resArray); 
});