多线程环境下如何避免Java传递给Karate的属性值被覆盖？

问题背景 #

通过Java代码调用Karate Runner时，使用.systemProperty()设置全局系统属性，在多请求并发执行时，tests.run.env等属性会被不同请求覆盖，导致测试逻辑读取到错误的环境值。

相关代码如下：

Java 启动代码 #

private void triggerAPIAutomationTestRun(TestCaseExecutionRequest request, String testsDirPath) {
    try {
        // Setting required properties into System property so that it's accessible in karate-config.js
        Results results = Runner.path("file:" + testsDirPath + SLASH + TESTCASE)
                .outputCucumberJson(true)
                .systemProperty("tests.run.env", request.getEnv())
                .systemProperty("service.port", serverPort)
                .parallel(PARALLEL_THREAD_COUNT);
        testsRunReportService.generateTestReport(request, testsDirPath, results.getReportDir());
        testsRunReportService.sendRunReportMail(request, (SLASH + TEST_REPORT_VIEWER + testsDirPath + SLASH + REPORTS + SLASH
                + API_AUTOMATION_TEST + SLASH + CUCUMBER_HTML_REPORTS + SLASH + RUN_REPORT_FILE_NAME),
                false, true);
        log.info("Test case run completed for service = " + request.getServiceName());
    } catch (Exception e) {
        log.error("Failed to run API automation tests. Cause : " + e.getMessage(), e);
        testsRunReportService.sendRunReportMail(request, "", false, false);
    }
}

karate-config.js 配置代码 #

function fn() {

    var env = karate.properties['tests.run.env'];
    karate.log('Value of tests.run.env : ', env);

    var config = {
        hostname : 'abc.com',
        qa_user_username: 'abc@gmail.com',
        qa_user_password: 'sdsfghyj'
    };

    if (env == 'local') {
        var port = karate.properties['service.port'];
        config.hostname = '127.0.0.1:' + port
    } else if (env == 'sandbox-lower') {
        config.hostname = 'abclower.com'
    } else if (env == 'uat') {
        config.hostname = 'abcuat.com'
    } else {
        config.hostname = 'abcprod.com'
    }

//    karate.configure('connectTimeout', 5000);
//    karate.configure('readTimeout', 5000);

    return config;
}

问题原因 #

System.setProperty()设置的是JVM全局静态属性，多线程并发执行时，不同请求会互相覆盖这些属性值，导致后续测试读取到错误的配置。

解决方案 #

推荐使用Karate提供的.config()方法传递上下文隔离的配置，替代全局系统属性，每个测试执行线程会拿到独立的配置，不会互相干扰。

步骤1：修改Java启动代码 #

将原来的.systemProperty()替换为.config()，通过Map传递配置参数：

private void triggerAPIAutomationTestRun(TestCaseExecutionRequest request, String testsDirPath) {
    try {
        // 用Map传递隔离的配置，替代全局系统属性
        Map<String, Object> testConfig = new HashMap<>();
        testConfig.put("tests.run.env", request.getEnv());
        testConfig.put("service.port", serverPort);

        Results results = Runner.path("file:" + testsDirPath + SLASH + TESTCASE)
                .outputCucumberJson(true)
                .config(testConfig) // 传递隔离配置
                .parallel(PARALLEL_THREAD_COUNT);
        testsRunReportService.generateTestReport(request, testsDirPath, results.getReportDir());
        testsRunReportService.sendRunReportMail(request, (SLASH + TEST_REPORT_VIEWER + testsDirPath + SLASH + REPORTS + SLASH
                + API_AUTOMATION_TEST + SLASH + CUCUMBER_HTML_REPORTS + SLASH + RUN_REPORT_FILE_NAME),
                false, true);
        log.info("Test case run completed for service = " + request.getServiceName());
    } catch (Exception e) {
        log.error("Failed to run API automation tests. Cause : " + e.getMessage(), e);
        testsRunReportService.sendRunReportMail(request, "", false, false);
    }
}

步骤2：修改karate-config.js #

从karate.config中读取配置参数，而不是全局的karate.properties：

function fn() {
    // 从隔离的config中读取环境值，兼容原有karate.env的用法
    var env = karate.env || karate.config['tests.run.env'];
    karate.log('Value of tests.run.env : ', env);

    var config = {
        hostname : 'abc.com',
        qa_user_username: 'abc@gmail.com',
        qa_user_password: 'sdsfghyj'
    };

    if (env == 'local') {
        // 从config中读取端口，而非全局属性
        var port = karate.config['service.port'];
        config.hostname = '127.0.0.1:' + port
    } else if (env == 'sandbox-lower') {
        config.hostname = 'abclower.com'
    } else if (env == 'uat') {
        config.hostname = 'abcuat.com'
    } else {
        config.hostname = 'abcprod.com'
    }

    return config;
}

其他可选方案 #

如果必须使用系统属性，可以通过**线程局部变量（ThreadLocal）**封装属性设置逻辑，确保每个线程的属性独立，但实现复杂度较高，不如.config()方法简洁可靠。

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