读取配置信息功能设计

功能需求

我们在设计系统的过程当中，经常会遇到需要读取配置信息需求，可以想到的几个设计要点是

1 将系统所有的配置信息都存放在数据库的一张表中，这样想查询相关业务只要筛选key字段即可。
2 我们希望数据可以自动更新，这样修改了数据后不必重启服务
3 这个问题是一个技术问题，也就是我们希望减少在bean初始化过程（如标记了{@link javax.annotation.PostConstruct}的方法）中使用配置项而导致的麻烦，那么我们需要提供一个可以在Spring自动注入开始前获取配置项holder的方法，也就是说获取的是一个代理类，在实际取值的时候才会去调用数据库

功能实现

1 首先说自动更新问题，很显然我们需要实现一个定时任务，我们可以实现http://www.jianshu.com/writer#/notebooks/13667805/notes/13753006 这里的抽象类来完成定时更新功能。
2 要实现自动更新，我们很容易想到发布订阅模式，很显然每个需要读取配置的地方都应该在config类中订阅，然后在合适的时候由config类进行通知。那么我们可以设置一个ConfigListener接口，所有需要读取配置的类都要实现这个接口

public interface ConfigListener {

    void update();

}

3 由于{@link javax.annotation.PostConstruct} 注解无法保证初始化的顺序，而其他类会在{@link javax.annotation.PostConstruct}过程中使用配置信息，因此需要设置一个代理，采用动态代理的好处是不需要对原代码进行更改，我们只需要加入从数据库读取配置信息以及注册的逻辑即可。
我们需要实现InvocationHandler接口，那么一个读取配置信息的client类就可以这么写

private class ConfigClientProxy implements InvocationHandler, ConfigListener {

        private ConfigClient client = new configClientImpl(); //这里是原client

        private volatile boolean init = false;

        public ConfigClient getClient() {
            return (ConfigClient) Proxy.newProxyInstance(
                    client.getClass().getClassLoader(),
                    client.getClass().getInterfaces(),
                    this);
        }

        @Override
        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
            if (!init) {
                init();
                init = true;
            }
            return method.invoke(client, args);
        }

        private void init() {
            update();
            configService.registerListener(ConfigConstants.APP_ID, this);
            configService.registerListener(ConfigConstants.CODE, this);
            configService.registerListener(ConfigConstants.TOKEN_URL, this);
            configService.registerListener(ConfigConstants.BASE_URL, this);
            configService.registerListener(ConfigConstants.SECRET, this);
            configService.registerListener(ConfigConstants.SOURCE, this);
            configService.registerListener(ConfigConstants.TARGET, this);
        }

        @Override
        public void update() {
            String appId = configService.getData(ConfigConstants.APP_ID, String.class);
            String authCode = configService.getData(ConfigConstants.AUTH_CODE, String.class);
            String tokenUrl = configService.getData(ConfigConstants.TOKEN_URL, String.class);
            String baseUrl = configService.getData(ConfigConstants.BASE_URL, String.class);
            String secret = configService.getData(ConfigConstants.SECRET, String.class);
            String source = configService.getData(ConfigConstants.SOURCE, String.class);
            String target = configService.getData(ConfigConstants.TARGET, String.class);
            client.setParameters(appId, authCode, tokenUrl, baseUrl, secret, source, target);
        }

    }

4 接下来我们就要看一下configService这个类该怎么实现了，通过刚刚提示的功能，我们可知接口类应该提供这么几个方法

public interface ConfigService {

    /**
     * 获取指定key的配置值
     *
     * @param key
     * @return
     */
    String getData(String key);

    /**
     * 获取指定key的配置值
     *
     * @param key 配置key
     * @param valueClass 配置值的类型
     * @param <T>
     * @return
     */
    <T> T getData(String key, Class<T> valueClass);

    /**
     * 获取指定key的配置值，并通过给的的转换器转换类型，若不存在则获取默认key的配置值并转换
     *
     * @param key
     * @param converter
     * @param <T>
     * @return
     */
    <T> T getData(String key, ConfigConverter<T> converter);

    /**
     * 将指定的监听器注册到指定的配置项上，当该配置项的值变化时会通知该监听器
     *
     * @param key
     * @param configListener
     */
    void registerListener(String key, ConfigListener configListener);

}

具体实现代码

@Service
public class ConfigServiceImpl extends ScheduledService implements ConfigService {

