Spring RestTemplate 不会使用超时设置
Spring RestTemplate wont use timeout settings
无法理解 RestTemplate 如何处理超时。
我将 RestTemplate
配置为 Bean
,如图所示:
@Bean
public RestTemplate rest(final RestTemplateBuilder builder) {
final RestTemplate restTemplate = new RestTemplate(getClientHttpRequestFactory());
return restTemplate;
}
private ClientHttpRequestFactory getClientHttpRequestFactory() {
final int timeout = 50000;
final RequestConfig config = RequestConfig.custom().setConnectTimeout(timeout).setConnectionRequestTimeout(timeout).setSocketTimeout(timeout).build();
final CloseableHttpClient client = HttpClientBuilder.create().setDefaultRequestConfig(config).build();
return new HttpComponentsClientHttpRequestFactory(client);
}
50000的价值只是学术价值
我在 Hystrix
包装的服务连接器中使用我的 RestTemplate
:
@HystrixCommand(commandProperties = { @HystrixProperty(name = "execution.isolation.strategy", value = "SEMAPHORE") }, fallbackMethod = "fallbackActivityCall")
public Optional<ResponseActivityValue> callForActivity() {
final StringBuilder urlBuilder = new StringBuilder(accessConfig.getTracking().getUrl());
final HttpEntity<String> entity = new HttpEntity<>(buildAuthHeader());
final ResponseEntity<ResponseActivityValue> re = restTemplate.exchange(urlBuilder.toString(), HttpMethod.GET, entity, ResponseActivityValue.class);
final HttpStatus code = re.getStatusCode();
return Optional.ofNullable(re.getBody());
}
我用停止呼叫的服务进行了测试。 3 秒后方法 returns 而不是预期值 50000。我在 te RestTemplate
中配置哪个值并不重要,它总是在 3 秒后 returns。
有人知道吗?
您可以直接使用 RestTemplateBuilder 构建器来构建您的 rest 模板实例:如下
@Bean
public RestTemplate rest(final RestTemplateBuilder builder) {
return builder
.setConnectTimeout(50000)
.setReadTimeout(50000)
.build()
}
并尝试在 application.properties
中设置 hysterix 的配置
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=50000
或者直接在您的命令中 (@HystrixProperty
)
@HystrixCommand(
commandProperties = {
@HystrixProperty(name = "execution.isolation.strategy", value = "SEMAPHORE"),
@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "50000")
}, fallbackMethod = "fallbackActivityCall")
public Optional<ResponseActivityValue> callForActivity() {
....
}
无法理解 RestTemplate 如何处理超时。
我将 RestTemplate
配置为 Bean
,如图所示:
@Bean
public RestTemplate rest(final RestTemplateBuilder builder) {
final RestTemplate restTemplate = new RestTemplate(getClientHttpRequestFactory());
return restTemplate;
}
private ClientHttpRequestFactory getClientHttpRequestFactory() {
final int timeout = 50000;
final RequestConfig config = RequestConfig.custom().setConnectTimeout(timeout).setConnectionRequestTimeout(timeout).setSocketTimeout(timeout).build();
final CloseableHttpClient client = HttpClientBuilder.create().setDefaultRequestConfig(config).build();
return new HttpComponentsClientHttpRequestFactory(client);
}
50000的价值只是学术价值
我在 Hystrix
包装的服务连接器中使用我的 RestTemplate
:
@HystrixCommand(commandProperties = { @HystrixProperty(name = "execution.isolation.strategy", value = "SEMAPHORE") }, fallbackMethod = "fallbackActivityCall")
public Optional<ResponseActivityValue> callForActivity() {
final StringBuilder urlBuilder = new StringBuilder(accessConfig.getTracking().getUrl());
final HttpEntity<String> entity = new HttpEntity<>(buildAuthHeader());
final ResponseEntity<ResponseActivityValue> re = restTemplate.exchange(urlBuilder.toString(), HttpMethod.GET, entity, ResponseActivityValue.class);
final HttpStatus code = re.getStatusCode();
return Optional.ofNullable(re.getBody());
}
我用停止呼叫的服务进行了测试。 3 秒后方法 returns 而不是预期值 50000。我在 te RestTemplate
中配置哪个值并不重要,它总是在 3 秒后 returns。
有人知道吗?
您可以直接使用 RestTemplateBuilder 构建器来构建您的 rest 模板实例:如下
@Bean
public RestTemplate rest(final RestTemplateBuilder builder) {
return builder
.setConnectTimeout(50000)
.setReadTimeout(50000)
.build()
}
并尝试在 application.properties
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=50000
或者直接在您的命令中 (@HystrixProperty
)
@HystrixCommand(
commandProperties = {
@HystrixProperty(name = "execution.isolation.strategy", value = "SEMAPHORE"),
@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "50000")
}, fallbackMethod = "fallbackActivityCall")
public Optional<ResponseActivityValue> callForActivity() {
....
}