Node js Streams Tutorial: Filestream, Pipes

Filestream in Node.js

Der Knoten nutzt Streams in großem Umfang als Datenübertragungsmechanismus.

Wenn Sie beispielsweise mit der Funktion console.log etwas an die Konsole ausgeben, verwenden Sie tatsächlich einen Stream, um die Daten an die Konsole zu senden.

Node.js bietet außerdem die Möglichkeit, Daten aus Dateien zu streamen, sodass diese entsprechend gelesen und geschrieben werden können. Wir werden uns nun ein Beispiel ansehen, wie wir Streams zum Lesen und Schreiben von Dateien verwenden können. Für dieses Beispiel müssen wir die unten aufgeführten Schritte befolgen

Schritt 1) Erstellen Sie eine Datei mit dem Namen data.txt, die die folgenden Daten enthält. Nehmen wir an, diese Datei ist auf dem Laufwerk D unseres lokalen Computers gespeichert.

Tutorial zu Node.js

Einleitung

Events

Generatoren

Datenkonnektivität

Jasmin verwenden

Schritt 2) Schreiben Sie den entsprechenden Code, der Streams zum Lesen von Daten aus der Datei verwendet.

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

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

Code-Erklärung:-

1. Zuerst müssen wir die „fs“-Module einbinden, die alle zum Erstellen von Streams erforderlichen Funktionen enthalten.
2. Als nächstes erstellen wir mit der Methode createReadStream einen lesbaren Stream. Als Eingabe geben wir den Speicherort unserer Datei data.txt an.
3. Die Steam.on-Funktion ist ein Event-Handler und darin geben wir den ersten Parameter als „Daten“ an. Dies bedeutet, dass immer dann, wenn Daten aus der Datei in den Stream eingehen, eine Rückruffunktion ausgeführt wird. In unserem Fall definieren wir eine Callback-Funktion, die zwei grundlegende Schritte ausführt. Die erste besteht darin, die aus der Datei gelesenen Daten in eine Zeichenfolge zu konvertieren. Die zweite wäre, die konvertierte Zeichenfolge als Ausgabe an die Konsole zu senden.
4. Wir nehmen jeden Datenblock, der aus dem Datenstrom gelesen wird, und wandeln ihn in einen String um.
5. Schließlich senden wir die Ausgabe jedes String-konvertierten Blocks an die Konsole.

Ausgang:

• Wenn der Code ordnungsgemäß ausgeführt wird, sehen Sie die obige Ausgabe in der Konsole. Diese Ausgabe ist dieselbe wie die in der Datei data.txt.

In eine Datei schreiben

Auf die gleiche Weise, wie wir einen Lesestream erstellen, können wir auch einen Schreibstream erstellen, um Daten in eine Datei zu schreiben. Erstellen wir zunächst eine leere Datei ohne Inhalt mit dem Namen data.txt. Nehmen wir an, diese Datei befindet sich auf dem Laufwerk D unseres Computers.

Der folgende Code zeigt, wie wir Daten in die Datei schreiben können.

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") 

Code-Erklärung:-

1. Wir erstellen einen beschreibbaren Stream mithilfe der Methode – createWriteStream. Als Eingabe geben wir den Speicherort unserer data.txt-Datei an.
2. Als nächstes haben wir die Methode stream.write verwendet, um die verschiedenen Textzeilen in unsere Textdatei zu schreiben. Der Stream kümmert sich darum, diese Daten in die Datei data.txt zu schreiben.

Wenn Sie die Datei data.txt öffnen, sehen Sie nun folgende Daten in der Datei

Tutorial zu Node.js

Einleitung

Events

Generatoren

Datenkonnektivität

Die richtigen Jasmin

Pipes in Node.js

Innerhalb von Node-Anwendungen können Streams mithilfe der Methode „pipe()“ zusammengeleitet werden, die zwei Argumente benötigt:

• Ein erforderlicher beschreibbarer Stream, der als Ziel für die Daten fungiert und
• Ein optionales Objekt, das zur Übergabe von Optionen verwendet wird.

Ein typisches Beispiel für die Verwendung von Pipes, wenn Sie Daten von einer Datei in eine andere übertragen möchten.

Sehen wir uns also ein Beispiel an, wie wir mithilfe von Pipes Daten von einer Datei in die andere übertragen können.

