Reaktivní proudy - Reactive Streams

Reaktivní proudy
První vydání15. května 2015; před 5 lety (2015-05-15)
Stabilní uvolnění
1.0.3 / 23. srpna 2019; Před 15 měsíci (2019-08-23)
Úložištěgithub.com/ reaktivní proudy/ reactive-streams-jvm
NapsánoJava (Scala, Groovy, Kotlin), .NET
webová stránkareaktivní proudy.org

Reaktivní proudy je iniciativa na poskytnutí a Standard pro asynchronní zpracování proudu s neblokující protitlak.[1]

Původ

Reaktivní proudy začaly jako iniciativa koncem roku 2013 mezi inženýry v Netflix, Stěžejní a Lightbend. Některé z prvních diskusí začaly v roce 2013 mezi Hrát si a Akka týmy v Lightbendu.[2][3] Lightbend je jedním z hlavních přispěvatelů Reactive Streams.[4] Mezi další přispěvatele patří červená čepice, Věštec, Cvrlikání a spray.io.[5]

Cíle

Hlavním cílem reaktivních proudů je řídit výměnu dat proudu přes asynchronní hranici - jako předávání prvků jinému vlákno nebo pool vláken - a přitom zajistit, aby přijímající strana k tomu nebyla nucena nárazník libovolné množství dat. Jinými slovy, protitlak je nedílnou součástí tohoto modelu, aby umožnil fronty které zprostředkovávají mezi vlákny ohraničený.

Záměrem specifikace je umožnit vytvoření mnoha vyhovujících implementace, které na základě dodržování pravidel budou moci spolupracovat plynule, se zachováním zmíněných výhod a charakteristik v celém grafu zpracování streamované aplikace. Volně dostupný Sada pro technologickou kompatibilitu[6] byl vyvinut společně se specifikací, která umožňuje implementátorům specifikace ověřit, zda pokrývají všechna pravidla a požadavky, včetně kontrol potenciálních závodních podmínek.

Rozsah reaktivních proudů je minimální sada rozhraní, metody a protokoly, které popisují nezbytné operace a entity k dosažení asynchronních toků dat s neblokujícím zpětným tlakem. Koncový uživatel DSL nebo vazba protokolu API záměrně byly vynechány z rozsahu, aby podporovaly a umožňovaly různé implementace, které potenciálně používají různé programovací jazyky, aby zůstaly co nejvěrnější idiomům jejich platformy.

Zahrnutí do standardu Java

Specifikace byla vyvinuta se záměrem budoucího zahrnutí do oficiální standardní knihovny Java, pokud se osvědčí a bude přijata dostatečným množstvím knihoven a prodejců.

Reaktivní proudy byly navrženy tak, aby se staly součástí Jáva 9 od Doug Lea, vůdce JSR 166[7] jako nová třída Flow[8] který by zahrnoval rozhraní aktuálně poskytovaná Reactive Streams.[4][9] Po úspěšném vydání 1.0 Reactive Streams a rostoucím přijetí byl návrh přijat a Reactive Streams byl zahrnut do JDK9 přes JEP -266.[9]

Přijetí

Dne 30. Dubna 2015 verze 1.0.0 Reactive Streams pro JVM byl vydán,[4][5][10] počítaje v to Java API,[11] textový Specifikace,[12] A TCK a příklady implementace. Dodává se s řadou kompatibilních implementací ověřených TCK pro 1.0.0, uvedených v abecedním pořadí:[10]

Mezi další implementace patří Cassandra,[22] Elasticsearch,[23] Apache Kafka,[24] Parallel Universe Quasar,[25] Hrajte Framework,[26] Armeria.[27]

Jaro 5 bylo oznámeno, že bude postaveno na Reactor Streams kompatibilním s Reactor Core.[28]

Amazon oznámil, že jeho Webové služby Amazon SDK by podporovalo Reactive Streams, aby poskytovalo možnosti streamování ve svých klientských knihovnách ve verzi 2.0.[29]

Reactive Streams 1.0.1 je vydán 9. srpna 2017, včetně různých vylepšení v přesnosti specifikace, vylepšení TCK a dalších vysvětlení. Specifikace stejně jako rozhraní zůstala plně zpětně kompatibilní s verzí 1.0.0, avšak jejím cílem bylo zjednodušit přijetí pro budoucí implementátory a sladit s některými dalšími požadavky stanovenými OpenJDK.[30]

Přístavy a vlivy

  • Přímý port specifikace, rozhraní a TCK byl pro stejnou pracovní skupinu zpřístupněn pro .SÍŤ plošina.[31]
  • Když Elixír Jazyk představil své streamovací API s názvem GenStage, autoři rozšířili poděkování „[ak] projektům akka-streams a reactive-streams, které nám poskytly vodítko při implementaci výměny na základě poptávky mezi fázemi“.[32]

Reference

  1. ^ reactive-streams.org
  2. ^ Cesta do reaktivních proudů
  3. ^ Reaktivní proudy 1.0.0 rozhovor
  4. ^ A b C Reactive Streams vydává první stabilní verzi pro JVM
  5. ^ A b Reactive Streams 1.0.0 - nový standard v reaktivním zpracování dat
  6. ^ „Reaktivní proudy TCK“.
  7. ^ jdk9 Třídy kandidátů Flow a SubmissionPublisher
  8. ^ java.util.concurrent.Flow
  9. ^ A b JEP 266: Další aktualizace souběžnosti
  10. ^ A b Reactive Streams 1.0.0 je tady!
  11. ^ Java API
  12. ^ Reaktivní proudy pro specifikaci JVM
  13. ^ InfoQ: Reaktivní proudy s proudy Akka
  14. ^ Principy designu za akka streamy
  15. ^ Ovladač Java MongoDB Reactive Streams
  16. ^ Ratpack: API Reactive Streams
  17. ^ Reactor 2.0.0.RC1 s nativní podporou Reactive Streams je nyní k dispozici!
  18. ^ Advanced RxJava: The Reactive-Streams API (part 1)
  19. ^ Slick 3: Reactive Streams for Asynchronous Database Access in Scala
  20. ^ Úhledný 3.0.0
  21. ^ Integrace reaktivních proudů Vert.x.
  22. ^ Reaktivní přístup ke Cassandře
  23. ^ elastic4s - neblokující, zadejte bezpečný klient DSL a Scala pro Elasticsearch
  24. ^ Reaktivní proudy pro Apache Kafka
  25. ^ Kvazar a reaktivní proudy
  26. ^ Play Framework - integrace reaktivních streamů (experimentální)
  27. ^ Armeria - zcela asynchronní a reaktivní
  28. ^ Reaktivní jaro
  29. ^ „Oznámení AWS SDK pro vývojáře Java 2.0“.
  30. ^ „Oznámení o vydání reaktivních proudů 1.0.1“.
  31. ^ „Reaktivní proudy .NET“.
  32. ^ „Blog Elixir: Announcing GenStage“.
  •  Tento článek včlení text od www.reaktivní proudy.org, který je vydán pod CC0 1.0 Universal (CC0 1.0) Public Domain Dedication.