我的架构之路 — 配置中心（三）— 动态更新配置
包含两方面的含义：一、变化的配置能够下发到客户端.二、客户端能够方便地处理这些变化的配置。下面会讲普通监听器回调方式和spring 注解到field的方式。 配置下发 1）客户端间隔20秒（可配）去数据库拉取配置，sql传递的参数有配置名称、环境、上一次最大更新时间2）取到配置后，合并更新本地备份。3）通过监听器的方式通知配置变化。 #监听器接口 public interface ConfigUpdateListener { void update(Properties properties); } #启动时添加监听器 public void addConfigUpdateListener(ConfigUpdateListener configUpdateListener) { configUpdateListeners.add(configUpdateListener); } #配置变化，调用监听器进行通知 for (ConfigUpdateListener configUpdateListener : configUpdateListeners) { configUpdateListener.update(changedProperties); } spring 注解方式绑定成员变量 通过@ConfigValue注解来实现变量绑定，当配置变化的时候会同时更新这个变量。这种方式可以用于一起开关切换、降级处理的场景。 @ConfigValue("baseUrl") private String baseUrl; 实现原理：1）从配置中心获取配置。2）通过BeanPostProcessor 遍历每个spring bean，找出所有包含@ConfigValue注解的field，然后设置值为配置中心的属性值，同时把记录field到Map对象，以后更新配置时就不用想办法遍历了。这里有一个严格处理原则，如果配置中心找不到相应key或值赋值时候报异常，终止程序，保证安全性。其实代码对非spring的、static 成员变量也支持，只是需要程序启动时候指定包含这些static变量的类名列表。 public class PropertyPlaceholderConfigurer extends org.springframework.beans.factory.config.PropertyPlaceholderConfigurer implements BeanPostProcessor { private Map<String,List<BeanField>> configMap= new ConcurrentHashMap<String,List<BeanField>>(); @Override public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException { ConfigInjectSupport.inject(mergedProperties,bean.getClass(),bean,configMap); return bean; } @Override public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException { return bean; } public static void inject(Properties properties, Class clazz, Object bean, Map<String,List<BeanField>> configMap){ Field[] fields = clazz.getDeclaredFields(); if (null != fields) { for (Field f : fields) { // 如果 bean ==null（非spring），则必须是静态方法 if(bean==null && !Modifier.isStatic(f.getModifiers())) continue; ConfigValue configValue = f.getAnnotation(ConfigValue.class); if (configValue != null) { String key = configValue.value(); f.setAccessible(true); Object value = properties.get(key); if (value != null) { try { f.set(bean, converter.convertIfNecessary(value, f.getType(), f)); } catch (IllegalAccessException e) { throw new RuntimeException(e); } }else{ RuntimeException e= new RuntimeException("can not find config. key="+key+", class="+clazz+", field="+f.getName()); e.printStackTrace(); throw e; } List<BeanField> list = configMap.get(key); if (list == null) { list = new ArrayList<BeanField>(); configMap.put(key, list); } BeanField beanField=new BeanField(); beanField.setBean(bean); beanField.setField(f); list.add(beanField); } } } clazz = clazz.getSuperclass(); } 3）加入监听器，接收变化的配置，更新field值 public static void addConfigUpdateListener(final Map<String,List<BeanField>> configMap) { DefaultConfigClient.addConfigUpdateListener(new ConfigUpdateListener() { @Override public void update(Properties properties) { for (Map.Entry<Object, Object> e : properties.entrySet()) { List<BeanField> beanFields = configMap.get(e.getKey().toString()); if (beanFields != null) { Object value = properties.get(e.getKey()); for (BeanField beanField : beanFields) { try { ConfigValue configValue = beanField.getField().getAnnotation(ConfigValue.class); if(configValue.updatable()) { ConfigInjectSupport.setFieldValue(beanField, value); } } catch (IllegalAccessException ex) { ex.printStackTrace(); } } } } } }); } public static void setFieldValue(BeanField beanField,Object value) throws IllegalAccessException { Field f=beanField.getField(); f.set(beanField.getBean(), ConvertUtils.convert(value,f.getType())); }
