首頁  >  文章  >  web前端  >  深入淺析Node.js中的異步

深入淺析Node.js中的異步

青灯夜游
青灯夜游轉載
2021-06-08 10:39:472438瀏覽

本篇文章給大家詳細介紹一下Node.js中的非同步。有一定的參考價值,有需要的朋友可以參考一下,希望對大家有幫助。

深入淺析Node.js中的異步

關於Node.js 異步,繞不開兩點:非阻塞I/O事件循環。也正是因為這兩點,Node.js 才能被稱為高效能並運用到線上環境中,那麼下面來了解一下 Node.js 的非同步機制和使用方式吧! 【推薦學習:《nodejs 教學》】

Node.js 的非阻塞I/O

  • I/O 即Input/Output,一個系統的輸入和輸出
  • 阻塞 I/O 和非阻塞 I/O 的差別就在於系統接收輸入再到輸出期間,能不能接收其他輸入

以點菜吃飯為例子:去飯堂點菜吃飯需要排隊等待,在這個過程中,阿姨每次只能接待一個人,“點菜-阿姨抖勺裝菜-把飯菜給到你」這個過程中阿姨並不能接收其他人的點菜,這個就是阻塞I/O;而去餐館點菜吃飯,去到餐館就可以跟服務員你要吃番茄炒蛋,服務生記下來之後交給後廚,這時候來了另一桌人就把服務員招呼過去說想吃小龍蝦,也就是說,在把菜給你上上來之前服務員接收了其他人的點菜,那這個就是非阻塞型I/O。

理解非阻塞I/O 的要點在於

  • 確定一個進行Input/Output 的系統
  • 思考在 I/O 過程中,能不能進行其他 I/O

那在點菜吃飯這個例子中,一個進行Input/Output 的系統就是點餐-後廚(阿姨)處理-上菜這樣能讓你吃上飯的系統;點餐就是Input,上菜就是Output,在這個例子中判斷兩者是非阻塞型還是阻塞型的關鍵就在於在點菜上菜這個過程中能不能接受其它的點菜上菜。就好比你點了個佛跳牆,等上菜可能就要好久了,然後來的人都是點一些簡單的菜品,一分鐘炒一份炒粉的那種,可能就是來來回回幾波人之後都還沒能給你上菜。

而Node.js 它是用來操縱電腦的,一些如讀取檔案之類的操作是非常耗時的,如果不能進行其它的I/O,那麼處理效率就很會很低了,這也是Node.js 是非阻塞型I/O 的原因。

Node.js 的事件循環

Node.js 啟動的時候會初始化由libuv 提供的事件循環,每次的事件循環都包含6個階段,這6個階段會在每一次的事件循環當中按照下圖當中的順序反覆執行,如下圖:

深入淺析Node.js中的異步

  • timers 階段:這個階段執行timersetTimeoutsetInterval)的回呼
  • I/O callbacks 階段:處理一些上一輪迴圈中的少數未執行的I/O 回呼
  • idleprepare 階段:僅Node 內部使用
  • poll 階段:取得新的I/O 事件, 適當的條件下Node 將阻塞在這裡
  • check 階段:執行setImmediate( ) 的回呼
  • close callbacks 階段:執行socketclose 事件回呼

#每個階段都有一個先入先出的(FIFO)的用於執行回調的隊列,事件循環運行到每個階段,都會從對應的回調隊列中取出回調函數去執行,直到隊列當中的內容耗盡,或執行的回調數量達到了最大

然後事件循環就會進入下一個階段,然後從下一個階段對應的佇列中取出回調函數執行,這樣反覆直到事件循環的最後一個階段。而事件循環也會一個一個依照循環執行,直到行程結束。

事件循環當中的6個巨集佇列和微佇列的關係如下:微佇列(microtask)在事件循環的各個階段之間執行,或是在事件循環的各個階段對應的巨集佇列(macrotask)之間執行。

深入淺析Node.js中的異步

這裡有一個特別容易混淆的版本改變:

  • 如果是Node10 及其先前版本:巨集佇列當中的有幾個巨集任務,是要等到巨集佇列當中的所有巨集任務全部執行完畢才會去執行微佇列當中的微任務
  • 如果是Node11 及之後版本:一旦執行一個階段裡對應宏隊列當中的一個宏任務(setTimeoutsetIntervalsetImmediate 三者其中之一,不包括I/O)就立刻執行微任務隊列,執行完微隊列當中的所有微任務再回到剛才的宏隊列執行下一個宏任務。這就跟瀏覽器端運行一致了。

Node.js 非同步程式設計- 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)
    }
非同步流程控制:回呼地獄、非同步並發等問題

  • npmasync.js;可以通過async.js 來控制非同步流程
  • thunk:一種程式設計方式

Node.js 非同步程式設計– Promise

    可以透過字面意思來理解,
  • Promise 是承諾的意思;當前事件循環得不到的結果,但未來的事件循環會給你結果
  • 它是一個狀態機,狀態一旦確定為
  • resolvedrejected 就不會改變
    • pending :初始狀態,還沒得到結果的狀態
    • fulfilled / resolved:成功狀態
    • rejected :失敗狀態
鍊式呼叫:

.then.catch

    # #resolved
  • 狀態的Promise 會回呼後面的第一個.then
  • rejected
  • 狀態的Promise 會回呼後面的第一個.catch任何一個
  • rejected
  • 狀態且後面沒有.catchPromise,都會造成瀏覽器/ 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 最終狀態根據thencatch 的回呼函數的執行結果決定

如果回呼函數最終是
    throw
  • ,該Promiserejected 狀態如果回呼函數最終是
  • return
  • ,該Promiseresolved 狀態但如果回呼函數最終
  • return
  • 了一個Promise ,該Promise 會和回呼函數returnPromise 狀態保持一致
Node.js 非同步程式設計–

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(&#39;failed&#39;);
              error.round = round;
              reject(error);
            } else {
              resolve(&#39;success&#39;);
            }
          }, 500)
        })
      }
    這是一個穿越事件循環存在的
  • function

總結

理解非阻塞I/O 主要在於

確定一個進行I/O 的系統,然後思考判斷能不能進行其它I /O
  • Node.js 的事件循環
  • 在 Node11 版本及之後是和瀏覽器的事件循環運行一致的,要注意區分。
  • Node.js 非同步程式設計的規範是第一個參數是 error
  • ,後面的才是結果。
  • Promise
  • 是一個
  • 狀態機,初始狀態為pending,一旦確定狀態為resolved rejected 就不會改變,可以透過.then.catch 進行鍊式呼叫。 async
  • /
  • await 以同步的方式寫非同步,是非同步程式設計的終極解決方案。 更多程式相關知識,請造訪:
  • 程式設計影片
! !

以上是深入淺析Node.js中的異步的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:juejin.cn。如有侵權,請聯絡admin@php.cn刪除