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!
