Dubbo的架构及用法
1. 介绍
Dubbo |ˈdʌbəʊ| 是阿里下的一个分布式、高性能、透明化的RPC服务框架,提供服务自动注册、自动发现等高效服务治理方案的开源框架。
1.1. RPC需要解决的问题
1.1.1. 通讯问题
主要是通过在客户端和服务器之间建立TCP连接,远程过程调用的所有交换的数据都在这个连接里传输。连接可以是按需连接,调用结束后就断掉,也可以是长连接,多个远程过程调用共享同一个连接。
1.1.2. 寻址问题
A服务器上的应用怎么告诉底层的RPC框架,如何连接到B服务器(如主机或IP地址)以及特定的端口,方法的名称是什么,这样才能完成调用。比如基于Web服务协议栈的RPC,就要提供一个endpoint URI,或者是从UDDI服务上查找。如果是RMI调用的话,还需要一个RMI Registry来注册服务的地址。
1.1.3. 序列化与反序列化
当A服务器上的应用发起远程过程调用时,方法的参数需要通过底层的网络协议如TCP传递到B服务器,由于网络协议是基于二进制的,内存中的参数的值要序列化成二进制的形式,也就是序列化(Serialize)或编组(marshal),通过寻址和传输将序列化的二进制发送给B服务器。
同理,B服务器接收参数要将参数反序列化。B服务器应用调用自己的方法处理后返回的结果也要序列化给A服务器,A服务器接收也要经过反序列化的过程。
2. Dubbo架构
2.2. Dubbo注册中心
Ø Multicast注册中心
Ø Zookeeper注册中心
Ø Redis注册中心
Ø Simple注册中心
2.3. 协议
Dubbo缺省协议采用单一长连接和NIO异步通讯,适合于小数据量大并发的服务调用,以及服务消费者机器数远大于服务提供者机器数的情况。
<dubbo:protocol name="dubbo" port="20880" />
URL格式:
dubbo://username:password@host:port/path?key=value&key=value
3. Dubbo优点
Ø 透明化的远程方法调用,就像调用本地方法一样调用远程方法,只需简单配置,没有任何API侵入。
Ø 软负载均衡及容错机制,可在内网替代F5等硬件负载均衡器,降低成本,减少单点。
Ø 服务自动注册与发现,不再需要写死服务提供方地址,注册中心基于接口名查询服务提供者的IP地址,并且能够平滑添加或删除服务提供者。
Ø 服务接口监控与治理
Dubbo-admin与Dubbo-monitor提供了完善的服务接口管理与监控功能,针对不同应用的不同接口,可以进行 多版本,多协议,多注册中心管理。
4. 推荐用法
4.1. 在Provider上尽量多配置Consumer端属性
Ø timeout 方法调用超时
Ø retries 失败重试次数,缺省是2(表示加上第一次调用,会调用3次)
Ø loadbalance 负载均衡算法(有多个Provider时,如何挑选Provider调用),缺省是随机(random)。还可以有轮询(roundrobin)、最不活跃优先(leastactive,指从Consumer端并发调用最好的Provider,可以减少的反应慢的Provider的调用,因为反应更容易累积并发的调用)
Ø actives 消费者端,最大并发调用限制,即当Consumer对一个服务的并发调用到上限后,新调用会Wait直到超时。 在方法上配置(dubbo:method)则并发限制针对方法,在接口上配置(dubbo:service),则并发限制针对服务。
4.2. Provider上配置合理的Provider端属性
Ø threads 服务线程池大小
Ø executes 一个服务提供者并行执行请求上限,即当Provider对一个服务的并发调用到上限后,新调用会Wait(Consumer可能到超时)。在方法上配置(dubbo:method )则并发限制针对方法,在接口上配置(dubbo:service),则并发限制针对服务。
4.3. 配置上Dubbo缓存文件
提供者列表缓存文件
<dubbo:registry file=”${user.home}/output/dubbo.cache” />
4.4. 配置优先级
Ø 方法级优先,接口级次之,全局配置再次之。
Ø 如果级别一样,则消费方优先,提供方次之。
4.5. 推荐XML配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!-- 提供方应用信息,用于计算依赖关系 -->
<dubbo:application name="ops-provider"/>
<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880"/>
<!-- 设置服务方统一参数 -->
<dubbo:provider timeout="60000" retries="0" accesslog="true"/>
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.**.api.UserInfoService" ref="userInfoService"/>
</beans>
5. Dubbo服务划分
1、接口尽可能大粒度,接口中的方法不要以业务流程来,这个流程尽量在方法逻辑中调用,接口应代表一个完整的功能对外提供;
2、接口应以业务为单位,业务相近的进行抽象,避免接口数量爆炸
3、参数先做校验,在传入接口。
4、要做到在设计接口时,已经确定这个接口职责、预测调用频率
6. Dubbo服务高级特性
1、启动检查
在启动某服务时,先检查该服务所依赖的服务是否可用,不可用则抛出异常,以便上线时,能及早发现问题,默认check=“true”;
2、负载均衡
针对某一方法在db管控台进行配置
负载算法:随机(Random LoadBalance)、轮循(RoundRobin)、最少活跃调用数(LeastActive ,越活跃接收请求的概率越大)、一致性hash(ConsistentHash )
3、线程模型:threadpool threads
最大线程数计算方式 ulimit -u命令计算服务器可执行最大线程数
4、只订阅
只订阅服务,自己不注册,例如该服务正在测试,先不能向zk中注册避免其他服务调用它报错
5、只注册
只注册服务,不订阅;应用在集群中该服务器上无该服务需要调用的服务,就让他只注册,指定调用其它服务器上的可用服务