Menu
▾
▴
resteasy-users
|
From: Borut B. <bor...@gm...> - 2013-10-11 10:38:20
|
Hello,
what is wrong with the code below? When using RestEasy Proxy Framework it
seems the client is not using the configuration for connection timeouts.
At line 54 there is a test url which returns response after 7 seconds, but
the call is not aborted as one might expect.
package si.najdi.httpclient;
import javax.ws.rs.ProcessingException;
import javax.ws.rs.core.Response;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.config.SocketConfig;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.jboss.resteasy.client.jaxrs.ResteasyClient;
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget;
import org.jboss.resteasy.client.jaxrs.engines.ApacheHttpClient4Engine;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Main {
static Logger logger = LoggerFactory.getLogger(Main.class);
public static void main(String[] args) {
logger.info("Starting HttpClient test.");
SocketConfig socketConfig = SocketConfig.custom()
.setTcpNoDelay(true)
.setSoKeepAlive(true)
.setSoReuseAddress(true)
.build();
PoolingHttpClientConnectionManager connManager = new
PoolingHttpClientConnectionManager();
connManager.setMaxTotal(100);
connManager.setDefaultMaxPerRoute(100);
connManager.setDefaultSocketConfig(socketConfig);
RequestConfig defaultRequestConfig = RequestConfig.custom()
.setSocketTimeout(2000)
.setConnectTimeout(100)
.setConnectionRequestTimeout(3000)
.setStaleConnectionCheckEnabled(true)
.build();
CloseableHttpClient httpClient = HttpClients.custom()
.setDefaultRequestConfig(defaultRequestConfig)
.setConnectionManager(connManager)
.build();
ApacheHttpClient4Engine apacheHttpClient4Engine = new
ApacheHttpClient4Engine(httpClient);
ResteasyClient client = new
ResteasyClientBuilder().httpEngine(apacheHttpClient4Engine).build();
//String host = "http://httpstat.us/400";
String host = "http://fake-response.appspot.com/?sleep=7";
ResteasyWebTarget newsWebTarget = client.target(host);
NewsClient newsClient = newsWebTarget.proxy(NewsClient.class);
boolean ok = false;
Response response = null;
try {
logger.info("Calling...");
response = newsClient.clickIncrement("666");
logger.info("...returning");
if (response.getStatus() == Response.Status.OK.getStatusCode()) {
String line = (String) response.readEntity(String.class);
logger.info("Response line: " + line);
} else {
String failMessage = response.getStatusInfo().getStatusCode() + " " +
response.getStatusInfo().getReasonPhrase();
logger.warn("Failed call. Reason: " + failMessage);
}
} catch (ProcessingException e) {
logger.warn("Exception incrementing click counter." + e);
} finally {
if (response != null) {
response.close();
}
}
}
}
Here is the client interface if it matters:
import javax.ws.rs.DefaultValue;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.core.Response;
public interface NewsClient {
@GET
//@Path("clickcounter/news/{newsId}")
Response clickIncrement(@PathParam("newsId") @DefaultValue("123")
String newsId);
}
The log output:
[12:05:46] INFO [si.najdi.httpclient.Main]: Starting HttpClient test.
[12:05:47] DEBUG [org.jboss.resteasy.plugins.providers.DocumentProvider]:
Unable to retrieve config: expandEntityReferences defaults to true
[12:05:47] DEBUG [org.jboss.resteasy.plugins.providers.DocumentProvider]:
Unable to retrieve config: expandEntityReferences defaults to true
[12:05:47] INFO [si.najdi.httpclient.Main]: Calling...
[12:05:54] INFO [si.najdi.httpclient.Main]: ...returning
[12:05:54] INFO [si.najdi.httpclient.Main]: Response line:
{"response":"This request has finsihed sleeping for 7 seconds"}
Best regards,
borut
|
|
From: Bill B. <bb...@re...> - 2013-10-11 12:34:52
|
Might be an Apache issue. Maybe try the timeout without Resteasy and
just an Apache call?
On 10/11/2013 6:37 AM, Borut Bolčina wrote:
> Hello,
>
> what is wrong with the code below? When using RestEasy Proxy Framework
> it seems the client is not using the configuration for connection timeouts.
>
> At line 54 there is a test url which returns response after 7 seconds,
> but the call is not aborted as one might expect.
>
> package si.najdi.httpclient;
>
> import javax.ws.rs.ProcessingException;
> import javax.ws.rs.core.Response;
>
> import org.apache.http.client.config.RequestConfig;
> import org.apache.http.config.SocketConfig;
> import org.apache.http.impl.client.CloseableHttpClient;
> import org.apache.http.impl.client.HttpClients;
> import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
> import org.jboss.resteasy.client.jaxrs.ResteasyClient;
> import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
> import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget;
> import org.jboss.resteasy.client.jaxrs.engines.ApacheHttpClient4Engine;
> import org.slf4j.Logger;
> import org.slf4j.LoggerFactory;
>
> public class Main {
>
> static Logger logger = LoggerFactory.getLogger(Main.class);
> public static void main(String[] args) {
> logger.info <http://logger.info>("Starting HttpClient test.");
> SocketConfig socketConfig = SocketConfig.custom()
> .setTcpNoDelay(true)
> .setSoKeepAlive(true)
> .setSoReuseAddress(true)
> .build();
> PoolingHttpClientConnectionManager connManager = new
> PoolingHttpClientConnectionManager();
> connManager.setMaxTotal(100);
> connManager.setDefaultMaxPerRoute(100);
> connManager.setDefaultSocketConfig(socketConfig);
> RequestConfig defaultRequestConfig = RequestConfig.custom()
> .setSocketTimeout(2000)
> .setConnectTimeout(100)
> .setConnectionRequestTimeout(3000)
> .setStaleConnectionCheckEnabled(true)
> .build();
> CloseableHttpClient httpClient = HttpClients.custom()
> .setDefaultRequestConfig(defaultRequestConfig)
> .setConnectionManager(connManager)
> .build();
> ApacheHttpClient4Engine apacheHttpClient4Engine = new
> ApacheHttpClient4Engine(httpClient);
> ResteasyClient client = new
> ResteasyClientBuilder().httpEngine(apacheHttpClient4Engine).build();
> //String host = "http://httpstat.us/400";
> String host = "http://fake-response.appspot.com/?sleep=7";
> ResteasyWebTarget newsWebTarget = client.target(host);
> NewsClient newsClient = newsWebTarget.proxy(NewsClient.class);
> boolean ok = false;
>
> Response response = null;
> try {
> logger.info <http://logger.info>("Calling...");
> response = newsClient.clickIncrement("666");
> logger.info <http://logger.info>("...returning");
>
> if (response.getStatus() == Response.Status.OK.getStatusCode()) {
> String line = (String) response.readEntity(String.class);
> logger.info <http://logger.info>("Response line: " + line);
> } else {
> String failMessage = response.getStatusInfo().getStatusCode() + " " +
> response.getStatusInfo().getReasonPhrase();
> logger.warn("Failed call. Reason: " + failMessage);
> }
> } catch (ProcessingException e) {
> logger.warn("Exception incrementing click counter." + e);
> } finally {
> if (response != null) {
> response.close();
> }
> }
> }
> }
>
>
> Here is the client interface if it matters:
>
> import javax.ws.rs.DefaultValue;
> import javax.ws.rs.GET;
> import javax.ws.rs.Path;
> import javax.ws.rs.PathParam;
> import javax.ws.rs.core.Response;
>
> public interface NewsClient {
>
> @GET
> //@Path("clickcounter/news/{newsId}")
> Response clickIncrement(@PathParam("newsId") @DefaultValue("123")
> String newsId);
> }
>
>
> The log output:
> [12:05:46] INFO [si.najdi.httpclient.Main]: Starting HttpClient test.
> [12:05:47] DEBUG
> [org.jboss.resteasy.plugins.providers.DocumentProvider]: Unable to
> retrieve config: expandEntityReferences defaults to true
> [12:05:47] DEBUG
> [org.jboss.resteasy.plugins.providers.DocumentProvider]: Unable to
> retrieve config: expandEntityReferences defaults to true
> [12:05:47] INFO [si.najdi.httpclient.Main]: Calling...
> [12:05:54] INFO [si.najdi.httpclient.Main]: ...returning
> [12:05:54] INFO [si.najdi.httpclient.Main]: Response line:
> {"response":"This request has finsihed sleeping for 7 seconds"}
>
>
> Best regards,
> borut
>
>
>
> ------------------------------------------------------------------------------
> October Webinars: Code for Performance
> Free Intel webinars can help you accelerate application performance.
> Explore tips for MPI, OpenMP, advanced profiling, and more. Get the most from
> the latest Intel processors and coprocessors. See abstracts and register >
> http://pubads.g.doubleclick.net/gampad/clk?id=60134071&iu=/4140/ostg.clktrk
>
>
>
> _______________________________________________
> Resteasy-users mailing list
> Res...@li...
> https://lists.sourceforge.net/lists/listinfo/resteasy-users
>
--
Bill Burke
JBoss, a division of Red Hat
http://bill.burkecentral.com
|
|
From: Bill B. <bb...@re...> - 2013-10-22 15:39:59
|
Then initialize the Reseasy client with the Http client you created in
the example.
On 10/22/2013 11:27 AM, Borut Bolčina wrote:
> Hi, this simple program which uses the same httpclient 4.3 works as
> expected. The timeout is respected. After 4 seconds you
> get java.net.SocketTimeoutException: Read timed out.
>
> So the bug is not with httpclient.
>
>
> import java.io.IOException;
>
> import org.apache.commons.lang.time.StopWatch;
> import org.apache.http.client.ClientProtocolException;
> import org.apache.http.client.config.RequestConfig;
> import org.apache.http.client.methods.CloseableHttpResponse;
> import org.apache.http.client.methods.HttpGet;
> import org.apache.http.config.SocketConfig;
> import org.apache.http.impl.client.CloseableHttpClient;
> import org.apache.http.impl.client.HttpClients;
> import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
> import org.slf4j.Logger;
> import org.slf4j.LoggerFactory;
>
> public class Main2 {
> static Logger logger = LoggerFactory.getLogger(Main2.class);
>
> public static void main(String[] args) {
> logger.info <http://logger.info>("Starting HttpClient test.");
> SocketConfig socketConfig = SocketConfig.custom()
> .setTcpNoDelay(true)
> .setSoKeepAlive(true)
> .setSoReuseAddress(true)
> .build();
> PoolingHttpClientConnectionManager connManager = new
> PoolingHttpClientConnectionManager();
> connManager.setMaxTotal(100);
> connManager.setDefaultMaxPerRoute(100);
> connManager.setDefaultSocketConfig(socketConfig);
> RequestConfig defaultRequestConfig = RequestConfig.custom()
> .setSocketTimeout(4000)
> .setConnectTimeout(2000)
> .setConnectionRequestTimeout(1000)
> .setStaleConnectionCheckEnabled(true)
> .build();
> CloseableHttpClient httpClient = HttpClients.custom()
> .setDefaultRequestConfig(defaultRequestConfig)
> .setConnectionManager(connManager)
> .build();
> String host = "http://fake-response.appspot.com/?sleep=7";
> HttpGet httpget = new HttpGet(host);
> CloseableHttpResponse response = null;
> StopWatch sw = new StopWatch();
> try {
> sw.start();
> response = httpClient.execute(httpget);
> System.out.println(response.getProtocolVersion());
> System.out.println(response.getStatusLine().getStatusCode());
> System.out.println(response.getStatusLine().getReasonPhrase());
> System.out.println(response.getStatusLine().toString());
> } catch (ClientProtocolException e) {
> e.printStackTrace();
> } catch (IOException e) {
> e.printStackTrace();
> } finally {
> try {
> sw.stop();
> System.out.println(sw);
> response.close();
> } catch (IOException e) {
> e.printStackTrace();
> }
> }
> }
> }
>
> Best regards,
> borut
>
>
> 2013/10/11 Bill Burke <bb...@re... <mailto:bb...@re...>>
>
> Might be an Apache issue. Maybe try the timeout without Resteasy and
> just an Apache call?
>
> On 10/11/2013 6:37 AM, Borut Bolčina wrote:
> > Hello,
> >
> > what is wrong with the code below? When using RestEasy Proxy
> Framework
> > it seems the client is not using the configuration for connection
> timeouts.
> >
> > At line 54 there is a test url which returns response after 7
> seconds,
> > but the call is not aborted as one might expect.
> >
> > package si.najdi.httpclient;
> >
> > import javax.ws.rs.ProcessingException;
> > import javax.ws.rs.core.Response;
> >
> > import org.apache.http.client.config.RequestConfig;
> > import org.apache.http.config.SocketConfig;
> > import org.apache.http.impl.client.CloseableHttpClient;
> > import org.apache.http.impl.client.HttpClients;
> > import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
> > import org.jboss.resteasy.client.jaxrs.ResteasyClient;
> > import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
> > import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget;
> > import
> org.jboss.resteasy.client.jaxrs.engines.ApacheHttpClient4Engine;
> > import org.slf4j.Logger;
> > import org.slf4j.LoggerFactory;
> >
> > public class Main {
> >
> > static Logger logger = LoggerFactory.getLogger(Main.class);
> > public static void main(String[] args) {
> > logger.info <http://logger.info> <http://logger.info>("Starting
> HttpClient test.");
> > SocketConfig socketConfig = SocketConfig.custom()
> > .setTcpNoDelay(true)
> > .setSoKeepAlive(true)
> > .setSoReuseAddress(true)
> > .build();
> > PoolingHttpClientConnectionManager connManager = new
> > PoolingHttpClientConnectionManager();
> > connManager.setMaxTotal(100);
> > connManager.setDefaultMaxPerRoute(100);
> > connManager.setDefaultSocketConfig(socketConfig);
> > RequestConfig defaultRequestConfig = RequestConfig.custom()
> > .setSocketTimeout(2000)
> > .setConnectTimeout(100)
> > .setConnectionRequestTimeout(3000)
> > .setStaleConnectionCheckEnabled(true)
> > .build();
> > CloseableHttpClient httpClient = HttpClients.custom()
> > .setDefaultRequestConfig(defaultRequestConfig)
> > .setConnectionManager(connManager)
> > .build();
> > ApacheHttpClient4Engine apacheHttpClient4Engine = new
> > ApacheHttpClient4Engine(httpClient);
> > ResteasyClient client = new
> > ResteasyClientBuilder().httpEngine(apacheHttpClient4Engine).build();
> > //String host = "http://httpstat.us/400";
> > String host = "http://fake-response.appspot.com/?sleep=7";
> > ResteasyWebTarget newsWebTarget = client.target(host);
> > NewsClient newsClient = newsWebTarget.proxy(NewsClient.class);
> > boolean ok = false;
> >
> > Response response = null;
> > try {
> > logger.info <http://logger.info> <http://logger.info>("Calling...");
> > response = newsClient.clickIncrement("666");
> > logger.info <http://logger.info>
> <http://logger.info>("...returning");
> >
> > if (response.getStatus() == Response.Status.OK.getStatusCode()) {
> > String line = (String) response.readEntity(String.class);
> > logger.info <http://logger.info> <http://logger.info>("Response
> line: " + line);
> > } else {
> > String failMessage = response.getStatusInfo().getStatusCode() + " " +
> > response.getStatusInfo().getReasonPhrase();
> > logger.warn("Failed call. Reason: " + failMessage);
> > }
> > } catch (ProcessingException e) {
> > logger.warn("Exception incrementing click counter." + e);
> > } finally {
> > if (response != null) {
> > response.close();
> > }
> > }
> > }
> > }
> >
> >
> > Here is the client interface if it matters:
> >
> > import javax.ws.rs.DefaultValue;
> > import javax.ws.rs.GET;
> > import javax.ws.rs.Path;
> > import javax.ws.rs.PathParam;
> > import javax.ws.rs.core.Response;
> >
> > public interface NewsClient {
> >
> > @GET
> > //@Path("clickcounter/news/{newsId}")
> > Response clickIncrement(@PathParam("newsId")
> @DefaultValue("123")
> > String newsId);
> > }
> >
> >
> > The log output:
> > [12:05:46] INFO [si.najdi.httpclient.Main]: Starting HttpClient
> test.
> > [12:05:47] DEBUG
> > [org.jboss.resteasy.plugins.providers.DocumentProvider]: Unable to
> > retrieve config: expandEntityReferences defaults to true
> > [12:05:47] DEBUG
> > [org.jboss.resteasy.plugins.providers.DocumentProvider]: Unable to
> > retrieve config: expandEntityReferences defaults to true
> > [12:05:47] INFO [si.najdi.httpclient.Main]: Calling...
> > [12:05:54] INFO [si.najdi.httpclient.Main]: ...returning
> > [12:05:54] INFO [si.najdi.httpclient.Main]: Response line:
> > {"response":"This request has finsihed sleeping for 7 seconds"}
> >
> >
> > Best regards,
> > borut
> >
> >
> >
> >
> ------------------------------------------------------------------------------
> > October Webinars: Code for Performance
> > Free Intel webinars can help you accelerate application performance.
> > Explore tips for MPI, OpenMP, advanced profiling, and more. Get
> the most from
> > the latest Intel processors and coprocessors. See abstracts and
> register >
> >
> http://pubads.g.doubleclick.net/gampad/clk?id=60134071&iu=/4140/ostg.clktrk
> >
> >
> >
> > _______________________________________________
> > Resteasy-users mailing list
> > Res...@li...
> <mailto:Res...@li...>
> > https://lists.sourceforge.net/lists/listinfo/resteasy-users
> >
>
> --
> Bill Burke
> JBoss, a division of Red Hat
> http://bill.burkecentral.com
>
> ------------------------------------------------------------------------------
> October Webinars: Code for Performance
> Free Intel webinars can help you accelerate application performance.
> Explore tips for MPI, OpenMP, advanced profiling, and more. Get the
> most from
> the latest Intel processors and coprocessors. See abstracts and
> register >
> http://pubads.g.doubleclick.net/gampad/clk?id=60134071&iu=/4140/ostg.clktrk
> _______________________________________________
> Resteasy-users mailing list
> Res...@li...
> <mailto:Res...@li...>
> https://lists.sourceforge.net/lists/listinfo/resteasy-users
>
>
--
Bill Burke
JBoss, a division of Red Hat
http://bill.burkecentral.com
|
Thanks for helping keep SourceForge clean.
X