//标准输入输出
process.stdin.pipe(process.stdout)
//最主要
const http = require('http')
const server = http.createServer((req,res)=>{
if(req.method === 'POST'){
req.pipe(res)//最重要,水管原理,资源入pipe资源出
}
})
server.listen(8000)
//复制文件
const fs = require('fs')
const path = require('path')
const fileName1 = path.resolve(__dirname,'data.txt')
const fileName2 = path.resolve(__dirname,'data-bak.txt')
const readStream = fs.createReadStream(fileName1)
const writeStream = fs.createWriteStream(fileName2)
//水桶1,pipe管道,水桶2
readStream.pipe(writeStream)
//数据流动监听
readStream.on('data',chunk=>{
console.log('数据copy监听,',chunk.toString())
})
//copy执行
readStream.on('end',()=>{
console.log('copy done拷贝完成!')
})
代码终端执行


