node.js中stream流中可读流和可写流的实现与使用方法实例分析

Node.js中的Stream流是一种基于事件的异步流处理机制，允许我们以小片数据的形式对流进行读入和写出，并在处理完成后对操作进行销毁，以便节省内存空间。其中的可读流（Readable）用于从外部数据源读取数据，而可写流（Writable）则是将处理的结果写入到外部数据源。下面我们将会分别简单介绍一下可读流和可写流的实现与使用方法实例。

一、可读流的实现与使用方法

在Node.js中可读流是通过一个继承自EventEmitter的Readble类来实现的，我们只要将Readble的实例对象中的_read方法进行重写，并触发data和end事件即可完成具体功能。下面是一个简单的可读流示例：

var fs=require("fs"); //引入文件模块
var readStream=fs.createReadStream("test.txt"); //创建可读流
var str="";
readStream.on("data",function(chunk){ //监听数据
    str+=chunk; 
})
readStream.on("end",function(){ //数据读取完成
    console.log(str); 
})

在以上的实例中，我们通过fs模块中的createReadStream方法创建了一个可读流，并对数据进行了监听，在接收到每一次数据的时候会将其暂存，并在结束时打印所有暂存的内容。需要注意的是，可读流要求重写_read方法并调用push方法将数据手动导入内部读缓存，否则可能会导致无法正常流动流程。

二、可写流的实现与使用方法

可写流是Node.js流机制的另一面，主要用于向外部数据源写入数据。我们可以创建一个继承于Writable的类，并重写其_write方法，并在完成写入操作后触发finish事件。如下是一个简单的可写流实现实例：

var fs=require("fs");
var writableStream=fs.createWriteStream("output.txt"); //      个参数为文件路径
for(var i=0;i<1000;i++){
    writableStream.write("Hello World
","utf-8"); //写入数据
}
writableStream.end(); //写入结束，调用end方法
writableStream.on("finish",function(){ //流程完成，触发finish事件
    console.log("Write complete!");
})

在以上实例中，我们重写了Writable的_write方法，并在循环中反复写入“Hello World

”的字符串，并完成后关闭流程，等待finish事件的调用。

综上可得，可读流与可写流是Node.js流处理机制中的两个重要组成部分，它们可以用于数据的高效读取与写入，并节约内存空间以及获得更好的运行效率，值得我们充分的学习和应用。