Thrift连接池实现

目标：
1、支持池化管理thrift客户端连接
2、支持thrift服务器的负载均衡
3、支持thrift服务器列表的动态管理

示例

单服务示例

ThriftConnectionPoolConfig config = new ThriftConnectionPoolConfig();
config.setConnectTimeout(3000);
config.setThriftProtocol(TProtocolType.BINARY);
config.setClientClass(Example.Client.class);
config.addThriftServer("127.0.0.1", 9119);
config.setMaxConnectionPerServer(2);
config.setMinConnectionPerServer(1);
config.setIdleMaxAge(2, TimeUnit.SECONDS);
config.setMaxConnectionAge(2);
config.setLazyInit(false);
try {
    ThriftConnectionPool<Example.Client> pool = new ThriftConnectionPool<Example.Client>(config);
    Example.Client client = pool.getConnection().getClient();
    client.ping();
    pool.close();
} catch (ThriftConnectionPoolException e) {
    e.printStackTrace();
} catch (TException e) {
    e.printStackTrace();
} catch (IOException e) {
    e.printStackTrace();
}

多接口服务示例

ThriftConnectionPoolConfig config = new ThriftConnectionPoolConfig(ThriftServiceType.MULTIPLEXED_INTERFACE);
config.setConnectTimeout(3000);
config.setThriftProtocol(TProtocolType.BINARY);
config.addThriftServer("127.0.0.1", 9119);
config.addThriftClientClass("other", Other.Client.class);
config.addThriftClientClass("example", Example.Client.class);

config.setMaxConnectionPerServer(2);
config.setMinConnectionPerServer(1);
config.setIdleMaxAge(2, TimeUnit.SECONDS);
config.setMaxConnectionAge(2);
config.setLazyInit(false);
config.setAcquireIncrement(2);
config.setAcquireRetryDelay(2000);

config.setAcquireRetryAttempts(1);
config.setMaxConnectionCreateFailedCount(1);
config.setConnectionTimeoutInMs(5000);

config.check();

ThriftConnectionPool<TServiceClient> pool = new ThriftConnectionPool<TServiceClient>(config);
ThriftConnection<TServiceClient> connection = pool.getConnection();
// example service
com.wmz7year.thrift.pool.example.Example.Client exampleServiceClient = connection.getClient("example",
        Example.Client.class);
exampleServiceClient.ping();

// other service
com.wmz7year.thrift.pool.example.Other.Client otherServiceClient = connection.getClient("other",
        Other.Client.class);
otherServiceClient.ping();
pool.close();

使用

<dependency>
        <groupId>com.github.wmz7year</groupId>
        <artifactId>ThriftConnectionPool</artifactId>
        <version>1.0.4-RELEASE</version>
</dependency>

特性

1、支持服务器之间的负载均衡
2、每个服务器拥有一个独立的连接分区 所有的连接分区合并一起为整个连接池
3、连接池支持自动创建连接、管理超时连接、管理失效连接
4、支持服务器列表动态增加或者移除
5、支持自动调取ping方法(在thrift描述文件添加方法void ping(),)检测连接可用性
6、支持当服务不可用时自动将对应的服务器剔除连接池的功能
7、添加多服务接口支持

接下来需要完善内容：

1、补充文档
2、补充性能测试
3、完善使用例子
4、操作重试机制?