Node.js_node.js의 스트림 소개

플로우란 무엇인가요?

스트림에 관해 말하자면, *nix 개념이 포함됩니다: 파이프 - *nix에서 스트림은 셸에서 |(파이프 문자)를 통해 연결될 수 있는 데이터로 구현됩니다. 프로세스(stdout)는 다음 프로세스의 입력(stdin)으로 직접 사용될 수 있습니다.

Node에서는 스트림(스트림)이라는 개념과 유사하며, 이는 데이터 스트림이 연결되는 능력을 나타냅니다.

파이프

스트리밍의 핵심은 .pipe() 메소드에 있습니다. 브리지 기능은 데이터 스트림(업스트림/다운스트림 또는 읽기/쓰기 스트림)의 양쪽 끝이 .pipe() 메서드를 사용하여 브리지된다는 것입니다.

의사코드의 표현형식은 다음과 같습니다.

코드 복사 코드는 다음과 같습니다.

//upstream.pipe(다운스트림)
Readable.pipe(쓰기 가능);

스트림 분류

이 글은 Node v0.4 이전의 소위 "클래식" 흐름을 논의하려는 의도가 아닙니다. 그런 다음 스트림은 여러 범주로 나뉩니다(모든 추상 인터페이스:

1.stream.Readable 읽기 가능한 스트림(_read 메소드 구현 필요, 데이터 스트림 읽기의 세부 사항에 초점이 맞춰짐
2.stream.Writable 쓰기 가능한 스트림(_write 메서드를 구현해야 하며 데이터 스트림 쓰기 세부 사항에 중점을 둡니다.
3.stream.Duplex 읽기/쓰기 스트림(위 두 인터페이스를 구현해야 함, 위 두 인터페이스의 세부 사항에 집중하세요
4.stream.Transform Duplex에서 상속됨(_transform 메서드 구현 필요, 초점은 데이터 블록 처리에 있음

요약:

1) .pipe()의 소유자는 읽기 가능한 스트림(이에 국한되지 않음) 기능을 가지고 있어야 합니다. 여기에는 일련의 '읽기 가능'/'데이터'/'종료'/'닫기'/'오류' 이벤트가 있습니다. 구독은 또한 호출을 위한 .read()/.pause()/.resume()과 같은 일련의 메서드를 제공합니다. 2) .pipe()의 매개변수에는 쓰기 가능한 스트림 기능이 있어야 합니다(그러나 이에 국한되지 않음). 여기에는 액세스를 위한 'drain'/'pipe'/'unpipe'/'error'/'finish' 이벤트가 있으며 . write()/.end() 및 기타 메소드를 사용하여
를 호출할 수 있습니다.

대체

조금이라도 불안한 마음이 드시나요? 걱정하지 마십시오. 인간의 언어를 사용하는 하위 수준 코더로서 Stream을 분리하여 이에 대해 이야기하겠습니다.

Node.js 소스 코드

의 Stream 클래스는 다음과 같이 정의됩니다.

코드 복사 코드는 다음과 같습니다.

var EE = require('events').EventEmitter;
var util = require('util');
util.inherits(Stream, EE);

함수 스트림() {
EE.call(this);
}

보시다시피 본질적으로 Stream은 EventEmitter입니다. 즉, 이벤트 기반 기능(.emit/.on...)이 있음을 의미합니다. 우리 모두 알고 있듯이 "Node.js는 V8 기반의 이벤트 중심 플랫폼"으로, 이벤트 중심 스트리밍 프로그래밍을 구현하고 Node.js와 동일한 비동기 콜백 특성을 가지고 있습니다.

예를 들어 읽기 가능 스트림에는 읽기 가능 이벤트가 있습니다. 일시 중지된 읽기 전용 스트림에서는 데이터 블록을 읽을 준비가 되어 있으면 구독자에게 전송됩니다(읽기 가능 스트림이란 무엇입니까?) ? Express) req, ftp 또는 다중 형식 업로드 구성 요소의 req.part, 시스템의 표준 입력 process.stdin 등). 읽을 수 있는 이벤트를 사용하면 셸 명령 출력을 처리하는 파서와 같은 도구를 만들 수 있습니다.

코드 복사 코드는 다음과 같습니다.

process.stdin.on('읽기 가능', function(){
var buf = process.stdin.read();
if(buf){
var 데이터 = buf.toString();
// 데이터 구문 분석 중 ...                                                }
});

다음과 같이 전화하세요.

코드 복사 코드는 다음과 같습니다.

head -10 some.txt | 노드 파서.js

읽기 가능한 스트림의 경우 클래식 소켓 예에서와 같이 해당 데이터 및 종료 이벤트를 구독하여 데이터 덩어리를 얻고 스트림이 소진되면 알림을 받을 수도 있습니다.

코드 복사 코드는 다음과 같습니다.

req.on('connect', function(res, 소켓, 헤드) {
소켓.온('데이터', 함수(청크) {
console.log(chunk.toString());
});
소켓.온('끝', 함수() {
       Proxy.close();
});
});

읽기 가능한 스트림 상태 전환
Readable 스트림에는 흐름 모드(torrent)와 일시 중지 모드(pause)의 두 가지 상태가 있다는 점에 유의해야 합니다. 전자는 전혀 중지할 수 없으며 파이프된 사람에게 계속 공급합니다. 후자는 다운스트림이 명시적으로 Stream.read() 요청을 호출하여 데이터 블록을 읽을 때까지 일시 중지됩니다. 읽기 가능 스트림은 초기화될 때 일시 중지 모드에 있습니다.

이 두 상태는 서로 전환될 수 있으며, 그 중

다음 동작 중 하나라도 발생하면 일시정지가 흐르는 동작으로 변경됩니다.

1. 읽기 가능한 스트림에 데이터 이벤트 구독을 추가합니다
2. Readable에서 .resume()을 호출하여 흐름을 명시적으로 활성화합니다
3. 읽기 가능 스트림의 .pipe(writable)를 호출하여 쓰기 가능 스트림에 연결합니다

다음 동작 중 하나라도 발생하면 흐름이 일시 중지로 돌아갑니다.

1.읽기 가능한 스트림은 아직 어떤 스트림에도 파이프되지 않았습니다. 조정 가능한 .pause()를 사용하여 일시 중지할 수 있습니다
2. 읽기 가능 스트림이 스트림으로 파이프되었습니다. 모든 데이터 이벤트 구독을 제거하고 .unpipe() 메서드를 호출하여 다운스트림 스트림과의 관계를 하나씩 해제해야 합니다.

훌륭한 활용

스트림의 비동기 특성과 결합하여 다음과 같은 애플리케이션을 작성할 수 있습니다. 사용자 A의 출력을 사용자 B의 페이지 출력에 직접 연결합니다.

코드 복사 코드는 다음과 같습니다.

router.post('/post', function(req, res) {
var Destination = req.headers['destination']; //보내는 사람
캐시[대상] = 요청;
//예, 반환되지 않으므로 Ajax 요청을 하는 것이 가장 좋습니다
});

사용자 B가 요청하는 경우:

코드 복사 코드는 다음과 같습니다.

router.get('/inbox', function(req, res){
var user = req.headers['user'];
캐시.find(user, function(err, PreviousReq){ //이전에 저장된 req를 찾습니다
      var form = new multiparty.Form();
        form.parse(previousReq); // 파일이 있습니다
       form.on('부분', 함수(부분) {
              part.pipe(res) //스트리밍 방식이 좋습니다:)

              part.on('error', 함수(err) {
console.log(err);
                 message.setRequestDone(uniqueID);
                     res.end(err) 반환;
            });
        });
});
});

참고자료

스트림을 사용하여 노드 프로그램을 작성하는 방법: 스트림 핸드북