Netflix Archaius 分布式配置管理依赖构件


声明:本文转载自https://my.oschina.net/xiaominmin/blog/1590730,转载目的在于传递更多信息,仅供学习交流之用。如有侵权行为,请联系我,我会及时删除。

概述

archaius是Netflix公司开源项目之一,基于java的配置管理类库,主要用于多配置存储的动态获取。主要功能是对apache common configuration类库的扩展。在云平台开发中可以将其用作分布式配置管理依赖构件。同时,它有如下一些特性:

  • 动态类型化属性

  • 高效和线程安全的配置操作

  • 配置改变时的回调机制

  • 轮询框架

  • JMX,通过Jconsole检查和调用操作属性

  • 组合配置

技术分享

image.png

适用场景

对于传统的单体应用,properties等配置文件可以解决配置问题,同时也可以通过maven profile配置来区别各个环境,但在一个几百上千节点的的微服务生态中,微服务采用多种语言开发,配置文件格式多样,如何把每个微服务的配置文件都进行更新,并且很多时候还需要重启服务,是一件无法忍受的事情。所以,对于微服务架构而言,一个通用的配置中心是必不可少的。

新接口逻辑上线,老接口面临迁移,开发测试完成后,马上要上线。但是接口调用发的研发同学对新接口的稳定性、性能存在一定的质疑,为了避免风险,要求可以上线后紧急切换回老接口。这时候我们就需要一个手动开关。所以对于类似需求,一个通用的配置中心是必不可少的。

Archaius提供的DynamicIntProperty类可以在配置发生变化时动态地获取配置,并且不需要重启应用,而底层的配置存储,建议使用zookeeper进行存储,Archaius作为客户端的类库使用。

代码案例

引入依赖

<dependency>     <groupId>com.netflix.archaius</groupId>     <artifactId>archaius-core</artifactId> </dependency>

自定义Configuration

PropertiesConfiguration

public class PropertiesConfiguration extends DynamicConfiguration {     private static final Logger LOGGER = LoggerFactory.getLogger(PropertiesConfiguration.class);     private static final int INITIAL_DELAY_MILLIS = 0;     private static final int DELAY_MILLIS = 60 * 1000;     private static final boolean IGNORE_DELETES_FROM_SOURCE = true;      public PropertiesConfiguration(String confDir) {         this(new String[]{confDir});     }      public PropertiesConfiguration(final String...confDirs) {         String[] propertiesPaths = Lists.newArrayList(Iterables.concat(Iterables.transform(Arrays.asList(confDirs), new Function<String, List<String>>() {             @Nullable             @Override             public List<String> apply(String confDir) {                 Assert.isTrue(new File(confDir).isDirectory(), StringUtil.format("路径[{}]无法查找[.properties]文件", confDirs));                 String[] propertiesPaths = getPaths(confDir);                 if (ArrayUtils.isNotEmpty(propertiesPaths)) {                     return Lists.newArrayList(propertiesPaths);                 } else {                                          return Lists.newArrayList();                 }             }         }))).toArray(new String[0]);         if (ArrayUtils.isNotEmpty(propertiesPaths)) {             super.startPolling(new URLConfigurationSource(propertiesPaths), new FixedDelayPollingScheduler(INITIAL_DELAY_MILLIS, DELAY_MILLIS, IGNORE_DELETES_FROM_SOURCE));         }         ConfigurationLog.successInit(PropertiesConfiguration.class, this.getProperties());     }      private static String[] getPaths(String confDir) {         try {             URL configHome = new File(confDir).toURI().toURL();             List<String> urls = new ArrayList<String>();             for (String filename : FileUtil.scan(confDir, ".properties$")) {                 String url = configHome.toString() + filename;                 urls.add(url);             }             return urls.toArray(new String[urls.size()]);         } catch (MalformedURLException e) {             throw Throwables.propagate(e);         }     } }

SystemConfiguration

public class SystemConfiguration extends ConcurrentMapConfiguration {     private static final Logger LOGGER = LoggerFactory.getLogger(SystemConfiguration.class);      public SystemConfiguration() {         super();         this.loadProperties(System.getProperties());         ConfigurationLog.successInit(SystemConfiguration.class, this.getProperties());     } }

同理,可以使用zookeeper client 封装一个基于zookeeper的 ConcurrentMapConfiguration

初始化

private static final ConcurrentCompositeConfiguration compositeConfig = new ConcurrentCompositeConfiguration();  public synchronized static void init() {     Preconditions.checkState(! hadInit, StringUtil.format("[{}]只能加载一次!", ConfigAdapter.class.getSimpleName()));     Preconditions.checkState(compositeConfig.getConfigurations().size() > 1,             StringUtil.format("[{}]没有加载任何配置", ConfigAdapter.class.getSimpleName()));     if (! ConfigurationManager.isConfigurationInstalled()) {         ConfigurationManager.install(compositeConfig);         Preconditions.checkState(ConfigurationManager.isConfigurationInstalled(), StringUtil.format("[{}]加载失败!",                 ConfigAdapter.class.getSimpleName()));     }     Iterable<String> configurationNames = Iterables.transform(compositeConfig.getConfigurations(), new Function<AbstractConfiguration, String>() {         @Nullable         @Override         public String apply(AbstractConfiguration input) {             return input.getClass().getSimpleName();         }     });     ConfigurationLog.successInit(ConfigAdapter.class, getAll());     hadInit = true; }

获取值

 public static DynamicBooleanProperty getDynamicBool(String key, boolean defaultValue) {         return getFactory().getBooleanProperty(key, defaultValue);     }  private static DynamicPropertyFactory getFactory() {         return DynamicPropertyFactory.getInstance();     }

注意

  • 在设置的时刻获取配置,配置源不会随着System#properties里面的配置更新而更新

  • 更新配置方法不会更新实际的property文件,仅仅为更新内存数据,重启后失效

  • 微服务都从配置中心动态的读取配置信息,而配置中心又在从配置源同步配置,所以这里就很自然的出现了一个读写安全的问题,好消息是Archaius已经解决了这个问题,Archaius是线程安全的,读写可以并发进行。

https://github.com/Netflix/Hystrix/wiki/Configuration#CommandProperties

本文发表于2017年12月16日 08:33
(c)注:本文转载自https://my.oschina.net/xiaominmin/blog/1590730,转载目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责。如有侵权行为,请联系我们,我们会及时删除.

阅读 2557 讨论 0 喜欢 0

抢先体验

扫码体验
趣味小程序
文字表情生成器

闪念胶囊

你要过得好哇,这样我才能恨你啊,你要是过得不好,我都不知道该恨你还是拥抱你啊。

直抵黄龙府,与诸君痛饮尔。

那时陪伴我的人啊,你们如今在何方。

不出意外的话,我们再也不会见了,祝你前程似锦。

这世界真好,吃野东西也要留出这条命来看看

快捷链接
网站地图
提交友链
Copyright © 2016 - 2021 Cion.
All Rights Reserved.
京ICP备2021004668号-1