Telnet 测试 Dubbo 服务,用Python3调用dubbo服务接口

一、Telnet 命令参考手册

Dubbo 服务发布之后,我们可以利用telnet命令进行调试、管理。

QQ20191204-211222@2x.png

Dubbo 2.0.5 以上版本服务提供端口支持 telnet 命令,使用方式:telnet localhost 20880

Telnet命令参考手册:http://alibaba.github.io/dubbo-doc-static/Telnet+Command+Reference-zh-showComments=true&showCommentArea=true.htm

ls 命令

  • ls:显示服务列表

  • ls -l:显示服务详细信息列表

  • ls XxxService:显示服务的方法列表

  • ls -l XxxService:显示服务的方法详细信息列表

ps 命令

  • ps:显示服务端口列表

  • ps -l:显示服务地址列表

  • ps 20880:显示端口上的连接信息

  • ps -l 20880:显示端口上的连接详细信息

cd 命令 (change default service)

  • cd XxxService:改变缺省服务,当设置了缺省服务,凡是需要输入服务名作为参数的命令,都可以省略服务参数。

  • cd /:取消缺省服务。

pwd 命令 (print working default service)

  • pwd:显示当前缺省服务。

trace 命令

  • trace XxxService:跟踪 1 次服务任意方法的调用情况

  • trace XxxService 10:跟踪 10 次服务任意方法的调用情况

  • trace XxxService xxxMethod:跟踪 1 次服务方法的调用情况

  • trace XxxService xxxMethod 10:跟踪 10 次服务方法的调用情况

count 命令

  • count XxxService:统计1次服务任意方法的调用情况。

  • count XxxService 10:统计10次服务任意方法的调用情况。

  • count XxxService xxxMethod:统计1次服务方法的调用情况。

  • count XxxService xxxMethod 10:统计10次服务方法的调用情况。

invoke 命令

  • invoke XxxService.xxxMethod({"prop": "value"}):调用服务的方法。

  • invoke xxxMethod({"prop": "value"}):调用服务的方法(自动查找包含此方法的服务)。

  • invoke XxxService.xxxMethod(["xxx","xxx"]):调用list,array参数方法

  • invoke ArtisanService.queryArtisans({"class":"com.xxx.user.api.model.ArtisanQuery", "status": "1", "type": "1", "city": "5306", "offset": 0, "rows": 3}):调用对象

比如StudentService.save这种方法。则需要将入参转换成json串,然后在json串中补上“class”一项,用于InvokeTelnetHandler类进行转换。

status 命令

  • status:显示汇总状态,该状态将汇总所有资源的状态,当全部OK时则显示OK,只要有一个ERROR则显示ERROR,只要有一个WARN则显示WARN。

  • status -l:显示状态列表。

log 命令

2.0.6以上版本支持

  • log debug:修改dubbo logger的日志级别

  • log 100:查看file logger的最后100字符的日志

help 命令

  • help:显示telnet命帮助信息。

  • help xxx:显示xxx命令的详细帮助信息。

clear 命令

  • clear:清除屏幕上的内容。

  • clear 100:清除屏幕上的指定行数的内容。

exit 命令

exit:退出当前telnet命令行。

二、利用python3调用dubbo服务接口

1、telnet 查看 dubbo 服务

dubbo>ls -l ArtisanService
com.xxx.user.api.model.ArtisanModel getArtisanById(java.lang.String)
java.util.List getArtisansByIds(java.util.List)
java.util.List queryArtisans(com.xxx.user.api.model.ArtisanQuery)

接下来使用python方式分别调用上面的三个方法

2、python 调用 dubbo 服务

# -*- coding: utf-8 -*-

import json
import telnetlib


class Dubbo(telnetlib.Telnet):
    prompt = 'dubbo>'
    coding = 'utf-8'

    def __init__(self, host=None, port=0):
        super().__init__(host, port)
        # 触发dubbo提示符
        self.write(b'\n')

    def command(self, flag, str_=""):
        data = self.read_until(flag.encode())
        self.write(str_.encode() + b"\n")
        return data

    def invoke(self, service_name, method_name, arg):
        self.command(Dubbo.prompt, "invoke {0}.{1}({2})".format(service_name, method_name, json.dumps(arg)))
        data = self.command(Dubbo.prompt, "")
        data = data.decode(Dubbo.coding, errors='ignore').split('\n')[0].strip()

        # 终止Telnet连接
        self.close()
        return data

    def do(self, arg):
        self.command(Dubbo.prompt, arg)
        data = self.command(Dubbo.prompt, arg)
        data = data.decode(Dubbo.coding, errors='ignore').split('\n')[0].strip()

        # 终止Telnet连接
        self.close()
        return data


