Spring RestTemplate readtimeout 属性 工作不正常 - 奇怪的问题
Spring RestTemplate readtimeout property not working properly - strange issue
我想使用 2 个服务并希望有不同的超时时间。所以，我覆盖了 Spring 的 SimpleClientHttpRequestFactory 并从我的 HttpDaoImpl.
中使用它
现在一切都在一个环境中工作，但完全相同的 EAR 在其他环境中不起作用，两种环境的唯一区别是我连接的服务 URL 是负载平衡的 URL在一个和非 LB 中。问题出在负载平衡服务 URL.
问题是每次 httpReadTimeout 生效或被使用但不是 XYZHttpReadTimeout，即使我有条件地设置超时。
这是一个非常奇怪的问题，因为一切都在一个环境中工作。而不是在其他。到目前为止，我对可能的根本原因的猜测是负载平衡 URL 但我仍然看不出任何技术原因来说明为什么负载平衡 URL 可能会出现问题，因为我的机器将打开一个套接字并关闭它读取超时后。
我已经在 CustomClientHttpRequestFactory 中放置了记录器并验证了是否使用了正确的值，但最终不知何故读取超时没有按预期工作。
CustomClientHttpRequestFactory.java:
public class CustomClientHttpRequestFactory extends SimpleClientHttpRequestFactory{
private Log logger = LogFactory.getLog(CustomClientHttpRequestFactory.class);
@Value("${httpRequest.readTimeoutInMilliseconds}")
private Integer httpRequestTimeout;
@Value("${httpRequest.connectionTimeoutInMilliseconds}")
private Integer httpReadTimeout;
@Value("${XYZ.httpRequest.readTimeoutInMilliseconds}")
private Integer XYZHttpRequestTimeout;
@Value("${XYZ.httpRequest.connectionTimeoutInMilliseconds}")
private Integer XYZHttpReadTimeout;
@Value("${sgw.XYZHttp.service.url}")
private String XYZSystemUrl;
/**
* Overriding the default and setting a separate read timeout and HTTP connection timeout values for XYZ transactions.
*
* @param uri
*/
public void setTimeoutProperties(URI uri){
boolean isXYZTransaction = isXYZTransaction(uri);
Integer connectionTimeout = isXYZTransaction ? XYZHttpRequestTimeout : httpRequestTimeout;
Integer readTimeout = isXYZTransaction ? XYZHttpReadTimeout : httpReadTimeout;
logger.info("Setting " + connectionTimeout + " : " + readTimeout);
this.setReadTimeout(readTimeout);
this.setConnectTimeout(connectionTimeout);
}
private boolean isXYZTransaction(URI uri){
try {
URI XYZUrl = new URI(XYZSystemUrl);
logger.info("################################### XYZ Debug");
logger.info("XYZHttpRequestTimeout = " + XYZHttpRequestTimeout);
logger.info("XYZHttpReadTimeout = " + XYZHttpReadTimeout);
return XYZUrl.equals(uri);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
}
HttpDaoImpl:
CustomClientHttpRequestFactory httpRequestFactory = (CustomClientHttpRequestFactory) myAppUtils.getApplicationContext().getBean("httpRequestFactory");
httpRequestFactory.setTimeoutProperties(lUri);
restTemplate.setRequestFactory(httpRequestFactory);
responseString = restTemplate.postForObject(lUri, requestString, String.class);
XML 配置:
<bean id="httpRequestFactory" class="com.abc.xyz.customComponents.CustomClientHttpRequestFactory" scope="prototype"/>
<bean id="restTemplate" class="org.springframework.web.client.RestTemplate">
<property name="messageConverters">
<list>
<bean class="org.springframework.http.converter.StringHttpMessageConverter">
<property name = "supportedMediaTypes">
<list>
<value>text/xml;charset=UTF-8</value>
</list>
</property>
</bean>
</list>
</property>
</bean>
终于找到了问题并使其正常工作。
根本原因：
Spring 的 RestTemplate 默认使用 org.springframework.http.client.SimpleClientHttpRequestFactory 并且在多线程环境中存在问题。当在多线程环境中使用 SimpleClientHttpRequestFactory 并且根据您的某些规则使用了不止一组超时值时，这将造成问题（在我们的例子中，基于我正在使用的 URL 或服务的不同超时）。
A blog 突出显示相同。
这是有道理的，因为我在问题中谈到的 2 个环境的另一个区别是一个环境（一切都很好）总是有一个用户，这意味着只有一个线程，而另一个环境（我有问题的地方）有很多并发用户，这意味着多个线程。
解法：
使用 org.springframework.http.client.CommonsClientHttpRequestFactory，这是 Spring 版本 3.0.6 中可用的 org.springframework.http.client.ClientHttpRequestFactory 的另一种实现，并且在多线程环境中运行良好。
如果 Spring 版本是 3.0+ 则使用 HttpComponentsClientHttpRequestFactory.
我想使用 2 个服务并希望有不同的超时时间。所以，我覆盖了 Spring 的 SimpleClientHttpRequestFactory 并从我的 HttpDaoImpl.
现在一切都在一个环境中工作，但完全相同的 EAR 在其他环境中不起作用，两种环境的唯一区别是我连接的服务 URL 是负载平衡的 URL在一个和非 LB 中。问题出在负载平衡服务 URL.
问题是每次 httpReadTimeout 生效或被使用但不是 XYZHttpReadTimeout，即使我有条件地设置超时。
这是一个非常奇怪的问题，因为一切都在一个环境中工作。而不是在其他。到目前为止，我对可能的根本原因的猜测是负载平衡 URL 但我仍然看不出任何技术原因来说明为什么负载平衡 URL 可能会出现问题，因为我的机器将打开一个套接字并关闭它读取超时后。
我已经在 CustomClientHttpRequestFactory 中放置了记录器并验证了是否使用了正确的值，但最终不知何故读取超时没有按预期工作。
CustomClientHttpRequestFactory.java:
public class CustomClientHttpRequestFactory extends SimpleClientHttpRequestFactory{
private Log logger = LogFactory.getLog(CustomClientHttpRequestFactory.class);
@Value("${httpRequest.readTimeoutInMilliseconds}")
private Integer httpRequestTimeout;
@Value("${httpRequest.connectionTimeoutInMilliseconds}")
private Integer httpReadTimeout;
@Value("${XYZ.httpRequest.readTimeoutInMilliseconds}")
private Integer XYZHttpRequestTimeout;
@Value("${XYZ.httpRequest.connectionTimeoutInMilliseconds}")
private Integer XYZHttpReadTimeout;
@Value("${sgw.XYZHttp.service.url}")
private String XYZSystemUrl;
/**
* Overriding the default and setting a separate read timeout and HTTP connection timeout values for XYZ transactions.
*
* @param uri
*/
public void setTimeoutProperties(URI uri){
boolean isXYZTransaction = isXYZTransaction(uri);
Integer connectionTimeout = isXYZTransaction ? XYZHttpRequestTimeout : httpRequestTimeout;
Integer readTimeout = isXYZTransaction ? XYZHttpReadTimeout : httpReadTimeout;
logger.info("Setting " + connectionTimeout + " : " + readTimeout);
this.setReadTimeout(readTimeout);
this.setConnectTimeout(connectionTimeout);
}
private boolean isXYZTransaction(URI uri){
try {
URI XYZUrl = new URI(XYZSystemUrl);
logger.info("################################### XYZ Debug");
logger.info("XYZHttpRequestTimeout = " + XYZHttpRequestTimeout);
logger.info("XYZHttpReadTimeout = " + XYZHttpReadTimeout);
return XYZUrl.equals(uri);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
}
HttpDaoImpl:
CustomClientHttpRequestFactory httpRequestFactory = (CustomClientHttpRequestFactory) myAppUtils.getApplicationContext().getBean("httpRequestFactory");
httpRequestFactory.setTimeoutProperties(lUri);
restTemplate.setRequestFactory(httpRequestFactory);
responseString = restTemplate.postForObject(lUri, requestString, String.class);
XML 配置:
<bean id="httpRequestFactory" class="com.abc.xyz.customComponents.CustomClientHttpRequestFactory" scope="prototype"/>
<bean id="restTemplate" class="org.springframework.web.client.RestTemplate">
<property name="messageConverters">
<list>
<bean class="org.springframework.http.converter.StringHttpMessageConverter">
<property name = "supportedMediaTypes">
<list>
<value>text/xml;charset=UTF-8</value>
</list>
</property>
</bean>
</list>
</property>
</bean>
终于找到了问题并使其正常工作。
根本原因：
Spring 的 RestTemplate 默认使用 org.springframework.http.client.SimpleClientHttpRequestFactory 并且在多线程环境中存在问题。当在多线程环境中使用 SimpleClientHttpRequestFactory 并且根据您的某些规则使用了不止一组超时值时，这将造成问题（在我们的例子中，基于我正在使用的 URL 或服务的不同超时）。
A blog 突出显示相同。
这是有道理的，因为我在问题中谈到的 2 个环境的另一个区别是一个环境（一切都很好）总是有一个用户，这意味着只有一个线程，而另一个环境（我有问题的地方）有很多并发用户，这意味着多个线程。
解法：
使用 org.springframework.http.client.CommonsClientHttpRequestFactory，这是 Spring 版本 3.0.6 中可用的 org.springframework.http.client.ClientHttpRequestFactory 的另一种实现，并且在多线程环境中运行良好。
如果 Spring 版本是 3.0+ 则使用 HttpComponentsClientHttpRequestFactory.