9.promise(异步编程)

9.1回调地狱：

由于异步性，程序并不会等待之前一个响应结束。也即下面的这样一个代码，对三个文件的读取顺序并没有保证，可能有时abc的顺序，有时cba。。

var fs =require('fs')fs.readFile('./a.txt',function(err,data){if (err){throw err}console.log(data)
})fs.readFile('./b.txt',function(err,data){if (err){throw err}console.log(data)
})fs.readFile('./C.txt',function(err,data){if (err){throw err}console.log(data)
})

若一定要保证顺序执行，则代码需要把下一个执行的代码放到上一个的回调函数里，也就是需要改成这样：

var fs =require('fs')fs.readFile('./a.txt',function(err,data){if (err){throw err}console.log(data)fs.readFile('./b.txt',function(err,data){if (err){throw err}console.log(data)fs.readFile('./C.txt',function(err,data){if (err){throw err}console.log(data)})})
})

如此再嵌套下去将出现很麻烦的地狱。无限套娃

9.2promise

在EcmaScript6新增了一个API Promise，是一个构造函数。

基本语法

var fs = require('fs')
//创建promise 容器
//promise不是异步的，但内部往往封装一个异步
//容器一旦创建，立即开始执行里面的代码
//resolve和reject也是两个回调函数
var p1 = new Promise(function(resolve,reject){fs.readFile('./Cx.txt',function(err,data){if (err){//失败了，即承诺容器中的任务失败了reject(err)}else{//承诺容器中的任务成功resolve(data)}})
})//p1即那个承诺
//then方法接受的第一个function就是promise中的resolve函数，
//第二个就是promise中的reje函数
//两个参数都是可选的
p1.then(function(data){console.log('right',data)
},function(err){console.log('wrong',err)
})

具有严格前后顺序（封装好的）廖雪峰的官方网站上有详细描述

// 返回input*input的计算结果:
function multiply(input) {return new Promise(function (resolve, reject) {log('calculating ' + input + ' x ' + input + '...');resolve(input * input)});
}//返回input+input的计算结果:
function add(input) {return new Promise(function (resolve, reject) {log('calculating ' + input + ' + ' + input + '...');resolve(input + input)});
}var p = new Promise(function (resolve, reject) {log('start new Promise...');resolve(123);
});
//then的方法就作为前一个的resolve
p.then(multiply).then(add).then(multiply).then(add).then(function (result) {log('Got value: ' + result);
});

文件顺序读取：（未封装）

var fs = require('fs')
var p1 = new Promise(function(resolve,reject){fs.readFile('./a.txt',function(err,data){if (err){reject(err)}else{resolve(data)}})
})var p2 = new Promise(function(resolve,reject){fs.readFile('./b.txt',function(err,data){if (err){reject(err)}else{resolve(data)}})
})var p3 = new Promise(function(resolve,reject){fs.readFile('./c.txt',function(err,data){if (err){reject(err)}else{resolve(data)}})
})p1.then(function(data){console.log('right ',data)//此时return的函数将在then的下一个function中作为参数传进去//即若return 123，后面then(function(data))中console.log(data)出来就是123//但是如果return一个容器，则.then(function(data))，中的function将作为该容器的resolve函数return p2
})
.then(function(data){console.log('right ',data)return p3
})
.then(function(data){console.log('right ',data)
})

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-CWqO8rm1-1583498166014)(C:\Users\U2016\AppData\Roaming\Typora\typora-user-images\image-20200306133127018.png)]

mongoose所有的API支持Promise

var mongoose = require('mongoose')
var Schema = mongoose.Schema
mongoose.connect('mongodb://localhost:27017/test', {useNewUrlParser: true,useUnifiedTopology: true })
var db = mongoose.connection
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function() {console.log('we are connected!') 
})
//设计架构
var UserSchema = new mongoose.Schema({name: {//限制为 string，必须项type : String,required : true},password:{type : String,required : true}
})var user = mongoose.model('User', UserSchema)
//查询name='cwd1'的数据
user.findOne({ name:'cwd7' })
.then(function(ret){if (ret){console.log('已有用户，不能注册')console.log(ret)}else{return new user({ name: 'cwd6', passwod : '123456789'}).save()}
})
.catch(function(){console.log('failed')
})