如何处理spring事务与多数据源冲突问题?

Spring 像插线板一样,mybatis 框架是插头,可以容易的组合到一起。插线板 spring 插 上 mybatis,两个框架就是一个整体。

2.适合大型项目,有很多的类,方法,需要大量的配置事务,使用aspectj框架功能,在spring配置文件中
声明类,方法需要的事务。这种方式业务方法和事务配置完全分离。

实现步骤: 都是在xml配置文件中实现。

1)要使用的是aspectj框架,需要加入依赖

2)声明事务管理器对象

  1. 声明方法需要的事务类型(配置方法的事务属性【隔离级别,传播行为,超时】)

  2. 配置aop:指定哪些哪类要创建代理。

1.做的是javase项目有main方法的,执行代码是执行main方法的,在main里面创建的容器对象

2.web项目是在tomcat服务器上运行的。 tomcat一起动,项目一直运行的。

web项目中容器对象只需要创建一次, 把容器对象放入到全局作用域ServletContext中。

使用监听器 当全局作用域对象被创建时 创建容器 存入ServletContext

监听器可以自己创建,也可以使用框架中提供好的ContextLoaderListener

一个项目中使用多个数据源的需求,我们在日常工作中时常会遇到。

以商城系统为例,有一个 MySQL 的数据库负责存储交易数据。公司还有一套 ERP 企业信息化管理系统,要求订单信息同步录入 ERP 数据库,便于公司统一管理,而该 ERP 系统采用的数据库为 SQL Server 。

此时,就可以在 Spring Boot 项目中配置多个数据源。另外,使用多数据源后,需要采用分布式事务来保持数据的完整性。

本小节我们使用 Spring Boot 开发一个商城系统的订单生成功能,订单信息同时进入 MySQL 与 SQL Server 数据库。

首先创建 MySQL 数据库 shop ,并新建订单表 order ,表结构如下:

然后创建 SQL Server 数据库 erpshop ,并新建订单表 erp_order ,表结构如下。注意 id 是自增长的唯一标识,out_id 是对应订单在 MySQL 数据库中的唯一标识,以便在两个库中比对订单。

接下来,我们开始实现 Spring Boot 后端项目,数据持久层采用 MyBatis 框架,同时访问两个数据源。

我们引入热部署依赖、 Web 依赖、数据库访问相关依赖及测试相关依赖,具体如下:

由于我们要同时访问两个数据库,所以需要在配置文件中添加两个数据源的配置信息。注意配置多数据源时, url 配置需要使用 spring.datasource.db1.jdbc-url=xxx 的形式。


4.4 注册数据源组件

多个数据源的情况下, 我们需要通过配置类,将数据源注册为组件放入 Spring 容器中。


 
 


classpath:mapper1/ 目录去寻找。这样数据源 – DAO 数据访问接口 – 映射文件三者的对应关系就建立起来了。


4.6 数据访问接口实现



这两个接口中使用的数据对象比较简单,代码如下:


 
 
 
 
 
 
 
 
 

数据操作接口与对应的映射文件均已编写完毕,现在可以通过测试类进行多数据源测试了,我们在测试类中同时向两个库插入记录。


 
 
 

运行测试方法后,两个数据库表中均新增数据成功,这样我们就成功的使用 Spring Boot 同时操作了两个数据源。

采用多数据源之后,事务的实现方式也随之发生变化。当某个数据源操作出现异常时,该数据源和其他数据源的事务都需要回滚。这种涉及多个数据源的事务,称为分布式事务,接来下我们就来具体实现一下。

5.1 引入分布式事务依赖

在 pom.xml 引入 Atomikos 事务管理器相关的依赖项, Atomikos 是一个开源的事务管理器,支持分布式事务。

 

5.2 更换数据源组件


 
 
 
 

5.3 添加分布式事务管理器组件

继续修改 DataSourceConfig 类,在其中配置分布式事务管理器组件。当项目中使用事务时,会通过配置的分布式事务管理器管理分布式事务操作。

 

5.4 测试分布式事务

在测试方法上添加 @Transactional 开启事务,然后在两个数据源操作中间模拟抛出异常。

 
 
 
 

此时运行测试类,可以发现数据源 1 的事务已回滚,验证成功!

在开发 Spring Boot 项目时,如果默认配置满足不了我们的需求,可以通过手工配置组件实现我们需要的功能。这些组件可能是各个公司提供的,我们根据相应文档,为其配置各个属性即可。

  • 配置多个数据源时,通过配置类,逐一配置数据源组件及其参数。
  • 配置 MyBatis 时,手工配置 MyBatis 相关组件,并指定相应扫描的 DAO 类及映射文件。
  • 使用分布式事务时,使用支持分布式事务的数据源组件,并配置分布式事务管理器。

最近在做毕业设计,其中涉及到一些知识图谱的内容,打算用Neo4j来存储知识图谱内容,与知识图谱无关的数据打算使用MySQL存储,为了后需方便开发,在一开始创建项目的时候就把依赖全部添加进来了,配置文件也都写好了。

就在系统的基本功能快完成的时候,打算测试一下对于MySQL操作的部分有没有bug,一番折腾下来,发现SpringBoot的事务没有生效,百度+Google找了一堆解决方法,都不起作用,于是拿出大杀器——单步调试,看看到底是执行到哪里出了问题。最终执行到下面图片上这行代码,恍然大悟。

没有走MySQL的事务,走的是Neo4j的事务,那MySQL里的数据肯定不会回滚。说白了就是SpringBoot的事务还不够智能,没法识别多个数据源。

问题找到了,那就好解决了,但万万没想到网上能搜到的MySQL+Neo4j多数据源事务有关的内容很旧,现在Spring Data Neo4j早就更新了,里面的API变化了很多,所以只能去查看官方文档,找找事务相关的内容。虽然网上现有的示例代码不能用,但其解决方案的思路还是可以用的,最后这个问题终于是解决了,下面记录一下解决方法。

思路很简单,自定义一个事务管理器,然后在里面维护多个数据源的事务就好了。下面以我目前的环境为例用代码实现,其他多数据源情况大同小异。

这样只要在需要开启事务的方法上添加相应的注解,就可以确保发生异常时回滚了。比如:

我要回帖

更多关于 springboot多数据源事务 的文章

 

随机推荐