一、前言
看到標題的小伙伴肯定很好奇，springboot項目中用JMeter能干什么，那么我先反問你JMeter能用來作什么？壓測；接口自動化？，如果你能猜到這兩點那你對JMeter肯定是有了一定的認知，同樣你也猜對了，用它來做接口自動化
但是可能會有小伙伴會有疑問為什么不拿他來做壓測，當然可能拿來做壓測但是不建議在springboot項目中整合壓測功能，畢竟壓測本來就是一種多線程的形式而且極其消耗內存，spring項目本來就很重，所以得不償失。當然對于壓測我又另一種方案，就是容器化的分布式壓測，這一塊方案我會再后續的文章分享出，接下來我們先來談談如何在springboot項目中做接口自動化吧
在這篇文章中我詳細介紹過JMeter engine啟動原理，知道JMeter engine原理之后，是否我們可以這樣做，在springboot項目引入JMeter開源組件包然后使用其開啟engine的方法，自己開啟engine，當然此時你的線程肯定是單線程，所以基本內存消耗很低，那么如何做？我們接著往下說
二、springboot項目引入JMeter完成接口自動化操作
首先導入JMeter對應的maven坐標
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
<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標準的引擎類，通過創建這個對象就可以開啟engine，當然事實并非如此簡單
|
1
2
3
4
5
6
7
8
9
10
11
|
//創建engineStandardJMeterEngine engine = new StandardJMeterEngine();//將hashTree配置注入engine中engine.configure(hashTree); try { //執行engine開始運行 engine.runTest();} catch (JMeterEngineException e) { engine.stopTest(); e.printStackTrace();} |
所以開啟engine就這么短短的幾步操作就行，但是上面需要HashTree對象傳入，就是你的配置，關于HashTree的用法及使用，可以參考我寫的這篇博文
HashTree有了之后，理論上是可以運行了，但是實際卻會報錯，因為JMeter engine開啟會初始化配置文件，也就是我們熟知的jmeter.properties配置的內容，所以你可以在springboot項目的resource下創建jmeter目錄存放jmeter.properties等配置
配置文件可以去github上去獲取JMeter 配置
好了配置有了，接下來我們需要先初始化jmeter.properties配置屬性然后在開啟jmeter engine就行
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
//初始化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方法必須寫成臨時文件這樣的形式，否則會獲取不到jmeter.properties JMeterUtils.loadJMeterProperties(tempFile.getAbsolutePath()); JMeterUtils.setJMeterHome(JMeterUtil.PATH); JMeterUtils.setLocale(LocaleContextHolder.getLocale()); } catch (IOException e) { e.printStackTrace(); }} |
在上面代碼中必須通過創建臨時文件的形式傳入臨時文件的路徑，否則springboot打成jar無法找到路徑從而報錯
在執行步驟2即可，但是會有一個問題engine.runTest()是一個空方法，那你如何接收運行的結果集數據呢？這里就要牽扯到jmeter后端監聽器的作用了，JMeter后端監聽器作用及原理可以參考這篇文章
后端監聽器可以異步的接收jmeter engine運行的結果集，所以我們可以通過這個方式實現一個完整的接口自動化流程
這是關于我的springboot項目采用后端監聽器的實現方式
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
public class CustomBackendListenerClient extends AbstractBackendListenerClient { private final List<SampleResult> queue = new ArrayList<>(); //獲得控制臺內容。 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執行之前會進行前置處理器 @Override public void setupTest(BackendListenerContext context) throws Exception { setConsole(); super.setupTest(context); } //engine執行中的處理 @Override public void handleSampleResults(List<SampleResult> sampleResults, BackendListenerContext context) { //結果集添加至集合中 queue.addAll(sampleResults); } //engine結束后的后置處理器 @Override public void teardownTest(BackendListenerContext context) throws Exception { //處理結果集中的數據并封裝至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接口自動化可以通過此方案來實現，希望能對你有所啟發
到此這篇關于springboot項目組引入JMeter的實現步驟的文章就介紹到這了,更多相關springboot項目組引入JMeter內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/weixin_40686603/article/details/114634552
