node模块async

Posted 2020-11-01 灰犀

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了node模块async相关的知识，希望对你有一定的参考价值。

async模块是为了解决异步回调大坑而存在的,尤其是在用了mysql模块的时候,简直要命啊,

虽然现在又es6的

Promise Generator Async(es7)

但是对于还不怎么用es6的人,简直是神器.

npm 安装好async模块,

然后引入就可以使用 var async = require(‘async‘);

他有几种模式

1.waterfall(tasks,[callback]) :瀑布流,个人用最多,最重要的一个

依次执行,前一个函数的输出为后一个函数的输入

如果中途出现错误,后面的函数将不在执行,之前执行的结果和错误信息将直接传到最终的回调函数

const express =require(‘express‘);
const bodyParser =   require(‘body-parser‘);
const mysql = require(‘mysql‘);
const async =require(‘async‘);

const db = mysql.createPool({host:‘localhost‘,user:‘root‘,password:‘123456‘,database:‘test‘});

var server = express();
server.listen(8090);
server.use(bodyParser.urlencoded({extended: false}));
server.use(bodyParser.json());

server.post(‘/‘,(req,res)=>{
   

    var qingqiu = function(callback){
        db.query(`SELECT * FROM user_table WHERE user_ID= "${req.body.user_ID}"`,(err,data)=>{
            if(err){
                console.log(err);
                res.status(500).send(‘database error‘).end();
            }
            else{

                callback(null, data);    //callback(错误信息,传递的数据)

            }

        })
    }
    
    //q为接收的数据
    var qingqiu2 = function(q,callback){
        console.log(q[0].user_ID);
        db.query(`SELECT count FROM user_table WHERE user_ID= "${q[0].user_ID}"`,(err,data)=>{
            if(err){
                console.log(err);
                res.status(500).send(‘database error‘).end();
            }
            else{
                console.log(data);
                callback(null, data[0]);
            }

        })
    }
    
    //执行
    async.waterfall([qingqiu,qingqiu2],function(err,result){
        if (err) {
            console.log(err);
        }
    })


});

2. series(tasks,[callback])

多个函数从上到下依次执行,相互之间没有数据交互,

如果中途发生错误,则将错误传递到回调函数,并停止执行后面的函数

3.parallel(tasks,[callback])

多个函数并行执行,不会等待其他函数

如果中途出错,则立即将err和值传到最终的回调函数,其他未执行完毕的函数将不再执行,但是要占一个位置

4.parallelLimit(tasks,limit,[callback])

和parallel类似,只是limit参数限制了同时并发执行的个数,不再是无限并发

5.auto(tasks,[callback])

多个函数有数据交互,有的并行,有的依次执行

6.whilst(test,fn,[callback])

相当于while循环,fn函数里不管是同步还是异步都会执行完上一次循环才会执行下一次循环,对异步循环很有帮助,