TransactionSynchronizationManager

时间: 2023-08-15 21:53:26 浏览: 79

SpringBoot多数据源配置（方式二：在代码中动态切换需要使用哪个数据源）.docx

在SpringBoot应用开发中，一般情况下，都是只会配置一个数据源信息，之后整个工程都是对当前数据源进行增删改查的操作。但是，在实际开发里面，也有可能会遇到多数据源的情况，例如：当前工程中除了需要访问自己应用的数据库，还需要直接连接第三方系统的数据库进行业务处理，这种情况下，就需要进行多数据源的配置。SpringBoot考虑到了这一点，所以它是支持多数据源的配置的，下面介绍一下如何配置多数据源，并且在代码中动态切换使用的数据源。 ### Spring Boot多数据源配置详解 #### 一、多数据源背景及应用场景在实际的Spring Boot项目开发过程中，通常我们会为项目配置一个主要的数据源，以便于项目的正常运行与数据库交互。但在某些复杂的业务场景下，比如需要同时操作两个或多个数据库（如本地数据库与第三方系统的数据库），这时候就需要对Spring Boot进行多数据源配置。这种方式不仅能够满足业务需求，还能够在一定程度上提升应用程序的灵活性和扩展性。 #### 二、多数据源配置原理在Spring Boot框架中，多数据源的实现主要是通过`DataSource`接口的实现来完成的。Spring Boot支持多种数据源实现类，如HikariCP、Druid等。为了实现动态切换数据源，我们可以通过配置多个数据源，并在代码层面实现数据源的动态切换，从而达到在不同的业务场景中使用不同的数据库的目的。 #### 三、多数据源配置步骤 ##### 1. 搭建基础工程我们需要创建一个基本的Spring Boot工程，并添加必要的Maven依赖。在本例中，我们已经引入了如下依赖： - `spring-boot-starter-parent`: Spring Boot的基础启动器。 - `spring-boot-starter-web`: 提供Web应用的支持。 - `mybatis-plus-boot-starter`: MyBatis Plus的Spring Boot启动器。 - `druid-spring-boot-starter`: Druid连接池的Spring Boot启动器。 - `mysql-connector-j`: MySQL数据库的JDBC驱动。 - `lombok`: 自动生成getter、setter等方法的工具库。这些依赖为后续的多数据源配置打下了坚实的基础。 ##### 2. 配置多数据源接下来是在`application.properties`或`application.yml`文件中配置多数据源的信息，包括不同数据源的URL、用户名、密码等： ```yaml # 主数据源配置 spring.datasource.druid0.username=root spring.datasource.druid0.password=root spring.datasource.druid0.url=jdbc:mysql://localhost:3306/db0 spring.datasource.druid0.driver-class-name=com.mysql.cj.jdbc.Driver # 第二个数据源配置 spring.datasource.druid1.username=root spring.datasource.druid1.password=root spring.datasource.druid1.url=jdbc:mysql://localhost:3306/db1 spring.datasource.druid1.driver-class-name=com.mysql.cj.jdbc.Driver ``` 这里我们配置了两个数据源，分别命名为`druid0`和`druid1`。 ##### 3. 实现数据源的动态切换为了实现在代码中动态切换数据源，我们可以使用Spring AOP（面向切面编程）的方式，在需要动态切换数据源的方法上添加注解，通过AOP拦截器来实现数据源的动态切换。具体的实现步骤如下： - 创建一个`DataSourceSelector`接口，定义数据源选择逻辑。 - 创建一个具体的实现类，根据传入的参数决定使用哪个数据源。 - 使用Spring AOP，在需要切换数据源的方法上添加自定义注解。示例代码如下： ```java // 数据源选择接口 public interface DataSourceSelector { String SELECT_DATA_SOURCE = "dataSource"; DataSource determineDataSource(); } // 具体实现类 public class DynamicDataSourceSelector implements DataSourceSelector { @Override public DataSource determineDataSource() { String dataSourceName = (String) TransactionSynchronizationManager.getAttribute(SELECT_DATA_SOURCE); return (dataSourceName != null ? dataSourceMap.get(dataSourceName) : defaultDataSource); } } // AOP拦截器 @Aspect @Component public class DataSourceInterceptor extends AbstractDataSourceRoutingInterceptor { @Autowired private DataSourceSelector dataSourceSelector; @Override protected Object determineCurrentLookupKey() { return TransactionSynchronizationManager.getAttribute(DataSourceSelector.SELECT_DATA_SOURCE); } } ``` 此外，还需要定义一个注解，用于标记需要动态切换数据源的方法： ```java @Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface DataSourceSwitch { String value(); } ``` 在需要切换数据源的方法上添加注解： ```java @DataSourceSwitch("druid1") public void switchDataSource() { // 这里将使用druid1数据源 } ``` 通过以上步骤，我们就完成了Spring Boot多数据源的配置以及在代码中动态切换数据源的功能。 #### 四、总结本文详细介绍了在Spring Boot应用中如何进行多数据源的配置，并通过代码实现了数据源的动态切换。这种方式不仅可以提高项目的灵活性，还能更好地应对复杂的应用场景。希望本文能帮助开发者们更好地理解和掌握Spring Boot多数据源配置的相关知识。

