關(guān)于jmeter測(cè)試dubbo接口方式

說明:

本文章介紹如何使用jmeter測(cè)試dubbo接口,涉及如下兩種方式

1.使用官方dubbo版本包測(cè)試dubbo接口

2.通過自己編寫java請(qǐng)求插件,實(shí)現(xiàn)dubbo調(diào)用

選擇方式1或方式2并沒有什么區(qū)別,取決于部分自研公司對(duì)dubbo進(jìn)行了封裝,導(dǎo)致官方提供的dubbo包并不適用于方式1,則可以通過方式2去調(diào)用

方式1:使用官方dubbo版本包調(diào)用dubbo接口

登陸以下地址下載jmeter的dubbo插件包

https://github.com/ningyu1/jmeter-plugins-dubbo/releases
解壓tar將獲取到的jar包放入${JMETER_HOME}\lib\ext路徑下(這里獲取到的jar包為jmeter-plugins-dubbo-2.7.1-jar-with-dependencies),重啟jmeter應(yīng)用(這里重啟完應(yīng)用會(huì)添加取樣器會(huì)多出一個(gè)dubbo sample)

1.添加線程組

右鍵添加,選擇線程->線程組


添加線程組
2.添加dubbo sample

2.光標(biāo)對(duì)準(zhǔn)線程組右鍵添加->取樣器->dubbo sample


添加dubbo sample
3.配置參數(shù)說明如下
參數(shù)說明

此處需要關(guān)注,當(dāng)方法接收的是一個(gè)String,或者List等類型的參數(shù),可參照截圖配置
那么當(dāng)方法接收的參數(shù)是一個(gè)對(duì)象時(shí),需要獲取對(duì)接接口的api jar包并關(guān)聯(lián)到當(dāng)前測(cè)試計(jì)劃
選中測(cè)試計(jì)劃,點(diǎn)擊下方瀏覽按鈕,選擇對(duì)應(yīng)的jar包


添加jar包

傳參的具體方式可參照如下


參數(shù)說明
4.點(diǎn)擊發(fā)送按鈕,查看結(jié)果

接口1返回:


返回1

接口2返回


返回2

方式2:編寫java請(qǐng)求方式請(qǐng)求dubbo接口

看了下網(wǎng)上的大多請(qǐng)求都是單接口請(qǐng)求dubbo,這樣就會(huì)導(dǎo)致,每次有新的接口的時(shí)候都得去更新新的請(qǐng)求,這里提供一個(gè)一勞永逸的方法,通過泛化調(diào)用,實(shí)現(xiàn)一個(gè)jar請(qǐng)求可適配所有接口,一般看到這個(gè)文章的可能大多都是測(cè)試的同學(xué),對(duì)于當(dāng)前方法需要對(duì)java有一定的基礎(chǔ),所以這個(gè)時(shí)候就體驗(yàn)到學(xué)習(xí)的重要性了,下面開始操作吧

1.創(chuàng)建maven項(xiàng)目

file->new->project,選擇maven


創(chuàng)建maven項(xiàng)目

輸入組織->坐標(biāo)后點(diǎn)擊next


配置信息

按需配置名稱路徑后點(diǎn)擊finsh


配置信息

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>dobbo-jmeter-interface</groupId>
    <artifactId>dobbo-jmeter-interface</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <!--Zdubbo-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.2.1</version>
            <!--去掉dubbo中的spring依賴,否則會(huì)與后邊的產(chǎn)生沖突-->
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.9</version>
        </dependency>
        <dependency>
            <groupId>org.apache.jmeter</groupId>
            <artifactId>ApacheJMeter_java</artifactId>
            <version>5.1</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.58</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <!--復(fù)制jar包插件,將使用到的jar包,復(fù)制到target/lib中-->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-dependency-plugin</artifactId>
                <executions>
                    <execution>
                        <id>copy-dependencies</id>
                        <phase>prepare-package</phase>
                        <goals>
                            <goal>copy-dependencies</goal>
                        </goals>
                        <configuration>
                            <outputDirectory>${project.build.directory}/lib</outputDirectory>
                            <overWriteReleases>false</overWriteReleases>
                            <overWriteSnapshots>false</overWriteSnapshots>
                            <overWriteIfNewer>true</overWriteIfNewer>
                        </configuration>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

實(shí)現(xiàn)方式如下

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ReferenceConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.utils.ReferenceConfigCache;
import com.alibaba.dubbo.rpc.service.GenericService;
import com.alibaba.fastjson.JSON;
import org.apache.jmeter.config.Arguments;
import org.apache.jmeter.protocol.java.sampler.AbstractJavaSamplerClient;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;
import org.apache.jmeter.samplers.SampleResult;

/**
 * @author Chance.W
 * @Description TODO
 * @date 2020/3/27-23:38
 */
