async/await與promise(nodejs中的異步操作問題)


 

 

此文只是粗略介紹使用方法,欲了解核心概念請參考官方文檔或其他資料。

舉例寫文章詳情頁面的時候的一個場景:首先更改文章詳情中的 PV,然后讀取文章詳情,然后根據文章詳情中文章 Id 查閱該文章評論和該文章作者信息。獲取全部數據之后渲染文章詳情頁。數據庫操作都是異步的,最直接想到的辦法就是一層一層的回調函數,問題出來了:十分不雅觀,要是層再多一點還會有更多麻煩。怎么解決?業內為了處理異步操作問題也是拼了,什么async,q,bluebird,co,處理方式不同,各有千秋,感興趣可以了解一下,但是驚喜的發現nodejs 7.6已經默認支持ES7中的 async/await 了,結合ES6中的 promise對象,用起來不亦樂乎的。

Async/await的主要益處是可以避免回調地獄(callback hell),且以最接近同步代碼的方式編寫異步代碼。

  1. 基本概念: 
  • promise 對象有三種狀態:成功(Fulfilled)失敗(Rejected)等待(Pending)
  • promise 不配合 async await 時,使用 .then() .catch() 處理成功和失敗情況是目前的常規方案。
  • async 表示這是一個async函數,await只能用在這個函數里面。async 對象也是一個 promise 對象。
  • await 表示在這里等待promise返回結果了,再繼續執行。
  • await 后面跟着的應該是一個promise對象(當然,其他返回值也沒關系,不過那樣就沒有意義了…)
  • 很多庫的接口返回 promise 對象,await 后賦值給一個變量后使用其 resolve 的值。[例如](http://mongoosejs.com/docs/api.html#query_Query-exec)
  • 注意三點,promise 對象的狀態,promise 對象上的方法(then,catch),promise 對象返回的值。
  • promise 是當時為了解決回調地獄的解決方案,也是當前處理異步操作最流行和廣泛使用的方案,async 和 await 最為當前的終極方案兩只之間還有一些過渡方案。
  1. 舉例:
  • 獲取返回值:
復制代碼

var sleep = function (time) {
return new Promise(function (resolve, reject) {
setTimeout(function () {
// 返回 ‘ok’
resolve('ok');
}, time);
})
};
var start = async function () {
let result = await sleep(3000);
console.log(result); // 收到 ‘ok’
};

復制代碼

 

  • 捕捉錯誤:
復制代碼
 
           

var sleep = function (time) {
return new Promise(function (resolve, reject) {
setTimeout(function () {
// 模擬出錯了,返回 ‘error’
reject('error');
}, time);
})
};
var start = async function () {
try {
console.log('start');
await sleep(3000); // 這里得到了一個返回錯誤

// 所以以下代碼不會被執行了
console.log('end');
} catch (err) {
console.log(err); // 這里捕捉到錯誤 `error`
}
};

const search = async () => {
const project = await Project.findById(id)
Project.belongsToMany(User, { through: 'UserProject' })
const users = await project.getUsers()
Project.hasMany(Task)
const task = await project.getTasks()
return { project, users, task }
}
search().then(data => res.json(data)).catch((err) => {
console.log(err)
res.send({ name: err.name, msg: err.message })
})



復制代碼

 

  • 在循環中:
復制代碼

var start = async function () {
for (var i = 1; i <= 10; i++) {
console.log(`當前是第${i}次等待..`);
await sleep(1000);
}
};

復制代碼

 

再循環中使用不需要閉包,每次循環會被阻塞。

  • 遇到可同時執行的異步操作:
復制代碼

let [foo, bar] = await Promise.all([getFoo(), getBar()]);
Promise.all() // 全部完成時返回
Promise.race() // 任意一個完成時返回
// 比下面按順序執行會節省一些時間
let foo = await getFoo();
let bar = await getBar();

復制代碼

 

最前面提到的場景:(綜合使用)

復制代碼

var showArticle = async function () {

await new Promise(function (resolve, reject) {

PostModel.incPv(postId, function (result) {

resolve(result);

});

});// pv 加 1

var post = await new Promise(function (resolve, reject) {

PostModel.getPostById(postId, function (article) {

resolve(article);

});

});// 獲取文章信息

await new Promise(function (resolve, reject) {

userModel.getUserById(post.author,function (author) {

post.author=author;

resolve();

})

});//獲取文章作者

var comments = await new Promise(function (resolve, reject) {

CommentModel.getComments(post._id, function (comment) {

resolve(comment);

});

});// 獲取該文章所有留言

for(var i=0;i<comments.length;i++){

await new Promise(function (resolve, reject) {

userModel.getUserById(comments[i].author,function (author) {

comments[i].author=author;

resolve();

})

});//獲取文章留言作者

}

if (!post) {

req.session.error = '該文章不存在';

return res.redirect('/post');

}

res.render('post',{post: post, comments: comments});

};

 

showArticle();

復制代碼

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM