开发配置:
咱们用python调用的时候,hessian+http这种方式调用,需要安装一个第三方模块,python-hessian这个模块
1、先找到调用地址、接口、方法。
dubbo是带有服务监控的功能的,这个都有,管开发要地址就行,这个里面可以看到你要测的服务,他里面的地址、方法,如下图,我们可以看到在dubbo服务监控里面有个HelloApi的服务:
然后我们带点这个服务进去,就可以看到这个服务是部署在哪个服务器上的,然后点这个服务器的ip进去,就可以看到调用地址、接口、和方法,分别是:
调用地址:http://192.168.1.100:8181/api/yz.dubbo.api.HelloApi ,#那个页面里写的是hessian,咱们用的是http协议发送的,这里咱们用的时候就改成http
方法:hello
如下图:
2、找到入参对象和入参
通过dubbo的服务监控,我们可以获得调用地址、接口,入参对象和入参就得看代码了,我们打开项目代码,看到入参类型是在yz.dubbo.api下面的param包里面的Param对象,那么入参对象就是yz.dubbo.api.param.Param,然后我们可以看到这个对象里面有几个属性,也就是它的入参,一个字符串类型的sth,一个整形数组ints,一个字符串键值对maps,对应到咱们python的数据类型就是一个字符串,一个list,一个字典。
入参对象:yz.dubbo.api.param.Param
入参:sth、ints、maps
3、调用
通过上面的东西,咱们调用的dubbo需要用到的东西全部都准备好了,咱们封装一个函数去调用,下面是代码,写好了注释
from pyhessian.clientimport HessianProxy
# 从pyhessian导入HessianProxy,用它来发请求
from pyhessianimport protocol
# 这个是用来进行把咱们python的数据类型序列化成二进制的
def dubbo_api(url, interface, method, param_obj, **kwargs):
'''
:paramurl: url地址
:paraminterface: 接口名称,因为这里可能还有别的服务要测,接口名不一样,这里定义成变量
:parammethod: 调用哪个方法
:paramparam_obj: 入参的对象
:paramkwargs: 这个用关键字参数,因为每个接口的参数都不一样,不固定,所以这里用关键字参数
:return:
'''
req_param = protocol.object_factory(param_obj, **kwargs)
# 这个是用来构造二进制的入参的,也就是把入参序列化
try:# 用try捕捉一下异常
req_obj = HessianProxy(url + interface)
# 这个req是生成一个请求对象
res =getattr(req_obj, method)(req_param)
# getattr是python的内置方法,获取对象的方法,咱们从构造的请求对象里面获取到方法,然后调用,把前面生成的
# 序列化好的参数传进去,然后获取到返回的数据
except Exception as e:
print('有异常了,异常信息是:%s' % e)
res = {"msg":"异常:%s" % e, "code":300}
# 这个是自己定义的异常,如果调用出错了,就返回这个
return res
if __name__ =='__main__':
url ='http://192.168.1.100:8181/api/'
interface ='yz.dubbo.api.HelloApi'
method ='hello'
param_obj ='yz.dubbo.api.param.Param'
params = {"sth":"dubbo", "ints": [1, 2, 3], "maps": {"name":"dubbo"}}
# 这个入参,为了不定义多个变量,咱们把它写成字典形式的,就和stu=dubbo这种方式调用是一样的
over = dubbo_api(url, interface, method, param_obj, **params)
# 测试调用一下
print(over)# 打印结果
运行结果看下图: