如何设置CloseableHttpAsyncClient的SocketTimeout及请求响应超时

在CloseableHttpAsyncClient里，http.socket.timeout（Socket Timeout）仅控制连接建立后数据包之间的最大空闲时长，无法覆盖从请求发起至响应接收的全流程时间限制。以下是两种实现整体超时的可靠方案：

方案一：通过Future.get()直接设置整体超时 #

提交异步请求后会得到Future<HttpResponse>对象，调用其get(long timeout, TimeUnit unit)方法，即可指定请求全流程的最大等待时长。超时未拿到响应时会抛出TimeoutException，此时可取消请求。

代码示例：

CloseableHttpAsyncClient httpclient = HttpAsyncClients.createDefault();
try {
    httpclient.start();
    HttpGet request = new HttpGet("http://example.com");
    Future<HttpResponse> future = httpclient.execute(request, null);
    
    // 设置整体超时为10秒
    HttpResponse response = future.get(10, TimeUnit.SECONDS);
    System.out.println("响应状态: " + response.getStatusLine());
} catch (TimeoutException e) {
    // 超时后取消请求并处理逻辑
    future.cancel(true);
    System.err.println("请求全流程超时");
} catch (Exception e) {
    e.printStackTrace();
} finally {
    httpclient.close();
}

方案二：回调+定时任务实现主动超时取消 #

如果需要在超时后主动触发请求取消（而非仅等待异常），可以结合请求回调与定时任务，在指定时长后检查请求状态并取消未完成的请求。

代码示例：

CloseableHttpAsyncClient httpclient = HttpAsyncClients.createDefault();
try {
    httpclient.start();
    HttpGet request = new HttpGet("http://example.com");
    
    // 先配置Socket Timeout（可选，与整体超时互补）
    RequestConfig config = RequestConfig.custom()
            .setSocketTimeout(5000) // 连接后空闲超时5秒
            .build();
    request.setConfig(config);

    CountDownLatch latch = new CountDownLatch(1);
    Future<HttpResponse> future = httpclient.execute(request, new FutureCallback<HttpResponse>() {
        @Override
        public void completed(HttpResponse response) {
            latch.countDown();
            System.out.println("响应已接收: " + response.getStatusLine());
        }

        @Override
        public void failed(Exception ex) {
            latch.countDown();
            System.err.println("请求失败: " + ex.getMessage());
        }

        @Override
        public void cancelled() {
            latch.countDown();
            System.err.println("请求已被取消");
        }
    });

    // 启动定时任务，10秒后取消未完成的请求
    ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
    scheduler.schedule(() -> {
        if (!future.isDone()) {
            future.cancel(true);
            System.err.println("请求全流程超时，已取消");
        }
    }, 10, TimeUnit.SECONDS);

    latch.await();
    scheduler.shutdown();
} catch (Exception e) {
    e.printStackTrace();
} finally {
    httpclient.close();
}

注意事项 #

• 两种方案可根据场景选择：方案一适合简单需求，代码简洁；方案二更灵活，支持自定义超时后的处理逻辑。
• 建议同时配置Socket Timeout与整体超时，避免出现连接长期空闲但未触发整体超时的情况。

内容的提问来源于stack exchange，提问作者Lee Ssunny