Reactive Streams sind eine Schlüsseltechnologie für hochskalierbare verteilte Systeme, sie automatisieren Parallelität und Nebenläufigkeit transparent. Aber wie erziele ich ein ganz bestimmtes Parallelitätsverhalten? Wann laufen Datenproduktion oder Pipeline-Stufen parallel? Wie optimiere ich Performance und Skalierbarkeit?

Im Tutorial lernen Sie, Parallelität in Reactor und RxJava effizient auf nichtfunktionale Anforderungen Ihres Systems zuzuschneiden und lernen den grundlegenden Einsatz und Realisierungskonzepte dieser Frameworks kennen.

Auf dem Rechner sollte JDK 9 oder neuer installiert sein.

Maximale Teilnehmerzahl: 30

Zielpublikum: Entwickler / Architekten die Reactive Streams effizient nutzen wollen (beliebige Programmiersprache)
Voraussetzungen: Kein Reactive Stream Wissen erforderlich, Java Grundlagen, JDK 9 oder neuer für die Übungsaufgaben
Schwierigkeitsgrad: Anfänger

Extended Abstract
The Time is Now: Das Pandemiejahr hat gezeigt, wie wichtig die Skalierbarkeit von Softwaresystemen für das Funktionieren unserer Gesellschaft ist. Reactive Streams sind eine zentrale Schlüsseltechnologie für hochskalierbare nebenläufige und verteilte Systeme. Parallelität und Nebenläufigkeit werden transparent hergestellt und mit wenigen Aufrufen konfiguriert. Aber in der Praxis ist es nicht immer einfach zu erkennen, mit welcher Konfiguration ich ein ganz bestimmtes gewünschtes Parallelitätsverhalten herstellen kann, und wie sich dieses dann auf Performance und Skalierbarkeit meiner Applikation auswirkt.

Nach einer Einführung in die Anwendung der Reactive Streams Framewoks RxJava und Reactor erwerben Sie in diesem Tutorial die Fähigkeit, die Parallelitätskonzepte in Reactive-Streams generell zu verstehen und diese gezielt für die Anforderungen Ihrer Applikation zu einzusetzen.

Es wird gezeigt, wie sich Parallelität, Nebenläufigkeit und Nonblocking Back-Pressure konfigurieren lassen, und welches genaue Verhalten hinsichtlich Datenproduktion, Datenfluss und Parallelität in der Pipeline sich hinter den jeweiligen Alternativen verbirgt.

Da die Konzepte programmiersprachenübergreifend sind, ist das Tutorial auch für Anwender von Reactive Streams in anderen Sprachen als Java gut geeignet.

Anhand zahlreicher praktischer Übungsaufgaben lernen Sie, sich Fragen der folgenden Art zu beantworten:

• Was muss ich bei parallellaufenden Stream-Stufen beachten?
• Wie ist das Queueing in einem Reactive Stream realisiert?
• Wie setze ich Back-Pressure als Schlüssel zu einer hohen Skalierbarkeit ein?

Agenda

• Einführung: Reactive Streams Standard und das Reactive Manifesto
• Grundlegende Benutzung von Reactor / RxJAva
• Streams aufbauen, verzweigen und zusammenführen
• Datengeneratoren
• Parallelität: Konfiguration und Verhalten
• Nebenläufigkeit: Datenmanagement in den Frameworks
• Nonblocking Back-Pressure: Benutzung und Realisierung
• Nichtfunktionale Anforderungen: Skalierbarkeit und Performance