Dubbo集群容错模式之Broadcast实现

- 日理万妓 2021-09-20 04:10 362阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

注： Dubbo版本是2.6.2

![175841_49aL_2518341.png][]

图1 Dubbo的BroadcastClusterInvoker类继承图

## 1.Broadcast的含义 ##

即广播，每个接收者都能收到消息。

## 2.Dubbo中是怎么实现 ##

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

@Override
    @SuppressWarnings({"unchecked", "rawtypes"})
    public Result doInvoke(final Invocation invocation, List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException {
        checkInvokers(invokers, invocation);
        RpcContext.getContext().setInvokers((List) invokers);
        RpcException exception = null;
        Result result = null;
        for (Invoker<T> invoker : invokers) {
            try {
                result = invoker.invoke(invocation);
            } catch (RpcException e) {
                exception = e;
                logger.warn(e.getMessage(), e);
            } catch (Throwable e) {
                exception = new RpcException(e.getMessage(), e);
                logger.warn(e.getMessage(), e);
            }
        }
        if (exception != null) {
            throw exception;
        }
        return result;
    }

循环遍历所有的服务提供者，逐个进行请求，如果有异常出现，则记录日志。需要注意的是，Dubbo中，这里并未使用多线程，所以个人估计如果服务提供者数量众多或者请求处理耗时长，则整体的耗时应该会长，所以最好根据业务场景，进行合理的选择。

由于上面的源码可以看出，轮询请求过程中，任意一个抛出异常，并不会中断后面的请求，只有在所有请求处理完成后，才会去检查异常。只有所有的请求都成功的情况下，才会将最后一次调用的结果返回。

## 3.思考 ##

如果这个广播过程用线程池实现，该怎么实现，我们需要考虑额外的哪些问题？这个留给读者思考。

转载于:https://my.oschina.net/u/2518341/blog/1814975

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20210726/592c4c1081e04b4b8cae0678ef04329d.png
[175841_49aL_2518341.png]: https://static.oschina.net/uploads/space/2018/0518/175841_49aL_2518341.png