dubbo的jmeter压测时jar包的热加载/动态加载

在做dubbo的jmeter压测时,需要把jar包放入jmeter的lib/ext目录下,但是jmeter启动的时候会自动加载这个目录lib目录及lib/ext目录,这样启动后放入这些目录下的jar包就不会加载了。

jmeter的master--slave/client模式下,作为jmeter client,jmeter-server服务一直是启动的,当新的jar包放入client后,无法读取,因此需要client的jmeter动态加载这些新放入的jar包。

解决办法参考:http://blog.csdn.net/kekadm/article/details/51783240

继上篇文章《Jmeter+H2Database动态部署JAR包到代理端》实现了测试业务jar包的动态部署后,再不重启代理端Jmeter的情况下,jar的变化内容仍无法自动加载到Jmeter内存,所以还是不能实现一次启动,动态更新的目的。

因为,Jmeter在启动的时候会自动加载lib目录下的jar包,如果不重启,目录下更新的jar包也不能加载到内存。所以,要实现类的动态加载,必须在Jmeter测试类中实现业务类的重载。

即在Jmeter测试类中的setupTest()方法中要自定义代码实现业务类的加载。

此处以一个简单例子说明实现过程:

编写要被测业务类:TransDemo.java

package perftest.jmeter.trans;

public class TransDemo {

public String action(){

Stringstr = "action1st.";

System.out.println(str);

return str;

}

public voidinit() {

System.out.println("testingstart....");

}

public voidend() {

System.out.println("testingover!!!!");

}

}

将其导出为perftest-trans.jar,将这个包放到jmeter/lib目录以外的地方。如:c:/perftest-trans.jar (不能放在Jmeter/lib目录下)。

编写Jmeter测试类:TransDemoActions.java

package perftest.jemter.action;

import java.io.File;

import java.lang.reflect.InvocationTargetException;

import java.lang.reflect.Method;

import java.net.URL;

import java.net.URLClassLoader;

import org.apache.jmeter.config.Arguments;

import org.apache.jmeter.protocol.java.sampler.AbstractJavaSamplerClient;

import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;

import org.apache.jmeter.samplers.SampleResult;

