Node.js-Node核心模块-stream

╰+哭是因爲堅強的太久メ 2022-05-13 13:26 202阅读 0赞

7. Stream

Node.js提供了多种流对象，例如：HTTP请求和process.stdout都是流的实例。

流可以是可读、可写或可读写的，所有的流都是EventEmitter的实例。

1.  流的类型
    
     *  Readable  ---可读的流（例如：fs.createReadStream()）
     *  Writeable  --可写的流（例如：fs.createWriteStream()）
     *  Duplex  ---可读可写流（例如：net.Socket）
     *  Transform  --可读写过程中可以修改和变换数据的Duplex流（例如：zlib.createDeflate()）
2.  可读流

可读流的实例

Http responses,on the client

HTTP requirests,on the server

Fs read stream

......

可写流事件

Data

Readonly

End

Close

Error

const stream = require('stream');
    const fs = require('fs');
    //创建文件可读流
    const rs = fs.createReadStream('./data.txt');
    rs.on('close', () => {
        console.log('close');
    });
    rs.on('data', () => {
        console.log('data');
    });
    rs.on('error', () => {
        console.log('error')
    })
    rs.on('readable', () => {
        console.log('readable');
    })
    rs.on('end', () => {
        console.log('end');
    });

3. 可写流

可写流的实例

Http responses,on the client

HTTP requirests,on the server

Fs write streams

......

可写流实例

Close

Drain

Error

Finsh

Pipe  --管道

Unpipe

const stream = require('stream');
    const fs = require('fs');
    const ws = fs.createWriteStream('./a.txt');
    ws.on('pipe', () => {
        console.log('pipe');
    });
    ws.on('finish', () => {
        console.log('finish');
    })
    ws.on('close', () => {
        console.log('writeStream close');
    })
    rs.pipe(ws);

4. Duplex流与Transform流

Duplex流是同时实现了Readable和write接口的流。

变换流（Transform streams）是一种Duplex流。他的输出和输入是通过某种方式关联的。变换流同时实现了Readable和Writeable接口。

发表评论取消回复

表情：

评论列表（有 0 条评论，202人围观）

还没有评论，来说两句吧...

相关阅读

相关 Nodejs核心模块

*(1)全局对象** 在浏览器JS中，通常window是全局对象，而nodejs中的全局对象是global,所有全局变量都是global对象的属性。在nodejs中...

以你之姓@/ 2024年04月17日 05:25/ 0 赞/ 75 阅读

相关 spark核心模块

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIz

浅浅的花香味﹌/ 2022年12月28日 00:51/ 0 赞/ 286 阅读

相关 Spark核心之Spark Streaming

前面说到Spark的核心技术的时候，有和大家说过，有五大核心技术，不知道大家还记不记得；给大家回忆下，这五大核心技术：分布式计算引擎Spark Core 、基于Hadoo

浅浅的花香味﹌/ 2022年12月03日 09:22/ 0 赞/ 283 阅读

相关 Node核心模块

node.js核心模块 fs Buffer http stream 流：用于和文件或其他的数据流交互 fs：文件系统模块通过`const

喜欢ヅ旅行/ 2022年11月21日 09:41/ 0 赞/ 150 阅读

相关 Qt：核心模块

Qt核心模块为C++添加了如下特性：一种非常强大的无缝对象通信机制，叫做信号与槽可查询和可设计对象属性有组织的层次化和可查询的对象树使用受保护

布满荆棘的人生/ 2022年11月17日 05:06/ 0 赞/ 167 阅读

相关 Python核心模块——urllib模块

urllib2可以接受一个Request类的实例来设置URL请求的headers，urllib仅可以接受URL。这意味着，你不可以通过urllib模块伪装你的User Agen

深碍√TFBOYSˉ_/ 2022年06月14日 02:36/ 0 赞/ 293 阅读

相关 Node.js-核心模块-crypto模块

10. crypto加密 (1) 加密方式 Hash包括md5算法、sha1算法、sha256算法、sha512算法等 AES对称加密 Diff

朱雀/ 2022年05月13日 13:28/ 0 赞/ 291 阅读

相关 Node.js-Node核心模块-stream

7. Stream Node.js提供了多种流对象，例如：HTTP请求和process.stdout都是流的实例。流可以是可读、可写或可读写的，所有的流都是EventEm

╰+哭是因爲堅強的太久メ/ 2022年05月13日 13:26/ 0 赞/ 203 阅读

相关 Node核心模块Http

静态服务器 let http = require('http'); let url = require('url'); // pathname,q

梦里梦外;/ 2022年01月20日 10:55/ 0 赞/ 277 阅读

相关 mySql核心模块

mysql可以在服务器中识别出一下模块：服务器初始化模块服务器初始化模块负责在启动时完成服务器初始化，大部分代码可在文件sql/mysqld.cc中找到。连接管...

系统管理员/ 2021年02月10日 09:34/ 0 赞/ 623 阅读