Node中流的概念

来源:https://www.cnblogs.com/yinhaiying/archive/2019/04/28/10784880.html
-Advertisement-
Play Games

在學習node的過程中,對於流的概念一直不是很理解,通過查閱一些資料,現在將自己對流的一些理解進行總結一下。 一.流的理解 首先我們必須知道什麼是流,很多書中只是提到使用流讀寫文件怎麼怎麼方便,卻不提流到底是什麼?在說流之前我們先說一下 流數據 : 流數據:就是位元組數據, 在應用程式中各種對象之間交 ...


在學習node的過程中,對於流的概念一直不是很理解,通過查閱一些資料,現在將自己對流的一些理解進行總結一下。

一.流的理解

首先我們必須知道什麼是流,很多書中只是提到使用流讀寫文件怎麼怎麼方便,卻不提流到底是什麼?在說流之前我們先說一下流數據
流數據:就是位元組數據,在應用程式中各種對象之間交換與傳輸數據的時候,總是先將該對象中所包含的數據轉化為位元組數據也就是流數據。再通過流的傳輸,到達目的對象後,再將流數據轉化為該對象中可以使用的數據。
從上面可知,流就是用來傳輸流數據的,它是一種傳輸手段
流:在一個應用程式中,流是一組有序的,有起點和終點的位元組數據(流數據)的傳輸手段

二.能夠使用流的對象

從流的概念中我們可以知道流是用來傳輸流數據的,也就是說我們需要把其他的對象數據轉化為流數據。
在Node中,使用了各種實現了stream.Readable介面的對象讀取流。也就是說只有這些對象才能夠讀取流
Node.js中可以讀取數據流的對象,列表如下:

對象 描述
fs.ReadStream 用於讀取文件
http.IncomingMesage 代表客戶端請求或服務端響應
net.Socket 代表一個socket埠對象
child.stdout 用於創建子進程的標準輸出流
child.stderr 用於創建子進程的標準錯誤輸出流
process.stdin 用於創建進程的標準輸入流
Gzip 用於實現數據壓縮

上面這些讀取數據的對象將會觸發的事件

事件名 描述
readable 當可以從流中讀取數據時觸發
data 當讀取到來自文件,客戶端,伺服器端等對象的新的數據時觸發
end 代表一個socket埠對象
child.stdout 當讀取完所有的事件時觸發,該事件的觸發意味著data事件將不再被觸發
err 當讀取數據的過程中產生錯誤時觸發
close 當用於讀取數據的對象被關閉時觸發,並非所有用於讀取流數據的對象都會觸發該事件

上面這些讀取數據的對象所擁有的方法
在對象讀取流的過程中,對象還擁有一些方法,可以對流進行一些操作,比如指定編碼,指定流的傳輸目的地等。列表如下:

方法名 描述
read 用於讀取數據
setEncoding 用於指定用什麼編碼方式讀取數據
pause 用於通知對象停止觸發data事件
resume 用於通知對象恢復觸發data事件
pipe 用於設置一個數據通道,然後取出所有流數據並將其輸出到通道另一端所指向的目標對象中
unpipe 用於取消pipe設置的通道

接下來使用fs模塊中的createReadStream方法創建一個將文件讀取為流數據的ReadStream對象,介紹一下流數據的讀取。示例代碼如下:

const fs = require('fs');

let file = fs.createReadStream('./data.txt');
// console.log(file);  //得到的是一個ReadStream對象
//對象在讀取文件時,需要先打開文件,打開文件會觸發open事件
file.on('open',function(fd){
  console.log('開始讀取文件');
  // console.log(fd);
});
//對象觸發data事件,讀取數據
file.on('data',function(data){
  console.log('讀取到數據');
  console.log(data.toString());
});
//讀取文件完畢,觸發end事件
file.on('end',function(){
  console.log('文件讀取完畢');
});
//關閉文件,觸發close事件
file.on('close',function(){
  console.log('關閉文件')
});
file.on('error',function(err){
  console.log(err)
});

上面介紹了Node.js中用於讀取流的對象,以及在讀取過程中,對象可能觸發的事件以及調用的方法。下麵介紹Node.js中用於寫入流的對象,以及在寫入過程中,這些對象可能觸發的事件和調用的方法。

