jmeter操作redis、mongo、mysql

一、 jmeter连接Redis

1.0 概述

jmeter提供一个插件Redis Data Set，但是此插件的功能仅类似于一个CSV Data Set Config。相当于一个前置配置，用于为每个线程、或者每一次循环提供一个参数化的值，这个值从redis的list或者set中读取。
上述插件并不适用于在测试请求过程动态提取redis中的值并使用（需通过编写beanshell脚本才能实现）。

1.1 Redis Data Set插件的使用

1.1.1 下载插件

下载Plugins Manager JAR文件：https://jmeter-plugins.org/get/

将文件复制到JMeter的lib/ext目录下

启动JMeter后可看到刚才添加的插件管理器

通过插件管理器添加redis插件

1.1.2 配置Redis Data Set

1.1.3 验证效果

已知在redis里，键books的值为["chinese","english","math"]，下面运行jmeter，设置3个线程，通过简单打印出变量book的值来验证是否可读取到保存在redis中的数据

1.2 通过BeanShell脚本实现全面操作redis

java主要依赖于jedis操作redis，由于上述安装redis插件的过程中，jmeter已经将jedis一并安装好了，无需再添加额外的jar包。

1.2.1 定义连接信息

1.2.2. BeanShell脚本通过jedis操作redis

代码如下：

import redis.clients.jedis.Jedis;

import org.apache.commons.lang3.StringUtils;

String host = "${redis-host}"; //服务器地址

int port = ${redis-port}; //端口号

String password = "${redis-password}"; //redis密码

int index = 0; //redis db

String key = "${redis-key}"; //key值

Jedis jedis = new Jedis(host, port);

if(StringUtils.isNotBlank(password)){

jedis.auth(password);

}

jedis.select(index);

String redisGetResult = jedis.get(key);

vars.put("redisGetResult",redisGetResult); //将key值保存为变量

如上，成功取到了需要的数据。

?? ??当然，此处仅演示了获取string类型的数据。至于获取其他类型数据，甚至对redis的数据库的增、删、改、查的所有操作，jedis都支持。具体可参考查阅jedis提供的所有方法。如果读者有兴趣，还可以自己再次进行封装。

此处推荐一篇文章：https://www.cnblogs.com/tengfly/p/9307373.html

二、 jmeter连接MongoDB

2.1 驱动包选择

如果MongoDB版本是3.x以下，那么用jmeter自带的mongo-java-driver-2.11.3.jar即可；如果MongoDB版本是3.x以上，则需要mongo-java-driver-2.13.2.jar，或者更高版本。
将驱动包放在 apache-jmeter-x.x\lib目录下或者apache-jmeter-x.x\lib\ext目录下即可。

2.2 添加Sampler，编写java代码访问mongo

可选择添加JSR223 Sampler（groovy）或者BeanShell Sampler，这2种采样器均支持java，但略有不同，语法有些许差异。此处以JSR223 Sampler（groovy）为例。

代码如下：

import com.mongodb.*;

import java.util.Set;

MongoClient mongoClient = new MongoClient("127.0.0.1",27017); //根据IP、端口连mongo

DB db = mongoClient.getDB("test"); //选择数据库

Set<String> collectionNames = db.getCollectionNames();

log.info(db.getName() + "包含如下集合：" + collectionNames.size());

for (String collectionName : collectionNames) {

log.info(collectionName);

}

log.info("数据库连接成功");

DBCollection dbCollection = db.getCollection("col_1"); //选择集合

log.info("集合连接成功");

BasicDBObject searchObj = new BasicDBObject();

searchObj.put("name", "zhf");

DBObject result = dbCollection.findOne(searchObj);

log.info("==============================>>>");

log.info(result.toString());

vars.put("email",result.get("email"));

log.info(vars.get("email"));

运行jmeter，查看效果：

2.3 由于直接在jmeter上写代码不是太方便，建议在IDEA上调试java代码

建maven项目，添加依赖，pom.xml文件参考如下：

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>zhf</groupId>

<artifactId>zhf</artifactId>

<version>1.0-SNAPSHOT</version>

<dependencies>

<dependency>

<groupId>org.mongodb</groupId>

<artifactId>mongo-java-driver</artifactId>

<version>2.13.2</version>

</dependency>

</dependencies>

</project>

测试代码如下：

import com.mongodb.*;

import java.util.Set;

public class Test {

public static void main(String[] args){

try {

MongoClient mongoClient = new MongoClient("127.0.0.1",27017);

DB db = mongoClient.getDB("test");

Set<String> collectionNames = db.getCollectionNames();

System.out.println(db.getName() + "包含如下集合：");

for (String collectionName : collectionNames) {

System.out.println(collectionName);

}

System.out.println("数据库连接成功");

DBCollection dbCollection = db.getCollection("col_1");

System.out.println("集合连接成功");

BasicDBObject searchObj = new BasicDBObject();

searchObj.put("name", "zhf");

DBObject result = dbCollection.findOne(searchObj);

System.out.println(result);

System.out.println(result.get("sex"));

} catch (Exception e) {

System.err.println(e.getClass().getName() + ": " + e.getMessage());

}

}

}

三、 jmeter连接Mysql

3.1 下载数据库连接驱动，放至apache-jmeter-xxx\lib\ext目录下

注意：mysql版本与驱动需对应，

目前已知mysql8.x版本对应驱动也为8.x；

其他mysql版本对应驱动为5.X。

官方驱动下载地址：https://dev.mysql.com/downloads/connector/j/

3.2 打开jmeter，添加JDBC Connection Configuration，配置连接信息

1）Variable Name不能为空

2）DataBase URL 格式为：jdbc:mysql://服务器ip:端口号/数据库?key=value

例如：

jdbc:mysql://127.0.0.1:3306/test?charset=utf-8&useSSL=false&serverTimezone=UTC&allowMultiQueries=true

3）如果mysql驱动版本是5.x，配置如下：

JDBC Driver Class：com.mysql.jdbc.Driver

如果mysql驱动版本是8.x，配置有变化，如下：

JDBC Driver Class：com.mysql.cj.jdbc.Driver

3.3 添加JDBC Request采样器查询数据库

运行，查看效果，如下：

3.4 提取查询结果，存入变量，供其他请求调用

加上Debug PostProcessor查看调试结果，如下：

可以看出，对于我们指定的变量username，根据查询结果，jmeter会做如下处理：

将结果条数赋值给username_#，

第一条结果赋值给username_1,

第二条结果赋值给username_2，

这样，我们就可以在接下来的其他请求中使用这些变量了。