node.js 스트림의 기본 사항

비동기적이고 이벤트 중심 인 node.js는 I/O 바운드 작업에서 탁월합니다. Node.js 스트림을 활용하면 더 작은 청크에서 데이터를 효율적으로 처리하여 이러한 작업을 크게 단순화합니다. 스트림의 세계를 탐구하고 I/O를 간소화하는 방법을 살펴 보겠습니다. 주요 개념 :

스트림은 읽기 가능, 쓰기 가능 또는 이중으로 분류됩니다 (읽기 가능하고 쓰기 가능). 읽기 쉬운 스트림은 소스에서 데이터를 가져옵니다. 쓰기 가능한 스트림은 대상으로 데이터를 보냅니다

함수는 매우 귀중하며 수동 흐름 관리없이 소스와 대상 사이의 원활한 데이터 전송을 용이하게합니다. , , 및

와 같은 메소드는 데이터 흐름에 대한 세분화 제어를 제공하여 스트림 기능을 향상시킵니다. 스트림 이해 : 스트림은 UNIX 파이프와 유사하므로 소스에서 대상으로 쉽게 데이터를 전송할 수 있습니다. 기본적으로 스트림은 특수한 방법을 갖는

입니다. 구현 된 방법은 스트림이 읽기 가능, 쓰기 가능 또는 이중인지 여부를 결정합니다. 읽기 쉬운 스트림은 데이터 입력을 제공합니다. 쓰기 가능한 스트림은 데이터 출력을 처리합니다 당신은 이미 node.js에서 스트림을 만났을 것입니다. HTTP 서버에서 요청은 읽기 쉬운 스트림이며 응답은 쓰기 가능한 스트림입니다. 모듈은 읽기 가능하고 쓰기 가능한 파일 스트림 기능을 모두 제공합니다. 이 기사는 읽기 쉬운 스트림에 중점을 둡니다. 이중 스트림은 그 범위를 벗어납니다.

