关于 Dubbo

Dubbo 是阿里巴巴公司开源的一个优秀的 Java 高性能服务框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和 Spring 框架无缝集成，随着近几年微服务架构的兴起，因为其理念很契合微服务，在国内有着比较广泛的用户群体。

Dubbo 架构

使用 MeterSphere 进行 Dubbo 接口测试 - 图1

节点角色说明

  • Provider：暴露服务的服务提供方
  • Consumer：调用远程服务的服务消费方
  • Registry：服务注册与发现的注册中心
  • Monitor：统计服务的调用次数和调用时间的监控中心
  • Container：服务运行容器

调用关系说明

  1. 服务容器负责启动，加载，运行服务提供者。
  2. 服务提供者在启动时，向注册中心注册自己提供的服务。
  3. 服务消费者在启动时，向注册中心订阅自己所需的服务。
  4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
  5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
  6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

部署 Dubbo 服务

要针对 Dubbo 接口进行测试，首先我们需要有一套基于 Dubbo 框架的应用系统。这里我准备了一个使用了 Dubbo 框架的 SpringBoot Demo 应用来进行说明，项目地址：https://github.com/metersphere/dubbo-docker（在此感谢下 原项目 作者 binblee 提供的项目）。如果大家自己已经有了现成的基于 Dubbo 框架的应用，可以忽略掉这一部分。

应用整体比较简单，只提供了如下的一个接口两个方法。

  1. package com.example.service.producer;
  3. import com.example.service.Greetings;
  4. import com.example.service.User;
  6. /**
  7.  * Created by libin on 9/19/16.
  8.  */
  9. public class GreetingsImpl implements Greetings {
  10.     public String say(String name) {
  11.         return "Greetings from " + name;
  12.     }
  14.     public String hello(User user) {
  15.         return "Name: "+user.name+", Age: "+user.age+", Gender: "+user.gender;
  16.     }
  17. }

项目的启动方式在 GitHub 上的 README 中已经有说明了，在此就不再赘述。当我们将项目运行起来以后，通过 HTTP GET 方法请求下 consumer 的 / 路径，可以看到 consumer 给我们返回了如下信息，说明 provider 是可以正常提供服务的。

  1. [~/Documents/workspace/dubbo-docker/docker]# curl http://localhost:8899
  2. Greetings from Dubbo Docker

常见的 Dubbo 接口测试方法

像 Dubbo 这样的 RPC 框架，其提供的接口更多是一个应用系统之间各个组件/服务内部通信使用的，不像基于 HTTP 的接口那样，其实可选择的测试工具不是特别多。 根据我自己的经验，一般有如下几种方式来进行 Dubbo 接口的测试，如果大家有其他更好的方式和工具，欢迎联系作者进行补充。

  • 自己写 Java 或 Python 等代码注册成一个 consumer 调用服务进行测试
  • 像上面例子里的 consumer 一样，由开发团队把需要测试的接口再包装成 HTTP 接口，通过测试 HTTP 接口测手段进行测试
  • 在测试环境中通过官方提供的 telnet 命令，直接 invoke 特定服务进行测试
  1. [~/Documents/workspace/dubbo-docker]# telnet localhost 20880
  2. Trying ::1...
  3. Connected to localhost.
  4. Escape character is '^]'.
  6. dubbo>ls
  7. com.example.service.Greetings
  8. dubbo>ls com.example.service.Greetings
  9. say
  10. hello
  11. dubbo>invoke com.example.service.Greetings.say("Tom")
  12. "Greetings from Tom"
  13. elapsed: 0 ms.
  14. dubbo>
  • 使用 JMeter 配合 Dubbo Sampler 插件进行测试 使用 MeterSphere 进行 Dubbo 接口测试 - 图2

使用 MeterSphere 持续测试平台进行 Dubbo 接口测试

除了上面提到的方法以外，我们还可以使用 MeterSphere 这样的完全兼容 JMeter 的测试平台来进行 Dubbo 接口测试。关于 MeterSphere 的详细介绍及部署使用方式，可以参考下面提供的链接。在这篇文章中，我们只聚焦于使用 MeterSphere 进行 Dubbo 接口测试进行介绍。

