快捷導(dǎo)航

springboot項目組引入JMeter的實現(xiàn)步驟

更新時間：2021年09月06日 11:19:43 作者：HenryXiao8080

本文主要介紹了springboot項目組引入JMeter的實現(xiàn)步驟，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下

一、前言

看到標(biāo)題的小伙伴肯定很好奇，springboot項目中用JMeter能干什么，那么我先反問你JMeter能用來作什么？壓測；接口自動化？，如果你能猜到這兩點那你對JMeter肯定是有了一定的認(rèn)知，同樣你也猜對了，用它來做接口自動化
但是可能會有小伙伴會有疑問為什么不拿他來做壓測，當(dāng)然可能拿來做壓測但是不建議在springboot項目中整合壓測功能，畢竟壓測本來就是一種多線程的形式而且極其消耗內(nèi)存，spring項目本來就很重，所以得不償失。當(dāng)然對于壓測我又另一種方案，就是容器化的分布式壓測，這一塊方案我會再后續(xù)的文章分享出，接下來我們先來談?wù)勅绾卧趕pringboot項目中做接口自動化吧

在這篇文章中我詳細(xì)介紹過JMeter engine啟動原理，知道JMeter engine原理之后，是否我們可以這樣做，在springboot項目引入JMeter開源組件包然后使用其開啟engine的方法，自己開啟engine，當(dāng)然此時你的線程肯定是單線程，所以基本內(nèi)存消耗很低，那么如何做？我們接著往下說

二、springboot項目引入JMeter完成接口自動化操作

首先導(dǎo)入JMeter對應(yīng)的maven坐標(biāo)

<properties>
    <jmeter.version>5.3</jmeter.version>
</properties>

<dependencies>
<dependency>
    <groupId>org.apache.jmeter</groupId>
    <artifactId>ApacheJMeter_http</artifactId>
    <version>${jmeter.version}</version>
    <exclusions>
        <exclusion>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-slf4j-impl</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>org.apache.jmeter</groupId>
    <artifactId>ApacheJMeter_functions</artifactId>
    <version>${jmeter.version}</version>
</dependency>
<dependency>
    <groupId>org.apache.jmeter</groupId>
    <artifactId>ApacheJMeter_jdbc</artifactId>
    <version>${jmeter.version}</version>
</dependency>
<dependency>
    <groupId>org.apache.jmeter</groupId>
    <artifactId>ApacheJMeter_tcp</artifactId>
    <version>${jmeter.version}</version>
</dependency>
</dependencies>

在JMeter engine啟動原理介紹了StandardJMeterEngine標(biāo)準(zhǔn)的引擎類，通過創(chuàng)建這個對象就可以開啟engine，當(dāng)然事實并非如此簡單

//創(chuàng)建engine
StandardJMeterEngine engine = new StandardJMeterEngine();
//將hashTree配置注入engine中
engine.configure(hashTree); 
try {
 //執(zhí)行engine開始運行
    engine.runTest();
} catch (JMeterEngineException e) {
    engine.stopTest();
    e.printStackTrace();
}

所以開啟engine就這么短短的幾步操作就行，但是上面需要HashTree對象傳入，就是你的配置，關(guān)于HashTree的用法及使用，可以參考我寫的這篇博文

一文搞懂JMeter engine中的HashTree配置

HashTree有了之后，理論上是可以運行了，但是實際卻會報錯，因為JMeter engine開啟會初始化配置文件，也就是我們熟知的jmeter.properties配置的內(nèi)容，所以你可以在springboot項目的resource下創(chuàng)建jmeter目錄存放jmeter.properties等配置

配置文件可以去github上去獲取JMeter 配置

好了配置有了，接下來我們需要先初始化jmeter.properties配置屬性然后在開啟jmeter engine就行

