如何在Quarkus集成测试中复用Testcontainers容器？

我完全懂你的痛点——Kafka容器启动那6-8秒的等待时间，在多个测试类里重复跑真的太拖效率了。下面是几个经过实践验证的可行方案，帮你实现容器复用：

方案一：调整测试资源生命周期+全局注册（最推荐） #

核心思路是：让Quarkus不再在每个测试类结束后关闭Kafka容器，而是交给JVM的 shutdown hook 在所有测试完成后统一清理，同时全局注册测试资源避免重复配置。

步骤1：修改KafkaNode类的生命周期逻辑 #

我们要修改stop()方法不再主动关闭容器，而是通过静态代码块添加JVM shutdown hook，确保所有测试结束后才关闭容器；同时在start()里判断容器状态，避免重复启动：

public class KafkaNode implements QuarkusTestResourceLifecycleManager { 
    static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1")) 
        .withNetworkAliases("kafkaNode") 
        .withNetwork(CommonNetwork.getInstance()); 

    // 静态代码块：添加JVM关闭钩子，所有测试结束后再关闭Kafka容器
    static {
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            if (kafka.isRunning()) {
                kafka.close();
            }
        }));
    }

    @Override 
    public Map<String, String> start() { 
        // 仅当容器未运行时才启动，避免重复初始化
        if (!kafka.isRunning()) {
            kafka.start();
        }
        return Collections.singletonMap("myapp.kafka.servers", kafka.getBootstrapServers()); 
    } 

    @Override 
    public void stop() { 
        // 移除主动关闭容器的逻辑，交给shutdown hook处理
        // kafka.close(); 
    } 
}

步骤2：全局注册测试资源 #

不用再给每个测试类添加@QuarkusTestResource注解了，我们通过配置文件全局注册，让所有@QuarkusTest自动加载这个资源：

在src/test/resources/META-INF/quarkus-test-resources.properties文件中添加：

quarkus.test.resources=com.yourpackage.KafkaNode

（记得把com.yourpackage替换成你实际的包名）

步骤3：清理测试类上的重复配置 #

移除所有测试类上的@QuarkusTestResource注解，比如你的MyIntegrationTest类可以改成：

@QuarkusTest 
@Tag(INTEGRATION_TEST) 
class MyIntegrationTest { ... }

这样调整后，Kafka容器只会在第一个测试类启动时初始化一次，所有后续测试类都会复用这个容器；当所有测试执行完毕，JVM退出时，shutdown hook会自动关闭容器。

方案二：利用Testcontainers的Singleton容器特性 #

Testcontainers本身支持单例容器模式，我们可以结合这个特性进一步简化代码：

public class KafkaNode implements QuarkusTestResourceLifecycleManager { 
    // 使用SingletonContainer包装Kafka容器，确保全局唯一实例
    static final SingletonContainer<KafkaContainer> kafkaSingleton = 
        new SingletonContainer<>(() -> new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"))
            .withNetworkAliases("kafkaNode")
            .withNetwork(CommonNetwork.getInstance()));

    @Override 
    public Map<String, String> start() { 
        // 获取单例容器实例并启动（自动判断是否已运行）
        KafkaContainer kafka = kafkaSingleton.getContainer();
        kafka.start();
        return Collections.singletonMap("myapp.kafka.servers", kafka.getBootstrapServers()); 
    } 

    @Override 
    public void stop() { 
        // SingletonContainer会自动处理容器关闭，无需手动操作
    } 
}

后续的全局注册和测试类清理和方案一一致。SingletonContainer会自动保证容器只启动一次，并且在JVM关闭时自动清理，非常省心。

注意事项 #

• 如果你的测试是并行执行的，不用担心线程安全问题：KafkaContainer本身是线程安全的，Testcontainers的单例实现也考虑了并发场景。
• 如果你需要在特定测试类中单独使用Kafka容器（不复用全局实例），可以保留该类的@QuarkusTestResource注解并设置restrictToAnnotatedClass=true，但这种场景建议尽量避免，保持测试环境一致性。

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