Vertiefendes Verständnis von Stream und Pipe in NodeJS

Dieser Artikel stellt hauptsächlich die Prinzipien und die Implementierung des Verständnisses des Stream- und Pipe-Mechanismus von NodeJS vor. Er hat einen gewissen Referenzwert.

Vorwort

Vor ein paar Tagen fragte mich jemand nach Pipe. Ich habe festgestellt, dass ich die Verwendung von Streams oft vermeide, obwohl ich sie schon seit langem verwende Ich war noch nie damit vertraut. Jetzt werde ich das relevante Wissen neu erlernen und organisieren.

Lernen Sie Stream über Nodeschool

nodeschool verfügt über ein Stream-Adventure-Tutorial, um die Verwendung von Stream zu lehren, es ist sehr einfach

Einfach Stream zur Pipe

Zuerst können wir die Eingabe über die Pipeline zur Ausgabe positionieren. Die Eingabe und Ausgabe kann der Konsolen- oder Dateistream oder eine HTTP-Anfrage sein, wie z. B.

process.stdin.pipe(process.stdout)
process.stdin.pipe(fs.createWriteStream(path))
fs.createReadStream(path).pipe(process.stdin)

Verarbeitung mitten in der Pipeline

Wenn wir beispielsweise mitten in der Pipeline verarbeiten wollen, wenn wir etwas ändern wollen Wenn Sie die Eingabezeichenfolge in Großbuchstaben umwandeln und in die Ausgabe schreiben, können wir etwas verwenden, das als Zwischenprodukt verwendet werden kann. Das Verarbeitungsframework, z. B. through2, ist sehr praktisch

var through2 = require('through2');
var stream = through2(write,end)
process.stdin
  .pipe(stream)
  .pipe(process.stdout);

function write(line,_,next){
  this.push(line.toString().toUpperCase())
  next();
})
function end(done){
  done();
})

Stream wird in einen normalen Rückruf umgewandelt

Wenn unsere Eingabe ein Stream ist, ist die Ausgabe eine gewöhnliche Funktion. Zu diesem Zeitpunkt müssen wir den Eingabestream in einen normalen Puffer konvertieren , können wir die Concat-Stream-Bibliothek

var concat = require('concat-stream');

var reverseStream=concat(function(text){
  console.log(text.toString().split("").reverse().join(""));
})

process.stdin.pipe(reverseStream)

auf dem http-Server ausprobieren. Stream

ähnelt stdin und fs . Aufgrund seiner Eigenschaften eignet sich http auch für die Verwendung von Streams, daher verfügt es über ähnliche Funktionen

var http = require('http');
var server = http.createServer(function(req,res){
  req.pipe(res);
})

Ein Stream, der sowohl als Eingabe als auch als Ausgabe dient

Das Anforderungsframework implementiert die folgenden Funktionen, leitet einen Stream an die Anforderungsanforderung weiter, sendet dann den Inhalt des Streams an den Server und gibt ihn dann als Stream für anderen Code zurück. Verwenden Sie ihn und implementieren Sie ihn wie folgt

var request = require('request');
var r = request.post('http://localhost:8099');
process.stdin.pipe(r).pipe(process.stdout)

Zweigpipeline

Das Folgende ist ein Beispiel. In diesem Beispiel wird der HTML-Code in die Pipeline eingegeben, um laut einzuschließen Die Elemente der Klasse werden zur Großbuchstabenoperation in eine andere Pipe gestellt und dann schließlich zur Ausgabe zusammengeführt

var trumpet = require('trumpet');
var through2 = require('through2');
var fs = require('fs');
var tr = trumpet();
var stream = tr.select('.loud').createStream();
var upper = through2(function(buf,_,next){
  this.push(buf.toString().toUpperCase());
  next();
})
stream.pipe(upper).pipe(stream);
process.stdin.pipe(tr).pipe(process.stdout);

Beispiel für das Zusammenführen von Eingabe- und Ausgabeströmen

Die zusammengeführte Eingabe und Ausgabe kann wie die vorherige Anfrage verwendet werden. Das folgende Beispiel implementiert die Verwendung von Streams zum Aufrufen von Unterprozessen

var spawn = require('child_process').spawn;
var duplexer2 = require('duplexer2');

module.exports = function(cmd, args){
  var c = spawn(cmd,args)
  return duplexer2(c.stdin,c.stdout)
}

Zusammenfassung

Anhand des obigen Beispiels erfahren Sie, wie Sie Streams und andere komplexere Anwendungsmethoden zusammenführen. Kurz gesagt, es entspricht insgesamt den folgenden Merkmalen:

• Stream ist in lesbar und beschreibbar unterteilt

• Stream steuert die Flussrichtung durch die Pipe-Methode

• httpServer und httpClient sowie Dateisystem und process.stdinouterr können normalerweise als Stream verwendet werden

• Stream kann in gewöhnliche Variablen konvertiert werden durch on(event) und gewöhnliche Variablen können durch Schreiben in den Stream konvertiert werden

• Der Stream selbst kann geteilt, zusammengeführt und gefiltert werden

Das obige ist der detaillierte Inhalt vonVertiefendes Verständnis von Stream und Pipe in NodeJS. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!