JMeter测试HBase

在网上找了关于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");

重新打包后运行正常。

巴特西

JMeter测试HBase

最新文章

热门文章