使用dubbo-go搭建dubbo接口测试平台

简介: 作为接口测试平台,没办法引入所有提供方定义的接口jar包,可以有以下方案来解决:dubbo支持telnet协议调用dubbo接口dubbo的泛化调用可以在不引入提供方接口定义jar包的情况下对接口进行调用

背景


http接口测试只需要一个curl命令,但dubbo协议没有这样的现成接口测试工具。通常公司内的dubbo控制台或其他平台会集成一个dubbo接口测试工具。


调用一个dubbo接口,需要知道服务名service、方法名method和参数args


正常的调用,调用方需引入服务提供方定义的接口jar包。


作为接口测试平台,没办法引入所有提供方定义的接口jar包,可以有以下方案来解决:


  1. dubbo支持telnet协议调用dubbo接口
  2. dubbo的泛化调用可以在不引入提供方接口定义jar包的情况下对接口进行调用


对于方案1,实现成本很低,甚至可以在服务器上直接用telnet测试


微信截图_20220423150340.png


它也有缺点


  • 调用无法经过filter
  • 无法携带隐式参数attachment

刚好我们把方案1的优缺点都踩了,我们的dubbo控制台是go语言编写,短时间快速实现,就采用了telnet的方式。


随着业务的发展,流量染色,或标签路由等需要携带隐式参数。


没有走自定义filter,导致业务接口执行不符合预期等都迫使我们升级为泛化调用。


dubbo接口泛化调用在控制台是go编写的情况下也有两个方案可选:


  1. 单独起一个java进程,暴露http端口,与go进程进行交互,泛化调用使用dubbo的java sdk进行编写
  2. 控制台引入dubbo-go,使用dubbo-go进行泛化调用


出于对dubbo java版本的了解,方案1肯定可行,只是架构变得复杂。


而方案2由于dubbo-go还是比较新的项目,并不是很了解,所以不确定其可行性和兼容性,但如果能实现,会大大降低架构的复杂度。


dubbo-go介绍


dubbo-go是dubbo的golang实现版本,它出现的初衷是为了让golang和java的dubbo生态互通。


如今dubbo-go支持provider和consumer端,可以作为一个独立的rpc框架使用,同时社区也是dubbo生态中最火的一个。


如果要说它的意义,我觉得除了和java互通外还有一点非常重要,那就是它能发挥golang协程的巨大作用,这一点可以用在dubbo网关上,如果用dubbo-go实现dubbo网关,就无需纠结线程池、异步等问题。


泛化调用的使用


首先provider端提供一个接口,这个不再赘述,非常简单,接口定义如下


package org.newboo.basic.api;
import org.newboo.basic.model.RpcResult;
import org.newboo.basic.model.User;
public interface MyDemoService {
    RpcResult<String> call(User user);
}
package org.newboo.basic.model;
import java.io.Serializable;
public class User implements Serializable {
    private String uid;
    private String name;
    private String remoteServiceTag;
    ...
}


再来编写java版的泛化调用代码,不引入provider方的jar包:


ReferenceConfig<GenericService> reference = new ReferenceConfig<>();
// ①引用服务名
reference.setInterface("org.newboo.basic.api.MyDemoService");
// ②设置泛化调用标志
reference.setGeneric("true");
DubboBootstrap bootstrap = DubboBootstrap.getInstance();
bootstrap.application(new ApplicationConfig("dubbo-demo-api-consumer"))
        .registry(new RegistryConfig("zookeeper://127.0.0.1:2181"))
        .reference(reference)
        .start();
GenericService genericService = ReferenceConfigCache.getCache().get(reference);
String[] ps = new String[1];
// ③参数类型
ps[0] = "org.newboo.basic.model.User";
Object[] ags = new Object[1];
// ④pojo参数使用map构造
Map<String, String> user = new HashMap<>();
user.put("uid", "1");
user.put("name", "roshi");
user.put("remoteServiceTag", "tag");
ags[0] = user;
// ⑤发起调用
Object res = genericService.$invoke("call", ps, ags);
System.out.println(res);


golang版本


var (
  appName         = "UserConsumer"
  referenceConfig = config.ReferenceConfig{
    InterfaceName: "org.newboo.basic.api.MyDemoService",
    Cluster:       "failover",
    // registry需要配置文件
    Registry:      "demoZk",
    Protocol:      dubbo.DUBBO,
    Generic:       true,
  }
)
func init() {
  referenceConfig.GenericLoad(appName) //appName is the unique identification of RPCService
  time.Sleep(1 * time.Second)
}
// need to setup environment variable "CONF_CONSUMER_FILE_PATH" to "conf/client.yml" before run
func main() {
  call()
}
func call() {
  // 设置attachment
  ctx := context.WithValue(context.TODO(), constant.AttachmentKey, map[string]string{"tag":"test"})
  resp, err := referenceConfig.GetRPCService().(*config.GenericService).Invoke(
    ctx,
    []interface{}{
      "call",
      []string{"org.newboo.basic.model.User"},
      []interface{}{map[string]string{"uid":"111","name":"roshi","remoteServiceTag":"hello"}},
    },
  )
  if err != nil {
    panic(err)
  }
  gxlog.CInfo("success called res: %+v\n", resp)
}


