Abstracta JMeter Java DSL：如何让RPSThreadGroup线程优雅结束？

针对测试结束后活跃线程被强制终止、引发异常和请求失败的问题，可通过以下方式解决：

1. 优化RPS调度逻辑，预留线程完成时间 #

当前仅将RPS逐步降到0，但未预留足够时间让正在执行的线程完成任务。修改线程组配置，延长降速时间并保持0 RPS一段时间，确保不再生成新请求的同时，已有线程能顺利完成当前采样：

private static RpsThreadGroup getRpsThreadgroup(String threadGroupName, int maxThreads, int requestsPerSecond, int rampDurationInSeconds, int holdDurationInMinutes) {
    return rpsThreadGroup(threadGroupName)
        .maxThreads(maxThreads)
        .rampToAndHold(
            requestsPerSecond,
            Duration.ofSeconds(rampDurationInSeconds),
            Duration.ofMinutes(holdDurationInMinutes)
        )
        .rampTo(
            0,
            Duration.ofSeconds(10) // 延长降速周期，避免线程突然停止
        )
        .holdFor(Duration.ofSeconds(15)); // 保持0请求量，等待活跃线程完成
}

2. 开启线程组优雅停机配置 #

为RPSThreadGroup开启优雅停机，让JMeter等待线程完成当前任务后再终止，而非强制中断：

private static RpsThreadGroup getRpsThreadgroup(String threadGroupName, int maxThreads, int requestsPerSecond, int rampDurationInSeconds, int holdDurationInMinutes) {
    return rpsThreadGroup(threadGroupName)
        .maxThreads(maxThreads)
        .rampToAndHold(
            requestsPerSecond,
            Duration.ofSeconds(rampDurationInSeconds),
            Duration.ofMinutes(holdDurationInMinutes)
        )
        .rampTo(0, Duration.ofSeconds(10))
        .holdFor(Duration.ofSeconds(15))
        .configure(threadGroup -> {
            threadGroup.setGracefulShutdown(true);
            threadGroup.setGracefulShutdownTimeout(30000); // 设置超时时间（毫秒），超时后仍会终止线程
        });
}

3. 增强采样器参数校验 #

针对Host may not be blank异常，在HttpSampler执行前添加参数校验逻辑，确保请求参数合法后再发送，避免无效请求引发错误：

// 示例：在HttpSampler前添加前置处理器校验Host
httpSampler("your-request-path")
    .preProcessor(jsr223PreProcessor("""
        String host = vars.get("host");
        if (host == null || host.isBlank()) {
            log.error("Host参数为空，终止当前请求");
            ctx.getPreviousResult().setSuccessful(false);
            ctx.getPreviousResult().setResponseMessage("Host may not be blank");
            ctx.setStopThread(true); // 终止当前线程，避免无效执行
        }
    """));

4. 设置全局测试计划停机超时 #

在测试计划层面配置全局停机超时，确保JMeter在结束测试前等待所有线程完成：

testPlan(
    getRpsThreadgroup("test-group", 50, 1, 10, 1),
    // 其他测试组件
).configure(testPlan -> {
    testPlan.setShutdownTimeout(60000); // 全局停机等待时间（毫秒）
});

验证时可观察测试结束后的线程状态，若所有线程正常退出、无失败请求和终止类异常，说明配置生效。

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