com.hyd.ssdb.conn

类 ConnectionPoolManager

java.lang.Object

com.hyd.ssdb.conn.ConnectionPoolManager

public class ConnectionPoolManager
extends Object

ConnectionPoolManager 有两个职责： 1、管理网络的拓扑结构（通过 Sharding 类），决定请求发送到哪个 SSDB 服务器； 2、当请求发送失败时，自动更新失效的服务器列表，并尝试重新发送请求到同一 Cluster 的其他服务器，直到没有服务器可用，才抛出异常。

作者:

Yiding

字段概要

字段

限定符和类型	字段和说明
static ConnectionPoolFactory	DEFAULT_CONNECTION_POOL_FACTORY

构造器概要

构造器

构造器和说明
ConnectionPoolManager(Sharding sharding)

方法概要

限定符和类型	方法和说明
void	close() 关闭所有连接池
List<PoolAndConnection>	getAllClusterConnections(Request request)
PoolAndConnection	getConnection(Request request) 根据请求获取一个连接。
Sharding	getSharding()
void	reportInvalidConnection(Connection connection)
void	reportInvalidConnection(String host, int port)
void	setConnectionPoolFactory(ConnectionPoolFactory connectionPoolFactory)

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

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

字段详细资料

DEFAULT_CONNECTION_POOL_FACTORY

public static final ConnectionPoolFactory DEFAULT_CONNECTION_POOL_FACTORY

构造器详细资料

ConnectionPoolManager

public ConnectionPoolManager(Sharding sharding)

方法详细资料

setConnectionPoolFactory

public void setConnectionPoolFactory(ConnectionPoolFactory connectionPoolFactory)

getSharding

public Sharding getSharding()

getAllClusterConnections

public List<PoolAndConnection> getAllClusterConnections(Request request)

getConnection

public PoolAndConnection getConnection(Request request)
                                throws SsdbNoServerAvailableException

根据请求获取一个连接。如果 Cluster 的某个服务器无法创建连接，则自动切换 到其他可用的服务器；如果所有的服务器都不可用，则抛出 SsdbNoServerAvailableException

参数:

request - 请求

返回:

连接和连接池

抛出:

SsdbNoServerAvailableException

close

public void close()

关闭所有连接池

reportInvalidConnection

public void reportInvalidConnection(Connection connection)

reportInvalidConnection

public void reportInvalidConnection(String host,
                                    int port)