如何在Apache HttpClient 5中获取未关闭且不占内存的响应InputStream？

针对你遇到的HttpClient 5迁移时的资源管理冲突问题，这里提供两种实用的解决方案，既不会提前关闭响应流，也不会把整个响应加载到内存：

1. 显式转移资源管理责任 #

直接返回响应流，同时通过注释和抑制警告明确告知调用方需负责关闭流（关闭流时会连带释放底层的ClassicHttpResponse资源）。这种方式代码改动最小，适合对原有逻辑改动要求低的场景。

示例代码：

import org.apache.hc.core5.http.HttpStatus;
import org.apache.hc.core5.http.io.ClassicHttpResponse;
import org.apache.hc.core5.http.io.ClassicHttpRequest;
import org.apache.hc.core5.http.message.ClassicRequestBuilder;
import org.apache.hc.client5.http.classic.HttpClient;
import org.apache.hc.client5.http.protocol.HttpClientContext;

import java.io.IOException;
import java.io.InputStream;

@SuppressWarnings("resource")
public InputStream fetchResponseStream(String url, HttpClient httpClient) throws IOException {
    ClassicHttpRequest request = ClassicRequestBuilder.get(url).build();
    ClassicHttpResponse response = httpClient.executeOpen(null, request, HttpClientContext.create(), null);

    // 先校验响应状态，异常时手动关闭response避免泄漏
    if (response.getCode() != HttpStatus.SC_OK) {
        try (response) {
            throw new IOException("Unexpected response status: " + response.getCode());
        }
    }

    // 返回响应流，调用方必须负责关闭此流
    return response.getEntity().getContent();
}

调用方使用示例（必须用try-with-resources管理流）：

try (InputStream in = fetchResponseStream("https://example.com", httpClient)) {
    // 处理流数据，比如逐行读取、分片写入文件等
}

2. 自定义包装流实现自动关联关闭 #

通过自定义FilterInputStream子类，在调用方关闭包装流时自动关闭底层的ClassicHttpResponse，既封装了资源管理逻辑，又不需要调用方额外关注底层资源。这种方式更健壮，适合作为公共工具方法使用。

示例代码：

import org.apache.hc.core5.http.HttpStatus;
import org.apache.hc.core5.http.io.ClassicHttpResponse;
import org.apache.hc.core5.http.io.ClassicHttpRequest;
import org.apache.hc.core5.http.message.ClassicRequestBuilder;
import org.apache.hc.client5.http.classic.HttpClient;
import org.apache.hc.client5.http.protocol.HttpClientContext;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

// 自定义包装流，关闭时自动关闭底层response
public class ResponseClosingInputStream extends FilterInputStream {
    private final ClassicHttpResponse response;
    private boolean closed = false;

    public ResponseClosingInputStream(InputStream in, ClassicHttpResponse response) {
        super(in);
        this.response = response;
    }

    @Override
    public void close() throws IOException {
        if (!closed) {
            closed = true;
            try {
                super.close();
            } finally {
                // 确保底层response被关闭
                response.close();
            }
        }
    }
}

// 使用包装流的获取方法
public InputStream fetchResponseStream(String url, HttpClient httpClient) throws IOException {
    ClassicHttpRequest request = ClassicRequestBuilder.get(url).build();
    ClassicHttpResponse response = httpClient.executeOpen(null, request, HttpClientContext.create(), null);

    try {
        if (response.getCode() != HttpStatus.SC_OK) {
            throw new IOException("Unexpected response status: " + response.getCode());
        }
        InputStream contentStream = response.getEntity().getContent();
        // 返回包装流，调用方关闭此流时自动释放所有资源
        return new ResponseClosingInputStream(contentStream, response);
    } catch (IOException e) {
        // 发生异常时手动关闭response
        response.close();
        throw e;
    }
}

调用方无需额外操作，正常使用try-with-resources即可：

try (InputStream in = fetchResponseStream("https://example.com", httpClient)) {
    // 处理流数据
}

注意事项 #

• 绝对不要绕过HttpClient的资源管理机制，否则会造成连接池资源泄漏，导致后续请求无法获取连接。
• 两种方案都保持了流的“按需读取”特性，不会把整个响应加载到内存，适合处理大体积响应数据。

内容的提问来源于stack exchange，提问作者Yevhen Vasyliev