com.hyd.ssdb.conf

类 Sharding

java.lang.Object

com.hyd.ssdb.conf.Sharding

直接已知子类:

ConsistentHashSharding

public abstract class Sharding
extends Object

根据服务器的拓扑结构，决定一个请求应该被发送到哪台服务器

created at 15-12-3

作者:

Yiding

字段概要

字段

限定符和类型	字段和说明
protected List<Cluster>	clusters

构造器概要

构造器

构造器和说明
Sharding(Cluster cluster) 构造方法
Sharding(List<Cluster> clusters) 构造方法

方法概要

限定符和类型	方法和说明
abstract boolean	clusterFailed(Cluster invalidCluster) 当某个 Cluster 下线（即 Cluster 中的所有的服务器都不可用）时的处理（交给子类实现） ServerMonitorDaemon 会检查下线的服务器，发现有服务器恢复运作的话，会修改对应的 Cluster 状态为上线
Cluster	getClusterById(String id)
abstract Cluster	getClusterByKey(String key) 根据 key 获取所对应的 Cluster
List<Cluster>	getClusters()
abstract void	initClusters() 对 clusters 进行初始化配置，或执行其他初始化工作

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

clusters

protected List<Cluster> clusters

构造器详细资料

Sharding

public Sharding(Cluster cluster)

构造方法

参数:

cluster - 集群配置，整个负载均衡当中只会有一个集群

Sharding

public Sharding(List<Cluster> clusters)

构造方法

参数:

clusters - 集群配置。注意本方法将会使用 clusters 的拷贝，因此调用本方法之后再操作 clusters（清空或增减元素），不会对 Sharding 有任何影响。

方法详细资料

initClusters

public abstract void initClusters()

对 clusters 进行初始化配置，或执行其他初始化工作

getClusterByKey

public abstract Cluster getClusterByKey(String key)

根据 key 获取所对应的 Cluster

参数:

key - 键

返回:

对应的 Cluster

clusterFailed

public abstract boolean clusterFailed(Cluster invalidCluster)

当某个 Cluster 下线（即 Cluster 中的所有的服务器都不可用）时的处理（交给子类实现） ServerMonitorDaemon 会检查下线的服务器，发现有服务器恢复运作的话，会修改对应的 Cluster 状态为上线

参数:

invalidCluster - 下线的 Cluster

返回:

是否允许选择其他的 Cluster

getClusters

public List<Cluster> getClusters()

getClusterById

public Cluster getClusterById(String id)