Node.js——Stream

介绍

  • 文件流:我们一般对大一点的文件实现stream的方式进行操作
  • http:显然http.createServer创建过程中的IncomingMessage实现了可读流的接口,ServerResponse实现了可写流的借口

文件流

  • 写入流的close事件,必须通过ws.end() 方法来调用
  • 文件的默认是flags是w,这是覆盖操作,追加的话是a
var fs = require(‘fs‘)

var rs = fs.createReadStream(‘./a.txt‘)

var ws = fs.createWriteStream(‘./hello.txt‘, {
    flags: ‘a‘
})

rs.once(‘open‘, function () {
    console.log(‘可读流打开了‘)
})

rs.once(‘close‘, function () {
    console.log(‘可读流关闭了‘)
    ws.end()
})

rs.on(‘data‘, function (data) {
    ws.write(data)
})

ws.once(‘open‘, function () {
    console.log(‘可写流打开了‘)
})

ws.once(‘close‘, function () {
    console.log(‘可写流关闭了‘)
})
  • 管道pipe对于流的操作更加方便,不需要在读流的过程中在写流
var fs = require(‘fs‘)

var rs = fs.createReadStream(‘./a.txt‘)

var ws = fs.createWriteStream(‘./hello.txt‘, {
    flags: ‘a‘
})

rs.once(‘open‘, function () {
    console.log(‘可读流打开了‘)
})

rs.once(‘close‘, function () {
    console.log(‘可读流关闭了‘)
    // ws.end()
})

// rs.on(‘data‘, function (data) {
//     ws.write(data)
// })

ws.once(‘open‘, function () {
    console.log(‘可写流打开了‘)
})

ws.once(‘close‘, function () {
    console.log(‘可写流关闭了‘)
})

rs.pipe(ws)

原文地址:https://www.cnblogs.com/wuqiuxue/p/9191956.html

时间: 2024-11-06 03:32:53

Node.js——Stream的相关文章

Node.js Stream(流)

Stream 是一个抽象接口,Node 中有很多对象实现了这个接口.例如,对http 服务器发起请求的request 对象就是一个 Stream,还有stdout(标准输出). Node.js,Stream 有四种流类型: Readable - 可读操作. Writable - 可写操作. Duplex - 可读可写操作. Transform - 操作被写入数据,然后读出结果. 所有的 Stream 对象都是 EventEmitter 的实例.常用的事件有: data - 当有数据可读时触发.

[Node.js]Stream

摘要 Stream是一个抽象接口,Node中有很多对象实现了这个接口.例如,对http服务器发送请求的request对象就是一个Stream. Stream Stream有四种流类型: Readable:可读操作. Writable:可写操作. Duplex:可读写操作. Transform:操作被写入数据,然后读出结果. 所有Stream对象都是EventEmitter的实例,常用的事件: data:当有数据可读时触发. end:没有更多的数据可读时触发. error:在接收和写入过程中发生错

node.js Stream Buffer FsPromise

Stream: 类似这样:a.pipe(b).pipe(c); 我想写一个b.所以: var rs=new (require('stream').Readable)(); var ws=new (require('stream').Writable)(); rs._read=function(){ this.push('send a msn for the first time'); this.push('send a msn for the second time'); this.push(n

Node.js Stream - 实战篇

邹斌 ·2016-07-22 11:04 背景 前面两篇(基础篇和进阶篇)主要介绍流的基本用法和原理,本篇从应用的角度,介绍如何使用管道进行程序设计,主要内容包括: 管道的概念 Browserify的管道设计 Gulp的管道设计 两种管道设计模式比较 实例 Pipeline 所谓“管道”,指的是通过a.pipe(b)的形式连接起来的多个Stream对象的组合. 假如现在有两个Transform:bold和red,分别可将文本流中某些关键字加粗和飘红.可以按下面的方式对文本同时加粗和飘红: //

Node.js 教程

Node.js 教程nodejs简单的说 Node.js 就是运行在服务端的 JavaScript.Node.js 是一个基于Chrome JavaScript 运行时建立的一个平台.Node.js是一个事件驱动I/O服务端JavaScript环境,基于Google的V8引擎,V8引擎执行Javascript的速度非常快,性能非常好.谁适合阅读本教程?如果你是一个前端程序员,你不懂得像PHP.Python或Ruby等动态编程语言,然后你想创建自己的服务,那么Node.js是一个非常好的选择.No

Node.js Stream-基础篇

Node.js Stream - 基础篇 邹斌 ·2016-07-08 11:51 背景 在构建较复杂的系统时,通常将其拆解为功能独立的若干部分.这些部分的接口遵循一定的规范,通过某种方式相连,以共同完成较复杂的任务.譬如,shell通过管道|连接各部分,其输入输出的规范是文本流. 在Node.js中,内置的Stream模块也实现了类似功能,各部分通过.pipe()连接. 鉴于目前国内系统性介绍Stream的文章较少,而越来越多的开源工具都使用了Stream,本系列文章将从以下几方面来介绍相关内

清晰地去看 Node.js(二)

比较缓冲器拷贝缓冲区 路由指的就是我们要针对不同的URL有不同的处理方式,例如处理/start的业务逻辑和处理/upload模块 的业务:逻辑就 是不一致的. Node.js 模块系统:http://www.shouce.ren/api/view/a/3470 代码区: /** * 比较缓冲器 * buf1.compare(buf2); */ var buffer1 = new Buffer('ABC'); var buffer2 = new Buffer('ABCD'); var result

Node.js 【Stream之笔记】

从Node.js API文档中可知, 'A stream is an abstract interface implemented by various objects in Node. For example a request to an HTTP server is a stream, as is stdout. Streams are readable, writable, or both. All streams are instances of EventEmitter.''流是很多

Node.js开发入门—Stream用法详解

Stream是Node.js中非常重要的一个模块,应用广泛.一个流是一个具备了可读.可写或既可读又可写能力的接口,通过这些接口,我们可以和磁盘文件.套接字.HTTP请求来交互,实现数据从一个地方流动到另一个地方的功能. 所有的流都实现了EventEmitter的接口,具备事件能力,通过发射事件来反馈流的状态.比如有错误发生时会发射"error"事件,有数据可被读取时发射"data"事件.这样我们就可以注册监听器来处理某个事件,达到我们的目的. Node.js定义了R