Secuencia de escritura y lectura

Veamos como se utilizan las secuencias y comprendamos por qué son vitales para la aplicación de Node.js, comenzaremos usando una secuencia para crear un archivo grande para ver que tan utiles son.

const fs = require('fs');
const file = fs.createWriteStream('./big-file.txt');

for(let i = 0; i <= 1000000; i++) {
  file.write('This is just a text that we are going to write to the big-file.txt one million times. So it becomes a big file (around 150MB) for Stream example purposes.\n');
}
file.end();

El módulo 'fs' se puede usar para leer y escribir en archivos usando una interfaz de flujo, en el ejemplo anterior estamos usando un bucle for para escribir en 1 millón de líneas a través de una secuencia de escritura en big-file.txt.

Ahora necesitamos servir el big-file.txt:

const server = require('http').createServer();
const fs = require('fs');

server.on('request', (req, res) => {
  fs.readFile('./big-file.txt', (err, data) => {
    if (err) throw err;
    res.end(data);
  });
});

server.listen(3000);

Cuando un servidor recibe una solicitud, intentará servir el archivo mencionada de manera asincrona utilizando el metodo de fs.readFile(). El problema es cuanta memoria consumirá, pondrá el contenido del archivo en memoria de la computadora antes de asignarlo al objeto response. Al usar el método fs.createReadStream() nos permite canalizar la secuencia al objeto de respuesta.

const fs = require('fs');
const server = require('http').createServer();

server.on('request', (req, res) => {
  const src = fs.createReadStream('./big-file.txt');
  src.pipe(res);
});

server.listen(3000);

Cuando el cliente solicita un archivo grande, transmitimos un fragmento a la vez, lo que significa que no estamos colocando todo el archivo en la RAM de una vez.

---

Con la configuración predeterminada, no puede servir un archivo más grande que el limite del bufer predeterminado en Node (2GB) sin usar secuencias.