代码拉取完成,页面将自动刷新
#forest-thrift thrift服务的简单的封装
##thrift-client
池化的高可用thrift客户端
maven依赖
<dependency>
<groupId>com.zhizus</groupId>
<artifactId>thrift-client</artifactId>
<version>0.0.1</version>
</dependency>
使用示例:
// 连接池配置,
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);
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方法生成对应的代理对象。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型