Node中流的概念

时间: 2019-04-29阅读: 1024标签: node

一.流的理解

首先我们必须知道什么是流,很多书中只是提到使用流读写文件怎么怎么方便,却不提流到底是什么?在说流之前我们先说一下数据
数据:就是字节数据,在应用程序中各种对象之间交换与传输数据的时候,总是先将该对象中所包含的数据转化为字节数据也就是流数据。再通过流的传输,到达目的对象后,再将流数据转化为该对象中可以使用的数据。
从上面可知,流就是用来传输流数据的,它是一种传输手段
流:在一个应用程序中,流是一组有序的,有起点和终点的字节数据(流数据)的传输手段


二.能够使用流的对象

从流的概念中我们可以知道流是用来传输流数据的,也就是说我们需要把其他的对象数据转化为流数据。
在Node中,使用了各种实现了stream.Readable接口的对象读取流。也就是说只有这些对象才能够读取流
Node.js中可以读取数据流的对象,列表如下:

对象描述
fs.ReadStream用于读取文件
http.IncomingMesage代表客户端请求或服务端响应
net.Socket代表一个socket端口对象
child.stdout用于创建子进程的标准输出流
child.stderr用于创建子进程的标准错误输出流
process.stdin用于创建进程的标准输入流
Gzip用于实现数据压缩

上面这些读取数据的对象将会触发的事件

事件名描述
readable当可以从流中读取数据时触发
data当读取到来自文件,客户端,服务器端等对象的新的数据时触发
end代表一个socket端口对象
child.stdout当读取完所有的事件时触发,该事件的触发意味着data事件将不再被触发
err当读取数据的过程中产生错误时触发
close当用于读取数据的对象被关闭时触发,并非所有用于读取流数据的对象都会触发该事件

上面这些读取数据的对象所拥有的方法
在对象读取流的过程中,对象还拥有一些方法,可以对流进行一些操作,比如指定编码,指定流的传输目的地等。列表如下:

方法名描述
read用于读取数据
setEncoding用于指定用什么编码方式读取数据
pause用于通知对象停止触发data事件
resume用于通知对象恢复触发data事件
pipe用于设置一个数据通道,然后取出所有流数据并将其输出到通道另一端所指向的目标对象中
unpipe用于取消pipe设置的通道

接下来使用fs模块中的createReadStream方法创建一个将文件读取为流数据的ReadStream对象,介绍一下流数据的读取。示例代码如下:

const fs = require('fs');

let file = fs.createReadStream('./data.txt');
// console.log(file);  //得到的是一个ReadStream对象
//对象在读取文件时,需要先打开文件,打开文件会触发open事件
file.on('open',function(fd){
  console.log('开始读取文件');
  // console.log(fd);
});
//对象触发data事件,读取数据
file.on('data',function(data){
  console.log('读取到数据');
  console.log(data.toString());
});
//读取文件完毕,触发end事件
file.on('end',function(){
  console.log('文件读取完毕');
});
//关闭文件,触发close事件
file.on('close',function(){
  console.log('关闭文件')
});
file.on('error',function(err){
  console.log(err)
});

上面介绍了Node.js中用于读取流的对象,以及在读取过程中,对象可能触发的事件以及调用的方法。下面介绍Node.js中用于写入流的对象,以及在写入过程中,这些对象可能触发的事件和调用的方法。

在Node.js中,使用各种实现了stream.Writable接口的对象来将流数据写入到对象中,所有这些对象都是继承了EventEmitter类的实例,在写入数据的过程中,将可能触发各种事件

各种用于写入流数据的对象,如下表所示:

对象描述
fs.WriteStream用于写入文件
http.ClientRequest用于写入http客户端请求数据
http.ServerResponse用于写入http服务端响应数据
net.Socket代表一个socket端口对象
child.stdin用于创建子进程的标准输入流
process.stderr用于创建进程的标准错误输出流
process.stdout用于创建进程的标准输出流
Gunzip用于解压数据

