2

How can I set timeout? I have set almost all timeout configurations. Normally without proxy it works fine. The problem happens when I am connecting with Proxy connection details. Log show that it is getting connected and no reply is received.

2020-03-04 19:53:39,751 DEBUG [main] org.springframework.core.log.CompositeLog: HTTP POST https://destinationurl.io/api/agentmanagement/v3/oauth/token 2020-03-04 19:53:39,803 DEBUG [main] org.springframework.core.log.CompositeLog: Accept=[application/json, application/*+json] 2020-03-04 19:53:39,807 DEBUG [main] org.springframework.core.log.CompositeLog: Writing [grant_type=client_credentials&client_assertion_type=urn:ietf:params:oauth:client-assertion-type:jwt-bearer&client_assertion=token--cjKRDhVI0OuYo] as "application/x-www-form-urlencoded" 2020-03-04 19:53:39,821 DEBUG [main] org.apache.http.client.protocol.RequestAuthCache: Auth cache not set in the context 2020-03-04 19:53:39,823 DEBUG [main] org.apache.http.impl.conn.PoolingHttpClientConnectionManager: Connection request: [route: {tls}->http://proxyurl:3128->https://destinationurl.io:443][total kept alive: 0; route allocated: 0 of 20; total allocated: 0 of 100] 2020-03-04 19:53:39,838 DEBUG [main] org.apache.http.impl.conn.PoolingHttpClientConnectionManager: Connection leased: [id: 0][route: {tls}->http://proxyurl:3128->https://destinationurl.io:443][total kept alive: 0; route allocated: 1 of 20; total allocated: 1 of 100] 2020-03-04 19:53:39,839 DEBUG [main] org.apache.http.impl.execchain.MainClientExec: Opening connection {tls}->http://proxyurl:3128->https://destinationurl.io:443 2020-03-04 19:53:40,047 DEBUG [main] org.apache.http.impl.conn.DefaultHttpClientConnectionOperator: Connecting to proxyurl/35.158.73.29:3128 2020-03-04 19:53:40,420 DEBUG [main] org.apache.http.impl.conn.DefaultHttpClientConnectionOperator: Connection established 132.186.74.92:65173<->35.158.73.29:3128 2020-03-04 19:53:40,423 DEBUG [main] org.apache.http.impl.conn.LoggingManagedHttpClientConnection: http-outgoing-0 >> CONNECT destinationurl.io:443 HTTP/1.1 2020-03-04 19:53:40,424 DEBUG [main] org.apache.http.impl.conn.LoggingManagedHttpClientConnection: http-outgoing-0 >> Host: destinationurl.io 2020-03-04 19:53:40,424 DEBUG [main] org.apache.http.impl.conn.LoggingManagedHttpClientConnection: http-outgoing-0 >> User-Agent: Apache-HttpClient/4.5.10 (Java/1.8.0_201) 2020-03-04 19:53:40,424 DEBUG [main] org.apache.http.impl.conn.Wire: http-outgoing-0 >> "CONNECT destinationurl.io:443 HTTP/1.1[\r][\n]" 2020-03-04 19:53:40,424 DEBUG [main] org.apache.http.impl.conn.Wire: http-outgoing-0 >> "Host: destinationurl.io[\r][\n]" 2020-03-04 19:53:40,424 DEBUG [main] org.apache.http.impl.conn.Wire: http-outgoing-0 >> "User-Agent: Apache-HttpClient/4.5.10 (Java/1.8.0_201)[\r][\n]" 2020-03-04 19:53:40,424 DEBUG [main] org.apache.http.impl.conn.Wire: http-outgoing-0 >> "[\r][\n]"

Log is attached.

 <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> <version>4.5.11</version> </dependency>

Here is my config. I'm using spring boot 2.2.

