Spring RestTemplate readtimeout属性不能正常工作 - 奇怪的问题

Question

我想要消耗2个服务,并希望有不同的超时.所以,我已经覆盖了Spring SimpleClientHttpRequestFactory并且使用了它HttpDaoImpl.

现在一切都工作在一个环境中,但完全一样的EAR不能在其他环境中工作,只有在这两个环境不同的是,我连接的服务URL是在一个非LB在其他负载平衡的URL.问题出现在负载均衡的服务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>

Answer 1

最后,找到了问题并使其正常运行.

根本原因:
Spring RestTemplate默认使用org.springframework.http.client.SimpleClientHttpRequestFactory,在多线程环境下出现问题.这将SimpleClientHttpRequestFactory在多线程环境中使用时出现问题,并且根据您的某些规则使用多组超时值(在我们的示例中,基于我正在使用的URL或服务的不同超时).

一个突出显示相同内容的博客.

这是有道理的,因为我在我的问题中谈到的两个环境中的另一个区别是一个环境(一切都很好)总是有一个用户,这意味着只有一个线程而另一个环境(我遇到问题)有很多并发用户,这意味着多个线程.

解决方案:
使用org.springframework.http.client.CommonsClientHttpRequestFactory,这是org.springframework.http.client.ClientHttpRequestFactorySpring 3.0.6 中提供的另一种实现,在多线程环境中运行良好.

如果Spring版本是3.0+然后使用HttpComponentsClientHttpRequestFactory.