Revision: 20204
http://sourceforge.net/p/gate/code/20204
Author: domrout
Date: 2017-04-05 08:04:41 +0000 (Wed, 05 Apr 2017)
Log Message:
-----------
Update WebUtils to use Apache Requests and thus support proper request pools.
This is extremely important with very large scale communication with Mimir.
I have unit tests- but they're in Groovy. Shall I bother converting them?
Also, should we bump the version, since we included a new dependency?
Modified Paths:
--------------
mimir/trunk/mimir-client/build/ivy.xml
mimir/trunk/mimir-client/build.xml
Removed Paths:
-------------
mimir/trunk/mimir-client/src/gate/mimir/tool/WebUtils.java
Modified: mimir/trunk/mimir-client/build/ivy.xml
===================================================================
--- mimir/trunk/mimir-client/build/ivy.xml 2017-03-03 22:30:30 UTC (rev
20203)
+++ mimir/trunk/mimir-client/build/ivy.xml 2017-04-05 08:04:41 UTC (rev
20204)
@@ -17,6 +17,8 @@
</publications>
<dependencies defaultconf="*->master(default),runtime(default)" >
- <dependency name="mimir-core" org="uk.ac.gate" rev="5.4-SNAPSHOT" />
+ <dependency name="mimir-core" org="uk.ac.gate" rev="5.5-SNAPSHOT" />
+ <dependency org="org.apache.httpcomponents" name="httpcore" rev="4.4.6"/>
+ <dependency org="org.apache.httpcomponents" name="httpclient" rev="4.5.3"/>
</dependencies>
</ivy-module>
Modified: mimir/trunk/mimir-client/build.xml
===================================================================
--- mimir/trunk/mimir-client/build.xml 2017-03-03 22:30:30 UTC (rev 20203)
+++ mimir/trunk/mimir-client/build.xml 2017-04-05 08:04:41 UTC (rev 20204)
@@ -53,8 +53,8 @@
<javac destdir="${classes.dir}"
srcdir="${src.dir}"
debug="true"
- target="1.7"
- source="1.7"
+ target="1.8"
+ source="1.8"
encoding="UTF-8"
classpathref="compile.classpath" />
</target>
@@ -83,7 +83,7 @@
Windowtitle="${app.title} (${app.version}) JavaDoc"
docencoding="UTF-8"
charset="UTF-8"
- source="1.7"
+ source="1.8"
useexternalfile="yes"
breakiterator="true">
<fileset dir="${src.dir}" includes="**/*.java"/>
Deleted: mimir/trunk/mimir-client/src/gate/mimir/tool/WebUtils.java
===================================================================
--- mimir/trunk/mimir-client/src/gate/mimir/tool/WebUtils.java 2017-03-03
22:30:30 UTC (rev 20203)
+++ mimir/trunk/mimir-client/src/gate/mimir/tool/WebUtils.java 2017-04-05
08:04:41 UTC (rev 20204)
@@ -1,700 +0,0 @@
-/*
- * WebUtils.java
- *
- * Copyright (c) 2007-2011, The University of Sheffield.
- *
- * This file is part of GATE MÃmir (see http://gate.ac.uk/family/mimir.html),
- * and is free software, licenced under the GNU Lesser General Public License,
- * Version 3, June 2007 (also included with this distribution as file
- * LICENCE-LGPL3.html).
- *
- * Valentin Tablan, 29 Jan 2010
- *
- * $Id$
- */
-package gate.mimir.tool;
-
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.io.ObjectInputStream;
-import java.io.ObjectOutputStream;
-import java.io.OutputStream;
-import java.io.Reader;
-import java.io.Serializable;
-import java.io.UnsupportedEncodingException;
-import java.net.CookieHandler;
-import java.net.CookieManager;
-import java.net.HttpURLConnection;
-import java.net.URISyntaxException;
-import java.net.URL;
-import java.net.URLConnection;
-import java.nio.CharBuffer;
-import java.nio.charset.UnsupportedCharsetException;
-import java.util.List;
-import java.util.Map;
-
-import javax.xml.bind.DatatypeConverter;
-
-/**
- * A collection of methods that provide various utility functions for web
- * applications.
- */
-public class WebUtils {
-
- private CookieHandler cookieJar;
-
- private String authHeader;
-
- public WebUtils() {
- this(new CookieManager(), null, null);
- }
-
- public WebUtils(CookieHandler cookieJar) {
- this(cookieJar, null, null);
- }
-
- public WebUtils(String userName, String password) {
- this(new CookieManager(), userName, password);
- }
-
- public WebUtils(CookieHandler cookieJar, String userName, String password) {
- this.cookieJar = cookieJar;
- if(userName != null && userName.length() > 0){
- try {
- String userPass = userName + ":" + password;
- authHeader = "Basic " +
DatatypeConverter.printBase64Binary(userPass.getBytes("UTF-8"));
- } catch(UnsupportedEncodingException e) {
- throw new UnsupportedCharsetException("UTF-8");
- }
- } else {
- authHeader = null;
- }
- }
-
-
- /**
- * Constructs a URL from a base URL segment and a set of query parameters.
- * @param urlBase the string that will be the prefix of the returned.
- * This should include everything apart from the query part of the URL.
- * @param params an array of String values, which should contain alternating
- * parameter names and parameter values. It is obvious that the size of this
- * array must be an even number.
- * @return a URl built according to the provided parameters. If for example
- * the following parameter values are provided: <b>urlBase:</b>
- * <tt>http://host:8080/appName/service</tt>; <b>params:</b> <tt>foo1, bar1,
- * foo2, bar2, foo3, bar3</tt>, then the following URL would be returned:
- *
<tt>http://host:8080/appName/service?foo1=bar1&foo2=bar2&foo3=bar3</tt>
- */
- public static String buildUrl(String urlBase, String... params){
- StringBuilder str = new StringBuilder(urlBase);
- if(params != null && params.length > 0){
- str.append('?');
- for(int i = 0 ; i < (params.length/2) - 1; i++){
- str.append(params[i * 2]);
- str.append('=');
- str.append(params[i * 2 + 1]);
- str.append('&');
- }
- //and now, the last parameter
- str.append(params[params.length - 2]);
- str.append('=');
- str.append(params[params.length - 1]);
- }
- return str.toString();
- }
-
- /**
- * Opens a URLConnection to the specified URL, setting any appropriate
- * cookie headers. Can be overridden by subclasses that need to set
- * any additional request headers.
- */
- protected URLConnection openURLConnection(URL u) throws IOException {
- URLConnection conn = u.openConnection();
- try {
- // add the cookie headers
- Map<String, List<String>> cookieHeaders = cookieJar.get(
- u.toURI(), conn.getRequestProperties());
- for(Map.Entry<String, List<String>> e : cookieHeaders.entrySet()) {
- for(String val : e.getValue()) {
- conn.addRequestProperty(e.getKey(), val);
- }
- }
- } catch(URISyntaxException e) {
- throw (IOException)new IOException(
- "Error converting URL " + u + " to a URI").initCause(e);
- }
- if(authHeader != null) {
- conn.setRequestProperty("Authorization", authHeader);
- }
- return conn;
- }
-
- /**
- * Calls a web service action (i.e. it connects to a URL). If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all content available from either
the
- * input and error streams of the resulting connection (which should permit
- * connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public void getVoid(String baseUrl, String... params) throws IOException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
-
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- try {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code != HttpURLConnection.HTTP_OK) {
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
-
- /**
- * Calls a web service action (i.e. it connects to a URL). If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will write all content available from the
- * input stream of the resulting connection to the provided Appendable.
- *
- * @param out an {@link Appendable} to which the output is written.
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public void getText(Appendable out, String baseUrl, String...params)
- throws IOException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
-
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- try {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code == HttpURLConnection.HTTP_OK) {
- // copy content to appendable
- Reader r = new InputStreamReader(httpConn.getInputStream(), "UTF-8");
- char[] bufArray = new char[4096];
- CharBuffer buf = CharBuffer.wrap(bufArray);
- int charsRead = -1;
- while((charsRead = r.read(bufArray)) >= 0) {
- buf.position(0);
- buf.limit(charsRead);
- out.append(buf);
- }
- }else{
- // some problem -> try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- }finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
-
- /**
- * Calls a web service action (i.e. it connects to a URL), and reads a
- * serialised int value from the resulting connection. If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all additional content available
from
- * either the input and error streams of the resulting connection (which
- * should permit connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public int getInt(String baseUrl, String... params)
- throws IOException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
-
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- int res;
- try {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code == HttpURLConnection.HTTP_OK) {
- res = new ObjectInputStream(httpConn.getInputStream()).readInt();
- }else{
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- return res;
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
-
- /**
- * Calls a web service action (i.e. it connects to a URL), and reads a
- * serialised long value from the resulting connection. If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all additional content available
from
- * either the input and error streams of the resulting connection (which
- * should permit connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public long getLong(String baseUrl, String... params)
- throws IOException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
-
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- long res;
- try {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code == HttpURLConnection.HTTP_OK) {
- res = new ObjectInputStream(httpConn.getInputStream()).readLong();
- }else{
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- return res;
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
- /**
- * Calls a web service action (i.e. it connects to a URL), and reads a
- * serialised double value from the resulting connection. If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all additional content available
from
- * either the input and error streams of the resulting connection (which
- * should permit connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public double getDouble(String baseUrl, String...params)
- throws IOException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
-
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- double res;
- try {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code == HttpURLConnection.HTTP_OK) {
- res = new ObjectInputStream(httpConn.getInputStream()).readDouble();
- }else{
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- return res;
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
-
- /**
- * Calls a web service action (i.e. it connects to a URL), and reads a
- * serialised boolean value from the resulting connection. If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all additional content available
from
- * either the input and error streams of the resulting connection (which
- * should permit connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public boolean getBoolean(String baseUrl, String... params)
- throws IOException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
-
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- boolean res;
- try {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code == HttpURLConnection.HTTP_OK) {
- res = new ObjectInputStream(httpConn.getInputStream()).readBoolean();
- }else{
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- return res;
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
-
- /**
- * Calls a web service action (i.e. it connects to a URL), and reads a
- * serialised Object value from the resulting connection. If the connection
- * fails, for whatever reason, or the response code is different from
- * {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all additional content available
from
- * either the input and error streams of the resulting connection (which
- * should permit connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- * @throws ClassNotFoundException if the value read from the remote
connection
- * is of a type unknown to the local JVM.
- */
- public Object getObject(String baseUrl, String... params)
- throws IOException, ClassNotFoundException {
-
- URL actionUrl = new URL(buildUrl(baseUrl, params));
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- Object res;
- try {
- res = readRemoteObject(httpConn);
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- return res;
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
- /**
- * Reads an Object value from a HTTP connection.
- * @param httpConn the connection to read from
- * @return the value sent from the remote endpoint
- * @throws IOException
- * @throws ClassNotFoundException
- */
- private Object readRemoteObject(HttpURLConnection httpConn)
- throws IOException, ClassNotFoundException {
- httpConn.connect();
- int code = httpConn.getResponseCode();
- if(code == HttpURLConnection.HTTP_OK) {
- return new ObjectInputStream(httpConn.getInputStream()).readObject();
- }else{
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- }
-
-
-
- /**
- * Calls a web service action (i.e. it connects to a URL) using the POST HTTP
- * method, sending the given object in Java serialized format as the request
- * body. The request is sent using chunked transfer encoding, and the
- * request's Content-Type is set to application/octet-stream. If the
- * connection fails, for whatever reason, or the response code is different
- * from {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all content available from either the
- * input and error streams of the resulting connection (which should permit
- * connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param object the object to serialize and send in the POST body
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public void postObject(String baseUrl, Serializable object,
- String... params) throws IOException {
- URL actionUrl = new URL(buildUrl(baseUrl, params));
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- try {
- // enable output and set HTTP method
- httpConn.setDoOutput(true);
- httpConn.setRequestMethod("POST");
- // turn on chunking (we don't want to buffer the output if we don't
- // have to). 0 means use default chunk size.
- httpConn.setChunkedStreamingMode(0);
- // don't time out
- httpConn.setConnectTimeout(0);
- httpConn.setReadTimeout(0);
-
- // MIME type (defaults to form encoded, so must change it)
- httpConn.setRequestProperty("Content-Type",
"application/octet-stream");
-
- // connect and send the object
- httpConn.connect();
- OutputStream httpOutputStream = httpConn.getOutputStream();
- ObjectOutputStream objectStream = new
ObjectOutputStream(httpOutputStream);
- objectStream.writeObject(object);
- objectStream.close();
-
- int code = httpConn.getResponseCode();
- if(code != HttpURLConnection.HTTP_OK) {
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
- /**
- * Calls a web service action (i.e. it connects to a URL) using the POST HTTP
- * method, sending the given bytes as the request
- * body. The request is sent using chunked transfer encoding, and the
- * request's Content-Type is set to application/octet-stream. If the
- * connection fails, for whatever reason, or the response code is different
- * from {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * This method will drain (and discard) all content available from either the
- * input and error streams of the resulting connection (which should permit
- * connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param data a {@link ByteArrayOutputStream} containing the data to be
- * written. Its {@link ByteArrayOutputStream#writeTo(OutputStream)} method
- * will be called causing it to write its data to the output connection.
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @throws IOException if the connection fails.
- */
- public void postData(String baseUrl, ByteArrayOutputStream data,
- String... params) throws IOException {
- URL actionUrl = new URL(buildUrl(baseUrl, params));
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- try {
- // enable output and set HTTP method
- httpConn.setDoOutput(true);
- httpConn.setRequestMethod("POST");
- // turn on chunking (we don't want to buffer the output if we don't
- // have to). 0 means use default chunk size.
- httpConn.setChunkedStreamingMode(0);
- // don't time out
- httpConn.setConnectTimeout(0);
- httpConn.setReadTimeout(0);
-
- // MIME type (defaults to form encoded, so must change it)
- httpConn.setRequestProperty("Content-Type",
"application/octet-stream");
-
- // connect and send the object
- httpConn.connect();
-
- OutputStream httpOutputStream = httpConn.getOutputStream();
- data.writeTo(httpOutputStream);
- httpOutputStream.close();
-
- int code = httpConn.getResponseCode();
- if(code != HttpURLConnection.HTTP_OK) {
- // try to get more details
- String message = httpConn.getResponseMessage();
- throw new IOException(code
- + (message != null ? " (" + message + ")" : "")
- + " Remote connection failed.");
- }
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
- /**
- * Calls a web service action (i.e. it connects to a URL) using the POST HTTP
- * method, sending the given object in Java serialized format as the request
- * body. The request is sent using chunked transfer encoding, and the
- * request's Content-Type is set to application/octet-stream. If the
- * connection fails, for whatever reason, or the response code is different
- * from {@link HttpURLConnection#HTTP_OK}, then an IOException is raised.
- * The response from the server is read and Java-deserialized, the resulting
- * Object being returned.
- *
- * This method will then drain (and discard) all the remaining content
- * available from either the input and error streams of the resulting
- * connection (which should permit connection keepalives).
- *
- * @param baseUrl the constant part of the URL to be accessed.
- * @param object the object to serialize and send in the POST body
- * @param params an array of String values, that contain an alternation of
- * parameter name, and parameter values.
- * @return the de-serialized value sent by the remote endpoint.
- * @throws IOException if the connection fails.
- * @throws ClassNotFoundException if the data sent from the remote endpoint
- * cannot be deserialized to a class locally known.
- */
- public Object rpcCall(String baseUrl, Serializable object,
- String... params) throws IOException, ClassNotFoundException {
- URL actionUrl = new URL(buildUrl(baseUrl, params));
- URLConnection conn = openURLConnection(actionUrl);
- if(conn instanceof HttpURLConnection) {
- HttpURLConnection httpConn = (HttpURLConnection)conn;
- try {
- // enable output and set HTTP method
- httpConn.setDoOutput(true);
- httpConn.setRequestMethod("POST");
- // turn on chunking (we don't want to buffer the output if we don't
- // have to). 0 means use default chunk size.
- httpConn.setChunkedStreamingMode(0);
- // don't time out
- httpConn.setConnectTimeout(0);
- httpConn.setReadTimeout(0);
-
- // MIME type (defaults to form encoded, so must change it)
- httpConn.setRequestProperty("Content-Type",
"application/octet-stream");
-
- // connect and send the object
- httpConn.connect();
- OutputStream httpOutputStream = httpConn.getOutputStream();
- ObjectOutputStream objectStream = new
ObjectOutputStream(httpOutputStream);
- objectStream.writeObject(object);
- objectStream.close();
-
- return readRemoteObject(httpConn);
- } finally {
- // make sure the connection is drained, to allow connection keepalive
- drainConnection(httpConn);
- }
- } else {
- throw new IOException("Connection received is not HTTP!"
- + " Connection class: " + conn.getClass().getCanonicalName());
- }
- }
-
-
- /**
- * Read and discard the response body from an HttpURLConnection. This first
- * attempts to get the normal input stream (
- * {@link HttpURLConnection#getInputStream}) and read that, but if that fails
- * with an exception we attempt to read the error stream (
- * {@link HttpURLConnection#getErrorStream}) instead. Also processes any
- * cookie-related headers from the response, storing them in the cookie jar.
- */
- private void drainConnection(HttpURLConnection httpConnection)
- throws IOException {
- try {
- // store cookies for future connections
- cookieJar.put(httpConnection.getURL().toURI(),
- httpConnection.getHeaderFields());
- } catch(URISyntaxException e1) {
- // ignore, we tried.
- }
- // small buffer - we're only expecting to drain a few dozen bytes from each
- // request, if that.
- byte[] buf = new byte[1024];
- try {
- InputStream in = httpConnection.getInputStream();
- while(in.read(buf) >= 0) {
- // do nothing
- }
- in.close();
- } catch(IOException e) {
- InputStream errStream = httpConnection.getErrorStream();
- if(errStream != null){
- while(errStream.read(buf) >= 0) {
- // do nothing
- }
- errStream.close();
- }
- }
- }
-}
This was sent by the SourceForge.net collaborative development platform, the
world's largest Open Source development site.
------------------------------------------------------------------------------
Check out the vibrant tech community on one of the world's most
engaging tech sites, Slashdot.org! http://sdm.link/slashdot
_______________________________________________
GATE-cvs mailing list
GATE-cvs@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/gate-cvs
