Java Forum 2019 | Johannes Schneider | cedarsoft.com Rx-Java 2 · Java Forum 2019 | Johannes...

Java Forum 2019 | Johannes Schneider | cedarsoft.com

Rx-Java 2

von 0 auf 100 in 45 min

Das Ziel:“Ist doch eigentlich ganz einfach”

“Dafür hätte ich nicht so lange da bleiben müssen”

Jetzt geht es wirklich los!

Warum Reactive Programming?

Szenario 1Verbindungsaufbau

Steuerung

GET 1(-3): Port-Guessing (80?, 443?, 8080?)

GET 4: PLC-Infos abrufen

GET 5: Berechtigungs-Infos

GET 6: Daten-Modell

GET 7: Visu-Modell

GET 8: Customizations

GET 9: Initiale Daten

9(+) Requests à 30 ms → kein Problem

Aber: VPN + Mobilfunk → ...

Was tun? Klar: Parallelisieren

→ Observer-Pattern / Callbacks (???)

Aber: Calls bauen (teilweise) aufeinander auf

Welcome to Callbacks-Hell

Szenario 2UI-Anbindung

(Android, Swing, JavaFX)

Aktionen im Hintergrund

Aber: Progress anzeigen

Aber: Abbrechen durch Benutzer

Update der UI nur im UI-Thread

Aber: Nicht zu viele Updates der UI!

Observer-Pattern (???)

Eigentlich richtig - in der Praxis zu kompliziert

Vorlesung “Design Patterns”

Typisches Pattern: 90% Pattern - 10% Probleme / Grenzen

Observer-Pattern10% Pattern - 90% Probleme / Grenzen

Niemand implementiert das “richtig”

Was dem Observer-Pattern fehlt...

… löst Reactive Programing

Schritt 1

aus Sicht des Observers

Grundsätzlicher Ansatz Reactive:

return Observable

Wenn du nicht mehr weiter weißt, füge einen Layer ein...

Grundprinzip

public Observable<String> fetchBestMovies(){...}

Noch ist nix passiert

Observable<String> myObservable = fetchBestMovies();

Noch ist nix passiert! Methode läuft noch nicht.

Jetzt geht es los!

myObservable.subscribe([...]);

Hier geht es (erst) los!

Callback

myObservable.subscribe(new Observer<String>(){

});Das eigentliche Callback.

Jetzt geht es los

public void onSubscribe(Disposable d) { }

public void onNext(String s) {}

public void onError(Throwable e) {}

public void onComplete() {}

Ganz am Anfang 1x aufgerufen

“Normale” Listener-Methode

Call für jedes Element

Fehlerbehandlung

Falls ein Fehler auftritt

Habe fertich

Damit wird gemeldet, dass keine Elemente mehr kommen

Abbruch durch Consumer (z.B. UI-Interaktion)

