com.hyd.ssdb.conf

类 Cluster

java.lang.Object

com.hyd.ssdb.conf.Cluster

public class Cluster
extends Object

表示一个集群。集群是负载均衡的基本单位，一个集群里面可以配置一台或多台服务器（Server）。 这个类里面几个方法标上了 synchronized，考虑到：一个 Cluster 最多只会包含几台十几台服务器， synchronized 方法执行速度会很快，而且服务器的变更不会很频繁，所以没有使用复杂的同步方式。 fillMasters() 方法没有加上 synchronized 是因为它在构造方法中执行，构造方法不会被多线程访问。

created at 15-12-3

作者:

Yiding

字段概要

字段

限定符和类型	字段和说明
static int	DEFAULT_WEIGHT

构造器概要

构造器

构造器和说明
Cluster(List<Server> servers)
Cluster(List<Server> servers, int weight)
Cluster(Server server)
Cluster(Server server, int weight)

方法概要

限定符和类型	方法和说明
void	addServer(Server server) 添加一台服务器
boolean	containsServer(Server server) 判断 server 是否属于当前 cluster
Server	findServer(String host, int port)
static Cluster	fromServers(List<Server> servers)
static Cluster	fromServers(Server... servers)
static Cluster	fromSingleServer(Server server)
static Cluster	fromSingleServer(String host, int port)
static Cluster	fromSingleServer(String host, int port, int timeoutSeconds)
static Cluster	fromSingleServer(String host, int port, int timeoutSeconds, int bufferSize)
static Cluster	fromSingleServer(String host, int port, String pass)
static Cluster	fromSingleServer(String host, int port, String pass, int timeoutSeconds, int bufferSize)
Cluster	getHashHostingCluster(int hash) 返回指定 hash 所属的 Cluster
Range<Integer>	getHashRange()
String	getId()
List<Server>	getInvalidServers()
Server	getMaster() 获取一台主服务器（用于写入）。
Server	getRandomServer() 获取一个随机的服务器（用于读取）
List<Server>	getServers()
Cluster	getTakenOverBy()
int	getWeight()
boolean	isInvalid()
void	markInvalid(Server invalid) 将服务器标记为无效的
void	markValid(Server server) 将服务器标记为有效的
void	removeServer(Server server) 删除一台服务器
void	setHashRange(Range<Integer> hashRange)
void	setId(String id)
void	setInvalid(boolean invalid)
void	setTakenOverBy(Cluster takenOverBy)
void	setWeight(int weight)
static List<Cluster>	toClusters(List<Server> servers)
String	toString()

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

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

字段详细资料

DEFAULT_WEIGHT

public static final int DEFAULT_WEIGHT

另请参阅:

常量字段值

构造器详细资料

Cluster

public Cluster(List<Server> servers,
               int weight)

Cluster

public Cluster(Server server,
               int weight)

Cluster

public Cluster(List<Server> servers)

Cluster

public Cluster(Server server)

方法详细资料

toClusters

public static List<Cluster> toClusters(List<Server> servers)

fromSingleServer

public static Cluster fromSingleServer(Server server)

fromSingleServer

public static Cluster fromSingleServer(String host,
                                       int port)

fromSingleServer

public static Cluster fromSingleServer(String host,
                                       int port,
                                       int timeoutSeconds)

fromSingleServer

public static Cluster fromSingleServer(String host,
                                       int port,
                                       int timeoutSeconds,
                                       int bufferSize)

fromSingleServer

public static Cluster fromSingleServer(String host,
                                       int port,
                                       String pass,
                                       int timeoutSeconds,
                                       int bufferSize)

fromSingleServer

public static Cluster fromSingleServer(String host,
                                       int port,
                                       String pass)

fromServers

public static Cluster fromServers(List<Server> servers)

fromServers

public static Cluster fromServers(Server... servers)

isInvalid

public boolean isInvalid()

setInvalid

public void setInvalid(boolean invalid)

getHashRange

public Range<Integer> getHashRange()

setHashRange

public void setHashRange(Range<Integer> hashRange)

getTakenOverBy

public Cluster getTakenOverBy()

setTakenOverBy

public void setTakenOverBy(Cluster takenOverBy)

getId

public String getId()

setId

public void setId(String id)

getWeight

public int getWeight()

setWeight

public void setWeight(int weight)

getServers

public List<Server> getServers()

getInvalidServers

public List<Server> getInvalidServers()

addServer

public void addServer(Server server)

添加一台服务器

参数:

server - 要添加的服务器

removeServer

public void removeServer(Server server)

删除一台服务器

参数:

server - 要删除的服务器

getMaster

public Server getMaster()

获取一台主服务器（用于写入）。所有的服务器中必须至少有一台设置为 master=true

返回:

获取到的主服务器，如果找不到则抛出异常

getRandomServer

public Server getRandomServer()

获取一个随机的服务器（用于读取）

返回:

一个随机的服务器

markInvalid

public void markInvalid(Server invalid)

将服务器标记为无效的

参数:

invalid - 需要被标记的服务器

markValid

public void markValid(Server server)

将服务器标记为有效的

参数:

server - 恢复正常的服务器

getHashHostingCluster

public Cluster getHashHostingCluster(int hash)

返回指定 hash 所属的 Cluster

参数:

hash - 要查询的 hash

返回:

如果当前 Cluster 的哈希段包含该值，则返回当前 Cluster 或托管的 Cluster，否则返回 null

toString

public String toString()

覆盖:

toString 在类中 Object

containsServer

public boolean containsServer(Server server)

判断 server 是否属于当前 cluster

参数:

server - 要判断的 server

返回:

如果属于当前 cluster 则返回 true

findServer

public Server findServer(String host,
                         int port)