14. Dubbo原理解析-集群&容错之Cluster

Dubbo作为一个分布式的服务治理框架,提供了集群部署,路由,软负载均衡及容错机制

下图描述了dubbo调用过程中的对于集群,负载等的调用关系。

Cluster

将Directory中的多个Invoker伪装成一个Invoker, 对上层透明,包含集群的容错机制

Cluster接口定义

@SPI(FailoverCluster.NAME)

public
interface
Cluster {

@Adaptive

<T> Invoker<T>join(Directory<T> directory) throws RpcException;

}

Cluster可以看做是工厂类, 将目录directory下的invoker合并成一个统一的Invoker,根据不同集群策略的Cluster创建不同的Invoker

我们来看下默认的失败转移,当出现失败重试其他服务的策略, 这个Cluster实现很简单就是创建FailoverCluseterInvoker对象

public
class
FailoverCluster implements Cluster {

public
final static
String NAME ="failover";

public<T> Invoker<T> join(Directory<T> directory)throws RpcException{

return
new
FailoverClusterInvoker<T>(directory);

}

}

下图展示了dubbo提供的所有集群方案

1)AvailableCluster: 获取可用的调用。遍历所有Invokers判断Invoker.isAvalible,只要一个有为true直接调用返回,不管成不成功

2)BroadcastCluster: 广播调用。遍历所有Invokers, 逐个调用每个调用catch住异常不影响其他invoker调用

3)FailbackCluster: 失败自动恢复, 对于invoker调用失败, 后台记录失败请求,任务定时重发, 通常用于通知

4)FailfastCluster: 快速失败,只发起一次调用,失败立即保错,通常用于非幂等性操作

5)FailoverCluster: 失败转移,当出现失败,重试其它服务器,通常用于读操作,但重试会带来更长延迟

(1)   目录服务directory.list(invocation) 列出方法的所有可调用服务

获取重试次数,默认重试两次

(2)   根据LoadBalance负载策略选择一个Invoker

(3)   执行invoker.invoke(invocation)调用

(4)   调用成功返回

调用失败小于重试次数,重新执行从3)步骤开始执行

调用次数大于等于重试次数抛出调用失败异常

6)FailsafeCluster: 失败安全,出现异常时,直接忽略,通常用于写入审计日志等操作。

7)ForkingCluster: 并行调用,只要一个成功即返回,通常用于实时性要求较高的操作,但需要浪费更多服务资源。

8)  MergeableCluster: 分组聚合, 按组合并返回结果,比如菜单服务,接口一样,但有多种实现,用group区分,现在消费方需从每种group中调用一次返回结果,合并结果返回,这样就可以实现聚合菜单项。

这个还蛮有意思,我们分析下是如何实现的

(1)   根据MERGE_KEY从url获取参数值

(2)   为空不需要merge, 正常调用

(3)   按group分组调用,将返回接口保存到集合中

(4)   获取MERGE_KEY如果是默认的话,获取默认merge策略,主要根据返回类型判断

(5)   如果不是,获取自定义的merge策略

(6)   Merge策略合并调用结果返回

9)MockClusterWrapper: 具备调用mock功能是其他Cluster包装

获取url的MOCK_KEY属性

(1)   不存在直接调用其他cluster

(2)   存在值startsWith("force") 强制mock调用

(3)   存在值不是startsWith("force") 先正常调用, 出现异常在mock调用

集群模式的配置

<dubbo:service cluster="failsafe" />    服务提供方

<dubbo:reference cluster="failsafe" />  服务消费方

时间: 2024-12-21 13:47:48

14. Dubbo原理解析-集群&容错之Cluster的相关文章

15. Dubbo原理解析-集群&amp;容错之目录服务Directory

