Spring 5 Web Reactive - 我们如何使用 WebClient 来检索 Flux 中的流数据？

Question

当前里程碑 (M4) 文档显示了有关如何使用 WebClient 检索 Mono 的示例：

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)));

我们如何使用 WebClient 将流式数据（来自 returns text/event-stream 的服务）传输到 Flux 中？是否支持自动Jackson转换？

我在之前的里程碑中就是这样做的，但是 API 已经改变了，再也找不到怎么做了：

final ClientRequest<Void> request = ClientRequest.GET(url)
    .accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> response = webClient.retrieveFlux(request, Alert.class)

Answer 1

这就是您如何使用新 API 实现相同的目的：

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

Answer 2

使用 Spring 5.0.0.RELEASE 这就是您的操作方式：

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;
}

Spring 5 Web Reactive - 我们如何使用 WebClient 来检索 Flux 中的流数据？

Spring 5 Web Reactive - How can we use WebClient to retrieve streamed data in a Flux?

spring

reactive-programming

project-reactor

spring-webflux