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

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

왜 스트림인가?

1. 메모리 효율성
2. 시간 효율성
3. 합성

스트림 유형

1. 가독성
2. 쓰기 가능
3. 듀플렉스
4. 변신

기본 스트림 사용량

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

성능 팁

1. highWaterMark를 사용하여 버퍼링 제어
2. 비동기 반복 가능 항목을 위한 stream.Readable.from() 구현
3. 정리를 위해 stream.finished() 활용

일반적인 함정

1. 배압 무시
2. 잘못된 오류
3. 쓰기 가능한 스트림 종료 무시

스트림은 대규모 데이터 세트 또는 실시간 데이터 처리로 빛을 발합니다. 확장 가능한 Node.js 애플리케이션을 위해 마스터하세요.

건배?

위 내용은 Node.js 스트림과 파이프라인 마스터하기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!