    @Autowired
    private DataDao dataDao;

    private volatile Map<String, String> values = new HashMap<String, String>();

    private ConcurrentHashMap<String, Set<ConfigListener>> listenerMap = new ConcurrentHashMap<String, Set<ConfigListener>>();

    /** 是否进行过初始化 */
    private volatile boolean init = false;

    /**
     * 默认的转换机制是使用Nutz的转换器
     *
     * @param valueClass
     * @param <T>
     * @return
     */
    private static <T> ConfigConverter<T> getDefaultConverter(final Class<T> valueClass) {
        return new ConfigConverter<T>() {
            @Override
            public T convert(String value) {
                return Castors.me().castTo(value, valueClass);
            }
        };
    }

    @Override
    public int updatePeriod() {
        return TimeConstants.MINUTE_IN_SECONDS;
    }

    @Override
    public void update() {
        List<Data> datas = dataDao.getAllDatas();
        Map<String, String> values = new HashMap<String, String>();
        for (Data data : datas) {
            values.put(data.getDataKey(), data.getDataValue());
        }
        Map<String, String> oldValues = this.values;
        this.values = values;
        invokeHolder(values, oldValues);
    }

    /**
     * 检查配置值是否有变化，若有变化，通知相关的holder
     *
     * @param newValues
     * @param oldValues
     */
    private void invokeHolder(Map<String, String> newValues, Map<String, String> oldValues) {
        Set<String> allKeys = new HashSet<String>();
        allKeys.addAll(newValues.keySet());
        allKeys.addAll(oldValues.keySet());
        for (String key : allKeys) {
            String newValue = newValues.get(key);
            String oldValue = oldValues.get(key);
            if (newValue == oldValue || (null != newValue && newValue.equals(oldValue))) {
                continue;
            }
            Set<ConfigListener> listeners = listenerMap.get(key);
            if (null == listeners) {
                continue;
            }
            for (ConfigListener holder : listeners) {
                try {
                    holder.update();
                } catch (Exception e) {
                    LogUtils.warning("ConfigServiceImpl: invoke error! " + key, e);
                }
            }
        }
    }

    @Override
    public String getData(String key) {
        if (!init) {
            update();
            init = true;
        }
        return values.get(key);
    }

    @Override
    public <T> T getData(String key, Class<T> valueClass) {
        return getData(key, getDefaultConverter(valueClass));
    }

    @Override
    public <T> T getData(String key, ConfigConverter<T> converter) {
        String value = getData(key);
        // 使用指定的转换器
        return converter.convert(value);
    }

    @Override
    public void registerListener(String key, ConfigListener configListener) {
        Set<ConfigListener> listeners = listenerMap.get(key);
        if (null == listeners) {
            listenerMap.putIfAbsent(key, Collections.newSetFromMap(new ConcurrentHashMap<ConfigListener, Boolean>()));
            listeners = listenerMap.get(key);
        }
        listeners.add(configListener);
    }

}

5 看了刚才的代码，可能觉得每次使用配置文件有些太复杂了，每次引用还需要自己去写一个动态代理类，那么我们可以写一个工具类，对这个过程做一个简化，也就是我们默认写好一个holder实现了刚才的注册等功能，每次调用的时候只需要执行

private ConfigHolder<String> lastName = ConfigUtils.getHolder(ConfigConstants.LAST_NAME, String.class);
address.setLastName(lastName.getValue());

也就是说我们获取的值都是一个个holder，只要调用它的getValue方法，就可以保证读到的都是最新的值。

/**
 * 系统配置工具类
 * <p />
 * 该类提供了{@link utils.ConfigUtils.ConfigHolder}的实现，通过该Holder，可以获取到指定配置的值。
 * 该类提供了这样一种机制，可以在Spring自动注入开始前获取到相关配置信息的Holder，
 * 虽然这些Holder需要等到Spring自动注入完成后才能使用，但能够在自动注入开始前（比如构造方法里）初始化Holder，
 * 可以在一些场景下简化代码的实现。
 *
 */
public class ConfigUtils {

    /**
     * 一个可以自动更新配置值的配置获取器
     *
     * @param <T>
     */
    public interface ConfigHolder<T> {

        /** 获取配置名称 */
        String getKey();

        /** 获取配置值 */
        T getValue();

    }

