⭐⭐⭐ Spring Boot 项目实战	⭐⭐⭐ Spring Cloud 项目实战
《Dubbo 实现原理与源码解析 —— 精品合集》	《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》	《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》	《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》	《Java 面试题 + Java 学习指南》

摘要: 原创出处 http://www.iocoder.cn/Apollo/server-config/ 「芋道源码」欢迎转载，保留摘要，谢谢！

🙂🙂🙂关注**微信公众号：【芋道源码】**有福利：

RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表

RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址

您对于源码的疑问每条留言都将得到认真回复。甚至不知道如何读源码也可以请教噢。

新的源码解析文章实时收到通知。每周更新一篇左右。

认真的源码交流微信群。

阅读源码最好的方式，是使用 IDEA 进行调试 Apollo 源码，不然会一脸懵逼。

胖友可以点击「芋道源码」扫码关注，回复 git018 关键字
获得艿艿添加了中文注释的 Apollo 源码地址。

阅读源码很孤单，加入源码交流群，一起坚持！

1. 概述

老艿艿：本系列假定胖友已经阅读过《Apollo 官方 wiki 文档》

Portal、Config Service、Admin Service 等等服务，自身需要配置服务。一种实现是，基于配置文件，简单方便。但是，不方便统一管理和共享。因此，Apollo 基于数据库实现类配置表 ServerConfig 。

老艿艿：如果胖友的系统暂时没有使用配置中心，

可以基于数据库实现类配置表 ServerConfig ，实现业务系统里面的配置功能，短平快。

配合 Redis 的 PUB/SUB 特性，实现配置更新的实时通知。

本文涉及的类如下图所示：

2. ServerConfig

2.1 Portal 侧

在 apollo-portal 项目中，com.ctrip.framework.apollo.portal.entity.po.ServerConfig ，继承 BaseEntity 抽象类，ServerConfig 实体，服务器 KV 配置项。代码如下：

@Entity
@Table(name = "ServerConfig")
@SQLDelete(sql = "Update ServerConfig set isDeleted = 1 where id = ?")
@Where(clause = "isDeleted = 0")
public class ServerConfig extends BaseEntity {

    /**
     * KEY
     */
    @Column(name = "Key", nullable = false)
    private String key;
    /**
     * VALUE
     */
    @Column(name = "Value", nullable = false)
    private String value;
    /**
     * 备注
     */
    @Column(name = "Comment", nullable = false)
    private String comment;
    
}

KV 结构，一个配置项，一条记录。例如：

2.2 Config 侧

在 apollo-biz 项目中，com.ctrip.framework.apollo.biz.entity.ServerConfig ，继承 BaseEntity 抽象类，ServerConfig 实体，服务器 KV 配置项。代码如下：

@Entity
@Table(name = "ServerConfig")
@SQLDelete(sql = "Update ServerConfig set isDeleted = 1 where id = ?")
@Where(clause = "isDeleted = 0")
public class ServerConfig extends BaseEntity {

    /**
     * KEY
     */
    @Column(name = "Key", nullable = false)
    private String key;
    /**
     * Cluster 名
     */
    @Column(name = "Cluster", nullable = false)
    private String cluster;
    /**
     * VALUE
     */
    @Column(name = "Value", nullable = false)
    private String value;
    /**
     * 备注
     */
    @Column(name = "Comment", nullable = false)
    private String comment;
    
}

提供给 Config Service、Admin Service 服务使用。
相比多了 cluster 属性，用于多机房部署使用。官方说明如下：

在多机房部署时，往往希望 config service 和 admin service 只向同机房的 eureka 注册，要实现这个效果，需要利用 ServerConfig 表中的 cluster 字段。

config service 和 admin service 会读取所在机器的 /opt/settings/server.properties（Mac/Linux）或 C:\opt\settings\server.properties（Windows）中的 idc 属性，如果该 idc 有对应的eureka.service.url 配置，那么就会向该机房的 eureka 注册。
- 默认情况下，使用 "default" 集群。
KV 结构，一个配置项，一条记录。例如：

