Spring RestTemplate readtimeout 属性无法正常工作 - 奇怪的问题

Question

我想使用 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>

Answer 1

终于，找到了问题并解决了问题。

根本原因：
Spring 的RestTemplate 默认使用org.springframework.http.client.SimpleClientHttpRequestFactory，在多线程环境下会出现问题。如果在多线程环境中使用SimpleClientHttpRequestFactory 并且根据您的某些规则使用了一组以上的超时值（在我们的情况下，基于我正在使用的 URL 或服务的不同超时），这将产生问题。

blog 突出显示相同。

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

解决方案：
使用org.springframework.http.client.CommonsClientHttpRequestFactory，这是Spring 3.0.6 版本中org.springframework.http.client.ClientHttpRequestFactory 的另一种实现，在多线程环境中运行良好。

如果 Spring 版本是 3.0+，则使用 HttpComponentsClientHttpRequestFactory。