JMeter跨线程组共享ConcurrentHashMap实例问题求助

问题根源 #

JMeter的props本质是Java的Properties类实例，仅支持存储字符串类型的键值对。当你尝试存入ConcurrentHashMap对象时，实际是将对象的toString()结果（字符串形式）存入，而非对象本身。后续线程组读取到的只是这个字符串，无法操作原Map实例，自然出现数据不共享的情况。采样线程组每次看到大小为1，是因为每次都新建了Map实例覆盖props里的字符串，而非操作同一个实例。

正确实现方案 #

跨线程组共享非字符串对象，需使用JMeter的全局上下文或静态单例，以下两种方式均可靠：

方案1：利用JMeter全局上下文存储对象 #

在Setup线程组的JSR223元件（推荐Groovy语言）中初始化：

import java.util.concurrent.ConcurrentHashMap

// 将Map实例存入JMeter全局变量
def sharedMap = new ConcurrentHashMap()
ctx.getJMeterContext().getVariables().putObject("sharedMap", sharedMap)

在Sampling线程组的JSR223元件中写入数据：

// 从全局上下文获取Map实例
def sharedMap = ctx.getJMeterContext().getVariables().getObject("sharedMap")
sharedMap.put("thread-${__threadNum}", "data-${__threadNum}")
// 可选：打印日志验证
log.info("Current map size: " + sharedMap.size())

在Cleanup线程组的JSR223元件中读取数据：

def sharedMap = ctx.getJMeterContext().getVariables().getObject("sharedMap")
log.info("Final map size: " + sharedMap.size())
// 遍历输出所有数据
sharedMap.each { key, value -> log.info("Key: ${key}, Value: ${value}") }

方案2：自定义静态单例类 #

在Setup线程组的JSR223元件中定义单例类：

import java.util.concurrent.ConcurrentHashMap

class SharedMapHolder {
    private static final ConcurrentHashMap INSTANCE = new ConcurrentHashMap()
    
    static ConcurrentHashMap getInstance() {
        return INSTANCE
    }
}

在Sampling和Cleanup线程组的JSR223元件中直接调用：

def sharedMap = SharedMapHolder.getInstance()
// 执行写入/读取操作，同方案1

关键注意事项 #

• 必须使用JSR223元件（优先选Groovy），BeanShell对对象的序列化/反序列化支持差，易出问题。
• 确保Setup线程组在所有采样线程组前执行：若测试计划中线程组是并行执行，需勾选测试计划的Run thread groups consecutively选项，保证初始化完成后再执行采样。
• 并发场景下必须用线程安全集合（如ConcurrentHashMap），避免多线程操作导致的数据不一致。

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