Spring WebFlux y Reactor Core
Construya API REST reactivas utilizando Spring WebFlux y trabaje con `Mono` y `Flux` de Reactor Core.
Spring WebFlux y Reactor Core es una lección gratuita de Spring Boot 4 Complete Guide en CoddyKit. Esta es la lección 2 de 4. Puedes leer la lección completa abajo gratuitamente — luego la practicas en el navegador con un editor de código integrado y un tutor de IA 24/7. Forma parte de la ruta de aprendizaje de Spring Boot 4 Complete Guide, y tu progreso se sincroniza en la web y la app de CoddyKit. El curso de Spring Boot 4 Complete Guide incluye 4 lecciones en total.
Partes de esta lección aún no han sido traducidas y se muestran en inglés.
Reactive Web with Spring WebFlux
Welcome to Spring WebFlux! This framework is Spring's answer to building reactive, non-blocking web applications.
Unlike traditional Spring MVC which uses a servlet-based, blocking model, WebFlux is designed for concurrency and high throughput with fewer threads.
It's perfect for microservices and applications needing to handle many concurrent connections efficiently.
Diving into Reactor Core
At the heart of Spring WebFlux lies Reactor Core. Reactor is a reactive programming library that implements the Reactive Streams specification.
It provides two key types for handling asynchronous data streams:
Mono: For sequences of 0 or 1 item.Flux: For sequences of 0 to N items.
These types represent publishers that emit data, which subscribers then consume.
`Mono`: Zero or One Element
A Mono is a specialized Publisher that can emit at most one item, or complete without emitting any item, or emit an error.
Think of it as an asynchronous container for a single value. It's ideal for operations that return a single result, like fetching a user by ID or performing a single update.
Your First `Mono`
Let's see Mono in action. We create a Mono and then subscribe() to it. The subscribe() method triggers the data flow.
import reactor.core.publisher.Mono;
public class Main {
public static void main(String[] args) {
Mono<String> greetingMono = Mono.just("Hello, Mono!");
// Subscribe to the Mono to consume the data
greetingMono.subscribe(
data -> System.out.println(data), // onNext consumer
error -> System.err.println("Error: " + error), // onError consumer
() -> System.out.println("Mono completed.") // onComplete callback
);
}
}`Flux`: Zero to Many Elements
A Flux is a Publisher that can emit 0 to N items over time, and then optionally terminate with a completion signal or an error.
It's perfect for handling streams of data, like a list of products, real-time events, or database query results that return multiple rows.
Your First `Flux`
Here's an example of creating a Flux from a list of items. Just like Mono, you need to subscribe() to start the emission of data.
import reactor.core.publisher.Flux;
import java.util.Arrays;
import java.util.List;
public class Main {
public static void main(String[] args) {
List<String> fruits = Arrays.asList("Apple", "Banana", "Cherry");
Flux<String> fruitFlux = Flux.fromIterable(fruits);
// Subscribe to the Flux to consume the data stream
fruitFlux.subscribe(
data -> System.out.println(data), // onNext consumer for each item
error -> System.err.println("Error: " + error), // onError consumer
() -> System.out.println("Flux completed.") // onComplete callback
);
}
}Building Reactive Endpoints
Spring WebFlux seamlessly integrates with Reactor Core's Mono and Flux. You can define your REST endpoints to return these reactive types.
When a WebFlux controller method returns a Mono or Flux, Spring handles the subscription and streaming of data automatically, allowing for non-blocking I/O.
Endpoint Returning `Mono`
Here's how you'd create a simple WebFlux endpoint that returns a Mono<String>. This endpoint would respond with a single string asynchronously.
Note: This code snippet is part of a Spring Boot application and cannot be run in isolation.
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;
@RestController
public class HelloController {
@GetMapping("/hello-mono")
public Mono<String> getHelloMono() {
// Simulate a non-blocking operation that returns a single greeting
return Mono.just("Hello from Mono endpoint!");
}
}Endpoint Returning `Flux`
For endpoints that need to stream multiple items, you can return a Flux<T>. WebFlux will handle sending these items as they become available, often using Server-Sent Events (SSE).
Note: This code snippet is part of a Spring Boot application and cannot be run in isolation.
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import java.time.Duration;
@RestController
public class HelloController {
@GetMapping(value = "/hello-flux", produces = "text/event-stream")
public Flux<String> getHelloFlux() {
// Emit 5 items, one every second
return Flux.interval(Duration.ofSeconds(1))
.map(sequence -> "Item " + sequence + " from Flux!")
.take(5);
}
}Check Your Knowledge
Let's test your understanding of Spring WebFlux and Reactor Core.
Recap: WebFlux & Reactor Core
In this lesson, you've learned about the core components of reactive programming with Spring Boot:
- Spring WebFlux: The non-blocking web framework.
- Reactor Core: The underlying library providing reactive types.
Mono: For handling 0 or 1 data item.Flux: For handling 0 to N data items.
You also saw how to define reactive endpoints in WebFlux controllers by returning Mono and Flux.
Aprende Java con un tutor de IA — gratis
Escribe y ejecuta código real en tu navegador, obtén ayuda instantánea de un tutor de IA disponible 24/7 y continúa donde lo dejaste en la web o en la aplicación.
- Cursos
- 21
- Lecciones
- 84
Preguntas frecuentes
¿La lección «Spring WebFlux y Reactor Core» es gratis?
Sí — el texto completo de «Spring WebFlux y Reactor Core» es gratis para leer aquí en la web. Para practicarla de forma interactiva (editor de código integrado y tutor de IA 24/7) y desbloquear el resto del curso de Spring Boot 4 Complete Guide, actualiza a CoddyKit PRO. El curso de Spring Boot 4 Complete Guide incluye 4 lecciones en total.
¿Qué aprenderé en «Spring WebFlux y Reactor Core»?
Construya API REST reactivas utilizando Spring WebFlux y trabaje con `Mono` y `Flux` de Reactor Core. Practicas Spring Boot 4 Complete Guide con código real que ejecutas directamente en el navegador, y un tutor de IA 24/7 responde tus preguntas mientras trabajas en la lección.
¿Necesito experiencia previa para empezar Spring Boot 4 Complete Guide?
No se requiere experiencia previa. Spring Boot 4 Complete Guide en CoddyKit está estructurado para principiantes hasta estudiantes avanzados, así que puedes empezar aquí o desde el inicio y avanzar a tu ritmo. Esta es la lección 2 de 4.
¿Cuánto tiempo toma la lección «Spring WebFlux y Reactor Core»?
La mayoría de las lecciones de CoddyKit toman alrededor de 5–10 minutos. Cada una es compacta e interactiva, así que avanzas constantemente y retomas exactamente por donde dejaste en la web y la app.
¿Puedo escribir y ejecutar código en esta lección de Spring Boot 4 Complete Guide?
Sí. Cada lección de Spring Boot 4 Complete Guide incluye un editor de código integrado, así que escribes y ejecutas código real directamente en tu navegador y obtienes retroalimentación instantánea de IA — sin configuración local necesaria.
Todas las lecciones de este curso
- Introducción a la programación reactiva
- Spring WebFlux y Reactor Core
- Acceso e integración de datos reactivos
- Control de presión y gestión de errores en flujos reactivos