Node可寫的流可用於輸出數據到底層

如何想使用一個流介面I/O輸出數據。那麼用繼承stream.Writable並且實現一個_write方法向底層源數據發送數據來解決。許多第三方模塊提供網路服務和資料庫流介面。跟隨這一趨勢是有利的，因為它允許你的類使用管道的API，這有助於保持碼塊的復用和解耦。你可能會只是希望簡單實現一個可寫流作為管道鏈，或者實現不支持的I/O資源。在一般情況下，所有你需要做的是正確地從繼承stream.Writable——更多的推薦使用的方式，然後添加一個_write方法。所有的_write方法需要做的就是當數據被寫入時調用提供的回調。下面的代碼顯示方法的參數和樣本_write的實現

chunk參數是Buffer的一個實例或者是一個字元串。customWriteOperation是你的類中自定義的寫操作。它可以是非同步的，這樣的話回調會在過後安全地調用。如果發生了錯誤，要調用Node內部代碼提供的回調。一個_write方法提供了一個回調，你可以在寫完成時調用。這允許_write是非同步的。在這裡customWriteOperation方法被簡單地使用——在真正實現時，將執行基本I/O。這可能涉及通過套接字訪問資料庫，或寫入文件。提供給回調的第一個參數應該是一個錯誤，允許在需要時_write傳遞錯誤。

節點的stream.Writable基類並不需要知道數據如何寫，它只需要關心操作是成功還是失敗。錯誤可以通過傳遞一個錯誤的對象回調報告調用者。這將導致錯誤的事件被觸發。請記住這些數據流的基類，所以你通常應該添加一個監聽器捕獲錯誤並優雅地處理錯誤。接下來的例子顯示完整地實現了stream.Writable類

使用通常的繼承模式來創建一個新的可寫流類。使用ANSI編碼序列來給數據塊添加綠色文本的標識。當文本已經被發送到標準輸出流時執行回調。使用管道從輸入到輸出來把文本轉換位綠色文本。這個簡短的示例將輸入的文本顏色變為綠色。它可以通過node writable.js來運行，或將文本通過管道來使用，如cat file.txt|node writable.js。編碼參數只有當被用來代替緩衝區字元串時才會生效。字元串可以通過設置decodeStrings為false來使用，在實例化可寫流時傳遞。流並不總是處理緩衝區對象，因為一些實現了優化處理字元串，因此在某些情況下直接處理字元串可以更有效。

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！