使用Apache HttpClient如何在请求和响应上设置超时


问题内容

我需要为我们对服务(而非Web服务)发出的Http请求设置超时。我们正在使用Apache
HTTP客户端。我添加了这两行代码,以根据请求和对服务的响应设置超时时间。

HttpConnectionParams.setConnectionTimeout(params, 10000);
HttpConnectionParams.setSoTimeout(params, 10000);

1)目前,我已将超时设置为10秒,因为我几乎立即从服务中看到了响应。我应该增加还是减少时间?

2)如果响应时间超过10秒,会发生什么?它会抛出异常吗?它将是什么异常?我还需要添加其他内容来设置以下代码中的超时时间。

public HashMap<String, Object> getJSONData(String url) throw Exception{
    DefaultHttpClient httpClient = new DefaultHttpClient();
    HttpParams params = httpClient.getParams();
    HttpConnectionParams.setConnectionTimeout(params, 10000);
    HttpConnectionParams.setSoTimeout(params, 10000);
    HttpHost proxy = new HttpHost(getProxy(), getProxyPort());
    ConnRouteParams.setDefaultProxy(params, proxy);
    URI uri;
    InputStream data = null;
    try {
        uri = new URI(url);
        HttpGet method = new HttpGet(uri);
        HttpResponse response = httpClient.execute(method);
        data = response.getEntity().getContent();
    }
    catch (Exception e) {
        e.printStackTrace();
    }
    Reader r = new InputStreamReader(data);
    HashMap<String, Object> jsonObj = (HashMap<String, Object>) GenericJSONUtil.fromJson(r);
    return jsonObj;
}

问题答案:

您将看到的例外是ConnectTimeoutExceptionSocketTimeoutException。您使用的实际超时值应该是应用程序愿意等待的最长时间。关于读取超时的一个重要说明是,它对应于套接字读取的超时。因此,这不是完全响应到达所允许的时间,而是单个套接字读取所给的时间。因此,如果有4个套接字读取,每个读取耗时9秒,那么您的总读取时间为9 * 4 = 36秒。

如果要指定响应到达的总时间(包括连接和总读取时间),则可以将调用包装在线程中,并为此使用线程超时。例如,我通常这样做:

Future<T> future = null;
future = pool.submit(new Callable<T>() {
    public T call() {
        return executeImpl(url);
    }   
});

try {
    return future.get(10, TimeUnit.SECONDS);
}   
catch (InterruptedException e) {
    log.warn("task interrupted", name);
}   
catch (ExecutionException e) {
    log.error(name + " execution exception", e); 
}   
catch (TimeoutException e) {
    log.debug("future timed out", name);
}

上面代码中的一些假设是:1)这是在带有url参数的函数中,2)它在具有名称变量的类中,3)log是log4j实例,4)pool是某个线程池执行程序。请注意,即使您使用了线程超时,也应该在HttpClient上指定连接和套接字超时,以免慢速请求不会占用线程池中的资源。还要注意,我使用线程池,因为通常我在Web服务中使用线程池,因此线程池在许多tomcat线程之间共享。您的环境可能有所不同,您可能希望为每个调用简单地产生一个新线程。

另外,我通常会看到通过参数的成员函数设置的超时,如下所示:

params.setConnectionTimeout(10000);
params.setSoTimeout(10000);

但是也许您的语法也能正常工作(不确定)。