Programación reactiva

1. Orígenes

ReactiveX (también conocida como Reactive Extensions) es una biblioteca de software creada originalmente por Microsoft, que permite a los lenguajes de programación imperativos trabajar sobre secuencias de datos de forma síncrona o asíncrona. Proporciona un conjunto de operadores de secuencia que actúan sobre cada elemento de la secuencia. Esta implementación de la programación reactiva proporciona un modelo para crear herramientas compatibles con varios lenguajes de programación. En otras palabras, ReactiveX es una API de programación asíncrona basada en flujos de observaciones. Esto permite a los programadores llamar a funciones y esperar su ejecución mediante callbacks. Los flujos de observaciones son similares a los emisores de eventos, emitiendo eventos de next, error y complete. Una vez que un flujo emite un evento de error o complete, deja de emitir eventos a menos que se vuelva a suscribir.

Los observadores se suscriben a flujos de observaciones y reciben los elementos de manera asíncrona. ReactiveX combina las ideas de los motivos "observador" e "iterador" con la programación funcional. Los operadores de ReactiveX permiten crear flujos de observaciones, combinar los elementos emitidos por flujos internos y realizar operaciones, tales como transformar, reducir o agrupar datos. La biblioteca ReactiveX fue creada por el equipo...

1. Akka

Aunque estos ecosistemas se pueden utilizar con Spring, tienen su propio ecosistema y se pueden utilizar por sí solos, sin Spring. Es la misma situación que ocurre con ecosistemas como AWS y Quarkus. RxJava y Spring pueden utilizarse juntos, pero la integración es parcial. RxJava ofrece funcionalidades que pueden utilizarse en Spring, pero la integración no es completa. Reactor, en cambio, ofrece una integración completa con Spring, desde la capa de exposición REST hasta la capa de almacenamiento Akka.

Para implementar una aplicación reactiva que haga, por ejemplo, event sourcing, con Akka, numerosos bloques de construcción y conceptos pueden ser utilizados:

1. En interno

Internamente, Reactor Core utiliza un motor de ejecución basado en el modelo de máquina de estados finitos para gestionar el flujo de datos y las operaciones de transformación. Esto optimiza la utilización de recursos y garantiza una ejecución eficiente de las operaciones asíncronas.

Su motor de ejecución interno utiliza el modelo de máquina de estados finitos (FiniteStateMachine,FSM) para gestionar de forma optimizada el flujo de datos y las operaciones de transformación. El flujo de datos se representa como una secuencia de estados y las operaciones de transformación se representan como transiciones entre estos estados. Cada operación aplicada a un Flujo o a un Mono puede considerarse como una transición de un estado a otro.

Además, gracias a este modelo, las operaciones asíncronas pueden ejecutarse de forma eficiente y sin bloqueos. El motor de ejecución gestiona las transiciones entre los estados de forma asíncrona, lo que permite procesar los flujos de datos de manera reactiva, sin bloquear el hilo de ejecución principal.

Reactor Core utiliza una combinación de listeners de mensajes y schedulers internos para crear un entorno multitarea simulado utilizando un bucle de mensajes. Cuando una operación asíncrona se ejecuta, emite un mensaje que es recogido por un listener dedicado. Este listener procesa el mensaje y decide la siguiente acción a realizar en función del tipo de mensaje recibido. Este enfoque permite gestionar eficazmente los eventos de forma no bloqueante....