Skip to content

Instantly share code, notes, and snippets.

@AizazZaidee
Created January 26, 2015 04:17
Show Gist options
  • Save AizazZaidee/ea93919c8a962744163d to your computer and use it in GitHub Desktop.
Save AizazZaidee/ea93919c8a962744163d to your computer and use it in GitHub Desktop.
Using Apache HTTP Client with Android Volley + Hurl Stack
Set up Apache with Volley
DefaultHttpClient mDefaultHttpClient = new DefaultHttpClient();
final ClientConnectionManager mClientConnectionManager = mDefaultHttpClient
.getConnectionManager();
final HttpParams mHttpParams = mDefaultHttpClient.getParams();
final ThreadSafeClientConnManager mThreadSafeClientConnManager = new ThreadSafeClientConnManager(
mHttpParams, mClientConnectionManager.getSchemeRegistry());
mDefaultHttpClient = new DefaultHttpClient(
mThreadSafeClientConnManager, mHttpParams);
mDefaultHttpClient.setCookieStore(new BasicCookieStore());
final HttpStack httpStack = new ExtHttpClientStack(
mDefaultHttpClient); // using Apache Client
this.mRequestQueue = Volley.newRequestQueue(
mCtx.getApplicationContext(), httpStack);
------- create your own Hurl Stack
package com.az.api;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.ProtocolVersion;
import org.apache.http.StatusLine;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.entity.BasicHttpEntity;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.message.BasicHeader;
import org.apache.http.message.BasicHttpResponse;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.message.BasicStatusLine;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams;
import com.android.volley.AuthFailureError;
import com.android.volley.Request;
import com.android.volley.Request.Method;
import com.android.volley.toolbox.HttpStack;
public class ExtHttpClientStack implements HttpStack {
protected final HttpClient mClient;
private final static String HEADER_CONTENT_TYPE = "Content-Type";
private static final int DEFAULT_CONNECTION_TIMEOUT = (int) TimeUnit.SECONDS
.toMillis(10);
public ExtHttpClientStack(HttpClient client) {
mClient = client;
}
private static void addHeaders(HttpUriRequest httpRequest,
Map<String, String> headers) {
for (String key : headers.keySet()) {
httpRequest.setHeader(key, headers.get(key));
}
}
@SuppressWarnings("unused")
private static List<NameValuePair> getPostParameterPairs(
Map<String, String> postParams) {
List<NameValuePair> result = new ArrayList<NameValuePair>(
postParams.size());
for (String key : postParams.keySet()) {
result.add(new BasicNameValuePair(key, postParams.get(key)));
}
return result;
}
@Override
public org.apache.http.HttpResponse performRequest(Request<?> request,
Map<String, String> additionalHeaders) throws IOException,
AuthFailureError {
HttpUriRequest httpRequest = createHttpRequest(request,
additionalHeaders);
addHeaders(httpRequest, additionalHeaders);
addHeaders(httpRequest, request.getHeaders());
onPrepareRequest(httpRequest);
HttpParams httpParams = httpRequest.getParams();
int timeoutMs = request.getTimeoutMs();
// TODO: Reevaluate this connection timeout based on more wide-scale
// data collection and possibly different for wifi vs. 3G.
HttpConnectionParams.setConnectionTimeout(httpParams,
DEFAULT_CONNECTION_TIMEOUT);
HttpConnectionParams.setSoTimeout(httpParams, timeoutMs);
HttpResponse resp = mClient.execute(httpRequest);
return convertResponseNewToOld(resp);
}
private org.apache.http.HttpResponse convertResponseNewToOld(
HttpResponse resp) throws IllegalStateException, IOException {
ProtocolVersion protocolVersion = new ProtocolVersion(resp
.getProtocolVersion().getProtocol(), resp.getProtocolVersion()
.getMajor(), resp.getProtocolVersion().getMinor());
StatusLine responseStatus = new BasicStatusLine(protocolVersion, resp
.getStatusLine().getStatusCode(), resp.getStatusLine()
.getReasonPhrase());
BasicHttpResponse response = new BasicHttpResponse(responseStatus);
org.apache.http.HttpEntity ent = convertEntityNewToOld(resp.getEntity());
response.setEntity(ent);
for (Header h : resp.getAllHeaders()) {
org.apache.http.Header header = convertheaderNewToOld(h);
response.addHeader(header);
}
return response;
}
private org.apache.http.HttpEntity convertEntityNewToOld(HttpEntity ent)
throws IllegalStateException, IOException {
BasicHttpEntity ret = new BasicHttpEntity();
if (ent != null) {
ret.setContent(ent.getContent());
ret.setContentLength(ent.getContentLength());
Header h;
h = ent.getContentEncoding();
if (h != null) {
ret.setContentEncoding(convertheaderNewToOld(h));
}
h = ent.getContentType();
if (h != null) {
ret.setContentType(convertheaderNewToOld(h));
}
}
return ret;
}
private org.apache.http.Header convertheaderNewToOld(Header header) {
org.apache.http.Header ret = new BasicHeader(header.getName(),
header.getValue());
return ret;
}
/**
* Creates the appropriate subclass of HttpUriRequest for passed in request.
*/
@SuppressWarnings("deprecation")
/* protected */static HttpUriRequest createHttpRequest(Request<?> request,
Map<String, String> additionalHeaders) throws AuthFailureError {
switch (request.getMethod()) {
case Method.DEPRECATED_GET_OR_POST: {
// This is the deprecated way that needs to be handled for backwards
// compatibility.
// If the request's post body is null, then the assumption is that
// the request is
// GET. Otherwise, it is assumed that the request is a POST.
byte[] postBody = request.getPostBody();
if (postBody != null) {
HttpPost postRequest = new HttpPost(request.getUrl());
postRequest.addHeader(HEADER_CONTENT_TYPE,
request.getBodyContentType());
HttpEntity entity;
entity = new ByteArrayEntity(postBody);
postRequest.setEntity(entity);
return postRequest;
} else {
return new HttpGet(request.getUrl());
}
}
case Method.GET:
return new HttpGet(request.getUrl());
case Method.DELETE:
return new HttpDelete(request.getUrl());
case Method.POST: {
HttpPost postRequest = new HttpPost(request.getUrl());
postRequest.addHeader(HEADER_CONTENT_TYPE,
request.getBodyContentType());
setEntityIfNonEmptyBody(postRequest, request);
return postRequest;
}
case Method.PUT: {
HttpPut putRequest = new HttpPut(request.getUrl());
putRequest.addHeader(HEADER_CONTENT_TYPE,
request.getBodyContentType());
setEntityIfNonEmptyBody(putRequest, request);
return putRequest;
}
default:
throw new IllegalStateException("Unknown request method.");
}
}
private static void setEntityIfNonEmptyBody(
HttpEntityEnclosingRequestBase httpRequest, Request<?> request)
throws AuthFailureError {
byte[] body = request.getBody();
if (body != null) {
HttpEntity entity = new ByteArrayEntity(body);
httpRequest.setEntity(entity);
}
}
/**
* Called before the request is executed using the underlying HttpClient.
*
* <p>
* Overwrite in subclasses to augment the request.
* </p>
*/
protected void onPrepareRequest(HttpUriRequest request) throws IOException {
// Nothing.
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment