springboot多数据源配置-springboot项目实现多数据源路由实践

在项目中，有这么一些场景，需要去考虑数据源路由的事情，比如说

你看到了，以上不管是分库、分表、还是主从实现读写分离，都表现出了一个应用，对应多个数据库实例的场景。

那么这个时候，我们就需要去考虑多数据源路由的事情了。在具体实现方案上，有两种比较常见的选择方案

这两种方案，具体该如何去选择呢？如果我们是中小型的团队，应用规模也不是很大，那么适合选择在应用层面实现数据源路由的方案，主要理由

基于以上，反过来我们就可以考虑采用proxy的代理方案了。方便你理解，还是上一个图吧，典型的主从集群，读写分离架构

1.准备环境

通过以上描述，我们知道在实现多数据路由上，有两种可选的方案，本篇文章我们分享方案一的实现springboot多数据源配置，即扩展spring提供的AbstractRoutingDataSource。

首先来准备环境，我在本地准备了两个数据库实例

这两个库虽然本身没有直接的关系，我们假设这是一个报表类应用（聚合多个数据源），且我们的重点是实现在数据源之间的路由，因此不影响。

在本案例的实现中

导入依赖

<dependencies>        <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-web</artifactId>    </dependency>        <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-aop</artifactId>    </dependency>        <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-jdbc</artifactId>    </dependency>        <dependency>        <groupId>org.mybatis.spring.boot</groupId>        <artifactId>mybatis-spring-boot-starter</artifactId>        <version>1.3.2</version>    </dependency>        <dependency>        <groupId>com.alibaba</groupId>        <artifactId>druid</artifactId>        <version>1.0.9</version>    </dependency>        <dependency>        <groupId>mysql</groupId>        <artifactId>mysql-connector-java</artifactId>        <scope>runtime</scope>    </dependency>        <dependency>        <groupId>org.projectlombok</groupId>        <artifactId>lombok</artifactId>    </dependency></dependencies>

2.核心配置

本案例持久层，选择的是mybatis框架，相关核心配置如下

2.1.application.yml

server:  port: 8080spring:  application:    name: follow-me-springboot-multidatasource
#数据源配置mysql:  datasource:    type-aliases-package: cn.edu.anan.entity    mapper-locations: classpath:mybatis/mapper/*Mapper.xml    config-location: classpath:mybatis/sqlMapConfig.xml    write:      url: jdbc:mysql://127.0.0.1:3320/training?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC      username: root      password: admin      driver-class-name: com.mysql.cj.jdbc.Driver    read:      url: jdbc:mysql://127.0.0.1:3310/user-center?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC      username: root      password: admin      driver-class-name: com.mysql.cj.jdbc.Driver

2.2.sqlMapConfig.xml

<configuration>    <settings>                <setting name="cacheEnabled" value="true" />                <setting name="lazyLoadingEnabled" value="true" />                <setting name="aggressiveLazyLoading" value="true"/>                <setting name="multipleResultSetsEnabled" value="true" />                <setting name="useColumnLabel" value="true" />                <setting name="useGeneratedKeys" value="false" />                <setting name="autoMappingBehavior" value="PARTIAL" />                <setting name="defaultExecutorType" value="SIMPLE" />                <setting name="defaultStatementTimeout" value="25" />                <setting name="defaultFetchSize" value="100" />                <setting name="safeRowBoundsEnabled" value="false" />                <setting name="mapUnderscoreToCamelCase" value="true" />                <setting name="localCacheScope" value="SESSION" />                <setting name="jdbcTypeForNull" value="NULL" />                <setting name="lazyLoadTriggerMethods" value="equals,clone,hashCode,toString" />    </settings>
</configuration>

2.3.项目代码结构

3.核心代码

扩展AbstractRoutingDataSource实现多数据源之间路由，核心是

3.1.数据源配置DataSourceConfig

/** * 数据源配置 * * @author ThinkPad * @version 1.0 * @date 2021/9/21 15:55 */@Configuration@MapperScan(basePackages = "cn.edu.anan.dao", sqlSessionFactoryRef = "sqlSessionFactory")public class DataSourceConfig {
    /**     * 包扫描别名     */    @Value("${mysql.datasource.type-aliases-package}")    private String typeAliasesPackage;
    /**     *mapper映射文件位置     */    @Value("${mysql.datasource.mapper-locations}")    private String mapperLocation;
    /**     *mybatis配置文件位置     */    @Value("${mysql.datasource.config-location}")    private String configLocation;
    /**     * 写数据源     * @return     */    @Primary    @Bean    @ConfigurationProperties(prefix = "mysql.datasource.write")    public DataSource writeDataSource() {        return new DruidDataSource();    }
    /**     * 读数据源     * @return     */    @Bean    @ConfigurationProperties(prefix = "mysql.datasource.read")    public DataSource readDataSource() {        return new DruidDataSource();    }
    /**     * 配置sqlSessionFactory     * @return     * @throws Exception     */    @Bean    public SqlSessionFactory sqlSessionFactory() throws Exception {        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(routingDataSource());        bean.setTypeAliasesPackage(typeAliasesPackage);
        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();        bean.setMapperLocations(resolver.getResources(mapperLocation));        bean.setConfigLocation(resolver.getResource(configLocation));
        return bean.getObject();    }
    /**     * 设置数据源路由表     * @return     */    @Bean    public AbstractRoutingDataSource routingDataSource() {        MyAbstractRoutingDataSource proxy = new MyAbstractRoutingDataSource();        Map