说说对 Node 中的 Stream 的理解？应用场景？

<h2>一、是什么</h2><p>流（Stream），是一个数据传输手段，是端到端信息交换的一种方式，而且是有顺序的,是逐块读取数据、处理内容，用于顺序读取输入或写入输出</p><p><code>Node.js</code>中很多对象都实现了流，总之它是会冒数据（以 <code>Buffer</code> 为单位）</p><p>它的独特之处在于，它不像传统的程序那样一次将一个文件读入内存，而是逐块读取数据、处理其内容，而不是将其全部保存在内存中</p><p>流可以分成三部分：<code>source</code>、<code>dest</code>、<code>pipe</code></p><p>在<code>source</code>和<code>dest</code>之间有一个连接的管道<code>pipe</code>,它的基本语法是<code>source.pipe(dest)</code>，<code>source</code>和<code>dest</code>就是通过pipe连接，让数据从<code>source</code>流向了<code>dest</code>，如下图所示：</p><p><img src="https://static.ecool.fun//article/e676a4d2-5cbf-4541-8cd6-7770ac09c348.png" alt="" data-href="" style=""/></p><h2>二、种类</h2><p>在<code>NodeJS</code>，几乎所有的地方都使用到了流的概念，分成四个种类：</p><ul><li>可写流：可写入数据的流。例如 fs.createWriteStream() 可以使用流将数据写入文件</li><li>可读流： 可读取数据的流。例如fs.createReadStream() 可以从文件读取内容</li><li>双工流： 既可读又可写的流。例如 net.Socket</li><li>转换流： 可以在数据写入和读取时修改或转换数据的流。例如，在文件压缩操作中，可以向文件写入压缩数据，并从文件中读取解压数据</li></ul><p>在<code>NodeJS</code>中<code>HTTP</code>服务器模块中，<code>request</code> 是可读流，<code>response</code> 是可写流。还有<code>fs</code> 模块，能同时处理可读和可写文件流</p><p>可读流和可写流都是单向的，比较容易理解，而另外两个是双向的</p><h3>双工流</h3><p>之前了解过<code>websocket</code>通信，是一个全双工通信，发送方和接受方都是各自独立的方法，发送和接收都没有任何关系</p><p>如下图所示：</p><p><img src="https://static.ecool.fun//article/9bc63359-6e40-4582-8bb5-4ab539b12f87.png" alt="" data-href="" style=""/></p><p>基本代码如下：</p><pre><code class="language-js">const { Duplex } = require('stream');

const myDuplex = new Duplex({
  read(size) {
    // ...
  },
  write(chunk, encoding, callback) {
    // ...
  }
});</code></pre><h3>双工流</h3><p>双工流的演示图如下所示：</p><p><img src="https://static.ecool.fun//article/7e262767-786d-4abf-84a3-1a3f759a8a57.png" alt="" data-href="" style=""/></p><p>除了上述压缩包的例子，还比如一个 <code>babel</code>，把<code>es6</code>转换为，我们在左边写入 <code>es6</code>，从右边读取 <code>es5</code></p><p>基本代码如下所示：</p><pre><code class="language-js">const { Transform } = require('stream');

// 两个文件名
const fileName1 = path.resolve(__dirname, 'data.txt')
const fileName2 = path.resolve(__dirname, 'data-bak.txt')
// 读取文件的 stream 对象
const readStream = fs.createReadStream(fileName1)
// 写入文件的 stream 对象
const writeStream = fs.createWriteStream(fileName2)
// 通过 pipe执行拷贝，数据流转
readStream.pipe(writeStream)
// 数据读取完成监听，即拷贝完成
readStream.on('end', function () {
    console.log('拷贝完成')
})
</code></pre><h3>一些打包工具的底层操作</h3><p>目前一些比较火的前端打包构建工具，都是通过<code>node.js</code>编写的，打包和构建的过程肯定是文件频繁操作的过程，离不来<code>stream</code>，如<code>gulp</code></p>

DreamCoders/CoderGuide

Content Risk Flag

Comments (0)

DreamCoders/CoderGuide .gitee-modal { width: 500px !important; }

Content Risk Flag