如何等待node.js中所有回调的单个函数的结果？

Question

可能是问题的标题不恰当的，但我可以解释什么，我想在我的代码做

//一个回调函数

connection_db.query(get_measure_query,function(err,user_data1){ 
     if(err){ 
      // throw err; 
      let response_data = status_codes.db_error_0001; 
      console.log(response_data); 
      res.end('error'); 
     }else { 

    } 

    }); 

//第二个回调函数

connection_db.query(get_measure_query,function(err,user_data2){ 
     if(err){ 
      // throw err; 
      let response_data = status_codes.db_error_0001; 
      console.log(response_data); 
      res.end(enc); 
     }else { 
     res.end('error'); 
    } 
    }); 

//第3回调功能

connection_db.query(get_measure_query,function(err,user_data3){ 
     if(err){ 
      // throw err; 
      let response_data = status_codes.db_error_0001; 
      console.log(response_data); 
      res.end('error'); 
     }else { 

    } 
    }); 

现在我需要所有数据user_data1，user_data2和user_data3。我怎样才能得到这个在一个单一的功能

function allData(){ 
// This should wait for all the callbacks and then execute 

} 

我希望我能够理解我的问题。请让我知道如果som eone不理解它 提前，感谢帮助家伙！

Answer 1

// 1. use Promise Promise.all() 
 
// https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise/all 
 

 

 
// 2. or gruff 
 
function handleAll(data) { 
 
    if(!handleAll.all) { 
 
    handleAll.all = [] 
 
    } 
 
    handleAll.all.push(data) 
 
    if(handleAll.all.length >= 3) { 
 
    //do something with handleAll.all [data1, data2, data3 ..] 
 

 

 
    handleAll.all = null 
 
    } 
 
} 
 
// invoke it in all the callback function 
 
connection_db.query(get_measure_query,function(err,user_data1){ 
 
    if(err){ 
 
    // throw err; 
 
    let response_data = status_codes.db_error_0001; 
 
    console.log(response_data); 
 
    res.end('error'); 
 
    }else { 
 
    handleAll(user_data1) 
 
    } 
 
});

Answer 2

我做了粗略，但你可以使用回调以获取在allData功能的所有数据。我认为下面的内容应该适合你，而不适应更新版本的代码。

function runALL(allData) { 
 
    connection_db.query(get_measure_query, function(err, user_data1) { 
 
     if (err) { 
 
      // throw err; 
 
      let response_data = status_codes.db_error_0001; 
 
      console.log(response_data); 
 
      res.end('error'); 
 
     } 
 
     else { 
 
      connection_db.query(get_measure_query, function(err, user_data2) { 
 
       if (err) { 
 
        // throw err; 
 
        let response_data = status_codes.db_error_0001; 
 
        console.log(response_data); 
 
        res.end(enc); 
 
       } 
 
       else { 
 
        connection_db.query(get_measure_query, function(err, user_data3) { 
 
         if (err) { 
 
          // throw err; 
 
          let response_data = status_codes.db_error_0001; 
 
          console.log(response_data); 
 
          res.end('error'); 
 
         } 
 
         else { 
 
          allData(user_data1, user_data2, user_data3) 
 
         } 
 
        }); 
 
       } 
 
      }); 
 
     } 
 

 
    }); 
 
} 
 
    
 
function allData((user_data1, user_data2, user_data3) { 
 
    // use user_data1, user_data2, user_data3 
 
}) 
 
    
 
runAll(allData)