Ktor Server（Netty）连接持续增长致崩溃问题排查求助

首先，从你描述的现象（端口连接数持续增长至2万+）和代码来看，HttpClient的使用方式是最可能的根源，其次是连接存活策略的配置，我们一步步来拆解：

1. Apache HttpClient的连接泄漏问题 #

你的post函数每次请求都会创建一个新的HttpClient实例，虽然调用了close()，但Apache HttpClient的资源释放逻辑并不是立刻回收所有底层连接的，频繁创建/销毁客户端会导致大量未及时释放的连接堆积：

• 每次新建HttpClient(Apache)都会初始化一个独立的连接池，而每个连接池里的连接在关闭客户端时，可能因为超时或未正确清理的原因，无法立刻被操作系统回收。
• 你的请求超时设置为60秒，但如果目标服务响应缓慢或出现异常，连接可能会在池中滞留更久。

修复方案：复用HttpClient实例 #

不要每次请求都创建新客户端，改为全局复用一个单例实例：

// 全局单例HttpClient
private val httpClient = HttpClient(Apache) {
    install(HttpTimeout) {
        requestTimeoutMillis = 60000
    }
    engine {
        customizeClient {
            sslContext = SSLContextBuilder.create().loadTrustMaterial(object : TrustStrategy {
                override fun isTrusted(chain: Array<out X509Certificate>?, authType: String?): Boolean {
                    return true
                }
            }).build()
            setSSLHostnameVerifier(NoopHostnameVerifier())
            // 配置连接池参数，避免连接堆积
            setMaxConnTotal(200) // 全局最大连接数
            setMaxConnPerRoute(50) // 每个域名的最大连接数
            setDefaultConnectionConfig(ConnectionConfig.custom()
                .setSocketTimeout(60000)
                .setConnectTimeout(10000)
                .setConnectionRequestTimeout(10000)
                .build())
        }
    }
}

suspend fun post(
    url: String,
    params: Map<String, String> = emptyMap(),
    headersMap: Map<String, String> = emptyMap()
): Result<String> {
    return kotlin.runCatching {
        httpClient.post<String>(url) {
            body = MultiPartFormDataContent(
                formData {
                    params.forEach { append(it.key, it.value) }
                }
            )
            headersMap.forEach { (key, value) -> header(key, value) }
        }
    }
    // 不需要每次关闭客户端，全局单例在服务停止时统一关闭
}

// 在服务停止的钩子中关闭客户端（比如Ktor的ApplicationStop事件）
fun Application.configureShutdownHook() {
    environment.monitor.subscribe(ApplicationStop) {
        httpClient.close()
    }
}

这样做的好处是：连接池会复用已有的连接，避免频繁创建新连接，同时通过配置连接池参数，限制最大连接数，防止连接无限制增长。

2. 伴生对象缓存的潜在问题 #

你提到伴生对象缓存数据，需要重点检查：

• 缓存的对象是否持有HttpClient、数据库连接或其他资源引用？如果这些资源没有正确释放，会导致内存和连接泄漏。
• 缓存的过期策略是否合理？如果缓存的对象永远不失效，可能导致内存占用过高，间接影响连接的回收。

建议：

• 给伴生对象的缓存添加过期时间（比如用Guava Cache或Kotlin的MutableMap配合定时清理逻辑）。
• 确保缓存的对象不持有任何未关闭的资源引用。

3. Ktor Server的Keep-Alive配置优化 #

默认情况下，Ktor的Netty引擎可能会让连接保持较长时间，导致大量空闲连接堆积。你可以在配置Netty引擎时，明确设置Keep-Alive的超时时间：

fun Application.module() {
    embeddedServer(Netty, port = 7171) {
        // 配置Netty引擎参数
        engine {
            configureBootstrap {
                childOption(ChannelOption.SO_KEEPALIVE, true)
                childOption(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
                childOption(ChannelOption.SO_TIMEOUT, 30000)
            }
            // 设置空闲连接超时，超过时间自动关闭
            pipeline.addLast("idle-handler", IdleStateHandler(0, 0, 30)) // 30秒无读写则触发超时
            pipeline.addLast("idle-disconnect", object : ChannelInboundHandlerAdapter() {
                override fun userEventTriggered(ctx: ChannelHandlerContext, evt: Any) {
                    if (evt is IdleStateEvent) {
                        ctx.close()
                    }
                }
            })
        }
        // 其他路由和配置...
    }.start(wait = true)
}

另外，在响应头中添加明确的Keep-Alive指令，告诉客户端连接的存活时间：

// 在路由或全局拦截器中设置响应头
install(DefaultHeaders) {
    header("Keep-Alive", "timeout=30, max=100")
}

• timeout=30：连接空闲30秒后关闭
• max=100：该连接最多处理100个请求后关闭

4. 额外排查步骤 #

• 用ss -antp | grep :7171查看连接的状态（TIME_WAIT、ESTABLISHED等），如果大量TIME_WAIT，可能是客户端没有正确关闭连接，或者操作系统的TIME_WAIT回收参数需要调整（比如设置net.ipv4.tcp_tw_reuse=1）。
• 利用你已经引入的ktor-metrics监控连接数、请求处理时间等指标，定位是否有慢请求导致连接长时间占用。
• 检查服务器的ulimit设置，确保打开文件描述符的限制足够（可以用ulimit -n查看，建议设置为65535）。

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