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

