Druid源码学习02-初始化

​ 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);
        }
    }

​ 默认使用非公平锁，判断 inited 状态确保 DataSource 对象只会执行一次初始化的方法。

    if (inited) {
    	return;
    }
	...
    final ReentrantLock lock = this.lock;
    lock.lockInterruptibly();
    ...
    if (inited){
    	return;
    }
	...
	inited = true;
	lock.unlock();

​ jdbcUrl进行trim处理，获取数据库类型。

​ filters加载方式：
​ 1、dataSource.setFilters(“”)； 可加载内置Filter(config,log4j) 还可配置完整类名通过反射实例化对象。
​ 2、dataSource.setProxyFilters(); 自定义实例化Filter对象进行加载。

    for (Filter filter : filters) {
        filter.init(this);
    }

​ maxActive、minIdle、timeBetweenLogStatsMillis、maxEvictableIdleTimeMillis、keepAlive 等。

​ 通过Java SPI的方式加载Filter，并使用@AutoLoad注解配置是否生效。

	initFromSPIServiceLoader();

    private void initFromSPIServiceLoader() {
        ...
        List filters = new ArrayList();
        //通过ServiceLoader加载所有的Filter
        ServiceLoader 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);
        }
    }

​ 如果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); 
        ...
    }

​ 可以支持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);
     }

​ 创建初始连接数的数组，生成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();
        }
    }

	//创建日志线程 timeBetweenLogStatsMillis 没有配置该线程不执行
	createAndLogThread();
	//用于创建连接的线程(如果连接数小于指定条件则创建新的连接并PUT进连接池)
	createAndStartCreatorThread();
	//用于释放连接的线程(连接数大于指定条件则释放对应的连接)
	createAndStartDestroyThread();