3. RefreshablePropertySource

com.ctrip.framework.apollo.common.config.RefreshablePropertySource ，实现 org.springframework.core.env.MapPropertySource 类，可刷新的 PropertySource 抽象类。代码如下：

public abstract class RefreshablePropertySource extends MapPropertySource {

    public RefreshablePropertySource(String name, Map<String, Object> source) {
        super(name, source);
    }

    @Override
    public Object getProperty(String name) {
        return this.source.get(name);
    }

    /**
     * refresh property
     */
    protected abstract void refresh();

}

Spring PropertySource 体系，在《【Spring4揭秘基础2】PropertySource和Enviroment》中，有详细解析。
#refresh() 抽象方法，刷新配置。

3.1 PortalDBPropertySource

com.ctrip.framework.apollo.portal.service.PortalDBPropertySource ，实现 RefreshablePropertySource 抽象类，基于 PortalDB 的 ServerConfig 的 PropertySource 实现类。代码如下：

@Component
public class PortalDBPropertySource extends RefreshablePropertySource {

    private static final Logger logger = LoggerFactory.getLogger(PortalDBPropertySource.class);

    @Autowired
    private ServerConfigRepository serverConfigRepository;

    public PortalDBPropertySource(String name, Map<String, Object> source) {
        super(name, source);
    }

    public PortalDBPropertySource() {
        super("DBConfig", Maps.newConcurrentMap());
    }

    @Override
    protected void refresh() {
        // 获得所有的 ServerConfig 记录
        Iterable<ServerConfig> dbConfigs = serverConfigRepository.findAll();
        // 缓存，更新到属性源
        for (ServerConfig config : dbConfigs) {
            String key = config.getKey();
            Object value = config.getValue();

            // 打印日志
            if (this.source.isEmpty()) {
                logger.info("Load config from DB : {} = {}", key, value);
            } else if (!Objects.equals(this.source.get(key), value)) {
                logger.info("Load config from DB : {} = {}. Old value = {}", key, value, this.source.get(key));
            }

            // 更新到属性源
            this.source.put(key, value);
        }
    }

}

在 PortalDBPropertySource 构造方法中，我们可以看到，属性源的名字为 "DBConfig" ，属性源使用 ConcurrentMap 。
#refresh() 实现方法，从 PortalDB 中，读取所有的 ServerConfig 记录，更新到属性源 source 。

3.2 BizDBPropertySource

com.ctrip.framework.apollo.biz.service.BizDBPropertySource ，实现 RefreshablePropertySource 抽象类，基于 ConfigDB 的 ServerConfig 的 PropertySource 实现类。代码如下：

@Component
public class BizDBPropertySource extends RefreshablePropertySource {

    private static final Logger logger = LoggerFactory.getLogger(BizDBPropertySource.class);

    @Autowired
    private ServerConfigRepository serverConfigRepository;

    public BizDBPropertySource(String name, Map<String, Object> source) {
        super(name, source);
    }

    public BizDBPropertySource() {
        super("DBConfig", Maps.newConcurrentMap());
    }

    String getCurrentDataCenter() {
        return Foundation.server().getDataCenter();
    }

