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 Listselected = 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
评论
lite-flow分布式任务流调度系统
liteflow是一个基于DAG来实现的分布式任务流调度系统,较azkaban等调度系统,liteflow增加了一些自己的特性:1.实现任务在任务流间共享2.任务/任务流的可视化配置3.一键修复任务/
lite-flow分布式任务流调度系统
0
iBase4J分布式系统
Springboot,Spring,SpringMVC,Mybatis,mybatis-plus,motan/dubbo分布式,Redis缓存,Shiro权限管理,Spring-Session单点登录
iBase4J分布式系统
0
JD-Hydra分布式跟踪系统
京东开源的基于Dubbo的调用跟踪系统类似于Google的Dapper、类似于twitter的Zipkin、类似于淘宝的EagleEye。
JD-Hydra分布式跟踪系统
0
OpenXDAS分布式审计系统
OpenXDAS是一个开源执行OpenGroup的分布式审计系统,遵照BSD开源许可证。该XDAS标准是在1998年确定的146/03工作组的代表来自几个软件公司支持各种版本的Unix和其他操作系统。
OpenXDAS分布式审计系统
0