Java 多线程编程在 JMeter 中应用

news2024/11/26 2:48:39

前言：

首先新建一个简单的线程组和一个简单的请求：

添加 JSR223 预处理程序（后置处理程序需要下一次次请求）

可以通过复制私有变量来控制所有线程获取公共变量时的线程安全问题。

日志输出：

前言：

Java多线程编程在JMeter中的应用可以帮助模拟并发用户对系统进行性能测试。JMeter本身就是基于Java开发的，因此可以利用Java多线程编程的能力来实现并发请求。

在最近的工作中，遇到一个需求：在JMeter中生成一个全局唯一变量，获取一次自增 x（这个不确定，可能根据响应信息）。这不是我的需求，只是从同事那边听说到的，周末没事儿想起来这个事儿。按照我的方案肯定是用Java或者Groovy去实现这个需求，肯定不会选JMeter。

如果非要给这个需求加一个jmeter的设定，我依然会选择用脚本语言实现，这次我的基本思路两个：1、还是新建一个全局的线程安全对象，然后通过自带的线程安全方法实现自增需求；2、处理全局变量时，通过Java 锁实现单线程操作自增，然后实现多线程情况下的线程安全。

事实证明还是第二种方案比较好，因为我暂时还没找到如果通过脚本去JMeter里面新建一个全局线程安全类对象的方法。所以我是新建一个全局变量，赋予一个初始值，然后在每个线程脚本里面去处理这个全局变量，步骤如下：1、获取对象锁（这里指的是存放所有全局变量的对象props）；2、获取参数值，自增，重新赋值；3、释放对象锁，完成其他逻辑处理。

首先新建一个简单的线程组和一个简单的请求：

添加 JSR223 预处理程序（后置处理程序需要下一次次请求）

脚本内容：

props.put("MY",test()+"")
//log.info(props.get("MY")+"")
def test() {
    synchronized (props) {
//        Thread.sleep(1000)
        int i = props.get("MY") as Integer
        log.info(i+"")
                i + 1
    }
}

这里有一个小知识点：JMeter中的对象props在JVM里面是有缓存的，经过我多次实验，只要JMeter不关闭，这个缓存一只会在。

可以通过复制私有变量来控制所有线程获取公共变量时的线程安全问题。

所以要在程序运行前设置一个初始值，如下：

脚本内容如下：

//int i = props.get("MY") == null ? 0 :  props.get("MY") as Integer
props.put("MY","999")

日志输出：

下面是未加锁的情况：

2020-07-19 19:29:50,187 INFO o.a.j.t.JMeterThread: Thread started: 线程组 1-3
2020-07-19 19:29:50,191 INFO o.a.j.t.JMeterThread: Thread started: 线程组 1-4
2020-07-19 19:29:50,192 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2020-07-19 19:29:50,192 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2020-07-19 19:29:50,199 INFO o.a.j.t.JMeterThread: Thread started: 线程组 1-5
2020-07-19 19:29:50,231 INFO o.a.j.m.J.JSR223 变量: 999
2020-07-19 19:29:50,232 INFO o.a.j.m.J.JSR223 变量: 999
2020-07-19 19:29:50,233 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-5
2020-07-19 19:29:50,233 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-5
2020-07-19 19:29:50,235 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-4
2020-07-19 19:29:50,235 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-4
2020-07-19 19:29:50,239 INFO o.a.j.m.J.JSR223 变量: 1000
2020-07-19 19:29:50,240 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-1
2020-07-19 19:29:50,240 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-1
2020-07-19 19:29:50,240 INFO o.a.j.m.J.JSR223 变量: 1000
2020-07-19 19:29:50,241 INFO o.a.j.m.J.JSR223 变量: 1001
2020-07-19 19:29:50,241 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-2
2020-07-19 19:29:50,241 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-2
2020-07-19 19:29:50,241 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-3
2020-07-19 19:29:50,241 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-3

下面是加锁的情况：

2020-07-19 19:28:40,988 INFO o.a.j.t.JMeterThread: Thread started: 线程组 1-5
2020-07-19 19:28:41,015 INFO o.a.j.m.J.JSR223 变量: 999
2020-07-19 19:28:41,017 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-1
2020-07-19 19:28:41,017 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-1
2020-07-19 19:28:41,031 INFO o.a.j.m.J.JSR223 变量: 1000
2020-07-19 19:28:41,041 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-2
2020-07-19 19:28:41,043 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-2
2020-07-19 19:28:41,044 INFO o.a.j.m.J.JSR223 变量: 1001
2020-07-19 19:28:41,046 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-5
2020-07-19 19:28:41,046 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-5
2020-07-19 19:28:41,046 INFO o.a.j.m.J.JSR223 变量: 1002
2020-07-19 19:28:41,048 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-4
2020-07-19 19:28:41,048 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-4
2020-07-19 19:28:41,049 INFO o.a.j.m.J.JSR223 变量: 1003
2020-07-19 19:28:41,052 INFO o.a.j.t.JMeterThread: Thread is done: 线程组 1-3
2020-07-19 19:28:41,052 INFO o.a.j.t.JMeterThread: Thread finished: 线程组 1-3