原创文章,转载请注明出处。
简单总结DruidDataSource初始化过程
- 读取配置文件,创建并配置DruidDataSource
- 注册数据库驱动DruidDriver
- 开始初始化,加锁
- 同步或者异步初始化DruidDataSource,主要是创建initialSize个连接放入空闲连接池
- 创建、运行连接池状态统计日志线程、连接创建线程、连接销毁线程
- 初始化完毕,释放锁
核心流程其实很简单,主要的复杂逻辑集中在线程之间的交互上。如果看过MyBatis的简单连接池实现的话,可以说Druid的核心实现就是在MyBatis基础上增加了独立的创建、销毁连接线程,增加了日志和监控,使这个初始化过程变得复杂了。
DruidDataSource初始化准备工作--before init()
- 读取、解析配置文件,封装为Map
- 使用工厂方法DruidDataSourceFactory.createDataSource(Map properties)创建一个DruidDataSource。
- 初始化非公平ReentrantLock,和生产者、消费者监视器
- 使用传入的map来配置DruidDataSource
- DruidDataSource对象的初始化。有两个地方可以触发初始化动作:
- 可以在配置中指定 init=true,会在set配置值时调用dataSource.init(),完成初始化。
- 在调用dataSource.getConnection(long maxWaitMillis)时,会调用dataSource.init(),完成初始化。
DruidDataSource初始化开始--do init()
- 禁止重复初始化
- 注册数据库驱动DruidDriver
- lock.lockInterruptibly();
- 分配唯一dataSourceId
- 如果有过滤器Filter,使用过滤器链包装dataSource
- SPI加载扩展服务
- 初始化空闲连接池、待删除连接池、保活连接池
- 判断走异步初始化、还是同步初始化,一般为同步初始化
- 根据配置的initialSize数量,创建数据库连接代理,放入空闲连接池
- 启动连接池状态统计日志线程、连接创建线程、连接销毁线程
- 主线程阻塞在CountDownLatch(2),等待连接创建线程、连接销毁线程运行起来。
- 向JMX注册线程池监控MBean
- 如果配置了保活keepAlive,唤醒生产者线程,生产连接,达到配置的minIdle数量
- 标记DataSource初始化完成
- lock.unlock()
理解
- 加锁的主要作用
- 保证线程池初始化、运行顺序的正确性。保证一定要在DataSource初始化完成以后,连接的创建、销毁线程才有可能持有锁,开始生产和销毁连接。
- 要操作共享变量,空闲连接池数组DruidConnectionHolder[] connections。填充连接,满足配置的initialSize数量。
- 代理
- Druid的代理基本都是静态代理模式