myObservable.subscribe(new Observer<String>(){ @Override public void onSubscribe(Disposable d) {

//Remember that disposable }[...]});

disposable.dispose();

Observer kann (irgendwann) abbrechen!

Callback auf welchem Thread?

Observer entscheidet!

myObservable.observeOn(SwingScheduler.INSTANCE).subscribe();

Wir “observieren” auf dem Swing Thread

public Observable<String> getFunnyNames(){...}

Observable<String> myObservable = getFunnyNames();

myObservable.observeOn(Schedulers.IO).subscribe();

Wir “observieren” auf einem (großen) Thread-Pool

public Observable<String> getFunnyNames(){...}

Observable<String> myObservable = getFunnyNames();

myObservable.observeOn(Schedulers.COMPUTE).subscribe();

Wir “observieren” auf einem Thread-Pool mitGröße == Anzahl Kerne

myObservable.observeOn(Schedulers.COMPUTE).subscribe();

Jeder Call wrappt das ursprüngliche Observable!

Demo 1

Hello World - aus Observer-Sicht

Wiederholung Basics

Wie war das noch?

Observable zurück geben

return Observable

Anstatt wie klassisch ein Callback zu übergeben

Erst bei subscribe()Geht die Reise los

Dadurch mehr Kontrolle / Konfigurationsmöglichkeit beim Aufrufer

Alles da was wir brauchen

Übliche Methoden sind vorhanden

onNext(T)

onError(Throwable)

onComplete()

Threading ist gelöst

(auch eigene Schedulers möglich)

observeOn(Scheduler)

Observer kann abbrechen

Disposable

Z.B. beim Verlassen einer Seite...

Falls ein anderer Server schneller antwortet...

Schritt 2

aus Sicht des “Observable”

Grundsätzlicher Ansatz Reactive:

return Observable

Wenn du nicht mehr weiter weißt, füge einen Layer ein...

Aus Sicht des Observierten

public Observable<String> fetchBestMovies(){

//Hier passiert noch nichts teures/langes

return observable;

}Schnell zurückkehren! Keine Arbeit direkt machen!

Erst bei subscribe() geht es los

Vorsicht!Oder: Was (fast) alle Tutorials falsch machen!

Macht das Sinn??? Deshalb Rective???

public Observable<String> fetchBestMovies(){

return Observable.fromArray(“a”, “b”, “c”);

Schnell zurückkehren??? Keine Arbeit direkt machen???

Brauche ich dafür eine fette Bibliothek???

Das ist ein (sinnfreies) Beispielum ein Observable zu bekommen

Besseres Minimal-Beispiel

→ Eigentlich lohnt es sich jetzt schon

Aber das Beste kommt ja noch

Reactive Operatoren

(zu) hohe Frequenz?

Throtteling ist schon da

Bitte etwas langsamer!

fetchBestMovies().throttleLatest(500L, TimeUnit.MILLISECONDS, true).observeOn(SwingScheduler.INSTANCE) //Maybe a ui thread?

.subscribe(new Observer<String>() {

Liefert den letzten/jüngsten Wert alle 500 ms

Demo 3

Operatoren, Operatoren, Operatoren

Operatoren sind schwer zu verstehendeshalb:

https://rxmarbles.com/

Typen von “Observables”Observable / Flowable

Maybe / Single / Completable

Szenario 3Pagination für eine Suche

Endless Loading

Eine Query mit vieeeeeeeeeeelen Results

UI entscheidet, wann die nächste Seite kommt

Demo Flowable

Alles perfekt?

Naja...

Performance(!?)

Kein Ersatz für For-Schleifen!

Debugging

Laaaange StackTraces

wie früher bei Hibernate ;-)

Komplexität, Komplexität

“Aus vielen Operatoren folgt große Verantwortung”

Best Practices

Was “unbedingt” zu empfehlen ist

observeOn() wird häufig benötigt

… subscribeOn() sehr selten

doOn…()-Methoden sind sehr hilfreich

Operatoren: Möglichst mit Einzeilern(vergleiche Streaming API)

Abstrakte Basis-Klassen für Observer erstellen

Es gibt für alles bereits einen Operator ;-)

Demos / Tests erstellen

Fragen / Anregungen / Ergänzungen?

Demo Code unter:

https://github.com/jschneider/rxjava2-examples

Java Forum 2019 | Johannes Schneider | cedarsoft.com Rx-Java 2 · Java Forum 2019 | Johannes...

Documents

RX 60-60 RX 60-70 RX 60-80 RX 60-80/900 - IFOY

Glow Plug Cross Reference - Diesel Rx · PDF fileGlow Plug Cross Reference AC DELCO Diesel RX BOSCH Diesel RX FORD Diesel RX 7G DRX00078 80034 DRX00050 E2TZ-12A342-A DRX00084 8G DRX00080/88*

TRAINIEREN PROGRAMMIEREN - ciando ebooksTRAINIEREN luigi LO IACONO stephan WIEFLING michael SCHNEIDER Mit über 120 Workouts in Java und Python PROGRAMMIEREN TRAINIEREN Im Internet:

Online Videos im Rx- und OTC-Marketing

RX THORAX SFRAURA nov 19• Radio ASP : 10 RX thorax • Scanner thorax : 300 RX thorax • Scanner abdomen : 600 RX thorax Syndrome de Silverman Nourrisson- toux, ﬁèvre 38 5 Thymus

RX 450h RX 450h Ld3rvezpmgp265q.cloudfront.net/lexusone/lexchdev11/... · RIVIERA . RX 13 LUXURY ist aussergewöhnlich. Ich neige den Fondsitz nach hinten und bemerke, dass die Armlehne

DER NEUE RXd3rvezpmgp265q.cloudfront.net/lexusone/lexchde/17MY RX MB CHG… · Hybrid-Technologie, der nahtlosen Kombination aus Benzin- und Elektroantrieb. 2004 wurde der RX 400h

Einführung in Java Enterprise Edition 5 (Java EE 5) · Einführung Web-Anwendungen mit Java EE Enterprise JavaBeans Einführung in Java Enterprise Edition 5 (Java EE 5) Dirk Wischermann

RX 60-60 RX 60-70 RX 60-80 RX 60-80/900 - ifoy. · PDF file6 mm 2697 2697 2697 2697 4.8 Sitzhöhe h 7 mm 1719 1719 1719 1719 4.12 Kupplungshöhe h 10 mm 520/670 520/670 520/670 520/670

군용 VoIP 전화기를 위한 고신뢰성 Rx 전력 시스템 설계koreascience.or.kr/article/JAKO202030161610148.pdf · 857 군용 VoIP 전화기를 위한 고신뢰성 Rx 전력

אהבת נשים - bat-kol.orgnnvv rx ntrnnt: '*t' .-.rx rlyz'.rl ax x' 30-7 "93' rx ,rmw: ,nvnl rx gilia@maariv.co.il 'a" 15-9 rx 'r't'y -,nx rnnv n-np "1 did it my way" -„IR

Einbauanleitung Lexus RX 450h - Продажа Webasto EVO ...автоотопитель.рф/manual/Lexus/RX/RX450h_2009_3.5_b_D... · Lexus RX 450h 1315136A 2 Inhaltsverzeichnis

DER NEUE RX 450h - keusch.com · DER NEUE RX 450h TESTEN SIE DEN NEUEN RX 450h D as reine Fahrvergnügen mit einem Lexus Fahrzeug lässt sich nur auf eine Art erleben: Setzen Sie

BlueLine Rx IDS - xylemanalytics.com Library/Resource Library/SIA/… · blueline rx ids bedienungsanleitung t 814252 05/2014 redox-messketten mit gelelektrolyt und nachfÜllbarem

RX Services | RX Services˘ ˇ ˆ ˙ ˝ ˛ ˚˜ ! " # $%% * Option for Lite16 & Lite16 std. **Option for Lite16 std. only HTR-HVL-CA002 Rev7 ˘ ˇˆ ˙ˆ ˝ ˛ ˚˜ ! ˚" # ˚

Das Java-Hamstermodell Von Dietrich Boles. Inhaltsverzeichnis Java allgemein Java allgemein Vorteile von Java Vorteile von Java Umgang mit dem Hamster-Editor

RX 60 Technische Daten Elektro-Gabelstapler

Java Deserializaon A0acks - OWASP · Java Deserializaon A0acks Angriﬀ & Verteidigung 1 Christian Schneider, @cschneider4711 Alvaro Muñoz, @pwntester (in Absentia)

Bitte Rx-Thorax nur anfertigen, falls bei schwererer ... · (2) Bitte Rx-Thorax nur anfertigen, falls bei schwererer Lungenerkrankung der letzte Rx-Thorax älter als 12 Monate ist

RX Trem - Ausbildung