如何編寫符合jmeter規范的java腳本

Jmeter的Sampler用來模擬向被測試系統發起請求的，Jmeter會記錄取樣的結果，也就是TPS、響應時間等性能指標。接下來就是使用Java請求進行一個接口測試。

大致流程：

1、導入jar包：導入Jmeter相關jar包

2、編寫腳本：使用Eclipse或者IntelliJ IDEA，進行Java測試腳本的編寫

3、導出為jar包：使用Eclipse或者IntelliJ IDEA將測試腳本編譯打包為jar包導出

4、配置Jmeter：使用自編譯的jar包，以及一些相關配置進行性能測試

5、選擇自編寫jar包：自編譯jar包

6、Jmeter運行：開始運行

實戰操作

一、核心步驟(以我實際操作為例)

1.創建工程

使用IntelliJ IDEA創建一個Java工程，取名為JmeterTest；

2.添加依賴

 

2.1lib及子目錄依賴

a.使用Jmeter運行Java腳本，需要用到Jmeter提供的框架jar包（分別在Jmeter目錄下的lib和ext目錄下）

ext:

ApacheJMeter_core.jar

ApacheJMeter_java.jar

lib:

slf4j-api-1.7.25.jar

jorphan.jar

Jmeter5.3需要多添加一個jar包：oro-2.0.8.jar

b.將JMeter的lib目錄下的jar文件添加進此工程；

注意：此處有坑，不能只添加lib這個大目錄，還需要添加lib目錄下的ext和junit目錄，否則無法調用相關jar包

lib目錄下兩個兩個子目錄

 

 2.2IDEA操作

1、打開 File -> Project Structure (Ctrl + Shift + Alt + S)或者使用快捷鍵

 

3.腳本編寫

創建一個類並實現JavaSamplerClient接口或繼承AbstractJavaSamplerClient，並重寫：

public Arguments getDefaultParameters()：設置可用參數及的默認值；自定義的參數，它可以獲取到Jmeter面板上的參數

public void setupTest(JavaSamplerContext arg0)：每個線程測試前執行一次，做一些初始化工作；

public SampleResult runTest(JavaSamplerContext arg0)：開始測試，從arg0參數可以獲得參數值；執行業務代碼函數，在setupTest方法后執行，每個線程執行N次

public void teardownTest(JavaSamplerContext arg0)：測試結束時調用；

query:

package cn.testfan;

import java.sql.*;

public class queryTest {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // 1.注冊驅動
        Class.forName("com.mysql.cj.jdbc.Driver");
        String url = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8";
        String userName = "root";
        String password = "root";
        String sql = "SELECT * FROM boys";
        // 2.建立鏈接：通過ip、端口號、數據庫名、用戶名、密碼
        Connection conn = DriverManager.getConnection(url,userName,password);
        // 3.對SQL語句做預編譯，提升執行性能,返回一個經過變異后的SQL語句對象PreparedStatement
        PreparedStatement ps = conn.prepareStatement(sql);
        // 5.執行SQL
        ResultSet set = ps.executeQuery();
        while (set.next()){
            String boyNum = set.getString("boyNum");
            String matchNum = set.getString("matchNum");
            System.out.println("boyNum為：" + boyNum);
            System.out.println("matchNum為：" + matchNum);
            System.out.println("++++++++++");
        }
        // 6.關閉數據庫鏈接
        conn.close();
    }
}

轉換為Jmeter可以執行的腳本：
類名后添加implements JavaSamplerClient，點擊ALT+Enter
update：

package cn.testfan;

import org.apache.jmeter.config.Arguments;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerClient;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;
import org.apache.jmeter.samplers.SampleResult;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/*
自定義的測試類，實現了Jmeter的接口JavaSamplerClient
 */