• 읽기 쉬운 스트림 :
읽기 쉬운 스트림은 소스 (파일, 메모리 버퍼 또는 다른 스트림)에서 데이터를 읽습니다.
• 이기 때문에 다양한 이벤트를 유발합니다. 우리는이 이벤트를 사용하여 스트림과 상호 작용합니다
스트림에서 읽는 것 :
• 가장 일반적인 접근법은 이벤트를 듣고 콜백을 첨부하는 것입니다. 데이터를 사용할 수 있으면 이벤트가 발생하여 콜백을 실행합니다. pipe()
는 읽기 쉬운 스트림을 만듭니다. 처음에는 정적으로
• 이벤트 리스너를 부착하면 흐르기 시작합니다. 그런 다음 데이터 청크가 콜백으로 전달됩니다. 이벤트의 빈도는 스트림 구현에 의해 결정됩니다 (예 : HTTP 요청은 몇 개의 KB 당 이벤트가 발생할 수 있고 파일 스트림은 한 줄에 따라 방출 될 수 있음). Readable.pause(). Readable.resume() 이벤트는 데이터의 끝을 나타냅니다 또는 모든 데이터를 읽을 때까지 스트림 인스턴스에서 반복적으로 readable.unpipe()를 호출하십시오.

  const fs = require('fs');
  const readableStream = fs.createReadStream('file.txt');
  let data = '';
  readableStream.on('data', (chunk) => { data += chunk; });
  readableStream.on('end', () => { console.log(data); });

  내부 버퍼에서 데이터를 검색합니다. 데이터가 남아 있지 않으면

  를 반환합니다. 이벤트는 데이터 가용성을 나타냅니다 <🎜 🎜> <<> 설정 인코딩 설정 : read() <🎜 🎜> 데이터는 일반적으로 null 객체입니다. 문자열의 경우 <,> : readable를 사용하십시오

  이것은 데이터를 UTF-8로 해석하여 콜백에 문자열로 전달합니다. <🎜 🎜>. <🎜 🎜> <<> 배관 :

  <🎜 🎜> 배관은 소스와 대상 사이의 데이터 전송을 단순화합니다 : <🎜 🎜> <🎜 🎜> <<>는 데이터 흐름을 자동으로 처리합니다 <<> 체인 : <🎜 🎜> <🎜 🎜> 스트림은 묶을 수 있습니다

  이 압축 압축 <🎜 🎜>는 결과를 <🎜 <p>. <🎜 🎜>에 씁니다 <code>Buffer</code> <<> 추가 읽기 쉬운 스트림 방법 : <code>Readable.setEncoding()</code> <🎜 🎜> </p> <pre class='brush:php;toolbar:false;'>const fs = require('fs'); const readableStream = fs.createReadStream('file.txt'); let data = ''; let chunk; readableStream.on('readable', () => { while ((chunk = readableStream.read()) !== null) { data += chunk; } }); readableStream.on('end', () => { console.log(data); });

  로그인 후 복사
  <<> : 스트림을 일시 중지합니다

  <<> : 일시 정지 스트림을 재개합니다

  <<> : 파이프에서 대상 스트림을 제거합니다

  <🎜 🎜> <<> 쓰기 가능한 스트림 : <🎜 🎜> 쓰기 가능한 스트림은 대상으로 데이터를 보냅니다. 읽기 쉬운 스트림과 마찬가지로 <🎜 <입니다

  <<> 스트림에 쓰기 : <🎜 🎜> <🎜 🎜>

  를 사용하여 데이터를 보내려면 : <🎜 🎜>

  const fs = require('fs');
  const readableStream = fs.createReadStream('file.txt');
  let data = '';
  readableStream.setEncoding('utf8');
  readableStream.on('data', (chunk) => { data += chunk; });
  readableStream.on('end', () => { console.log(data); });

  <<> 성공을 나타내는 부울을 반환합니다. False 인 경우 스트림이 일시적으로 가득 차 있습니다. 더 많이 쓰기 전에

  이벤트를 기다리십시오 <🎜 🎜> <<> 데이터 종료 : <🎜 🎜> pipe()

  전화 <🎜 🎜>는 데이터의 끝을 알리려면 전화를 끊습니다. 모든 데이터가 플러시 된 후에

  이벤트가 방출됩니다. <<> 중요한 서면 스트림 이벤트 : <🎜 🎜>

  <<> : 오류를 나타냅니다.

  <🎜 🎜> <<> : 읽기 쉬운 스트림이 파이프를 할 때 방출됩니다

  const fs = require('fs');
  const readableStream = fs.createReadStream('file1.txt');
  const writableStream = fs.createWriteStream('file2.txt');
  readableStream.pipe(writableStream);

  : 가 읽을 수있는 스트림에서 호출 될 때 방출됩니다. input.txt.gz output.txt 결론 : 스트림은 Node.js의 강력한 기능으로 I/O 효율성을 향상시킵니다. 스트림, 배관 및 체인 이해를 이해하면 깨끗하고 성능이 좋은 코드를 작성할 수 있습니다. node.js streams faq :
  node.js streams 란 무엇입니까?
  전체 데이터 세트를 메모리에로드하는 것을 피하고 효율적이고 점진적인 데이터 처리를 허용하는 객체입니다.
  • Readable.pause() node.js 스트림의 주요 유형?
  읽기 가능, 쓰기 가능, 듀플렉스 및 변환.
  • Readable.resume() 읽기 쉬운 스트림 생성?
  • 를 사용하고 readable.unpipe() 메소드를 구현하십시오.
  읽기 쉬운 스트림의 일반적인 사용 사례?

  큰 파일 읽기, HTTP 요청에서 데이터 처리, 실시간 데이터 처리.

  쓰기 가능한 스트림 생성?

  를 사용하고 EventEmitter 메소드를 구현하십시오.

• 쓰기 가능한 스트림의 일반적인 사용? 파일에 데이터를 저장하고 서비스로 데이터를 보냅니다.

  이중 스트림?
는 읽을 수 있고 쓰기 가능한 기능을 결합합니다

• 스트림 변환 스트림? 데이터가 통과 할 때 데이터 수정 (예 : 압축, 암호화). 스트림간에 배관 데이터?

메소드를 사용하십시오

• node.js streams로 작업하기위한 모범 사례? 대형 데이터 세트에 사용하고 오류 및 배압을 처리하고 약속 기반 작업에 대해 를 고려하십시오.

위 내용은 node.js 스트림의 기본 사항의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!