Spring Boot 4 Microservices & REST APIs · Aula

Contrapressão e operadores

Transforme e controle fluxos reativos.

Aula 4 de 413 etapas

Contrapressão e operadores é uma aula grátis de Spring Boot 4 Microservices & REST APIs no CoddyKit. Esta é a aula 4 de 4. Você pode ler a aula completa abaixo gratuitamente — depois pratica ao vivo no navegador com um editor de código integrado e um tutor de IA 24/7. Faz parte do caminho de aprendizado de Spring Boot 4 Microservices & REST APIs, e seu progresso é sincronizado entre a web e o app CoddyKit. O curso de Spring Boot 4 Microservices & REST APIs inclui 4 aulas no total.

Partes desta aula ainda não foram traduzidas e aparecem em inglês.

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, 3

Using 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, 2

Buffering 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, limitRate shape the stream
Grátis para começar

Aprenda Java com um tutor de IA — grátis

Escreva e execute código real no seu navegador, obtenha ajuda instantânea de um tutor de IA 24/7 e continue de onde parou na web ou no app.

Cursos
24
Aulas
93

Perguntas Frequentes

A aula “Contrapressão e operadores” é grátis?

Sim — o texto completo de “Contrapressão e operadores” é grátis para ler aqui na web. Para praticá-la interativamente (um editor de código integrado e um tutor de IA 24/7) e desbloquear o restante do curso de Spring Boot 4 Microservices & REST APIs, atualize para CoddyKit PRO. O curso de Spring Boot 4 Microservices & REST APIs inclui 4 aulas no total.

O que vou aprender em “Contrapressão e operadores”?

Transforme e controle fluxos reativos. Você pratica Spring Boot 4 Microservices & REST APIs com código prático que executa diretamente no navegador, e um tutor de IA 24/7 responde suas dúvidas enquanto trabalha na aula.

Preciso ter experiência prévia para começar Spring Boot 4 Microservices & REST APIs?

Nenhuma experiência prévia é necessária. Spring Boot 4 Microservices & REST APIs no CoddyKit é estruturado para alunos iniciantes até avançados, então você pode começar aqui ou desde o início e aprender no seu ritmo. Esta é a aula 4 de 4.

Quanto tempo leva a aula “Contrapressão e operadores”?

A maioria das aulas CoddyKit leva cerca de 5–10 minutos. Cada uma é compacta e interativa, então você faz progresso constante e retoma exatamente de onde parou entre web e app.

Posso escrever e executar código nesta aula de Spring Boot 4 Microservices & REST APIs?

Sim. Cada aula de Spring Boot 4 Microservices & REST APIs inclui um editor de código integrado, então você escreve e executa código real direto no navegador e recebe feedback de IA instantaneamente — nenhuma configuração local necessária.

Todas as aulas deste curso

  1. Fundamentos de Mono e Flux
  2. Controladores reativos
  3. WebClient para chamadas reativas
  4. Contrapressão e operadores
← Voltar para Spring Boot 4 Microservices & REST APIs