怎么利用 HttpClient API 实现支持 HTTP/2 与 WebSocket 的高性能异步网络请求-java教程-PHP中文网

java 11+ httpclient 默认尝试协商 http/2，但仅当满足三条件时才真正启用：服务端支持 alpn（h2）、客户端运行 java 11+（推荐 17+/21）、请求使用 https://；否则自动降级至 http/1.1。

怎么利用 httpclient api 实现支持 http/2 与 websocket 的高性能异步网络请求

Java 11 HttpClient 默认就支持 HTTP/2，但得满足几个硬性条件

不是调用 sendAsync() 就自动走 HTTP/2 —— 它会先协商协议版本。实际是否启用 HTTP/2 取决于服务端是否支持、TLS 配置是否合规、以及 JDK 自身限制。

必须同时满足以下三点，HttpClient 才会真正使用 HTTP/2：

服务端明确通告 ALPN 支持 h2（比如 Nginx/OpenResty/Tomcat 9+ 配置了 TLSv1.2+ 和 ALPN）
客户端运行在 Java 11 或更高版本（Java 17+ 更稳定，Java 21 已修复多个 HTTP/2 流控 bug）
请求 URI 使用 https://（HTTP/2 over cleartext 即 h2c 在 JDK 中默认禁用，且需显式调用 HttpClient.newBuilder().version(HttpClient.Version.HTTP_2) 并配合自定义 SSLContext 才可能生效，不推荐）

验证是否走 HTTP/2：抓包看 TLS 握手的 ALPN 协商字段，或在响应中检查 response.version() 是否返回 HttpClient.Version.HTTP_2。

WebSocket 连接不能靠 HttpClient.sendAsync() 建立

HttpClient 提供的是 java.net.http.WebSocket 类型，但它和 HTTP 请求是两套独立路径。你无法用 HttpRequest.newBuilder().uri("wss://...") 然后调用 sendAsync() —— 这会直接抛出 IllegalArgumentException：“Unsupported protocol: wss”。

正确做法是调用 HttpClient.newHttpClient().newWebSocketBuilder()：

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

HttpClient client = HttpClient.newHttpClient();
client.newWebSocketBuilder()
    .buildAsync(URI.create("wss://echo.websocket.org"), new WebSocket.Listener() {
        @Override
        public void onOpen(WebSocket webSocket) {
            webSocket.sendText("hello", true);
        }
        @Override
        public void onText(WebSocket webSocket, CharSequence data, boolean last) {
            System.out.println("received: " + data);
        }
    });

注意：newWebSocketBuilder() 返回的是 CompletableFuture<websocket></websocket>，不是 CompletableFuture<httpresponse></httpresponse>；监听器方法全部异步回调，不阻塞线程。

异步请求链路上最容易漏掉的资源管理点

很多人只记得 sendAsync() 不阻塞，却忽略两个隐性成本：

HttpClient 实例内部持有 Executor 和连接池，长期复用没问题，但若每次请求都新建 HttpClient.newBuilder().build()，会泄漏线程与 socket 资源
CompletableFuture 链未加异常处理时，失败会静默吞掉异常（比如 DNS 失败、SSL handshake timeout），导致调试时看不到错误堆栈

推荐写法：

HttpClient client = HttpClient.newBuilder()
    .connectTimeout(Duration.ofSeconds(5))
    .build(); // 复用这个 client 实例

client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
    .thenApply(HttpResponse::body)
    .exceptionally(t -> {
        System.err.println("Request failed: " + t.getMessage());
        return "";
    })
    .thenAccept(System.out::println);