Spring 5 Web Reactive - WebClient를 사용하여 Flux에서 스트리밍 된 데이터를 검색하려면 어떻게해야합니까? <code>WebClient</code>를 사용하여 <code>Mono</code>를 검색하는 방법에 대한

Question

현재 중요 시점 (M4) 문서 쇼와 예 :

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

어떻게 우리가 플럭스 사용하여 웹 클라이언트에 (text/event-stream를 반환하는 서비스)에서 스트리밍 데이터를 얻을 수 있습니까? 자동 잭슨 변환을 지원합니까?

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

Answer 1

이 새와 같은 일을 달성 할 수있는 방법이다 : 나는 이전의 이정표에 그것을 어떻게

이

는하지만 API 변경하고 더 이상 작업을 수행하는 방법을 찾을 수 없습니다 API는 :

봄 5.0.0.RELEASE와

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

Answer 2

이 당신이 그것을 할 방법 :

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