准备工作

  • 已经部署了 MeterSphere 环境，并且有具有执行接口测试权限的账号
  • 准备 Dubbo 接口相关信息，包括注册中心连接信息、接口定义等
  • 如果使用了本文中提到的 Duboo Demo 项目，由于服务注册时的 IP 地址是 producer 容器的 IP，可能会出现调用不通的情况。这里我们通过 zk 命令手动地把这个 Demo 环境的 provider 信息改一下，把原来 provider 中的容器 IP 改为部署该 Demo 应用的主机 IP。
  1. [~/Documents/workspace/dubbo-docker/docker]# zkcli -s 192.168.2.170:2181
  2. 2020/08/06 18:55:25 Connected to 192.168.2.170:2181
  3. >>> ls /dubbo/com.example.service.Greetings/providers
  4. [dubbo%3A%2F%2F172.19.0.2%3A20880%2Fcom.example.service.Greetings%3Fanyhost%3Dtrue%26application%3Dproducer-app%26dubbo%3D2.5.3%26interface%3Dcom.example.service.Greetings%26methods%3Dsay%2Chello%26pid%3D1%26revision%3D1.0-SNAPSHOT%26side%3Dprovider%26timestamp%3D1596709972791]
  5. >>> delete /dubbo/com.example.service.Greetings/providers/dubbo%3A%2F%2F172.19.0.2%3A20880%2Fcom.example.service.Greetings%3Fanyhost%3Dtrue%26application%3Dproducer-app%26dubbo%3D2.5.3%26interface%3Dcom.example.service.Greetings%26methods%3Dsay%2Chello%26pid%3D1%26revision%3D1.0-SNAPSHOT%26side%3Dprovider%26timestamp%3D1596709972791
  6. Deleted /dubbo/com.example.service.Greetings/providers/dubbo%3A%2F%2F172.19.0.2%3A20880%2Fcom.example.service.Greetings%3Fanyhost%3Dtrue%26application%3Dproducer-app%26dubbo%3D2.5.3%26interface%3Dcom.example.service.Greetings%26methods%3Dsay%2Chello%26pid%3D1%26revision%3D1.0-SNAPSHOT%26side%3Dprovider%26timestamp%3D1596709972791
  7. >>> create /dubbo/com.example.service.Greetings/providers/dubbo%3A%2F%2F192.168.2.170%3A20880%2Fcom.example.service.Greetings%3Fanyhost%3Dtrue%26application%3Dproducer-app%26dubbo%3D2.5.3%26interface%3Dcom.example.service.Greetings%26methods%3Dsay%2Chello%26pid%3D1%26revision%3D1.0-SNAPSHOT%26side%3Dprovider%26timestamp%3D1596709972791
  8. Created /dubbo/com.example.service.Greetings/providers/dubbo%3A%2F%2F192.168.2.170%3A20880%2Fcom.example.service.Greetings%3Fanyhost%3Dtrue%26application%3Dproducer-app%26dubbo%3D2.5.3%26interface%3Dcom.example.service.Greetings%26methods%3Dsay%2Chello%26pid%3D1%26revision%3D1.0-SNAPSHOT%26side%3Dprovider%26timestamp%3D1596709972791
  9. >>>

创建项目

登录 MeterSphere 平台后，点击在上方菜单中选择「接口测试」，在项目列表中点击「创建项目」 使用 MeterSphere 进行 Dubbo 接口测试 - 图3

创建接口测试

点击界面上方中央的【创建测试按钮】，创建新的接口测试集 使用 MeterSphere 进行 Dubbo 接口测试 - 图4

在接口测试创建页面选择该测试所属的项目，并填入接口测试集名称 使用 MeterSphere 进行 Dubbo 接口测试 - 图5

配置场景信息

点击左侧场景列表中的场景配置，在右侧的场景信息中，填入场景名称，并选择「Dubbo 配置」标签页。

在该页面中把准备的注册中心连接信息，接口版本等信息填好。 使用 MeterSphere 进行 Dubbo 接口测试 - 图6

  1.   在场景中配置的变量、HTTP 请求头、Dubbo 配置等信息试用于该场景下的所有请求

添加 Dubbo 请求

点击左侧场景列表中添加请求按钮，选择 Dubbo 类型的接口进行添加 使用 MeterSphere 进行 Dubbo 接口测试 - 图7

填写该请求的名称后，点击「Get Providers List」从注册中心中获取服务列表，从下拉列表中选择需要测试的接口及方法，根据该方法的定义，传入所需的参数 使用 MeterSphere 进行 Dubbo 接口测试 - 图8

上面添加的接口只有一个 String 类型的参数，再次添加一个参数类型为自定义类的请求。这里我们查看一下代码中这个接口的定义，发现其需要一个 User 类的对象作为参数

  1. package com.example.service;
  3. /**
  4.  * Created by libin on 9/19/16.
  5.  */
  6. public interface Greetings {
  7.     String say(String name);
  8.     String hello(User user);
  9. }

同时结合 User 类的定义

  1. package com.example.service;
  3. enum Gender {
  4.     MALE, FEMALE;
  5. }
  7. public class User {
  8.     public String name;
  9.     public Integer age;
  10.     public Gender gender;
  11. }

我们可以通过这样的形式传入参数值 {“name”:”姓名”, “age”:年龄, “gender”: “MALE 或 FEMALE”} 使用 MeterSphere 进行 Dubbo 接口测试 - 图9

当接口请求都添加完成后，我们先把默认添加的那个 HTTP 请求删掉，然后就可以点击「保存并执行」按钮进行 Dubbo 接口的测试了 使用 MeterSphere 进行 Dubbo 接口测试 - 图10

查看报告

测试执行完成后，即可在页面上查看到测试执行的结果报告 使用 MeterSphere 进行 Dubbo 接口测试 - 图11

点击报告中的场景及请求，可查看到请求的详细内容及响应内容 使用 MeterSphere 进行 Dubbo 接口测试 - 图12

转化为性能测试

接口测试执行通过后，我们还可以通过 MeterSphere 提供的接口测试转性能测试的功能，直接发起针对 Dubbo 接口的性能测试。

在「接口测试」页面的「测试」下拉列表中，选择我们刚创建的测试，点击更多操作中的「创建性能测试」选项 使用 MeterSphere 进行 Dubbo 接口测试 - 图13

在弹出的页面中根据需求配置压力参数后，点击「保存并执行」按钮即可发起性能测试 使用 MeterSphere 进行 Dubbo 接口测试 - 图14