node.js基本模块学习(二) stream
2017-11-23 11:23
701 查看
stream是node.js提供的仅在服务端可用的模块,目的是支持流这种数据结构,不同于java的i/o,node.js
i/o是异步非阻塞i/o
在Node.js中,流也是一个对象,我们只需要响应流的事件就可以了,data事件表示流的数据已经可以读取了,end事件表示这个流已经到末尾了,没有数据可以读取了,error事件表示出错了。
var rs = fs.createReadStream('sample.txt', 'utf-8');
rs.on('data', function (chunk) {
console.log('DATA:')
console.log(chunk);
});
rs.on('end', function () {
console.log('END');
});
rs.on('error', function (err) {
console.log('ERROR: ' + err);
});
要注意,data事件可能会有多次,每次传递的chunk是流的一部分数据。
要以流的形式写入文件,只需要不断调用write()方法,最后以end()结束:
'use strict';
var fs = require('fs');
var ws1 = fs.createWriteStream('output1.txt', 'utf-8');
ws1.write('使用Stream写入文本数据...\n');
ws1.write('END.');
ws1.end();
var ws2 = fs.createWriteStream('output2.txt');
ws2.write(new Buffer('使用Stream写入二进制数据...\n', 'utf-8'));
ws2.write(new Buffer('END.', 'utf-8'));
ws2.end(); pipe流
就像可以把两个水管串成一个更长的水管一样,两个流也可以串起来。一个Readable流和一个Writable流串起来后,所有的数据自动从Readable流进入Writable流,这种操作叫pipe。
在Node.js中,Readable流有一个pipe()方法,就是用来干这件事的。
让我们用pipe()把一个文件流和另一个文件流串起来,这样源文件的所有数据就自动写入到目标文件里了,所以,这实际上是一个复制文件的程序:
'use strict';
var fs = require('fs');
var rs = fs.createReadStream('sample.txt');
var ws = fs.createWriteStream('copied.txt');
rs.pipe(ws);
当readable流的数据读取完毕,end事件触发,将自动关闭writeable流,如果不希望关闭writeable流
readable.pipe(writeable,{end:false});
i/o是异步非阻塞i/o
在Node.js中,流也是一个对象,我们只需要响应流的事件就可以了,data事件表示流的数据已经可以读取了,end事件表示这个流已经到末尾了,没有数据可以读取了,error事件表示出错了。
var rs = fs.createReadStream('sample.txt', 'utf-8');
rs.on('data', function (chunk) {
console.log('DATA:')
console.log(chunk);
});
rs.on('end', function () {
console.log('END');
});
rs.on('error', function (err) {
console.log('ERROR: ' + err);
});
要注意,data事件可能会有多次,每次传递的chunk是流的一部分数据。
要以流的形式写入文件,只需要不断调用write()方法,最后以end()结束:
'use strict';
var fs = require('fs');
var ws1 = fs.createWriteStream('output1.txt', 'utf-8');
ws1.write('使用Stream写入文本数据...\n');
ws1.write('END.');
ws1.end();
var ws2 = fs.createWriteStream('output2.txt');
ws2.write(new Buffer('使用Stream写入二进制数据...\n', 'utf-8'));
ws2.write(new Buffer('END.', 'utf-8'));
ws2.end(); pipe流
就像可以把两个水管串成一个更长的水管一样,两个流也可以串起来。一个Readable流和一个Writable流串起来后,所有的数据自动从Readable流进入Writable流,这种操作叫pipe。
在Node.js中,Readable流有一个pipe()方法,就是用来干这件事的。
让我们用pipe()把一个文件流和另一个文件流串起来,这样源文件的所有数据就自动写入到目标文件里了,所以,这实际上是一个复制文件的程序:
'use strict';
var fs = require('fs');
var rs = fs.createReadStream('sample.txt');
var ws = fs.createWriteStream('copied.txt');
rs.pipe(ws);
当readable流的数据读取完毕,end事件触发,将自动关闭writeable流,如果不希望关闭writeable流
readable.pipe(writeable,{end:false});
相关文章推荐
- Node.js的基本模块学习(一)
- Node.js的基本模块学习(三)
- node.js基本模块学习(一) fs模块
- node.js之基本流处理模块stream
- Node.js基本模块stream
- Node.js学习——基本模块之fs
- Node.js基本模块学习(二)
- node.js学习(三)简单的node程序&&模块简单使用&&commonJS规范&&深入理解模块原理
- node.js入门学习之url模块
- Node.js基本模块http
- node.js认识学习二:__dirname获取当前模块文件所在目录的完整绝对路径
- NODE.JS学习笔记——CRYPTO 加密模块
- 浅析Node.js的Stream模块中的Readable对象
- Node.js学习笔记3【核心模块--event】
- node.js 学习笔记二:创建属于自己的模块
- Node.js中DNS模块学习总结
- Node.js学习笔记4【核心模块--fs】
- Node.js学习第二天 Node.js模块系统
- Node.js stream 流学习
- node.js之流学习(Stream)