性能测试工具操作数据库(十一)-Jmeter与Hbase

  1. 云栖社区>
  2. 博客>
  3. 正文

性能测试工具操作数据库(十一)-Jmeter与Hbase

smooth00 2017-07-04 09:12:12 浏览172 评论0

摘要: 由于在网上找不到Jmeter连接Hbase的源文件或是插件,所以本文只是通过Jmeter的BeanShell来调用和调试Hbase的远程连接操作,具体性能测试时,需要怎么应用(比如通过Java Request等方式),等具体开展测试时再进行灵活扩展和调整。

版权声明:本文为博主原创文章,未经博主允许不得转载。欢迎访问我的博客 https://blog.csdn.net/smooth00/article/details/74279856

由于在网上找不到Jmeter连接Hbase的源文件或是插件,所以本文只是通过Jmeter的BeanShell来调用和调试Hbase的远程连接操作,具体性能测试时,需要怎么应用(比如通过Java Request等方式),等具体开展测试时再进行灵活扩展和调整。

关键的是要引用正确的Hbase jar包(还要保证版本的兼容,Hbase1.0开始就要求JDK1.7及以上,而且Jmeter引用的Hbase Jar包最好是与服务端的Hbase一致,否则也会出现兼容性问题)。以下的测试代码都是在Jmeter3.1+JDK1.8环境下进行的。

1、下载Hbase Jar包,可以到官网下载整个包,获取其中的lib jar包:http://archive.apache.org/dist/hbase/,也可以下载我为本次测试所整理好的jar包(性能测试工具所引用的hbase依赖包

2、在Jmeter的测试计划里把所有Jar包添加到classpath中(我不习惯把Jar包直接扔到Jmeter目录的lib\ext下,不方便区分管理)


3、将hadoop-common-2.2.0-bin-master文件目录放到Jmeter的bin目录下,主要是Windows下调用Hadoop组件,如果没有winutils.exe会报错(可以到网上下载这个包,上面提供的性能测试工具所引用的hbase依赖包里也有)。

4、在Jmeter中建立线程组,和建一个BeanShell Sampler,直接将以下代码复制上去进行调试(注意要配好zookeeper连接地址和端口)

import java.io.IOException;               
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.MasterNotRunningException;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.ZooKeeperConnectionException;
import java.io.File;

public class HbaseTest
{ 
     String tableName="student";
     Configuration configuration=null;	
     public void SetConfiguration() {    
   		configuration = HBaseConfiguration.create();       
   		//config.set("hbase.zookeeper.quorum", "hellotest");//单机            
   		configuration.set("hbase.zookeeper.quorum", "agent01.org.cn,agent02.org.cn,master.org.cn");
   		//包括三个节点的zookeeper地址(也可以是Host IP),第一个是主节点
   		configuration.set("hbase.zookeeper.property.clientPort", "2181");// zookeeper端口  
   		configuration.set("hbase.regionserver.port", "16020");
   		configuration.set("zookeeper.znode.parent", "/hbase-unsecure");
   		configuration.set("hbase.rootdir", "hdfs://master.org.cn:8020/apps/hbase/data");
   		//connection = ConnectionFactory.createConnection(config); 
     }

