com.hyd.ssdb.sharding

类 ConsistentHashSharding

java.lang.Object

com.hyd.ssdb.conf.Sharding

com.hyd.ssdb.sharding.ConsistentHashSharding

public class ConsistentHashSharding
extends Sharding

基于一致性哈希的分片策略。这是 hydrogen-ssdb 实现的缺省分片策略。

ConsistentHashSharding 有一个属性叫做 spofStrategy，用于决定当出现单点故障时如何处理。

created at 15-12-8

作者:

Yiding

字段概要

从类继承的字段 com.hyd.ssdb.conf.Sharding

clusters

构造器概要

构造器

构造器和说明
ConsistentHashSharding(Cluster... clusters)
ConsistentHashSharding(Cluster cluster)
ConsistentHashSharding(List<Cluster> clusters)

方法概要

限定符和类型	方法和说明
void	addCluster(Cluster newCluster, Cluster prevCluster) 添加一个 Cluster
boolean	clusterFailed(Cluster invalidCluster) 当某个 Cluster 下线（即 Cluster 中的所有的服务器都不可用）时的处理（交给子类实现） ServerMonitorDaemon 会检查下线的服务器，发现有服务器恢复运作的话，会修改对应的 Cluster 状态为上线
Cluster	getClusterByKey(String key) 根据 key 获取所对应的 Cluster
Map<String,Range<Integer>>	getRangeMap()
SPOFStrategy	getSpofStrategy()
void	initClusters() 对 Sharding.clusters 进行初始化配置，或执行其他初始化工作
void	removeCluster(String clusterId)
void	setSpofStrategy(SPOFStrategy spofStrategy)

从类继承的方法 com.hyd.ssdb.conf.Sharding

getClusterById, getClusters

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

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

构造器详细资料

ConsistentHashSharding

public ConsistentHashSharding(Cluster cluster)

ConsistentHashSharding

public ConsistentHashSharding(List<Cluster> clusters)

ConsistentHashSharding

public ConsistentHashSharding(Cluster... clusters)

方法详细资料

getSpofStrategy

public SPOFStrategy getSpofStrategy()

setSpofStrategy

public void setSpofStrategy(SPOFStrategy spofStrategy)

getRangeMap

public Map<String,Range<Integer>> getRangeMap()

removeCluster

public void removeCluster(String clusterId)

addCluster

public void addCluster(Cluster newCluster,
                       Cluster prevCluster)

添加一个 Cluster

参数:

newCluster - 要加入的 Cluster

prevCluster - 需要被分担负载的 Cluster

initClusters

public void initClusters()

从类复制的说明: Sharding

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

指定者:

initClusters 在类中 Sharding

clusterFailed

public boolean clusterFailed(Cluster invalidCluster)

从类复制的说明: Sharding

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

指定者:

clusterFailed 在类中 Sharding

参数:

invalidCluster - 下线的 Cluster

返回:

是否允许选择其他的 Cluster

getClusterByKey

public Cluster getClusterByKey(String key)

从类复制的说明: Sharding

根据 key 获取所对应的 Cluster

指定者:

getClusterByKey 在类中 Sharding

参数:

key - 键

返回:

对应的 Cluster