在Node.js中，流是一种处理数据的方式，可以帮助我们有效地处理大量的数据。流的特点是逐个读取数据，并且不需要将整个数据加载到内存中。这使得流非常适合用于处理大型文件和网络通信。
同时，Node.js还提供了一种称为“观测值”的机制，它可以让我们更加方便地管理异步代码。本文将探讨Node.js中的流和观测值，并提供示例代码以帮助您深入了解。
流
Node.js中的流分为四种类型：可读流（Readable）、可写流（Writable）、双工流（Duplex）和转换流（Transform）。在这里，我们将重点介绍可读流和可写流。
可读流
可读流是从数据源读取数据的流。在使用可读流时，数据被分成小块（也称为“缓冲区”），并且每次只读取一小块。当一个块被读取完毕后，可读流会等待下一个块的到来。这个过程会一直持续，直到所有的数据都被读取完毕。
以下是一个简单的可读流示例代码：
-- -------------------- ---- ------- ----- -- - -------------- ----- ---------- - --------------------------------- --------------------- ----- -- - --------------------- --------------- ----- -- -------- --- -------------------- -- -- - --------------------- ------- -------- --- ---------------------- --- -- - ----------------- ----- --------- ----------------- ---
在这个示例中，我们创建了一个可读流对象readStream ，并使用fs.createReadStream()方法从文件系统中读取数据。当可读流准备好读取数据时，它会触发data事件，并传递一个缓冲区块的引用chunk。我们可以在事件处理程序中使用chunk来处理数据块。
可写流
可写流是将数据写入目标的流。可写流也分成小块，每次只写一个小块。如果写入速度比读取速度快，那么可写流就会等待下一个数据块；如果写入速度比读取速度慢，那么可写流就会将数据块存储在内部缓冲区中，直到有足够的空间进行写入。
以下是一个简单的可写流示例代码：
-- -------------------- ---- ------- ----- -- - -------------- ----- ----------- - ----------------------------------- ------------------------- --- ---------------------------- ------------------ ------------------------ -- -- - --------------------- ------- -------- --- ----------------------- --- -- - ----------------- ----- --------- ----------------- ---
在这个示例中，我们创建了一个可写流对象writeStream，并使用fs.createWriteStream()方法向文件系统中写入数据。我们可以通过调用writeStream.write()方法来写入数据块，最后调用writeStream.end()方法结束写入。
观测值
观测值是一种广泛用于异步代码的机制，它允许开发人员对异步事件进行监听和响应。在Node.js中，我们可以使用内置的EventEmitter类来创建自定义观察者对象。
以下是一个简单的观测值示例代码：
-- -------------------- ---- ------- ----- ------------ - ------------------ ----- --------- ------- ------------ -- ----- --------- - --- ------------ --------------------- -- -- - --------------- ----- ------------ --- ------------------------
在这个示例中，我们定义了一个名为MyEmitter的自定义观察者类，并创建了一个myEmitter对象。我们可以使用on()方法将一个回调函数绑定
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/14034