Node.js 教程

Node.js中的streams基于事件。

所有这些stream类都继承自基本抽象Stream类,它继承自EventEmitter。

var stream = require("stream"); 
var EventEmitter = require("events").EventEmitter; 

console.log(new stream.Stream() instanceof EventEmitter); // true 
console.log(new stream.Readable({}) instanceof stream.Stream); // true 
console.log(new stream.Writable({}) instanceof stream.Stream); // true 
console.log(new stream.Duplex({}) instanceof stream.Stream); // true 
console.log(new stream.Transform({}) instanceof stream.Stream); // true

上面的代码生成以下结果。

管道

所有流都支持使用管道成员函数可以完成的管道操作。

此函数称为管道,因为它模拟命令行管道操作符的行为,例如cat file.txt | grep yourtest

fs 核心模块提供了用于从文件创建可读或可写流的实用程序函数。

以下代码显示如何将文件从文件系统流式传输到用户控制台。

var fs = require("fs"); 
// Create readable stream 
var readableStream = fs.createReadStream("./a.js"); 
// Pipe it to stdout 
readableStream.pipe(process.stdout);

你还可以使用pipe链接多个stream。

以下代码从文件创建可读取流,通过zip变换流管道,然后将其管道到可写文件流。

这将在文件系统上创建一个zip文件。

var fs = require("fs"); 
var gzip = require("zlib").createGzip(); 

var inp = fs.createReadStream("a.js"); 
var out = fs.createWriteStream("a.js.gz"); 

// Pipe chain 
inp.pipe(gzip).pipe(out);

Node.js中的steams基于事件。

新闻动态 联系方式 广告合作 招聘英才 安科实验室 帮助与反馈 About Us

Copyright © 2013 - 2019 Ancii.com All Rights Reserved京ICP备18063983号-5 京公网安备11010802014868号