在Ktor中实现异步HTTP请求复用同一TCP连接的方法

你遇到的问题核心是Ktor Java引擎默认配置下，并发异步请求没有启用连接池复用，导致每个请求新建TCP连接。只需显式配置引擎的连接池参数，就能解决这个问题。

修改后的代码示例 #

import io.ktor.client.*
import io.ktor.client.engine.java.*
import io.ktor.client.request.*
import kotlinx.coroutines.*

suspend fun main() {
    // 配置带连接池的HttpClient
    val client = HttpClient(Java) {
        engine {
            // 设置最大同时连接数，按需调整（建议大于并发请求数）
            maxConnectionsCount = 10
            // 空闲连接保持存活时间（毫秒），确保后续请求能复用
            keepAliveTime = 5000
            // 连接超时时间，按需设置
            connectionTimeout = 10000
        }
    }

    // 使用coroutineScope自动管理协程生命周期，无需手动cancel
    coroutineScope {
        val responseDeferred = (0..2).map { async { client.get("http://ktor.io/") } }
        responseDeferred.forEach { it.await() }
    }

    client.close()
}

关键配置说明 #

• maxConnectionsCount：设置客户端允许的最大同时TCP连接数。当并发请求数不超过这个值时，客户端会优先复用已建立的空闲连接，而不是新建连接。
• keepAliveTime：指定空闲连接在池中保持存活的时间。只要连接在这个时间内没有被使用，就会被保留下来供后续请求复用。
• 复用前提：必须保证所有请求使用同一个HttpClient实例，不能为每个请求新建客户端，否则连接池无法共享。

另外补充：Ktor客户端默认会发送Connection: keep-alive请求头，只要目标服务器支持HTTP长连接（现代服务器基本都支持），就能实现连接复用。

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