    @Override
    protected void refresh() {
        // 获得所有的 ServerConfig 记录
        Iterable<ServerConfig> dbConfigs = serverConfigRepository.findAll();

        // 创建配置 Map ，将匹配的 Cluster 的 ServerConfig 添加到其中
        Map<String, Object> newConfigs = Maps.newHashMap();
        // 匹配默认的 Cluster
        // default cluster's configs
        for (ServerConfig config : dbConfigs) {
            if (Objects.equals(ConfigConsts.CLUSTER_NAME_DEFAULT, config.getCluster())) {
                newConfigs.put(config.getKey(), config.getValue());
            }
        }
        // 匹配数据中心的 Cluster
        // data center's configs
        String dataCenter = getCurrentDataCenter();
        for (ServerConfig config : dbConfigs) {
            if (Objects.equals(dataCenter, config.getCluster())) {
                newConfigs.put(config.getKey(), config.getValue());
            }
        }
        // 匹配 JVM 启动参数的 Cluster
        // cluster's config
        if (!Strings.isNullOrEmpty(System.getProperty(ConfigConsts.APOLLO_CLUSTER_KEY))) { // -Dapollo.cluster=xxxx
            String cluster = System.getProperty(ConfigConsts.APOLLO_CLUSTER_KEY);
            for (ServerConfig config : dbConfigs) {
                if (Objects.equals(cluster, config.getCluster())) {
                    newConfigs.put(config.getKey(), config.getValue());
                }
            }
        }

        // 缓存，更新到属性源
        // put to environment
        for (Map.Entry<String, Object> config : newConfigs.entrySet()) {
            String key = config.getKey();
            Object value = config.getValue();

            // 打印日志
            if (this.source.get(key) == null) {
                logger.info("Load config from DB : {} = {}", key, value);
            } else if (!Objects.equals(this.source.get(key), value)) {
                logger.info("Load config from DB : {} = {}. Old value = {}", key,
                        value, this.source.get(key));
            }

            // 更新到属性源
            this.source.put(key, value);
        }
    }

}

提供给 Config Service、Admin Service 服务使用。
相比 PortalDBPropertySource ，BizDBPropertySource 多了多机房部署的 Cluster 过滤。在 #refresh() 实现方法中，按照默认的 Cluster、数据中心的 Cluster、JVM 启动参数的 Cluster ，逐个匹配 ServerConfig 的 cluster 字段。若匹配，最终会更新到属性源。
另外，使用 Foundation 类，获取数据中心的代码实现，我们后续单独分享。

4. RefreshableConfig

com.ctrip.framework.apollo.common.config.RefreshableConfig ，可刷新的配置抽象类。

4.1 构造方法

private static final Logger logger = LoggerFactory.getLogger(RefreshableConfig.class);

private static final String LIST_SEPARATOR = ",";
protected Splitter splitter = Splitter.on(LIST_SEPARATOR).omitEmptyStrings().trimResults();
/**
 * RefreshablePropertySource 刷新频率，单位：秒
 */
//TimeUnit: second
private static final int CONFIG_REFRESH_INTERVAL = 60;

/**
 * Spring ConfigurableEnvironment 对象
 */
@Autowired
private ConfigurableEnvironment environment;

/**
 * RefreshablePropertySource 数组，通过 {@link #getRefreshablePropertySources} 获得
 */
private List<RefreshablePropertySource> propertySources;

/**
 * register refreshable property source.
 * Notice: The front property source has higher priority.
 */

propertySources 属性，RefreshablePropertySource 数组。
- 在 #setup() 初始化方法中，将自己添加到 environment 中。
- 通过 #getRefreshablePropertySources() 抽象方法，返回需要注册的 RefreshablePropertySource 数组。代码如下：
  protected abstract List<RefreshablePropertySource> getRefreshablePropertySources();
  - BizConfig 和 PortalConfig 实现该方法，返回其对应的 RefreshablePropertySource 实现类的对象的数组。
environment 属性，Spring ConfigurableEnvironment 对象。其 PropertySource 不仅仅包括 propertySources ，还包括 yaml properties 等 PropertySource 。这就是为什么 ServerConfig 被封装成 PropertySource 的原因。
CONFIG_REFRESH_INTERVAL 静态属性，每 60 秒，刷新一次 propertySources 配置。

4.2 初始化

