Flujos reactivos

Reactive Streams es una iniciativa para proporcionar un estándar para el procesamiento asíncrono de flujos con contrapresión sin bloqueo . ^{[ 1 ] [ 2 ]}

Reactive Streams comenzó como una iniciativa a finales de 2013 entre ingenieros de Netflix , Pivotal y Lightbend . Algunas de las primeras conversaciones comenzaron en 2013 entre los equipos de Play y Akka en Lightbend. ^{[ 3 ] [ 4 ]} Lightbend es uno de los principales contribuyentes de Reactive Streams. ^{[ 5 ]} Otros contribuyentes incluyen Red Hat , Oracle , Twitter y spray.io. ^{[ 6 ]}

El objetivo principal de Reactive Streams es gestionar el intercambio de datos de flujo a través de un límite asíncrono ( como pasar elementos a otro hilo o grupo de hilos ) y, al mismo tiempo, garantizar que el receptor no se vea obligado a almacenar cantidades arbitrarias de datos en búfer. En otras palabras, la contrapresión es una parte integral de este modelo para permitir que las colas que median entre los hilos tengan un tamaño limitado .  

La intención de la especificación es permitir la creación de múltiples implementaciones conformes que, al cumplir con las reglas, podrán interoperar sin problemas, preservando los beneficios y características mencionados en todo el gráfico de procesamiento de una aplicación de flujo. Junto con la especificación, se desarrolló un kit de compatibilidad tecnológica ^{[ 7 ]} de libre acceso que permite a los implementadores verificar si han cubierto todas las reglas y requisitos, incluyendo comprobaciones de posibles condiciones de carrera .

El alcance de Reactive Streams es un conjunto mínimo de interfaces , métodos y protocolos que describen las operaciones y entidades necesarias para lograr flujos de datos asíncronos con contrapresión no bloqueante. ^{[ 2 ]} Los DSL de usuario final o las API de enlace de protocolo se han dejado deliberadamente fuera del alcance para fomentar y permitir que diferentes implementaciones que potencialmente utilizan diferentes lenguajes de programación se mantengan lo más fieles posible a los modismos de su plataforma.

La especificación se desarrolló con la intención de incluirla en el futuro en la biblioteca estándar oficial de Java, si demuestra ser exitosa y es adoptada por suficientes bibliotecas y proveedores.

Doug Lea , líder de JSR 166 ^{[ 8 ],} propuso que Reactive Streams se integrara en Java 9 como una nueva clase Flow ^{[ 9 ]} que incluiría las interfaces que actualmente proporciona Reactive Streams. ^{[ 5 ] [ 10 ]} Tras el exitoso lanzamiento de la versión 1.0 de Reactive Streams y su creciente adopción, la propuesta fue aceptada y Reactive Streams se incluyó en JDK9 mediante JEP -266. ^{[ 10 ]}

El 30 de abril de 2015 se lanzó la versión 1.0.0 de Reactive Streams para la JVM , ^{[ 5 ] [ 6 ] [ 11 ]} incluyendo la API de Java , ^{[ 12 ]} una especificación textual , ^{[ 13 ]} un TCK y ejemplos de implementación. Viene con multitud de implementaciones compatibles verificadas por el TCK para 1.0.0, listadas en orden alfabético: ^{[ 11 ]}

• Akka Streams ^{[ 14 ] [ 15 ]}
• MongoDB ^{[ 16 ]}
• Ratpack ^{[ 17 ]}
• Reactive Rabbit : controlador para RabbitMQ / AMQP 
• Primavera ^{[ 2 ]} y Reactor de Proyecto Pivotal ^{[ 18 ]}
• Netflix RxJava ^{[ 19 ]}
• Slick 3.0 ^{[ 20 ] [ 21 ]}
• Vert.x 3.0 ^{[ 22 ]}
• Motín
• Helidón

Otras implementaciones incluyen Cassandra , ^{[ 23 ]} Elasticsearch , ^{[ 24 ]} Apache Kafka , ^{[ 25 ]} Parallel Universe Quasar, ^{[ 26 ]} Play Framework , ^{[ 27 ]} Armeria. ^{[ 28 ]}

Se anuncia que Spring 5 se basará en un núcleo Reactor compatible con Reactive Streams. ^{[ 29 ]}

Amazon anunció que su SDK de Amazon Web Services admitiría Reactive Streams para proporcionar capacidades de transmisión en sus bibliotecas cliente en la versión 2.0. ^{[ 30 ]}

Reactive Streams 1.0.1 se publicó el 9 de agosto de 2017, incluyendo varias mejoras en la precisión de la especificación, mejoras en TCK y otras aclaraciones. La especificación y las interfaces mantuvieron una compatibilidad total con la versión 1.0.0, pero se buscó simplificar la adopción para futuros implementadores y alinearla con algunos requisitos adicionales establecidos por OpenJDK . ^{[ 31 ]}

• Se puso a disposición una versión directa de la especificación, las interfaces y el TCK bajo el mismo grupo de trabajo para la plataforma .NET . ^{[ 32 ]}
• Cuando el lenguaje Elixir introdujo su API de transmisión llamada GenStage, los autores expresaron su agradecimiento a "[los] proyectos akka-streams y reactive-streams que nos brindaron orientación en la implementación del intercambio impulsado por la demanda entre etapas". ^{[ 33 ]}

• Walls, Craig (octubre de 2019). Primavera en acción (quinta  ed.). Manning . pág.  520. ISBN 9781617294945.

•  Este artículo incorpora texto de www.reactive-streams.org , que se publica bajo una Dedicación de Dominio Público CC0 1.0 Universal (CC0 1.0) .