Я использую http://loopj.com/android-async-http/ в моем приложении для Android. Настройка заключается в том, что существует один экземпляр указанного ниже класса HttpDataSource для каждой конечной точки API (например: http://myhost.com/some/service/{pathParam}); таким образом, существует несколько экземпляров AsyncHttpClient (и, в свою очередь, Apache HttpClient); что может быть причиной моих проблем.
import java.io.IOException;
import java.net.URI;
import android.util.Log;
import com.loopj.android.http.AsyncHttpClient;
import com.loopj.android.http.AsyncHttpResponseHandler;
import com.loopj.android.http.RequestParams;
import org.apache.http.Header;
import org.apache.http.HttpException;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.HttpResponseInterceptor;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.client.params.ClientPNames;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.protocol.ExecutionContext;
import org.apache.http.protocol.HttpContext;
public class HttpDataSource {
private final AsyncHttpClient asyncHttpClient;
public HttpDataSource() {
asyncHttpClient = new AsyncHttpClient();
asyncHttpClient.setUserAgent(UserAgentFactory.createUserAgent());
asyncHttpClient.setEnableRedirects(true);
addRedirectListener();
}
protected void get(final String url, final RequestParams requestParams, final HttpResponseHandler responseHandler) {
// Method not important; constructs headers for conditional GETs
final Header[] headers = checkForMetaData(url);
asyncHttpClient.get(null, url, headers, requestParams, new AsyncHttpResponseHandler() {
@Override
public void onSuccess(final int statusCode, final Header[] headers, final byte[] responseBody) {
// we do some work then pass on to the responseHandler
responseHandler.onSuccess(statusCode, headers, responseBody);
}
@Override
public void onFailure(final int statusCode, final Header[] headers, final byte[] responseBody,
final Throwable error) {
// we do some work then pass on to the responseHandler
responseHandler.onFailure(statusCode, headers, responseBody, error);
}
});
}
private void addRedirectListener() {
getHttpClient().addResponseInterceptor(new HttpResponseInterceptor() {
@Override
public void process(final HttpResponse httpResponse, final HttpContext httpContext)
throws HttpException, IOException {
if (httpResponse.getStatusLine().getStatusCode() == 302) {
final URI reqUri = ((HttpUriRequest) httpContext.getAttribute(ExecutionContext.HTTP_REQUEST)).getURI();
final HttpHost currentHost = (HttpHost) httpContext.getAttribute(ExecutionContext.HTTP_TARGET_HOST);
final String url = (reqUri.isAbsolute()) ? reqUri.toString() : (currentHost.toURI() + reqUri.getPath());
Log.e("HttpDataSource", "Got 302 for '" + url + "'");
}
}
});
}
private DefaultHttpClient getHttpClient() {
return ((DefaultHttpClient) asyncHttpClient.getHttpClient());
}
}
Когда я делаю параллельные GET для разных URL-адресов (например: http://myhost.com/some/service/bar, http://myhost.com/some/service/foo) прослушиватель перенаправления срабатывает дважды, но с одним и тем же объектом HttpContext, что, я думаю, неправильно. Журналы:
HttpDataSource﹕ Got 302 for 'http://myhost.com/some/service/foo'
HttpDataSource﹕ Got 302 for 'http://myhost.com/some/service/foo'
Я подозреваю, что проблема связана с Apache HttpClient, а не с AsyncHttpClient Loop4J, поскольку AsyncHttpClient имеет экземпляр HttpClient, который, как вы надеетесь, будет «безопасным для экземпляра».
Как я могу получить правильный объект HttpContext для URL-адреса, который возвращает 302 при запуске одновременных запросов?