Dubbo集群容错模式之Broadcast实现

注： Dubbo版本是2.6.2

                               

                                                图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.思考

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