如何在Spring的AsynCrestTemplate上设置超时？

Question

我在我的项目中设置了一个RestTemplate和一个AsyncRestTemplate,如下所示：

我注意到连接超时实际上并不起作用，除非我将httpRequestFactory（）bean更改为如下所示：

@Bean
public ClientHttpRequestFactory httpRequestFactory() {
    HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient());
    factory.setConnectTimeout(DEFAULT_READ_TIMEOUT_MILLISECONDS);
    factory.setReadTimeout(DEFAULT_READ_TIMEOUT_MILLISECONDS);
    return factory;
}

如果我将DEFAULT_READ_TIMEOUT_MILLISECONDS设置为5，则当我使用restTemplate时会发生超时（正如预期的那样）。但是，当我使用AsyncRestTemplate时，不会发生超时。我已经像httpRequestFactory（）一样修改了asyncHttpRequestFactory（）,但没有修改骰子。

@Bean
public AsyncClientHttpRequestFactory asyncHttpRequestFactory() {
    HttpComponentsAsyncClientHttpRequestFactory factory = new HttpComponentsAsyncClientHttpRequestFactory(asyncHttpClient());
    factory.setConnectTimeout(DEFAULT_READ_TIMEOUT_MILLISECONDS);
    factory.setReadTimeout(DEFAULT_READ_TIMEOUT_MILLISECONDS);
    return factory;
}

下面是我如何尝试在Spring MVC控制器中使用AsyncRestTemplate：

String url = "...";
// Start the clock
long start = System.currentTimeMillis();

ListenableFuture<ResponseEntity<String>> results = asyncRestTemplate.getForEntity(url, String.class);
// Wait until the request is finished
while (!(results.isDone())) {
    Thread.sleep(10); //millisecond pause between each check
}
System.out.println("Elapsed time: " + (System.currentTimeMillis() - start));
return results.get().getBody();

与此相关的是，https://spring.io/guides/gs/async-method/使用了@async和RestTemplate，似乎可以实现我所要实现的目标。与RestTemplate相比，使用AsyncRestTemplate有什么优势？

Answer 1

与同步非常相似：

final SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setTaskExecutor(new SimpleAsyncTaskExecutor());
requestFactory.setConnectTimeout(connectTimeout);
requestFactory.setReadTimeout(readTimeout);

final AsyncRestTemplate asyncRestTemplate = new AsyncRestTemplate();
asyncRestTemplate.setAsyncRequestFactory(requestFactory); 

从源代码中可以看到，AsyncrestTemplate实例是通过使用SimpleClientTtpRequestFactory和SimpleAsynctAskExecutor创建的。因此您可以使用设置了超时值的SimpleClientTtpRequestFactory实例来执行相同的操作。