Node.js 스트림과 파이프라인 마스터하기-JS 튜토리얼-php.cn

Node.js 스트림과 파이프라인 마스터하기

DDD

풀어 주다： 2024-09-19 06:15:33

원래의

1045명이 탐색했습니다.

Mastering Node.js Streams and Pipelines

스트림은 대규모 데이터세트를 효율적으로 처리하는 Node.js의 강력한 기능입니다. 스트림과 파이프라인에 대해 자세히 살펴보겠습니다.

왜 스트림인가?

메모리 효율성
시간 효율성
합성

스트림 유형

가독성
쓰기 가능
듀플렉스
변신

기본 스트림 사용량

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

로그인 후 복사

파이프라인 입력

파이프라인은 스트림 구성과 오류 처리를 단순화합니다.

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

로그인 후 복사

사용자 정의 변환 스트림

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

로그인 후 복사