Mailing-List: contact httpclient-users-help@hc.apache.org; run by ezmlm
Precedence: bulk
Reply-To: "HttpClient User Discussion" <httpclient-users@hc.apache.org>
Received-SPF: neutral (athena.apache.org: local policy)
From: James Puckett <jpuckett@e-c-group.com>
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: quoted-printable
Subject: inputStream.read() blocks at end of chunk
Message-Id: <9FE5A679-A08B-4082-B428-A091B78B6164@e-c-group.com>
Date: Mon, 1 Apr 2013 17:32:48 -0400
To: httpclient-users@hc.apache.org
Mime-Version: 1.0 (Mac OS X Mail 6.3 \(1503\))

I need a persistent Http connection over which I will receive multiple =
XML responses.  Each XML response should be a chunk from the server.

I'm using httpclient-4.2.3 and the following code.  Currently, the =
HttpClient blocks on the inputStream.read() on the character following =
the of the chunk.  The read eventually (~15 seconds) returns and things =
continue.  I should note that the first read() fills the buffer with the =
180 (b4) chars of the first chunk.  It's the second read that blocks.


Is there a way to get access to the chunk size prior to the read?  In =
the case capture in the DEBUG output below, it's 180 (b4) chars.

Or is there a better way to read this full chunk, even if it spans =
multiple buffers and therefore multiple reads?


=3D=3D

		try {
			response =3D httpClient.execute(post);
			System.out.println("OUTPUT: " + =
Runner.getURIBase() + request.getURIPath() + "\n" + postContent);

			HttpEntity entity =3D response.getEntity();

			byte[] buffer =3D new byte[1024];
			if (entity !=3D null) {
				InputStream inputStream =3D =
entity.getContent();
				try {
					while (!done) {

						StringBuilder sb =3D new =
StringBuilder();
						int bytesRead =3D 0;
						while ((bytesRead =3D =
inputStream.read(buffer)) !=3D -1) {
							String chunk =3D =
new String(buffer, 0, bytesRead);
							=
System.out.println("CHUNK?: " + chunk);
							=
sb.append(chunk);
						}
					=09
						// TODO: Need to check =
here for multiple messages in the same chunk
						if (sb.length() > 0) {
							=
System.out.println("CHUNK: " + sb.toString());
							=
BroadWorksResponse broadworksResponse =3D BroadWorksResponse
									=
.getResponse(sb.toString());
						=09
						=09
							if =
(broadworksResponse !=3D null)
								=
broadworksResponse.fireNextEvent();
						=09
							sb.setLength(0);
						}

						//
					}
				} catch (Exception e) {
					e.printStackTrace();
				} finally {
					try {
						inputStream.close();
					} catch (Exception ignore) {
					}
				}

			}

		} catch (ClientProtocolException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}


