Node js 流教程：文件流、管道

Node.js 中的文件流

Node 广泛使用流作为数据传输机制。

例如，当您使用 console.log 函数将任何内容输出到控制台时，您实际上是在使用流将数据发送到控制台。

Node.js 还能够从文件中流式传输数据，以便可以正确地读取和写入数据。现在我们将看一个示例，了解如何使用流从文件中读取和写入数据。对于此示例，我们需要遵循以下步骤

步骤1） 创建一个名为 data.txt 的文件，其中包含以下数据。假设此文件存储在本地计算机的 D 盘上。

Node.js 教程

介绍

活动

Generators

数据连接

使用 Jasmine

步骤2） 编写相关代码，利用流从文件读取数据。

var fs = require("fs");
var stream;
stream = fs.createReadStream("D://data.txt");

stream.on("data", function(data) {
    var chunk = data.toString();
    console.log(chunk);
});

代码说明：-

我们首先需要包含包含创建流所需的所有功能的“fs”模块。
接下来，我们使用 createReadStream 方法创建一个可读流。作为输入，我们给出了 data.txt 文件的位置。
steam.on 函数是一个事件处理程序，在其中，我们将第一个参数指定为“数据”。这意味着每当数据从文件流中进入时，就会执行回调函数。在我们的例子中，我们定义了一个回调函数，它将执行 2 个基本步骤。第一个是将从文件读取的数据转换为字符串。第二个是将转换后的字符串作为输出发送到控制台。
我们正在从数据流中读取每个数据块并将其转换为字符串。
最后，我们将每个字符串转换块的输出发送到控制台。

输出：

如果代码正确执行，您将在控制台中看到上述输出。此输出与 data.txt 文件中的输出相同。

写入文件

和创建读取流一样，我们也可以创建写入流来将数据写入文件。我们先创建一个没有内容的空文件，名为 data.txt。假设这个文件放在我们电脑的 D 盘。

下面的代码显示了如何将数据写入文件。

var fs = require("fs");
var stream;
stream = fs.createWriteStream("D://data.txt");

stream.write("Tutorial on Node.js")
stream.write("Introduction")
stream.write("Events")
stream.write("Generators")
stream.write("Data Connectivity")
stream.write("Using Jasmine")

代码说明：-

我们使用 createWriteStream 方法创建可写流。作为输入，我们给出了 data.txt 文件的位置。
接下来我们使用 stream.write 方法将不同行的文本写入文本文件。流将负责将这些数据写入 data.txt 文件。

如果你打开 data.txt 文件，你将在文件中看到以下数据

Node.js 教程

介绍

活动

Generators

数据连接

运用 Jasmine

Node.js 中的管道

在 Node 应用程序中，可以使用 pipe() 方法将流连接在一起，该方法接受两个参数：

必需的可写流，作为数据的目标，以及
用于传递选项的可选对象。

使用管道的一个典型例子是，如果您想将数据从一个文件传输到另一个文件。

让我们看一个例子，了解如何使用管道将数据从一个文件传输到另一个文件。

步骤1） 创建一个名为 datainput.txt 的文件，其中包含以下数据。假设此文件存储在我们本地机器的 D 盘上。

Node.js 教程

介绍

活动

Generators

数据连接

使用 Jasmine

步骤2） 创建一个名为 dataOutput.txt 的空白文件并将其放在本地机器的 D 盘上。

步骤3） 编写以下代码来执行从datainput.txt文件到dataOutput.txt文件的数据传输。

var fs = require("fs");
var readStream = fs.createReadStream("D://datainput.txt");
var writeStream = fs.createWriteStream("D://dataOutput.txt");
readStream.pipe(writeStream);

代码说明：-

我们首先为我们的 datainput.txt 文件创建一个“readstream”，其中包含需要传输到新文件的所有数据。
然后，我们需要为我们的 dataOutput.txt 文件创建一个“写入流”，这是我们的空文件，也是从 datainput.txt 文件传输数据的目的地。
然后我们使用管道命令将数据从读取流传输到写入流。管道命令将获取进入读取流的所有数据，并将其推送到写入流。

如果您现在打开 dataOutput.txt 文件，您将看到 datainput.txt 文件中存在的所有数据。

Node.js 中的事件

事件是 Node.js 中的关键概念之一，有时 Node.js 被称为事件驱动框架。

