转载

mybatis多数据源踩坑,数据库连接经常断开问题

最近某项目上出现一个奇怪的问题,就是数据库经常隔几小时就报连接已关闭

mybatis多数据源踩坑,数据库连接经常断开问题
mybatis多数据源踩坑,数据库连接经常断开问题

即使是加了如下配置也依然不行,网上也没找到什么文章解释这个坑

test-on-borrow: true
test-while-idle: true
validation-query: select 1 from dual
复制代码

关于上面配置为什么能解决连接中断可以看这三篇文章

  • 使用druid连接池带来的坑
  • 常用数据库validationQuery语句
  • 深入理解Spring Boot数据源与连接池原理

排查

网上查不到,那就只能自己推敲猜测了。因为是mybatis多数据源的配置,所以每个db我都有专门写一个config作为连接配置。

mybatis多数据源踩坑,数据库连接经常断开问题

看着DataSourceConfig的代码,我突然想到,会不会是因为我使用到是DataSource默认创建方法,所以并没有读取到我写在application.yml的配置:

@Bean(name = "db1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    @Primary
    public DataSource dbDataSource() {
        return DataSourceBuilder.create().build();
    }
复制代码

果断跟进build()方法

public DataSource build() {
		Class<? extends DataSource> type = getType();
		DataSource result = BeanUtils.instantiate(type);
		maybeGetDriverClassName();
		bind(result);
		return result;
	}
复制代码

打个断点可以看到此时返回的result的是一个全新的DataSource

mybatis多数据源踩坑,数据库连接经常断开问题

所以我们可以通过修改dbDataSource()方法,写入我们的配置参数:

@Value("${spring.datasource.db1.url}")
    private String url;
    @Value("${spring.datasource.db1.username}")
    private String username;
    @Value("${spring.datasource.db1.password}")
    private String password;
    @Value("${spring.datasource.db1.tomcat.test-on-borrow}")
    private boolean testOnBorrow;
    @Value("${spring.datasource.db1.tomcat.test-while-idle}")
    private boolean testWhileIdle;
    @Value("${spring.datasource.db1.tomcat.validation-query}")
    private String validationQuery;
    @Value("${spring.datasource.db1.tomcat.max-idle}")
    private int maxIdle;
    @Value("${spring.datasource.db1.tomcat.min-idle}")
    private int minIdle;
    @Value("${spring.datasource.db1.tomcat.initial-size}")
    private int initialSize;
    @Value("${spring.datasource.db1.tomcat.max-active}")
    private int maxActive;
    @Value("${spring.datasource.db1.tomcat.time-between-eviction-runs-millis}")
    private int timeBetweenEvictionRunsMillis;

    @Bean(name = "db1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    @Primary
    public DataSource dbDataSource() {
        org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
        dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        dataSource.setMaxActive(maxActive);
        dataSource.setMinIdle(minIdle);
        dataSource.setMaxIdle(maxIdle);
        dataSource.setTestOnBorrow(testOnBorrow);
        dataSource.setTestWhileIdle(testWhileIdle);
        dataSource.setValidationQuery(validationQuery);
        dataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        dataSource.setInitialSize(initialSize);
        return dataSource;
        //return DataSourceBuilder.create().build();
    }
复制代码

二次排查

通过上面方法确实可以解决问题了,但是我突然想到,默认创建的DataSource是没有url,username,password等必要的基础信息的。那这几个配置参数是为什么又可以写入进去呢?

这个时候我看到了我们dbDataSource方法上有一个 @Bean(name = "db1DataSource") ,于是大胆猜测我们这些配置参数的注入是第一次创建的时候通过Spring的IOC注入的。通过我的Debug发现事实也确实如此。

对DataBinder类的bind方法打断点,

public void bind(PropertyValues pvs) {
		MutablePropertyValues mpvs = (pvs instanceof MutablePropertyValues) ?
				(MutablePropertyValues) pvs : new MutablePropertyValues(pvs);
		doBind(mpvs);
	}
复制代码
mybatis多数据源踩坑,数据库连接经常断开问题

我们可以看到方法的调用路径

mybatis多数据源踩坑,数据库连接经常断开问题

看到了我们熟悉的refresh大法,这一部分Spring源码相关请看Spring源码分析

此时只剩最后一个疑惑了,我们的url,username,password等既然能通过IOC注入到DataSource里,那为什么其他的参数不可以呢?我随着DataSource类一路往上,找到他的父类接口PoolConfiguration,看到了所有的参数和getset方法。

mybatis多数据源踩坑,数据库连接经常断开问题

再看一眼我的application.yml配置文件里的参数

spring:
    datasource:
        db1:
            url: 
            username: 
            password: 
            driver-class-name: oracle.jdbc.driver.OracleDriver
            tomcat:
                max-wait: 10000
                max-active: 30
                test-on-borrow: true
                max-idle: 5
        db2:
            xxx
            ....
复制代码

终于找到这个坑了!

原来Spring data默认使用tomcat-jdbc的连接池的时候,配置的参数是

spring:
    datasource:
        url: 
        username: 
        password: 
        driver-class-name: oracle.jdbc.driver.OracleDriver
        tomcat:
            max-wait: 10000
            max-active: 30
            test-on-borrow: true
            max-idle: 5
复制代码

而当使用多数据源配置的时候,简单的以为只是复制过去即可,所以Spring IOC注入的时候,读的到的tomcat.max-wait并不能匹配到DataSource里的setMaxWait方法。自然就不起作用了。

所以这个问题只需要将配置文件改为如下即可

spring:
    datasource:
        db1:
            url: 
            username: 
            password: 
            driver-class-name: oracle.jdbc.driver.OracleDriver
            max-wait: 10000
            max-active: 30
            test-on-borrow: true
            test-while-idle: true
            validation-query: select 1 from dual
            max-idle: 5
        db2:
            xxx
            ....
复制代码

总结

这个问题从结果上来看,那真是简单的不行,但是从过程上来说,不仅让我又复习了一遍spring IOC的流程,也让我感觉到这种一步一步解剖问题,把多个知识点连接起来的成就感。如果之前没有学习spring的源码,我这次大概率也不会想到去看bean的注入吧

原文  https://juejin.im/post/5d673fbc5188256e8b5d0490
正文到此结束
Loading...