1 Star 0 Fork 9

恋风 / forest-thrift

forked from 郑大侠 / forest-thrift 
Create your Gitee Account
Explore and code with more than 6 million developers,Free private repositories !:)
Sign up
This repository doesn't specify license. Without author's permission, this code is only for learning and cannot be used for other purposes.
Clone or download
Cancel
Notice: Creating folder will generate an empty file .keep, because not support in Git
Loading...
README.md

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

##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方法生成对应的代理对象。

Comments ( 0 )

Sign in for post a comment

About

thrift pool client & thrift server spread retract
Cancel

Releases

No release

Contributors

All

Activities

load more
can not load any more
Java
1
https://gitee.com/lianfeng/forest-thrift.git
git@gitee.com:lianfeng/forest-thrift.git
lianfeng
forest-thrift
forest-thrift
master

Search