分布式流控系统 dimit

码农软件 · 软件分类 · 网络工具包 · 2019-02-24 17:59:08

软件介绍

dimit

分布式流控系统 QQ: 527645454 (开发讨论群)

快速开始

    
        
            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

为你推荐:

本文地址:https://www.codercto.com/soft/d/48.html

分布式算法导论

分布式算法导论

泰尔 / 霍红卫 / 机械工业出版社 / 2004年09月 / 39.0

分布式算法20多年来一直是倍受关注的主流方向。本书第二版不仅给出了算法的最新进展,还深入探讨了与之相关的理论知识。这本教材适合本科高年级和研究生使用,同时,本书所覆盖的广度和深度也十分适合从事实际工作的工程师和研究人员参考。书中重点讨论了点对点消息传递模型上的算法,也包括计算机通信网络的实现算法。其他重点讨论的内容包括分布式应用的控制算法(如波算法、广播算法、选举算法、终止检测算法、匿名网络的随机......一起来看看 《分布式算法导论》 这本书的介绍吧!

JS 压缩/解压工具
JS 压缩/解压工具

在线压缩/解压 JS 代码

UNIX 时间戳转换
UNIX 时间戳转换

UNIX 时间戳转换

RGB HSV 转换
RGB HSV 转换

RGB HSV 互转工具