if __name__ == '__main__':
    conn = Dubbo('172.0.0.1', 20880)

    # 调用方式1:格式invoke 接口全名字.方法名(参数1,参数2,参数3...参数n)
    # invoke_str = 'invoke com.xxx.user.api.service.ArtisanService.getArtisanById("7b988f3ba005466eba12f5852b15ad0e")'
    # invoke_str = 'invoke ArtisanService.getArtisanById("7b988f3ba005466eba12f5852b15ad0e")'
    invoke_str = 'invoke getArtisanById("7b988f3ba005466eba12f5852b15ad0e")'
    result = conn.do(invoke_str)
    # print(result)
    # eval 把 str 转换 dict,indent 缩进空格数量,ensure_ascii 显示中文
    print(json.dumps(eval(result), indent=4, ensure_ascii=False))

    # 调用方式2:
    # service_name = 'com.xxx.user.api.service.ArtisanService'
    # service_name = 'ArtisanService'
    # method_name = 'getArtisanById'
    # arg = '7b988f3ba005466eba12f5852b15ad0e'
    # result = conn.invoke(service_name, method_name, arg)

    # 调用list参数
    # invoke_str = 'invoke ArtisanService.getArtisansByIds(["7b988f3ba005466eba12f5852b15ad0e", "000e67027e9b44fa978800e8e7f7ea98"])'
    # result = conn.do(invoke_str)

    # 调用object对象
    # param = {
    #     "class": "com.helijia.user.api.model.ArtisanQuery",
    #     "status": "1",
    #     "type": "1",
    #     "city": "5306",
    #     "offset": 0,
    #     "rows": 3
    # }
    # invoke_str = 'invoke ArtisanService.queryArtisans(' + str(param) + ')'
    # invoke_str = 'invoke ArtisanService.queryArtisans({"class":"com.xxx.user.api.model.ArtisanQuery", "status": "1", "type": "1", "city": "5306", "offset": 0, "rows": 3})'
    # print(invoke_str)
    # result = conn.do(invoke_str)

说明

1、调用方式

# 以下三种方式调用结果相同
invoke_str = 'invoke com.xxx.user.api.service.ArtisanService.getArtisanById("7b988f3ba005466eba12f5852b15ad0e")'
invoke_str = 'invoke ArtisanService.getArtisanById("7b988f3ba005466eba12f5852b15ad0e")'
invoke_str = 'invoke getArtisanById("7b988f3ba005466eba12f5852b15ad0e")'

2、json结果缩进

# eval 把 str 转换 dict,indent 缩进空格数量,ensure_ascii 显示中文
print(json.dumps(eval(result), indent=4, ensure_ascii=False))

结果

{
    "artisanCode": "18aar10196",
    "artisanGlory": 0,
    "artisanId": "xxx",
    "artisanLevel": 10,
    "averagePrice": 170.0,
    "bankCardno": "xxx",
    "bankCity": "北京市",
    "bankDeposit": "xx美甲",
    "bankType": "95588",
    "cardholder": "白鲸",
    "certificationFlag": 0,
    "checkBankStatus": 2,
    "city": 2,
    "commentCount": 0,
    "constellation": "巨蟹座",
    "createDate": xxx,
    "dataIsNew": 0,
    "description": "老娘的美甲,天下第一!无敌!",
    "email": "sjsjjsjsjsh@163.com",
    "fastEnterFlag": 2,
    "favCount": 8,
    "gender": 1,
    ...
}

3、请求参数是集合,数组

invoke_str = 'invoke ArtisanService.getArtisansByIds(["7b988f3ba005466eba12f5852b15ad0e", "000e67027e9b44fa978800e8e7f7ea98"])'

4、请求参数是对象

invoke_str = 'invoke ArtisanService.queryArtisans({"class":"com.xxx.user.api.model.ArtisanQuery", "status": "1", "type": "1", "city": "5306", "offset": 0, "rows": 3})'

# 等同于
param = {
    "class": "com.xxx.user.api.model.ArtisanQuery",
    "status": "1",
    "type": "1",
    "city": "5306",
    "offset": 0,
    "rows": 3
}
invoke_str = 'invoke ArtisanService.queryArtisans(' + str(param) + ')'

补充

有了telnet终端,为什么我们还需要python方式来调用呢?

优势1:终端不允许左右键盘控制指定输入某一个字符,会变成乱码符号,而python就像编辑文本文件一样方便

优势2:终端不支持输入中文参数,会变成乱码符号,如下代码,而python却可以。

dubbo>invoke ArtisanService.queryArtisans({"class":"com.xxx.user.api.model.ArtisanQuery", "status": "1", "type": "1", "city": "5306", "offset": 0, "rows": 3, "nick": "QAi^G
e:^Fg>^Ng2"})Unsupported command: ��invoke
dubbo>
Unsupported command: e:g>g2"})
dubbo>

python方式

param = {
    "class": "com.xxx.user.api.model.ArtisanQuery",
    "status": "1",
    "type": "1",
    "city": "5306",
    "nick": "重庆美甲",
    "offset": 0,
    "rows": 3
}


未经允许请勿转载:程序喵 » Telnet 测试 Dubbo 服务,用Python3调用dubbo服务接口

点  赞 (1) 打  赏
分享到: