Discussion :

[thom's68]

Hello tout le monde ,

je viens de découvrir nodeJS et notamment sa gestion de flux est ce que quelqu'un aurait la gentillesse de bien vouloir m'expliquer un peu tout ca ou le cas echeant peut etre mieux rediriger mes recherche sur ce sujet la.

Merci d'avance pour vos réponse =)

[Marco46]

Quel est ton besoin ?

C'est pour limiter l'empreinte mémoire parce que tu as de gros fichiers ? Ou bien c'est plutôt pour écrire un service type streaming de vidéo ?

Ya beaucoup de cas d'utilisation. C'est un peu vaste pour te répondre comme ça de but en blanc.

Perso j'ai à peine effleuré ce sujet mais l'exemple le plus simple c'est de démarrer avec des fichiers je pense. Cf documentation officielle de node avec readStream et writeStream.

[thom's68]

Alors deja merci pour la reponse si rapide,

effectivement il s'agit bien de flux pour eviter une trop grosse perte de memoire lors de copie de gros fichier par exemple.

J'ai un peu du mal a comprendre le fonctionnement du processus

[Marco46]

Ça n'est utile qu'avec des gros fichiers (autour de 10mo ça commence à faire des économies), puisque fs.readFile va lire tout le fichier (donc charger une copie du contenu en mémoire) avant de te le mettre à dispo.

Le principe du stream c'est de lire par séquence et de te mettre le contenu à dispo au fur et à mesure de la lecture.

Un exemple tout bête :

Code javascript :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
'use strict';
 
const fs = require("fs");
 
let data = '';
 
const rs = fs.createReadStream('stream-read-example-file.txt', {encoding: 'utf8', highWaterMark: 1});
 
rs.on('data', function(chunk) {
    console.log('chunk = ', chunk);
    data += chunk;
});
 
rs.on('end',function(){
    console.log("data = ", data);
});
 
rs.on('error', function(err){
    console.log(err.stack);
});
 
console.log("stream terminé");

Le fichier stream-read-example-file.txt contient dans mon exemple :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
 
aaaaa aaaaa aaaaa aaaaa aaaaa
bbbbb bbbbb bbbbb bbbbb bbbbb
ccccc ccccc ccccc ccccc ccccc

Exécute ça ça sera plus clair.

La propriété de config highWaterMark définit la taille du buffer (du chunk si tu préfères), tu peux l'augmenter pour voir ce qui est logué dans la console. La valeur par défaut est beaucoup plus importante mais pour que ce soit lisible dans cet exemple je l'ai mis à 1 octet.

EDIT : Tu noteras que le log "stream terminé" est affiché au tout début et non à la fin. Je t'invite à réfléchir au pourquoi !