这些对象将有可能触发的事件如下表所示:

事件名描述
drain当用于写入数据的write方法返回false之后触发
finish当end方法被调用且数据被全部写入操作系统缓存区时触发
pipe当用于读取数据的pipe方法被调用时触发
unpipe当用于读取数据的pipe方法被调用时触发
error当写入数据的过程中产生错误时触发

这些对象在写入数据的过程中,所拥有的方法如下表所示:

方法名描述
write用于写入有数据
end当没有数据再被写入流中时调用该方法,这将迫使操作系统缓存区中的剩余

使用fs模块的createWriteStream方法创建一个将流数据写入文件的WriteStream对象。

const fs = require('fs');
let file = fs.createWriteStream('./result.txt');
file.write('hello Node.js',function(){
  console.log('写入文件')
})
站长推荐

1.云服务推荐: 国内主流云服务商,各类云产品的最新活动,优惠券领取。地址:阿里云腾讯云华为云

链接: http://www.fly63.com/article/detial/3112

理解 nodeJS 中的 buffer,stream

在Node.js开发中,当遇到 buffer,stream,和二进制数据处理时,你是否像我一样,总是感到困惑?这种感觉是否会让你认为不了解它们,以为它们不适合你,认为而这些是Node.js作者们的事情?

node.js+express 做301重定向实验

目前百度无法承诺 301 跳转的生效时间,因为站长感受到的生效时间会受多因素影响,比如 Baiduspider 再次抓取这个页面发现其设置了 301 的时间、网页的重要程度以及自身质量等。

nodejs适合做什么?

面对一个新技术,多问几个为什么总是好的。既然 PHP、Python、Java 都可以用来进行后端开发,那么为什么还要去学习 Node.js?Node.js适合做什么?Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境,一个让 JavaScript 运行在服务端的开发平台。

把你的NodeJS程序给没有NodeJS的人运行

众所周知,NodeJS程序开发简便且容易实现跨平台。但是,当你开发了一个NodeJS程序,想要分发给其他人运行的时候,你会发现,你往往需要对方也来安装一个NodeJS环境

happypack提升项目构建速度

运行在 Node.js 之上的 Webpack 是单线程模型的,也就是说 Webpack 需要处理的任务需要一件件挨着做,不能多个事情一起做。happypack把任务分解给多个子进程去并发的执行,子进程处理完后再把结果发送给主进程。

如何创建高性能、可扩展的Node.js应用?

在这篇文章中,我们将介绍关于开发 Node.js web 应用程序的一些最佳实践,重点关注效率和性能,以便用更少的资源获得最佳结果。提高 web 应用程序吞吐量的一种方法是对其进行扩展,多次实例化其以平衡在多个实例之间的传入连接

我怎样用Node.js自动完成工作的

我们在工作中经常会进行很多繁琐的任务:更新配置文件,复制和粘贴文件,更新 Jira 标签等。慢慢的花在这些任务上的时间会越来越多。reskin 的定义是使用相同的游戏机制,屏幕和元素的定位

Node.js创建服务器和模拟客户端请求

服务器是某种长期运行,等待请求资源的应用程序,Web服务器是使用HTTP协议,等待客户端连接后请求资源的驻守应用程序;HTTP协议是应用层的协议,在传输层依然是使用TCP或者UDP协议

Node.js 处理 CORS

CORS 是“跨域资源共享”的简写。它是一种允许或限制向 Web 服务器上请求资源的机制,具体取决于进行 HTTP 请求的位置。

怎么彻底删除nodejs?

Node.js 是一个基于Chrome JavaScript 运行时建立的一个平台。Node.js是一个事件驱动I/O服务端JavaScript环境,基于Google的V8引擎,V8引擎执行Javascript的速度非常快,性能非常好。

点击更多...

内容以共享、参考、研究为目的,不存在任何商业目的。其版权属原作者所有,如有侵权或违规,请与小编联系!情况属实本人将予以删除!