Schritt 1) Erstellen Sie eine Datei mit dem Namen datainput.txt, die die folgenden Daten enthält. Nehmen wir an, diese Datei ist auf dem Laufwerk D unseres lokalen Computers gespeichert.

Tutorial zu Node.js

Einleitung

Events

Generatoren

Datenkonnektivität

Jasmin verwenden

Schritt 2) Erstellen Sie eine leere Datei mit dem Namen dataOutput.txt und legen Sie sie auf dem Laufwerk D Ihres lokalen Computers ab.

Schritt 3) Schreiben Sie den folgenden Code, um die Übertragung von Daten aus der Datei datainput.txt in die Datei dataOutput.txt durchzuführen.

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

Code-Erklärung:-

1. Wir erstellen zunächst einen „Readstream“ zu unserer datainput.txt-Datei, der alle unsere Daten enthält, die in die neue Datei übertragen werden müssen.
2. Anschließend müssen wir einen „Writestream“ für unsere Datei „dataOutput.txt“ erstellen, die unsere leere Datei ist und das Ziel für die Übertragung von Daten aus der Datei „datainput.txt“ darstellt.
3. Anschließend verwenden wir den Pipe-Befehl, um die Daten vom Lesestream zum Schreibstream zu übertragen. Der Pipe-Befehl nimmt alle Daten, die in den Lesestream gelangen, und schiebt sie an den Schreibstream.

Wenn Sie nun die Datei dataOutput.txt öffnen, sehen Sie alle Daten, die in der Datei datainput.txt vorhanden waren.

Ereignisse in Node.js

Ereignisse sind eines der Schlüsselkonzepte in Node.js und manchmal wird Node.js als ereignisgesteuertes Framework bezeichnet.

Im Grunde ist ein Ereignis etwas, das passiert. Wenn beispielsweise eine Verbindung zu einer Datenbank hergestellt wird, wird das Datenbankverbindungsereignis ausgelöst. Bei der ereignisgesteuerten Programmierung geht es darum, Funktionen zu erstellen, die ausgelöst werden, wenn bestimmte Ereignisse ausgelöst werden.

Schauen wir uns ein einfaches Beispiel für die Definition eines Ereignisses in Node.js an.

Wir werden ein Ereignis namens „data_received“ erstellen. Wenn dieses Ereignis ausgelöst wird, wird der Text „Daten empfangen“ an die Konsole gesendet.

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

eventEmitter.emit('data_received'); 

Code-Erklärung:-

1. Verwenden Sie die Funktion „require“, um das Modul „events“ einzubinden. Mit diesem Modul können Sie Ereignisse in Node.js erstellen.
2. Erstellen Sie einen neuen Ereignisemitter. Dies wird verwendet, um das Ereignis, das in unserem Fall „data_received“ ist, an eine Rückruffunktion zu binden, die in Schritt 3 definiert wird.
3. Wir definieren eine ereignisgesteuerte Funktion, die besagt, dass wir, falls das Ereignis „data_received“ ausgelöst wird, den Text „data_received“ an die Konsole ausgeben sollen.
4. Schließlich haben wir einen manuellen Auslöser unseres Ereignisses mithilfe der Funktion eventEmiter.emit. Dadurch wird das data_received-Ereignis ausgelöst.

Wenn das Programm ausgeführt wird, wird der Text „Daten empfangen“ wie unten gezeigt an die Konsole gesendet.

Ereignisse ausgeben

Bei der Definition von Ereignissen gibt es verschiedene Methoden für Ereignisse, die aufgerufen werden können. In diesem Thema geht es darum, jeden einzelnen davon im Detail zu betrachten.

1. Einmalige Event-Handler

Manchmal möchten Sie möglicherweise nur auf ein Ereignis reagieren, wenn es zum ersten Mal auftritt. In diesen Situationen können Sie die Methode Once() verwenden.

Sehen wir uns an, wie wir die Once-Methode für Event-Handler nutzen können.

Code-Erklärung:-

1. Hier verwenden wir die Methode „once“, um zu sagen, dass die Callback-Funktion für das Ereignis „data_received“ nur einmal ausgeführt werden soll.
2. Hier lösen wir manuell das Ereignis „data_received“ aus.
3. Wenn das Ereignis „data_received“ erneut ausgelöst wird, passiert dieses Mal nichts. Dies liegt daran, dass wir im ersten Schritt gesagt haben, dass das Ereignis nur einmal ausgelöst werden kann.