     /**
  * create a new Table
  * @param configuration Configuration
  * @param tableName String,the new Table's name
  * */
 public static void createTable(Configuration configuration,String tableName){
  HBaseAdmin admin;
  	try {
   		admin = new HBaseAdmin(configuration);
   		if(admin.tableExists(tableName)){
    		admin.disableTable(tableName);
    		admin.deleteTable(tableName);
    		System.out.println(tableName+"is exist ,delete ......");
    		log.info(tableName+"is exist ,delete ......");
   		}
 
   		HTableDescriptor tableDescriptor=new HTableDescriptor(TableName.valueOf(tableName));
   		tableDescriptor.addFamily(new HColumnDescriptor("info"));
   		tableDescriptor.addFamily(new HColumnDescriptor("address"));
   		admin.createTable(tableDescriptor);
   		System.out.println("end create table");
   		log.info("end create table");
  	} catch (MasterNotRunningException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (ZooKeeperConnectionException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (IOException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	}
  
 }
 
 /**
  * Delete the existing table
  * @param configuration Configuration
  * @param tableName String,Table's name
  * */
 public static void dropTable(Configuration configuration,String tableName){
  HBaseAdmin admin;
  	try {
   		admin = new HBaseAdmin(configuration);
   		if(admin.tableExists(tableName)){
    		admin.disableTable(tableName);
    		admin.deleteTable(tableName);
    		System.out.println(tableName+"delete success!");
    		log.info(tableName+"delete success!");
   		}else{
    		System.out.println(tableName+"Table does not exist!");
    		log.info(tableName+"Table does not exist!");
   		}
  	} catch (MasterNotRunningException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (ZooKeeperConnectionException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (IOException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	}
 }
 
 /**
  * insert a data
  * @param configuration Configuration
  * @param tableName String,Table's name
  * */
 public static void addData(Configuration configuration,String tableName){
  HBaseAdmin admin;
  	try {
   		admin = new HBaseAdmin(configuration);
   		if(admin.tableExists(tableName)){
    		HTable table=new HTable(configuration, tableName);
    		Put put=new Put(Bytes.toBytes("zhangsan"));
    		put.add(Bytes.toBytes("info"), Bytes.toBytes("age"), Bytes.toBytes("28"));
    		table.put(put);
    		System.out.println("add success!");
    		log.info("add success!");
   		}else{
    		System.out.println(tableName+"Table does not exist!");
    		log.info(tableName+"Table does not exist!");
   		}
  	} catch (MasterNotRunningException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (ZooKeeperConnectionException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (IOException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	}
 }
 
 /**
  * Delete a data
  * @param configuration Configuration
  * @param tableName String,Table's name
  * */
 public static void deleteDate(Configuration configuration,String tableName){
  HBaseAdmin admin;
  	try {
   		admin=new HBaseAdmin(configuration);
   		if(admin.tableExists(tableName)){
    		HTable table=new HTable(configuration, tableName);
    		Delete delete=new Delete(Bytes.toBytes("zhangsan"));
    		table.delete(delete);
    		System.out.println("delete success!");
    		log.info("delete success!");
   		}else{
    		System.out.println("Table does not exist!");
   		}
  	} catch (MasterNotRunningException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (ZooKeeperConnectionException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	} catch (IOException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	}
 	}
 

 /**
  * get a data
  * @param configuration Configuration
  * @param tableName String,Table's name
  * */
 public static void getData(Configuration configuration,String tableName){
  HTable table;
  	try {
   		table = new HTable(configuration, tableName);
   		Get get=new Get(Bytes.toBytes("zhangsan"));
   		Result result=table.get(get);
 
   		for(Cell cell:result.rawCells()){
    		System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
    		System.out.println("Timetamp:"+cell.getTimestamp()+" ");
    		System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
    		System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
    		System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");
    
    		log.info("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
    		log.info("Timetamp:"+cell.getTimestamp()+" ");
    		log.info("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
    		log.info("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
    		log.info("value:"+new String(CellUtil.cloneValue(cell))+" ");
   		}
  	} catch (IOException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	}
 }
 
 /**
  * insert all data
  * @param configuration Configuration
  * @param tableName String,Table's name
  * */
 public static void getAllData(Configuration configuration,String tableName){
  HTable table;
  	try {
   		table=new HTable(configuration, tableName);
   		Scan scan=new Scan();
   		ResultScanner results=table.getScanner(scan);
   		for (Result result = results.next(); result != null; result = results.next()) {
   		// print out the row we found and the columns we were looking for
    		for(Cell cell:result.rawCells()){   
     			System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
     			System.out.println("Timetamp:"+cell.getTimestamp()+" ");
     			System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
     			System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
     			System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");

     			log.info("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
     			log.info("Timetamp:"+cell.getTimestamp()+" ");
     			log.info("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
     			log.info("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
     			log.info("value:"+new String(CellUtil.cloneValue(cell))+" ");
    		}
   		}
  	} catch (IOException e) {
   		// TODO Auto-generated catch block
   		e.printStackTrace();
  	}  
 }
 public boolean runActions(){
	 	File directory = new File(".");
	 	System.setProperty("hadoop.home.dir", directory.getCanonicalPath()+"\\hadoop-common-2.2.0-bin-master");
  		 SetConfiguration();
	      createTable(configuration, tableName);
	      addData(configuration, tableName);
	      getData(configuration, tableName);
	      getAllData(configuration, tableName);
	      deleteDate(configuration, tableName);
	      dropTable(configuration, tableName);
	      return true;
	}
}

boolean runFlag=new HbaseTest().runActions();
log.info("runFlag:"+runFlag);
以上代码中,加了log.info,用来调试代码以验证代码是否执行成功

5、在线程组中加上查看结果树、Summary Report、Debug Sampler,以全运行时查看成功情况。通过点击Jmeter右上方的三角!号(如果代码报错也能看能看到提示),可以查看代码运行日志(这是调试Java代码比较方便的工具),运行结果如下:

6、可以将以上的测试代码保存成java(或者可以打成jar包再用),直接通过jmerter进行引用和测试

7、相对来讲,Jmeter不适合调试Java代码,因为报一段长长的错误日志后,可能报错的最后一句话才能看出错误所在,所以以上代码也可以等在Java开发工具中调测通过后,再移植过来,然后再进一步调试和修改一些兼容性的错误。

【云栖快讯】一站式开发者服务,海量学习资源免费学  详情请点击

网友评论