TransactionSynchronizationManager是Spring框架中的一个事务同步管理器，用于管理事务同步器。事务同步器是在事务进行过程中，被注册到TransactionSynchronizationManager中的一组回调方法。这些回调方法包括了在不同的事务阶段进行的一些操作，例如在事务提交完成后执行的一些清理工作等。TransactionSynchronizationManager会在事务执行过程中，按照一定的规则，依次执行事务同步器中的回调方法，来完成事务的一些后续操作。这个机制可以确保在事务执行过程中，所有相关的资源都能够得到正确的处理和释放，从而避免了出现资源泄露等问题。

阅读全文

TransactionSynchronizationManager

相关推荐

读写分离设计文档1

javaweb 通过threadlocal 手动提交事务

transactionsynchronizationmanager

TransactionSynchronizationManager.registerSynchronization

transactionsynchronizationmanager.registersynchronization

TransactionSynchronizationManager.getResource

TransactionSynchronizationManager.isSynchronizationActive()

TransactionSynchronizationManager.registerSynchronization抛异常

TransactionSynchronizationManager.setCurrentTransactionReadOnly()用法

java中TransactionSynchronizationManager.registerSynchronization的用法

java中TransactionSynchronizationManager.registerSynchronization()作用

TransactionSynchronizationManager.registerSynchronization() 效率高吗

TransactionSynchronizationManager 中没有getCurrentTransactionSynchronization()这个方法

使用TransactionSynchronizationManager.clearSynchronization后，提示事务已被关闭

TransactionSynchronizationManager.registerSynchronization方法嵌套后嵌套的逻辑没有执行

解释下这个方法的用法 TransactionSynchronizationManager.registerSynchronization();

TransactionSynchronizationManager.registerSynchronization中afterCommit中一个a方法发生异常，外层代码没回滚

一次请求，多次注册TransactionSynchronizationManager.registerSynchronization，但第二次不生效问题

使用TransactionSynchronizationManager.registerSynchronization的afterCommit下游抛异常导致上游事务提交后会影响处理结果怎么办

最新推荐

前端协作项目：发布猜图游戏功能与待修复事项

管理建模和仿真的文件

【高斯信道信号编码优化】：4大方法优化Chirp信号编码过程

对给定图，实现图的深度优先遍历和广度优先遍历。以邻接表或邻接矩阵为存储结构，实现连通无向图的深度优先和广度优先遍历。以用户指定的结点为起点，分别输出每种遍历下的结点访问序列，并调试算法。使用C语言

Spring框架REST服务开发实践指南

"互动学习：行动中的多样性与论文攻读经历"

【Chirp信号检测算法精解】：掌握高效检测Chirp信号的5大关键步骤

如何修改此代码使其支持模糊匹配？

ALU课设实现基础与高级运算功能

关系数据表示学习