DEBUG [org.apache.http.impl.conn.DefaultClientConnection] Sending =
request: POST /com.broadsoft.async/com.broadsoft.xsi-events/v2.0/channel =
HTTP/1.1
DEBUG [org.apache.http.wire] >> "POST =
/com.broadsoft.async/com.broadsoft.xsi-events/v2.0/channel =
HTTP/1.1[\r][\n]"
DEBUG [org.apache.http.wire] >> "Content-Length: 233[\r][\n]"
DEBUG [org.apache.http.wire] >> "Content-Type: text/plain; =
charset=3DISO-8859-1[\r][\n]"
DEBUG [org.apache.http.wire] >> "Host: ews1.vwave.net:80[\r][\n]"
DEBUG [org.apache.http.wire] >> "Connection: Keep-Alive[\r][\n]"
DEBUG [org.apache.http.wire] >> "User-Agent: Apache-HttpClient/4.2.3 =
(java 1.5)[\r][\n]"
DEBUG [org.apache.http.wire] >> "Cookie: =
JSESSIONID=3DC041612511AE5606103DC6CDB2C79973[\r][\n]"
DEBUG [org.apache.http.wire] >> "Cookie2: $Version=3D1[\r][\n]"
DEBUG [org.apache.http.wire] >> "Authorization: Basic =
MjI5MzE2MDAxMkB2d2F2ZS5uZXQ6c2lnbmFsbWUwMQ=3D=3D[\r][\n]"
DEBUG [org.apache.http.wire] >> "[\r][\n]"
DEBUG [org.apache.http.headers] >> POST =
/com.broadsoft.async/com.broadsoft.xsi-events/v2.0/channel HTTP/1.1
DEBUG [org.apache.http.headers] >> Content-Length: 233
DEBUG [org.apache.http.headers] >> Content-Type: text/plain; =
charset=3DISO-8859-1
DEBUG [org.apache.http.headers] >> Host: ews1.vwave.net:80
DEBUG [org.apache.http.headers] >> Connection: Keep-Alive
DEBUG [org.apache.http.headers] >> User-Agent: Apache-HttpClient/4.2.3 =
(java 1.5)
DEBUG [org.apache.http.headers] >> Cookie: =
JSESSIONID=3DC041612511AE5606103DC6CDB2C79973
DEBUG [org.apache.http.headers] >> Cookie2: $Version=3D1
DEBUG [org.apache.http.headers] >> Authorization: Basic =
MjI5MzE2MDAxMkB2d2F2ZS5uZXQ6c2lnbmFsbWUwMQ=3D=3D
DEBUG [org.apache.http.wire] >> "<?xml version=3D"1.0" encoding=3D"UTF-8" =
standalone=3D"no"?>[\n]"
DEBUG [org.apache.http.wire] >> "<Channel =
xmlns=3D"http://schema.broadsoft.com/xsi">[\n]"
DEBUG [org.apache.http.wire] >> =
"<channelSetId>TempTestChannelSetId</channelSetId>[\n]"
DEBUG [org.apache.http.wire] >> "<priority>1</priority>[\n]"
DEBUG [org.apache.http.wire] >> "<weight>50</weight>[\n]"
DEBUG [org.apache.http.wire] >> "<expires>3600</expires>[\n]"
DEBUG [org.apache.http.wire] >> "</Channel>[\n]"
DEBUG [org.apache.http.wire] << "HTTP/1.1 200 OK[\r][\n]"
DEBUG [org.apache.http.wire] << "Date: Mon, 01 Apr 2013 21:21:46 =
GMT[\r][\n]"
DEBUG [org.apache.http.wire] << "Server: Apache-Coyote/1.1[\r][\n]"
DEBUG [org.apache.http.wire] << "Expires: Thu, 01 Jan 1970 00:00:00 =
GMT[\r][\n]"
DEBUG [org.apache.http.wire] << "Content-Language: en-US[\r][\n]"
DEBUG [org.apache.http.wire] << "Cache-Control: no-store[\r][\n]"
DEBUG [org.apache.http.wire] << "Pragma: no-cache[\r][\n]"
DEBUG [org.apache.http.wire] << "Content-Type: =
application/xml;charset=3DUTF-8[\r][\n]"
DEBUG [org.apache.http.wire] << "Set-Cookie: =
JSESSIONID=3DBC1A855C506266CB346506641C735FFC; =
Path=3D/com.broadsoft.xsi-events[\r][\n]"
DEBUG [org.apache.http.wire] << "Keep-Alive: timeout=3D15, =
max=3D98[\r][\n]"
DEBUG [org.apache.http.wire] << "Connection: Keep-Alive[\r][\n]"
DEBUG [org.apache.http.wire] << "Transfer-Encoding: chunked[\r][\n]"
DEBUG [org.apache.http.wire] << "[\r][\n]"
DEBUG [org.apache.http.impl.conn.DefaultClientConnection] Receiving =
response: HTTP/1.1 200 OK
DEBUG [org.apache.http.headers] << HTTP/1.1 200 OK
DEBUG [org.apache.http.headers] << Date: Mon, 01 Apr 2013 21:21:46 GMT
DEBUG [org.apache.http.headers] << Server: Apache-Coyote/1.1
DEBUG [org.apache.http.headers] << Expires: Thu, 01 Jan 1970 00:00:00 =
GMT
DEBUG [org.apache.http.headers] << Content-Language: en-US
DEBUG [org.apache.http.headers] << Cache-Control: no-store
DEBUG [org.apache.http.headers] << Pragma: no-cache
DEBUG [org.apache.http.headers] << Content-Type: =
application/xml;charset=3DUTF-8
DEBUG [org.apache.http.headers] << Set-Cookie: =
JSESSIONID=3DBC1A855C506266CB346506641C735FFC; =
Path=3D/com.broadsoft.xsi-events
DEBUG [org.apache.http.headers] << Keep-Alive: timeout=3D15, max=3D98
DEBUG [org.apache.http.headers] << Connection: Keep-Alive
DEBUG [org.apache.http.headers] << Transfer-Encoding: chunked
 WARN [org.apache.http.client.protocol.ResponseProcessCookies] Cookie =
rejected: "[version: 0][name: JSESSIONID][value: =
BC1A855C506266CB346506641C735FFC][domain: ews1.vwave.net][path: =
/com.broadsoft.xsi-events][expiry: null]". Illegal path attribute =
"/com.broadsoft.xsi-events". Path of origin: =
"/com.broadsoft.async/com.broadsoft.xsi-events/v2.0/channel"
DEBUG [org.apache.http.impl.client.DefaultHttpClient] Connection can be =
kept alive for 15000 MILLISECONDS
DEBUG [org.apache.http.impl.client.DefaultHttpClient] Authentication =
succeeded
DEBUG [org.apache.http.impl.client.TargetAuthenticationStrategy] Caching =
'basic' auth scheme for http://ews1.vwave.net:80
OUTPUT: =
http://ews1.vwave.net:80/com.broadsoft.async/com.broadsoft.xsi-events/v2.0=
/channel
org.apache.http.entity.StringEntity@78c36c6f
DEBUG [org.apache.http.wire] << "b4[\r][\n]"
DEBUG [org.apache.http.wire] << "<?xml version=3D"1.0" =
encoding=3D"UTF-8"?>[\n]"
DEBUG [org.apache.http.wire] << "<Channel =
xmlns=3D"http://schema.broadsoft.com/xsi"><channelId>c9d5b432-db96-4256-87=
71-cdb6e3a1e897</channelId><expires>3600</expires></Channel>"
CHUNK?: <?xml version=3D"1.0" encoding=3D"UTF-8"?>
<Channel =
xmlns=3D"http://schema.broadsoft.com/xsi"><channelId>c9d5b432-db96-4256-87=
71-cdb6e3a1e897</channelId><expires>3600</expires></Channel>
DEBUG [org.apache.http.wire] << "[\r][\n]"=

---------------------------------------------------------------------
To unsubscribe, e-mail: httpclient-users-unsubscribe@hc.apache.org
For additional commands, e-mail: httpclient-users-help@hc.apache.org