Node.js-Streams und Pipelines beherrschen

Streams sind die Superleistung von Node.js für die effiziente Verarbeitung großer Datenmengen. Lassen Sie uns in Streams und Pipelines eintauchen.

Warum Streams?

1. Speichereffizienz
2. Zeiteffizienz
3. Zusammensetzbarkeit

Arten von Streams

1. Lesbar
2. Beschreibbar
3. Duplex
4. Transformieren

Grundlegende Stream-Nutzung

const fs = require('fs');

const readStream = fs.createReadStream('big.file');
const writeStream = fs.createWriteStream('output.file');

readStream.on('data', (chunk) => {
  writeStream.write(chunk);
});

readStream.on('end', () => {
  writeStream.end();
});

Geben Sie Pipelines ein

Pipelines vereinfachen die Stream-Zusammensetzung und Fehlerbehandlung.

const { pipeline } = require('stream/promises');
const fs = require('fs');
const zlib = require('zlib');

async function compressFile(input, output) {
  await pipeline(
    fs.createReadStream(input),
    zlib.createGzip(),
    fs.createWriteStream(output)
  );
  console.log('Compression complete');
}

compressFile('big.file', 'big.file.gz').catch(console.error);

Benutzerdefinierte Transformationsstreams

const { Transform } = require('stream');

const upperCaseTransform = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});

pipeline(
  process.stdin,
  upperCaseTransform,
  process.stdout
).catch(console.error);

Leistungstipps

1. Verwenden Sie highWaterMark, um die Pufferung zu steuern
2. Implementieren Sie stream.Readable.from() für asynchrone Iterables
3. Nutzen Sie stream.finished() zur Bereinigung

Häufige Fallstricke

1. Gegendruck ignorieren
2. Misshandlungsfehler
3. Versäumnis, beschreibbare Streams zu beenden

Streams glänzen mit großen Datensätzen oder Echtzeit-Datenverarbeitung. Beherrschen Sie sie für skalierbare Node.js-Anwendungen.

Prost?

Das obige ist der detaillierte Inhalt vonNode.js-Streams und Pipelines beherrschen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!