//初始化jmeter屬性配置
private void initJMeterProperties() {
    if (!StringUtils.isEmpty(JMeterUtils.getJMeterProperties())){
        return;
    }
    try {
        InputStream inputStream = JMeterUtil.class.getResource("/jmeter/jmeter.properties").openStream();
        File tempFile = FileUtil.createTempFile(null);
        FileUtil.writeFromStream(inputStream,tempFile);
        //這里面loadJMeterProperties方法必須寫成臨時文件這樣的形式，否則會獲取不到j(luò)meter.properties
        JMeterUtils.loadJMeterProperties(tempFile.getAbsolutePath());
        JMeterUtils.setJMeterHome(JMeterUtil.PATH);
        JMeterUtils.setLocale(LocaleContextHolder.getLocale());
    } catch (IOException e) {
        e.printStackTrace();
    }
}

在上面代碼中必須通過創(chuàng)建臨時文件的形式傳入臨時文件的路徑，否則springboot打成jar無法找到路徑從而報錯

在執(zhí)行步驟2即可，但是會有一個問題engine.runTest()是一個空方法，那你如何接收運行的結(jié)果集數(shù)據(jù)呢？這里就要牽扯到jmeter后端監(jiān)聽器的作用了，JMeter后端監(jiān)聽器作用及原理可以參考這篇文章

后端監(jiān)聽器可以異步的接收jmeter engine運行的結(jié)果集，所以我們可以通過這個方式實現(xiàn)一個完整的接口自動化流程

這是關(guān)于我的springboot項目采用后端監(jiān)聽器的實現(xiàn)方式

public class CustomBackendListenerClient extends AbstractBackendListenerClient {

    private final List<SampleResult> queue = new ArrayList<>();

    //獲得控制臺內(nèi)容。
    private PrintStream oldPrintStream = System.out;
    private ByteArrayOutputStream bos = new ByteArrayOutputStream();

    private void setConsole() {
        System.setOut(new PrintStream(bos));
    }

    private String getConsole() {
        System.setOut(oldPrintStream);
        return bos.toString();
    }
 // engine執(zhí)行之前會進行前置處理器
    @Override
    public void setupTest(BackendListenerContext context) throws Exception {
        setConsole();
        super.setupTest(context);
    }
 //engine執(zhí)行中的處理
    @Override
    public void handleSampleResults(List<SampleResult> sampleResults, BackendListenerContext context) {
     //結(jié)果集添加至集合中
        queue.addAll(sampleResults);
    }
 //engine結(jié)束后的后置處理器
    @Override
    public void teardownTest(BackendListenerContext context) throws Exception {
     //處理結(jié)果集中的數(shù)據(jù)并封裝至JMeterRequestResult對象中
        RunJMeterRequestService runJMeterRequestService = CommonBeanFactory.getBean(RunJMeterRequestService.class);
        List<JMeterRequestResult> jMeterRequestResults = Lists.newArrayList();
        String testId = context.getParameter("testId");
        queue.stream().forEach(result -> {
            setRequestResult(result, jMeterRequestResults);
        });
        queue.clear();
        runJMeterRequestService.addDebugResult(testId, jMeterRequestResults);
        super.teardownTest(context);
    }

    private void setRequestResult(SampleResult result, List<JMeterRequestResult> jMeterRequestResults) {
        JMeterRequestResult metricResult = new JMeterRequestResult();
        Long responseTime = result.getEndTime() - result.getStartTime();
        metricResult.setUrl(result.getUrlAsString());
        metricResult.setResponseSize(((Integer) result.getBodySize()).toString());
        metricResult.setResponseTime(responseTime.toString());
        metricResult.setResponseResult(result.getResponseDataAsString());
        metricResult.setConsoleResult(getConsole());
        if (result instanceof HTTPSampleResult) {
            HTTPSampleResult res = (HTTPSampleResult) result;
            metricResult.setCookie(res.getCookies());
            metricResult.setRequestMethod(res.getHTTPMethod());
        }
        metricResult.setRequestData(result.getSamplerData());
        metricResult.setResponseHeader(result.getResponseHeaders());
        metricResult.setRequestHeader(result.getRequestHeaders());
        metricResult.setStatusCode(result.getResponseCode());
        jMeterRequestResults.add(metricResult);
    }
}

至此JMeter接口自動化可以通過此方案來實現(xiàn)，希望能對你有所啟發(fā)

到此這篇關(guān)于springboot項目組引入JMeter的實現(xiàn)步驟的文章就介紹到這了,更多相關(guān)springboot項目組引入JMeter內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: