백프레셔와 연산자
리액티브 스트림을 변환하고 제어해 보세요.
백프레셔와 연산자은(는) CoddyKit의 무료 Spring Boot 4 Microservices & REST APIs 강의입니다. 이것은 4개 중 4번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Spring Boot 4 Microservices & REST APIs 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Spring Boot 4 Microservices & REST APIs 강의에는 총 4개의 강의가 포함되어 있습니다.
이 강의의 일부는 아직 번역되지 않았으며 영어로 표시됩니다.
Operators Build Pipelines
Reactive operators chain together to form a processing pipeline. Each operator returns a new publisher describing the next step.
Common ones: map, flatMap, filter, take, buffer.
map vs flatMap
map transforms each item synchronously (1-to-1). flatMap transforms each item into another publisher and flattens the results — use it for async work.
Using map
map for pure, synchronous transformations.
Flux<Integer> lengths = Flux.just("a", "bb", "ccc")
.map(String::length);
lengths.subscribe(System.out::println); // 1, 2, 3Using flatMap
flatMap when each item triggers an async call returning a Mono or Flux.
Flux<User> users = Flux.just("1", "2", "3")
.flatMap(id -> userService.findById(id));
users.subscribe(System.out::println);flatMap Ordering
flatMap interleaves results as inner publishers complete, so order is not guaranteed. Use concatMap to preserve order.
Flux<User> ordered = Flux.just("1", "2", "3")
.concatMap(id -> userService.findById(id));What is Backpressure
Backpressure is the mechanism by which a slow consumer tells a fast producer to slow down.
Subscribers request a number of items; the producer only emits up to that demand. This prevents memory overflow.
Limiting with take
take requests only the first N items, then cancels the upstream.
Flux<Long> first3 = Flux.interval(Duration.ofMillis(100))
.take(3);
first3.subscribe(System.out::println); // 0, 1, 2Buffering Items
buffer groups items into lists, useful for batching.
Flux<List<Integer>> batches = Flux.range(1, 10)
.buffer(3);
batches.subscribe(System.out::println);
// [1,2,3], [4,5,6], [7,8,9], [10]onBackpressureBuffer
When a producer is faster than the consumer, strategies control overflow: buffer, drop, or latest.
Flux.interval(Duration.ofMillis(1))
.onBackpressureBuffer(100)
.subscribe(System.out::println);Throttling with limitRate
limitRate caps how many items are requested upstream at a time, applying controlled backpressure.
Flux.range(1, 1000)
.limitRate(10)
.subscribe(System.out::println);Combining Operators
Real pipelines chain several operators to filter, transform, and limit a stream.
Flux.range(1, 100)
.filter(n -> n % 2 == 0)
.map(n -> n * n)
.take(5)
.subscribe(System.out::println);Quick Check
Test your understanding of operators and backpressure.
Recap
You learned about operators and backpressure:
map= sync transform;flatMap= async, unordered;concatMap= async, ordered- Backpressure lets slow consumers control fast producers
take,buffer,limitRateshape the stream
자주 묻는 질문
“백프레셔와 연산자” 강의는 무료인가요?
네 — “백프레셔와 연산자” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Spring Boot 4 Microservices & REST APIs 강의 전체를 잠금 해제할 수 있습니다. Spring Boot 4 Microservices & REST APIs 강의에는 총 4개의 강의가 포함되어 있습니다.
“백프레셔와 연산자”에서 뭘 배우나요?
리액티브 스트림을 변환하고 제어해 보세요. 브라우저에서 직접 실행하는 실습 코드로 Spring Boot 4 Microservices & REST APIs을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.
Spring Boot 4 Microservices & REST APIs을(를) 시작하는 데 경험이 필요한가요?
사전 경험은 필요하지 않습니다. CoddyKit의 Spring Boot 4 Microservices & REST APIs은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 4번째 강의입니다.
“백프레셔와 연산자” 강의는 얼마나 걸리나요?
대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.
이 Spring Boot 4 Microservices & REST APIs 강의에서 코드를 작성하고 실행할 수 있나요?
네. 모든 Spring Boot 4 Microservices & REST APIs 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.