public class InsertTest implements JavaSamplerClient {
//    String url = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8";
//    String userName = "root";
//    String password = "root";
//    String boyNum = "boy-001";
//    String matchNum = "111";
    String sql = "INSERT INTO boys (boyNum, matchNum) VALUES (?,?)";
    PreparedStatement ps;
    Connection conn;
    public static void main(String[] args) {
        // 模擬Jmeter執行一次腳本
        InsertTest test = new InsertTest();
        JavaSamplerContext context = new JavaSamplerContext(test.getDefaultParameters());
        test.setupTest(context);
        test.runTest(context);
        test.teardownTest(context);
    }
/*
 * 初始化函數，每個線程先執行此函數，並且僅執行一次
 */
    @Override
    public void setupTest(JavaSamplerContext javaSamplerContext) {
        try {
            // 1.注冊驅動
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 2.建立鏈接：通過ip、端口號、數據庫名、用戶名、密碼
            String dbUrl = javaSamplerContext.getParameter("dbUrl");
            String dbUserName = javaSamplerContext.getParameter("dbUserName");
            String dbPassWord = javaSamplerContext.getParameter("dbPassWord");
            conn = DriverManager.getConnection(dbUrl,dbUserName,dbPassWord);
            // 3.對SQL語句做預編譯，提升執行性能,返回一個經過變異后的SQL語句對象PreparedStatement
            ps = conn.prepareStatement(sql);
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }

    }
/*
* 執行業務代碼函數，在setupTest方法后執行，每個線程執行N次
*/
    @Override
    public SampleResult runTest(JavaSamplerContext javaSamplerContext) {
        //給請求起個名字
        SampleResult sampleResult = new SampleResult();
        sampleResult.setSampleLabel("insert");
        //請求開始
        sampleResult.sampleStart();
        try {
            // 4、對SQL語句中的問號進行替換
            String boyNum = javaSamplerContext.getParameter("boyNum");
            String matchNum = javaSamplerContext.getParameter("matchNum");
            // int age = javaSamplerContext.getIntParameter("age");
            ps.setString(1,boyNum);
            ps.setString(2,matchNum);
            // 5.執行SQL
            int rows = ps.executeUpdate();
            if (rows == 1){
                //請求成功
                sampleResult.setSuccessful(true);
            }else{
                //請求失敗
                sampleResult.setSuccessful(false);
            }
            String response = "插入的行數為："+rows;
            sampleResult.setResponseData(response,"utf-8");

            System.out.println("插入的數據行數為：" + rows);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        //請求結束
        sampleResult.sampleEnd();
        return sampleResult;
    }

    @Override
    public void teardownTest(JavaSamplerContext javaSamplerContext) {
        // 6.關閉數據庫鏈接
        try {
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
/*
* 自定義的參數，它可以獲取到Jmeter面板上的參數
*/
    @Override
    public Arguments getDefaultParameters() {
        Arguments arguments = new Arguments();
        arguments.addArgument("dbUrl","jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8");
        arguments.addArgument("dbUserName","root");
        arguments.addArgument("dbPassWord","root");
        arguments.addArgument("boyNum","boy-007");
        arguments.addArgument("matchNum","111");
        return arguments;
    }
}

3.1服務

package test;

import java.io.File;

import java.io.PrintWriter;

/**

* Created by April_Chou on 2018/4/10.

*/

public class OutputService {undefined

public static void output(String filename,int a, int b)throws Exception {undefined

PrintWriter out =new PrintWriter(new File(filename));

out.write(a+":"+b);

out.close();

}

}

3.2測試類：

package test;

import org.apache.jmeter.config.Arguments;

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

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

import org.apache.jmeter.samplers.SampleResult;

/**

* Created by April_Chou on 2018/4/10.

*/

public class PerformenceTestimplements JavaSamplerClient {undefined

private SampleResultresults;

private Stringa;

private Stringb;

private Stringfilename;

// 設置傳入的參數，可以設置多個，已設置的參數會顯示到Jmeter的參數列表中

public ArgumentsgetDefaultParameters() {undefined

Arguments params =new Arguments();

params.addArgument("filename", "0");//設置參數，並賦予默認值0

params.addArgument("a", "0");//設置參數，並賦予默認值0

params.addArgument("b", "0");//設置參數，並賦予默認值0

return params;

}

// 初始化方法，實際運行時每個線程僅執行一次，在測試方法運行前執行

public void setupTest(JavaSamplerContext arg0) {undefined

results =new SampleResult();

}

// 測試執行的循環體，根據線程數和循環次數的不同可執行多次

@Override

public SampleResultrunTest(JavaSamplerContext arg0) {undefined

b = arg0.getParameter("b"); // 獲取在Jmeter中設置的參數值

a = arg0.getParameter("a"); // 獲取在Jmeter中設置的參數值

filename = arg0.getParameter("filename"); // 獲取在Jmeter中設置的參數值

results.sampleStart();// jmeter 開始統計響應時間標記

try {undefined

OutputService test =new OutputService();

test.output(filename,Integer.parseInt(a), Integer.parseInt(b));

results.setSuccessful(true);

// 被測對象調用

}catch (Throwable e) {undefined

results.setSuccessful(false);

e.printStackTrace();

}finally {undefined

results.sampleEnd();// jmeter 結束統計響應時間標記

}

return results;

}

// 結束方法，實際運行時每個線程僅執行一次，在測試方法運行結束后執行

public void teardownTest(JavaSamplerContext arg0) {undefined

}

public static void main(String[] args) {undefined

// TODO Auto-generated method stub

Arguments params =new Arguments();

params.addArgument("a", "0");//設置參數，並賦予默認值0

params.addArgument("b", "0");//設置參數，並賦予默認值0

JavaSamplerContext arg0 =new JavaSamplerContext(params);

PerformenceTest test =new PerformenceTest();

test.setupTest(arg0);

test.runTest(arg0);

test.teardownTest(arg0);

}

}

4.Export為Runnable Jar File

打開IDEA的file -> Project Structure或者快捷方式，進入項目配置頁面。如下圖：

Artifacts

點擊Artifacts，進入Artifacts配置頁面，點擊 + ，選擇如下圖的選項

 

 

 

說明：

第一步選擇Main函數執行的類，可以進行自動搜索。

第二步選擇如圖的選項，目的是對第三方Jar包打包時做額外的配置，如果不做額外的配置可不選這個選項(但不保證打包成功)

第三步需要在測試類的目錄下，新建一個resources目錄，將MANIFEST.MF文件保存在這里面，因為如果用默認缺省值的話，在IDEA12版本下會有bug。

點擊OK之后，出現如下圖界面，右鍵點擊output root，點擊Create Directory,創建一個libs，將所有的第三方JAR放進libs目錄下，成功之后，如下圖所示：

 

 

點擊Build->Build Artifacts，選擇build

build

 

 就會生成我們需要的jar包。其位置在項目目錄的out目錄下

 

 

 jar包成功

5.Jmeter導入

將此jar包放入JMETER_HOME\lib\ext目錄

6.打開Jmeter

建議以管理員身份打開JMeter

7.配置Jmeter

創建線程組、Java請求、圖形結果、查看結果樹、聚合報告、用表格察看結果，進行測試

注意：

這樣的Java請求值需要你在相應的盤創建一個文件夾，否則會運行失敗，我這里是D盤創建了一個test的文件夾。

界面

Java請求里的參數可以使用函數助手進行填充，如下圖：

 

線程組設置

 

 

8.運行結果

 

 

原文鏈接：https://blog.csdn.net/weixin_42509720/article/details/114040784