Skip to content

Commit

Permalink
[JBEAP-12012] : ApacheHttpClient4Engine ignores HttpClient#defaultReq…
Browse files Browse the repository at this point in the history
…uestConfig.
  • Loading branch information
panossot committed Jul 17, 2017
1 parent 4516bcc commit 17346e6
Show file tree
Hide file tree
Showing 7 changed files with 548 additions and 23 deletions.
2 changes: 1 addition & 1 deletion jaxrs/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@
<version.org.glassfish.javax.el>3.0.0</version.org.glassfish.javax.el>
<version.io.undertow>1.2.8.Final</version.io.undertow>
<version.com.fasterxml.jackson>2.6.3</version.com.fasterxml.jackson>
<version.org.apache.httpcomponents>4.3.6</version.org.apache.httpcomponents>
<version.org.apache.httpcomponents>4.5.2</version.org.apache.httpcomponents>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<!-- java 7-->
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,171 @@
package org.jboss.resteasy.client.jaxrs;

import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocket;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.TrustManager;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.HttpClientConnectionManager;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.DefaultHostnameVerifier;
import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
import org.apache.http.ssl.SSLContexts;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.conn.BasicHttpClientConnectionManager;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.jboss.resteasy.client.jaxrs.engines.ApacheHttpClient43Engine;
import org.jboss.resteasy.client.jaxrs.engines.PassthroughTrustManager;
import org.jboss.resteasy.client.jaxrs.engines.factory.ApacheHttpClient4EngineFactory;

import java.io.IOException;
import java.security.SecureRandom;


/**
* A temporary class for transition between Apache pre-4.3 apis and 4.3.
* Must maintain support for HttpClient creation in ResteasyClientBuilder
* and creation of HttpClient that refs 4.3 classes not available in pre-4.3.
* This usage allows pre-4.3 resteasy tests to continue to run successful.
*
* User: rsearls
* Date: 5/24/16
*/
public class HttpClientBuilder43 {

/**
* Create ClientHttpEngine using Apache 4.3.x+ apis.
* @return
*/
protected static ClientHttpEngine initDefaultEngine43(final ResteasyClientBuilder that)
{
HttpClient httpClient = null;

HostnameVerifier verifier = null;
if (that.verifier != null) {
verifier = new ResteasyClientBuilder.VerifierWrapper(that.verifier);
}
else
{
switch (that.policy)
{
case ANY:
verifier = new NoopHostnameVerifier();
break;
case WILDCARD:
verifier = new DefaultHostnameVerifier();
break;
case STRICT:
verifier = new DefaultHostnameVerifier();
break;
}
}
try
{
SSLConnectionSocketFactory sslsf = null;
SSLContext theContext = that.sslContext;
if (that.disableTrustManager)
{
theContext = SSLContext.getInstance("SSL");
theContext.init(null, new TrustManager[]{new PassthroughTrustManager()},
new SecureRandom());
verifier = new NoopHostnameVerifier();
sslsf = new SSLConnectionSocketFactory(theContext, verifier);
}
else if (theContext != null)
{
sslsf = new SSLConnectionSocketFactory(theContext, verifier) {
@Override
protected void prepareSocket(SSLSocket socket) throws IOException
{
that.prepareSocketForSni(socket);
}
};
}
else if (that.clientKeyStore != null || that.truststore != null)
{
SSLContext ctx = SSLContexts.custom()
.useProtocol(SSLConnectionSocketFactory.TLS)
.setSecureRandom(null)
.loadKeyMaterial(that.clientKeyStore,
that.clientPrivateKeyPassword != null ? that.clientPrivateKeyPassword.toCharArray() : null)
.loadTrustMaterial(that.truststore, TrustSelfSignedStrategy.INSTANCE)
.build();
sslsf = new SSLConnectionSocketFactory(ctx, verifier) {
@Override
protected void prepareSocket(SSLSocket socket) throws IOException
{
that.prepareSocketForSni(socket);
}
};
}
else
{
final SSLContext tlsContext = SSLContext.getInstance(SSLConnectionSocketFactory.TLS);
tlsContext.init(null, null, null);
sslsf = new SSLConnectionSocketFactory(tlsContext, verifier);
}

final Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.getSocketFactory())
.register("https", sslsf)
.build();

HttpClientConnectionManager cm = null;
if (that.connectionPoolSize > 0)
{
PoolingHttpClientConnectionManager tcm = new PoolingHttpClientConnectionManager(
registry, null, null ,null, that.connectionTTL, that.connectionTTLUnit);
tcm.setMaxTotal(that.connectionPoolSize);
if (that.maxPooledPerRoute == 0) {
that.maxPooledPerRoute = that.connectionPoolSize;
}
tcm.setDefaultMaxPerRoute(that.maxPooledPerRoute);
cm = tcm;

}
else
{
cm = new BasicHttpClientConnectionManager(registry);
}

RequestConfig.Builder rcBuilder = RequestConfig.custom();
if (that.socketTimeout > -1)
{
rcBuilder.setSocketTimeout((int) that.socketTimeoutUnits.toMillis(that.socketTimeout));
}
if (that.establishConnectionTimeout > -1)
{
rcBuilder.setConnectTimeout((int)that.establishConnectionTimeoutUnits.toMillis(that.establishConnectionTimeout));
}
if (that.connectionCheckoutTimeoutMs > -1)
{
rcBuilder.setConnectionRequestTimeout(that.connectionCheckoutTimeoutMs);
}

httpClient = HttpClientBuilder.create()
.setConnectionManager(cm)
.setDefaultRequestConfig(rcBuilder.build())
.setProxy(that.defaultProxy)
.disableContentCompression()
.build();
ApacheHttpClient43Engine engine =
(ApacheHttpClient43Engine) ApacheHttpClient4EngineFactory.create(httpClient, true);
engine.setResponseBufferSize(that.responseBufferSize);
engine.setHostnameVerifier(verifier);
// this may be null. We can't really support this with Apache Client.
engine.setSslContext(theContext);
return engine;
}
catch (Exception e)
{
throw new RuntimeException(e);
}
}

}

0 comments on commit 17346e6

Please sign in to comment.