JMeter测试HBase

2023-11-10

在网上找了关于jmeter连接hbase的方式,主要分为两种:通过导入jar包连接(Java Request)和通过BeanShell远程连接,由于刚接触jmeter没多久,对BeanShell还不熟,所以打算通过eclipse用Java编写连接hbase的程序并打包成jar包,导入到jmeter的方式连接hbase。

HBase本地远程连接HBase是测试成功的,一开始采用直接打包成runnable jar的方式导入到jmeter,但是创建Java Request之后,页面查不到创建好的接口,后来网上查询到,需要专门写一个程序继承“AbstractJavaSamplerClient”类,jmeter才能识别。

1、创建Java工程

新创建一个Java工程或者在需要调用的工程上创建个类,将ext目录下ApacheJMeter_core.jar、ApacheJMeter_java.jar引入项目(若提示无法找到org/apache/jorphan/logging/LoggingManager接口,需要同时引入lib目录下的jorphan.jar包);继承AbstractJavaSamplerClient类,并重写以下方法:

public Arguments getDefaultParameters();设置可用参数及的默认值;

public void setupTest(JavaSamplerContext arg0):每个线程测试前执行一次,做一些初始化工作;

public SampleResult runTest(JavaSamplerContext arg0):开始测试,从arg0参数可以获得参数值;

public void teardownTest(JavaSamplerContext arg0):测试结束时调用;

具体接口如下:

package main.jmeter;

import java.io.IOException;

import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Result;
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;

import main.hbase.HBaseDAO;

public class Create extends AbstractJavaSamplerClient {
    private String tableName = null;//表名
    private String rowkey = null;    //rowkey值
    private SampleResult results;
    
    /**
     * 设置传入参数
     * 可以设置多个,已设置的参数会显示到Jmeter参数列表中
     */
    @Override
    public Arguments getDefaultParameters() {
        Arguments params = new Arguments();
        params.addArgument("tableName","");
        params.addArgument("rowkey","");
        return params;
    }
    
    /**
     * 初始化方法,初始化性能测试时的每个线程
     * 实际运行时每个线程仅执行一次,在测试方法运行前执行,类似于LoadRunner中的init方法
     */
    @Override
    public void setupTest(JavaSamplerContext context) {
        results = new SampleResult();
        tableName = context.getParameter("tableName");//注意:此处是接收jmeter的参数传入,需要用引号括起来,否则读取不到值
        if(tableName != null && tableName.length() > 0){
            results.setSamplerData(tableName);
        }
        rowkey = context.getParameter("rowkey");
        if(rowkey != null && rowkey.length() > 0){
            results.setSamplerData(rowkey);
        }
    };
    
    /**
     * 性能测试时的线程运行体
     * 测试执行的循环体,根据线程数和循环次数的不同可执行多次,类似于Loadrunner中的Action方法
     */
    @SuppressWarnings("deprecation")
    @Override
    public SampleResult runTest(JavaSamplerContext arg0) {
        boolean success = false;
        results.sampleStart();
        HBaseDAO hbase = new HBaseDAO();
        HTable table = hbase.getHTable(tableName);
        // getRow 根据rowkey获取所有版本记录
        Result r;
        try {
            r = hbase.getRowVersions(table, rowkey,1);
            KeyValue[] kv = r.raw();
            for(KeyValue value:kv){
                results.setDataEncoding("UTF-8");
                results.setResponseData("运行结果 :  value = " + new String(value.getValue()));
                success = true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                table.close();
                results.sampleEnd();
                results.setSuccessful(success);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return results;
    }
    
     /**
      * 测试结束方法,结束测试中的每个线程
      * 实际运行时,每个线程仅执行一次,在测试方法运行结束后执行,类似于Loadrunner中的End方法
      */
    @Override
    public void teardownTest(JavaSamplerContext arg0) {
        
    }

}

2、打包并导入

 将编辑好的Java项目打成jar包:Export->JAR file->finish

将导出的jar包放入\lib\ext目录下

3、运行JMeter

打开jmeter,点击测试计划将HBase依赖的所有jar包加入环境(建议先拷贝至ext目录下),添加线程组、Java Request

在类名称中找到自己创建的类,参数列表会自动显示类中自定义的参数,填入要测试的值(可添加CSV配置元件,通过参数方式传入);

添加察看结果树、聚合报告,看是否能正常运行,若有异常,点击右上角三角符号查看原因

若遇到java.io.IOException: Could not locate executable null\bin\winutils.exe in the Hadoop binaries.异常,是由于找不到hadoop.home.dir的路径;

我本地运行连接hbase是正常的,但是导入到JMeter之后报个这个异常,我们集群用的是Hadoop 2.6.0,所以从网上下载了个Apache Hadoop Common 2.6.0:https://github.com/amihalik/hadoop-common-2.6.0-bin

解压到本地,然后在HBase的初始化程序中添加(也可配置环境变量)

System.setProperty("hadoop.home.dir", "D:\\Hadoop\\hadoop-common-2.6.0");

重新打包后运行正常。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

JMeter测试HBase 的相关文章

随机推荐