Disconf自动加载单个或多个配置项并自定义解析配置项

我会带着你远行 2021-12-19 03:55 356阅读 0赞

`disconf`加载配置项，分为`xml`配置和注解扫描，本博客将一下怎么使用注解扫描的方式，实现单个配置项的加载及自定义解析配置项。

**disconf.properties配置文件**

version=0.0.0
    app=commons-config
    env=rd

**spring配置文件**

**disconf配置中心的配置**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDM4MTEx_size_16_color_FFFFFF_t_70]  
**JAVA**

1.  自动加载有变化的配置文件，`reload`指定的配置项
2.  自定义配置项的解析规则，放到内存`map`中
    
        import com.alibaba.fastjson.JSON;
        import com.baidu.disconf.client.common.annotations.DisconfFile;
        import com.baidu.disconf.client.common.annotations.DisconfFileItem;
        import org.apache.commons.lang3.StringUtils;
        import org.slf4j.Logger;
        import org.slf4j.LoggerFactory;
        import org.springframework.stereotype.Component;
        import java.util.concurrent.ConcurrentHashMap;
        
        /**
         * 针对某个配置型单独reload
         * DisconfFile的filename指定disconf配置中心的配置文件的名称
         **/
        @Component
        @DisconfFile(filename = "xxx.properties")
        public class AutowiredThirdType {
        
            private static final Logger LOGGER = LoggerFactory.getLogger(AutowiredThirdType.class);
            /*
             * 将解析的内容放在ConcurrentHashMap中使用
             */
            public final static ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>();
            /*
             * 定义配置项，生成set、get方法，在get方法上使用DisconfFileItem注解，name是配置中心定义的key
             * set方法中可以实现你自己的解析逻辑，也可以什么都不做
             */
            private String reloadThirdType;
        
            @DisconfFileItem(name = "key")
            public String getReloadThirdType() {
                return reloadThirdType;
            }
            
        	/**
             * disconf配置中心配置项更改后，会自动调用此方法，在此方法中可以自己解析配置项
             * 这里自定义解析，然后放到ConcurrentHashMap中，在其他地方使用
             * @param reloadThirdType
             */
            public void setReloadThirdType(String reloadThirdType) {
                try {
                    String values = String.valueOf(reloadThirdType);
                    if ("null".equals(values)) {
                        LOGGER.error("reload key , values is null");
                    } else {
                        values = StringUtils.replaceChars(values, "，", ",");
                        String[] kvs = StringUtils.split(values, ",");
                        for (int i = 0; i < kvs.length; i++) {
                            String[] kv = StringUtils.split(kvs[i], "@");
                            if (kv.length < 2) {
                                LOGGER.error("kv {} error", kvs[i]);
                            } else {
                                map.put(StringUtils.trim(kv[0]), Integer.valueOf(StringUtils.trim(kv[1])));
                                LOGGER.info("reload third type key is {} , value is {}", kv[0], kv[1]);
                            }
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    LOGGER.error("reload Dis conf Item error {}", e.getMessage());
                } finally {
                    LOGGER.info("current third type map has {}", JSON.toJSONString(ThirdTypeMap.map));
                }
            }
        }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDM4MTEx_size_16_color_FFFFFF_t_70]: /images/20211218/3a35a87ade98435ca1030cfc84731367.png