1 DruidDataSource类图
DruidDataSource为整个链接池的基础入口，实现了JDBC的Datasource
类图.png
2 初始化-构造函数
public DruidDataSource(){
this(false);
}
public DruidDataSource(boolean fairLock){
super(fairLock);
configFromPropety(System.getProperties());
}
参数用来控制锁的公平性，默认false非公平
configFromPropety 方法从配置中，初始化各种配置属性，属性及其多，浏览一下即可
看一下super的构造函数，定义了锁的状态
public DruidAbstractDataSource(boolean lockFair){
lock = new ReentrantLock(lockFair);
notEmpty = lock.newCondition();
empty = lock.newCondition();
}
然后调用init()方法初始化
init又非常得长，主要做了如下几件事情：
- 获取锁（可中断） lock.lockInterruptibly();
- 生成dataSource的ID DruidDriver.createDataSourceId()
- 校验配置参数的合法性
- 通过SPI加载Filter initFromSPIServiceLoader()
- 根据配置加载JDBC驱动 resolveDriver(); initCheck();
- 创建连接Holder的数组
connections = new DruidConnectionHolder[maxActive];
evictConnections = new DruidConnectionHolder[maxActive];
keepAliveConnections = new DruidConnectionHolder[maxActive];
- 根据设置，同步或者异步创建连接PhysicalConnectionInfo，放到之前的Holder数组connections 中
- 创建线程池，日志，创建者和销毁者
- 创建线程池有一个CountDownLatch，异步创建完成后，初始化就结束了
- 后续还有一些异常处理，日志等等
3 获取连接
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);
}
}
主要链路
getConnectionDirect(maxWaitMillis)->
getConnectionInternal(maxWaitMillis)->
createPhysicalConnection()->
DruidConnectionHolder ->pollLast()
失败重新创建一个->new DruidConnectionHolder(this, pyConnInfo);
最后返回通过Holder获取的connection new DruidPooledConnection(holder);
其他
生成DataSourceId的时候，用了几个原子类来记录偏移量，后续看到再标注
long delta = (this.id - 1) * 100000;
this.connectionIdSeedUpdater.addAndGet(this, delta);
this.statementIdSeedUpdater.addAndGet(this, delta);
this.resultSetIdSeedUpdater.addAndGet(this, delta);
this.transactionIdSeedUpdater.addAndGet(this, delta);
看源码的方法，可以从Test单元测试类开始
DruidDataSourceTest 初始化到关闭的流程走了一遍
