Dubbo集群容错模式之Failfast实现 原

注:dubbo的版本是2.6.2。

                                                  图1 Dubbo的FailfastClusterInvoker类继承图

1.Failfast的含义

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

2.Failfast的实现

    核心代码在FailfastClusterInvoker的doInvoke(Invocation,List<Invoker<T>>,LoadBalance)中,源码如下。

@Override
public Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException {
    checkInvokers(invokers, invocation);
    Invoker<T> invoker = select(loadbalance, invocation, invokers, null);
    try {
        return invoker.invoke(invocation);
    } catch (Throwable e) {
        if (e instanceof RpcException && ((RpcException) e).isBiz()) { // biz exception.
            throw (RpcException) e;
        }
        throw new RpcException(e instanceof RpcException ? ((RpcException) e).getCode() : 0, "Failfast invoke providers " + invoker.getUrl() + " " + loadbalance.getClass().getSimpleName() + " select from all providers " + invokers + " for service " + getInterface().getName() + " method " + invocation.getMethodName() + " on consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() + ", but no luck to perform the invocation. Last error is: " + e.getMessage(), e.getCause() != null ? e.getCause() : e);
    }
}
  • 方法select(loadbalance, invocation, invokers, null),根据loadbalance从候选服务提供者中选出Invoker<T> invoker,之后调用invoker的invoke方法。
  • 如果调用成功,则直接返回结果,若失败则抛出异常,不再做其它任何处理。

    这个比较简单,好理解。重点在失败之后不再进行重调等尝试。

(adsbygoogle = window.adsbygoogle || []).push({});

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券