백프레셔와 파이핑
pipeTo와 pipeThrough로 흐름을 제어합니다.
백프레셔와 파이핑은(는) CoddyKit의 무료 JavaScript Academy 강의입니다. 이것은 4개 중 4번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 JavaScript Academy 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. JavaScript Academy 강의에는 총 4개의 강의가 포함되어 있습니다.
배압 문제
생산자가 소비자가 처리할 수 있는 속도보다 빠르게 데이터를 생성하면 메모리가 가득 찹니다. 배압은 느린 소비자가 빠른 생산자에게 속도를 늦추라고 알리는 메커니즘입니다.
WritableStream
WritableStream은 청크를 써 넣는 대상입니다. 이 스트림의 write(chunk) sink 메서드는 비동기일 수 있으며, 다음 청크를 받을 준비가 되었음을 알립니다.
const sink = new WritableStream({
write(chunk) {
console.log("writing", chunk);
}
});writer 가져오기
getWriter()는 쓰기 가능 스트림을 잠그고 write(), close(), ready 프로미스를 가진 writer를 반환합니다.
const writer = sink.getWriter();
await writer.write("hello");
await writer.close();ready 신호
쓰기 전에 writer.ready를 기다리세요. 스트림이 더 많은 데이터를 받을 수 있을 때 이 프로미스가 이행됩니다. 이것이 실제로 작동하는 배압입니다.
await writer.ready;
await writer.write(chunk);pipeTo
readable.pipeTo(writable)는 소스를 대상에 연결하고 배압을 자동으로 관리합니다. 파이핑이 완료되면 이 메서드가 반환한 프로미스가 이행됩니다.
await readableStream.pipeTo(writableStream);
console.log("done piping");pipeThrough
pipeThrough(transform)은 소스와 sink 사이에 변환을 삽입하고 변환된 읽기 가능 스트림을 반환합니다. 여러 단계를 연결해 파이프라인을 구성할 수 있습니다.
sourceStream
.pipeThrough(new TextDecoderStream())
.pipeThrough(parser)
.pipeTo(consumer);상한 표시
대기열 전략의 highWaterMark는 배압이 작동하기 전에 대기열에 들어갈 수 있는 청크 수를 설정합니다. 처리량과 메모리 사이의 균형을 맞추도록 값을 조정하세요.
new ReadableStream(source, new CountQueuingStrategy({ highWaterMark: 4 }));desiredSize
컨트롤러의 desiredSize는 대기열에 남은 공간이 얼마나 되는지 생산자에게 알려 줍니다. 값이 0 이하가 되면 더 이상 큐에 넣지 마세요.
pull(controller) {
while (controller.desiredSize > 0) {
controller.enqueue(nextChunk());
}
}파이프 중단
{ signal }을 pipeTo에 전달하면 AbortController로 전체 파이프라인을 중단할 수 있습니다.
const ctrl = new AbortController();
readable.pipeTo(writable, { signal: ctrl.signal });
ctrl.abort();파이프 옵션
pipeTo는 preventClose, preventAbort, preventCancel을 받아 양 끝 사이에서 오류와 완료를 전파하는 방식을 제어합니다.
readable.pipeTo(writable, { preventClose: true });전체 파이프라인
모든 것을 연결해 보겠습니다. 바이트를 가져오고, 디코딩하고, 변환한 다음 sink에 씁니다. 이 모든 과정에서 흐름 제어가 자동으로 이루어집니다.
const res = await fetch("/data");
await res.body
.pipeThrough(new TextDecoderStream())
.pipeThrough(lineSplitter)
.pipeTo(uiSink);빠른 확인
배압을 테스트해 봅니다.
복습: 배압과 파이핑
WritableStream과 writer를 사용하고, 배압을 위해 ready를 기다리고, pipeTo/pipeThrough로 스트림을 연결하고, highWaterMark를 조정하고 desiredSize를 확인하고, 파이프라인을 중단하는 방법을 배웠습니다. 이것으로 Streams API를 모두 마쳤습니다.
자주 묻는 질문
“백프레셔와 파이핑” 강의는 무료인가요?
네 — “백프레셔와 파이핑” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 JavaScript Academy 강의 전체를 잠금 해제할 수 있습니다. JavaScript Academy 강의에는 총 4개의 강의가 포함되어 있습니다.
“백프레셔와 파이핑”에서 뭘 배우나요?
pipeTo와 pipeThrough로 흐름을 제어합니다. 브라우저에서 직접 실행하는 실습 코드로 JavaScript Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.
JavaScript Academy을(를) 시작하는 데 경험이 필요한가요?
사전 경험은 필요하지 않습니다. CoddyKit의 JavaScript Academy은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 4번째 강의입니다.
“백프레셔와 파이핑” 강의는 얼마나 걸리나요?
대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.
이 JavaScript Academy 강의에서 코드를 작성하고 실행할 수 있나요?
네. 모든 JavaScript Academy 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.
이 강의의 모든 강의
- 읽을 수 있는 스트림
- Fetch 응답 스트리밍하기
- 변환 스트림
- 백프레셔와 파이핑