Wenn der Code ordnungsgemäß ausgeführt wird, lautet die Ausgabe im Protokoll „data_received erfolgreich“. Diese Meldung wird nur einmal in der Konsole angezeigt.

2. Überprüfen von Ereignis-Listenern

Zu jedem Zeitpunkt seiner Lebensdauer können einem Ereignisemitter null oder mehr Listener zugeordnet sein. Die Listener für jeden Ereignistyp können auf verschiedene Arten überprüft werden.

Wenn Sie nur die Anzahl der angeschlossenen Listener ermitteln möchten, ist die Methode EventEmitter.listenerCount() genau das Richtige für Sie.

(Hinweis: Zuhörer sind wichtig, da das Hauptprogramm wissen sollte, ob Zuhörer spontan zu einem Ereignis hinzugefügt werden. Andernfalls kommt es zu Fehlfunktionen des Programms, da zusätzliche Zuhörer aufgerufen werden.)

Code-Erklärung:-

1. Wir definieren einen eventEmitter-Typ, der für die Verwendung der ereignisbezogenen Methoden erforderlich ist.
2. Anschließend definieren wir ein Objekt namens Emitter, das zur Definition unserer Event-Handler verwendet wird.
3. Wir erstellen zwei Event-Handler, die im Grunde nichts tun. In unserem Beispiel ist dies einfach gehalten, nur um zu zeigen, wie die Methode listenerCount funktioniert.
4. Wenn Sie nun die Methode listenerCount für unser data_received-Ereignis aufrufen, wird die Anzahl der an dieses Ereignis angehängten Ereignis-Listener im Konsolenprotokoll gesendet.

Wenn der Code ordnungsgemäß ausgeführt wird, wird im Konsolenprotokoll der Wert 2 angezeigt.

3. Das newListener-Ereignis

Jedes Mal, wenn ein neuer Ereignishandler registriert wird, gibt der Ereignisemitter ein newListener-Ereignis aus. Dieses Ereignis wird verwendet, um neue Ereignishandler zu erkennen. Normalerweise verwenden Sie das Ereignis newListener, wenn Sie Ressourcen zuweisen oder eine Aktion für jeden neuen Ereignishandler ausführen müssen.

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() {}); 

Code-Erklärung:-

1. Wir erstellen einen neuen Eventhandler für das „newListener“-Ereignis. Immer wenn ein neuer Eventhandler registriert wird, wird in der Konsole der Text „Listener für hinzugefügt“ + der Ereignisname angezeigt.
2. Hier schreiben wir in die Konsole den Text „Hinzugefügter Listener für“ + den Ereignisnamen für jedes registrierte Ereignis.
3. Wir definieren zwei Event-Handler für unser Event „data_received“.

Wenn der obige Code ordnungsgemäß ausgeführt wird, wird der folgende Text in der Konsole angezeigt. Es zeigt lediglich, dass der Ereignishandler „newListener“ zweimal ausgelöst wurde.

Listener für data_received-Ereignisse hinzugefügt

Listener für data_received-Ereignisse hinzugefügt

Zusammenfassung

• Streams werden in Node.js verwendet, um Daten von Eingabe-Ausgabe-Geräten zu lesen und zu schreiben. Node.js verwendet die Bibliothek „fs“, um lesbare und beschreibbare Streams für Dateien zu erstellen. Diese Streams können zum Lesen und Schreiben von Daten aus Dateien verwendet werden.
• Rohre können verwendet werden, um mehrere Ströme miteinander zu verbinden. Eines der häufigsten Beispiele ist die Zusammenführung des Lese- und Schreibstroms für die Übertragung von Daten von einer Datei zur anderen.
• Node.js wird oft auch als ereignisgesteuertes Framework bezeichnet und es ist sehr einfach, Ereignisse in Node.js zu definieren. Es können Funktionen definiert werden, die auf diese Ereignisse reagieren.
• Ereignisse stellen auch Methoden zur Reaktion auf Schlüsselereignisse bereit. Wir haben zum Beispiel den Event-Handler Once() gesehen, mit dem sichergestellt werden kann, dass eine Callback-Funktion nur einmal ausgeführt wird, wenn ein Ereignis ausgelöst wird.