sofarpc集群容错之Failfast实现

注意&＃xff1a;我们分析的sofa-rpc版本是5.4.0。

                                                        图1 FailFastCluster的类继承图

1.Failfast的含义

    Failfast可以理解为只发起一次调用&＃xff0c;若失败则立即报错。

2.sofa-rpc中Failfast的实现

    核心代码在FailFastCluster的doInvoke(SofaRequest request)中&＃xff0c;源码如下。

&＃64;Override
public SofaResponse doInvoke(SofaRequest request) throws SofaRpcException {ProviderInfo providerInfo &＃61; select(request);try {SofaResponse response &＃61; filterChain(providerInfo, request);if (response !&＃61; null) {return response;} else {throw new SofaRpcException(RpcErrorType.CLIENT_UNDECLARED_ERROR,"Failed to call " &＃43; request.getInterfaceName() &＃43; "." &＃43; request.getMethodName()&＃43; " on remote server " &＃43; providerInfo &＃43; ", return null");}} catch (Exception e) {throw new SofaRpcException(RpcErrorType.CLIENT_UNDECLARED_ERROR,"Failed to call " &＃43; request.getInterfaceName() &＃43; "." &＃43; request.getMethodName()&＃43; " on remote server: " &＃43; providerInfo &＃43; ", cause by: "&＃43; e.getClass().getName() &＃43; ", message is: " &＃43; e.getMessage(), e);}
}

•     首先select(request)获取一个服务提供者。    
•     filterChain(providerInfo,request)的实现不关心&＃xff0c;把它理解为一个黑盒&＃xff0c;它的作用是调用服务提供者的服务。
•     如果结果为不为null且不抛出异常&＃xff0c;则返回结果&＃xff1b;如果抛出异常&＃xff0c;则先catch&＃xff0c;而后封装原始异常&＃xff0c;之后再讲异常抛出。

    重点在于请求异常之后&＃xff0c;立即将异常抛出给调用者。

3.思考

    你是否在其它框架中看到过Failfast的实现&＃xff1f; Dubbo中有Failfast的实现&＃xff0c;可以去看Dubbo中FailfastClusterInvoker.java的实现&＃xff0c;我的博客中分析过。