You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Quarkus测试中共享KubernetesClient引发的问题(TestContainers+K3s)

问题分析

核心矛盾在于:ClientFactory是@ApplicationScoped作用域,它注入的KubernetesClient会被长期持有复用;而控制器中通过use块关闭了从该实例适配出的命名空间客户端,这会直接关闭原始的KubernetesClient实例,导致后续所有依赖该实例的操作因客户端已关闭而失败。你尝试的@Dependent作用域Producer未生效,是因为ApplicationScoped的ClientFactory会将注入的客户端升级为自身的单例作用域,无法实现每次调用生成新实例。

解决方案

方案1:每次创建独立的客户端实例

修改ClientFactory,基于配置每次构建全新的KubernetesClient,避免复用同一实例:

@ApplicationScoped
class ClientFactory {
    @Inject
    lateinit var config: Config

    fun createClient(namespace: String): NamespacedKubernetesClient {
        return KubernetesClientBuilder()
            .withConfig(config)
            .build()
            .adapt(NamespacedKubernetesClient::class.java)
            .inNamespace(namespace)
    }
}

这样每次调用createClient都会生成独立的客户端实例,use块关闭的只是当前实例,不会影响后续测试的客户端。

方案2:通过CDI Instance延迟获取新客户端

利用Instance<KubernetesClient>延迟获取客户端,确保每次调用都拿到@Dependent作用域的新实例:

@ApplicationScoped
class ClientFactory {
    @Inject
    lateinit var clientInstance: Instance<KubernetesClient>

    fun createClient(namespace: String): NamespacedKubernetesClient {
        return clientInstance.get()
            .adapt(NamespacedKubernetesClient::class.java)
            .inNamespace(namespace)
    }
}

该方案依赖你已实现的@Dependent作用域KubernetesClientProducer,确保每次get()都会生成新的客户端实例。

方案3:交由CDI管理客户端生命周期

如果希望复用客户端实例,移除控制器中的use块,让Quarkus的CDI负责客户端的销毁:

@GET
fun foo(@RestPath namespace: String): RestResponse<String> =
    runBlocking(Dispatchers.IO) {
        val client = kubernetesClientFactory.createClient(namespace)
        // ... 业务逻辑,无需手动调用close()
    }

此方式需注意:Quarkus会在应用上下文关闭时自动销毁CDI管理的客户端,不会出现资源泄漏问题。

额外测试优化

若需要彻底隔离测试环境,可移除测试类上的@TestInstance(TestInstance.Lifecycle.PER_CLASS),改用默认的PER_METHOD作用域。这样每个测试方法都会创建新的测试类实例和CDI上下文,从根源避免客户端复用问题,但会增加测试执行时间,需根据实际场景权衡。

内容的提问来源于stack exchange,提问作者VanTheMan

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.09 12:43:27