接口测试平台：Dubbo接口支持(旧版已废弃)

爱被打了一巴掌 2023-06-20 10:49 122阅读 0赞

Dubbo具体的Java调用方式可以参考这篇文章《Dubbo接口泛化调用》。

列表展示大概如下：
在这里插入图片描述
前端配置页，则是对入参进行二次封装。
在这里插入图片描述
返回结果的处理部分，与http请求基本一致
在这里插入图片描述
bean文件

  1. @Data
  2. public class DubboCase {
  4.     /** 主键id */
  5.     private int id;
  7.     /** 创建人 */
  8.     private String createrName;
  10.     /** 创建人code */
  11.     private String createrCode;
  13.     /** 创建时间 */
  14.     @JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
  15.     private Date createDate;
  17.     /** 更新人 */
  18.     private String updaterName;
  20.     /** 更新人 */
  21.     private String updaterCode;
  23.     /** 更新时间 */
  24.     @JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
  25.     private Date updateDate;
  27.     /** 所属系统名称 */
  28.     private String systemName;
  30.     /** 前端填写的apiName */
  31.     private String apiName;
  33.     /** 传给dubbo服务器的接口名 */
  34.     private String apiNameValue;
  36.     /** zookeeper地址 */
  37.     private String zkAddress;
  39.     /** 服务名 */
  40.     private String serviceName;
  42.     /** 分组 */
  43.     private String groupName;
  45.     /** zookeeper版本 */
  46.     private String version;
  48.     /** 入参 */
  49.     private String params;
  51.     /** 函数名 */
  52.     private String functionName;
  54.     /** 类名 */
  55.     private String className;
  57.     /** 备注 */
  58.     private String description;
  60.     /** 需要保存的变量 */
  61.     private String variableListValue;
  62.     private List<VariableSave> variableList;
  64.     /** 校验方式 */
  65.     private String expectedListValue;
  66.     private List<Expected> expectedList;
  68.     /** 最后一次请求状态 */
  69.     private Boolean status;
  71.     /** 响应结果 */
  72.     private String result;
  73. }

service层
与http请求的处理基本一致，都是逐条case遍历进行处理，区别在于String result = ApiTestUtils.doDubboRequest(dubboCase);

  1. @Override
  2.     public ResponseVo excuteRequest(Integer[] ids) {
  4.         ResponseVo responseVo = new ResponseVo();
  6.         // 全局变量赋值
  7.         List<Variable> variableList = apiTestConfigMapper.selectGlobalVariable();
  8.         for (Variable variable:variableList){
  9.             ApiTestConfig.globalVariableMap.put(variable.getVariableName(), variable.getVariableValue());
  10.         }
  12.         // 获取当前选中的所有case
  13.         List<DubboCase> caseList = dubboCaseMapper.selectDubboCaseListByIds(ids);
  14.         // 遍历caseList，进行http请求
  15.         for (DubboCase dubboCase :caseList){
  17.             String result = ApiTestUtils.doDubboRequest(dubboCase);
  19.             // 保存变量
  20.             ApiTestUtils.saveVariable(result, dubboCase.getVariableListValue(), ApiTestConfig.GLOBAL_COLLECTION_ID);
  22.             // 判断是否通过了所有校验条件
  23.             if (ApiTestUtils.verifyResult(result, dubboCase.getExpectedListValue(), ApiTestConfig.GLOBAL_COLLECTION_ID)){
  24.                 dubboCase.setStatus(Boolean.TRUE);
  25.             } else {
  26.                 dubboCase.setStatus(Boolean.FALSE);
  27.             }
  28.             // 给testCase的执行状态进行赋值
  29.             dubboCase.setResult(result);
  31.             // 更新数据库保存的信息
  32.             setJsonValue(dubboCase);
  33.             dubboCaseMapper.updateDubboCase(dubboCase);
  35.             // 将执行后的结果返回给前端
  36.             responseVo.setIsSuccess(Boolean.TRUE);
  37.             responseVo.setResult(dubboCase);
  39.         }
  40.         return responseVo;
  41.     }

ApiTestUtils

  1. public static String doDubboRequest(DubboCase dubboCase){
  3.         ApplicationConfig application = new ApplicationConfig();
  4.         application.setName(getVariable(dubboCase.getApiNameValue()));
  6.         // 连接注册中心配置
  7.         RegistryConfig registry = new RegistryConfig();
  8.         registry.setAddress(getVariable(dubboCase.getZkAddress()));
  10.         ReferenceConfig<GenericService> reference = new ReferenceConfig<>();
  11.         reference.setApplication(application);
  12.         reference.setRegistry(registry);
  13.         reference.setInterface(getVariable(dubboCase.getServiceName()));
  14.         // 声明为泛化接口
  15.         reference.setGeneric(true);
  16.         reference.setGroup(getVariable(dubboCase.getGroupName()));
  17.         reference.setVersion(getVariable(dubboCase.getVersion()));
  18.         try {
  19.             ReferenceConfigCache cache = ReferenceConfigCache.getCache();
  20.             GenericService genericService = cache.get(reference);
  22.             HashMap<String, Object> maps = EntityUtil.jsonToMap(getVariable(dubboCase.getParams()));
  24.             // 基本类型以及Date,List,Map等不需要转换，直接调用
  25.             Object result = genericService.$invoke(getVariable(dubboCase.getFunctionName()),
  26.                     new String[]{getVariable(dubboCase.getClassName())},
  27.                     new Object[]{maps});
  28.             return JSON.toJSONString(result);
  30.         } catch (Exception e) {
  31.             e.printStackTrace();
  32.         }
  34.         return null;
  35.     }

目前Dubbo请求只支持调试执行，最近考虑在场景执行里，支持http与dubbo的混合执行。emm，如果场景支持多类型接口了，可能顺便会把sql执行，显示等待，函数助手等功能都加进去。这样，预计开源时间会推迟到3月以后。
有疑问的小伙伴欢迎在文章下方留言，我会根据问题不断优化文章内容！

发表评论

表情：
评论列表 （有 0 条评论，122人围观）

还没有评论，来说两句吧...

相关阅读