测试开发：自学Dubbo+Python经验总结分享

Posted 2021-08-10 测试开发技术

1. 背景

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，需一个治理系统确保架构有条不紊的演进。

目前市场一些基本的架构：

• 单一应用架构
• 当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。
• 此时，用于简化增删改查工作量的 数据访问框架(ORM) 是关键。
• 垂直应用架构
• 当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。
• 此时，用于加速前端页面开发的 Web框架(MVC) 是关键。
• 分布式服务架构
• 当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。
• 此时，用于提高业务复用及整合的 分布式服务框架(RPC) 是关键。
• 流动计算架构
• 当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。
• 此时，用于提高机器利用率的 资源调度和治理中心(SOA) 是关键。

2. 介绍

Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的RPC实现服务的输出和输入功能，可以和spring框架无缝集成。

Dubbo是一款高性能，轻量级的开源Java RPC框架，他提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

3. 原理

3.1 核心

Remoting：网络通信框架，实现了sync-over-async和request-response消息机制。

RPC：一个远程过程调用的抽象，支持负载均衡，容灾和集群功能。

Registry：服务目录框架用于服务的注册和服务事件发布和订阅。

3.2 架构

节点角色

• Provider：暴露服务的服务提供方
• Consumer：调用服务的服务消费方
• Registry：服务注册与发现的注册中心
• Monitor：统计服务的调用次数和调用时间的监控中心
• Container：服务运行容器

调用关系

• 0、服务容器负责启动，加载，运行服务提供者
• 1、服务提供者在启动时，向注册中心注册自己提供的服务
• 2、服务消费者在启动时，向注册中心订阅自己所需的服务
• 3、注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者
• 4、服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用
• 5、服务消费者和提供者，在内存中累计调用次数和调用时间定时每分钟发送一次统计数据到监控中心

特点

连通性，健壮性，伸缩性，以及向未来架构的升级性。想要了解更多，可直接去官网查看：

https://dubbo.apache.org/zh/

4. 作用

1、透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。

2、软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器，降低成本，减少单点。

5. 利用Python库调试Dubbo

python想要实现dubbo接口的调用可以参考dubbo的官方文档中提到的：dubbo可以通过telnet命令进行服务治理，可以通过telnet链接dubbo服务，再通过invoke方法调用dubbo接口，详情见：

https://dubbo.apache.org/zh/docs/v2.7/user/references/telnet/

而在Python中有一个第三方包telnetlib，所以我们可以通过这个包来执行telnet命令，进而对dubbo接口进行调用。

注意：python版本为2.7

pip install dubbo_telnet

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

import dubbo_telnet
import json
Host = '192.168.0.1'  # Doubble服务器IP
Port = 9036  # Doubble服务端口

# 初始化dubbo对象
conn = dubbo_telnet.connect(Host, Port)

# 设置telnet连接超时时间
conn.set_connect_timeout(10)

# 设置dubbo服务返回响应的编码
conn.set_encoding('gbk')

# 显示服务列表
print conn.do("ls")

# 显示指定服务的方法列表
print conn.do("ls XXXService")

# 方法调用
interface = 'XXXService'
method = 'userinfo'
param = user_id
result = conn.invoke(interface, method, param)

print json.dumps(result, sort_keys=True, indent=4, separators=(',', ': '), skipkeys=True, ensure_ascii=False)

# 详见：https://hhyo.github.io/2017/10/20/python-dubbo-telnet/

推荐阅读

END

所有原创文章

第一时间发布至此公众号「测试开发技术」

长按二维码/微信扫码  添加作者

回复【百人计划】