最近公司开发新的一套系统,开发出来的方案会基于dubbo分布式服务框架开发的,那么什么是dubbo,身为测试的我,第一眼看到这个,我得去了解了解dubbo是啥玩意,为开展的测试工作做准备,提前先学 dubbo的相关知识
1.什么是dubbo
Dubbo是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。简单的说,dubbo就是个服务框架,如果没有分布式的需求,其实是不需要用的,只有在分布式的时候,才有dubbo这样的分布式服务框架的需求,并且本质上是个服务调用的东东
其核心部分包含:
1. 远程通讯: 提供对多种基于长连接的NIO框架抽象封装,包括多种线程模型,序列化,以及“请求-响应”模式的信息交换方式。
2. 集群容错: 提供基于接口方法的透明远程过程调用,包括多协议支持,以及软负载均衡,失败容错,地址路由,动态配置等集群支持。
3. 自动发现: 基于注册中心目录服务,使服务消费方能动态的查找服务提供方,使地址透明,使服务提供方可以平滑增加或减少机器。
Dubbo本身支持多种远程调用方式,例如Dubbo RPC(二进制序列化 + tcp协议)、http invoker(二进制序列化 + http协议)、hessian(二进制序列化 + http协议)、WebServices (文本序列化 + http协议)等。
2. Dubbo能做什么?
1.透明化的远程方法调用,就像调用本地方法一样调用远程方法,只需简单配置,没有任何API侵入。
2.软负载均衡及容错机制,可在内网替代F5等硬件负载均衡器,降低成本,减少单点。
3. 服务自动注册与发现,不再需要写死服务提供方地址,注册中心基于接口名查询服务提供者的IP地址,并且能够平滑添加或删除服务提供者。
3. dubbo的架构
Provider
暴露服务方称之为“服务提供者”。
Consumer
调用远程服务方称之为“服务消费者”。
Registry
服务注册与发现的中心目录服务称之为“服务注册中心”。
Monitor
统计服务的调用次数和调用时间的日志服务称之为“服务监控中心”。
调用关系说明:
0 服务容器负责启动,加载,运行服务提供者。
1. 服务提供者在启动时,向注册中心注册自己提供的服务。
2. 服务消费者在启动时,向注册中心订阅自己所需的服务。
3. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
4. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
5. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
以上均是dubbo框架的一些理论知识、那么了解了基础的知识,我们怎么来测试dubbo提供的接口呢。
遇到这个问题我也会咨询一些前辈,有人说java编写代码可以测试,但是需要的依赖多,有些人说基于python也是可以调用的,那么也是需要第三库来支持的,
我们可以去下载对应的python库,有的版本不支持python3 你可以下载下来源码,对源码中的一些代码格式调整到python3支持的格式就好。
我这里才用的是dubbo_telnet,下载安装后我们先测试下,看代码是否能够正常运行。
我们拿来了官方的例子。
import dubbo_telnet Host = '192.168.1.203' # Doubble服务器IP Port = 28008 # Doubble服务端口 # 初始化dubbo对象 conn = dubbo_telnet.connect(Host, Port) # 设置telnet连接超时时间 conn.set_connect_timeout(10) # 设置dubbo服务返回响应的编码 conn.set_encoding('gbk') interface = 'com.zrj.pay.trade.api.QueryTradeService'#接口 method = 'tradeDetailQuery'#方法 param = '{"message": "HelloWorld"}'#参数 print (conn.invoke(interface, method, param)) command = 'invoke com.zrj.pay.trade.api.QueryTradeService.tradeDetailQuery({"message":"HelloWorld"})' print (conn.do(command)) #打印接口返回结果
运行后,
这样我们的代码是没有问题的,由于我本地没有dubbo的服务,所以这里是返回None。
对于上述代码,我做了进一步的优化。
import dubbo_telnet def coondoubble_data(Host,Port,interface,method,param): try: # 初始化dubbo对象 conn = dubbo_telnet.connect(Host, Port) # 设置telnet连接超时时间 conn.set_connect_timeout(10) # 设置dubbo服务返回响应的编码 conn.set_encoding('gbk') conn.invoke(interface, method, param) command = 'invoke %s.%s(%s)'%(interface,method,param) return conn.do(command) except: return Exception if __name__=="__main__": Host = '192.168.1.203' # Doubble服务器IP Port = 28008 # Doubble服务端口 interface = 'com.zrj.pay.trade.api.QueryTradeService' # 接口 method = 'tradeDetailQuery' # 方法 param = '{"message": "HelloWorld"}' # 参数 data=coondoubble_data(Host,Port,interface,method,param) print(data)
可见,我们用python是能够调用出来我们的dubbo服务的,那么接下来就是根据现有的dubbo接口进行测试了,由于现在研发还没有进行一系列的开发,所以我打算先自己去尝试的按照网上例子写一个dubbo的例子,用作自己的测试。
dubbo的接口测试其实也不是那么难,只要我们肯下功夫,我们一定能够做成功的。dubbo接口。开始学起来。