Dubbo远程调用
通过代理对象进行远程方法的调用,从大的方面也可以分为三步,分别是代理调用、容错负载和远程通信。
容错负载是Dubbo的重要组成模块,该模块实现了多种集群特性,还实现了目录服务、负载均衡、路由策略和服务治理配置等特性。
Invoker是服务提供者(Provider)的抽象,Invoker封装了Provider地址及服务接口信息。
Directory代表多个Invoker,可以把它看作List,但与List不同的是,它的值可能是动态变化的,比如注册中心推送变更。
Cluster将Directory中的多个Invoker伪装成一个Invoker,伪装过程包含了容错逻辑,调用失败后,重试另一个。
Router可以从多个Invoker中通过路由规则进行过滤和筛选。
LoadBalance可以从多个Invoker中选出一个使用。
RoundRobinLoadBalance:权重轮询算法,按照公约后的权重设置轮询比例
原理:把来自用户的请求轮流分配给内部中的服务器。例如:从1开始,一直到N(其中,N是内部服务器的总数),然后重新开始循环。
LeastActiveLoadBalance:最少活跃调用数均衡算法
原理:最少活跃调用数,活跃数指调用前后计数差,使慢的机器收到更少。
ConsistentHashLoadBalance:一致性Hash算法
原理:一致性Hash,相同参数的请求总是发到同一个提供者。一致性Hash算法可以解决服务提供者的增加、移除及“挂掉”时的情况,也可以通过构建虚拟节点,尽可能避免分配失衡,具有很好的平衡性。
RandomLoadBalance:随机均衡算法(Dubbo的默认负载均衡策略)
原理:按权重设置随机概率,如果每个提供者的权重都相同,那么根据列表长度直接随机选取一个,如果权重不同,则累加权重值。从0~累加的权重值中选取一个随机数,然后判断该随机数落在哪个提供者上。
FailoverCluster:失败转移
当出现失败时,重试其他服务器,通常用于读操作,但重试会带来更长延迟(默认集群策略)。
FailfastCluster:快速失败
只发起一次调用,失败立即报错,通常用于非幂等性操作。
FailbackCluster:失败自动恢复
对于Invoker调用失败,后台记录失败请求,任务定时重发,通常用于通知。
BroadcastCluster:广播调用
遍历所有Invokers,如果调用其中某个invoker报错,则“catch”住异常,这样就不影响其他Invoker调用。
AvailableCluster:获取可用的调用
遍历所有Invokers并判断Invoker.isAvalible,只要有一个为true就直接调用返回,不管成不成功。
FailsafeCluster:失败安全
出现异常时,直接忽略,通常用于写入审计日志等操作。
ForkingCluster:并行调用
只要一个成功即返回,通常用于实时性要求较高的操作,但需要浪费更多的服务资源。
MergeableCluster:分组聚合
按组合并返回结果,比如某个服务接口有多种实现,可以用group区分,调用者调用多种实现并将得到的结果合并。
Directory:代表多个Invoker,可以看作List,它的值可能是动态变化的,比如注册中心推送变更。
StaticDirectory:静态目录服务,它的所有Invoker通过构造函数传入,并且将所有Invoker返回。
RegistryDirectory:注册目录服务,它的Invoker集合是从注册中心获取的,并且实现了NotifyListener接口的notify(List)方法。
AbstractDirectory:所有目录服务实现的抽象类,它在获取所有的Invoker后,通过Router服务进行路由过滤。
ConditionRouter:基于条件表达式的路由规则,不足之处是在规则复杂且多分支的情况下,规则不容易描述。
ScriptRouter:基于脚本引擎的路由规则,没有运行沙箱,脚本能力强大,可能成为后门。
那么在选择出一个可用服务后,接下来就正式进入服务调用环节了,也就是Result result = invoker.invoke(invocation)。这一行代码会经过一系列的Filter通过配置好的通信协议,远程调用相应的Provider,执行并返回结果,返回结果和异常信息全部封装到Result对象中,最终实现一次完整的调用过程。