加载配置文件的大致过程
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()函数来主导，它的检查内容有：
DBLE的访问权限配置中必须要有起码一个用户，无论是业务用户还是管理用户
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);
}
}
}
}
}
虚拟库配置中起码要有一个虚拟库
在后端配置中声明了，但是实际上并没有逻辑库使用（逻辑库中没有出现过）的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();
}
- 检查是否所有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;
}
}
}
