nodejs Stream 동작

흐름 에서 데이터 읽 기
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("      ");

이상 코드 실행 결 과 는 다음 과 같 습 니 다.

        hello world

기록 흐름
main. js 파일 을 만 듭 니 다. 코드 는 다음 과 같 습 니 다.

var fs = require("fs"); var data = 'www.baidu.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("      ");

이 프로그램 은 data 변수의 데 이 터 를 output. txt 파일 에 기록 합 니 다.코드 실행 결 과 는 다음 과 같 습 니 다.

$ node main.js            。

pipe    

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("      ");


          

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("      。");

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("      。");