测试/本地环境中复用DockerComposeContainer的解决方案

可以通过先检测目标服务是否已运行，再决定是否启动Testcontainers容器的方式实现需求。下面是具体的实现方案：

1. 实现服务运行状态检测 #

有两种可靠的检测方式，选一种即可：

方式一：用Testcontainers自带的Docker客户端（推荐） #

利用Testcontainers内置的Docker客户端API，直接查询运行中的容器，无需依赖系统命令：

import org.testcontainers.DockerClientFactory;
import com.github.dockerjava.api.model.Container;
import java.util.Collections;
import java.util.List;

private static boolean isServiceRunning(String serviceName) {
    try {
        // 查询名称匹配且处于运行状态的容器
        List<Container> runningContainers = DockerClientFactory.instance().client()
                .listContainersCmd()
                .withNameFilter(Collections.singletonList(serviceName))
                .withStatusFilter(Collections.singletonList("running"))
                .exec();
        return !runningContainers.isEmpty();
    } catch (Exception e) {
        // 异常情况下默认认为服务未运行
        return false;
    }
}

方式二：执行Docker系统命令 #

通过调用docker inspect命令判断容器状态，适合无法引入Docker Java客户端的场景：

import java.io.IOException;

private static boolean isServiceRunning(String serviceName) {
    try {
        Process process = new ProcessBuilder(
                "docker", "inspect", "-f", "{{.State.Running}}", serviceName
        ).redirectErrorStream(true).start();
        
        int exitCode = process.waitFor();
        if (exitCode != 0) return false;
        
        String output = new String(process.getInputStream().readAllBytes()).trim();
        return Boolean.parseBoolean(output);
    } catch (IOException | InterruptedException e) {
        return false;
    }
}

注意：如果你的Docker Compose容器名称是自动生成的（比如项目名_服务名_1），需要把serviceName替换成实际的容器名称，或者用模糊匹配的方式查询。

2. 修改测试代码，实现条件复用 #

调整原有的静态初始化逻辑，根据检测结果选择复用本地服务或启动Testcontainers容器：

import org.testcontainers.containers.DockerComposeContainer;
import java.io.File;

private static DockerComposeContainer<?> dockerComposeContainer;
// 统一提供服务地址和端口给测试方法使用
private static String serviceHost;
private static Integer servicePort;

// 常量定义
private static final String SERVICE_NAME = "your-service-name";
private static final int SERVICE_PORT = 1234;

static {
    boolean isLocalServiceRunning = isServiceRunning(SERVICE_NAME);
    if (isLocalServiceRunning) {
        // 复用本地已运行的服务，直接使用localhost和原端口
        serviceHost = "localhost";
        servicePort = SERVICE_PORT;
    } else {
        // 本地服务未运行，启动Testcontainers容器
        dockerComposeContainer = new DockerComposeContainer<>(new File("docker-compose.yml"))
                .withServices(SERVICE_NAME)
                .withExposedService(SERVICE_NAME, SERVICE_PORT);
        dockerComposeContainer.start();
        // 获取Testcontainers映射后的动态地址和端口
        serviceHost = dockerComposeContainer.getServiceHost(SERVICE_NAME, SERVICE_PORT);
        servicePort = dockerComposeContainer.getServicePort(SERVICE_NAME, SERVICE_PORT);
    }
}

// 测试示例
@Test
void testServiceInteraction() {
    // 使用统一的serviceHost和servicePort初始化客户端
    YourServiceClient client = new YourServiceClient(serviceHost, servicePort);
    // 执行测试逻辑
    // ...
}

关键注意事项 #

• 若使用Docker Compose的自定义容器名称，确保检测时的serviceName与实际容器名一致；
• 测试代码中所有服务连接逻辑都要使用serviceHost和servicePort变量，避免硬编码地址；
• 如果本地服务的端口与Testcontainers映射的端口不同，无需额外处理，Testcontainers的getServicePort会返回正确的映射端口。

内容的提问来源于stack exchange，提问作者C.P.O