Node.js——Stream

Posted 2020-11-18 站错队了同志

介绍

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