public classTransDemoActions extends AbstractJavaSamplerClient{

SampleResultresult= null;

public Class<?>trans = null;

Arguments    params= null;

Method  methodInit= null;

Method  methodAction= null;

Method  methodEnd= null;

MyClassLoader  classLoader= null;

Object   newTrans= null;

/**

* 自定义类加载方法

@param jarpath

@param classpath

*/

public void loadClass(String[] jarpath,Stringclasspath){

URL[]  urls= new  URL[] {};

classLoader = new MyClassLoader(urls,null);

try {

for(String  jar:jarpath){

classLoader.addJar(new File(jar.trim()).toURI().toURL());

System.out.println("load jar file : "+jar.trim());

}

trans = classLoader.loadClass(classpath);

System.out.println("load class file : "+classpath);

methodInit = trans.getDeclaredMethod("init");

methodAction = trans.getDeclaredMethod("action");

methodEnd = trans.getDeclaredMethod("end");

boolean  accessible = methodInit.isAccessible();

if(accessible ==false){

methodInit.setAccessible(true);

}

newTrans = trans.newInstance();

catch (Exceptione) {

e.printStackTrace();

}

}

/**

* 自定义jmeter外部参数

*/

public Arguments  getDefaultParameters() {

Arguments  params= new   Arguments();

params.addArgument("TRANS_JARPATH","c:/perftest-trans.jar");

params.addArgument("TRANS_CLASSPATH","perftest.jmeter.trans.TransDemo");

returnparams;

}

public void   setupTest(JavaSamplerContext arg0) {

try {

loadClass(arg0.getParameter("TRANS_JARPATH").split(","),arg0.getParameter("TRANS_CLASSPATH"));

//通过反射调用TestDemo的init()方法,下同

methodInit.invoke(newTrans);

}catch(IllegalAccessException   e) {

e.printStackTrace();

}catch(IllegalArgumentException   e) {

e.printStackTrace();

}catch(InvocationTargetException  e) {

e.printStackTrace();

}

}

@Override

public SampleResult    runTest(JavaSamplerContextarg0) {

try {

methodAction.invoke(newTrans);

}catch(IllegalAccessException  e) {

e.printStackTrace();

}catch(IllegalArgumentException   e) {

e.printStackTrace();

}catch(InvocationTargetException   e) {

e.printStackTrace();

}

returnresult;

}

public void   teardownTest(JavaSamplerContext arg0) {

try {

methodEnd.invoke(newTrans);

}catch(IllegalAccessException   e) {

e.printStackTrace();

}catch(IllegalArgumentException   e) {

e.printStackTrace();

}catch(InvocationTargetException    e) {

e.printStackTrace();

}catch (Exceptione) {

e.printStackTrace();

}

}

/**

* 自定义内部类实现动态加载class

@author

*

*/

static class MyClassLoader extends URLClassLoader {

public MyClassLoader(URL[]urls) {

super(urls);

}

public MyClassLoader(URL[]urls, ClassLoader parent) {

super(urls,parent);

}

public void addJar(URL url) {

this.addURL(url);

}

}

}

将其导出为perftest-actons.jar,并将它放入<jmeterPath>/lib/ext下,在Jmeter启动时可以自动发现这个测试类: perftest.jemter.action.TestDemoActons 。

启动Jmeter,建立测试计划和添加线程组及“Java请求”

线程组大小设置为1,线程循环次数设置2:即一个虚拟用户进行2次迭代。

运行测试

运行测试可以看到System.out.println的输出结果:

修改被测业务类TransDemo的action()方法

public String action(){

//此处修改打印输出字符

String   str = "actionsecond.";

System.out.println(str);

return str;

}

重新将TransDemo.class打包为perftest-trans.jar,并覆盖前面的c:/perftest-trans.jar

重新运行测试

在不关闭和重启Jmeter的情况下,再次执行测试,可以看到输出信息已经改变为“action seconde.”:

小结:

所以要实现类的动态加载,必须在Jmeter测试类AbstractJavaSamplerClient(java请求)中使用URLClassLoader实现被测业务类的重新加载,并使用invoke()方法调用业务方法。

自此,通过《Jmeter+H2Database动态部署JAR包到代理端》及本篇可以为分布式测试中的众多代理端实现被测业务(jar)包的实时更新及业务测试类(class)的热加载。

再也不用重启100+台Jmeter代理端而烦恼了。

原文地址:https://www.cnblogs.com/shengulong/p/8419044.html

时间: 2024-11-08 15:03:03

dubbo的jmeter压测时jar包的热加载/动态加载的相关文章

Dubbo-使用Maven构建Dubbo服务的可执行jar包

一.为什么要构建Dubbo服务的可执行jar包? 1.1 Dubbo服务运行方式比较 ?使用Servlet容器运行(Tomcat.Jetty等)  ---不可取 --缺点:增加复杂性(多了容器的端口) 浪费内存资源,Servlet运行要占用一定的内存 ?自建main()方法来运行Spring容器  ---不可取 (本地调试可用) --缺点:Dubbo本身提供的高级特性没用上  自己编写启动类可能会有缺陷 ?使用Dubbo框架提供main()方法来运行Spring容器  ---建议使用 --优点:

跟我学习dubbo-使用Maven构建Dubbo服务的可执行jar包(4)

Dubbo服务的运行方式: 1.使用Servlet容器运行(Tomcat.Jetty等)----不可取 缺点:增加复杂性(端口.管理) 浪费资源(内存) 官方:服务容器是一个standalone的启动程序,因为后台服务不需要Tomcat或JBoss等Web容器的功能,如果硬要用Web容器去加载服务提供方,增加复杂性,也浪费资源. 2.自建Main方法类来运行(Spring容器) ----不建议(本地调试可用) 缺点: Dobbo本身提供的高级特性没用上 自已编写启动类可能会有缺陷 官方:服务容器

linux 解压修改jar包

打包以及修改jar包 cd genesys_data_etl mvn clean package -Poffline -Dmaven.test.skip=true 日志如下: [INFO] --- maven-jar-plugin:2.6:jar (default-jar) @ genesys_data_etl --- [INFO] Building jar: /Users/xx/IdeaProjects/genesys_data_etl/target/genesys_data_etl-0.0.

创建一个jmeter的外部jar包

说明 /** * Description:本包生成的顺序身份证.姓名和手机号,前30万条基本不会重复. * Created by Jim on 2017/9/6. * orderName() 顺序生成一个姓名,共计322,452个 * orderMobile() 顺序生成一个手机号,共39个号段,每9999个随机号后切换至新号段,即前39*9999(389,961)个号码重复机率很小. * orderIDNumber() 顺序生成一个身份证号,前365*1000(365,000)个绝不会重复,每

python解压分析jar包

import osimport shutilimport zipfile count = 1def getSumDir(): sumfilelist = os.listdir(os.getcwd()) for dir in sumfilelist: if ".idea" not in dir: classify(dir) def getlibDir(): sumfilelist = os.listdir(os.getcwd()) for dir in sumfilelist: if &

在linux上用jmeter压测时出现很多异常java.net.NoRouteToHostException: Cannot assign requested address.

今天压力测试时, 刚开始出现了很多异常, 都是 java.net.NoRouteToHostException: Cannot assign requested address. 经网上查资料, 是由于linux分配的客户端连接端口用尽, 无法建立socket连接所致,虽然socket正常关闭,但是端口不是立即释放, 而是处于TIME_WAIT状态, 默认等待60s后才释放. 查看linux支持的客户端连接端口范围, 也就是28232个端口: cat /proc/sys/net/ipv4/ip_

windows 自动移动maven jar包到jmeter 文件夹下面

jmeter 自动移动maven jar包到jmeter 文件夹下面 bat 文件 rem 本文件放在jmeter 脚本maven项目根目录下面,和pom.xml在同一个文件夹下面 rem 预置条件,把官网下载的apache-jmeter-3.2.zip 放在如下filePath 并解压到当前文件夹 set filePath=D:\work\jmeterPerformanceTest rem rd /s /q %filePath%\apache-jmeter-3.2\ rem echo "sta

如何在制作jar包时引用第三方jar包

我用的是Eclipse打包,但在CMD窗口执行的时候报“ActiveMQ.jar中没有主清单属性”错误. 在网上搜了下,这个与MANIFEST.MF文件有关,该文件没有定义MAIN方法所在类的路径,利用好压打开jar包,果然如此.里面只有一行 Manifest-Version: 1.0 需添加Main-Class.在本例中,添加如下: Main-Class: com.luoluo.TestUse.activemq.ActiveMQStateMain 上面,有几点需要注意: 1. Main-Cla

Eclipse下导出java程序可执行的jar包图片无法显示问题的一种解决方法

说明:在eclipse中运行java程序的时候一切正常,可是当把jar包导出的时候却发现图片没法显示,这估计是java程序的各种配置和路径问题所导致,后来找到一种解决方法,供遇到这方面问题的学习java程序的鞋同参考: Java项目下的目录结构如下: 其中class类放在包:package accpedu; (即实际是在如上bin/accpedu文件夹下面) 通过下面的方法来引用图片时,在eclipse里面执行是可以正常显示图片的: ImageIcon image1 = new ImageIco