这里我设置了一个attachment,也能正常被provider识别


微信截图_20220423150804.png


泛化调用原理


泛化调用GenericService是dubbo默认提供的一个服务。


其提供了一个名为$invoke的方法,该方法参数有三个,第一个参数是真实要调用的方法名,第二个是参数类型数组,第三个是真实的参数数组,其定义为


public interface GenericService {
    Object $invoke(String method, String[] parameterTypes, Object[] args) throws GenericException;
    ...
}


有了这三个参数,利用反射就能调用到真实的接口了。


java版实现细节


实现这种泛化调用主要涉及到两个filter:

  • consumer端的GenericImplFilter
  • provider端的GenericFilter


consumer端的filter将generic标志设置到attachment中,并封装调用为

GenericService.$invoke


provider端filter判断请求是generic时进行拦截,获取调用方法名、参数、参数值,先序列化为pojo对象,再进行反射调用真实接口。


dubbo-go版细节


与java实现基本一致,其中generic_filter充当consumer端的filter,也是将调用封装为GenericService.$invoke,其中还涉及到一个参数类型的转换,将map转换为dubbo-go-hessian2.Object,这样provider端就可以将其反序列化为Object对象。


与其相关的版本变更如下

  • v1.3.0开始支持泛化调用
  • v1.4.0开始支持用户设置attachement
  • v1.5.1开始支持动态tag路由
  • v1.5.7-rc1修复了直连provider时无法走filter的bug


结论


dubbo-go的泛化调用推荐使用>=v1.5.7-rc1版本,其功能几乎已和java版打平,甚至其实现都与java类似。


使用dubbo-go构建网关、接口测试平台、或者打通golang与java技术生态,不失为一个好的选择。


相关文章
|
1天前
|
IDE 测试技术 Go
【字节跳动青训营】后端笔记整理-3 | Go语言工程实践之测试
用于验证已经修改或新增功能后,软件的既有功能是否受到影响。
49 2
|
14天前
|
数据挖掘 测试技术 网络安全
LabVIEW开发卫星测试平台
LabVIEW开发卫星测试平台
15 3
|
14天前
|
算法 物联网 5G
LabVIEW开发最小化5G系统测试平台
LabVIEW开发最小化5G系统测试平台
21 0
|
14天前
|
消息中间件 测试技术 Linux
linux实时操作系统xenomai x86平台基准测试(benchmark)
本文是关于Xenomai实时操作系统的基准测试,旨在评估其在低端x86平台上的性能。测试模仿了VxWorks的方法,关注CPU结构、指令集等因素对系统服务耗时的影响。测试项目包括信号量、互斥量、消息队列、任务切换等,通过比较操作前后的时戳来测量耗时,并排除中断和上下文切换的干扰。测试结果显示了各项操作的最小、平均和最大耗时,为程序优化提供参考。注意,所有数据基于特定硬件环境,测试用例使用Alchemy API编写。
70 0
linux实时操作系统xenomai x86平台基准测试(benchmark)
|
14天前
|
传感器 Linux 测试技术
xenomai 在X86平台下中断响应时间测试
该文讨论了实时操作系统中断响应时间的重要性,并介绍了x86中断机制和Xenomai的中断管理,包括硬件中断和虚拟中断的处理。Xenomai通过I-Pipe确保实时性,中断优先级高的Xenomai先处理中断。文中还提到了中断响应时间的测试设计,分别针对I-Pipe内核间虚拟中断和硬件中断进行了测试,并给出了在不同负载下的测试结果。
14 0
xenomai 在X86平台下中断响应时间测试
|
14天前
|
Linux 测试技术 数据安全/隐私保护
CentOS安装MeterSphere并实现无公网IP远程访问本地测试平台
CentOS安装MeterSphere并实现无公网IP远程访问本地测试平台
|
14天前
|
安全 测试技术 Go
Golang深入浅出之-Go语言单元测试与基准测试:testing包详解
【4月更文挑战第27天】Go语言的`testing`包是单元测试和基准测试的核心,简化了测试流程并鼓励编写高质量测试代码。本文介绍了测试文件命名规范、常用断言方法,以及如何进行基准测试。同时,讨论了测试中常见的问题,如状态干扰、并发同步、依赖外部服务和测试覆盖率低,并提出了相应的避免策略,包括使用`t.Cleanup`、`t.Parallel()`、模拟对象和检查覆盖率。良好的测试实践能提升代码质量和项目稳定性。
18 1
|
14天前
|
人工智能 监控 数据处理
【AI大模型应用开发】【LangSmith: 生产级AI应用维护平台】1. 快速上手数据集与测试评估过程
【AI大模型应用开发】【LangSmith: 生产级AI应用维护平台】1. 快速上手数据集与测试评估过程
46 0
|
14天前
|
JSON 测试技术 Go
《Go 简易速速上手小册》第6章:错误处理和测试(2024 最新版)(下)
《Go 简易速速上手小册》第6章:错误处理和测试(2024 最新版)
45 0
|
14天前
|
SQL 安全 数据库连接
《Go 简易速速上手小册》第6章:错误处理和测试(2024 最新版)(上)
《Go 简易速速上手小册》第6章:错误处理和测试(2024 最新版)
48 1

热门文章

最新文章