Ich versuche, meinen Kopf um Hystrix zu wickeln und nachdem ich ihre Dokumente gelesen habe habe eine Frage zu seinen Nutzungsmustern.
Zum einen verstehe ich den Anwendungsfall nicht für , wenn die asynchrone Ausführung im Gegensatz zu Reaktiv
Nehmen wir an, Sie haben zwei Serviceaufrufe A und B als HystrixCommand umbrochen. Sie haben jetzt drei Optionen:
Verwenden Sie .execute() : reiner synchroner Aufruf. Sie rufen die Methode auf und setzen Ihr Programm fort, sobald das Ergebnis angekommen ist. Die Gesamtausführungszeit Ihres Programms ist die Summe beider Aufrufe. Der Hauptfluss Ihres Programms ist sehr linear.
benutze .queue() : empfange sofort einen Future für beide Befehle. Beide Serviceaufrufe werden parallel ausgeführt. Verwenden Sie dann .get() , um die Ergebnisse abzurufen. Diese Aufrufe mit Block bis das Ergebnis dort ist. Ihre gesamte Ausführungszeit ist schneller als zuvor: Ihre Ausführungszeit entspricht der Länge des längsten Serviceanrufs. Verwenden Sie dies, wenn Sie die Ergebnisse der beiden Dienste kombinieren möchten. Der Hauptfluss Ihres Programms ist immer noch linear, obwohl beide Aufrufe parallel ausgeführt werden.
benutze .subscribe() : empfange sofort einen Observable für beide Befehle. Beide Serviceaufrufe werden parallel ausgeführt. Verwenden Sie dann .subscribe() , um einen Rückruf zu registrieren, um auf das Ergebnis zu reagieren, sobald es verfügbar ist. Dies ist sehr nützlich, wenn Sie die Ergebnisse nicht kombinieren wollen und nach dem Eintreffen auf die Ergebnisse von Service A und B unabhängig reagieren möchten.
Der Hauptfluss Ihres Programms ist nicht linear, sondern reaktiv: Der Fluss des Programms wird innerhalb des Callbacks für jeden Befehl fortgesetzt.
Ich hoffe, es hilft.
Tags und Links java asynchronous reactive-programming hystrix fault-tolerance