基本上，事件就是发生的事情。例如，如果建立了与数据库的连接，则会触发数据库连接事件。事件驱动编程是创建在触发特定事件时触发的函数。

让我们看一个在 Node.js 中定义事件的基本示例。

我们将创建一个名为“data_received”的事件。当触发此事件时，文本“数据已接收”将发送到控制台。

var events = require('events');
var eventEmitter = new events.EventEmitter();
eventEmitter.on('data_received', function() {
    console.log('data received succesfully.');
});

eventEmitter.emit('data_received');

代码说明：-

使用 require 函数包含“events”模块。使用此模块，您将能够在 Node.js 中创建事件。
创建一个新的事件发射器。这用于将事件（在我们的例子中为“data_received”）绑定到在步骤 3 中定义的回调函数。
我们定义一个事件驱动函数，该函数表示如果触发“data_received”事件，那么我们应该将文本“data_received”输出到控制台。
最后，我们使用 eventEmiter.emit 函数手动触发事件。这将触发 data_received 事件。

程序运行时，文本“数据已接收”将发送到控制台，如下所示。

发射事件

定义事件时，可以调用不同的事件方法。本主题重点介绍每种方法的详细信息。

一次性事件处理程序

有时您可能只想对第一次发生的事件做出反应。在这种情况下，您可以使用 once() 方法。

让我们看看如何利用 once 方法处理事件。

代码说明：-

这里我们使用‘once’方法来表示对于事件‘data_received’，回调函数应该只执行一次。
这里我们手动触发“data_received”事件。
当 'data_received' 事件再次被触发时，这次什么也不会发生。这是因为在第一步我们说过该事件只能被触发一次。

如果代码正确执行，日志中将输出“data_received successful”。此消息只会在控制台中出现一次。

检查事件监听器

在其生命周期的任何时刻，事件发射器都可以附加零个或多个侦听器。可以通过多种方式检查每种事件类型的侦听器。

如果您只对确定附加监听器的数量感兴趣，那么 EventEmitter.listenerCount() 方法就是最好的选择。

(请注意： 监听器很重要，因为主程序应该知道是否正在将监听器添加到事件中，否则程序将因调用其他监听器而出现故障。）

代码说明：-

我们正在定义使用事件相关方法所需的 eventEmitter 类型。
然后我们定义一个名为 emitter 的对象，它将用于定义我们的事件处理程序。
我们创建了 2 个事件处理程序，它们基本上不执行任何操作。我们的示例保持简单，只是为了展示 listenerCount 方法的工作原理。
现在，当您在 data_received 事件上调用 listenerCount 方法时，它将在控制台日志中发送附加到此事件的事件监听器的数量。

如果代码正确执行，控制台日志中将显示值 2。

newListener 事件

每次注册新的事件处理程序时，事件发射器都会发出 newListener 事件。此事件用于检测新的事件处理程序。当您需要为每个新的事件处理程序分配资源或执行某些操作时，通常会使用 newListener 事件。

var events = require('events');
var eventEmitter = events.EventEmitter;
var emitter = new eventEmitter();
emitter.on("newListener", function(eventName, listener) {
    console.log("Added listener for " + eventName + " events");
});
emitter.on('data_received', function() {});
emitter.on('data_received', function() {});

代码说明：-

我们正在为“newListener”事件创建一个新的事件处理程序。因此，每当注册新的事件处理程序时，控制台中都会显示文本“已添加侦听器”+ 事件名称。
这里我们向控制台写入文本“已添加监听器”+每个注册事件的事件名称。
我们为事件“data_received”定义了 2 个事件处理程序。

如果上述代码正确执行，控制台中将显示以下文本。它仅显示“newListener”事件处理程序被触发了两次。

添加了 data_received 事件的监听器

总结

Node.js 中使用流从输入输出设备读取和写入数据。 Node.js 使用 'fs' 库创建可读写文件流。这些流可用于从文件读取和写入数据。
管道可用于将多个流连接在一起。最常见的示例之一是将读取流和写入流连接在一起，以便将数据从一个文件传输到另一个文件。
Node.js 通常也被标记为事件驱动框架，并且在 Node.js 中定义事件非常容易。可以定义响应这些事件的函数。
事件还公开了响应关键事件的方法。例如，我们已经看到了 once() 事件处理程序，它可用于确保回调函数在触发事件时仅执行一次。

Node.js 中的文件流

相关文章

Node.js 中的管道

Node.js 中的事件

发射事件

总结

注册简报