SpringBoot中动态数据源配置与使用详解_Java

在现代应用中，处理多数据源是常见的需求。可能由于业务需要，或者为了实现读写分离，我们往往需要在同一个应用中配置多个数据源，并根据具体的操作选择不同的数据源。在 spring boot 中，这样的需求可以通过动态数据源来轻松实现。本篇博客将详细介绍如何在 spring boot 中配置和使用动态数据源，并演示如何切换到指定的数据源。

一、为什么要使用动态数据源？

业务隔离：在一些复杂的业务场景中，不同的模块可能需要连接不同的数据库。通过动态数据源配置，可以在同一个应用中隔离这些不同的数据库访问。
读写分离：为了提升系统的性能，通常会将读写操作分离到不同的数据库上。比如，将写操作放在主数据库，而读操作放在从数据库上。
数据库迁移：在系统迁移期间，可能需要在两个数据库之间切换，从而确保迁移的平稳进行。

二、spring boot 中的多数据源配置

我们将通过一个示例来介绍如何在 spring boot 中配置和使用动态数据源。假设我们有两个数据源，一个是 master，另一个是 adcontrol。master 数据源主要用于主业务数据库，而 adcontrol 数据源用于广告控制的相关数据存储。

1. 数据源配置

首先，我们需要在 application.yml 文件中配置两个数据源。

datasource:
  dynamic:
    primary: master # 默认使用master库
    strict: false   # 不使用严格模式
    datasource:
      master:
        url: jdbc:mysql://127.0.0.1:3306/test?servertimezone=asia/shanghai&characterencoding=utf8&usessl=false
        username: root
        password: 123456
        driver-class-name: com.mysql.cj.jdbc.driver
        hikari:
          connection-timeout: 30000
          max-lifetime: 1800000
          max-pool-size: 15
          min-idle: 5
          connection-test-query: select 1
          pool-name: ysxhikaricp
      adcontrol:
        url: jdbc:mysql://ip:3306/test2?servertimezone=asia/shanghai&characterencoding=utf8&usessl=false
        username: test
        password: test
        driver-class-name: com.mysql.cj.jdbc.driver

上述配置中，master 数据源是默认使用的数据源，而 adcontrol 数据源是备用的广告控制数据源。

2. 引入动态数据源依赖

为了让 spring boot 能够识别和使用这些动态数据源，我们需要引入动态数据源的依赖库。这里我们使用 dynamic-datasource-spring-boot-starter 这个开源库。

在 pom.xml 中添加如下依赖：

<dependency>
    <groupid>com.github.dynamic-datasource</groupid>
    <artifactid>dynamic-datasource-spring-boot-starter</artifactid>
    <version>3.2.1</version> <!-- 确保使用合适的版本 -->
</dependency>

3. 配置动态数据源

通过 dynamicdatasource，我们可以在应用中灵活切换数据源。下面是一个简单的 dynamicdatasource 配置示例：

import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
import com.github.dynamic.datasource.dynamicroutingdatasource;
import javax.sql.datasource;
import org.springframework.boot.autoconfigure.jdbc.datasourcebuilder;
import java.util.hashmap;
import java.util.map;

@configuration
public class datasourceconfig {

    @bean
    public datasource datasource() {
        dynamicroutingdatasource datasource = new dynamicroutingdatasource();

        // 配置主数据源
        datasource masterdatasource = datasourcebuilder.create()
                .url("jdbc:mysql://127.0.0.1:3306/test1?servertimezone=asia/shanghai&characterencoding=utf8&usessl=false")
                .username("root")
                .password("123456")
                .driverclassname("com.mysql.cj.jdbc.driver")
                .build();

        // 配置广告控制数据源
        datasource adcontroldatasource = datasourcebuilder.create()
                .url("jdbc:mysql://ip1:3306/test2?servertimezone=asia/shanghai&characterencoding=utf8&usessl=false")
                .username("test")
                .password("test")
                .driverclassname("com.mysql.cj.jdbc.driver")
                .build();

        // 将数据源放入map
        map<object, object> datasourcemap = new hashmap<>();
        datasourcemap.put("master", masterdatasource);
        datasourcemap.put("adcontrol", adcontroldatasource);

        datasource.setdefaulttargetdatasource(masterdatasource);
        datasource.settargetdatasources(datasourcemap);

        return datasource;
    }
}

4. 使用 @ds 注解动态切换数据源

在服务层，我们可以通过 @ds 注解来指定当前方法应该使用哪个数据源。例如：

import com.github.dynamic.datasource.annotation.ds;
import org.springframework.stereotype.service;

@service
public class myservice {

    @ds("adcontrol")
    public void handleadcontrollogic() {
        // 使用adcontrol数据源执行操作
    }

    @ds("master")
    public void handlemasterlogic() {
        // 使用master数据源执行操作
    }
}

通过 @ds 注解，我们可以在方法层面灵活切换数据源，确保不同的业务逻辑使用正确的数据库连接。

三、异常处理与回滚

在使用多个数据源时，处理好事务和异常非常重要。如果在一个事务内执行了多个数据源的操作，那么事务的管理和异常处理就变得尤为关键。

spring 提供了全局事务管理器的支持，可以配置为管理多个数据源的事务。但是在使用 dynamic-datasource 时，要特别注意确保在同一个事务中操作的多个数据源能够正确地提交或回滚。

例如：

import org.springframework.transaction.annotation.transactional;

@service
public class myservice {

    @transactional
    @ds("master")
    public void processtransaction() {
        try {
            // 操作master数据库
            handlemasterlogic();

            // 切换到adcontrol数据源
            handleadcontrollogic();

        } catch (exception e) {
            // 处理异常，可能需要回滚事务
            throw new runtimeexception("事务失败，进行回滚", e);
        }
    }

    @ds("adcontrol")
    public void handleadcontrollogic() {
        // 操作adcontrol数据库
    }

    @ds("master")
    public void handlemasterlogic() {
        // 操作master数据库
    }
}

在上面的代码中，如果 handleadcontrollogic 方法抛出了异常，那么整个事务将被回滚。