说明:

本文章介绍如何使用jmeter测试dubbo接口,涉及如下两种方式

1.使用官方dubbo版本包测试dubbo接口

2.通过自己编写java请求插件,实现dubbo调用

选择方式1或方式2并没有什么区别,取决于部分自研公司对dubbo进行了封装,导致官方提供的dubbo包并不适用于方式1,则可以通过方式2去调用

方式1:使用官方dubbo版本包调用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应用(这里重启完应用会添加取样器会多出一个dubbo sample)

1.添加线程组

右键添加,选择线程->线程组

添加线程组

2.添加dubbo sample

2.光标对准线程组右键添加->取样器->dubbo sample

添加dubbo sample

3.配置参数说明如下

参数说明

此处需要关注,当方法接收的是一个String,或者List等类型的参数,可参照截图配置
那么当方法接收的参数是一个对象时,需要获取对接接口的api jar包并关联到当前测试计划
选中测试计划,点击下方浏览按钮,选择对应的jar包

添加jar包

传参的具体方式可参照如下

参数说明

4.点击发送按钮,查看结果

接口1返回:

返回1

接口2返回

返回2

方式2:编写java请求方式请求dubbo接口

看了下网上的大多请求都是单接口请求dubbo,这样就会导致,每次有新的接口的时候都得去更新新的请求,这里提供一个一劳永逸的方法,通过泛化调用,实现一个jar请求可适配所有接口,一般看到这个文章的可能大多都是测试的同学,对于当前方法需要对java有一定的基础,所以这个时候就体验到学习的重要性了,下面开始操作吧

1.创建maven项目

file->new->project,选择maven

创建maven项目

输入组织->坐标后点击next

配置信息

按需配置名称路径后点击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依赖，否则会与后边的产生冲突-->
            <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>
            <!--复制jar包插件，将使用到的jar包，复制到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>

实现方式如下

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;

    // 该方法设置的参数，都会出现在jmeter的参数列表中，并且展示相关设置的默认值
    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");
        // 当前dubbo consumer的application配置，不设置会直接抛异常
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("test_service");
        // 注册中心配置
        RegistryConfig registryConfig = new RegistryConfig();
        // 注册中心这里需要配置上注册中心协议，例如下面的zookeeper
        registryConfig.setAddress(zkAddress);
        registryConfig.setGroup(dubboGroup);
        reference.setApplication(applicationConfig);
        reference.setRegistry(registryConfig);
        // 设置调用的reference属性，下面只设置了协议、接口名、版本、超时时间
        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 中获取相关的参数，组装后，调用相关的接口
        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();
            //当出现异常时,将异常显示到结果树
            sr.setResponseMessage(e.getMessage());
        }
        return sr;
    }

    public void teardownTest(JavaSamplerContext arg0) {

    }
}

打包操作

打包

左侧窗口为生成的jar包和lib目录

jar包位置

这里要说明下,网上提供了一种方式,通过修改安装目录bin下jmeter.properties文件关联lib下的依赖
文件中增加如下(通过尝试,这么做会导致jmeter启动由于jar包加载顺序的问题,ui部分控件不可用)

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

这里我使用的是另一种更为简便的方式
将原安装目录lib下ext修改为extbak
新建ext,并将工程lib下的jar包和dobbo-jmeter-interface-1.0-SNAPSHOT.jar放入之
由于可能会用到随机函数,从extbak获取ApacheJMeter_functions.jar,也放入到新建的ext目录下
重启jmeter,稍等片刻

添加java请求

添加java请求
参数说明

添加结果树

结果树

点击运行后,结果树信息如下

结果树返回

后续可自行配置断言和随机参数等