在Node.js中,使用各種實現了stream.Writable介面的對象來將流數據寫入到對象中,所有這些對象都是繼承了EventEmitter類的實例,在寫入數據的過程中,將可能觸發各種事件

各種用於寫入流數據的對象,如下表所示:

對象 描述
fs.WriteStream 用於寫入文件
http.ClientRequest 用於寫入http客戶端請求數據
http.ServerResponse 用於寫入http服務端響應數據
net.Socket 代表一個socket埠對象
child.stdin 用於創建子進程的標準輸入流
process.stderr 用於創建進程的標準錯誤輸出流
process.stdout 用於創建進程的標準輸出流
Gunzip 用於解壓數據

這些對象將有可能觸發的事件如下表所示:

事件名 描述
drain 當用於寫入數據的write方法返回false之後觸發
finish 當end方法被調用且數據被全部寫入操作系統緩存區時觸發
pipe 當用於讀取數據的pipe方法被調用時觸發
unpipe 當用於讀取數據的pipe方法被調用時觸發
error 當寫入數據的過程中產生錯誤時觸發

這些對象在寫入數據的過程中,所擁有的方法如下表所示:

方法名 描述
write 用於寫入有數據
end 當沒有數據再被寫入流中時調用該方法,這將迫使操作系統緩存區中的剩餘

使用fs模塊的createWriteStream方法創建一個將流數據寫入文件的WriteStream對象。

const fs = require('fs');
let file = fs.createWriteStream('./result.txt');
file.write('hello Node.js',function(){
  console.log('寫入文件')
})

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 一、rem佈局基本原理 原理:rem可以理解為一個長度單位,單位rem的值等於網頁font-size的值。如果網頁的字體大小為預設值16px,那麼1rem就等於16px,0.5rem等於8px。 根據這個原理,如果網頁預設的字體大小改變,那麼單位rem的大小也會改變,我們使用rem做單位的HTML元 ...
  • 近期由於業務的需求,讓我這從未想過要碰Web Gis的業餘前端開發者,走了Web Gis的開發道路。功能需求很簡單,但卻也是讓自己難為了好幾天。如,應該選擇那個Gis框架,Gis框架的相容性如何,直接Ie哪些版,能不能簡單到只有一張圖片就行解決問題,等等。。。。。。 在如此多的技術盲點,以及不確定的 ...
  • this一般運用場景: 1.位於函數中,誰調用指向誰 var make = "Mclaren"; var model = "720s" function fullName() { console.log(this.make + " " + this.model); } var car = { mak ...
  • 因為IT互聯網發展的非常迅速,而web前端這塊很火,目前工資水平給的很高,在市場上也是非常的稀缺人才,現在各個行業轉行做web前端的很多,今天給大家一些建議,希望新手少走點彎路吧! 建議一:有一個比較適合自己系統的學習方案,系統的學習教程,很多人在開始學習web前端的時候都不知道如何規劃,也不知道w ...
  • Node.js安裝和簡單使用 1. 安裝方法 簡單的安裝方式是直接官網下載,然後本地安裝即可。官網地址:nodejs.org Windows系統下,選擇和系統版本匹配的.msi尾碼的安裝文件。Mac OS X系統下,選擇.pkg尾碼的安裝文件。 2. 測試是否安裝成功 打開終端,鍵入命令 ,如果進入 ...
  • FullCalendar Timeline View(v4) The Scheduler add-on provides a new view called “timeline view” with a customizable horizontal time-axis and resources ...
  • canvas實現畫板 主要用到知識點: 滑鼠事件onmousedown() onmousemove() onmouseup() onmouseleave() 事件委托 canvas的一些方法 如:繪製線條moveTo() lineTo() stroke() 撤銷功能getImageData() pu ...
  • 微信分享時 分享鏈接攜帶參數可能不是固定的 需要在分享的前一刻才知道 這裡就是動態設置分享鏈接的基本寫法 代碼不是那麼詳盡 但大致流程如下 1.安裝引用jssdk 2.通過config介面註入配置信息 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...