我想要消耗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或服务的不同超时),这将引发问题.

一个blog突出显示相同.

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

解：
使用org.springframework.http.client.CommonsClientHttpRequestFactory,它是Spring 3.0.6版中提供的org.springframework.http.client.ClientHttpRequestFactory的另一个实现,在多线程环境中运行良好.

如果Spring版本是3.0,那么使用HttpComponentsClientHttpRequestFactory.