SpringBoot
Tutorial SpringBoot: Repositorios reactivos
Spring Boot repositorios reactivos: manejo. Aprende a manejar repositorios reactivos en Spring Boot mediante ejemplos prácticos y detallados.
Aprende SpringBoot GRATIS y certifícateLos Repositorios Reactivos en Spring Boot, son una parte esencial de la implementación de un sistema de persistencia de datos para una aplicación que sigue el paradigma de programación reactiva.
En el entorno de Spring, estos repositorios son proporcionados por Spring Data y se basan en la Programación Reactiva, un modelo de programación asincrónica que se ocupa de los flujos de datos y la propagación de cambios. Este enfoque es especialmente útil en aplicaciones con un alto volumen de usuarios o datos, ya que permite manejar de manera eficiente grandes cantidades de datos y afrontar situaciones con alta latencia de una forma no bloqueante.
Dentro de Spring Data, existen proyectos para trabajar con bases de datos de forma reactiva como Spring Data R2DBC para bases de datos relacionales y Spring Data MongoDB Reactive para MongoDB.
Por tanto, para poder usar los repositorios reactivos será necesario uno de estos starters, por ejemplo para trabajar con PostgreSQL:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>r2dbc-postgresql</artifactId>
<scope>runtime</scope>
</dependency>
ReactiveCrudRepository
El ReactiveCrudRepository
es una interfaz de Spring Data que define una serie de operaciones para trabajar de manera reactiva con una base de datos. Esta interfaz forma parte de Spring Data y está diseñada para ser utilizada en aplicaciones con Spring Boot. Proporciona operaciones básicas de CRUD (Create, Read, Update, Delete) de manera no bloqueante y asincrónica.
Al igual que otros repositorios de Spring Data, ReactiveCrudRepository
trabaja con entidades de dominio y se parametriza con el tipo de la entidad y el tipo de su ID. Los métodos proporcionados por esta interfaz retornan objetos de tipo Mono
o Flux
, que son proporcionados por la librería Project Reactor.
Mono<T>
: Representa una secuencia de datos que puede emitir cero o un elemento.Flux<T>
: Representa una secuencia de datos que puede emitir cero, uno o muchos elementos.
Aquí hay un ejemplo de cómo se podría usar ReactiveCrudRepository
con una entidad Book
:
import org.springframework.data.repository.reactive.ReactiveCrudRepository;
import reactor.core.publisher.Mono;
public interface BookRepository extends ReactiveCrudRepository<Book, String> {
Mono<Book> findByTitle(String title);
}
En este caso, BookRepository
extiende de ReactiveCrudRepository
con la entidad Book
y su ID de tipo String
. Además, se define un método personalizado findByTitle
que busca un libro por su título y devuelve un Mono<Book>
, que es una secuencia que puede contener el libro buscado o estar vacía si no se encuentra.
Los métodos que se obtienen al extender ReactiveCrudRepository
incluyen:
save(S entity)
: Guarda una entidad y retorna unMono
con la entidad guardada.findAll()
: Encuentra todas las entidades y retorna unFlux
con las entidades encontradas.findById(ID id)
: Busca una entidad por su ID y retorna unMono
con la entidad encontrada.delete(S entity)
: Borra una entidad y retorna unMono<Void>
cuando se ha completado la operación.
Estos métodos permiten realizar operaciones de base de datos de forma reactiva y no bloqueante, lo que puede mejorar el rendimiento y la escalabilidad de las aplicaciones en escenarios con alta latencia o gran cantidad de usuarios.
Operadores Reactivos
Los Operadores Reactivos son funciones que permiten manipular las secuencias de datos en la programación reactiva. Estos operadores permiten transformar, filtrar, combinar, crear, y de muchas otras formas manipular los flujos de datos de los objetos Flux
y Mono
en Project Reactor, una librería de programación reactiva en Java usada por Spring.
Aquí hay algunos ejemplos de operadores reactivos y cómo se utilizan:
Transformación
Los operadores de transformación modifican los elementos de una secuencia. Por ejemplo, el operador map
aplica una función a cada elemento en el flujo:
Flux<Integer> flux = Flux.just(1, 2, 3)
.map(i -> i * 2); // transforma el flujo a 2, 4, 6
Filtro
Los operadores de filtro eliminan elementos del flujo basándose en algún criterio. El operador filter
permite pasar sólo los elementos que satisfacen una condición dada:
Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5)
.filter(i -> i % 2 == 0); // filtra el flujo a 2, 4
Combinación
Los operadores de combinación unen múltiples flujos en uno solo. Por ejemplo, el operador zip
combina los elementos de varios flujos en un flujo de tuplas:
Flux<Integer> flux1 = Flux.just(1, 2, 3);
Flux<String> flux2 = Flux.just("a", "b", "c");
Flux<Tuple2<Integer, String>> zipped = Flux.zip(flux1, flux2); // combina los flujos a (1,"a"), (2,"b"), (3,"c")
Creación
Los operadores de creación generan un flujo a partir de diversas fuentes de datos. Por ejemplo, el operador just
crea un flujo a partir de uno o más elementos:
Flux<Integer> flux = Flux.just(1, 2, 3); // crea un flujo con los elementos 1, 2, 3
Error
Los operadores de error manejan los errores que pueden ocurrir durante el procesamiento de un flujo. Por ejemplo, el operador onErrorReturn
permite especificar un valor de retorno cuando ocurre un error:
Flux<Integer> flux = Flux.just(1, 2, 3)
.map(i -> {
if (i == 2) {
throw new RuntimeException("Error!");
}
return i;
})
.onErrorReturn(-1); // en caso de error retorna el flujo con el valor -1
Los operadores reactivos son fundamentales para manejar los flujos de datos en la programación reactiva. Permiten realizar operaciones complejas con flujos de datos de manera declarativa y no bloqueante, mejorando la eficiencia y la escalabilidad de las aplicaciones.
Integración con Project Reactor
Project Reactor es una librería para la programación reactiva en el ecosistema de Spring. Proporciona abstracciones para Java que manejan los flujos de datos de forma no bloqueante y respaldan tanto operaciones síncronas como asincrónicas.
Los dos tipos principales que proporciona Project Reactor son Mono
y Flux
:
Mono<T>
: Representa un flujo de datos que emitirá 0 o 1 elemento. Se puede usar cuando se espera que una operación devuelva un solo resultado o ninguno, por ejemplo, al buscar un solo registro en una base de datos.Flux<T>
: Representa una secuencia de 0 a N elementos. Se puede usar cuando se espera que una operación devuelva múltiples resultados, por ejemplo, al realizar una consulta que devuelve varios registros de una base de datos.
Estos tipos son fundamentales en los repositorios reactivos de Spring Data, que los utilizan para representar los resultados de las consultas de base de datos. Por ejemplo, en un ReactiveCrudRepository
, los métodos findById
y findAll
devolverán un Mono
y un Flux
respectivamente.
Aquí hay un ejemplo de cómo se podrían utilizar estos tipos en un ReactiveCrudRepository
:
public interface UserRepository extends ReactiveCrudRepository<User, String> {
Mono<User> findByUsername(String username);
Flux<User> findAllByAge(int age);
}
En este ejemplo, findByUsername
devolverá un Mono<User>
porque se espera que la búsqueda por nombre de usuario devuelva un solo usuario o ninguno. Por otro lado, findAllByAge
devolverá un Flux<User>
porque la búsqueda por edad podría devolver varios usuarios.
Los tipos Mono
y Flux
proporcionan una amplia gama de operadores que permiten transformar, filtrar, combinar y realizar muchas otras operaciones en los flujos de datos. Por ejemplo:
Flux<User> users = userRepository.findAllByAge(20);
Mono<User> user = userRepository.findByUsername("john");
users.map(User::getUsername) // Transforma el flujo de User a un flujo de nombres de usuario.
.subscribe(System.out::println); // Imprime cada nombre de usuario.
user.map(User::getUsername) // Transforma el Mono<User> a un Mono<String> con el nombre de usuario.
.subscribe(System.out::println); // Imprime el nombre de usuario.
La integración con Project Reactor permite a los repositorios reactivos de Spring Data proporcionar una API no bloqueante para las operaciones de base de datos, permitiendo un uso más eficiente de los recursos del sistema en aplicaciones con alta carga o latencia.
Conclusión
Los repositorios reactivos en Spring Boot representan una alternativa importante al enfoque tradicional de bloqueo en las operaciones de base de datos. Permiten a las aplicaciones manejar un gran número de solicitudes concurrentes de manera más eficiente al utilizar los recursos del sistema de manera no bloqueante.
La principal ventaja de utilizar repositorios reactivos es que permiten a las aplicaciones seguir trabajando en otras tareas mientras esperan a que las operaciones de base de datos se completen. Esto puede llevar a una mayor utilización de los recursos del sistema y una mayor capacidad de respuesta, especialmente en escenarios de alta latencia o con un gran número de usuarios concurrentes.
Además, los repositorios reactivos se integran con el Project Reactor de Spring, proporcionando una API rica para manipular los flujos de datos de manera declarativa. Los tipos Mono
y Flux
y los operadores reactivos permiten transformar, filtrar, combinar y realizar muchas otras operaciones en los flujos de datos.
Sin embargo, la programación reactiva también tiene sus desafíos. Puede ser más difícil de entender y depurar debido a su naturaleza asincrónica y no bloqueante. También puede requerir cambios significativos en la arquitectura de una aplicación para aprovechar sus beneficios.
Ejercicios de esta lección Repositorios reactivos
Evalúa tus conocimientos de esta lección Repositorios reactivos con nuestros retos de programación de tipo Test, Puzzle, Código y Proyecto con VSCode, guiados por IA.
API Query By Example (QBE)
Identificadores y relaciones JPA
Borrar datos de base de datos
Web y Test Starters
Métodos find en repositorios
Controladores Spring MVC
Inserción de datos
CRUD Customers Spring MVC + Spring Data JPA
Backend API REST con Spring Boot
Controladores Spring REST
Uso de Spring con Thymeleaf
API Specification
Registro de usuarios
Crear entidades JPA
Asociaciones en JPA
Asociaciones de entidades JPA
Integración con Vue
Consultas JPQL
Open API y cómo agregarlo en Spring Boot
Uso de Controladores REST
Repositorios reactivos
Inyección de dependencias
Introducción a Spring Boot
CRUD y JPA Repository
Inyección de dependencias
Vista en Spring MVC con Thymeleaf
Servicios en Spring
Operadores Reactivos
Configuración de Vue
Entidades JPA
Integración con Angular
API Specification
API Query By Example (QBE)
Controladores MVC
Anotaciones y mapeo en JPA
Consultas JPQL con @Query en Spring Data JPA
Repositorios Spring Data
Inyección de dependencias
Data JPA y Mail Starters
Configuración de Angular
Controladores Spring REST
Configuración de Controladores MVC
Consultas JPQL con @Query en Spring Data JPA
Actualizar datos de base de datos
Verificar token JWT en peticiones
Login de usuarios
Integración con React
Configuración de React
Todas las lecciones de SpringBoot
Accede a todas las lecciones de SpringBoot y aprende con ejemplos prácticos de código y ejercicios de programación con IDE web sin instalar nada.
Introducción A Spring Boot
Introducción Y Entorno
Spring Boot Starters
Introducción Y Entorno
Inyección De Dependencias
Introducción Y Entorno
Controladores Spring Mvc
Spring Web
Vista En Spring Mvc Con Thymeleaf
Spring Web
Controladores Spring Rest
Spring Web
Open Api Y Cómo Agregarlo En Spring Boot
Spring Web
Servicios En Spring
Spring Web
Clientes Resttemplate Y Restclient
Spring Web
Rxjava En Spring Web
Spring Web
Crear Entidades Jpa
Persistencia Spring Data
Asociaciones De Entidades Jpa
Persistencia Spring Data
Repositorios Spring Data
Persistencia Spring Data
Métodos Find En Repositorios
Persistencia Spring Data
Inserción De Datos
Persistencia Spring Data
Actualizar Datos De Base De Datos
Persistencia Spring Data
Borrar Datos De Base De Datos
Persistencia Spring Data
Consultas Jpql Con @Query En Spring Data Jpa
Persistencia Spring Data
Api Query By Example (Qbe)
Persistencia Spring Data
Api Specification
Persistencia Spring Data
Repositorios Reactivos
Persistencia Spring Data
Introducción E Instalación De Apache Kafka
Mensajería Asíncrona
Crear Proyecto Con Apache Kafka
Mensajería Asíncrona
Creación De Producers
Mensajería Asíncrona
Creación De Consumers
Mensajería Asíncrona
Kafka Streams En Spring Boot
Mensajería Asíncrona
Introducción A Spring Webflux
Reactividad Webflux
Spring Data R2dbc
Reactividad Webflux
Controlador Rest Reactivo Basado En Anotaciones
Reactividad Webflux
Controlador Rest Reactivo Funcional
Reactividad Webflux
Operadores Reactivos Básicos
Reactividad Webflux
Operadores Reactivos Avanzados
Reactividad Webflux
Cliente Reactivo Webclient
Reactividad Webflux
Introducción A Spring Security
Seguridad Con Spring Security
Seguridad Basada En Formulario En Mvc Con Thymeleaf
Seguridad Con Spring Security
Registro De Usuarios
Seguridad Con Spring Security
Login De Usuarios
Seguridad Con Spring Security
Verificar Token Jwt En Peticiones
Seguridad Con Spring Security
Seguridad Jwt En Api Rest Spring Web
Seguridad Con Spring Security
Seguridad Jwt En Api Rest Reactiva Spring Webflux
Seguridad Con Spring Security
Autenticación Y Autorización Con Anotaciones
Seguridad Con Spring Security
Testing Unitario De Componentes Y Servicios
Testing Con Spring Test
Testing De Repositorios Spring Data Jpa
Testing Con Spring Test
Testing Controladores Spring Mvc Con Thymeleaf
Testing Con Spring Test
Testing Controladores Rest Con Json
Testing Con Spring Test
Testing De Aplicaciones Reactivas Webflux
Testing Con Spring Test
Testing De Seguridad Spring Security
Testing Con Spring Test
Testing Con Apache Kafka
Testing Con Spring Test
Integración Con Angular
Integración Frontend
Integración Con React
Integración Frontend
Integración Con Vue
Integración Frontend
En esta lección
Objetivos de aprendizaje de esta lección
- Comprender qué son los repositorios reactivos y cuándo utilizarlos en el desarrollo de aplicaciones.
- Aprender a utilizar la interfaz
ReactiveCrudRepository
para implementar operaciones CRUD reactivas. - Conocer los operadores reactivos y cómo se utilizan para manipular flujos de datos en la programación reactiva.
- Entender la integración de los repositorios reactivos con Project Reactor y cómo utilizar los tipos
Mono
yFlux
. - Evaluar los beneficios y desafíos de la programación reactiva y cómo puede mejorar el rendimiento y la escalabilidad de las aplicaciones.