Compréhension approfondie du flux et du canal dans nodejs

Cet article présente principalement les principes et la mise en œuvre de la compréhension du mécanisme de flux et de pipeline de nodejs. Il a une certaine valeur de référence. Les amis intéressés peuvent s'y référer

Avant-propos

<.>Il y a quelques jours, quelqu'un m'a posé une question sur pipe. J'ai découvert que même si j'utilise nodejs depuis longtemps, j'évite souvent d'utiliser stream car je ne l'utilise pas beaucoup à chaque fois. familier avec lui. Maintenant, je vais le réapprendre et l'organiser.

Apprenez le stream via nodeschool

nodeschool a un tutoriel stream-adventure pour enseigner l'utilisation du stream, c'est très simple

Simple stream to pipe

Tout d'abord, nous pouvons positionner l'entrée vers la sortie via le pipeline. L'entrée et la sortie peuvent être le flux de console ou de fichier ou une requête http, telle que

<.>

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

Traitement au milieu du pipeline

Si nous voulons traiter au milieu du pipeline, par exemple, si nous voulons changer la chaîne d'entrée en majuscule et l'écrire dans la sortie, nous pouvons en utiliser un Le cadre de traitement, tel que through2, est très pratique

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

le flux est converti en un rappel normal

Lorsque notre entrée est un flux, La sortie est une fonction ordinaire Nous devons convertir le flux d'entrée en un tampon ordinaire. À ce stade, nous pouvons essayer la concaténation. bibliothèque stream

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

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

process.stdin.pipe(reverseStream)

dans le serveur http Stream

est similaire à stdin et fs En raison de ses caractéristiques, http. est également adapté à l'utilisation de flux, il a donc des fonctionnalités similaires

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

Un flux qui sert à la fois d'entrée et de sortie

Le framework de requête implémente les fonctions suivantes, dirige un flux vers la requête de requête, puis envoie le contenu du flux au serveur, puis le renvoie sous forme de flux pour un autre code. Utilisation, implémentez comme suit

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

Pipeline de branchement

Ce qui suit est un exemple, cet exemple saisira le HTML dans le pipeline pour inclure fort Les éléments de classe sont mis dans un autre tube pour les opérations en majuscules, puis finalement fusionné en sortie

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

Exemple de fusion de flux d'entrée et de sortie

Le les entrées et sorties fusionnées peuvent être utilisées comme la requête précédente. L'exemple suivant implémente l'utilisation de flux pour appeler des sous-processus

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

Résumé

. Grâce à l'exemple ci-dessus, vous pouvez savoir comment fusionner des flux et d'autres méthodes d'application plus complexes. En bref, il est conforme aux caractéristiques suivantes dans leur ensemble :

Le flux est divisé en lisible et inscriptible
Le flux contrôle la direction du flux à travers la méthode pipe
httpServer et httpClient et le système de fichiers et process.stdinouterr peuvent généralement être utilisés comme flux
Le flux peut être converti en variables ordinaires par on(event), et les variables ordinaires peuvent être converties en écrivant dans le flux
Le flux lui-même peut être divisé, fusionné, filtré

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!