finekit/src/main/java/com/fanruan/api/conf/ConfigurationKit.java

package com.fanruan.api.conf;

import com.fanruan.api.generic.Matcher;
import com.fanruan.api.generic.Runner;
import com.fr.config.Configuration;
import com.fr.config.holder.ConfigChangeListener;
import com.fr.transaction.Configurations;
import com.fr.transaction.ValidateProxy;
import com.fr.transaction.WorkerFacade;

/**
 * @author richie
 * @version 10.0
 * Created by richie on 2019-09-17
 * 配置管理工具类
 */
public class ConfigurationKit {

    /**
     * 兼容配置缓存失效
     *
     * @param matcher 匹配器
     * @param runner  匹配后执行的动作
     */
    public static void listenCacheChange(final Matcher<Class<? extends Configuration>> matcher, final Runner runner) {
        ValidateProxy.getInstance().getValidateManager().registerListener(new ConfigChangeListener() {

            @Override
            public boolean accept(Class<? extends Configuration> clazz) {
                if (matcher == null) {
                    return true;
                }
                return matcher.match(clazz);
            }

            @Override
            public void change() {
                if (matcher != null) {
                    runner.run();
                }
            }
        });
    }

    /**
     * 在一个事务中修改配置
     *
     * @param configType 配置类
     * @param runner     执行器
     */
    public static void modify(Class<? extends Configuration> configType, Runner runner) {
        Configurations.modify(new WorkerFacade(configType) {
            @Override
            public void run() {
                if (runner != null) {
                    runner.run();
                }
            }
        });
    }
}