HTTP-Response-Exception Handling im Frühjahr 5 Reaktive

Entwickle ich einige reaktive microservices mit Spring Boot 2 und die Feder 5 mit WebFlux reaktive starter.

Ich stehe vor dem folgenden problem: ich möchte, um alle HTTP-Status, die ich empfangen von anrufen weitere REST-Services und wirft eine exception, wenn ich ein paar schlechte HTTP-Status. Zum Beispiel, wenn ich rufen Sie einen Endpunkt aus und ich erhalte einen 404-HTTP-Status, will ich eine Ausnahme und diese Ausnahme behandelt werden, in einigen ExceptionHandler-Klasse, nur die Art, wie es war im Frühjahr 4 mit @ControllerAdvice.

Was ist der richtige Weg, dies zu tun? Hoffe auf einige gute Vorschläge.

InformationsquelleAutor Dina Bogdan | 2018-04-04
  1. 4

    Dieser angesprochen werden kann in zwei unabhängige Teile.

    Wie konvertieren von HTTP 404-Antworten, die durch WebClient in benutzerdefinierte Ausnahmen

    Bei der Verwendung WebClient erhalten Sie HTTP 404 Antworten von remote-services. Standardmäßig, alle 4xx und 5xx client Antworten wird verwandelt werden in WebClientResponseException. So können Sie direkt mit den Ausnahmen in Ihrer WebFlux app.

    Wenn Sie möchten, um wiederum nur 404-Antworten in benutzerdefinierten Ausnahmen, können Sie Folgendes tun:

    WebClient webClient = //...
webClient.get().uri("/persons/1")
  .retrieve()
  .onStatus(httpStatus -> HttpStatus.NOT_FOUND.equals(httpStatus),
                        clientResponse -> Mono.error(new MyCustomException()))
  .bodyToMono(...);

    Dies ist natürlich auf einer pro-client-call-basis.

    Erreichen Sie dieselbe in einem mehr wiederverwendbare Art und Weise mit einem ExchangeFilterFunction dass Sie ein für alle mal auf eine WebClient Instanz wie folgt:

    WebClient.builder().filter(myExchangeFilterFunction)...

    Zu behandeln, wie benutzerdefinierte Ausnahmen in WebFlux apps

    Mit Feder WebFlux mit Anmerkungen, können Sie die Ausnahmen behandeln mit Methoden versehen mit @ExceptionHandler (siehe Spring Framework reference documentation).

    Hinweis: die Verwendung eines WebExceptionHandler ist möglich, aber es ist ziemlich low-level, da wirst du keine high-level-support: Sie müssen manuell schreiben ist die Reaktion mit Puffer ohne Unterstützung für die Serialisierung.

    • Tolle Antwort, aber könnten Sie mehr details, wie genau bekommst du die exception-Nachricht des remote-services im exchangeFilterFunction? Ich habe versucht, dies herauszufinden, für einige Zeit jetzt ohne Erfolg. Ich denke, es wäre sehr hilfreich und liefern eine detaillierte Antwort.
    • Ich verstehe nicht, - Sie nicht bekommen, eine Ausnahme Nachricht von remote-service, Sie bekommen einfach eine HTTP-Antwort. Vielleicht sollte dies eine neue Frage?
    • Oh, ja, sorry. Was ich meinte ist, wenn du einmal eine Antwort mit dem Statuscode 4xx oder 5xx und Sie versuchen, mit Ihr in eine ExchangeFilterFunction, wie genau sind Sie in der Lage, um den Körper von der Reaktion(die eigentlich die Fehlermeldung enthält)? Wie gesagt, ich möchte, um alle erfolglosen Anfragen innerhalb der WebClient und nicht pro client aufrufen.
    • Wie gehe ich mit einem WebClientResponseException in einem nicht-Webflux app? Mein Verständnis ist, dass @ExceptionHandler wird nur unterstützt, in contollers.
    • Könnten Sie diese Frage in einer anderen Frage? Es ist nicht leicht zu beantworten in den Kommentaren.
    InformationsquelleAutor Brian Clozel
  2. 2

    Ich denke was du suchst ist WebFluxResponseStatusExceptionHandler das Kontrollkästchen dieses für Referenz.

    In der WebHandler-API, eine WebExceptionHandler kann verwendet werden, um zu behandeln
    Ausnahmen von der Kette der WebFilter ist und das Ziel WebHandler.
    Bei der Verwendung der WebFlux Config, registrieren Sie einen WebExceptionHandler ist als
    einfach wie erklärt es als Spring-bean und Optional auszudrücken
    Vorrang via @Um auf die bean-Deklaration oder Implementierung
    Bestellt.

    Dieses Beispiel helfen kann, habe nicht selber ausprobiert.

    @Component
@Order(-2)
class RestWebExceptionHandler implements WebExceptionHandler{

    @Override
    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
        if (ex instanceof PostNotFoundException) {
            exchange.getResponse().setStatusCode(HttpStatus.NOT_FOUND);

            //marks the response as complete and forbids writing to it
            return exchange.getResponse().setComplete();
        }
        return Mono.error(ex);
    }
}

class PostNotFoundException extends RuntimeException {
    PostNotFoundException(String id) {
        super("Post:" + id + " is not found.");
    }
}
    • Ja, ur rechts. Hab ich schon gefunden, aber ich habe nicht gesehen, der die Umsetzung von it. Können Sie mir so etwas?
    • Ich denke, dass diese passen zu meinem problem.
    InformationsquelleAutor Pär Nilsson
Schreibe einen Kommentar