    private static abstract class BaseConfigHolder<T> implements ConfigHolder<T>, ConfigListener {

        private String key;

        private T value;

        private boolean init = false;

        public BaseConfigHolder(String key) {
            this.key = key;
        }

        @Override
        public String getKey() {
            return key;
        }

        /**
         * 获取配置的值
         * <p />
         * <b>注意</b>：该方法实际使用了{@link ConfigUtils#configService}来获取配置值，因此必须在Spring自动注入后才能调用
         *
         * @return
         */
        public final T getValue() {
            if (!init) {
                init();
                init = true;
            }
            return value;
        }

        private void init() {
            update();
            configService.registerListener(key, this);
        }

        @Override
        public final void update() {
            value = getValueFromConfigService();
        }

        /**
         * 从{@link ConfigUtils#configService}获取配置值的方法，
         * 子类通过实现该方法可以实现不同类型的Holder
         *
         * @return
         */
        protected abstract T getValueFromConfigService();

    }

    private static class ClassBasedConfigHolder<T> extends BaseConfigHolder<T> {

        private Class<T> valueClazz;

        public ClassBasedConfigHolder(String key, Class<T> valueClazz) {
            super(key);
            this.valueClazz = valueClazz;
        }

        @Override
        protected T getValueFromConfigService() {
            return configService.getData(getKey(), valueClazz);
        }

    }

    private static class ConverterBasedConfigHolder<T> extends BaseConfigHolder<T> {

        private ConfigConverter<T> configConverter;

        public ConverterBasedConfigHolder(String key, ConfigConverter<T> configConverter) {
            super(key);
            this.configConverter = configConverter;
        }

        @Override
        protected T getValueFromConfigService() {
            return configService.getData(getKey(), configConverter);
        }

    }

    /**
     * 一个{@link ConfigService}的指针，用于在{@link ConfigHolder}中使用，
     * 该值实际的赋值过程发生在{@link service.config.ConfigServiceImpl}的构造方法里，
     * 因此只有在Spring自动注入后才会拥有合法值
     */
    private static ConfigService configService;

    /**
     * 注入{@link ConfigService}的过程，其他情况下不应该被调用
     *
     * @param configService
     */
    public void setConfigService(ConfigService configService) {
        ConfigUtils.configService = configService;
    }

    /**
     * 提供一个可以在Spring自动注入开始前获取配置项holder的方法，以便减少在bean初始化过程中初始化配置项而导致的编码困难。
     * <p />
     * 通过该方法获取配置值时，配置值通过Nutz的自动转换机制转换为指定的类型
     * <p />
     * <b>注意</b>：该方法虽然可以在自动注入前获取到holder，但此时holder是无法获取配置值的，需等到自动注入完成才能使用！
     *
     * @param key
     * @param valueClass
     * @param <T>
     * @return
     */
    public static <T> ConfigHolder<T> getHolder(String key, Class<T> valueClass) {
        return new ClassBasedConfigHolder<T>(key, valueClass);
    }

    /**
     * 提供一个可以在Spring自动注入开始前获取配置项holder的方法，以便减少在bean初始化过程中初始化配置项而导致的编码困难。
     * <p />
     * 通过该方法获取配置值时，配置值通过指定的转换器转换为指定的类型
     * <p />
     * <b>注意</b>：该方法虽然可以在自动注入前获取到holder，但此时holder是无法获取配置值的，需等到自动注入完成才能使用！
     *
     * @param key
     * @param converter
     * @param <T>
     * @return
     */
    public static <T> ConfigHolder<T> getHolder(String key, ConfigConverter<T> converter) {
        return new ConverterBasedConfigHolder<T>(key, converter);
    }

}

最后编辑于：2017.12.08 05:26:40

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 194,524评论 5赞 460
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 81,869评论 2赞 371
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 141,813评论 0赞 320
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 52,210评论 1赞 263
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 61,085评论 4赞 355
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 46,117评论 1赞 272
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 36,533评论 3赞 381
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 35,219评论 0赞 253
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 39,487评论 1赞 290
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 34,582评论 2赞 309
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 36,362评论 1赞 326
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 32,218评论 3赞 312
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 37,589评论 3赞 299
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 28,899评论 0赞 17
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,176评论 1赞 250
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 41,503评论 2赞 341
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 40,707评论 2赞 335

读取配置信息功能设计

功能需求

功能实现

推荐阅读更多精彩内容