Node.js 流

Stream 是一個抽象接口，Node 中有很多物件實作了這個接口。例如，對http 伺服器發起請求的request 物件就是一個 Stream，還有stdout（標準輸出）。

Node.js，Stream 有四種流類型：

#Readable - 可讀操作。
Writable - 可寫入動作。
Duplex - 可讀可寫入操作.
Transform - 操作被寫入數據，然後讀出結果。

所有的 Stream 物件都是 EventEmitter 的實例。常用的事件有：

data - 當有資料可讀時觸發。
end - 沒有更多的資料可讀時觸發。
error - 在接收和寫入過程中發生錯誤時觸發。
finish - 所有資料已寫入到底層系統時觸發。

本教學會為大家介紹常用的流程操作。

從流讀取資料

建立input.txt 文件，內容如下：

php中文网官网地址：www.php.cn

建立main.js 文件, 程式碼如下：

var fs = require("fs");
var data = '';

// 创建可读流
var readerStream = fs.createReadStream('input.txt');

// 设置编码为 utf8。
readerStream.setEncoding('UTF8');

// 处理流事件 --> data, end, and error
readerStream.on('data', function(chunk) {
   data += chunk;
});

readerStream.on('end',function(){
   console.log(data);
});

readerStream.on('error', function(err){
   console.log(err.stack);
});

console.log("程序执行完毕");

以上程式碼執行結果如下：

程序执行完毕
php中文网官网地址：www.php.cn

寫入流

建立main.js 檔案, 程式碼如下：

var fs = require("fs");
var data = 'php中文网官网地址：www.php.cn';

// 创建一个可以写入的流，写入到文件 output.txt 中
var writerStream = fs.createWriteStream('output.txt');

// 使用 utf8 编码写入数据
writerStream.write(data,'UTF8');

// 标记文件末尾
writerStream.end();

// 处理流事件 --> data, end, and error
writerStream.on('finish', function() {
    console.log("写入完成。");
});

writerStream.on('error', function(err){
   console.log(err.stack);
});

console.log("程序执行完毕");

以上程式會將data 變數的資料寫入到output.txt 檔案中。程式碼執行結果如下：

$ node main.js 
程序执行完毕
写入完成。

查看 output.txt 檔案的內容：

$ cat output.txt 
php中文网官网地址：www.php.cn

管道流

管道提供了一個輸出流到輸入流的機制。通常我們用於從一個流中獲取資料並將資料傳遞到另一個流。

如上面的圖片所示，我們把檔案比喻為裝水的桶，而水就是檔案裡的內容，我們用一根管子(pipe)連接兩個桶子使得水從一個桶子流入另一個桶，這樣就慢慢的實現了大文件的複製過程。

以下實例我們透過讀取一個檔案內容並將內容寫入到另一個檔案中。

設定input.txt 檔案內容如下：

php中文网官网地址：www.php.cn
管道流操作实例

建立main.js 檔案, 程式碼如下：

var fs = require("fs");

// 创建一个可读流
var readerStream = fs.createReadStream('input.txt');

// 创建一个可写流
var writerStream = fs.createWriteStream('output.txt');

// 管道读写操作
// 读取 input.txt 文件内容，并将内容写入到 output.txt 文件中
readerStream.pipe(writerStream);

console.log("程序执行完毕");

程式碼執行結果如下：

$ node main.js 
程序执行完毕

查看output.txt 檔案的內容：

$ cat output.txt 
php中文网官网地址：www.php.cn
管道流操作实例

鍊式流

鍊式是透過連接輸出流到另一個流並建立多個對個流操作鏈的機制。鍊式流一般用於管道操作。

接下來我們就是用管道和鍊式來壓縮和解壓縮檔案。

建立compress.js 檔案, 程式碼如下：

var fs = require("fs");
var zlib = require('zlib');

// 压缩 input.txt 文件为 input.txt.gz
fs.createReadStream('input.txt')
  .pipe(zlib.createGzip())
  .pipe(fs.createWriteStream('input.txt.gz'));
  
console.log("文件压缩完成。");

程式碼執行結果如下：

$ node compress.js 
文件压缩完成。

執行完以上操作後，我們可以看到目前目錄下產生了input .txt 的壓縮檔案input.txt.gz。

接下來，讓我們來解壓縮該文件，創建 decompress.js 文件，程式碼如下：

var fs = require("fs");
var zlib = require('zlib');

// 解压 input.txt.gz 文件为 input.txt
fs.createReadStream('input.txt.gz')
  .pipe(zlib.createGunzip())
  .pipe(fs.createWriteStream('input.txt'));
  
console.log("文件解压完成。");

程式碼執行結果如下：

$ node decompress.js 
文件解压完成。

Node.js 流

從流讀取資料

寫入流

管道流

鍊式流

PHP中文網