com.hyd.ssdb.conn

类 ConnectionPoolManager

java.lang.Object

com.hyd.ssdb.conn.ConnectionPoolManager

public class ConnectionPoolManager
extends Object

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

作者:

Yiding

构造器概要

构造器

构造器和说明
ConnectionPoolManager(Sharding sharding)

方法概要

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

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

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

构造器详细资料

ConnectionPoolManager

public ConnectionPoolManager(Sharding sharding)

方法详细资料

getSharding

public Sharding getSharding()

getAllConnections

public List<PoolAndConnection> getAllConnections(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)