Dubbo 的集群容错模式：Broadcast Cluster_

集群容错系列文章：
Failover Cluster 失败自动切换
Failfast Cluster 快速失败，抛出异常
Failsafe Cluster 快速失败，不抛出异常
Failback Cluster 失败后定时重试
Forking Cluster 并行调用多个实例，只要一个成功就返回
Broadcast Cluster 广播调用所有实例，有一个报错则抛出异常
Available Cluster 可用的实例
Mergeable Cluster 合并结果

本文简单介绍 Dubbo 中的 Broadcast Cluster（广播调用所有提供者，逐个调用，任何一台报错则报错）。

简介

广播调用所有提供者，逐个调用，任意一台报错则报错。通常用于通知所有提供者更新缓存或日志等本地资源信息。

如何使用

<dubbo:service cluster="broadcast" />
1

或

<dubbo:reference cluster="broadcast" />
1

实现逻辑

1. 循环调用所有的实例
2. 如果有发生异常则记录异常保存
3. 只要有异常，则抛出异常，如果没有则返回执行结果

源代码

public class BroadcastClusterInvoker<T> extends AbstractClusterInvoker<T> {

    private static final Logger logger = LoggerFactory.getLogger(BroadcastClusterInvoker.class);

    public BroadcastClusterInvoker(Directory<T> directory) {
        super(directory);
    }

    @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;
    }

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

做个有梦想的程序猿