問題:http請求發(fā)起后接收不到返回數(shù)據(jù)!??!【測試環(huán)境沒出問題,發(fā)到正式環(huán)境就有問題】
項(xiàng)目中通過restTemplate發(fā)起請求:
log.info("請求入?yún)?{}",JSON.toJSONString(request));//打印日志1
// 配置http請求的連接超時時間和讀取超時時間
HttpsClientRequestFactory factory = new HttpsClientRequestFactory();
factory.setConnectTimeout(60 * 1000);
factory.setReadTimeout(5 * 60 * 1000);
RestTemplate restTemplate = new RestTemplate(factory);
Result<InventoryResult> result = restTemplate.postForObject(address.concat(inventoryUrl), request, Result.class);
log.info("庫存同步,返回數(shù)據(jù): {}", result);//打印日志2
打印日志1內(nèi)容為:
http請求入?yún)?{data=[{ productStatus=10,skuCode=null}], messageId=ewpfpr1t6ey5r6qj0su0w1h6rt73hr,token=vgvU5EJKuZbuHii7WH6pTINp40ZRicaqLz4dq5P7L6pDzWir8EEGZhCKPucQjljsw69EHasEy+iJfdTofDg==}
日志打印2沒有打印內(nèi)容?。?!
最后發(fā)現(xiàn)是因?yàn)闇y試環(huán)境中數(shù)據(jù)量較小,http請求后,很快能得到相應(yīng),而正式環(huán)境數(shù)據(jù)量較大,沒有及時得到響應(yīng),連接或者讀取超時?。。?/p>
三種解決方式:
第一種
1、添加HttpsClientRequestFactory 類,并繼承SimpleClientHttpRequestFactory?
/**
* 兼容調(diào)Https接口
*/
public class HttpsClientRequestFactory extends SimpleClientHttpRequestFactory {
@Override
protected void prepareConnection(HttpURLConnection connection, String httpMethod)
throws IOException {
if (connection instanceof HttpsURLConnection) {
prepareHttpsConnection((HttpsURLConnection) connection);
}
super.prepareConnection(connection, httpMethod);
}
private void prepareHttpsConnection(HttpsURLConnection connection) {
connection.setHostnameVerifier(new SkipHostnameVerifier());
try {
connection.setSSLSocketFactory(createSslSocketFactory());
}
catch (Exception ex) {
// Ignore
}
}
private SSLSocketFactory createSslSocketFactory() throws Exception {
SSLContext context = SSLContext.getInstance("TLS");
context.init(null, new TrustManager[] { new SkipX509TrustManager() },
new SecureRandom());
return context.getSocketFactory();
}
private class SkipHostnameVerifier implements HostnameVerifier {
@Override
public boolean verify(String s, SSLSession sslSession) {
return true;
}
}
private static class SkipX509TrustManager implements X509TrustManager {
@Override
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[0];
}
@Override
public void checkClientTrusted(X509Certificate[] chain, String authType) {
}
@Override
public void checkServerTrusted(X509Certificate[] chain, String authType) {
}
}
}
2、使用restTemplate發(fā)起請求前先設(shè)置連接和超時時間即可;
//配置http請求的連接超時時間和讀取超時時間
HttpsClientRequestFactory factory = new HttpsClientRequestFactory();
factory.setConnectTimeout(60 * 1000);
factory.setReadTimeout(5 * 60 * 1000);
RestTemplate restTemplate = new RestTemplate(factory);
BaseResult<QueryInventoryResult> result = restTemplate.postForObject(address.concat(inventoryUrl), request, Result.class);
或者通過容器加載配置類,然后設(shè)置超時時間進(jìn)去,使用的時候直接注入restTemplate即可??;
@Configuration
public class RestConfig {
//60 * 1000
@Value("${rest.connectTimeout:60000}")
private int connectTimeout;
//5 * 60 * 1000
@Value("${rest.readTimeout:300000}")
private int readTimeout;
@Bean
public RestTemplate restTemplate() {
SimpleClientHttpRequestFactory simpleClientHttpRequestFactory = new SimpleClientHttpRequestFactory();
simpleClientHttpRequestFactory.setConnectTimeout(connectTimeout);
simpleClientHttpRequestFactory.setReadTimeout(readTimeout);
RestTemplate restTemplate = new RestTemplate(simpleClientHttpRequestFactory);
return restTemplate;
}
第二種
@Configuration
public class RestConfig {
//60 * 1000
@Value("${rest.connectTimeout:60000}")
private int connectTimeout;
//5 * 60 * 1000
@Value("${rest.readTimeout:300000}")
private int readTimeout;
@Value("${rest.connectionRequestTimeout:300000}")
private int connectionRequestTimeout;
/**
* 使用 HttpComponentsClientHttpRequestFactory創(chuàng)建http請求(推薦)
*/
@Bean
public RestTemplate restTemplate() {
HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();
httpRequestFactory.setConnectionRequestTimeout(connectionRequestTimeout);
httpRequestFactory.setConnectTimeout(connectTimeout);
httpRequestFactory.setReadTimeout(readTimeout);
return new RestTemplate(httpRequestFactory);
}
}
第三種(基于第二種升級)文章來源:http://www.zghlxwxcb.cn/news/detail-502313.html
@Configuration
public class RestConfig {
/**
* 高并發(fā)采用HttpClient連接池
*/
@Bean
public RestTemplate restTemplate() {
return new RestTemplate(httpRequestFactory());
}
@Bean
public ClientHttpRequestFactory httpRequestFactory() {
return new HttpComponentsClientHttpRequestFactory(httpClient());
}
@Bean
public HttpClient httpClient() {
Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.getSocketFactory())
.register("https", SSLConnectionSocketFactory.getSocketFactory())
.build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);
//設(shè)置整個連接池最大連接數(shù)
connectionManager.setMaxTotal(400);
//路由是對maxTotal的細(xì)分
connectionManager.setDefaultMaxPerRoute(100);
RequestConfig requestConfig = RequestConfig.custom()
.setSocketTimeout(30000) //返回數(shù)據(jù)的超時時間
.setConnectTimeout(20000) //連接上服務(wù)器的超時時間
.setConnectionRequestTimeout(1000) //從連接池中獲取連接的超時時間
.build();
return HttpClientBuilder.create()
.setDefaultRequestConfig(requestConfig)
.setConnectionManager(connectionManager)
.build();
}
}
問題得到解決、、、、、、文章來源地址http://www.zghlxwxcb.cn/news/detail-502313.html
到了這里,關(guān)于java中http請求之restTemplate配置超時時間(親測有用?。┑奈恼戮徒榻B完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!