此文只是粗略介紹使用方法,欲了解核心概念請參考官方文檔或其他資料。
舉例寫文章詳情頁面的時候的一個場景:首先更改文章詳情中的 PV,然后讀取文章詳情,然后根據文章詳情中文章 Id 查閱該文章評論和該文章作者信息。獲取全部數據之后渲染文章詳情頁。數據庫操作都是異步的,最直接想到的辦法就是一層一層的回調函數,問題出來了:十分不雅觀,要是層再多一點還會有更多麻煩。怎么解決?業內為了處理異步操作問題也是拼了,什么async,q,bluebird,co,處理方式不同,各有千秋,感興趣可以了解一下,但是驚喜的發現nodejs 7.6已經默認支持ES7中的 async/await 了,結合ES6中的 promise對象,用起來不亦樂乎的。
Async/await的主要益處是可以避免回調地獄(callback hell),且以最接近同步代碼的方式編寫異步代碼。
- 基本概念:
- 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 最為當前的終極方案兩只之間還有一些過渡方案。
- 舉例:
- 獲取返回值:
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();