[jetty-users] https (HTTP/1.1) request timeout

[Cao, William (NSB - CN/Qingdao)]

Hello,

I am trying to use Jetty client (9.4.7 and 9.2.24) to develop a https client (HTTP/1.1). When it tried to send out the request, the server can receive the request and respond it, and in the client side the jetty log also shows that it got 200 OK response. However, the client application got timeout. I think the major point is the onContent(Response response, ByteBuffer buffer, Callback callback), and we can call callback.succeeded() to terminate the onContent(...). How should I check that all the content is received so that I can call callback.succeeded() in onContent(...) so as to avoid the timeout?

Below is the jetty debug log and the code:

Padded plaintext after DECRYPTION: len = 456
0000: 48 54 54 50 2F 31 2E 31 20 32 30 30 20 4F 4B 0D HTTP/1.1 200 OK.
0010: 0A 53 65 6E 64 2D 54 69 6D 65 3A 20 31 35 32 36 .Send-Time: 1526
0020: 32 38 35 31 36 34 38 31 34 0D 0A 45 63 68 6F 2D 285164814..Echo-
...
The received content is <?xml version="1.0" encoding="UTF-8"?><cn:action xmlns:cn="urn:oma:xml:rest:netapi:callnotification:1"><actionToPerform>Continue</actionToPerform><decisionId>continue89271a52-08b6-4698-afd7-3e91a5b94050</decisionId></cn:action>
The request failed with Exception java.util.concurrent.TimeoutException: Total timeout 3000 ms elapsed

Exception with stacktrace: java.lang.Exception: java.util.concurrent.TimeoutException: Total timeout 3000 ms elapsed
com.mycom.securityas.http.HttpsRequestHandler$3.onFailure(HttpsRequestHandler.java:475)
org.eclipse.jetty.client.ResponseNotifier.notifyFailure(ResponseNotifier.java:170)
org.eclipse.jetty.client.ResponseNotifier.notifyFailure(ResponseNotifier.java:162)
org.eclipse.jetty.client.HttpReceiver.abort(HttpReceiver.java:533)
org.eclipse.jetty.client.HttpChannel.abortResponse(HttpChannel.java:129)
org.eclipse.jetty.client.HttpChannel.abort(HttpChannel.java:122)
org.eclipse.jetty.client.HttpExchange.abort(HttpExchange.java:257)
org.eclipse.jetty.client.HttpConversation.abort(HttpConversation.java:141)
org.eclipse.jetty.client.HttpRequest.abort(HttpRequest.java:748)
org.eclipse.jetty.client.TimeoutCompleteListener.run(TimeoutCompleteListener.java:71)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)


import org.eclipse.jetty.client.HttpClient;
import org.eclipse.jetty.client.api.Request;
import org.eclipse.jetty.client.api.Response;
import org.eclipse.jetty.client.api.Result;
import org.eclipse.jetty.client.util.BytesContentProvider;
import org.eclipse.jetty.http.HttpMethod;
import org.eclipse.jetty.util.Callback;
//......
public class HttpsRequestHandler {
......
private HttpClient httpsclient = null;
private SslContextFactory clientTLSFactory = null;

private void sendHttpsRequest(String destinationUrl, String msgBody) {

byte[] bytesBody = msgBody.getBytes(Charset.forName("UTF-8"));

Request httpsreq = client
.newRequest(destinationUrl)
.method(HttpMethod.POST)
.timeout(3000, TimeUnit.MILLISECONDS)
.content(new BytesContentProvider(bytesBody), "application/xml");
//...set headers ... ignored

httpsreq.send(new Response.Listener.Adapter() {

@Override
public void onContent(Response response, ByteBuffer buffer, Callback callback) {
System.out.println("Https request onContent 1");
StringBuffer sbf = new StringBuffer();

byte[] thebuffer = new byte[buffer.limit()];
buffer.get(thebuffer);
sbf.append(new String(thebuffer));

System.out.println("The received content is " + sbf.toString());
//callback.succeeded();
}

@Override
public void onFailure(Response response, Throwable failure) {
Exception e = new Exception(failure);
System.out.println("The request failed with Exception " + e.getMessage());
e.printStackTrace();
}

@Override
public void onSuccess(Response response) {
System.out.println("The request succeeded");
}
//...... //other logics
});
}


public boolean init() {}
clientTLSFactory = createSslContextFactory();
if (!startClient(clientTLSFactory)) {
return false;
}
return true;
}

