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

原创
2016/10/17 11:59
阅读数 997

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

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

一些特性

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

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

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

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

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

  • ...

Diablo架构

Quick start

安装

  • 下载最新的压缩包;

  • 或者通过源码构建:

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

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

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

    	${DIABLO_HOME}/bin/diablo.sh start
    	${DIABLO_HOME}/bin/diablo.sh stop
    	${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到应用中

  • SimpleDiabloClient(编程模式):

    • 添加maven依赖:

      	<dependency>
          <groupId>me.hao0</groupId>
          <artifactId>diablo-client</artifactId>
          <version>${version}</version>
      	</dependency>
      
    • 代码样例:

      	SimpleDiabloClient client = new SimpleDiabloClient();
      client.setAppName("myapp");
      client.setAppKey("123456");
      client.setServers("127.0.0.1:2143,127.0.0.1:2144");
      // 可添加配置监听
      client.addListener(new ConfigListener<String>() {
          @Override
          public String name() {
              // 配置项名称
              return "test_config1";
          }
      
          @Override
          public void onUpdate(String newValue) {
              // 该方法会在本地配置更新后触发
              System.out.println("test_config1 has updated to " + newValue);
          }
      });
      client.start();
      
      // 获取配置项最新的值
      String testConfig = client.get("test_config");
      
      // 获取配置项最新的json对象
      MyClass myClass = client.get("test_json", MyClass.class);
      
      client.shutdown();
      
    • 具体见测试用例.

  • SpringDiabloClient(Spring注入模式):

    • 添加maven依赖:

      	<dependency>
          <groupId>me.hao0</groupId>
          <artifactId>diablo-client-spring</artifactId>
          <version>${version}</version>
      	</dependency>
      
    • 配置片段:

      	<bean class="me.hao0.diablo.client.SpringDiabloClient">
      		<property name="appName" value="myapp" />
      		<property name="appKey" value="123456" />
      		<property name="servers" value="127.0.0.1:2143,127.0.0.1:2144" />
      		<!-- 可选配置 -->
      		<property name="listeners">
      			<list>
      				<ref bean="activityNoListener" />
      				<ref bean="timeInfoListener" />
      				<ref bean="timeInfosListener" />
      				<ref bean="timeInfoMapListener" />
      			</list>
      		</property>
      	</bean>
      
      	<!-- 可配置一些监听器,会在本地配置更新后触发 -->
      	<bean id="activityNoListener" class="me.hao0.diablo.client.listener.ActivityNoListener" />
      	<bean id="timeInfoListener" class="me.hao0.diablo.client.listener.TimeInfoListener" />
      	<bean id="timeInfosListener" class="me.hao0.diablo.client.listener.TimeInfosListener" />
      	<bean id="timeInfoMapListener" class="me.hao0.diablo.client.listener.TimeInfoMapListener" />
      
    • 添加diablo配置Beanspring上下文中, 如:

      	@Component
      	public class MyAppConfig implements DiabloConfig {
      
      		// 支持基本类型转换 
      	    private String activityNo;
      	    private Integer activityChannel;
      	    private Boolean activityStart;
      	    private Float activityRatio;
      	    private Long activityCount;
      	    private Double activityFee;
      
      	    // 支持普通json对象转换
      	    private TimeInfo timeInfo;
      
      	    // 支持一级List对象转换
      	    private List<TimeInfo> timeInfos;
      
      	    // 支持一级Map对象转换
      	    private Map<String, TimeInfo> timeInfoMap;
      
      		// getters and setters
      	}
      
  • 具体见测试用例.

  • 这样一旦你通过Diablo Tower修改了对应配置项时,客户端将收到通知。

  • Github地址

展开阅读全文
加载中

作者的其它热门文章

打赏
2
3 收藏
分享
打赏
4 评论
3 收藏
2
分享
返回顶部
顶部