在非阻塞IO下的nodejs下的同步并行 ES6的 promise 从入门深入(二)

in 编程
关注公众号【好便宜】( ID:haopianyi222 ),领红包啦~
阿里云,国内最大的云服务商,注册就送数千元优惠券:https://t.cn/AiQe5A0g
腾讯云,良心云,价格优惠: https://t.cn/AieHwwKl
搬瓦工,CN2 GIA 优质线路,搭梯子、海外建站推荐: https://t.cn/AieHwfX9

看过 (一)的同学一定觉得这个Promise很简单,好像没什么可以用的地方,但是事实上,它的用处非常大啊,尤其是在nodejs上,愈加重要,虽然已经有大量的库实现了对Promise的封装了,不过我还是更倾向用原生的node来实现对Promise的实现。
现在我们要用的重点就是我们的Promise.all,这是一个能让函数并行的promise,可以基于多个Promise。我们讲介绍下简单的应用和在复杂的环境下的一些使用方法.

两个demo函数
function demo1(){
    return Promise.resolve(1);
}
function demo2(){
    return Promise.resolve(2);
}
function demo3(){
    return Promise.all([demo1(),demo2()]);
}

demo3().then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})

基于以上的代码,你将得到一个数组,获得[1,2],其原理很简单,就是让两个函数同时开始异步操作,就是并行拉,然后返回的数据存放在一个数组,并且是按顺序的!!!而且注意,在Promise.all中,如果其中一个操作获得了reject或是error,那么我们都将得到一个reject,并且,这两个操作的最终时长是取决于两者中最长的那个,直到两个都完成了才能返回结果。非常有用啊!!

先上一个错误的代码

function demo1(){
    return Promise.resolve(1);
}
function demo2(){
    return Promise.reject(2);
}
function demo3(){
    return Promise.all([demo1(),demo2()]);
}

demo3().then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})


这时候我们得到的就是数字2了,而不是一个数组,这就是神奇所在。
再最后一个例子就是Promise.race 这个简单介绍以下就好了,因为这个不常用,想想也知道你说你要执行两个操作,只要完成其中一个就返回其中一个的结果,除非是赛跑,不然这个东西有什么意义,比较难想象有能运用的地方,我写了这么就的Promise就是没用遇到过了!下面是例子

function demo1(){
    return Promise.resolve(1);
}
function demo2(){
    return Promise.resolve(2);
}
function demo3(){
    return Promise.race([demo1(),demo2()]);
}

demo3().then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})


我们得到的结果将会是1或2,跟前面的reject一样,如果其中之一来reject,或是异常,一定会被catch捕获!这是毋庸置疑的,但前提是在两个之一都没有完成的情况下才能被捕获,所以是十分困难的。


运用以上的所有内容就基本能解决我们在项目中的大部分问题了,但是偶尔我们会遇到比较难的问题,下面拿我使用mongodb时候遇到的问题来讲解。大家可以忽略这些细节,更关注用法!

问题1 是:我要同时查10笔操作,可是我们该如何操作

    
    
  
 //这是10笔要查的数据集合
    var array = [1,2,3,4,5,6,7,8,9,10];
    //这里大家使用自己的数据库进行案例
    var model = mongoose.model('demo');
    Promise.all([array.map(i=>{
        return new Promise((resolve,reject)=>{
            resolve(demo(i))
        })
    })]).then(result=>{
        //获得十笔查询后的记录
        console.log(result);
    })
    
    
    function demo(name){
        return model.find({name:name}).exec();
    }

问题2:我该如何使用混合同步并发执行先查询图片名字,然后记录下来并且删除这些图片

//模拟查询图片
function queryImgs(){
    return new Promise((resolve,reject)=>{
    //返回查询结果
        resolve(1);
    })
}
//模拟删除图片
function deleteImg(imgs){
    return new Promise((resolve,reject)=>{
            resolve(1);
        })
}
//模拟记录图片
function recordImg(imgs){
    return new Promise((resolve,reject)=>{
            resolve(1);
        })
}

function delAndRecord(imgs){
    return Promise.all([deleteImgs(imgs),recordImgs(imgs)]);
}

queryImgs().then(delAndRecord).then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})

当然,我们这边的deleteImgs和recordImgs都会继续划分,因为我们这里是并发的删除,我们是用方法就是用问题一来解决这些所有的东西!

以上就是两章内容,过几天上第三章内容,基本上就解决所有可能遇到的问题了!以上这些方法足以解决上百同时的并发查询!我指单个请求中包含的!

关注公众号【好便宜】( ID:haopianyi222 ),领红包啦~
阿里云,国内最大的云服务商,注册就送数千元优惠券:https://t.cn/AiQe5A0g
腾讯云,良心云,价格优惠: https://t.cn/AieHwwKl
搬瓦工,CN2 GIA 优质线路,搭梯子、海外建站推荐: https://t.cn/AieHwfX9
扫一扫关注公众号添加购物返利助手,领红包
Comments are closed.

推荐使用阿里云服务器

超多优惠券

服务器最低一折,一年不到100!

朕已阅去看看