private SslContextFactory createSslContextFactory() {
SslContextFactory sslContextFactory = new SslContextFactory();
sslContextFactory.setKeyStorePath("/etc/pki/CA/cert/trust.jks");
sslContextFactory.setKeyStorePassword("xxxxxxxxx");
sslContextFactory.setIncludeProtocols("TLSv1.2");
return sslContextFactory;
}

private boolean startClient(String v4IpLocal, SslContextFactory sslContextFactory)
{
//local ip settings, set IPv4 as the default binding address, and will be changed when sending request
InetSocketAddress socketOfLocal;

if ((v4IpLocal != null) && (!v4IpLocal.equals("none"))) {
socketOfLocal = new InetSocketAddress(v4IpLocal, 0);
} else {
return false;
}

QueuedThreadPool clientThreads = new QueuedThreadPool();
clientThreads.setName("httpsClient");

httpsclient = new HttpClient(sslContextFactory);
httpsclient.setExecutor(clientThreads);
httpsclient.setBindAddress(socketOfLocal);

httpsclient.setConnectTimeout(3000);
httpsclient.setIdleTimeout(0); //ms, persistent connection?
httpsclient.setRemoveIdleDestinations(false);
httpsclient.setStrictEventOrdering(false);
try {
httpsclient.start();
} catch (Exception e) {
e.printStackTrace();
return false;
}

return true;
}
//......
}

Best Regards,
William Cao

[Simone Bordet]

Hi,

On Mon, May 14, 2018 at 10:50 AM, Cao, William (NSB - CN/Qingdao)

Post by Cao, William (NSB - CN/Qingdao)
I am trying to use Jetty client (9.4.7 and 9.2.24) to develop a https client
(HTTP/1.1). When it tried to send out the request, the server can receive
the request and respond it, and in the client side the jetty log also shows
that it got 200 OK response. However, the client application got timeout. I
think the major point is the onContent(Response response, ByteBuffer buffer,
Callback callback), and we can call callback.succeeded() to terminate the
onContent(…). How should I check that all the content is received so that I
can call callback.succeeded() in onContent(…) so as to avoid the timeout?

onContent(...) may be called multiple times.
Every time you must call callback.succeeded() to signal that you have
processed the content and that you want to get the next content chunk.

[Cao, William (NSB - CN/Qingdao)]

Hi Simone,

Many thanks for the quick and nice response. It is clear now.

Best Regards,
William

-----Original Message-----
From: jetty-users-***@eclipse.org [mailto:jetty-users-***@eclipse.org] On Behalf Of Simone Bordet
Sent: 2018年5月14日 17:01
To: JETTY user mailing list <jetty-***@eclipse.org>
Subject: Re: [jetty-users] https (HTTP/1.1) request timeout

Hi,

Post by Cao, William (NSB - CN/Qingdao)
I am trying to use Jetty client (9.4.7 and 9.2.24) to develop a https
client (HTTP/1.1). When it tried to send out the request, the server
can receive the request and respond it, and in the client side the
jetty log also shows that it got 200 OK response. However, the client
application got timeout. I think the major point is the
onContent(Response response, ByteBuffer buffer, Callback callback),
and we can call callback.succeeded() to terminate the onContent(…).
How should I check that all the content is received so that I can call callback.succeeded() in onContent(…) so as to avoid the timeout?

onContent(...) may be called multiple times.
Every time you must call callback.succeeded() to signal that you have processed the content and that you want to get the next content chunk.
--
Simone Bordet
----
http://cometd.org
http://webtide.com
Developer advice, training, services and support from the Jetty & CometD experts.
_______________________________________________
jetty-users mailing list
jetty-***@eclipse.org
To change your delivery options, retrieve your password, or unsubscribe from this list, visit https://dev.eclipse.org/mailman/listinfo/jetty-users