[module] Node.js - stream 모듈 - 스트리밍 데이터 처리.

1. stream 모듈 예제
2. stream 모듈 정의
3. stream 모듈 구문
4. stream 모듈 메서드 (읽기 가능 stream용)
5. stream 모듈 메서드 (쓰기 가능 stream용)

stream 모듈 예제

1. C:\User\사용자명\hz.js 생성.

 

var http = require('http');

http.createServer(function (req, res) {

    res.writeHead(200, {'Content-Type': 'text/html'});

    res.write('Homzzang.com');

    res.end();

}).listen(8080);

 

---

2. CMD 모드 실행 후, 아래 명령어 입력.

 

C:\User\사용자명>node hz.js

 

결과값: Homzzang.com 

stream 모듈 정의

 

스트리밍 데이터를 처리하는 방법을 제공.

 

---

※ 스트림에는 읽기 및 쓰기의 두 가지 유형 존재.

읽기 가능 스트림 예제: 

http.createServer() 메서드로 작업 할 때 얻는 응답 객체.

쓰기 가능 스트림 예제:

http.createServer() 메서드로 작업 할 때 얻는 요청 객체.

 

stream 모듈 구문

 

var stream = require('stream');

 

---

PS.

일부 메서드 (예: http.createServer() 메서드)는 읽기/쓰기 가능한 스트림 개체를 반환하며, 이 경우 stream 모듈을 따로 포함 안 해도 됨.

 

stream 모듈 메서드 (읽기 가능 stream용)

 

isPaused()

읽을 수있는 스트림의 상태가 일시 중지 된 경우 true 반환하고, 그렇지 않으면 false 반환.

 

pause()

읽을 수있는 스트림을 일시 중지.

 

pipe()

읽기 가능한 스트림을 지정된 쓰기 가능한 스트림으로 변환.

 

read()

읽을 수있는 스트림의 지정된 부분을 반환.

 

resume()

일시 중지 된 스트림을 다시 시작.

 

setEncoding()

읽을 수있는 스트림의 문자 인코딩을 설정.

 

unpipe()

pipe() 메서드로 인해 읽을 수있는 스트림을 쓰기 가능한 스트림으로 변환하는 것을 중지.

 

unshift()

일부 지정된 데이터를 내부 버퍼로 다시 푸시.

 

wrap()

이전 Node.js 버전에서 만든 스트림을 읽는 걸 도움.

 

stream 모듈 메서드 (쓰기 가능 stream용)

 

cork()

쓰기 가능한 스트림을 중지하고 기록된 모든 데이터는 메모리에 버퍼링 됨.

 

end()

쓰기 가능한 스트림을 종료.

 

setDefaultEncoding()

쓰기 가능한 스트림의 인코딩을 설정.

 

uncork()

cork() 메서드가 호출 된 이후 버퍼링 된 모든 데이터를 플러시 (=  데이터를 임시 저장소에서 영구적인 데이터 저장소로 전송) 함.

write()

스트림에 데이터를 쓰기.