#setup() 方法，通过 Spring 调用，初始化定时刷新配置任务。代码如下：

 1: @PostConstruct
 2: public void setup() {
 3:     // 获得 RefreshablePropertySource 数组
 4:     propertySources = getRefreshablePropertySources();
 5:     if (CollectionUtils.isEmpty(propertySources)) {
 6:         throw new IllegalStateException("Property sources can not be empty.");
 7:     }
 8: 
 9:     // add property source to environment
10:     for (RefreshablePropertySource propertySource : propertySources) {
11:         propertySource.refresh();
12:         environment.getPropertySources().addLast(propertySource);
13:     }
14: 
15:     // 创建 ScheduledExecutorService 对象
16:     // task to update configs
17:     ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1, ApolloThreadFactory.create("ConfigRefresher", true));
18:     // 提交定时任务，每分钟刷新一次 RefreshablePropertySource 数组
19:     executorService.scheduleWithFixedDelay(() -> {
20:         try {
21:             propertySources.forEach(RefreshablePropertySource::refresh);
22:         } catch (Throwable t) {
23:             logger.error("Refresh configs failed.", t);
24:             Tracer.logError("Refresh configs failed.", t);
25:         }
26:     }, CONFIG_REFRESH_INTERVAL, CONFIG_REFRESH_INTERVAL, TimeUnit.SECONDS);
27: }

第 3 至 7 行：调用 #getRefreshablePropertySources() 方法，获得 RefreshablePropertySource 数组。
第 9 至 13 行：循环调用 ConfigurableEnvironment#getPropertySources()#addLast(propertySource) 方法，将 propertySources 注册到 environment 中。
第 17 行：创建 ScheduledExecutorService 对象。
第 18 至 26 行：提交定时任务，每 60 秒，循环调用 RefreshablePropertySource#refresh() 方法，刷新 propertySources 的配置。

4.3 获得值

public int getIntProperty(String key, int defaultValue) {
    try {
        String value = getValue(key);
        return value == null ? defaultValue : Integer.parseInt(value);
    } catch (Throwable e) {
        Tracer.logError("Get int property failed.", e);
        return defaultValue;
    }
}

public boolean getBooleanProperty(String key, boolean defaultValue) {
    try {
        String value = getValue(key);
        return value == null ? defaultValue : "true".equals(value);
    } catch (Throwable e) {
        Tracer.logError("Get boolean property failed.", e);
        return defaultValue;
    }
}

public String[] getArrayProperty(String key, String[] defaultValue) {
    try {
        String value = getValue(key);
        return Strings.isNullOrEmpty(value) ? defaultValue : value.split(LIST_SEPARATOR);
    } catch (Throwable e) {
        Tracer.logError("Get array property failed.", e);
        return defaultValue;
    }
}

public String getValue(String key, String defaultValue) {
    try {
        return environment.getProperty(key, defaultValue);
    } catch (Throwable e) {
        Tracer.logError("Get value failed.", e);
        return defaultValue;
    }
}

public String getValue(String key) {
    return environment.getProperty(key);
}

每个方法中，调用 ConfigurableEnvironment#getProperty(key, defaultValue) 方法，进行转换后返回值。🙂

4.4 PortalConfig

com.ctrip.framework.apollo.portal.component.config.PortalConfig ，实现 RefreshableConfig 抽象类。

4.4.1 getRefreshablePropertySources

@Autowired
private PortalDBPropertySource portalDBPropertySource;

@Override
public List<RefreshablePropertySource> getRefreshablePropertySources() {
    return Collections.singletonList(portalDBPropertySource);
}

返回 PortalDBPropertySource 对象的数组。

4.4.2 获得值

方法比较多，胖友自己查看。如下是一个例子：

// 获得 Env 集合
public List<Env> portalSupportedEnvs() {
    // 获得配置项
    String[] configurations = getArrayProperty("apollo.portal.envs", new String[]{"FAT", "UAT", "PRO"});
    // 创建成 List
    List<Env> envs = Lists.newLinkedList();
    for (String env : configurations) {
        envs.add(Env.fromString(env));
    }
    return envs;
}

4.5 BizConfig

com.ctrip.framework.apollo.biz.config.BizConfig ，实现 RefreshableConfig 抽象类。

4.5.1 getRefreshablePropertySources

@Autowired
private BizDBPropertySource propertySource;

@Override
protected List<RefreshablePropertySource> getRefreshablePropertySources() {
    return Collections.singletonList(propertySource);
}

返回 BizDBPropertySource 对象的数组。

4.5.2 获得值