Node.js——Stream

时间：2018-06-17 11:06:31 阅读：122 评论：0 收藏：0 [点我收藏+]

标签：mes creates func response 需要 fun create 调用事件

介绍

文件流：我们一般对大一点的文件实现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)

Node.js——Stream

标签：mes creates func response 需要 fun create 调用事件

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

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行