Feder 5 Web-Reaktiven - Wie können wir WebClient abrufen-Stream von Daten in einem Fluss?

Den aktuellen Meilenstein (M4) - Dokumentation zeigt und Beispiel darüber, wie das abrufen einer Mono mit WebClient:

WebClient webClient = WebClient.create(new ReactorClientHttpConnector());

ClientRequest<Void> request = ClientRequest.GET("http://example.com/accounts/{id}", 1L)
                .accept(MediaType.APPLICATION_JSON).build();

Mono<Account> account = this.webClient
                .exchange(request)
                .then(response -> response.body(toMono(Account.class)));

Wie kann man die gestreamten Daten (von einem service, der zurück text/event-stream) in einen Fluss mit WebClient? Unterstützt automatische Jackson-Konvertierung?.

Dies ist, wie ich es gemacht habe in einem früheren Meilenstein, aber die API hat sich geändert und kann nicht herausfinden, wie es nicht mehr tun:

final ClientRequest<Void> request = ClientRequest.GET(url)
    .accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> response = webClient.retrieveFlux(request, Alert.class)
  • Aktuelle Meilenstein M4... So möchten Sie vielleicht zu prüfen, die Dokumentation wieder eine Menge Arbeit wurde in der M4-Version, um die komplette reaktiven Funktionen.
  • Ich habe es gecheckt und selbst der aktuelle snapshot, aber keine details zu diesem.
  • Ich überprüfte das Spring-Framework 5 RC3 und es scheint, dass ClientRequest nicht GET-Methode nun
  • haben Sie einen Blick auf die neue Antwort.
InformationsquelleAutor codependent | 2016-12-30
  1. 7

    Dies ist, wie können Sie erreichen die gleiche Sache mit der neuen API:

    final ClientRequest request = ClientRequest.GET(url)
        .accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> alerts = webClient.exchange(request)
        .retrieve().bodyToFlux(Alert.class);
    InformationsquelleAutor Brian Clozel
  2. 5

    Mit Feder 5.0.0.Dieses RELEASE ist wie Sie es tun:

    public Flux<Alert> getAccountAlerts(int accountId){
    String url = serviceBaseUrl+"/accounts/{accountId}/alerts";
    Flux<Alert> alerts = webClient.get()
        .uri(url, accountId)
        .accept(MediaType.APPLICATION_JSON)
        .retrieve()
        .bodyToFlux( Alert.class )
        .log();
    return alerts;
}
    InformationsquelleAutor codependent
Schreibe einen Kommentar