Spring Boot RestController中三个HttpClient请求无法执行求助

嘿，这个问题我之前排查过类似的情况！你遇到的这个现象——三个HttpGet一起执行就卡，去掉任意一个就正常——大概率是连接资源没及时释放或者HttpClient默认连接池不够用导致的，咱们一步步来解决：

1. 先确保每个请求的响应都被正确关闭 #

你原来的代码里没有关闭CloseableHttpResponse，这会导致连接一直占用连接池的资源。当第三个请求过来时，连接池已经没有可用连接了，方法就会一直阻塞等待连接释放。

CloseableHttpResponse实现了AutoCloseable接口，咱们可以用try-with-resources语法自动关闭响应，同时还要确保响应体被完全消费（否则有些情况下连接不会被放回连接池）：

// 第一个请求
try (CloseableHttpResponse response1 = httpclient.execute(httpget1)) {
    // 这里处理你的业务逻辑，比如读取响应内容
    // 必须消费实体，否则连接可能无法回收
    EntityUtils.consume(response1.getEntity());
} catch (IOException e) {
    // 按需处理异常，比如打印日志或者抛出业务异常
    e.printStackTrace();
}

// 第二个请求同理
try (CloseableHttpResponse response2 = httpclient.execute(httpget2)) {
    EntityUtils.consume(response2.getEntity());
} catch (IOException e) {
    e.printStackTrace();
}

// 第三个请求
try (CloseableHttpResponse response3 = httpclient.execute(httpget3)) {
    EntityUtils.consume(response3.getEntity());
} catch (IOException e) {
    e.printStackTrace();
}

2. 检查并调整HttpClient的连接池配置 #

默认的HttpClient连接池总最大连接数和单路由最大连接数都比较小（比如默认总连接数是2），当你同时发起三个请求时，第三个请求拿不到连接就会阻塞。咱们可以手动配置连接池，增大连接数：

// 创建连接池管理器
PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager();
// 设置总最大连接数（根据你的业务场景调整）
connManager.setMaxTotal(10);
// 设置单个路由（同一个目标域名）的最大连接数
connManager.setDefaultMaxPerRoute(5);

// 使用连接池构建HttpClient
CloseableHttpClient httpclient = HttpClients.custom()
        .setConnectionManager(connManager)
        .build();

这样三个请求就能同时获取到连接，不会出现阻塞的情况了。

3. 可选优化：异步执行请求（提升性能） #

如果这三个请求之间没有依赖关系，完全可以用异步的方式并行执行，既避免同步阻塞的问题，又能提升接口的响应速度。比如用Java的CompletableFuture：

// 异步执行三个请求
CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> {
    try (CloseableHttpResponse response1 = httpclient.execute(httpget1)) {
        EntityUtils.consume(response1.getEntity());
        // 处理第一个请求的业务逻辑
    } catch (IOException e) {
        e.printStackTrace();
    }
});

CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> {
    try (CloseableHttpResponse response2 = httpclient.execute(httpget2)) {
        EntityUtils.consume(response2.getEntity());
        // 处理第二个请求的业务逻辑
    } catch (IOException e) {
        e.printStackTrace();
    }
});

CompletableFuture<Void> future3 = CompletableFuture.runAsync(() -> {
    try (CloseableHttpResponse response3 = httpclient.execute(httpget3)) {
        EntityUtils.consume(response3.getEntity());
        // 处理第三个请求的业务逻辑
    } catch (IOException e) {
        e.printStackTrace();
    }
});

// 等待所有异步请求完成
CompletableFuture.allOf(future1, future2, future3).join();

总结 #

最核心的问题就是连接资源未正确释放或者连接池默认配置不足以支撑三个并发请求。先尝试第一点的资源释放，基本就能解决问题；如果还不行，再调整连接池配置。异步执行是锦上添花的优化，适合对性能有要求的场景。

内容的提问来源于stack exchange，提问作者Ayoub Rossi