Latest web development tutorials

Node.jsの流れ（ストリーム）

ストリームが抽象インタフェースで、ノードは、多くのオブジェクトが、このインタフェースを実装しています。 例えば、httpリクエストオブジェクトに対する要求を開始したサーバーはストリームだけでなく、標準出力（標準出力）です。

Node.jsの、ストリームフローの4つのタイプがあります。

  • 読み取り可能-読み取り可能な操作。

  • 書き込み可能-書き込み操作。

  • デュプレックス-読み取りおよび書き込み操作を。

  • 変換-データを操作書き込まれ、結果を読み出すことができます。

すべてのオブジェクトが持つEventEmitterストリームのインスタンスです。 一般的なイベントは次のとおりです。

  • データ-データが時間を読み取るときにトリガ。

  • エンド-より読みやすいデータをトリガすることなく。

  • エラー-エラーが受信し、書き込み処理中に発生したときにトリガ。

  • 仕上げ-すべてのデータが基礎となるシステムに書き込まれたときに発生。

このチュートリアルでは、一般的なストリーム操作を紹介します。

ストリームからデータを読みます

次のように、INPUT.TXTファイルを作成します。 

本教程官网地址：www.w3big.com

次のように、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("程序执行完毕");

次のように上記のコードが実行されます。 

程序执行完毕
本教程官网地址：www.w3big.com

ストリームを書きます

次のように、main.jsファイルのファイルを作成します。 

var fs = require("fs");
var data = '本教程官网地址：www.w3big.com';

// 创建一个可以写入的流，写入到文件 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("程序执行完毕");

上記のプログラムデータは、変数データファイルoutput.txtとに書き込まれます。 次のようにコードの実行結果は以下のとおりです。 

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

ファイルの内容を表示OUTPUT.TXT： 

$ cat output.txt 
本教程官网地址：www.w3big.com

パイプラインの流れ

パイプラインは、出力フローの入力ストリームのためのメカニズムを提供します。 我々は、通常、データを取得し、ストリームから別のストリームにデータを転送するために使用されます。

上の写真に示すように、我々は水で満たされた文書のバケツを比較して、私たちは、配管（パイプ）と他のバケツにバケツの水の2つのバケットを接続するように水は、文書の内容ですゆっくり複製プロセスの大容量ファイルを実現しました。

次の例では、我々は、ファイルやコンテンツの内容を読み取ることにより、別のファイルに書き込みたいです。

次のようにINPUT.TXT設定文書が読み取ります。 

本教程官网地址：www.w3big.com
管道流操作实例

次のように、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 
本教程官网地址：www.w3big.com
管道流操作实例

チェーンの流れ

チェーンは別の流動する流れであり、出力を接続することにより、複数のストリーム操作機構のチェーンを作成します。 チェーン・ストリームは、一般に、パイプライン動作のために使用されます。

次に、圧縮したファイルを解凍するパイプとチェーンです。

次のように、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 
文件解压完成。