集群扩展
此文档已经不再维护。您当前查看的是快照版本。如果想要查看最新版本的文档，请参阅最新版本。
扩展说明
当有多个服务提供方时，将多个服务提供方组织成一个集群，并伪装成一个提供方。
扩展接口
org.apache.dubbo.rpc.cluster.Cluster
扩展配置
<dubbo:protocol cluster="xxx" />
<!-- 缺省值配置，如果<dubbo:protocol>没有配置cluster时，使用此配置 -->
<dubbo:provider cluster="xxx" />
已知扩展
org.apache.dubbo.rpc.cluster.support.wrapper.MockClusterWrapperorg.apache.dubbo.rpc.cluster.support.FailoverClusterorg.apache.dubbo.rpc.cluster.support.FailfastClusterorg.apache.dubbo.rpc.cluster.support.FailsafeClusterorg.apache.dubbo.rpc.cluster.support.FailbackClusterorg.apache.dubbo.rpc.cluster.support.ForkingClusterorg.apache.dubbo.rpc.cluster.support.AvailableClusterorg.apache.dubbo.rpc.cluster.support.MergeableClusterorg.apache.dubbo.rpc.cluster.support.BroadcastClusterorg.apache.dubbo.rpc.cluster.support.registry.ZoneAwareCluster
扩展示例
Maven 项目结构：
src
|-main
|-java
|-com
|-xxx
|-XxxCluster.java (实现Cluster接口)
|-resources
|-META-INF
|-dubbo
|-org.apache.dubbo.rpc.cluster.Cluster (纯文本文件，内容为：xxx=com.xxx.XxxCluster)
XxxCluster.java：
package com.xxx;
import org.apache.dubbo.rpc.cluster.Cluster;
import org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker;
import org.apache.dubbo.rpc.cluster.Directory;
import org.apache.dubbo.rpc.cluster.LoadBalance;
import org.apache.dubbo.rpc.Invoker;
import org.apache.dubbo.rpc.Invocation;
import org.apache.dubbo.rpc.Result;
import org.apache.dubbo.rpc.RpcException;
public class XxxCluster implements Cluster {
public <T> Invoker<T> merge(Directory<T> directory) throws RpcException {
return new AbstractClusterInvoker<T>(directory) {
public Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException {
// ...
}
};
}
}
META-INF/dubbo/org.apache.dubbo.rpc.cluster.Cluster：
xxx=com.xxx.XxxCluster
Feedback
Was this page helpful?
Glad to hear it! Please tell us how we can improve.
Sorry to hear that. Please tell us how we can improve.
