集群容错
在集群调用失败时,Dubbo 提供了多种容错方案,缺省为 failover 重试。
各节点关系:
- 这里的
Invoker
- 是
Provider
- 的一个可调用
Service
- 的抽象,
Invoker
- 封装了
Provider
- 地址及
Service
Directory
- 代表多个
Invoker
- ,可以把它看成
List<Invoker>
- ,但与
List
Cluster
- 将
Directory
- 中的多个
Invoker
- 伪装成一个
Invoker
- ,对上层透明,伪装过程包含了容错逻辑,调用失败后,重试另一个
Router
- 负责从多个
Invoker
LoadBalance
- 负责从多个
Invoker
集群容错模式
可以自行扩展集群容错策略,参见:集群扩展
Failover Cluster
失败自动切换,当出现失败,重试其它服务器 1。通常用于读操作,但重试会带来更长延迟。可通过 retries="2"
重试次数配置如下:
<dubbo:service retries="2"
或
<dubbo:reference retries="2"
或
<dubbo:reference>
<dubbo:method name="findFoo" retries="2"
</dubbo:reference>
Failfast Cluster
快速失败,只发起一次调用,失败立即报错。通常用于非幂等性的写操作,比如新增记录。
Failsafe Cluster
失败安全,出现异常时,直接忽略。通常用于写入审计日志等操作。
Failback Cluster
失败自动恢复,后台记录失败请求,定时重发。通常用于消息通知操作。
Forking Cluster
并行调用多个服务器,只要一个成功即返回。通常用于实时性要求较高的读操作,但需要浪费更多服务资源。可通过 forks="2"
Broadcast Cluster
广播调用所有提供者,逐个调用,任意一台报错则报错 2。通常用于通知所有提供者更新缓存或日志等本地资源信息。
集群模式配置
按照以下示例在服务提供方和消费方配置集群模式
<dubbo:service cluster="failsafe"
或
<dubbo:reference cluster="failsafe"
集群接口:
@SPI(FailoverCluster.NAME) //默认使用failOver模式
public interface Cluster {
/**
* Merge the directory invokers to a virtual invoker.
*
* @param <T>
* @param directory
* @return cluster invoker
* @throws RpcException
*/
@Adaptive
<T> Invoker<T> join(Directory<T> directory) throws RpcException;
}