本篇文章给大家详细介绍一下Node.js中的异步。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。
关于 Node.js 异步,绕不开两点:非阻塞 I/O 和事件循环。也正是因为这两点,Node.js 才能被称为高性能并运用到线上环境中,那么下面来了解一下 Node.js 的异步机制和使用方式吧!【推荐学习:《nodejs 教程》】
Input
/Output
,一个系统的输入和输出。以点菜吃饭为例子:去饭堂点菜吃饭需要排队等待,在这个过程中,阿姨每次只能接待一个人,“点菜-阿姨抖勺装菜-把饭菜给到你”这个过程中阿姨并不能接收其他人的点菜,这个就是阻塞 I/O;而去餐馆点菜吃饭,去到餐馆就可以跟服务员你要吃番茄炒蛋,服务员记下来之后交给后厨,这时候来了另一桌人就把服务员招呼过去说想吃小龙虾,也就是说,在把菜给你上上来之前服务员接收了其他人的点菜,那这个就是非阻塞型 I/O。
理解非阻塞 I/O 的要点在于
Input
/Output
的系统。那在点菜吃饭这个例子中,一个进行 Input
/Output
的系统就是点餐-后厨(阿姨)处理-上菜这样一个能让你吃上饭的系统;点餐就是 Input
,上菜就是 Output
,在这个例子中判断两者是非阻塞型还是阻塞型的关键就在于在点菜上菜这个过程中能不能接受其它的点菜上菜。就好比你点了个佛跳墙,等上菜可能就要好久了,然后来的人都是点一些简单的菜品,一分钟炒一份炒粉的那种,可能就是来来回回几波人之后都还没能给你上菜。
而 Node.js 它是用来操纵计算机的,一些如读取文件之类的操作是非常耗时的,要是不能进行其它的 I/O,那么处理效率就很会很低了,这也是 Node.js 是非阻塞型 I/O 的一个原因。
Node.js 启动的时候会初始化由 libuv 提供的事件循环,每次的事件循环都包含6个阶段,这6个阶段会在每一次的事件循环当中按照下图当中的顺序反复执行,如下图:
timers
阶段:这个阶段执行 timer
(setTimeout
、setInterval
)的回调callbacks
阶段 :处理一些上一轮循环中的少数未执行的 I/O 回调idle
,prepare
阶段 :仅 Node 内部使用poll
阶段 :获取新的 I/O 事件, 适当的条件下 Node 将阻塞在这里check
阶段 :执行 setImmediate()
的回调close callbacks
阶段:执行 socket
的 close
事件回调每个阶段都有一个先入先出的(FIFO)的用于执行回调的队列,事件循环运行到每个阶段,都会从对应的回调队列中取出回调函数去执行,直到队列当中的内容耗尽,或者执行的回调数量达到了最大。
然后事件循环就会进入下一个阶段,然后又从下一个阶段对应的队列中取出回调函数执行,这样反复直到事件循环的最后一个阶段。而事件循环也会一个一个按照循环执行,直到进程结束。
事件循环当中的6个宏队列和微队列的关系如下:微队列(microtask
)在事件循环的各个阶段之间执行,或者说在事件循环的各个阶段对应的宏队列(macrotask
)之间执行。
这里有一个特别容易混淆的版本改变:
setTimeout
,setInterval
和 setImmediate
三者其中之一,不包括I/O)就立刻执行微任务队列,执行完微队列当中的所有微任务再回到刚才的宏队列执行下一个宏任务。这就跟浏览器端运行一致了。callback
error-first callback
node-style callback
error
,后面的参数才是结果。// 第一个参数是错误捕获 interview(function (err, res) { if (err) { console.log('cry') return; } console.log('smile') }) function interview(callback) { setTimeout(() => { if (Math.random() > 0.2) { callback(null, 'success') } else { callback(new Error('fail')) } }, 500) }
异步流程控制:回调地狱、异步并发等问题
npm
:async.js
;可以通过 async.js
来控制异步流程thunk
:一种编程方式Promise
Promise
是承诺的意思;当前事件循环得不到的结果,但未来的事件循环会给到你结果resolved
或 rejected
就不会改变pending
:初始状态,还没得到结果的状态fulfilled
/ resolved
:成功状态rejected
:失败状态链式调用:.then
和 .catch
resolved
状态的 Promise
会回调后面的第一个 .then
rejected
状态的 Promise
会回调后面的第一个 .catch
rejected
状态且后面没有 .catch
的 Promise
,都会造成浏览器/ Node 环境的全局错误// promise的状态转换以及通过then获取内容 const promise = new Promise((resolve, reject) => { setTimeout(function () { resolve(3); // reject(new Error(4)) }, 500) }) promise.then(function (result) { console.log(result) }).catch(function (err) { console.log(err) }) setTimeout(() => { console.log(promise) }, 800)
执行 then
和 catch
会返回一个新 Promise
,该 Promise
最终状态根据 then
和 catch
的回调函数的执行结果决定
throw
,该 Promise
是 rejected
状态return
,该 Promise
是 resolved
状态return
了一个 Promise
,该 Promise
会和回调函数 return
的 Promise
状态保持一致async
/await
async function
是 Promise
的语法糖封装await
关键字可以“暂停” async function
的执行await
关键字可以以同步的写法获取 Promise
的执行结果try-catch
可以获取 await
所得到的错误(async function () { await findJob() console.log('trip') })() async function findJob() { try { // 进行三轮面试 await interview(1); await interview(2); await interview(3); console.log('smile') } catch (e) { console.log('cry at ' + e.round) } } // 进行第round轮面试 function interview(round) { return new Promise((resolve, reject) => { setTimeout(() => { if (Math.random() < 0.2) { const error = new Error('failed'); error.round = round; reject(error); } else { resolve('success'); } }, 500) }) }
这是一个穿越事件循环存在的 function
。
error
,后面的才是结果。Promise
是一个状态机,初始状态为 pending
,一旦确定状态为 resolved
或 rejected
就不会改变,可以通过 .then
和 .catch
进行链式调用。async
/await
以同步的方式写异步,是异步编程的终极解决方案。更多编程相关知识,请访问:编程视频!!
Atas ialah kandungan terperinci 深入浅析Node.js中的异步. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!