开源软件名称：

forest-thrift

开源软件地址：

https://gitee.com/dempe/forest-thrift

开源软件介绍：

#forest-thriftthrift服务的简单的封装

##thrift-client

池化的高可用thrift客户端

future

支持连接池
支持thrift描述文件的ping校验
支持负载均衡策略
支持容灾策略
支持自动熔断策略
支持基于zk的服务发现

quick start

maven依赖

<dependency>    <groupId>com.zhizus</groupId>    <artifactId>thrift-client</artifactId>    <version>0.0.1</version></dependency>

Alt text

使用示例：

// 连接池配置，    GenericKeyedObjectPoolConfig poolConfig = new GenericKeyedObjectPoolConfig();    // 校验接口，连接池的validateObject方法会调用到这里的ping方法    // 这里主要用于对thrift描述文件层面的心跳校验支持    PingValidate pingValidate = new PingValidate() {        @Override        public boolean ping(ServerInfo key, TTransport transport) {            return true;        }    };    // 客户端熔断策略，默认1min中10次异常则自动熔断，恢复时间也为1min中    IsolationStrategy<ServerInfo> infoIsolationStrategy = new IsolationStrategy<>();    DefaultThriftClient thriftClient = new DefaultThriftClient(LoadBalanceType.RANDOM, HAStrategyType.FAILED_FAST,            new ConfRegistry("localhost:9999"), poolConfig, pingValidate, infoIsolationStrategy);    //每次使用client请调用iface接口，这里通过代理模式包装了异常统计和回池操作，一个 iface生成的代理对象调用多次会出现问题    //  thriftClient.iface(YourThrift.class);

thrift-server

更多示例

user guide

1.根据thrift的描述文件生成thrift静态代码

thrift-0.6.1.exe -r -gen java sample.thrift

2.继承AbstractThriftServer，实现getProcessor()方法：

  @Override    protected TProcessor getProcessor() {        return new Sample.Processor(new Sample.Iface() {            @Override            public String hello(String para) throws TException {                return "hello " + para;            }            @Override            public boolean ping() throws TException {                return true;            }        });    }

调用start()方法，启动server

3.基于DefaultThriftClient构造client，并且调用iface方法生成对应的代理对象。