springboot項目組引入JMeter的實現(xiàn)步驟
一、前言
看到標題的小伙伴肯定很好奇,springboot項目中用JMeter能干什么,那么我先反問你JMeter能用來作什么?壓測;接口自動化?,如果你能猜到這兩點那你對JMeter肯定是有了一定的認知,同樣你也猜對了,用它來做接口自動化
但是可能會有小伙伴會有疑問為什么不拿他來做壓測,當然可能拿來做壓測但是不建議在springboot項目中整合壓測功能,畢竟壓測本來就是一種多線程的形式而且極其消耗內(nèi)存,spring項目本來就很重,所以得不償失。當然對于壓測我又另一種方案,就是容器化的分布式壓測,這一塊方案我會再后續(xù)的文章分享出,接下來我們先來談?wù)勅绾卧趕pringboot項目中做接口自動化吧
在這篇文章中我詳細介紹過JMeter engine啟動原理,知道JMeter engine原理之后,是否我們可以這樣做,在springboot項目引入JMeter開源組件包然后使用其開啟engine的方法,自己開啟engine,當然此時你的線程肯定是單線程,所以基本內(nèi)存消耗很低,那么如何做?我們接著往下說
二、springboot項目引入JMeter完成接口自動化操作
首先導(dǎo)入JMeter對應(yīng)的maven坐標
<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標準的引擎類,通過創(chuàng)建這個對象就可以開啟engine,當然事實并非如此簡單
//創(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的用法及使用,可以參考我寫的這篇博文

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)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java實戰(zhàn)權(quán)限管理系統(tǒng)的實現(xiàn)流程
讀萬卷書不如行萬里路,只學(xué)書上的理論是遠遠不夠的,只有在實戰(zhàn)中才能獲得能力的提升,本篇文章手把手帶你用java+SpringBoot+MyBatis+AOP+LayUI+Mysql實現(xiàn)一個權(quán)限管理系統(tǒng),大家可以在過程中查缺補漏,提升水平2022-01-01
Java?多個文件生成zip包、下載zip包的實現(xiàn)代碼
這篇文章主要介紹了Java?多個文件生成zip包、下載zip包,包括文件上傳,文件下載,多個文件打成zip包的操作代碼,本文給大家介紹的非常詳細,需要的朋友可以參考下2024-01-01
Java實現(xiàn)Excel轉(zhuǎn)PDF的兩種方法詳解
使用具將Excel轉(zhuǎn)為PDF的方法有很多,在這里我給大家介紹兩種常用的方法:使用spire轉(zhuǎn)化PDF、使用jacob實現(xiàn)Excel轉(zhuǎn)PDF,分別應(yīng)對兩種不一樣的使用場景,需要的可以參考一下2022-01-01
tk.mybatis通用插件updateByPrimaryKeySelective無法自動更新列的解決辦法
tk.mybatis是一個很好用的通用插件,本文主要介紹了tk.mybatis通用插件updateByPrimaryKeySelective無法自動更新列的解決辦法,具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-12-12
java開發(fā)微服務(wù)架構(gòu)設(shè)計消息隊列的水有多深
今天我們說說消息隊列的問題,來帶大家探一探消息隊列的水有多深,希望看完本文大家在引入消息隊列的時候先想一想,是不是一定要引入?引入消息隊列后產(chǎn)生的問題能不能解決2021-10-10

