const fs = require('fs' )
const stream = fs. createWriteStream(' ./big file.txt' )
for(let i=0; i<10000; i++){
stream. write(~这是第${i} 行内容，我们需要很多很多内容，
要不停地写文件啊啊啊啊啊啊回车\n )
stream.end() //别忘了关掉stream
console.log( ' done' )
最后更新于
//请先引入fs和http
const server = http. createServer( )
server.on( ' request'，( request, response)=>{
fs.readFile(' ./big_ file. txt', (error ,
data)=>{
if(error) throw error
response.end( data )
console.log( ' done ' )
})
})
server.listen(8888)
console.log("8888")const server = http.createServer()
server.on('request', (request, response)=>{
const stream = fs.createReadStream('/big_file.txt')
stream.pipe(response)
stream.on('end',()=> console.log('done'))
})
server.listen(8888)// stream1 一有数据就基给stream2
stream1.on('data', (chunk)=>{
stream2.Write( chunk)
})
/ stream1 停了，就停掉stream2
stream1.on('end'，()=>{
stream2.end( )
})//4.js
const fs = require('fs')
const s = fs.createReadStream('./big_file.txt')
console.log(s)
//这里打印出来的东西不能继续看下面一层是什么，需要使用
//node --inspect-brk 4.jsconst { Writable } = require( "'stream') ;
const outStream = new Writable( {
write( chunk, encoding, callback) {
console. log( chunk. toString() );
callback( );
});
process. stdin. pipe( outStream) ;
//保存文件为writable.js 然后用node运行
//不管你输入什么，都会得到相同的结果const { Readable } = require("stream");
const inStream = new Readable();
inStream.push("ABCDEFGHIJKLM") ;
inStream .push("NOPQRSTUVWXYZ");
inStream.push(null); // No more data
inStream.pipe(process.stdout); // 保存文件为 readable.js 然后用 node 运行
// 我们先把所有数据都 push 进去了，然后 pipeconst { Readable } = require("stream"); }
const inStream = new Readable({
read(size) {
this.push(String.fromCharCode(this.currentCharCode++));
if (this.currentCharCode > 90) {
this.push(null);
7)
})
inStream.currentCharCode = 65 // A
inStream.pipe(process.stdout)
// 保存文件为 readable2.js然后用 node 运行
// 这次的数据是按需供给的，对方调用read 我们才会给一次数据const { Duplex } = require("stream");
const inoutStream =new Duplex({ write(chunk, encoding, callback) { console.log(chunk.toString());
callback();
}，
read(size) {
this.push(String.fromCharCode(this.currentCharCode++)); if (this.currentCharCode > 90) {
this.push(null);
});
inoutStream.currentCharCode = 65:
process.stdin.pipe(inoutStream).pipe(process.stdout);
// 源代码来源见参考链接
const { Transform }= require("stream");
const upperCaseTr = new Transform({
transform(chunk, encoding, callback) {
this.push(chunk.toString().toUpperCase());
callback();
}
});
process.stdin.pipe(upperCaseTr)
.pipe(process.stdout);
// 源代码来源见参考链接内置的 const fs =require("fs");
const zlib = require("zlib");//做gzip压缩
const file = process.argv[2];//读第二个参数，也就是用户传的一个路径
fs.createReadStream(file)
.pipe(zlib.createGzip())
.pipe(fs.createWriteStream(file + ".gz"));const fs = require("fs");
const zlib = require(" zlib");
const file = process.argv[2];
fs.createReadStream(file)
.pipe( zlib. createGzip( ))
.on("data", () => process.stdout.write("."))
.pipe(fs.createWriteStream(file + ".zz"))
.on("finish", () => console.log( "Done") ) ;//略
const file = process.argv[2];
const {Transform} = require("stream");
const reportProgress = new Transform({
transform(chunk, encoding, callback) {
process.stdout.write(".");
this.push(chunk);
callback(null, chunk);
}
});
fs.createReadStream(file)
.pipe(zlib.createGzip())
.pipe(reportProgress)
.pipe(fs.createWriteStream(file + ".zz"))
.on("finish", () => console.log("Done"));const CRYPTO require("crypto");
fs.createReadStream(file)
.pipe(crypto.createCipher("aes192", "123456")) //createCipher已经弃用
.pipe(zlib.createGzip())
.pipe(reportProgress)
.pipe(fs.createWriteStream(file + ".zz"))
.on("finish", () => console.log("Done"));