Springboot：如何使用WebClient代替RestTemplate来执行非阻塞和异步调用

Question

我有一个springboot项目，它使用springboot RestTemplate。我们已经从1.5.3转移到了SpringBoot2.0.1，并且我们正在尝试通过使用WebClient将rest调用异步化。我们过去使用Resttemplate处理接收到的字符串，如下所示。但是WebClient只返回单点或通量数据。如何将数据作为字符串获取。已经尝试了block（）方法，但它执行异步调用。

@Retryable(maxAttempts = 4, value = java.net.ConnectException.class,
           backoff = @Backoff(delay = 3000, multiplier = 2))
public Mono<String> getResponse(String url) {
    return webClient.get().uri(urlForCurrent).accept(APPLICATION_JSON)
                    .retrieve()
                    .bodyToMono(String.class);
}

使用RestTemplate呈现数据流

null

@RequestMapping(value = traffic/, method = RequestMethod.GET,
                produces = MediaType.APPLICATION_JSON_VALUE)
public String getTraffic(@RequestParam("place") String location) throws InterruptedException, ExecutionException {
    String trafficJSON = Provider.getTrafficJSON(location)
    return trafficJSON;
}

public String getTrafficJSON(String location) {
    String url = ----;

    ResponseEntity<String> response = dataFetcher.getResponse(url);

    /// RESPONSEBODY IS READ AS STRING AND IT NEEDS TO BE PROCESSED
    if (null != response {
        return parser.transformJSON(response.getBody(), params);
    }

    return null;
}

@Retryable(maxAttempts = 4,
           value = java.net.ConnectException.class,
           backoff = @Backoff(delay = 3000, multiplier = 2))
public ResponseEntity<String> getResponse(String url) {
    /* ----------------------- */
    return getRestTemplate().getForEntity(urlForCurrent, String.class);
}

Answer 1

由于有很多误解，所以在这里我要澄清一些事情。

Spring已经正式声明RESTTemplate处于维护模式，所以如果可以的话，可以使用WebClient，如果您想尽可能地成为将来的证明。

如RestTemplate API所述

非反应式应用程序使用Tomcat作为底层服务器实现，这是一个基于servlet的服务器，它将为每个请求分配1个线程，因此您将无法获得与反应式应用程序相比的性能提升。

反应性应用

另一方面，如果您有一个反应性应用程序，那么在任何情况下都不应该在应用程序中调用block()。阻塞正是它所说的，它将阻塞一个线程，阻塞线程的执行，直到它可以继续前进，这在反应世界中是不好的。

我怎么知道我有什么申请？

Spring声明，如果类路径上同时有spring-web和spring-webflux，那么应用程序将支持spring-web，并且默认情况下启动一个具有底层tomcat服务器的非反应应用程序。

如果需要，此行为可以作为spring状态手动重写。

@Retryable(maxAttempts = 4,
       value = java.net.ConnectException.class,
       backoff = @Backoff(delay = 3000, multiplier = 2))
public ResponseEntity<String> getResponse(String url) {
    return webClient.get()
            .uri(url)
            .exchange()
            .flatMap(response -> response.toEntity(String.class))
            .block();
}

我想说这是最简单、侵入性最小的实现。当然，您需要在@bean中构建一个合适的webclient，并将其自动转换到它的类中。