sofa-rpc集羣容錯之Failfast實現

注意：咱們分析的sofa-rpc版本是5.4.0。

                    

                                                        圖1 FailFastCluster的類繼承圖

1.Failfast的含義

    Failfast能夠理解爲只發起一次調用，若失敗則當即報錯。

2.sofa-rpc中Failfast的實現

    核心代碼在FailFastCluster的doInvoke(SofaRequest request)中，源碼以下。

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

•     首先select(request)獲取一個服務提供者。    
•     filterChain(providerInfo,request)的實現不關心，把它理解爲一個黑盒，它的做用是調用服務提供者的服務。
•     若是結果爲不爲null且不拋出異常，則返回結果；若是拋出異常，則先catch，然後封裝原始異常，以後再講異常拋出。

    重點在於請求異常以後，當即將異常拋出給調用者。

3.思考

    你是否在其它框架中看到過Failfast的實現？ Dubbo中有Failfast的實現，能夠去看Dubbo中FailfastClusterInvoker.java的實現，個人博客中分析過。