public class DubboRequest extends AbstractJavaSamplerClient {

    private ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>();
    private com.alibaba.dubbo.rpc.service.GenericService genericService;

    // 該方法設(shè)置的參數(shù),都會(huì)出現(xiàn)在jmeter的參數(shù)列表中,并且展示相關(guān)設(shè)置的默認(rèn)值
    public Arguments getDefaultParameters() {
        Arguments params = new Arguments();
        params.addArgument("dubbo.registry.address", "zookeeper://172.16.25.100:26011");
        params.addArgument("dubbo.registry.group", "dubbo_test");
        params.addArgument("dubbo.request.apiService", "com.test.test.test.aaa.api.ccc.QueryService");
        params.addArgument("dubbo.request.reqType", "com.test.test.test.aaa.api.ccc.param.DrmAgentAccountQueryRequest");
        params.addArgument("dubbo.request.method", "TestQry");
        params.addArgument("dubbo.request.restMessage", "{\n" +
                "\t\"Code\":\"201909260000001\"\n" +
                "}");
        return params;
    }

    public void setupTest(JavaSamplerContext arg0) {
        String zkAddress = arg0.getParameter("dubbo.registry.address");
        String dubboGroup = arg0.getParameter("dubbo.registry.group");
        String apiService = arg0.getParameter("dubbo.request.apiService");
        // 當(dāng)前dubbo consumer的application配置,不設(shè)置會(huì)直接拋異常
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("test_service");
        // 注冊(cè)中心配置
        RegistryConfig registryConfig = new RegistryConfig();
        // 注冊(cè)中心這里需要配置上注冊(cè)中心協(xié)議,例如下面的zookeeper
        registryConfig.setAddress(zkAddress);
        registryConfig.setGroup(dubboGroup);
        reference.setApplication(applicationConfig);
        reference.setRegistry(registryConfig);
        // 設(shè)置調(diào)用的reference屬性,下面只設(shè)置了協(xié)議、接口名、版本、超時(shí)時(shí)間
        reference.setProtocol("dubbo");
        reference.setInterface(apiService);
        reference.setGeneric(true);
        ReferenceConfigCache cache = ReferenceConfigCache.getCache();
        //獲取接口并聲明為泛化
        genericService = cache.get(reference);
    }

    public SampleResult runTest(JavaSamplerContext arg0) {
        SampleResult sr = new SampleResult();
        //從jmeter 中獲取相關(guān)的參數(shù),組裝后,調(diào)用相關(guān)的接口
        String requestType = arg0.getParameter("dubbo.request.reqType");
        String methodName = arg0.getParameter("dubbo.request.method");
        String restMessage = arg0.getParameter("dubbo.request.restMessage");
        try {
            sr.sampleStart();
            //  sr.setSampleLabel(agentCode);
            sr.setRequestHeaders(restMessage);
            Object responseData = genericService.$invoke(methodName, new String[]{requestType}, new Object[]{JSON.parseObject(restMessage)});
            //  System.out.println(JSON.toJSONString(responseData));
            sr.setResponseMessage(responseData.toString());
            sr.setResponseData("responseMessage:" + responseData.toString(), "utf-8");
            sr.setSuccessful(true);
            sr.sampleEnd();

        } catch (Exception e) {
            e.printStackTrace();
            //當(dāng)出現(xiàn)異常時(shí),將異常顯示到結(jié)果樹
            sr.setResponseMessage(e.getMessage());
        }
        return sr;
    }

    public void teardownTest(JavaSamplerContext arg0) {

    }
}

打包操作


打包

左側(cè)窗口為生成的jar包和lib目錄


jar包位置

這里要說明下,網(wǎng)上提供了一種方式,通過修改安裝目錄bin下jmeter.properties文件關(guān)聯(lián)lib下的依賴
文件中增加如下(通過嘗試,這么做會(huì)導(dǎo)致jmeter啟動(dòng)由于jar包加載順序的問題,ui部分控件不可用)

search_paths=D:/Software/apache-jmeter-5.0/lib-dependency

這里我使用的是另一種更為簡(jiǎn)便的方式
將原安裝目錄lib下ext修改為extbak
新建ext,并將工程lib下的jar包和dobbo-jmeter-interface-1.0-SNAPSHOT.jar放入之
由于可能會(huì)用到隨機(jī)函數(shù),從extbak獲取ApacheJMeter_functions.jar,也放入到新建的ext目錄下
重啟jmeter,稍等片刻

添加java請(qǐng)求


添加java請(qǐng)求

參數(shù)說明

添加結(jié)果樹


結(jié)果樹

點(diǎn)擊運(yùn)行后,結(jié)果樹信息如下


結(jié)果樹返回

后續(xù)可自行配置斷言和隨機(jī)參數(shù)等

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容