首页 > 代码库 > Apache HttpAsyncClient 如何设置per request timeout
Apache HttpAsyncClient 如何设置per request timeout
最近做一个项目时用到HttpAsyncClient；因项目所需，要求能对一个具体的request 设置连接和读写超时；但发现在HttpAsyncClient中，只有在创建一个HttpAsyncClient实例时才能通过RequestConfig设置一个timeout，除此之外并没有一个接口可以设置单个请求的超时。为了达到项目的要求，只有从把HttpAsyncClient的源码大致读了一遍，一是希望能从源码中找到设置超时的方法，二是希望，如果确实没有办法，能仿照源码写一个可控制超时的HttpAsyncClient实现。
通过对HttpAsyncClient源码的分析发现，在执行一个HttpRequest时，HttpAsyncClient会调用HttpAsyncClientExchangeHandler来完成请求的处理，缺省的HttpAsyncClientExchangeHandler实现中，它的requestConnection函数里会从一个HttpClientContext获取一个RequestConfig，从获取的RequestConfig中它将取出所设置的超时值并加以使用。
在缺省HttpAsyncClient实现中，HttpClientContext要么可从HttpAsyncClient.execute传入的HttpContext参数创建，要么则会临时生成一个缺省的BasicContext。HttpContext本身并没有提供对RequestConfig的设置或修改，但HttpClientContext则可以允许设置或修改RequestConfig。有了这个发现，则可以通过如下的workaround来满足我们的需求（之所以说是workaround，因为我总觉得这个做法并不是最自然的做法，或许有更好更直观的做法来满足需求？）
private HttpClientContext _getContext(int connectTimeoutInSec, int socketTimeoutInSec) { HttpClientContext ctx = new HttpClientContext(); /** * 从缺省的requestConfig中copy一个requestConfig出来以便修改 */ RequestConfig config = RequestConfig.copy(_requestConfig).setConnectTimeout( connectTimeoutInSec <= 0 ? _DEFAULT_CONNECT_TIMEOUT * 1000 : connectTimeoutInSec * 1000 ).setSocketTimeout( socketTimeoutInSec <= 0 ? _DEFAULT_READ_TIMEOUT * 1000 : socketTimeoutInSec * 1000 ).build(); ctx.setRequestConfig(config); return ctx; }
有了上述代码，那我们自然而然的就可以在做post/get请求时加入我们所需的超时设置了：
public void get(HttpGet req, Callback<HttpResponse> callback, int connectTimeoutInSec, int socketTimeoutInSec) { _httpClient.execute(req, _getContext(connectTimeoutInSec, socketTimeoutInSec), new CallbackAdaptor<HttpResponse>(callback)); } public void post(HttpPost req, Callback<HttpResponse> callback, int connectTimeoutInSec, int socketTimeoutInSec) { _httpClient.execute(req, _getContext(connectTimeoutInSec, socketTimeoutInSec), new CallbackAdaptor<HttpResponse>(callback)); }