项目作者: ihaolin

项目描述 :
分布式配置管理平台(Distributed Configuration Management Platform)
高级语言: Java
项目地址: git://github.com/ihaolin/diablo.git
创建时间: 2016-10-08T06:54:46Z
项目社区:https://github.com/ihaolin/diablo

开源协议:MIT License

下载




轻量的分布式配置管理平台Build Status

English wiki

在线Demo: 用户名/密码(admin/admin123).

一些特性

  • 轻量级: 没有复杂的技术和第三方依赖;

  • 可靠存储: 使用Redis作为存储,建议使用Redis ClusterRedis Master-Slave 或者 Redis Proxy Middleware等技术保证存储的可靠性;

  • 对等的Server节点: Server节点的对等性,保证即便某些Server不可用,集群仍能工作;

  • 近似实时更新: diablo使用Http长轮询来保证客户端能及时得到配置更新的通知;

  • 简单的UI: diablo内嵌了一个简单易用的web界面,叫做Diablo Tower;

Diablo架构

Quick start

安装

  • 下载最新的压缩包;
  • 或者通过源码构建:

    1. mvn clean package -DskipTests
    2. # package located diablo-server/target/diablo-server-{version}.tar.gz
  • 解压缩包:

    1. tar zxf diablo-server.tar.gz
    2. ll diabloh
    3. bin # the execute scripts
    4. conf # conf dir
    5. lib # dependency libs
  • 编辑配置文件diablo.conf

    1. # vim ${DIABLO_HOME}/conf/diablo.conf
    2. # The server bind address
    3. BIND_ADDR=127.0.0.1
    4. # The server listening port
    5. LISTEN_PORT=2143
    6. # The redis host
    7. REDIS_HOST=127.0.0.1
    8. # The redis port
    9. REDIS_PORT=6379
    10. # The log path
    11. LOG_PATH=~/logs/diablo
    12. # The password for Diablo Tower admin
    13. TOWER_PASS=admin
    14. # The inverval(seconds) for checking server's status
    15. CHECK_SERVER_INTERVAL=5
    16. # Enable or disable client api auth
    17. # client must config the appKey, if CLIENT_AUTH=true
    18. CLIENT_AUTH=true
    19. # Java Heap options
    20. JAVA_HEAP_OPTS="-Xms512m -Xmx512m"
  • 启动或停止diablo server:

    1. ${DIABLO_HOME}/bin/diablo.sh start
    2. ${DIABLO_HOME}/bin/diablo.sh stop
    3. ${DIABLO_HOME}/bin/diablo.sh restart

使用 Diablo Tower

  • 启动diablo server后,便可通过Http访问diablo tower(如http://127.0.0.1:2143);

  • 事先准备应用配置项

    • 编辑应用:

      app_edit_en.png

    • 编辑配置项:

      config_edit_en.png

集成diablo client到应用中

  • 以下针对Java客户端,其他客户端可参考该规范

  • SimpleDiabloClient(编程模式):

    • 添加maven依赖:

      1. <dependency>
      2. <groupId>me.hao0</groupId>
      3. <artifactId>diablo-client</artifactId>
      4. <version>1.2.3</version>
      5. </dependency>
    • 代码样例:

      1. SimpleDiabloClient client = new SimpleDiabloClient();
      2. client.setAppName("myapp");
      3. client.setAppKey("123456");
      4. client.setServers("127.0.0.1:2143,127.0.0.1:2144");
      5. // 可添加配置监听
      6. client.addListener(new ConfigListener<String>() {
      7. @Override
      8. public String name() {
      9. // 配置项名称
      10. return "test_config1";
      11. }
      12. @Override
      13. public void onUpdate(String newValue) {
      14. // 该方法会在本地配置更新后触发
      15. System.out.println("test_config1 has updated to " + newValue);
      16. }
      17. });
      18. client.start();
      19. // 获取配置项最新的值
      20. String testConfig = client.get("test_config");
      21. // 获取配置项最新的json对象
      22. MyClass myClass = client.get("test_json", MyClass.class);
      23. client.shutdown();
    • 具体见测试用例.
  • SpringDiabloClient(Spring注入模式):

    • 添加maven依赖:

      1. <dependency>
      2. <groupId>me.hao0</groupId>
      3. <artifactId>diablo-client-spring</artifactId>
      4. <version>1.2.2</version>
      5. </dependency>
    • 配置片段:

      1. <bean class="me.hao0.diablo.client.SpringDiabloClient">
      2. <property name="appName" value="myapp" ></property>
      3. <property name="appKey" value="123456" ></property>
      4. <property name="servers" value="127.0.0.1:2143,127.0.0.1:2144" ></property>
      5. <!-- 可选配置 -->
      6. <property name="listeners">
      7. <list>
      8. <ref bean="activityNoListener" ></ref>
      9. <ref bean="timeInfoListener" ></ref>
      10. <ref bean="timeInfosListener" ></ref>
      11. <ref bean="timeInfoMapListener" ></ref>
      12. </list>
      13. </property>
      14. </bean>
      15. <!-- 可配置一些监听器,会在本地配置更新后触发 -->
      16. <bean id="activityNoListener" class="me.hao0.diablo.client.listener.ActivityNoListener" ></bean>
      17. <bean id="timeInfoListener" class="me.hao0.diablo.client.listener.TimeInfoListener" ></bean>
      18. <bean id="timeInfosListener" class="me.hao0.diablo.client.listener.TimeInfosListener" ></bean>
      19. <bean id="timeInfoMapListener" class="me.hao0.diablo.client.listener.TimeInfoMapListener" ></bean>
    • 添加diablo配置Beanspring上下文中, 如:

      1. @Component
      2. public class MyAppConfig implements DiabloConfig {
      3. // 支持基本类型转换
      4. private String activityNo;
      5. private Integer activityChannel;
      6. private Boolean activityStart;
      7. private Float activityRatio;
      8. private Long activityCount;
      9. private Double activityFee;
      10. // 支持普通json对象转换
      11. private TimeInfo timeInfo;
      12. // 支持一级List对象转换
      13. private List<TimeInfo> timeInfos;
      14. // 支持一级Map对象转换
      15. private Map<String, TimeInfo> timeInfoMap;
      16. // getters and setters
      17. }
  1. + 具体见[测试用例](diablo-client-spring/src/test/java/me/hao0/diablo/client/SpringDiabloClientTests.java).
  • 这样一旦你通过Diablo Tower修改了对应配置项时,客户端将收到通知。

有事请烧钱

  • 支付宝:

  • 微信: