DBLE 2.17.08.1与MyCat 1.6.5的启动过程（

加载配置文件的大致过程

---

DBLE基本是直接沿用了MyCat的配置文件设计。两者的主要配置文件都是server.xml、schema.xml和rule.xml文件。

配置文件的加载发生在DbleServer实例化的前期（MyCat则是MycatServer）中，由ConfigInitializer类的构造方法来协调。

com.actiontech.dble.DbleServer
com.actiontech.dble.config.ServerConfig.ServerConfig
com.actiontech.dble.config.ConfigInitializer.ConfigInitializer

ConfigInitializer()的工作总共有5步，分列如下。

1. 使用com.actiontech.dble.config.xml.XMLConfigLoader加载server.xml

XMLConfigLoader configLoader = new XMLConfigLoader();

2. 使用com.actiontech.dble.config.xml.XMLSchemaLoader加载schema.xml和rule.xml

SchemaLoader schemaLoader = new XMLSchemaLoader(configLoader.getSystemConfig().isLowerCaseTableNames());

3. 依次初始化PhysicalDBPool集合（对应于配置文件的<DataHost>）和PhysicalDBNode集合（对应于配置文件的<DataNode>）

this.dataHosts = initDataHosts(schemaLoader);
this.dataNodes = initDataNodes(schemaLoader);

4. 根据配置文件，装载对应类型的序列号发生器——所有配置文件读取完毕，返回到DbleServer的构建函数后，才会进一步进行序列号发生器的初始化

if (system.getSequnceHandlerType() == SystemConfig.SEQUENCE_HANDLER_MYSQL) {
    IncrSequenceMySQLHandler.getInstance().load(system.isLowerCaseTableNames());
}

if (system.getSequnceHandlerType() == SystemConfig.SEQUENCE_HANDLER_LOCAL_TIME) {
    IncrSequenceTimeHandler.getInstance().load();
}

if (system.getSequnceHandlerType() == SystemConfig.SEQUENCE_HANDLER_ZK_DISTRIBUTED) {
    DistributedSequenceHandler.getInstance().load();
}

if (system.getSequnceHandlerType() == SystemConfig.SEQUENCE_HANDLER_ZK_GLOBAL_INCREMENT) {
    IncrSequenceZKHandler.getInstance().load(system.isLowerCaseTableNames());
}

5. 对当前读进来的配置进行自查

public ConfigInitializer(boolean loadDataHost) {
    // ...
    this.selfChecking0();
}

这个自查由selfChecking0()函数来主导，它的检查内容有：

1. DBLE的访问权限配置中必须要有起码一个用户，无论是业务用户还是管理用户

2. DBLE的访问权限配置中的逻辑库（例如“某个用户在某个逻辑库上的权限”），必须存在于后端配置（MySQL数据源的配置）

if (users == null || users.isEmpty()) {
    // ...
} else {
        // ...
        if (!uc.isManager()) {
            Set<String> authSchemas = uc.getSchemas();
            if (authSchemas == null) {
                throw new ConfigException("SelfCheck### user " + uc.getName() + "refered schemas is empty!");
            }
            for (String schema : authSchemas) {
                if (!schemas.containsKey(schema)) {
                    String errMsg = "SelfCheck###  schema " + schema + " refered by user " + uc.getName() + " is not exist!";
                    throw new ConfigException(errMsg);
                }
            }
        }
    }
}

3. 虚拟库配置中起码要有一个虚拟库

4. 在后端配置中声明了，但是实际上并没有逻辑库使用（逻辑库中没有出现过）的MySQL数据源（<DataHost>和<DataNode>），从有效集合中移除——使DBLE不会去连接这些没用的MySQL，减少DBLE的占用的连接数、线程数，减轻压力

private void selfChecking0() throws ConfigException {

    // ...

    for (SchemaConfig sc : schemas.values()) {
        if (null == sc) {
            throw new ConfigException("SelfCheck### schema all node is empty!");
        } else {
            if (this.dataNodes != null && this.dataHosts != null) {
                Set<String> dataNodeNames = sc.getAllDataNodes();
                for (String dataNodeName : dataNodeNames) {
                    PhysicalDBNode node = this.dataNodes.get(dataNodeName);
                    if (node == null) {
                        throw new ConfigException("SelfCheck### schema dbnode is empty!");
                    }
                }
                allUseDataNode.addAll(dataNodeNames);
            }
        }
    }

    deleteRedundancyConf(allUseDataNode);

    // ...
}

private void deleteRedundancyConf(Set<String> allUseDataNode) {
    Set<String> allUseHost = new HashSet<>();
    //delete redundancy dataNode
    Iterator<Map.Entry<String, PhysicalDBNode>> iterator = this.dataNodes.entrySet().iterator();
    while (iterator.hasNext()) {
        Map.Entry<String, PhysicalDBNode> entry = iterator.next();
        String dataNodeName = entry.getKey();
        if (allUseDataNode.contains(dataNodeName)) {
            allUseHost.add(entry.getValue().getDbPool().getHostName());
        } else {
            LOGGER.warn("dataNode " + dataNodeName + " is useless,server will ignore it");
            iterator.remove();
        }
    }
    allUseDataNode.clear();
    //delete redundancy dataHost
    if (allUseHost.size() < this.dataHosts.size()) {
        Iterator<String> dataHost = this.dataHosts.keySet().iterator();
        while (dataHost.hasNext()) {
            String dataHostName = dataHost.next();
            if (!allUseHost.contains(dataHostName)) {
                LOGGER.warn("dataHost " + dataHostName + " is useless,server will ignore it");
                dataHost.remove();
            }
        }
    }
    allUseHost.clear();
}

5. 检查是否所有MySQL数据源（这里单指<DataHost>）都配置了写服务器——其实哪怕有数据源没有配置写服务器，也不影响DBLE启动（但是影响运行，该数据源无法做写操作了），只会产生一个WARN提示到日志中

private void selfChecking0() throws ConfigException {

    // ...

    checkWriteHost();

}

private void checkWriteHost() {
    for (Map.Entry<String, PhysicalDBPool> pool : this.dataHosts.entrySet()) {
        if (pool.getValue().getSources() == null || pool.getValue().getSources().length == 0) {
            LOGGER.warn("dataHost " + pool.getKey() + " has no writeHost ,server will ignore it");
            this.dataHostWithoutWH = true;
        }
    }
}