如何使用Java 11 HttpClient读取HTTP响应Trailers？

Java 11 HttpClient 读取响应Trailers的核心逻辑是：Trailers作为HTTP响应的收尾部分，必须在响应体流完全读取完毕后才能被解析获取，以下是具体实现方案：

同步请求+流处理场景 #

HttpClient client = HttpClient.newHttpClient();
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("你的流接口地址"))
        .build();

// 以InputStream形式接收响应体
HttpResponse<InputStream> response = client.send(request, HttpResponse.BodyHandlers.ofInputStream());

// 完整读取并处理响应体流
try (InputStream in = response.body()) {
    byte[] buffer = new byte[1024];
    int bytesRead;
    while ((bytesRead = in.read(buffer)) != -1) {
        // 这里添加你的业务处理逻辑，比如写入文件、解析数据等
        System.out.write(buffer, 0, bytesRead);
    }
}

// 流读取完成后，获取Trailers
HttpHeaders trailers = response.trailers();
// 遍历输出所有Trailer字段
trailers.map().forEach((key, values) -> {
    System.out.printf("Trailer %s: %s%n", key, values);
});

异步请求+流处理场景 #

如果使用异步请求，同样需要在响应体流处理完成后再获取Trailers：

HttpClient client = HttpClient.newHttpClient();
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("你的流接口地址"))
        .build();

client.sendAsync(request, HttpResponse.BodyHandlers.ofInputStream())
        .thenAccept(response -> {
            try (InputStream in = response.body()) {
                byte[] buffer = new byte[1024];
                int bytesRead;
                while ((bytesRead = in.read(buffer)) != -1) {
                    // 处理流数据
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            // 获取并处理Trailers
            HttpHeaders trailers = response.trailers();
            trailers.map().forEach((k, v) -> System.out.println(k + ": " + v));
        })
        .join();

注意事项与非常规方案说明 #

• 标准方案的可靠性基于HTTP协议规范：Trailers必须跟随在响应体之后发送，因此只有读完响应体流，HttpClient才能完整解析Trailers。
• 非常规方案（如未读完流就尝试获取Trailers）：这种操作不符合HTTP协议逻辑，大概率无法获取到有效Trailers，因为服务器此时可能还未发送Trailers，HttpClient也未完成解析。如果业务场景特殊必须尝试，可自定义BodySubscriber监听流结束事件，但实现复杂且成功率极低，不推荐使用。

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