集群目录服务Directory, 代表多个Invoker, 可以看成List<Invoker>,它的值可能是动态变化的比如注册中心推送变更.集群选择调用服务时通过目录服务找到所有服务 Directory的接口定义 public interfaceDirectory<T> extends Node {     //服务类型 Class<T>getInterface(); //列出所有服务的可执行对象 List<Invoker<T>>list(Inv

16. Dubbo原理解析-集群&amp;容错之router路由服务

Router服务路由, 根据路由规则从多个Invoker中选出一个子集AbstractDirectory是所有目录服务实现的上层抽象, 它在list列举出所有invokers后,会在通过Router服务进行路由过滤. Router接口定义 public interface Router extendsComparable<Router> { URL getUrl(); <T> List<Invoker<T>> route(List<Invoker<

17. Dubbo原理解析-集群&amp;容错之负载均衡

LoadBalance负载均衡, 负责从多个 Invokers中选出具体的一个Invoker用于本次调用,调用过程中包含了负载均衡的算法,调用失败后需要重新选择 LoadBalance接口定义 @SPI(RandomLoadBalance.NAME) public interface LoadBalance{ @Adaptive("loadbalance") <T> Invoker<T> select(List<Invoker<T>> i

Dubbo之旅--集群容错和负载均衡

当我们的系统中用到Dubbo的集群环境,因为各种原因在集群调用失败时,Dubbo提供了多种容错方案,缺省为failover重试. Dubbo的集群容错在这里想说说他是因为我们实际的项目中出现了此类的问题,因为依赖的第三方项目出现异常,导致dubbo调用超时,此时使用的是默认的集群容错方式,而配置的reties='3',这样前段系统连续掉用了三次服务,结果可想而知. 先说一下各节点关系: 这里的Invoker是Provider的一个可调用Service的抽象,Invoker封装了Provider地

Dubbo点滴之集群容错

首先看来自官方文档 这里的Invoker是Provider的一个可调用Service的抽象,Invoker封装了Provider地址及Service接口信息. Directory代表多个Invoker,可以把它看成List<Invoker>,但与List不同的是,它的值可能是动态变化的,比如注册中心推送变更. Cluster将Directory中的多个Invoker伪装成一个Invoker,对上层透明,伪装过程包含了容错逻辑,调用失败后,重试另一个. Router负责从多个Invoker中按路

Dubbo 源码分析 - 集群容错之 LoadBalance

1.简介 LoadBalance 中文意思为负载均衡,它的职责是将网络请求,或者其他形式的负载"均摊"到不同的机器上.避免集群中部分服务器压力过大,而另一些服务器比较空闲的情况.通过负载均衡,可以让每台服务器获取到适合自己处理能力的负载.在为高负载的服务器分流的同时,还可以避免资源浪费,一举两得.负载均衡可分为软件负载均衡和硬件负载均衡.在我们日常开发中,一般很难接触到硬件负载均衡.但软件负载均衡还是能够接触到一些的,比如 Nginx.在 Dubbo 中,也有负载均衡的概念和相应的实现

Dubbo服务集群容错

Dubbo是Alibaba开源的分布式服务框架,我们可以非常容易地通过Dubbo来构建分布式服务,并根据自己实际业务应用场景来选择合适的集群容错模式,这个对于很多应用都是迫切希望的,只需要通过简单的配置就能够实现分布式服务调用,也就是说服务提供方(Provider)发布的服务可以天然就是集群服务,比如,在实时性要求很高的应用场景下,可能希望来自消费方(Consumer)的调用响应时间最短,只需要选择Dubbo的Forking Cluster模式配置,就可以对一个调用请求并行发送到多台对等的提供方

Dubbo 系列(07-3)集群容错 - 负载均衡

目录 Spring Cloud Alibaba 系列目录 - Dubbo 篇 1. 背景介绍 1.1 负载均衡算法 1.2 继承体系 2. 源码分析 2.1 AbstractLoadBalance 2.2 RandomLoadBalance 2.3 LeastActiveLoadBalance 2.4 ConsistentHashLoadBalance Dubbo 系列(07-3)集群容错 - 负载均衡 Spring Cloud Alibaba 系列目录 - Dubbo 篇 1. 背景介绍 相关

Dubbo 系列(07-5)集群容错 - Mock

Dubbo 系列(07-5)集群容错 - Mock [toc] Spring Cloud Alibaba 系列目录 - Dubbo 篇 1. 背景介绍 相关文档推荐: Dubbo 实战 - 服务降级 Dubbo 实战 - 本地伪装 Dubbo 实战 - 本地存根 Dubbo 的集群容错中默认会组装 MockClusterWrapper,它实现了 Dubbo 的服务降级和本地伪装. 1.1 服务降级 服务降级配置方式,更多参考官网 Dubbo 实战 - 服务降级 <dubbo:reference