1、初始化
? Druid的初始化过程，使用都是创建DruidDataSource对象进行配置参数之后，调用init方法进行初始化。
? 方式一：Spring 配置初始化方法
@Bean(name = "dataSource", initMethod = "init", destroyMethod = "close")
@Primary
public DataSource dataSource() {
DruidDataSource dataSource = new DruidDataSource();
dataSource.setUrl(url);
dataSource.setUsername(user);
dataSource.setPassword(password);
dataSource.setDriverClassName(driverName);
return dataSource;
}
? 方式二：实例化对象后调用
static {
DruidDataSource dataSource = new DruidDataSource();
dataSource.setUrl(url);
dataSource.setUsername(user);
dataSource.setPassword(password);
dataSource.setDriverClassName(driverName);
dataSource.init();
}
? 方式三：获取Connection对象
public DruidPooledConnection getConnection(long maxWaitMillis) throws SQLException {
init();
if (filters.size() > 0) {
FilterChainImpl filterChain = new FilterChainImpl(this);
return filterChain.dataSource_connect(this, maxWaitMillis);
} else {
return getConnectionDirect(maxWaitMillis);
}
}
2、初始化过程
2.1 Double Check
? 默认使用非公平锁，判断 inited 状态确保 DataSource 对象只会执行一次初始化的方法。
if (inited) {
return;
}
...
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
...
if (inited){
return;
}
...
inited = true;
lock.unlock();
2.2 参数配置
? jdbcUrl进行trim处理，获取数据库类型。
2.3 遍历Filter列表，执行init方法
? filters加载方式：
? 1、dataSource.setFilters(“”)； 可加载内置Filter(config,log4j) 还可配置完整类名通过反射实例化对象。
? 2、dataSource.setProxyFilters(); 自定义实例化Filter对象进行加载。
for (Filter filter : filters) {
filter.init(this);
}
2.4 参数校验
? maxActive、minIdle、timeBetweenLogStatsMillis、maxEvictableIdleTimeMillis、keepAlive 等。
2.5 SPI机制加载Filter
? 通过Java SPI的方式加载Filter，并使用@AutoLoad注解配置是否生效。
initFromSPIServiceLoader();
private void initFromSPIServiceLoader() {
...
List<Filter> filters = new ArrayList<Filter>();
//通过ServiceLoader加载所有的Filter
ServiceLoader<Filter> autoFilterLoader = ServiceLoader.load(Filter.class);
for (Filter filter : autoFilterLoader) {
AutoLoad autoLoad = filter.getClass().getAnnotation(AutoLoad.class);
//获取指定的注解对象判断是否启用，默认为true
if (autoLoad != null && autoLoad.value()) {
filters.add(filter);
}
}
autoFilters = filters;
for (Filter filter : autoFilters) {
//添加到filters集合并去重
addFilter(filter);
}
}
2.6 驱动处理
? 如果driver或者driverClass为空，则获取驱动名称。
protected void resolveDriver() throws SQLException {
if (this.driver == null) {
if (this.driverClass == null || this.driverClass.isEmpty()) {
//根据jdbcURL进行前缀匹配得到驱动名称
this.driverClass = JdbcUtils.getDriverClassName(this.jdbcUrl);
}
}
//对驱动进行加载
clazz = Class.forName(driverClassName);
...
}
2.7 数据源统计
? 可以支持connection、statement、result 相关的统计，分析SQL 的执行性能和数据库访问性能。
if (isUseGlobalDataSourceStat()) {
//使用全局的数据源统计
dataSourceStat = JdbcDataSourceStat.getGlobal();
if (dataSourceStat == null) {
dataSourceStat = new JdbcDataSourceStat("Global", "Global", this.dbTypeName);
JdbcDataSourceStat.setGlobal(dataSourceStat);
}
if (dataSourceStat.getDbType() == null) {
dataSourceStat.setDbType(this.dbTypeName);
}
} else {
//不使用全局数据源统计
dataSourceStat = new JdbcDataSourceStat(name, jdbcUrl, dbTypeName,connectProperties);
}
2.8 初始化连接池
? 创建初始连接数的数组，生成initialSize 个连接存放到connections中，如果初始化过程中不指定连接数，只有需要Connection的时候，才会去创建物理的连接就使用了懒加载的方式。
//存放正常的连接
connections = new DruidConnectionHolder[maxActive];
//存放需要抛弃的连接
evictConnections = new DruidConnectionHolder[maxActive];
//存放需要进行活性检测的连接
keepAliveConnections = new DruidConnectionHolder[maxActive];
if (createScheduler != null && asyncInit) {
for (int i = 0; i < initialSize; ++i) {
//异步方式创建连接
submitCreateTask(true);
}
} else if (!asyncInit) {
while (poolingCount < initialSize) {
try {
//创建物理的连接
PhysicalConnectionInfo pyConnectInfo = createPhysicalConnection();
//通过DruidConnectionHolder包装连接对象
DruidConnectionHolder holder = new DruidConnectionHolder(this, pyConnectInfo);
//存放到连接数组中
connections[poolingCount++] = holder;
} catch (SQLException ex) {
LOG.error("init datasource error, url: " + this.getUrl(), ex);
if (initExceptionThrow) {
connectError = ex;
break;
} else {
Thread.sleep(3000);
}
}
}
if (poolingCount > 0) {
poolingPeak = poolingCount;
poolingPeakTime = System.currentTimeMillis();
}
}
2.9 开启守护线程
//创建日志线程 timeBetweenLogStatsMillis 没有配置该线程不执行
createAndLogThread();
//用于创建连接的线程(如果连接数小于指定条件则创建新的连接并PUT进连接池)
createAndStartCreatorThread();
//用于释放连接的线程(连接数大于指定条件则释放对应的连接)
createAndStartDestroyThread();
