dimit分布式流控系统
dimit
分布式流控系统 QQ: 527645454 (开发讨论群)
快速开始
-
maven加pom依赖
io.github.dzh
dimit-core
io.github.dzh
dimit-zk
-
初始化StoreSystem
String uri = "dimit-zk://dzh/dimit?host=127.0.0.1:2181&sleep=1000&retry=3";
DimitStoreSystem dss = DimitStores.newStoreSystem(URI.create(uri), null);
-
依次创建流控Conf,配置结构层次:
- DimitConf 定义一个流控器
- ChannelGroupConf 通道组配置
- ChannelConf 通道配置
注: 参考单位测试 dimit-demo/../TestZkStoreConfDemo
-
初始化Dimiter，依据流控Conf创建对应的运行时数据
// init dimiter and runtime channels
String uri = "dimit-zk://dzh/dimit?host=127.0.0.1:2181&sleep=1000&retry=3";
Dimiter dimiter = Dimiter.newDimiter(URI.create(uri), null, dimitConfId);
ChannelGroupWrapper group = demo.initChannelGroup(channelGroupConfId);
group.newChannel(ChannelConfId_1, ChannelType.SEND);
group.newChannel(ChannelConfId_2, ChannelType.SEND);
// select
List
selected = group.select(TagA,TagB);
V result = null;
for(ChannelWrapper channel : selected) {
try{
result = channel.call(new ChannelCallable
{
// TODO request
...
});
// TODO parse result
...
break;
}catch(RateLimiterException e){
LOG.info(e.getMessage(), e);
}catch(InvalidChannelException e){
LOG.error(e.getMessage(), e);
}catch(Exception e){ // or break
LOG.error(e.getMessage(), e);
}
}
// program exit
dimiter.close();
注: 参考单位测试 dimit-demo/../TestDimiterDemo
特性列表
-
流量控制
-
ChannelConf定义max-tps, Channel实例的tps = max-tps / Channel总数
-
-
Tag筛选
-
ChannelConf定义通道的tag列表，ChannelGroupWrapper.select(...)时选择满足条件的Channel组
-
-
主备切换
-
ChannelConf定义通道ChannelStatus, select返回的可用通道列表里PRIMARY优先于STANDBY
-
-
质量分析
-
启用Channel的质量分析功能(
stat.enable=true默认开启)，在ChannelWrapper.call()时采集stat信息
-
-
异常切换
-
通过stat信息动态计算ChannelWrapper.priority(), 影响select结果
-
-
Web管理
-
TODO
-
环境依赖
-
JDK1.7 or higher
-
maven 3
-
protobuf 3
-
servlet-api v3.1.0 TODO 使用wep4j
评论