JMeter运行时基于日志动态增减线程数的实现问题求助

• 核心需求：根据日志中每秒请求数（RPS）动态调整JMeter线程数——RPS高则增加线程数，RPS低则减少线程数
• 两次尝试及遇到的问题：

尝试1：Schedule Feedback Function + Throughput Shaping Timer + Concurrent Thread Group #

• 问题点：Throughput Shaping Timer要求预先设置startRPS和endRPS，但日志中包含数百万动态变化的RPS值，静态配置完全不现实
• 尝试解决：用前置处理器结合用户定义变量动态更新startRPS和endRPS，但该定时器仅读取初始值，运行过程中不会迭代更新，导致全程只用一组RPS值执行测试
• 所用代码：

if(props.get("index") == null)
    props.put("index", 0);

int[] lst =  {15,20,31,21,99,50};

var i = vars.get("index");

if(i < lst.length)
{
    if(i == 0)
    {
        props.put("startRPS", "1");
        props.put("endRPS", lst[i]);
    }
    else
    {
        props.put("startRPS", lst[i-1]);
        props.put("endRPS", lst[i]);
    }
}

log.info("**** START: " + props.get("startRPS"));
log.info("**** END: " + props.get("endRPS"));

i = i + 1;
props.put("index", i);

尝试2：JSR223 Sampler直接修改线程数 #

• 问题点：代码中计算出目标线程数后，线程组的numberOfThreads始终保持默认值1，修改操作未生效
• 所用代码：

int num_of_reqs = Integer.parseInt(parsedString[1]);
int threadCount = num_of_reqs / 5;

log.info( "Num of reqs" + num_of_reqs +  "Threads: " + threadCount);

ctx.getThreadGroup().setNumThreads(threadCount);
props.put("threads", threadCount);

log.info("&&&&" + ctx.getThreadGroup ().getNumberOfThreads());

针对尝试2的修复（直接动态调整Concurrent Thread Group线程数） #

Concurrent Thread Group的线程数不能通过普通setNumThreads()方法修改，需要调用其专属的setConcurrentThreads()方法，同时要确保线程组实例是org.apache.jmeter.control.gui.ConcurrentThreadGroup类型。修改后的JSR223 Sampler代码：

// 假设已从日志解析出每秒请求数num_of_reqs
int num_of_reqs = Integer.parseInt(parsedString[1]);
int threadCount = num_of_reqs / 5;
// 确保线程数不低于1，避免无线程执行
threadCount = Math.max(threadCount, 1);

log.info("当前每秒请求数：" + num_of_reqs + "，目标线程数：" + threadCount);

// 获取Concurrent Thread Group实例
def threadGroup = ctx.getThreadGroup()
if (threadGroup instanceof org.apache.jmeter.control.gui.ConcurrentThreadGroup) {
    threadGroup.setConcurrentThreads(threadCount);
    // 同步更新线程组属性，确保修改生效
    threadGroup.setProperty(org.apache.jmeter.control.gui.ConcurrentThreadGroup.CONCURRENT_THREADS, threadCount);
    log.info("线程数已更新为：" + threadGroup.getConcurrentThreads());
} else {
    log.error("当前线程组不是Concurrent Thread Group，无法动态调整线程数");
}

实时读取日志计算RPS的方法 #

可以在JSR223 Sampler中使用Apache Commons IO的Tailer类实时监听日志文件，或定期读取日志片段计算每秒请求数：

import org.apache.commons.io.input.Tailer
import org.apache.commons.io.input.TailerListenerAdapter
import java.util.concurrent.atomic.AtomicInteger

// 日志文件路径，替换为实际路径
def logFilePath = "/path/to/your/access.log"
// 原子类存储最近1秒的请求数，避免多线程计数冲突
def requestCount = new AtomicInteger(0)

// 自定义日志监听类，处理日志行并统计请求数
class LogListener extends TailerListenerAdapter {
    private long lastCheckTime = System.currentTimeMillis()
    private AtomicInteger count

    LogListener(AtomicInteger count) {
        this.count = count
    }

    @Override
    void handle(String line) {
        long currentTime = System.currentTimeMillis()
        // 每1秒重置一次计数
        if (currentTime - lastCheckTime >= 1000) {
            count.set(0)
            lastCheckTime = currentTime
        }
        // 根据实际日志格式判断请求行，这里假设含GET/POST的行是请求
        if (line.contains("GET") || line.contains("POST")) {
            count.incrementAndGet()
        }
    }
}

// 仅在测试启动时初始化一次日志监听
if (!props.get("logTailer")) {
    def listener = new LogListener(requestCount)
    def tailer = Tailer.create(new File(logFilePath), listener, 1000)
    props.put("logTailer", tailer)
}

// 获取当前1秒内的请求数
int num_of_reqs = requestCount.get()
// 计算目标线程数并执行调整逻辑（同上一段线程数修改代码）
int threadCount = num_of_reqs / 5
threadCount = Math.max(threadCount, 1)

// 线程数调整逻辑
def threadGroup = ctx.getThreadGroup()
if (threadGroup instanceof org.apache.jmeter.control.gui.ConcurrentThreadGroup) {
    threadGroup.setConcurrentThreads(threadCount);
    threadGroup.setProperty(org.apache.jmeter.control.gui.ConcurrentThreadGroup.CONCURRENT_THREADS, threadCount);
    log.info("线程数已更新为：" + threadGroup.getConcurrentThreads());
}

注意事项 #

• 确保JMeter的lib目录下有commons-io.jar（JMeter通常自带，若缺失需手动添加）
• 线程数调整频率建议控制在1-5秒一次，过于频繁会导致JMeter性能波动
• 建议设置线程数上下限，防止线程数过高压垮被测系统或过低无法匹配请求量

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