Java内置HTTP客户端复用连接异常：异步请求多连接原因与解决

我用Java的ServerSocket实现了自定义HTTP服务器，为测试流水线功能编写了一个预期会失败的测试。

异步测试代码（实际创建2个连接，不符合预期） #

void sendMultipleRequestsOnSameConnection() throws URISyntaxException, InterruptedException, ExecutionException {
        HttpRequest httpRequest = HttpRequest.newBuilder()
            .POST(BodyPublishers.ofString("LOREM"))
            .uri(new URI("http://127.0.0.1/wait2"))
            .version(Version.HTTP_1_1)
            .build();

        HttpRequest httpRequest2 = HttpRequest.newBuilder()
            .POST(BodyPublishers.ofString("LOREM"))
            .uri(new URI("http://127.0.0.1/wait"))
            .version(Version.HTTP_1_1)
            .build();

        CompletableFuture<HttpResponse<String>> future1 = httpClient.sendAsync(httpRequest, BodyHandlers.ofString());
        Thread.sleep(500);
        CompletableFuture<HttpResponse<String>> future2 = httpClient.sendAsync(httpRequest2, BodyHandlers.ofString());
}

服务器会记录新连接的创建操作，运行该测试后发现服务器建立了2个连接，但我预期应该只创建1个——因为另一个同步请求的测试可以正常复用1个连接：

同步测试代码（正常复用1个连接） #

@Test
void sendMultipleRequestsOnSameConnection() throws URISyntaxException, IOException, InterruptedException {
        HttpRequest httpRequest = HttpRequest.newBuilder()
            .POST(BodyPublishers.ofString("LOREM"))
            .uri(new URI("http://127.0.0.1/"))
            .version(Version.HTTP_1_1)
            .build();

        String responseBody1 = httpClient.send(httpRequest, BodyHandlers.ofString()).body();
        String responseBody2 = httpClient.send(httpRequest, BodyHandlers.ofString()).body();

        Assertions.assertEquals("HELLO WORLD", responseBody1);
        Assertions.assertEquals("HELLO WORLD", responseBody2);
}

疑问 #

1. 出现这种情况的原因是什么？
2. 是否有办法强制HTTP客户端复用第一个请求的连接？
3. 如果不行，是否有其他Java HTTP客户端支持该需求，还是我需要直接使用Socket来确保仅创建1个连接？

1. 异步请求创建2个连接的原因 #

Java 11引入的HttpClient默认连接池策略为：异步请求在第一个连接仍处于活跃状态时，不会等待连接释放，而是直接创建新连接。这是因为异步API设计为非阻塞模式，连接池不会为了复用而让后续请求等待正在使用的连接。

而同步请求能复用连接，是因为第一个请求完全处理完成、连接回到连接池后，第二个请求才发起，此时可以直接复用空闲连接。你的异步测试中虽然调用了Thread.sleep(500)，但第一个请求的连接因服务器端/wait2接口的阻塞仍处于活跃状态，连接池判定该连接被占用，因此第二个异步请求会新建连接。

2. 能否强制Java HttpClient复用连接？ #

可以通过自定义连接池配置调整，但无法强制在第一个连接活跃时复用——因为HTTP/1.1的流水线（pipelining）虽允许在同一连接上发送多个请求并等待响应，但Java HttpClient默认关闭了流水线功能。

若要启用流水线，需手动配置HttpClient：

HttpClient httpClient = HttpClient.newBuilder()
        .version(HttpClient.Version.HTTP_1_1)
        .connectTimeout(Duration.ofSeconds(5))
        .build();

即便如此，HttpClient也仅会在连接空闲或服务器明确支持流水线时尝试复用。同时需确保服务器端正确实现HTTP/1.1流水线处理（能在同一连接上接收多个请求并按顺序返回响应），否则可能出现响应乱序问题。

3. 其他可行方案 #

如果必须保证在同一连接上发送多个请求（无论前一个请求是否完成），可考虑以下两种方式：

• 使用Apache HttpClient：它支持显式开启HTTP流水线，且能通过配置连接池强制复用活跃连接，示例配置：

CloseableHttpClient httpClient = HttpClients.custom()
        .setConnectionReuseStrategy(new DefaultConnectionReuseStrategy() {
            @Override
            public boolean keepAlive(HttpResponse response, HttpContext context) {
                return true; // 强制保持连接
            }
        })
        .build();

Apache HttpClient对流水线的支持比Java原生客户端更灵活。

• 直接使用Socket：若上述客户端无法满足需求，直接用Socket手动发送HTTP请求是最直接的方式——你可以完全控制连接生命周期，在同一Socket上连续发送多个请求并依次读取响应。这种方式需要自行处理HTTP协议细节（如请求头、响应解析、Content-Length处理等），但能绝对保证连接唯一。

内容的提问来源于stack exchange，提问作者dev-rifaii