本文详解如何在 jvm 平台上（java/kotlin）使用 jetty httpclient 实现真正的 http/2 双向、实时、非阻塞流式通信，支持客户端边发送二进制数据、边读取服务端 json 响应，满足单连接下 5gb 级别分块上传与即时反馈的严苛场景。
本文详解如何在 jvm 平台上（java/kotlin）使用 jetty httpclient 实现真正的 http/2 双向、实时、非阻塞流式通信，支持客户端边发送二进制数据、边读取服务端 json 响应，满足单连接下 5gb 级别分块上传与即时反馈的严苛场景。
HTTP/2 协议原生支持多路复用与请求/响应双向流（bidi streaming），但主流 Java HTTP 客户端（如 OkHttp、Ktor、Java 11+ HttpClient）默认采用“请求体写入完成 → 等待响应头 → 再读响应体”的串行模型，无法满足“边发边收”的实时交互需求——这正是你在 OkHttp 和 Ktor 示例中遇到 onResponse() 或 execute { } 永不触发的根本原因：它们将请求体视为一次性封闭流（RequestBody.writeTo() 必须返回后才发起请求），而 HTTP/2 的双向能力被上层抽象屏蔽了。
要真正解锁 HTTP/2 的双向流能力，必须选用底层可精确控制流生命周期的客户端。Jetty 的 HttpClient（配合 HttpClientTransportOverHTTP2）是目前 JVM 生态中唯一开箱即用、稳定支持非阻塞双向流式 I/O 的生产级方案。其核心在于两个关键组件：
- OutputStreamRequestContent：提供可随时写入、无需预知长度、不依赖 close() 触发请求的输出流；
- InputStreamResponseListener：提供异步可读的响应输入流，在首字节到达后即可开始消费，无需等待整个响应结束。
以下为 Kotlin（兼容 Java）的完整实现示例，已适配你的 5GB 二进制流 + JSON 响应场景：
import org.eclipse.jetty.client.*
import org.eclipse.jetty.client.api.Request
import org.eclipse.jetty.client.api.Response
import org.eclipse.jetty.client.http.HttpClientTransportOverHTTP2
import org.eclipse.jetty.http.HttpMethod
import org.eclipse.jetty.util.IO
import java.io.*
import java.nio.charset.StandardCharsets
import java.util.concurrent.TimeUnit
fun setupBidirectionalHttp2Session(
baseUrl: String = "https://your-php-server.com",
path: String = "/media"
): Pair<OutputStream, InputStream> {
// 1. 初始化 Jetty HTTP/2 客户端
val http2Client = HTTP2Client()
val client = HttpClient(HttpClientTransportOverHTTP2(http2Client))
client.start()
// 2. 创建双向流载体
val content = OutputStreamRequestContent()
val listener = InputStreamResponseListener()
// 3. 发起异步 POST 请求（不阻塞）
val request: Request = client.newRequest("$baseUrl$path")
.method(HttpMethod.POST)
.header("Content-Type", "application/octet-stream")
.body(content)
.send(listener)
// 4. 可选：同步等待响应头确认连接就绪（超时 5s）
try {
val response: Response = listener.get(5, TimeUnit.SECONDS)
if (response.status != 200) {
throw IOException("Server rejected with status ${response.status}")
}
} catch (e: Exception) {
client.stop()
throw RuntimeException("Failed to establish bidirectional session", e)
}
// 5. 返回可读写的流对 —— 此刻即可并发操作！
return Pair(content.outputStream, listener.inputStream)
}
// 使用示例：模拟分块上传 + 即时解析 JSON 响应
fun demoBidirectionalFlow() {
val (output, input) = setupBidirectionalHttp2Session()
// 启动响应处理线程（持续读取 JSON 响应）
Thread {
val reader = BufferedReader(InputStreamReader(input, StandardCharsets.UTF_8))
var line: String?
while (reader.readLine().also { line = it } != null) {
println("← Server response: $line") // 如: {"chunk_id":1,"processed":true,"checksum":"abc123"}
}
}.start()
// 主线程：分块写入二进制数据（例如从文件或实时采集源）
val chunkSize = 64 * 1024 // 64KB per chunk
val buffer = ByteArray(chunkSize)
var chunkId = 0
// 模拟生成 3 块二进制数据（实际中替换为 FileInputStream / PipeSource 等）
repeat(3) {
val len = generateChunkData(buffer, chunkId++)
output.write(buffer, 0, len)
output.flush() // 关键：主动 flush 确保数据立即发出
Thread.sleep(100) // 模拟处理间隔
}
// 发送完毕，关闭输出流（通知服务端 EOF）
output.close()
// 注意：input 流将在服务端关闭连接后自然结束（read() 返回 -1）
}✅ 关键要点说明：
立即学习“Java免费学习笔记（深入）”；
- content.outputStream 是非阻塞、可多次 write() + flush() 的真实 HTTP/2 请求体流，无需等待 close() 即可驱动数据发送；
- listener.inputStream 在收到首个响应字节后即可 read()，支持逐行解析 JSON（如使用 BufferedReader）、或按帧解析（若服务端使用自定义分隔符）；
- 务必调用 output.flush()：虽然 OutputStreamRequestContent 内部有缓冲，但在高吞吐场景下显式 flush() 能显著降低服务端响应延迟；
- PHP 服务端需正确实现 HTTP/2 流式响应：确保使用 ob_flush() + flush()（或 Swoole/FPM 配置支持）及时推送响应，且不缓存整个响应体；
- 资源管理：client.stop() 应在会话结束后调用，避免连接泄漏；生产环境建议复用 HttpClient 实例（单例），而非每次新建。
⚠️ 注意事项与常见陷阱：
- ❌ 不要使用 RequestBody.create() 或 setBody(ByteArray)：它们强制加载全部数据到内存，违背流式初衷；
- ❌ 避免在 OutputStream 上调用 close() 过早——仅当所有数据发送完毕时调用，否则连接将异常终止；
- ✅ 对于超大文件（如 5GB），推荐结合 FileInputStream + Channels.newChannel() 直接传输，避免内存拷贝；
- ✅ 若需严格顺序保障（如 chunk N 的响应必须在 chunk N+1 发送前到达），可在客户端添加简单序列号校验逻辑；
- ? Jetty 默认启用 ALPN，确保 JVM 运行于 JDK 8u252+ 或 JDK 9+，并已安装 jetty-alpn-conscrypt-server（Conscrypt）或 jetty-alpn-java（JDK 自带）等 ALPN 提供者。
总结而言，Jetty 的 OutputStreamRequestContent + InputStreamResponseListener 组合，是当前 JVM 上实现符合 RFC 7540 标准的 HTTP/2 双向流通信的最直接、最可靠、最轻量级的方案。它绕过了高层客户端的抽象约束，直抵协议本质，完美匹配你“单连接、大体积、二进制、JSON 交错响应”的架构需求。只需确保 PHP 服务端同样以流式方式处理请求与响应，整套链路即可稳定承载 TB 级数据的实时双向交互。
