Node.js流操作

const fs = require('fs')
const zlib =require('zlib')

let rs = fs.createReadStream('112.jpg')
let ws = fs.createWriteStream('copy.jpg')

rs.on('error',err=>{
    console.log('读取失败');  
})

ws.on('finish',()=>{
    console.log('写入完成');
    
})

rs.pipe(ws)

const fs = require('fs')
const zlib =require('zlib')

let rs1 = fs.createReadStream('fileupload.html')
let ws1 = fs.createWriteStream('fileupload.html.gz')

let gz = zlib.createGzip()

rs1.pipe(gz).pipe(ws1)

ws1.on('finish',()=>{
    console.log('完成压缩'); 
})

应用到服务器：

const http = require('http')
const fs = require('fs')
const zlib = require('zlib')

let server = http.createServer((req, res) => {

    let rs = fs.createReadStream(`upload${req.url}`)

    res.setHeader('content-encoding','gzip')

    let gz = zlib.createGzip()

    rs.pipe(gz).pipe(res)

    rs.on('error',err=>{
        res.writeHead(404)
        res.write('Not Found')
        res.end();
    })

})

server.listen(8080, () => {
    console.log('http://localhost:8080/');
})