PoolingHttpClientConnectionManager connectionManager; if (properties.isAllCertificateAllowed()) { connectionManager = new PoolingHttpClientConnectionManager( buildSocketFactoryRegistry(trustAllSslConnectionSocketFactory(trustAllSslContext()))); } else { connectionManager = new PoolingHttpClientConnectionManager(); } RequestConfig config = RequestConfig.custom() .setSocketTimeout(properties.getConnectTimeout()) .setConnectTimeout(properties.getConnectTimeout()) .setConnectionRequestTimeout(properties.getConnectTimeout()) .build(); /* HttpClientBuilder using http client connection connectionManager */ HttpClientBuilder httpClientBuilder = HttpClientBuilder.create() .setConnectionManager(connectionManager) .useSystemProperties() .disableCookieManagement() .setDefaultRequestConfig(config); HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory(); httpRequestFactory.setConnectTimeout(properties.getConnectTimeout()) ; httpRequestFactory.setReadTimeout(properties.getReadTimeout()); httpRequestFactory.setConnectionRequestTimeout(properties.getConnectionRequestTimeout()); if (properties.isProxyEnabled()) { log.info(properties.toString()); /* proxy username ,password name setting */ CredentialsProvider credentialsProvider = new BasicCredentialsProvider(); credentialsProvider.setCredentials( new AuthScope(properties.getProxyAddress(), properties.getProxyPort()), new UsernamePasswordCredentials( properties.getProxyUsername(), properties.getProxyPassword())); httpClientBuilder.setProxy( new HttpHost(properties.getProxyAddress(), properties.getProxyPort())); //TODO,"https" httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider); CloseableHttpClient httpClient = httpClientBuilder.build(); httpRequestFactory.setHttpClient(httpClient); } RestTemplate restTemplate = new RestTemplate(httpRequestFactory);
Improve this question
2
  • 1
    Seems like duplicate question. Please, check stackoverflow.com/questions/13837012/… Commented Mar 4, 2020 at 14:42
  • @RaufAgayev, thanks.. I checked them. I have done the same config. Did I miss something? Commented Mar 4, 2020 at 14:47

1 Answer 1

Reset to default
2

Looks like its a proxy problem. HTTP/HTTPS schema of proxy configuration should be checked with your given proxy details. You can give the option to trust all the certificates while creating the restTemplate. Please see the sample below for trusting all the certificates :-

Reference: Spring RestTemplate Connection Timeout is not working

Sample code :- 

@Bean public RestTemplate restTemplate(AgentManagementProperties properties) { PoolingHttpClientConnectionManager connectionManager; if (properties.isAllCertificateAllowed()) { connectionManager = new PoolingHttpClientConnectionManager( buildSocketFactoryRegistry(trustAllSslConnectionSocketFactory(trustAllSslContext()))); } else { connectionManager = new PoolingHttpClientConnectionManager(); } connectionManager.setMaxTotal(properties.getMaxPooledHttpConnections()); connectionManager.setDefaultMaxPerRoute(properties.getMaxHttpConnectionsPerRoute()); RequestConfig config = RequestConfig.custom() .setSocketTimeout(properties.getConnectTimeout()) .setConnectTimeout(properties.getConnectTimeout()) .setConnectionRequestTimeout(properties.getConnectTimeout()) .build(); /* HttpClientBuilder using http client connection connectionManager */ HttpClientBuilder httpClientBuilder = HttpClientBuilder.create() .setConnectionManager(connectionManager) .useSystemProperties() .disableCookieManagement() .setDefaultRequestConfig(config); HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory(); httpRequestFactory.setConnectTimeout(properties.getConnectTimeout()); httpRequestFactory.setReadTimeout(properties.getReadTimeout()); httpRequestFactory.setConnectionRequestTimeout(properties.getConnectionRequestTimeout()); if (properties.isProxyEnabled()) { // proxy username and password setting CredentialsProvider credentialsProvider = new BasicCredentialsProvider(); credentialsProvider.setCredentials( new AuthScope(properties.getProxyAddress(), properties.getProxyPort()), new UsernamePasswordCredentials( properties.getProxyUsername(), properties.getProxyPassword())); // proxy url, port and schema setting httpClientBuilder.setProxy( new HttpHost( properties.getProxyAddress(), properties.getProxyPort(), properties.getProxySchema())); httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider); CloseableHttpClient httpClient = httpClientBuilder.build(); httpRequestFactory.setHttpClient(httpClient); } return new RestTemplate(httpRequestFactory); } private static Registry<ConnectionSocketFactory> buildSocketFactoryRegistry( SSLConnectionSocketFactory sslConnectionSocketFactory) { return RegistryBuilder.<ConnectionSocketFactory>create() .register("http", new PlainConnectionSocketFactory()) .register("https", sslConnectionSocketFactory) .build(); } private static SSLConnectionSocketFactory trustAllSslConnectionSocketFactory( SSLContext sslContext) { return new SSLConnectionSocketFactory(sslContext); } private static SSLContext trustAllSslContext() { SSLContext sslContext = null; try { sslContext = SSLContext.getInstance("TLS"); sslContext.init( null, new TrustManager[] { new X509TrustManager() { public void checkClientTrusted(X509Certificate[] arg0, String arg1) { // NOT IMPLEMENTED Please refer SDK Core } public void checkServerTrusted(X509Certificate[] arg0, String arg1) { // NOT IMPLEMENTED Please refer SDK Core } public X509Certificate[] getAcceptedIssuers() { return new X509Certificate[0]; } } }, new SecureRandom()); } catch (KeyManagementException | NoSuchAlgorithmException e) { String errorMessage = "An error occured while configuring ssl context: {}"; log.error(errorMessage, e); } return sslContext; }
Improve this answer
Sign up to request clarification or add additional context in comments.

Comments

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.